开通博客赚积分
发布资源赚积分
分类

源码开发语言/平台
当前位置：首页 > 源码/资料 > Internet/网络编程 > 代理服务器 > 查看源码
protocol.c
资源名称：socks5.zip　[点击查看]
上传用户：sddyfurun
上传日期：2007-01-04
资源大小：525k
文件大小：17k
源码类别：

代理服务器

开发平台：

Unix_Linux

protocol.c：源码内容
  1. /* Copyright (c) 1995,1996,1997 NEC Corporation.  All rights reserved.       */
  2. /*                                                                           */
  3. /* The redistribution, use and modification in source or binary forms of     */
  4. /* this software is subject to the conditions set forth in the copyright     */
  5. /* document ("Copyright") included with this distribution.                   */
  7. /*
  8.  * $Id: protocol.c,v 1.82.4.5 1998/11/11 22:55:45 wlu Exp $
  9.  */
  11. #include "socks5p.h"
  12. #include "buffer.h"
  13. #include "addr.h"
  14. #include "protocol.h"
  15. #include "hostname.h"
  16. #include "msg.h"
  17. #include "null.h"
  18. #include "upwd.h"
  19. #include "gss.h"
  20. #include "log.h"
  23. #ifndef PROTO_EXCHANGE_TIMEOUT
  24. #define PROTO_EXCHANGE_TIMEOUT 15
  25. #endif
  27. #ifndef PROTO_RECVRESP_TIMEOUT
  28. #define PROTO_RECVRESP_TIMEOUT 75
  29. #endif
  31. #ifndef PROTO_SENDRESP_TIMEOUT
  32. #define PROTO_SENDRESP_TIMEOUT 10
  33. #endif
  35. #define PROTO_IOFLAGS S5_IOFLAGS_RESTART|S5_IOFLAGS_TIMED|S5_IOFLAGS_NBYTES
  37. #define RSPSIZE4       8
  38. #define ADDRLEN(x)     (HOSTLEN((x)) + PORTLEN((x)))
  39. #define HDRSIZE4(x)    (int)(RSPSIZE4 + strlen((x)+RSPSIZE4) + 1)
  41. int LIBPREFIX2(init)(const char *name) {
  42.     static int done = 0;
  44.     if (done) return 0;
  46.     done = 1;
  48.     if (S5LogDefaultHandle == NULL) {
  49.      S5LogStart(&S5LogDefaultHandle, -1, -1, "libsocks5");
  50.      S5LogUpdate(S5LogDefaultHandle, S5_LOG_DEBUG(0), 0, "NEC NWSL %s library", SOCKS5_VERSION_NAME);
  51.     }
  53.     
  54.     return 0;
  55. }
  57. char *lsEffUser() {
  58.     static char EffUser[S5_USERNAME_SIZE];
  59.     static int done = 0;
  60.     struct passwd *pw;
  62.     if (done) {
  63. S5LogUpdate(S5LogDefaultHandle, S5_LOG_DEBUG(10), 0, "GetUserName: name was cached...");
  64.     } else {
  65. char *name;
  66. done = 1;
  68. if ((name = getlogin()) != NULL) {
  69.     S5LogUpdate(S5LogDefaultHandle, S5_LOG_DEBUG(10), 0, "GetUserName: got name from getlogin...");
  70.     strncpy(EffUser, name, MIN(strlen(name), S5_USERNAME_SIZE));
  71.     EffUser[MIN(strlen(name), S5_USERNAME_SIZE)] = '';
  72.     return EffUser;
  73. }
  75. if ((pw = getpwuid(geteuid())) != NULL) {
  76.     S5LogUpdate(S5LogDefaultHandle, S5_LOG_DEBUG(10), 0, "GetUserName: got name from getpwuid...");
  77.     strncpy(EffUser, pw->pw_name, MIN(strlen(pw->pw_name), S5_USERNAME_SIZE));
  78.     EffUser[MIN(strlen(pw->pw_name), S5_USERNAME_SIZE)] = '';
  79.     return EffUser;
  80. }
  82. S5LogUpdate(S5LogDefaultHandle, S5_LOG_WARNING, 0, "GetUserName: couldn't get a name for the current user (uid: %d)", geteuid());
  83. strcpy(EffUser, "Unknown");
  84.     }
  86.     return EffUser;
  87. }
  89. int lsGetProtoAddrLenFromAddr(u_char version, const S5NetAddr *na) {
  90.     switch (na->sa.sa_family) {
  91. case AF_INET:
  92.     return IPV4HDRSIZE;
  93. case AF_S5NAME:
  94.     if (version != SOCKS5_VERSION) return -1;
  95.     return NAMEHDRSIZE(na->sn.sn_name);
  96. #ifdef HAVE_NETINET6_IN6_H
  97. case AF_INET6:
  98.     if (version != SOCKS5_VERSION) return -1;
  99.     return IPV6HDRSIZE;
  100. #endif
  101. default:
  102.     return -1;
  103.     }
  104. }
  106. int lsGetProtoAddrLenFromBuf(u_char version, const char *buf) {
  107.     switch (version) {
  108. case SOCKS4_VERSION:
  109.     return sizeof(u_short) + sizeof(struct in_addr);
  110. case SOCKS5_VERSION:
  111.     break;
  112. default:
  113.     return -1;
  114.     }
  116.     switch (buf[RP_FLAGS]) {
  117. case SOCKS5_IPV4ADDR:
  118.     return sizeof(u_short) + sizeof(struct in_addr);
  119. case SOCKS5_HOSTNAME:
  120.     return sizeof(u_short) + (u_char)buf[RP_HOSTOFF] + 1;
  121. #ifdef HAVE_NETINET6_IN6_H
  122. case SOCKS5_IPV6ADDR:
  123.     return sizeof(u_short) + sizeof(struct in_addr6);
  124. #endif
  125. default:
  126.     return -1;
  127.     }
  128. }
  130. int lsGetProtoAddr(u_char version, const char *buf, S5NetAddr *result) {
  131.     if (version == SOCKS4_VERSION) {
  132. memset(&result->sin, 0, sizeof(ssi));
  133. result->sin.sin_family = AF_INET;
  134. memcpy(&result->sin.sin_addr, buf+SP_HOSTOFF, sizeof(struct in_addr));
  135. memcpy(&result->sin.sin_port, buf+SP_PORTOFF, sizeof(u_short));
  136. return 0;
  137.     }
  139.     switch (buf[RP_FLAGS]) {
  140. case SOCKS5_HOSTNAME:
  141.     memset(result, 0, sizeof(ssn));
  142.     result->sa.sa_family = AF_S5NAME;
  143.     memcpy(result->sn.sn_name,  buf+RP_HOSTOFF+1, (u_char)buf[RP_HOSTOFF]);
  144.     memcpy(&result->sn.sn_port, buf+RP_HOSTOFF+1+buf[RP_HOSTOFF], sizeof(u_short));
  145.     result->sn.sn_name[(int)(u_char)buf[RP_HOSTOFF]] = '';
  146.     return 0;
  147. case SOCKS5_IPV4ADDR:
  148.     memset(result, 0, sizeof(ssi));
  149.     result->sin.sin_family = AF_INET;
  150.     memcpy(&result->sin.sin_addr, buf+RP_HOSTOFF, sizeof(struct in_addr));
  151.     memcpy(&result->sin.sin_port, buf+RP_HOSTOFF + sizeof(struct in_addr), sizeof(u_short));
  152.     return 0;
  153. #ifdef HAVE_NETINET6_IN6_H
  154. case SOCKS5_IPV6ADDR:
  155.     memset(result, 0, sizeof(ssi6));
  156. #ifdef SIN6_LEN
  157.     result->sin6.sin6_len    = sizeof(struct sockaddr_in6);
  158. #endif
  159.     result->sin6.sin6_family = AF_INET6;
  160.     memcpy(&result->sin6.sin6_addr, buf+RP_HOSTOFF, sizeof(struct in_addr6));
  161.     memcpy(&result->sin6.sin6_port, buf+RP_HOSTOFF + sizeof(struct in_addr6), sizeof(u_short));
  162.     return 0;
  163. #endif
  164. default:
  165.     S5LogUpdate(S5LogDefaultHandle, S5_LOG_WARNING, 0, "Unknown address type: %d");
  166.     return -1;
  167.     }
  168. }
  170. int lsSetProtoAddr(u_char version, char *buf, const S5NetAddr *name) {
  171.     if (version == SOCKS4_VERSION) {
  172. if (name->sa.sa_family != AF_INET) return -1;
  173. memcpy(buf+SP_HOSTOFF, &name->sin.sin_addr, sizeof(struct in_addr));
  174. memcpy(buf+SP_PORTOFF, &name->sin.sin_port, sizeof(u_short));
  175. return 0;
  176.     }
  178.     switch (name->sa.sa_family) {
  179. case AF_S5NAME:
  180.     buf[RP_FLAGS] = SOCKS5_HOSTNAME;
  181.     buf[RP_HOSTOFF] = strlen(name->sn.sn_name);
  182.     memcpy(buf+RP_HOSTOFF+1,                 name->sn.sn_name,  (u_char)buf[RP_HOSTOFF]);
  183.     memcpy(buf+RP_HOSTOFF+1+buf[RP_HOSTOFF], &name->sn.sn_port, sizeof(u_short));
  184.     return 0;
  185. case AF_INET:
  186.     buf[RP_FLAGS] = SOCKS5_IPV4ADDR;
  187.     memcpy(buf+RP_HOSTOFF,                          &name->sin.sin_addr, sizeof(struct in_addr));
  188.     memcpy(buf+RP_HOSTOFF + sizeof(struct in_addr), &name->sin.sin_port, sizeof(u_short));
  189.     return 0;
  190. #ifdef HAVE_NETINET6_IN6_H
  191. case AF_INET6:
  192.     buf[RP_FLAGS] = SOCKS5_IPV6ADDR;
  193.     memcpy(buf+RP_HOSTOFF,                           &name->sin6.sin6_addr, sizeof(struct in_addr6));
  194.     memcpy(buf+RP_HOSTOFF + sizeof(struct in_addr6), &name->sin6.sin6_port, sizeof(u_short));
  195.     return 0;
  196. #endif
  197. default:
  198.     return -1;
  199.     }
  200. }
  202. static int lsSendProto(S5IOHandle fd, S5IOInfo *cinfo, const S5NetAddr *addr, u_char version, u_char cp, u_char rs, char *opt) {
  203.     double timerm = PROTO_EXCHANGE_TIMEOUT;
  204.     char buf[MAXHDRSIZE];
  205.     int size;
  207.     memset(buf, 0, sizeof(buf));
  209.     if (version == SOCKS5_VERSION) {
  210. buf[RP_VERSION] = SOCKS5_VERSION;
  211. buf[RP_REPLY]   = cp;
  212. buf[RP_RESERVE] = rs;
  213. lsSetProtoAddr(version, buf, addr);
  214. size = HDRSIZE(buf);
  215.     } else {
  216. buf[SP_VERSION] = version;
  217. buf[SP_COMMAND] = cp;
  218. memcpy(buf+SP_HOSTOFF, &addr->sin.sin_addr, sizeof(struct in_addr));
  219. memcpy(buf+SP_PORTOFF, &addr->sin.sin_port, sizeof(u_short));
  220. if (opt != NULL) {
  221.     strcpy(buf+SP_USEROFF, (char *)opt);
  222.     size = HDRSIZE4(buf);
  223. } else size = RSPSIZE4; 
  224.     }
  225.     
  226.     if (S5IOSend(fd, cinfo, buf, size, 0, PROTO_IOFLAGS, &timerm) != size) return -1;
  227.     return 0;
  228. }
  230. int lsSendRequest(S5IOHandle fd, S5IOInfo *cinfo, const S5NetAddr *dest, u_char version, u_char command, u_char flags, char *opt) {
  231.     S5LogUpdate(S5LogDefaultHandle, S5_LOG_DEBUG(10), 0, "lsSendRequest: dest is (%s:%d)", ADDRANDPORT(dest));
  233.     if (lsSendProto(fd, cinfo, dest, version, command, flags, opt) < 0) {
  234. S5LogUpdate(S5LogDefaultHandle, S5_LOG_DEBUG(0), 0, "lsSendRequest: network failure");
  235. return -1;
  236.     }
  237.     
  238.     S5LogUpdate(S5LogDefaultHandle, S5_LOG_DEBUG(10), 0, "lsSendRequest: request sent");
  239.     return 0;
  240. }
  242. int lsReadRequest(S5IOHandle fd, S5IOInfo *cinfo, S5NetAddr *peer, u_char *version, u_char *cmd, u_char *flags) {
  243.     double timerm = (double)PROTO_RECVRESP_TIMEOUT;
  244.     char buf[MAXHDRSIZE];
  245.     int len;
  247.     if (S5IORecv(fd, cinfo, buf, RP_HOSTOFF+1, 0, PROTO_IOFLAGS, &timerm) != RP_HOSTOFF+1) {
  248.         S5LogUpdate(S5LogDefaultHandle, S5_LOG_DEBUG(0), 0, "Socks5: Read request failed: %m");
  249.         return -1;
  250.     }
  252.     S5LogUpdate(S5LogDefaultHandle, S5_LOG_DEBUG(5), 0, "Socks5: Read initial protocol");
  254.     *version  = (u_char)buf[RP_VERSION];
  256.     if ((len = lsGetProtoAddrLenFromBuf(*version, buf)) < 0) {
  257.         S5LogUpdate(S5LogDefaultHandle, S5_LOG_DEBUG(0), 0, "Socks5: Unable to determine address length from buffer (bad address type?)");
  258.         return -1;
  259.     }
  261.     /* read rest of address information                                      */
  262.     if (S5IORecv(fd, cinfo, buf+RP_HOSTOFF+1, len-1, 0, PROTO_IOFLAGS, &timerm) != len-1) {
  263.         S5LogUpdate(S5LogDefaultHandle, S5_LOG_DEBUG(0), 0, "Socks5: Read request failed: %m");
  264.         return -1;
  265.     }
  267.     S5LogUpdate(S5LogDefaultHandle, S5_LOG_DEBUG(10), 0, "Socks5: Read address part of protocol");
  269.     if (lsGetProtoAddr(*version, buf, peer) < 0) {
  270.         S5LogUpdate(S5LogDefaultHandle, S5_LOG_DEBUG(0), 0, "Socks5: Invalid address passed from client");
  271.         return -1;
  272.     }
  274.     *cmd  = (u_char)buf[RP_COMMAND];
  275.     *flags = (u_char)buf[RP_RESERVE];
  277.     return 0;
  278. }
  280. int lsSendResponse(S5IOHandle fd, S5IOInfo *cinfo, const S5NetAddr *reply, u_char version, u_char error, u_char flags, char *opt) {
  281.     S5LogUpdate(S5LogDefaultHandle, S5_LOG_DEBUG(10), 0, "lsSendResponse: reply is (%s:%d)", ADDRANDPORT(reply));
  283.     if (lsSendProto(fd, cinfo, reply, (version == SOCKS4_VERSION)?0:version, error, flags, opt) < 0) {
  284. S5LogUpdate(S5LogDefaultHandle, S5_LOG_DEBUG(0), 0, "lsSendResponse: network failure");
  285. return -1;
  286.     }
  287.     
  288.     S5LogUpdate(S5LogDefaultHandle, S5_LOG_DEBUG(10), 0, "lsSendResponse: response sent");
  289.     return 0;
  290. }
  292. /* Read a socks5 response back from the server...                            */
  293. int lsReadResponse(S5IOHandle fd, S5IOInfo *cinfo, S5NetAddr *peer, u_char version, u_char *res, u_char *flags) {
  294.     double timerm = (double)PROTO_RECVRESP_TIMEOUT;
  295.     char tmpbuf[MAXHDRSIZE];
  296.     int len, hdlen;
  298.     switch (version) {
  299. case SOCKS4_VERSION:
  300.     hdlen = SP_PORTOFF;
  301.     break;
  302. case SOCKS5_VERSION:
  303.     hdlen = RP_HOSTOFF+1;
  304.     break;
  305. default:
  306.     S5LogUpdate(S5LogDefaultHandle, S5_LOG_WARNING, 0, "lsReadResponse: Invalid version: %d", version);
  307.     SETSOCKETERROR(ECONNREFUSED);
  308.     return -1;
  309.     }
  311.     S5LogUpdate(S5LogDefaultHandle, S5_LOG_DEBUG(10), 0, "lsReadResponse: Reading response (version: %d)...", version);
  313.     if (S5IORecv(fd, cinfo, tmpbuf, hdlen, 0, PROTO_IOFLAGS, &timerm) != hdlen) {
  314. S5LogUpdate(S5LogDefaultHandle, S5_LOG_DEBUG(0), 0, "lsReadResponse: read: %m");
  315. SETSOCKETERROR(ECONNREFUSED);
  316. return -1;
  317.     }
  319.     if ((len = lsGetProtoAddrLenFromBuf(version, tmpbuf)) < 0) {
  320. S5LogUpdate(S5LogDefaultHandle, S5_LOG_DEBUG(0), 0, "lsReadResponse: Invalid address type: %d", tmpbuf[RP_HOSTOFF]);
  321. SETSOCKETERROR(ECONNREFUSED);
  322. return -1;
  323.     }
  324.     
  325.     /* If this was a socks5 request, we read one too many before so that the */
  326.     /* address length thing would work, so we take it off here...            */
  327.     if (version == SOCKS5_VERSION) {
  328. len--;
  329.     }
  331.     if (S5IORecv(fd, cinfo, tmpbuf+hdlen, len, 0, PROTO_IOFLAGS, &timerm) != len) {
  332. S5LogUpdate(S5LogDefaultHandle, S5_LOG_DEBUG(0), 0, "lsReadResponse: Address read: %m");
  333. SETSOCKETERROR(ECONNREFUSED);
  334. return -1;
  335.     }
  336.     
  337.     S5LogUpdate(S5LogDefaultHandle, S5_LOG_DEBUG(10), 0, "lsReadResponse: Server response read");
  338.     
  339.     if (lsGetProtoAddr(version, tmpbuf, peer) < 0) {
  340. S5LogUpdate(S5LogDefaultHandle, S5_LOG_DEBUG(0), 0, "lsReadResponse: Bad address in Response");
  341. SETSOCKETERROR(ECONNREFUSED);
  342. return -1;
  343.     }
  344.     
  345.     S5LogUpdate(S5LogDefaultHandle, S5_LOG_DEBUG(10), 0, "lsReadResponse: Response Address: %d:%s:%d", peer->sa.sa_family, ADDRANDPORT(peer));
  347.     if (version == SOCKS4_VERSION) {
  348. switch ((int)(*res = (u_char)tmpbuf[SP_COMMAND])) {
  349.     case SOCKS_NOERR:
  350.     case SOCKS_RESULT:
  351. return 0;
  352.     case SOCKS_FAIL:
  353. S5LogUpdate(S5LogDefaultHandle, S5_LOG_ERROR, 0, "Socks4 Server: permission denied");
  354. SETSOCKETERROR(ECONNREFUSED);
  355. return -1;
  356.     case SOCKS_NO_IDENTD:
  357. S5LogUpdate(S5LogDefaultHandle, S5_LOG_ERROR, 0, "Socks4 Server: couldn't contact your identd");
  358. SETSOCKETERROR(ECONNREFUSED);
  359. return -1;
  360.     case SOCKS_BAD_ID:
  361. S5LogUpdate(S5LogDefaultHandle, S5_LOG_ERROR, 0, "Socks4 Server: user denied");
  362. SETSOCKETERROR(ECONNREFUSED);
  363. return -1;
  364.     default:
  365. S5LogUpdate(S5LogDefaultHandle, S5_LOG_ERROR, 0, "Socks4 Server: Unknown reply code: %d", (int)(u_char)tmpbuf[SP_COMMAND]);
  366. SETSOCKETERROR(ECONNREFUSED);
  367. return -1;
  368. }
  369.     } else {
  370. *flags = (u_char)tmpbuf[RP_RESERVE];
  371. switch ((int)(*res = tmpbuf[RP_REPLY])) {
  372.     case SOCKS5_TTLEXP:
  373. S5LogUpdate(S5LogDefaultHandle, S5_LOG_ERROR, 0, "Socks5 Server: Server timed out");
  374. SETSOCKETERROR(ETIMEDOUT);
  375. return -1;
  376.     case SOCKS5_BADCMND:
  377. S5LogUpdate(S5LogDefaultHandle, S5_LOG_ERROR, 0, "Socks5 Server: Bad Command");
  378. SETSOCKETERROR(ECONNREFUSED);
  379. return -1;
  380.     case SOCKS5_NETUNREACH:
  381. S5LogUpdate(S5LogDefaultHandle, S5_LOG_ERROR, 0, "Socks5 Server: Net unreachable");
  382. SETSOCKETERROR(ENETUNREACH);
  383. return -1;
  384.     case SOCKS5_HOSTUNREACH:
  385. S5LogUpdate(S5LogDefaultHandle, S5_LOG_ERROR, 0, "Socks5 Server: Host unreachable");
  386. SETSOCKETERROR(EHOSTUNREACH);
  387. return -1;
  388.     case SOCKS5_BADADDR:
  389. S5LogUpdate(S5LogDefaultHandle, S5_LOG_ERROR, 0, "Socks5 Server: Bad Address type");
  390. SETSOCKETERROR(ECONNREFUSED);
  391. return -1;
  392.     case SOCKS5_CONNREF:
  393. S5LogUpdate(S5LogDefaultHandle, S5_LOG_ERROR, 0, "Socks5 Server: Connection failed");
  394. SETSOCKETERROR(ECONNREFUSED);
  395. return -1;
  396.     case SOCKS5_FAIL:
  397. S5LogUpdate(S5LogDefaultHandle, S5_LOG_ERROR, 0, "Socks5 Server: Server failure");
  398. SETSOCKETERROR(ECONNREFUSED);
  399. return -1;
  400.     case SOCKS5_AUTHORIZE:
  401. S5LogUpdate(S5LogDefaultHandle, S5_LOG_ERROR, 0, "Socks5 Server: Authorization failed");
  402. SETSOCKETERROR(ECONNREFUSED);
  403. return -1;
  404.     case SOCKS5_RESULT:
  405. S5LogUpdate(S5LogDefaultHandle, S5_LOG_DEBUG(10), 0, "lsReadResponse: Received a good status reply");
  406. return 0;
  407.     default:
  408. S5LogUpdate(S5LogDefaultHandle, S5_LOG_ERROR, 0, "Socks5 Server: Unknown reply code: %d", *res);
  409. SETSOCKETERROR(ECONNREFUSED);
  410. return -1;
  411. }
  412.     }
  413. }
  415. /* perform the authentication and  the authsend "command" message to */
  416. /* the proxy server                                                  */
  417. int lsProtoExchg(S5IOHandle fd, S5IOInfo *cinfo, const S5NetAddr *dest, char *effuser, u_char version, u_char command, u_char flags) {
  418.     char tmpbuf[MAXHDRSIZE], *tmp = tmpbuf+2, auth = AUTH_FAIL;
  419.     double timerm = PROTO_EXCHANGE_TIMEOUT;
  421.     S5LogUpdate(S5LogDefaultHandle, S5_LOG_DEBUG(10), 0, "lsProtoExchg: dest is (%s:%d)", ADDRANDPORT(dest));
  423.     memset(tmpbuf, 0, sizeof(tmpbuf));
  424.     S5BufSetupContext(cinfo);
  425.     cinfo->fd = fd;
  427.     if (version == SOCKS4_VERSION) {    
  428. if (lsSendRequest(fd, cinfo, dest, version, command, flags, effuser) < 0) {
  429.     S5LogUpdate(S5LogDefaultHandle, S5_LOG_DEBUG(0), 0, "lsProtoExchg: write: %m");
  430.     SETSOCKETERROR(ECONNREFUSED);
  431.     return -1;
  432. }
  434. return 0;
  435.     } else {
  436. *tmp++ = AUTH_NONE;
  437. *tmp++ = AUTH_PASSWD;
  438. #ifdef HAVE_LIBGSSAPI_KRB5
  439. *tmp++ = AUTH_GSSAPI;
  440. #endif
  441. tmpbuf[1] = tmp - (tmpbuf + 2);
  442. tmpbuf[RP_VERSION] = SOCKS5_VERSION;
  443.     
  444. if (S5IOSend(fd, cinfo, tmpbuf, 2+(u_int)tmpbuf[1], 0, PROTO_IOFLAGS, &timerm) != 2+(int)(u_int)tmpbuf[1]) {
  445.     S5LogUpdate(S5LogDefaultHandle, S5_LOG_DEBUG(0), 0, "lsProtoExchg: write: %m");
  446.     SETSOCKETERROR(ECONNREFUSED);
  447.     return -1;
  448. }
  449.     
  450. if (S5IORecv(fd, cinfo, tmpbuf, 2, 0, PROTO_IOFLAGS, &timerm) != 2) {
  451.     S5LogUpdate(S5LogDefaultHandle, S5_LOG_DEBUG(0), 0, "lsProtoExchg: read: %m");
  452.     SETSOCKETERROR(ECONNREFUSED);
  453.     return -1;
  454. }
  455.     
  456. if (tmpbuf[0] != SOCKS5_VERSION) {
  457.     S5LogUpdate(S5LogDefaultHandle, S5_LOG_DEBUG(0), 0, "lsProtoExchg: Cannot Speak Socks5 protocol to Socks4 Server.");
  458.     SETSOCKETERROR(ECONNREFUSED);
  459.     return -1;
  460. }
  461.     
  462. S5LogUpdate(S5LogDefaultHandle, S5_LOG_DEBUG(10), 0, "lsProtoExchg: server asked us to do method #%d", (int)tmpbuf[1]);
  464. switch ((u_char)tmpbuf[1]) {
  465.     case AUTH_NONE:   auth = lsNullCliAuth  (fd, &cinfo->auth, effuser); break;
  466.     case AUTH_PASSWD: auth = lsPasswdCliAuth(fd, &cinfo->auth, effuser); break;
  467.     case AUTH_GSSAPI: auth = lsGssapiCliAuth(fd, &cinfo->auth, effuser); break;
  468. }
  469.     
  470. S5LogUpdate(S5LogDefaultHandle, S5_LOG_DEBUG(10), 0, "lsProtoExchg: authentication done: %s", (auth == AUTH_OK)?"ok":"failed");
  472. if (auth != AUTH_OK) {
  473.     SETSOCKETERROR(ECONNREFUSED);
  474.     return -1;
  475. }
  477. if (lsSendRequest(fd, cinfo, dest, version, command, flags, NULL) < 0) {
  478.     S5LogUpdate(S5LogDefaultHandle, S5_LOG_DEBUG(0), 0, "lsProtoExchg: write: %m");
  479.     SETSOCKETERROR(ECONNREFUSED);
  480.     return -1;
  481. }
  482.     
  483. S5LogUpdate(S5LogDefaultHandle, S5_LOG_DEBUG(10), 0, "lsProtoExchg: done");
  484. return 0;
  485.     }
  486. }