HevSocks5TProxy: Supports standard and pipeline socks5 handshakes.

Author: heiher

README.md

@@ -67,6 +67,8 @@ socks5:
   address: 127.0.0.1
   # Socks5 UDP relay mode (tcp|udp)
   udp: 'udp'
+  # Socks5 handshake using pipeline mode
+# pipeline: false
   # Socks5 server username
   username: 'username'
   # Socks5 server password

conf/main.yml

@@ -7,6 +7,8 @@ socks5:
   address: 127.0.0.1
   # Socks5 UDP relay mode (tcp|udp)
   udp: 'udp'
+  # Socks5 handshake using pipeline mode
+# pipeline: false
   # Socks5 server username
   username: 'username'
   # Socks5 server password

src/hev-config.c

@@ -44,6 +44,7 @@ hev_config_parse_server (yaml_document_t *doc, yaml_node_t *base,
     const char *user = NULL;
     const char *pass = NULL;
     const char *mark = NULL;
+    const char *pipe = NULL;
 
     if (!base || YAML_MAPPING_NODE != base->type || !srv)
         return -1;
@@ -72,6 +73,8 @@ hev_config_parse_server (yaml_document_t *doc, yaml_node_t *base,
             addr = value;
         else if (0 == strcmp (key, "udp"))
             udpm = value;
+        else if (0 == strcmp (key, "pipeline"))
+            pipe = value;
         else if (0 == strcmp (key, "username"))
             user = value;
         else if (0 == strcmp (key, "password"))
@@ -98,6 +101,9 @@ hev_config_parse_server (yaml_document_t *doc, yaml_node_t *base,
     strncpy (srv->addr, addr, 256 - 1);
     srv->port = strtoul (port, NULL, 10);
 
+    if (pipe && (strcasecmp (pipe, "true") == 0))
+        srv->pipeline = 1;
+
     if (udpm && (strcasecmp (udpm, "udp") == 0))
         srv->udp_in_udp = 1;
 

src/hev-config.h

@@ -19,6 +19,7 @@ struct _HevConfigServer
     unsigned int mark;
     short udp_in_udp;
     unsigned short port;
+    unsigned char pipeline;
     char addr[256];
 };
 

src/hev-socks5-session.c

@@ -48,7 +48,7 @@ hev_socks5_session_run (HevTProxySession *base)
         LOG_D ("%p socks5 client auth %s:%s", base, srv->user, srv->pass);
     }
 
-    res = hev_socks5_client_handshake (HEV_SOCKS5_CLIENT (base));
+    res = hev_socks5_client_handshake (HEV_SOCKS5_CLIENT (base), srv->pipeline);
     if (res < 0) {
         LOG_E ("%p socks5 session handshake", base);
         return;