From 00ae06df1cd59b0f015e4ec0b64f19ab9e270105 Mon Sep 17 00:00:00 2001 From: zhouhui8915 Date: Mon, 7 Sep 2015 17:30:25 +0800 Subject: [PATCH] TODO add namespace add buglist --- TODO | 2 +- buglist | 2 ++ client_conn.go | 38 +++++++++++++++++++------------------- 3 files changed, 22 insertions(+), 20 deletions(-) create mode 100644 buglist diff --git a/TODO b/TODO index 1a3830f..9f1dc80 100644 --- a/TODO +++ b/TODO @@ -1,3 +1,3 @@ 1.long polling 2.connect timeout -3. \ No newline at end of file +3.namespace \ No newline at end of file diff --git a/buglist b/buglist new file mode 100644 index 0000000..75981c9 --- /dev/null +++ b/buglist @@ -0,0 +1,2 @@ +1、没有实现异步连接,onconnect未起作用 +2、 \ No newline at end of file diff --git a/client_conn.go b/client_conn.go index c0f156d..0f06985 100644 --- a/client_conn.go +++ b/client_conn.go @@ -293,28 +293,28 @@ func (c *clientConn) onOpen() error { c.pingTimeout = msg.PingTimeout c.id = msg.Sid - /* - q.Set("sid", c.id) - c.request.URL.RawQuery = q.Encode() + c.getCurrent().Close() - transport, err = creater.Client(c.request) - if err != nil { - return err - } - c.setCurrent("polling", transport) + q.Set("sid", c.id) + c.request.URL.RawQuery = q.Encode() - pack, err = c.getCurrent().NextReader() - if err != nil { - return err - } + transport, err = creater.Client(c.request) + if err != nil { + return err + } + c.setCurrent("polling", transport) - p2 := make([]byte, 4096) - l, err = pack.Read(p2) - if err != nil { - return err - } - //fmt.Println(string(p2)) - */ + pack, err = c.getCurrent().NextReader() + if err != nil { + return err + } + + p2 := make([]byte, 4096) + l, err = pack.Read(p2) + if err != nil { + return err + } + //fmt.Println(string(p2)) //upgrade creater, exists = creaters["websocket"]