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

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

Telnet服务器

开发平台：

Unix_Linux

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