mark the inner loop

hopper.go

@@ -234,22 +234,23 @@ func (l *Listener) switcher() {
 			return
 		}
 
+	RESULTS_LOOP:
 		for _, res := range results {
 			switch res.Operation {
 			case gaio.OpWrite:
 				// done writting to proxy connection.
 				if res.Error != nil {
 					l.logger.Printf("[switcher]gaio.OpWrite: %v, %v, %v, %v", res.Error, res.Conn.RemoteAddr(), res.Conn.LocalAddr(), res.Context)
 					l.removeClient(res.Conn.RemoteAddr())
-					continue
+					continue RESULTS_LOOP
 				}
 
 			case gaio.OpRead:
 				// any read error from the proxy connection cleans the other side(client).
 				if res.Error != nil {
 					l.logger.Printf("[switcher]gaio.OpRead: %v, %v, %v, %v", res.Error, res.Conn.RemoteAddr(), res.Conn.LocalAddr(), res.Context)
 					l.removeClient(res.Conn.RemoteAddr())
-					continue
+					continue RESULTS_LOOP
 				}
 
 				// received data from the proxy connection.
@@ -259,15 +260,15 @@ func (l *Listener) switcher() {
 				dataFromProxy, err := decryptPacket(l.crypterOut, dataFromProxy)
 				if err != nil {
 					l.logger.Println("[switcher]decryptPacket:", err)
-					continue
+					continue RESULTS_LOOP
 				}
 
 				// onNextHopIn callback
 				if l.onNextHopIn != nil {
 					dataFromProxy = l.onNextHopIn(res.Conn.RemoteAddr(), res.Context.(net.Addr), dataFromProxy)
 					// blackhole the packet if the callback returns nil.
 					if dataFromProxy == nil {
-						continue
+						continue RESULTS_LOOP
 					}
 				}