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

源码开发语言/平台
当前位置：首页 > 源码/资料 > Internet/网络编程 > Telnet服务器 > 查看源码
inndchannel.c
资源名称：3.0-20000220-SNAP.tar.gz　[点击查看]
上传用户：minyiyu
上传日期：2018-12-24
资源大小：864k
文件大小：16k
源码类别：

Telnet服务器

开发平台：

Unix_Linux

inndchannel.c：源码内容
  1. #include "innbbsconf.h"
  2. #include "daemon.h"
  3. #include "bbslib.h"
  4. #include "version.h"
  6. #ifndef MAXCLIENT
  7. #define MAXCLIENT 10
  8. #endif
  10. #ifndef ChannelSize
  11. #define ChannelSize 4096
  12. #endif
  14. #ifndef ReadSize
  15. #define ReadSize 1024
  16. #endif
  18. #ifndef DefaultINNBBSPort
  19. #define DefaultINNBBSPort "7777"
  20. #endif
  22. #ifndef HIS_MAINT
  23. #define HIS_MAINT
  24. #define HIS_MAINT_HOUR 5
  25. #define HIS_MAINT_MIN  30
  26. #endif
  28. int     Maxclient = MAXCLIENT;
  29. ClientType *Channel = NULL;
  30. ClientType INNBBSD_STAT;
  32. int     Max_Art_Size = MAX_ART_SIZE;
  34. int     inetdstart = 0;
  36. int     Junkhistory = 0;
  38. char   *REMOTEUSERNAME, *REMOTEHOSTNAME;
  40. static fd_set rfd, wfd, efd, orfd, owfd, oefd;
  41. clearfdset(fd)
  42. int     fd;
  43. {
  44. FD_CLR(fd, &rfd);
  45. }
  47. static
  48. channelcreate(client)
  49. ClientType *client;
  50. {
  51. buffer_t *in, *out;
  52. in = &client->in;
  53. out = &client->out;
  54. if (in->data != NULL)
  55. free(in->data);
  56. in->data = (char *) mymalloc(ChannelSize);
  57. in->left = ChannelSize;
  58. in->used = 0;
  59. if (out->data != NULL)
  60. free(out->data);
  61. out->data = (char *) mymalloc(ChannelSize);
  62. out->used = 0;
  63. out->left = ChannelSize;
  64. client->ihavecount = 0;
  65. client->ihaveduplicate = 0;
  66. client->ihavefail = 0;
  67. client->ihavesize = 0;
  68. client->statcount = 0;
  69. client->statfail = 0;
  70. client->begin = time(NULL);
  71. client->filter_buffer = NULL;
  72. }
  73. channeldestroy(client)
  74. ClientType *client;
  75. {
  76. if (client->in.data != NULL) {
  77. free(client->in.data);
  78. client->in.data = NULL;
  79. }
  80. if (client->out.data != NULL) {
  81. free(client->out.data);
  82. client->out.data = NULL;
  83. }
  84. if (client->filter_buffer != NULL) {
  85. free(client->filter_buffer);
  86. client->filter_buffer = NULL;
  87. }
  88. #if !defined(PowerBBS) && !defined(DBZSERVER)
  89. if (client->ihavecount > 0 || client->statcount > 0) {
  90. bbslog("%s@%s rec: %d dup: %d fail: %d size: %d, stat rec: %d fail: %d, time sec: %dn",
  91. client->username, client->hostname, client->ihavecount,
  92. client->ihaveduplicate, client->ihavefail, client->ihavesize,
  93. client->statcount, client->statfail, time(NULL) - client->begin);
  94. INNBBSD_STAT.ihavecount += client->ihavecount;
  95. INNBBSD_STAT.ihaveduplicate += client->ihaveduplicate;
  96. INNBBSD_STAT.ihavefail += client->ihavefail;
  97. INNBBSD_STAT.ihavesize += client->ihavesize;
  98. INNBBSD_STAT.statcount += client->statcount;
  99. INNBBSD_STAT.statfail += client->statfail;
  100. }
  101. #endif
  102. }
  103. inndchannel(port, path)
  104. char   *port, *path;
  105. {
  106. time_t  tvec;
  107. int     i;
  108. int     bbsinnd;
  109. int     localbbsinnd;
  110. char    obuf[4096];
  111. struct timeval tout;
  112. ClientType *client = (ClientType *) mymalloc(sizeof(ClientType) * Maxclient);
  113. int     localdaemonready = 0;
  114. Channel = client;
  116. bbsinnd = pmain(port);
  117. if (bbsinnd < 0) {
  118. perror("pmain, existing");
  119. docompletehalt();
  120. return (-1);
  121. }
  122. FD_ZERO(&rfd);
  123. FD_ZERO(&wfd);
  124. FD_ZERO(&efd);
  126. localbbsinnd = p_unix_main(path);
  127. if (localbbsinnd < 0) {
  128. perror("local pmain, existing");
  129. if (!inetdstart)
  130. fprintf(stderr, "if no other innbbsd running, try to remove %sn", path);
  131. close(bbsinnd);
  132. return (-1);
  133. } else {
  134. FD_SET(localbbsinnd, &rfd);
  135. localdaemonready = 1;
  136. }
  138. FD_SET(bbsinnd, &rfd);
  139. tvec = time((time_t *) 0);
  140. for (i = 0; i < Maxclient; ++i) {
  141. client[i].fd = -1;
  142. client[i].access = 0;
  143. client[i].buffer[0] = '';
  144. client[i].mode = 0;
  145. client[i].in.left = 0;
  146. client[i].in.used = 0;
  147. client[i].in.data = NULL;
  148. client[i].out.left = 0;
  149. client[i].out.used = 0;
  150. client[i].out.data = NULL;
  151. client[i].midcheck = 1;
  152. }
  153. for (;;) {
  154. int     nsel, i;
  155. /*
  156.           When to maintain history files.
  157. */
  158. time_t  now;
  159. static int maint = 0;
  160. struct tm *local;
  161. if (INNBBSDshutdown()) {
  162. HISclose();
  163. bbslog(" Shutdown Complete n");
  164. docompletehalt();
  165. exit(0);
  166. }
  167. time(&now);
  168. local = localtime(&now);
  169. if (local != NULL & local->tm_hour == His_Maint_Hour &&
  170. local->tm_min >= His_Maint_Min) {
  171. if (!maint) {
  172. bbslog(":Maint: start (%d:%d).n", local->tm_hour, local->tm_min);
  173. HISmaint();
  174. time(&now);
  175. local = localtime(&now);
  176. if (local != NULL)
  177. bbslog(":Maint: end (%d:%d).n", local->tm_hour, local->tm_min);
  178. maint = 1;
  179. }
  180. } else {
  181. maint = 0;
  182. }
  183. /*
  184. */
  185. /*
  186. in order to maintain history, timeout every 60 seconds in case
  187. no connections
  188. */
  189. tout.tv_sec = 60;
  190. tout.tv_usec = 0;
  191. orfd = rfd;
  192. if ((nsel = select(FD_SETSIZE, &orfd, NULL, NULL, &tout)) < 0) {
  193. continue;
  194. }
  195. if (localdaemonready && FD_ISSET(localbbsinnd, &orfd)) {
  196. int     ns, length;
  197. int     cc;
  198. ns = tryaccept(localbbsinnd);
  199. if (ns < 0)
  200. continue;
  201. for (i = 0; i < Maxclient; ++i) {
  202. if (client[i].fd == -1)
  203. break;
  204. }
  205. if (i == Maxclient) {
  206. static char msg[] = "502 no free descriptorsrn";
  207. printf("%s", msg);
  208. write(ns, msg, sizeof(msg));
  209. close(ns);
  210. continue;
  211. }
  212. client[i].fd = ns;
  213. client[i].buffer[0] = '';
  214. client[i].mode = 0;
  215. client[i].midcheck = 1;
  216. channelcreate(&client[i]);
  217. FD_SET(ns, &rfd); /* FD_SET(ns,&wfd); */
  218. {
  219. strncpy(client[i].username, "localuser", 20);
  220. strncpy(client[i].hostname, "localhost", 128);
  221. client[i].Argv.in = fdopen(ns, "r");
  222. client[i].Argv.out = fdopen(ns, "w");
  223. #if !defined(PowerBBS) && !defined(DBZSERVER)
  224. bbslog("connected from (%s@%s).n", client[i].username, client[i].hostname);
  225. #endif
  226. #ifdef INNBBSDEBUG
  227. printf("connected from (%s@%s).n", client[i].username, client[i].hostname);
  228. #endif
  229. #ifdef DBZSERVER
  230. fprintf(client[i].Argv.out, "200 %s InterNetNews DBZSERVER server %s (%s@%s).rn", MYBBSID, VERSION, client[i].username, client[i].hostname);
  231. #else
  232. fprintf(client[i].Argv.out, "200 %s InterNetNews INNBBSD server %s (%s@%s).rn", MYBBSID, VERSION, client[i].username, client[i].hostname);
  233. #endif
  234. fflush(client[i].Argv.out);
  235. verboselog("UNIX Connect from %s@%sn", client[i].username, client[i].hostname);
  236. }
  237. }
  238. if (FD_ISSET(bbsinnd, &orfd)) {
  239. int     ns = tryaccept(bbsinnd), length;
  240. struct sockaddr_in there;
  241. char   *name;
  242. struct hostent *hp;
  243. int     cc;
  244. if (ns < 0)
  245. continue;
  246. for (i = 0; i < Maxclient; ++i) {
  247. if (client[i].fd == -1)
  248. break;
  249. }
  250. if (i == Maxclient) {
  251. static char msg[] = "502 no free descriptorsrn";
  252. printf("%s", msg);
  253. write(ns, msg, sizeof(msg));
  254. close(ns);
  255. continue;
  256. }
  257. client[i].fd = ns;
  258. client[i].buffer[0] = '';
  259. client[i].mode = 0;
  260. client[i].midcheck = 1;
  261. channelcreate(&client[i]);
  262. FD_SET(ns, &rfd); /* FD_SET(ns,&wfd); */
  263. length = sizeof(there);
  264. if (getpeername(ns, (struct sockaddr *) & there, &length) >= 0) {
  265. time_t  now = time((time_t *) 0);
  266. name = (char *) my_rfc931_name(ns, &there);
  267. strncpy(client[i].username, name, 20);
  268. hp = (struct hostent *) gethostbyaddr((char *) &there.sin_addr, sizeof(struct in_addr), there.sin_family);
  269. if (hp)
  270. strncpy(client[i].hostname, hp->h_name, 128);
  271. else
  272. strncpy(client[i].hostname, (char *) inet_ntoa(there.sin_addr), 128);
  274. client[i].Argv.in = fdopen(ns, "r");
  275. client[i].Argv.out = fdopen(ns, "w");
  276. if ((char *) search_nodelist(client[i].hostname, client[i].username) == NULL) {
  277. bbslog(":Err: invalid connection (%s@%s).n", client[i].username, client[i].hostname);
  278. fprintf(client[i].Argv.out, "502 You are not in my access file. (%s@%s)rn", client[i].username, client[i].hostname);
  279. fflush(client[i].Argv.out);
  280. fclose(client[i].Argv.in);
  281. fclose(client[i].Argv.out);
  282. close(client[i].fd);
  283. FD_CLR(client[i].fd, &rfd);
  284. client[i].fd = -1;
  285. continue;
  286. }
  287. bbslog("connected from (%s@%s).n", client[i].username, client[i].hostname);
  288. if (isPause()) {
  289. fprintf(client[i].Argv.out, "400 Server Paused. (%s@%s)rn", client[i].username, client[i].hostname);
  290. fflush(client[i].Argv.out);
  291. fclose(client[i].Argv.in);
  292. fclose(client[i].Argv.out);
  293. close(client[i].fd);
  294. FD_CLR(client[i].fd, &rfd);
  295. client[i].fd = -1;
  296. continue;
  297. }
  298. #ifdef INNBBSDEBUG
  299. printf("connected from (%s@%s).n", client[i].username, client[i].hostname);
  300. #endif
  301. #ifdef DBZSERVER
  302. fprintf(client[i].Argv.out, "200 %s InterNetNews DBZSERVER server %s (%s@%s).rn", MYBBSID, VERSION, client[i].username, client[i].hostname);
  303. #else
  304. fprintf(client[i].Argv.out, "200 %s InterNetNews INNBBSD server %s (%s@%s).rn", MYBBSID, VERSION, client[i].username, client[i].hostname);
  305. #endif
  306. fflush(client[i].Argv.out);
  307. verboselog("INET Connect from %s@%sn", client[i].username, client[i].hostname);
  308. } else {
  309. }
  311. }
  312. for (i = 0; i < Maxclient; ++i) {
  313. int     fd = client[i].fd;
  314. if (fd < 0) {
  315. continue;
  316. }
  317. if (FD_ISSET(fd, &orfd)) {
  318. int     nr;
  319. #ifdef DEBUG
  320. printf("before read i %d in.used %d in.left %dn", i, client[i].in.used, client[i].in.left);
  321. #endif
  322. nr = channelreader(client + i);
  323. #ifdef DEBUG
  324. printf("after read i %d in.used %d in.left %dn", i, client[i].in.used, client[i].in.left);
  325. #endif
  326. /* int nr=read(fd,client[i].buffer,1024); */
  327. if (nr <= 0) {
  328. FD_CLR(fd, &rfd);
  329. fclose(client[i].Argv.in);
  330. fclose(client[i].Argv.out);
  331. close(fd);
  332. client[i].fd = -1;
  333. channeldestroy(client + i);
  334. continue;
  335. }
  336. #ifdef DEBUG
  337. printf("nr %d %.*s", nr, nr, client[i].buffer);
  338. #endif
  339. if (client[i].access == 0) {
  340. continue;
  341. }
  342. }
  343. }
  344. }
  345. }
  347. int 
  348. channelreader(client)
  349. ClientType *client;
  350. {
  351. int     len, clientlen;
  352. char    buffer1[8192], buffer2[4096];
  353. char   *ptr;
  354. buffer_t *in = &client->in;
  355. if (in->left < ReadSize + 3) {
  356. int     need = in->used + in->left + ReadSize + 3;
  357. need += need / 5;
  358. in->data = (char *) myrealloc(in->data, need);
  359. in->left = need - in->used;
  360. verboselog("channelreader realloc %dn", need);
  361. }
  362. len = read(client->fd, in->data + in->used, ReadSize);
  364. if (len <= 0)
  365. return len;
  367. in->data[len + in->used] = '';
  368. in->lastread = len;
  369. #ifdef DEBUG
  370. printf("after read lastread %dn", in->lastread);
  371. printf("len %d client %dn", len, strlen(in->data + in->used));
  372. #endif
  374. REMOTEHOSTNAME = client->hostname;
  375. REMOTEUSERNAME = client->username;
  376. if (client->mode == 0) {
  377. if ((ptr = (char *) strchr(in->data, 'n')) != NULL) {
  378. if (in->data[0] != 'r')
  379. commandparse(client);
  380. }
  381. } else {
  382. commandparse(client);
  383. }
  384. return len;
  385. }
  386. commandparse(client)
  387. ClientType *client;
  388. {
  389. char   *ptr, *lastend;
  390. argv_t *Argv = &client->Argv;
  391. int     (*Main) ();
  392. char   *buffer = client->in.data;
  393. int     fd = client->fd;
  394. buffer_t *in = &client->in;
  395. int     dataused;
  396. int     dataleft;
  397. #ifdef DEBUG
  398. printf("%s %s buffer %s", client->username, client->hostname, buffer);
  399. #endif
  400. ptr = (char *) strchr(in->data + in->used, 'n');
  401. if (client->mode == 0) {
  402. if (ptr == NULL) {
  403. in->used += in->lastread;
  404. in->left -= in->lastread;
  405. return;
  406. } else {
  407. dataused = ptr - (in->data + in->used) + 1;
  408. dataleft = in->lastread - dataused;
  409. lastend = ptr + 1;
  410. }
  411. } else {
  412. if (in->used >= 5) {
  413. ptr = (char *) strstr(in->data + in->used - 5, "rn.rn");
  414. } else if (strncmp(in->data, ".rn", 3) == 0) {
  415. ptr = in->data;
  416. } else {
  417. ptr = (char *) strstr(in->data + in->used, "rn.rn");
  418. }
  419. if (ptr == NULL) {
  420. in->used += in->lastread;
  421. in->left -= in->lastread;
  422. return;
  423. } else {
  424. ptr[2] = '';
  425. if (strncmp(in->data, ".rn", 3) == 0)
  426. dataused = 3;
  427. else
  428. dataused = ptr - (in->data + in->used) + 5;
  429. dataleft = in->lastread - dataused;
  430. lastend = ptr + 5;
  431. verboselog("Get: %s@%s end of data . size %dn", client->username, client->hostname, in->used + dataused);
  432. client->ihavesize += in->used + dataused;
  433. }
  434. }
  435. if (client->mode == 0) {
  436. struct Daemoncmd *dp;
  437. Argv->argc = 0, Argv->argv = NULL,
  438. Argv->inputline = buffer;
  439. if (ptr != NULL)
  440. *ptr = '';
  441. verboselog("Get: %sn", Argv->inputline);
  442. Argv->argc = argify(in->data + in->used, &Argv->argv);
  443. if (ptr != NULL)
  444. *ptr = 'n';
  445. dp = (struct Daemoncmd *) searchcmd(Argv->argv[0]);
  446. Argv->dc = dp;
  447. if (Argv->dc) {
  448. #ifdef DEBUG
  449. printf("enter command %sn", Argv->argv[0]);
  450. #endif
  451. if (Argv->argc < dp->argc) {
  452. fprintf(Argv->out, "%d Usage: %srn", dp->errorcode, dp->usage);
  453. fflush(Argv->out);
  454. verboselog("Put: %d Usage: %sn", dp->errorcode, dp->usage);
  455. } else if (dp->argno != 0 && Argv->argc > dp->argno) {
  456. fprintf(Argv->out, "%d Usage: %srn", dp->errorcode, dp->usage);
  457. fflush(Argv->out);
  458. verboselog("Put: %d Usage: %sn", dp->errorcode, dp->usage);
  459. } else {
  460. Main = Argv->dc->main;
  461. if (Main) {
  462. fflush(stdout);
  463. (*Main) (client);
  464. }
  465. }
  466. } else {
  467. fprintf(Argv->out, "500 Syntax error or bad commandrn");
  468. fflush(Argv->out);
  469. verboselog("Put: 500 Syntax error or bad commandrn");
  470. }
  471. deargify(&Argv->argv);
  472. } else {
  473. if (Argv->dc) {
  474. #ifdef DEBUG
  475. printf("enter data moden");
  476. #endif
  477. Main = Argv->dc->main;
  478. if (Main) {
  479. fflush(stdout);
  480. (*Main) (client);
  481. }
  482. }
  483. }
  484. if (client->mode == 0) {
  485. if (dataleft > 0) {
  486. strncpy(in->data, lastend, dataleft);
  487. #ifdef INNBBSDEBUG
  488. printf("***** try to copy %x %x %d bytesn", in->data, lastend, dataleft);
  489. #endif
  490. } else {
  491. dataleft = 0;
  492. }
  493. in->left += in->used - dataleft;
  494. in->used = dataleft;
  495. }
  496. }
  497. do_command()
  498. {
  499. }
  501. void 
  502. dopipesig(s)
  503. int     s;
  504. {
  505. printf("catch sigpipen");
  506. signal(SIGPIPE, dopipesig);
  507. }
  509. int 
  510. standaloneinit(port)
  511. char   *port;
  512. {
  513. int     ndescriptors;
  514. FILE   *pf;
  515. char    pidfile[24];
  516. ndescriptors = getdtablesize();
  517. /*#ifndef NOFORK*/
  518. if (!inetdstart)
  519. if (fork())
  520. exit(0);
  521. /*#endif*/
  523. sprintf(pidfile, "/usr/tmp/innbbsd-%s.pid", port);
  524. if (!inetdstart)
  525. fprintf(stderr, "PID file is in %sn", pidfile);
  527. {
  528. int     s;
  529. for (s = 3; s < ndescriptors; s++)
  530. (void) close(s);
  531. }
  532. pf = fopen(pidfile, "w");
  533. if (pf != NULL) {
  534. fprintf(pf, "%dn", getpid());
  535. fclose(pf);
  536. }
  537. }
  539. extern char *optarg;
  540. extern int opterr, optind;
  541. innbbsusage(name)
  542. char   *name;
  543. {
  544. fprintf(stderr, "Usage: %s   [options] [port [path]]n", name);
  545. fprintf(stderr, "   -v   (verbose log)n");
  546. fprintf(stderr, "   -h|? (help)n");
  547. fprintf(stderr, "   -n   (not to use in core dbz)n");
  548. fprintf(stderr, "   -i   (start from inetd with wait option)n");
  549. fprintf(stderr, "   -c   connections  (maximum number of connections accepted)n");
  550. fprintf(stderr, "        default=%dn", Maxclient);
  551. fprintf(stderr, "   -j   (keep history of junk article, default=none)n");
  552. }
  555. #ifdef DEBUGNGSPLIT
  556. main()
  557. {
  558. char  **ngptr;
  559. char    buf[1024];
  560. gets(buf);
  561. ngptr = (char **) BNGsplit(buf);
  562. printf("line %sn", buf);
  563. while (*ngptr != NULL) {
  564. printf("%sn", *ngptr);
  565. ngptr++;
  566. }
  567. }
  568. #endif
  570. static time_t INNBBSDstartup;
  571. innbbsdstartup()
  572. {
  573. return INNBBSDstartup;
  574. }
  575. main(argc, argv)
  576. int     argc;
  577. char  **argv;
  578. {
  580. char   *port, *path;
  581. int     c, errflag = 0;
  582. extern  INNBBSDhalt();
  583. #if !defined(DBZSERVER)
  584. initial_lang();
  585. #endif
  587. port = DefaultINNBBSPort;
  588. path = LOCALDAEMON;
  589. Junkhistory = 0;
  591. time(&INNBBSDstartup);
  592. openlog("innbbsd", LOG_PID | LOG_ODELAY, LOG_DAEMON);
  593. while ((c = getopt(argc, argv, "c:f:s:vhidn?j")) != -1)
  594. switch (c) {
  595. case 'j':
  596. Junkhistory = 1;
  597. break;
  598. case 'v':
  599. verboseon("innbbsd.log");
  600. break;
  601. case 'n':
  602. hisincore(0);
  603. break;
  604. case 'c':
  605. Maxclient = atoi(optarg);
  606. if (Maxclient < 0)
  607. Maxclient = 0;
  608. break;
  609. case 'i':{
  610. struct sockaddr_in there;
  611. int     len = sizeof(there);
  612. int     rel;
  613. if ((rel = getsockname(0, (struct sockaddr *) & there, &len)) < 0) {
  614. fprintf(stdout, "You must run -i from inetd with inetd.conf line: n");
  615. fprintf(stdout, "service-port stream  tcp wait  bbs  /home/bbs/innbbsd innbbsd -i portn");
  616. fflush(stdout);
  617. exit(5);
  618. }
  619. inetdstart = 1;
  620. startfrominetd(1);
  621. }
  622. break;
  623. case 'd':
  624. dbzdebug(1);
  625. break;
  626. case 's':
  627. Max_Art_Size = atol(optarg);
  628. if (Max_Art_Size < 0)
  629. Max_Art_Size = 0;
  630. break;
  631. case 'h':
  632. case '?':
  633. default:
  634. errflag++;
  635. }
  636. if (errflag > 0) {
  637. innbbsusage(argv[0]);
  638. return (1);
  639. }
  640. if (argc - optind >= 1) {
  641. port = argv[optind];
  642. }
  643. if (argc - optind >= 2) {
  644. path = argv[optind + 1];
  645. }
  646. standaloneinit(port);
  648. initial_bbs("feed");
  650. if (!inetdstart)
  651. fprintf(stderr, "Try to listen in port %s and path %sn", port, path);
  653. HISmaint();
  654. HISsetup();
  655. installinnbbsd();
  656. sethaltfunction(INNBBSDhalt);
  658. signal(SIGPIPE, dopipesig);
  659. inndchannel(port, path);
  660. HISclose();
  661. }