http connection

server/proxy/http.go

@@ -158,10 +158,10 @@ func (s *httpServer) httpHandle(c *conn.Conn, r *http.Request) {
 				defer connClient.Close()
 				defer c.Close()
 				for {
-					r := <-reqCh
 					if resp, err := http.ReadResponse(bufio.NewReader(connClient), r); err != nil {
 						return
 					} else {
+						r := <-reqCh
 						//if the cache is start and the response is in the extension,store the response to the cache list
 						if s.useCache && strings.Contains(r.URL.Path, ".") {
 							b, err := httputil.DumpResponse(resp, true)

server/proxy/p2p.go

@@ -65,7 +65,6 @@ func (s *P2PServer) p2pProcess(c *conn.Conn) {
 	logs.Trace("new p2p connection ,role %s , password %s, nat type %s ,local address %s", f, string(b), strconv.Itoa(int(natType)), c.RemoteAddr().String())
 	//存储
 	if f == common.WORK_P2P_VISITOR {
-		logs.Warn("try visitor")
 		v.visitorAddr = c.Conn.RemoteAddr().String()
 		v.visitorNatType = natType
 		v.visitor = c