testing

protocol/common.go

@@ -110,6 +110,7 @@ func forward(in net.Conn, out transport.Transport) {
 		b1.Write(buf[:n])
 		out.WritePacket(createPacket(PKT_TYPE_DATA, b1.Bytes()))
 		b1.Reset()
+		log.Printf("Forward data")
 	}
 }
 
@@ -123,5 +124,6 @@ func receive(data []byte, out net.Conn) {
 	binary.Read(buf, binary.LittleEndian, &pkt)
 
 	out.Write(pkt)
+	log.Printf("Received data")
 }
 

protocol/server.go

@@ -66,6 +66,7 @@ func (s *Server) Process(ctx context.Context) error {
 			return err
 		}
 
+		log.Printf("%x", pkt)
 		switch pt {
 		case PKT_TYPE_HANDSHAKE_REQUEST:
 			log.Printf("Client handshakeRequest from %s", common.GetClientIp(ctx))
@@ -141,6 +142,7 @@ func (s *Server) Process(ctx context.Context) error {
 			go forward(s.Remote, s.Session.TransportOut)
 			s.State = SERVER_STATE_CHANNEL_CREATE
 		case PKT_TYPE_DATA:
+			log.Printf("Data received")
 			if s.State < SERVER_STATE_CHANNEL_CREATE {
 				log.Printf("Data received while in wrong state %d != %d", s.State, SERVER_STATE_CHANNEL_CREATE)
 				return errors.New("wrong state")