common.c 22 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852853854855856857858859860861862863864865866867868869870871872873874875876877878879880881882883884885886887888889890891892893894895896897898899900901902
  1. /*
  2. 3APA3A simpliest proxy server
  3. (c) 2002-2016 by Vladimir Dubrovin <3proxy@3proxy.ru>
  4. please read License Agreement
  5. */
  6. #include "proxy.h"
  7. char * copyright = COPYRIGHT;
  8. int randomizer = 1;
  9. int havelog = 0;
  10. #ifndef _WIN32
  11. pthread_attr_t pa;
  12. void daemonize(void){
  13. if(fork() > 0) {
  14. usleep(SLEEPTIME);
  15. _exit(0);
  16. }
  17. setsid();
  18. }
  19. #endif
  20. unsigned char **stringtable = NULL;
  21. int myinet_ntop(int af, void *src, char *dst, socklen_t size){
  22. #ifndef NOIPV6
  23. if(af != AF_INET6){
  24. #endif
  25. unsigned u = ntohl(((struct in_addr *)src)->s_addr);
  26. return sprintf(dst, "%u.%u.%u.%u",
  27. ((u&0xFF000000)>>24),
  28. ((u&0x00FF0000)>>16),
  29. ((u&0x0000FF00)>>8),
  30. ((u&0x000000FF)));
  31. #ifndef NOIPV6
  32. }
  33. *dst = 0;
  34. inet_ntop(af, src, dst, size);
  35. return (int)strlen(dst);
  36. #endif
  37. }
  38. char *rotations[] = {
  39. "",
  40. "/min",
  41. "/hour",
  42. "/day",
  43. "/week",
  44. "/month",
  45. "/year",
  46. "",
  47. };
  48. struct extparam conf = {
  49. {1, 5, 30, 60, 180, 1800, 15, 60, 15, 5, 0, 0},
  50. NULL,
  51. NULL,
  52. NULL, NULL,
  53. NULL,
  54. NULL,
  55. NULL,
  56. 0,
  57. 0, -1, 0, 0, 0, 0,
  58. 0, 500, 0, 0, 0, 0,
  59. 6, 600,
  60. 1048576,
  61. NULL, NULL,
  62. NONE, NONE,
  63. NULL,
  64. #ifndef NOIPV6
  65. {AF_INET},{AF_INET6},{AF_INET},
  66. #else
  67. {AF_INET},{AF_INET},
  68. #endif
  69. NULL,
  70. NULL,
  71. doconnect,
  72. lognone,
  73. NULL,
  74. NULL,
  75. NULL, NULL,
  76. NULL,
  77. NULL,
  78. NULL,
  79. NULL,
  80. NULL,
  81. NULL,
  82. (time_t)0, (time_t)0,
  83. 0,0,
  84. '@',
  85. };
  86. int numservers=0;
  87. char* NULLADDR="\0\0\0\0\0\0\0\0\0\0\0\0\0\0\0\0\0\0\0\0";
  88. int myrand(void * entropy, int len){
  89. int i;
  90. unsigned short init;
  91. init = randomizer;
  92. for(i=0; i < len/2; i++){
  93. init ^= ((unsigned short *)entropy)[i];
  94. }
  95. srand(init);
  96. randomizer = rand();
  97. return rand();
  98. }
  99. #ifndef WITH_POLL
  100. #ifndef WITH_WSAPOLL
  101. int
  102. #ifdef _WIN32
  103. WINAPI
  104. #endif
  105. mypoll(struct mypollfd *fds, unsigned int nfds, int timeout){
  106. fd_set readfd;
  107. fd_set writefd;
  108. fd_set oobfd;
  109. struct timeval tv;
  110. unsigned i;
  111. int num;
  112. SOCKET maxfd = 0;
  113. tv.tv_sec = timeout/1000;
  114. tv.tv_usec = (timeout%1000)*1000;
  115. FD_ZERO(&readfd);
  116. FD_ZERO(&writefd);
  117. FD_ZERO(&oobfd);
  118. for(i=0; i<nfds; i++){
  119. if((fds[i].events&POLLIN))FD_SET(fds[i].fd, &readfd);
  120. if((fds[i].events&POLLOUT))FD_SET(fds[i].fd, &writefd);
  121. if((fds[i].events&POLLPRI))FD_SET(fds[i].fd, &oobfd);
  122. fds[i].revents = 0;
  123. if(fds[i].fd > maxfd) maxfd = fds[i].fd;
  124. }
  125. if((num = select(((int)(maxfd))+1, &readfd, &writefd, &oobfd, &tv)) < 1) return num;
  126. for(i=0; i<nfds; i++){
  127. if(FD_ISSET(fds[i].fd, &readfd)) fds[i].revents |= POLLIN;
  128. if(FD_ISSET(fds[i].fd, &writefd)) fds[i].revents |= POLLOUT;
  129. if(FD_ISSET(fds[i].fd, &oobfd)) fds[i].revents |= POLLPRI;
  130. }
  131. return num;
  132. }
  133. #endif
  134. #endif
  135. struct sockfuncs so = {
  136. socket,
  137. accept,
  138. bind,
  139. listen,
  140. connect,
  141. getpeername,
  142. getsockname,
  143. getsockopt,
  144. setsockopt,
  145. #ifndef WITH_POLL
  146. #ifndef WITH_WSAPOLL
  147. mypoll,
  148. #else
  149. WSAPoll,
  150. #endif
  151. #else
  152. poll,
  153. #endif
  154. (void *)send,
  155. (void *)sendto,
  156. (void *)recv,
  157. (void *)recvfrom,
  158. shutdown,
  159. #ifdef _WIN32
  160. closesocket
  161. #else
  162. close
  163. #endif
  164. };
  165. #ifdef _WINCE
  166. static char cebuf[1024];
  167. static char ceargbuf[256];
  168. char * ceargv[32];
  169. char * CEToUnicode (const char *str){
  170. int i;
  171. for(i=0; i<510 && str[i]; i++){
  172. cebuf[(i*2)] = str[i];
  173. cebuf[(i*2)+1] = 0;
  174. }
  175. cebuf[(i*2)] = 0;
  176. cebuf[(i*2)+1] = 0;
  177. return cebuf;
  178. };
  179. int cesystem(const char *str){
  180. STARTUPINFO startupInfo = {0};
  181. startupInfo.cb = sizeof(startupInfo);
  182. PROCESS_INFORMATION processInformation;
  183. return CreateProcessW((LPWSTR)CEToUnicode(str), NULL, NULL, NULL, FALSE, NORMAL_PRIORITY_CLASS, NULL, NULL, &startupInfo, &processInformation);
  184. }
  185. int ceparseargs(const char *str){
  186. int argc = 0, i;
  187. int space = 1;
  188. for(i=0; i<250 && argc<30 && str[2*i]; i++){
  189. ceargbuf[i] = str[2*i];
  190. if(space && ceargbuf[i]!=' '&& ceargbuf[i]!='\t'&& ceargbuf[i]!='\r'&& ceargbuf[i]!='\n'){
  191. ceargv[argc++] = ceargbuf + i;
  192. space = 0;
  193. }
  194. else if(!space && (ceargbuf[i]==' ' || ceargbuf[i]=='\t' || ceargbuf[i]=='\r' || ceargbuf[i]=='\n')){
  195. ceargbuf[i] = 0;
  196. space = 1;
  197. }
  198. }
  199. return argc;
  200. }
  201. #endif
  202. int parsehost(int family, unsigned char *host, struct sockaddr *sa){
  203. char *sp=NULL,*se=NULL;
  204. unsigned short port=0;
  205. int ret = 0;
  206. if(!host) return 2;
  207. if(*host == '[') se=strchr((char *)host, ']');
  208. if ( (sp = strchr(se?se:(char *)host, ':')) && !strchr(sp+1, ':')) *sp = 0;
  209. if(se){
  210. *se = 0;
  211. }
  212. if(sp){
  213. port = atoi(sp+1);
  214. }
  215. ret = !getip46(family, host + (se!=0), (struct sockaddr *)sa);
  216. if(se) *se = ']';
  217. if(sp) *sp = ':';
  218. if(port)*SAPORT(sa) = htons(port);
  219. return ret;
  220. }
  221. int parsehostname(char *hostname, struct clientparam *param, unsigned short port){
  222. char *sp=NULL,*se=NULL;
  223. int ret = 0;
  224. if(!hostname || !*hostname)return 2;
  225. if(*hostname == '[') se=strchr(hostname, ']');
  226. if ( (sp = strchr(se?se:hostname, ':')) && !strchr(sp+1, ':')) *sp = 0;
  227. if(se){
  228. *se = 0;
  229. }
  230. if(hostname != (char *)param->hostname){
  231. if(param->hostname) myfree(param->hostname);
  232. param->hostname = (unsigned char *)mystrdup(hostname + (se!=0));
  233. }
  234. if(sp){
  235. port = atoi(sp+1);
  236. }
  237. ret = !getip46(param->srv->family, param->hostname, (struct sockaddr *)&param->req);
  238. if(se) *se = ']';
  239. if(sp) *sp = ':';
  240. *SAPORT(&param->req) = htons(port);
  241. memset(&param->sinsr, 0, sizeof(param->sinsr));
  242. return ret;
  243. }
  244. int parseusername(char *username, struct clientparam *param, int extpasswd){
  245. char *sb = NULL, *se = NULL, *sp = NULL;
  246. if(!username || !*username) return 1;
  247. if(param->srv->needuser && (sb = strchr(username, ':')) && (se = strchr(sb + 1, ':')) && (!extpasswd || (sp = strchr(se + 1, ':')))){
  248. *sb = 0;
  249. *se = 0;
  250. if(sp) *sp = 0;
  251. if(*(sb+1)) {
  252. if(param->password) myfree(param->password);
  253. param->password = (unsigned char *)mystrdup(sb+1);
  254. }
  255. if(*username) {
  256. if(param->username) myfree(param->username);
  257. param->username = (unsigned char *)mystrdup(username);
  258. }
  259. username = se+1;
  260. }
  261. if(extpasswd){
  262. if(!sp) sp = strchr(username, ':');
  263. if(sp){
  264. *sp = 0;
  265. if(param->extpassword) myfree(param->extpassword);
  266. param->extpassword = (unsigned char *) mystrdup(sp+1);
  267. }
  268. }
  269. if(param->extusername) myfree(param->extusername);
  270. param->extusername = (unsigned char *)mystrdup(username);
  271. if(sb) *sb = ':';
  272. if(se) *se = ':';
  273. if(sp) *sp = ':';
  274. return 0;
  275. }
  276. int parseconnusername(char *username, struct clientparam *param, int extpasswd, unsigned short port){
  277. char *sb, *se;
  278. if(!username || !*username) return 1;
  279. if ((sb=strchr(username, conf.delimchar)) == NULL){
  280. if(!param->hostname && param->remsock == INVALID_SOCKET) return 2;
  281. if(param->hostname)parsehostname((char *)param->hostname, param, port);
  282. return parseusername(username, param, extpasswd);
  283. }
  284. while ((se=strchr(sb+1, conf.delimchar)))sb=se;
  285. *(sb) = 0;
  286. if(parseusername(username, param, extpasswd)) return 3;
  287. *(sb) = conf.delimchar;
  288. if(parsehostname(sb+1, param, port)) return 4;
  289. return 0;
  290. }
  291. void clearstat(struct clientparam * param) {
  292. #ifdef _WIN32
  293. struct timeb tb;
  294. ftime(&tb);
  295. param->time_start = (time_t)tb.time;
  296. param->msec_start = (unsigned)tb.millitm;
  297. #else
  298. struct timeval tv;
  299. struct timezone tz;
  300. gettimeofday(&tv, &tz);
  301. param->time_start = (time_t)tv.tv_sec;
  302. param->msec_start = (tv.tv_usec / 1000);
  303. #endif
  304. param->statscli64 = param->statssrv64 = param->nreads = param->nwrites =
  305. param->nconnects = 0;
  306. }
  307. char months[12][4] = {
  308. "Jan", "Feb", "Mar", "Apr", "May", "Jun",
  309. "Jul", "Aug", "Sep", "Oct", "Nov", "Dec"
  310. };
  311. int dobuf2(struct clientparam * param, unsigned char * buf, const unsigned char *s, const unsigned char * doublec, struct tm* tm, char * format){
  312. int i, j;
  313. int len;
  314. time_t sec;
  315. unsigned msec;
  316. long timezone;
  317. unsigned delay;
  318. #ifdef _WIN32
  319. struct timeb tb;
  320. ftime(&tb);
  321. sec = (time_t)tb.time;
  322. msec = (unsigned)tb.millitm;
  323. timezone = tm->tm_isdst*60 - tb.timezone;
  324. #else
  325. struct timeval tv;
  326. struct timezone tz;
  327. gettimeofday(&tv, &tz);
  328. sec = (time_t)tv.tv_sec;
  329. msec = tv.tv_usec / 1000;
  330. #ifdef _SOLARIS
  331. timezone = -altzone / 60;
  332. #else
  333. timezone = tm->tm_gmtoff / 60;
  334. #endif
  335. #endif
  336. delay = param->time_start?((unsigned) ((sec - param->time_start))*1000 + msec) - param->msec_start : 0;
  337. *buf = 0;
  338. for(i=0, j=0; format[j] && i < 4040; j++){
  339. if(format[j] == '%' && format[j+1]){
  340. j++;
  341. switch(format[j]){
  342. case '%':
  343. buf[i++] = '%';
  344. break;
  345. case 'y':
  346. sprintf((char *)buf+i, "%.2d", tm->tm_year%100);
  347. i+=2;
  348. break;
  349. case 'Y':
  350. sprintf((char *)buf+i, "%.4d", tm->tm_year+1900);
  351. i+=4;
  352. break;
  353. case 'm':
  354. sprintf((char *)buf+i, "%.2d", tm->tm_mon+1);
  355. i+=2;
  356. break;
  357. case 'o':
  358. sprintf((char *)buf+i, "%s", months[tm->tm_mon]);
  359. i+=3;
  360. break;
  361. case 'd':
  362. sprintf((char *)buf+i, "%.2d", tm->tm_mday);
  363. i+=2;
  364. break;
  365. case 'H':
  366. sprintf((char *)buf+i, "%.2d", tm->tm_hour);
  367. i+=2;
  368. break;
  369. case 'M':
  370. sprintf((char *)buf+i, "%.2d", tm->tm_min);
  371. i+=2;
  372. break;
  373. case 'S':
  374. sprintf((char *)buf+i, "%.2d", tm->tm_sec);
  375. i+=2;
  376. break;
  377. case 't':
  378. sprintf((char *)buf+i, "%.10u", (unsigned)sec);
  379. i+=10;
  380. break;
  381. case 'b':
  382. i+=sprintf((char *)buf+i, "%u", delay?(unsigned)(param->statscli64 * 1000./delay):0);
  383. break;
  384. case 'B':
  385. i+=sprintf((char *)buf+i, "%u", delay?(unsigned)(param->statssrv64 * 1000./delay):0);
  386. break;
  387. case 'D':
  388. i+=sprintf((char *)buf+i, "%u", delay);
  389. break;
  390. case '.':
  391. sprintf((char *)buf+i, "%.3u", msec);
  392. i+=3;
  393. break;
  394. case 'z':
  395. sprintf((char *)buf+i, "%+.2ld%.2u", timezone / 60, (unsigned)(timezone%60));
  396. i+=5;
  397. break;
  398. case 'U':
  399. if(param->username && *param->username){
  400. for(len = 0; i< 4000 && param->username[len]; len++){
  401. buf[i] = param->username[len];
  402. if(param->srv->nonprintable && (buf[i] < 0x20 || strchr((char *)param->srv->nonprintable, buf[i]))) buf[i] = param->srv->replace;
  403. if(doublec && strchr((char *)doublec, buf[i])) {
  404. buf[i+1] = buf[i];
  405. i++;
  406. }
  407. i++;
  408. }
  409. }
  410. else {
  411. buf[i++] = '-';
  412. }
  413. break;
  414. case 'n':
  415. len = param->hostname? (int)strlen((char *)param->hostname) : 0;
  416. if (len > 0 && !strchr((char *)param->hostname, ':')) for(len = 0; param->hostname[len] && i < 256; len++, i++){
  417. buf[i] = param->hostname[len];
  418. if(param->srv->nonprintable && (buf[i] < 0x20 || strchr((char *)param->srv->nonprintable, buf[i]))) buf[i] = param->srv->replace;
  419. if(doublec && strchr((char *)doublec, buf[i])) {
  420. buf[i+1] = buf[i];
  421. i++;
  422. }
  423. }
  424. else {
  425. buf[i++] = '[';
  426. i += myinet_ntop(*SAFAMILY(&param->req), SAADDR(&param->req), (char *)buf + i, 64);
  427. buf[i++] = ']';
  428. }
  429. break;
  430. case 'N':
  431. if(param->service < 15) {
  432. len = (conf.stringtable)? (int)strlen((char *)conf.stringtable[SERVICES + param->service]) : 0;
  433. if(len > 20) len = 20;
  434. memcpy(buf+i, (len)?conf.stringtable[SERVICES + param->service]:(unsigned char*)"-", (len)?len:1);
  435. i += (len)?len:1;
  436. }
  437. break;
  438. case 'E':
  439. sprintf((char *)buf+i, "%.05d", param->res);
  440. i += 5;
  441. break;
  442. case 'T':
  443. if(s){
  444. for(len = 0; i<4000 && s[len]; len++){
  445. buf[i] = s[len];
  446. if(param->srv->nonprintable && (buf[i] < 0x20 || strchr((char *)param->srv->nonprintable, buf[i]))) buf[i] = param->srv->replace;
  447. if(doublec && strchr((char *)doublec, buf[i])) {
  448. buf[i+1] = buf[i];
  449. i++;
  450. }
  451. i++;
  452. }
  453. }
  454. break;
  455. case 'e':
  456. i += myinet_ntop(*SAFAMILY(&param->sinsl), SAADDR(&param->sinsl), (char *)buf + i, 64);
  457. break;
  458. case 'i':
  459. i += myinet_ntop(*SAFAMILY(&param->sincl), SAADDR(&param->sincl), (char *)buf + i, 64);
  460. break;
  461. case 'C':
  462. i += myinet_ntop(*SAFAMILY(&param->sincr), SAADDR(&param->sincr), (char *)buf + i, 64);
  463. break;
  464. case 'R':
  465. i += myinet_ntop(*SAFAMILY(&param->sinsr), SAADDR(&param->sinsr), (char *)buf + i, 64);
  466. break;
  467. case 'Q':
  468. i += myinet_ntop(*SAFAMILY(&param->req), SAADDR(&param->req), (char *)buf + i, 64);
  469. break;
  470. case 'p':
  471. sprintf((char *)buf+i, "%hu", ntohs(*SAPORT(&param->srv->intsa)));
  472. i += (int)strlen((char *)buf+i);
  473. break;
  474. case 'c':
  475. sprintf((char *)buf+i, "%hu", ntohs(*SAPORT(&param->sincr)));
  476. i += (int)strlen((char *)buf+i);
  477. break;
  478. case 'r':
  479. sprintf((char *)buf+i, "%hu", ntohs(*SAPORT(&param->sinsr)));
  480. i += (int)strlen((char *)buf+i);
  481. break;
  482. case 'q':
  483. sprintf((char *)buf+i, "%hu", ntohs(*SAPORT(&param->req)));
  484. i += (int)strlen((char *)buf+i);
  485. break;
  486. case 'I':
  487. sprintf((char *)buf+i, "%"PRINTF_INT64_MODIFIER"u", param->statssrv64);
  488. i += (int)strlen((char *)buf+i);
  489. break;
  490. case 'O':
  491. sprintf((char *)buf+i, "%"PRINTF_INT64_MODIFIER"u", param->statscli64);
  492. i += (int)strlen((char *)buf+i);
  493. break;
  494. case 'h':
  495. sprintf((char *)buf+i, "%d", param->redirected);
  496. i += (int)strlen((char *)buf+i);
  497. break;
  498. case '1':
  499. case '2':
  500. case '3':
  501. case '4':
  502. case '5':
  503. case '6':
  504. case '7':
  505. case '8':
  506. case '9':
  507. {
  508. int k, pmin=0, pmax=0;
  509. for (k = j; isnumber(format[k]); k++);
  510. if(format[k] == '-' && isnumber(format[k+1])){
  511. pmin = atoi(format + j) - 1;
  512. k++;
  513. pmax = atoi(format + k) -1;
  514. for (; isnumber(format[k]); k++);
  515. j = k;
  516. }
  517. if(!s || format[k]!='T') break;
  518. for(k = 0, len = 0; s[len] && i < 4000; len++){
  519. if(isspace(s[len])){
  520. k++;
  521. while(isspace(s[len+1]))len++;
  522. if(k == pmin) continue;
  523. }
  524. if(k>=pmin && k<=pmax) {
  525. buf[i] = s[len];
  526. if(param->srv->nonprintable && (buf[i] < 0x20 || strchr((char *)param->srv->nonprintable, buf[i]))) buf[i] = param->srv->replace;
  527. if(doublec && strchr((char *)doublec, buf[i])) {
  528. buf[i+1] = buf[i];
  529. i++;
  530. }
  531. i++;
  532. }
  533. }
  534. break;
  535. }
  536. default:
  537. buf[i++] = format[j];
  538. }
  539. }
  540. else buf[i++] = format[j];
  541. }
  542. buf[i] = 0;
  543. return i;
  544. }
  545. int dobuf(struct clientparam * param, unsigned char * buf, const unsigned char *s, const unsigned char * doublec){
  546. struct tm* tm;
  547. int i;
  548. char * format;
  549. time_t t;
  550. time(&t);
  551. if(!param) return 0;
  552. if(param->trafcountfunc)(*param->trafcountfunc)(param);
  553. format = param->srv->logformat?(char *)param->srv->logformat : DEFLOGFORMAT;
  554. tm = (*format == 'G' || *format == 'g')?
  555. gmtime(&t) : localtime(&t);
  556. i = dobuf2(param, buf, s, doublec, tm, format + 1);
  557. clearstat(param);
  558. return i;
  559. }
  560. void lognone(struct clientparam * param, const unsigned char *s) {
  561. if(param->trafcountfunc)(*param->trafcountfunc)(param);
  562. clearstat(param);
  563. }
  564. void logstdout(struct clientparam * param, const unsigned char *s) {
  565. FILE *log;
  566. unsigned char tmpbuf[8192];
  567. dobuf(param, tmpbuf, s, NULL);
  568. log = param->srv->stdlog?param->srv->stdlog:conf.stdlog?conf.stdlog:stdout;
  569. if(!param->nolog)if(fprintf(log, "%s\n", tmpbuf) < 0) {
  570. perror("printf()");
  571. };
  572. if(log != conf.stdlog)fflush(log);
  573. }
  574. #ifndef _WIN32
  575. void logsyslog(struct clientparam * param, const unsigned char *s) {
  576. unsigned char tmpbuf[8192];
  577. dobuf(param, tmpbuf, s, NULL);
  578. if(!param->nolog)syslog(LOG_INFO, "%s", tmpbuf);
  579. }
  580. #endif
  581. int connectwithpoll(SOCKET sock, struct sockaddr *sa, SASIZETYPE size, int to){
  582. struct pollfd fds[1];
  583. #ifdef _WIN32
  584. unsigned long ul = 1;
  585. ioctlsocket(sock, FIONBIO, &ul);
  586. #else
  587. fcntl(sock,F_SETFL,O_NONBLOCK);
  588. #endif
  589. if(so._connect(sock,sa,size)) {
  590. if(errno != EAGAIN && errno != EINPROGRESS) return (13);
  591. }
  592. memset(fds, 0, sizeof(fds));
  593. fds[0].fd = sock;
  594. fds[0].events = POLLOUT;
  595. if(so._poll(fds, 1, to*1000) <= 0) {
  596. return (13);
  597. }
  598. return 0;
  599. }
  600. int doconnect(struct clientparam * param){
  601. SASIZETYPE size;
  602. if (*SAFAMILY(&param->sincl) == *SAFAMILY(&param->req) && !memcmp(SAADDR(&param->sincl), SAADDR(&param->req), SAADDRLEN(&param->req)) &&
  603. *SAPORT(&param->sincl) == *SAPORT(&param->req)) return 519;
  604. if (param->operation == ADMIN || param->operation == DNSRESOLVE || param->operation == BIND || param->operation == UDPASSOC)
  605. return 0;
  606. if (param->remsock != INVALID_SOCKET){
  607. size = sizeof(param->sinsr);
  608. if(so._getpeername(param->remsock, (struct sockaddr *)&param->sinsr, &size)==-1) {return (15);}
  609. }
  610. else {
  611. struct linger lg = {1,conf.timeouts[SINGLEBYTE_S]};
  612. if(SAISNULL(&param->sinsr)){
  613. if(SAISNULL(&param->req)) {
  614. return 100;
  615. }
  616. *SAFAMILY(&param->sinsr) = *SAFAMILY(&param->req);
  617. memcpy(SAADDR(&param->sinsr), SAADDR(&param->req), SAADDRLEN(&param->req));
  618. }
  619. if(!*SAPORT(&param->sinsr))*SAPORT(&param->sinsr) = *SAPORT(&param->req);
  620. if ((param->remsock=so._socket(SASOCK(&param->sinsr), SOCK_STREAM, IPPROTO_TCP)) == INVALID_SOCKET) {return (11);}
  621. setopts(param->remsock, param->srv->srvsockopts);
  622. so._setsockopt(param->remsock, SOL_SOCKET, SO_LINGER, (char *)&lg, sizeof(lg));
  623. #ifdef REUSE
  624. {
  625. int opt;
  626. #ifdef SO_REUSEADDR
  627. opt = 1;
  628. so._setsockopt(param->remsock, SOL_SOCKET, SO_REUSEADDR, (char *)&opt, sizeof(int));
  629. #endif
  630. #ifdef SO_REUSEPORT
  631. opt = 1;
  632. so._setsockopt(param->remsock, SOL_SOCKET, SO_REUSEPORT, (unsigned char *)&opt, sizeof(int));
  633. #endif
  634. }
  635. #endif
  636. #ifdef SO_BINDTODEVICE
  637. if(param->srv->obindtodevice) so._setsockopt(param->remsock, SOL_SOCKET, SO_BINDTODEVICE, param->srv->obindtodevice, strlen(param->srv->obindtodevice) + 1);
  638. #endif
  639. if(SAISNULL(&param->sinsl)){
  640. #ifndef NOIPV6
  641. if(*SAFAMILY(&param->sinsr) == AF_INET6) param->sinsl = param->srv->extsa6;
  642. else
  643. #endif
  644. param->sinsl = param->srv->extsa;
  645. }
  646. *SAPORT(&param->sinsl) = 0;
  647. if(so._bind(param->remsock, (struct sockaddr*)&param->sinsl, SASIZE(&param->sinsl))==-1) {
  648. return 12;
  649. }
  650. if(param->operation >= 256 || (param->operation & CONNECT)){
  651. if(connectwithpoll(param->remsock,(struct sockaddr *)&param->sinsr,SASIZE(&param->sinsr),CONNECT_TO)) {
  652. return 13;
  653. }
  654. }
  655. size = sizeof(param->sinsl);
  656. if(so._getsockname(param->remsock, (struct sockaddr *)&param->sinsl, &size)==-1) {return (15);}
  657. }
  658. return 0;
  659. }
  660. int scanaddr(const unsigned char *s, unsigned long * ip, unsigned long * mask) {
  661. unsigned d1, d2, d3, d4, m;
  662. int res;
  663. if ((res = sscanf((char *)s, "%u.%u.%u.%u/%u", &d1, &d2, &d3, &d4, &m)) < 4) return 0;
  664. if(mask && res == 4) *mask = 0xFFFFFFFF;
  665. else if (mask) *mask = htonl(0xFFFFFFFF << (32 - m));
  666. *ip = htonl ((d1<<24) ^ (d2<<16) ^ (d3<<8) ^ d4);
  667. return res;
  668. }
  669. RESOLVFUNC resolvfunc = NULL;
  670. #ifndef _WIN32
  671. pthread_mutex_t gethostbyname_mutex;
  672. int ghbn_init = 0;
  673. #endif
  674. #ifdef GETHOSTBYNAME_R
  675. struct hostent * my_gethostbyname(char *name, char *buf, struct hostent *hp){
  676. struct hostent *result;
  677. int gherrno;
  678. #ifdef _SOLARIS
  679. return gethostbyname_r(name, hp, buf, 1024, &gherrno);
  680. #else
  681. if(gethostbyname_r(name, hp, buf, 1024, &result, &gherrno) != 0)
  682. return NULL;
  683. return result;
  684. #endif
  685. }
  686. #endif
  687. #ifdef NOIPV6
  688. unsigned long getip(unsigned char *name){
  689. unsigned long retval;
  690. int i;
  691. int ndots = 0;
  692. struct hostent *hp=NULL;
  693. RESOLVFUNC tmpresolv;
  694. #ifdef GETHOSTBYNAME_R
  695. struct hostent he;
  696. char ghbuf[1024];
  697. #define gethostbyname(NAME) my_gethostbyname(NAME, ghbuf, &he)
  698. #endif
  699. if(strlen((char *)name)>255)name[255] = 0;
  700. for(i=0; name[i]; i++){
  701. if(name[i] == '.'){
  702. if(++ndots > 3) break;
  703. continue;
  704. }
  705. if(name[i] <'0' || name[i] >'9') break;
  706. }
  707. if(!name[i] && ndots == 3){
  708. if(scanaddr(name, &retval, NULL) == 4){
  709. return retval;
  710. }
  711. }
  712. if((tmpresolv=resolvfunc)){
  713. if((*tmpresolv)(AF_INET, name, (unsigned char *)&retval)) return retval;
  714. if(conf.demanddialprog) system(conf.demanddialprog);
  715. return (*tmpresolv)(AF_INET, name, (unsigned char *)&retval)?retval:0;
  716. }
  717. #if !defined(_WIN32) && !defined(GETHOSTBYNAME_R)
  718. if(!ghbn_init){
  719. pthread_mutex_init(&gethostbyname_mutex, NULL);
  720. ghbn_init++;
  721. }
  722. pthread_mutex_lock(&gethostbyname_mutex);
  723. #endif
  724. hp=gethostbyname((char *)name);
  725. if (!hp && conf.demanddialprog) {
  726. system(conf.demanddialprog);
  727. hp=gethostbyname((char *)name);
  728. }
  729. retval = hp?*(unsigned long *)hp->h_addr:0;
  730. #if !defined(_WIN32) && !defined(GETHOSTBYNAME_R)
  731. pthread_mutex_unlock(&gethostbyname_mutex);
  732. #endif
  733. #ifdef GETHOSTBYNAME_R
  734. #undef gethostbyname
  735. #endif
  736. return retval;
  737. }
  738. #endif
  739. unsigned long getip46(int family, unsigned char *name, struct sockaddr *sa){
  740. #ifndef NOIPV6
  741. int ndots=0, ncols=0, nhex=0;
  742. struct addrinfo *ai, hint;
  743. int i;
  744. RESOLVFUNC tmpresolv;
  745. if(!sa) return 0;
  746. if(!family) {
  747. family = 4;
  748. #else
  749. ((struct sockaddr_in *)sa)->sin_family = AF_INET;
  750. return (((struct sockaddr_in *)sa)->sin_addr.s_addr = getip(name))? AF_INET:0;
  751. #endif
  752. #ifndef NOIPV6
  753. }
  754. for(i=0; name[i]; i++){
  755. if(name[i] == '.'){
  756. if(++ndots > 3) {
  757. break;
  758. }
  759. }
  760. else if(name[i] == ':'){
  761. if(++ncols > 7) {
  762. break;
  763. }
  764. }
  765. else if(name[i] == '%' || (name[i] >= 'a' && name[i] <= 'f') || (name[i] >= 'A' && name[i] <= 'F')){
  766. nhex++;
  767. }
  768. else if(name[i] <'0' || name[i] >'9') {
  769. break;
  770. }
  771. }
  772. if(!name[i]){
  773. if(ndots == 3 && ncols == 0 && nhex == 0){
  774. *SAFAMILY(sa)=(family == 6)?AF_INET6 : AF_INET;
  775. return inet_pton(*SAFAMILY(sa), (char *)name, SAADDR(sa))? *SAFAMILY(sa) : 0;
  776. }
  777. if(ncols >= 2) {
  778. *SAFAMILY(sa)=AF_INET6;
  779. return inet_pton(AF_INET6, (char *)name, SAADDR(sa))?(family==4? 0:AF_INET6) : 0;
  780. }
  781. }
  782. if((tmpresolv = resolvfunc)){
  783. int f = (family == 6 || family == 64)?AF_INET6:AF_INET;
  784. *SAFAMILY(sa) = f;
  785. if(tmpresolv(f, name, SAADDR(sa))) return f;
  786. if(family == 4 || family == 6) return 0;
  787. f = (family == 46)? AF_INET6 : AF_INET;
  788. *SAFAMILY(sa) = f;
  789. if(tmpresolv(f, name, SAADDR(sa))) return f;
  790. return 0;
  791. }
  792. memset(&hint, 0, sizeof(hint));
  793. hint.ai_family = (family == 6 || family == 64)?AF_INET6:AF_INET;
  794. if (getaddrinfo((char *)name, NULL, &hint, &ai)) {
  795. if(family == 64 || family == 46){
  796. hint.ai_family = (family == 64)?AF_INET:AF_INET6;
  797. if (getaddrinfo((char *)name, NULL, &hint, &ai)) return 0;
  798. }
  799. else return 0;
  800. }
  801. if(ai){
  802. if(ai->ai_addr->sa_family == AF_INET || ai->ai_addr->sa_family == AF_INET6){
  803. *SAFAMILY(sa)=ai->ai_addr->sa_family;
  804. memcpy(SAADDR(sa), SAADDR(ai->ai_addr), SAADDRLEN(ai->ai_addr));
  805. freeaddrinfo(ai);
  806. return *SAFAMILY(sa);
  807. }
  808. freeaddrinfo(ai);
  809. }
  810. return 0;
  811. #endif
  812. }