summaryrefslogtreecommitdiffstats
path: root/innbbsd/bbsnnrp.c
diff options
context:
space:
mode:
Diffstat (limited to 'innbbsd/bbsnnrp.c')
-rw-r--r--innbbsd/bbsnnrp.c2020
1 files changed, 1030 insertions, 990 deletions
diff --git a/innbbsd/bbsnnrp.c b/innbbsd/bbsnnrp.c
index 6682f7ba..fadafe72 100644
--- a/innbbsd/bbsnnrp.c
+++ b/innbbsd/bbsnnrp.c
@@ -1,32 +1,29 @@
/*
- Usage: bbsnnrp [options] nntpserver activefile
- -h|? (help)
- -v (verbose protocol transactions)
- -c (reset active files only; don't receive articles)
- -r remotehost(send articles to remotehost, default=local)
- -p port|(send articles to remotehost at port, default=7777)
- path(send articles to local at path, default=~bbs/innd/.innbbsd)
- -n (don't ask innbbsd server and stat articles)
- -w seconds (wait for seconds and run infinitely, default=once)
- -a max_art (maximum number of articles received for a group each time)
- -s max_stat(maximum number of articles stated for a group each time)
- -t stdin|nntp (default=nntp)
-*/
+ * Usage: bbsnnrp [options] nntpserver activefile -h|? (help) -v (verbose
+ * protocol transactions) -c (reset active files only; don't receive
+ * articles) -r remotehost(send articles to remotehost, default=local) -p
+ * port|(send articles to remotehost at port, default=7777) path(send
+ * articles to local at path, default=~bbs/innd/.innbbsd) -n (don't ask
+ * innbbsd server and stat articles) -w seconds (wait for seconds and run
+ * infinitely, default=once) -a max_art (maximum number of articles received
+ * for a group each time) -s max_stat(maximum number of articles stated for a
+ * group each time) -t stdin|nntp (default=nntp)
+ */
#include "innbbsconf.h"
#include <sys/mman.h>
#ifndef AIX
-# include <sys/fcntl.h>
+#include <sys/fcntl.h>
#endif
#include "bbslib.h"
#include "daemon.h"
#include "nntp.h"
#ifndef MAX_ARTS
-# define MAX_ARTS 100
+#define MAX_ARTS 100
#endif
#ifndef MAX_STATS
-# define MAX_STATS 1000
+#define MAX_STATS 1000
#endif
#if defined(__linux)
@@ -35,35 +32,35 @@
#define USE_MMAP
#endif
-int Max_Arts= MAX_ARTS;
-int Max_Stats = MAX_STATS;
+int Max_Arts = MAX_ARTS;
+int Max_Stats = MAX_STATS;
typedef struct NEWSRC_T {
- char *nameptr, *lowptr, *highptr, *modeptr;
- int namelen, lowlen, highlen;
- ULONG low, high;
- int mode, subscribe;
-} newsrc_t;
+ char *nameptr, *lowptr, *highptr, *modeptr;
+ int namelen, lowlen, highlen;
+ ULONG low, high;
+ int mode, subscribe;
+} newsrc_t;
typedef struct NNRP_T {
- int nnrpfd;
- int innbbsfd;
- FILE *nnrpin, *nnrpout;
- FILE *innbbsin, *innbbsout;
- char activefile[MAXPATHLEN];
- char rcfile[MAXPATHLEN];
- newsrc_t *newsrc;
- char *actpointer, *actend;
- int actsize, actfd, actdirty;
-} nnrp_t;
+ int nnrpfd;
+ int innbbsfd;
+ FILE *nnrpin, *nnrpout;
+ FILE *innbbsin, *innbbsout;
+ char activefile[MAXPATHLEN];
+ char rcfile[MAXPATHLEN];
+ newsrc_t *newsrc;
+ char *actpointer, *actend;
+ int actsize, actfd, actdirty;
+} nnrp_t;
typedef struct XHDR_T {
- char *header;
- ULONG artno;
-} xhdr_t;
+ char *header;
+ ULONG artno;
+} xhdr_t;
-xhdr_t XHDR[MAX_ARTS];
-char LockFile[1024];
+xhdr_t XHDR[MAX_ARTS];
+char LockFile[1024];
#define NNRPGroupOK NNTP_GROUPOK_VAL
#define NNRPXhdrOK NNTP_HEAD_FOLLOWS_VAL
@@ -74,85 +71,86 @@ char LockFile[1024];
#define NNRPstatOK NNTP_NOTHING_FOLLOWS_VAL
#define INNBBSconnectOK NNTP_POSTOK_VAL
-nnrp_t BBSNNRP;
+nnrp_t BBSNNRP;
-void doterm(s)
-int s;
+void
+doterm(s)
+ int s;
{
- printf("bbsnnrp terminated. Signal %d\n", s);
- writerc(&BBSNNRP);
- if (isfile(LockFile))
- unlink(LockFile);
- exit(1);
+ printf("bbsnnrp terminated. Signal %d\n", s);
+ writerc(&BBSNNRP);
+ if (isfile(LockFile))
+ unlink(LockFile);
+ exit(1);
}
-extern char *optarg;
-extern int opterr, optind;
+extern char *optarg;
+extern int opterr, optind;
#ifndef MIN_WAIT
-# define MIN_WAIT 60
+#define MIN_WAIT 60
#endif
-int ResetActive = 0;
-int StatHistory = 1;
-int AskLocal = 1;
-int RunOnce = 1;
+int ResetActive = 0;
+int StatHistory = 1;
+int AskLocal = 1;
+int RunOnce = 1;
-int DefaultWait = MIN_WAIT;
+int DefaultWait = MIN_WAIT;
-char *DefaultPort = DefaultINNBBSPort;
-char *DefaultPath = LOCALDAEMON;
-char *DefaultRemoteHost;
+char *DefaultPort = DefaultINNBBSPort;
+char *DefaultPath = LOCALDAEMON;
+char *DefaultRemoteHost;
#ifndef MAXBUFLEN
#define MAXBUFLEN 256
#endif
-char DefaultNewsgroups[MAXBUFLEN];
-char DefaultOrganization[MAXBUFLEN];
-char DefaultModerator[MAXBUFLEN];
-char DefaultTrustfrom[MAXBUFLEN];
-char DefaultTrustFrom[MAXBUFLEN];
+char DefaultNewsgroups[MAXBUFLEN];
+char DefaultOrganization[MAXBUFLEN];
+char DefaultModerator[MAXBUFLEN];
+char DefaultTrustfrom[MAXBUFLEN];
+char DefaultTrustFrom[MAXBUFLEN];
usage(arg)
-char *arg;
+ char *arg;
{
-fprintf(stderr,"Usage: %s [options] nntpserver activefile\n", arg);
-fprintf(stderr," -h|? (help) \n");
-fprintf(stderr," -v (verbose protocol transactions)\n");
-fprintf(stderr," -c (reset active files only; don't receive articles)\n");
-fprintf(stderr," -r [proto:]remotehost\n");
-fprintf(stderr," (send articles to remotehost, default=ihave:local)\n");
-fprintf(stderr," -p port|(send articles to remotehost at port, default=%s)\n",DefaultINNBBSPort);
-fprintf(stderr," path(send articles to local at path, default=~bbs/innd/.innbbsd)\n");
-fprintf(stderr," -w seconds ( > 1 wait for seconds and run infinitely, default=once)\n");
-fprintf(stderr," -n (don't ask innbbsd server and stat articles)\n");
-fprintf(stderr," -a max_art(maximum number of articles received for a group each time)\n");
-fprintf(stderr," default=%d\n", MAX_ARTS);
-fprintf(stderr," -s max_stat(maximum number of articles stated for a group each time)\n");
-fprintf(stderr," default=%d\n", MAX_STATS);
-fprintf(stderr," -t stdin|nntp (default=nntp)\n");
-fprintf(stderr," -g newsgroups\n");
-fprintf(stderr," -m moderator\n");
-fprintf(stderr," -o organization\n");
-fprintf(stderr," -f trust_user (From: trust_user)\n");
-fprintf(stderr," -F trust_user (From trust_user)\n");
-fprintf(stderr," Please E-mail bug to skhuang@csie.nctu.edu.tw or\n");
-fprintf(stderr," post to tw.bbs.admin.installbbs\n");
+ fprintf(stderr, "Usage: %s [options] nntpserver activefile\n", arg);
+ fprintf(stderr, " -h|? (help) \n");
+ fprintf(stderr, " -v (verbose protocol transactions)\n");
+ fprintf(stderr, " -c (reset active files only; don't receive articles)\n");
+ fprintf(stderr, " -r [proto:]remotehost\n");
+ fprintf(stderr, " (send articles to remotehost, default=ihave:local)\n");
+ fprintf(stderr, " -p port|(send articles to remotehost at port, default=%s)\n", DefaultINNBBSPort);
+ fprintf(stderr, " path(send articles to local at path, default=~bbs/innd/.innbbsd)\n");
+ fprintf(stderr, " -w seconds ( > 1 wait for seconds and run infinitely, default=once)\n");
+ fprintf(stderr, " -n (don't ask innbbsd server and stat articles)\n");
+ fprintf(stderr, " -a max_art(maximum number of articles received for a group each time)\n");
+ fprintf(stderr, " default=%d\n", MAX_ARTS);
+ fprintf(stderr, " -s max_stat(maximum number of articles stated for a group each time)\n");
+ fprintf(stderr, " default=%d\n", MAX_STATS);
+ fprintf(stderr, " -t stdin|nntp (default=nntp)\n");
+ fprintf(stderr, " -g newsgroups\n");
+ fprintf(stderr, " -m moderator\n");
+ fprintf(stderr, " -o organization\n");
+ fprintf(stderr, " -f trust_user (From: trust_user)\n");
+ fprintf(stderr, " -F trust_user (From trust_user)\n");
+ fprintf(stderr, " Please E-mail bug to skhuang@csie.nctu.edu.tw or\n");
+ fprintf(stderr, " post to tw.bbs.admin.installbbs\n");
}
-static char *StdinInputType="stdin";
-static char *NntpInputType="nntp";
-static char *NntpIhaveProtocol="ihave";
-static char *NntpPostProtocol="post";
-static char *DefaultNntpProtocol ;
+static char *StdinInputType = "stdin";
+static char *NntpInputType = "nntp";
+static char *NntpIhaveProtocol = "ihave";
+static char *NntpPostProtocol = "post";
+static char *DefaultNntpProtocol;
main(argc, argv)
-int argc;
-char **argv;
+ int argc;
+ char **argv;
{
- char *ptr, *server, *active;
- int c, errflag=0;
- int lockfd;
- char *inputtype;
+ char *ptr, *server, *active;
+ int c, errflag = 0;
+ int lockfd;
+ char *inputtype;
DefaultNntpProtocol = NntpIhaveProtocol;
*DefaultNewsgroups = '\0';
@@ -161,1032 +159,1074 @@ char **argv;
*DefaultTrustFrom = '\0';
*DefaultTrustfrom = '\0';
inputtype = NntpInputType;
- while ((c = getopt(argc,argv,"f:F:m:o:g:w:r:p:a:s:t:h?ncv"))!= -1)
- switch (c) {
- case 'v':
- verboseon("bbsnnrp.log");
- break;
- case 'c':
- ResetActive = 1;
- break;
- case 'g':
- strncpy(DefaultNewsgroups, optarg, sizeof DefaultNewsgroups);
- break;
- case 'm':
- strncpy(DefaultModerator, optarg, sizeof DefaultModerator);
- break;
- case 'o':
- strncpy(DefaultOrganization, optarg, sizeof DefaultOrganization);
- break;
- case 'f':
- strncpy(DefaultTrustfrom, optarg, sizeof DefaultTrustfrom);
- break;
- case 'F':
- strncpy(DefaultTrustFrom, optarg, sizeof DefaultTrustFrom);
- break;
- case 'r': {
- char *hostptr;
- AskLocal = 0;
- DefaultRemoteHost = optarg;
- if ((hostptr = strchr(optarg,':')) != NULL) {
- *hostptr = '\0';
- DefaultRemoteHost = hostptr+1;
- if (strcasecmp( optarg, "post" ) == 0)
- DefaultNntpProtocol = NntpPostProtocol;
- *hostptr = ':';
- }
- break;
- }
- case 'w':
- RunOnce = 0;
- DefaultWait = atoi(optarg);
- if (DefaultWait < MIN_WAIT)
- DefaultWait = MIN_WAIT;
- break;
- case 'p':
- if (AskLocal == 0) {
- DefaultPort = optarg;
- } else {
- DefaultPath = optarg;
- }
- break;
- case 'n':
- StatHistory = 0;
- break;
- case 'a':
- Max_Arts = atol(optarg);
- if (Max_Arts < 0) Max_Arts = 0;
- break;
- case 's':
- Max_Stats = atol(optarg);
- if (Max_Stats < 0) Max_Stats = 0;
- break;
- case 't':
- if ( strcasecmp(optarg,StdinInputType) == 0) {
- inputtype = StdinInputType;
- }
- break;
- case 'h':
- case '?':
- default:
- errflag ++;
- }
+ while ((c = getopt(argc, argv, "f:F:m:o:g:w:r:p:a:s:t:h?ncv")) != -1)
+ switch (c) {
+ case 'v':
+ verboseon("bbsnnrp.log");
+ break;
+ case 'c':
+ ResetActive = 1;
+ break;
+ case 'g':
+ strncpy(DefaultNewsgroups, optarg, sizeof DefaultNewsgroups);
+ break;
+ case 'm':
+ strncpy(DefaultModerator, optarg, sizeof DefaultModerator);
+ break;
+ case 'o':
+ strncpy(DefaultOrganization, optarg, sizeof DefaultOrganization);
+ break;
+ case 'f':
+ strncpy(DefaultTrustfrom, optarg, sizeof DefaultTrustfrom);
+ break;
+ case 'F':
+ strncpy(DefaultTrustFrom, optarg, sizeof DefaultTrustFrom);
+ break;
+ case 'r':{
+ char *hostptr;
+ AskLocal = 0;
+ DefaultRemoteHost = optarg;
+ if ((hostptr = strchr(optarg, ':')) != NULL) {
+ *hostptr = '\0';
+ DefaultRemoteHost = hostptr + 1;
+ if (strcasecmp(optarg, "post") == 0)
+ DefaultNntpProtocol = NntpPostProtocol;
+ *hostptr = ':';
+ }
+ break;
+ }
+ case 'w':
+ RunOnce = 0;
+ DefaultWait = atoi(optarg);
+ if (DefaultWait < MIN_WAIT)
+ DefaultWait = MIN_WAIT;
+ break;
+ case 'p':
+ if (AskLocal == 0) {
+ DefaultPort = optarg;
+ } else {
+ DefaultPath = optarg;
+ }
+ break;
+ case 'n':
+ StatHistory = 0;
+ break;
+ case 'a':
+ Max_Arts = atol(optarg);
+ if (Max_Arts < 0)
+ Max_Arts = 0;
+ break;
+ case 's':
+ Max_Stats = atol(optarg);
+ if (Max_Stats < 0)
+ Max_Stats = 0;
+ break;
+ case 't':
+ if (strcasecmp(optarg, StdinInputType) == 0) {
+ inputtype = StdinInputType;
+ }
+ break;
+ case 'h':
+ case '?':
+ default:
+ errflag++;
+ }
if (errflag > 0) {
- usage(argv[0]);
- return(1);
+ usage(argv[0]);
+ return (1);
}
if (inputtype == NntpInputType && argc - optind < 2) {
- usage(argv[0]);
- exit(1);
+ usage(argv[0]);
+ exit(1);
}
if (inputtype == NntpInputType) {
- server = argv[optind];
- active = argv[optind+1];
- if ( isfile(active) ) {
- strncpy(BBSNNRP.activefile, active, sizeof BBSNNRP.activefile);
- } else if ( strchr(active,'/') == NULL) {
- sprintf(BBSNNRP.activefile, "%s/innd/%.*s",BBSHOME, sizeof BBSNNRP.activefile - 7 - strlen(BBSHOME), active);
- } else {
- strncpy(BBSNNRP.activefile, active, sizeof BBSNNRP.activefile);
- }
+ server = argv[optind];
+ active = argv[optind + 1];
+ if (isfile(active)) {
+ strncpy(BBSNNRP.activefile, active, sizeof BBSNNRP.activefile);
+ } else if (strchr(active, '/') == NULL) {
+ sprintf(BBSNNRP.activefile, "%s/innd/%.*s", BBSHOME, sizeof BBSNNRP.activefile - 7 - strlen(BBSHOME), active);
+ } else {
+ strncpy(BBSNNRP.activefile, active, sizeof BBSNNRP.activefile);
+ }
- strncpy(LockFile , (char*)fileglue("%s.lock",active), sizeof LockFile);
- if ((lockfd = open(LockFile, O_RDONLY)) >= 0) {
- char buf[10];
- int pid;
+ strncpy(LockFile, (char *)fileglue("%s.lock", active), sizeof LockFile);
+ if ((lockfd = open(LockFile, O_RDONLY)) >= 0) {
+ char buf[10];
+ int pid;
- if (read(lockfd, buf, sizeof buf) > 0 && (pid = atoi(buf))>0 && kill(pid,0)==0) {
- fprintf(stderr, "another process [%d] running\n", pid);
- exit(1);
- } else {
- fprintf(stderr, "no process [%d] running, but lock file existed, unlinked\n", pid);
+ if (read(lockfd, buf, sizeof buf) > 0 && (pid = atoi(buf)) > 0 && kill(pid, 0) == 0) {
+ fprintf(stderr, "another process [%d] running\n", pid);
+ exit(1);
+ } else {
+ fprintf(stderr, "no process [%d] running, but lock file existed, unlinked\n", pid);
+ unlink(LockFile);
+ }
+ close(lockfd);
+ }
+ if ((lockfd = open(LockFile, O_RDWR | O_CREAT | O_EXCL, 0644)) < 0) {
+ fprintf(stderr, "maybe another %s process running\n", argv[0]);
+ exit(1);
+ } else {
+ char buf[10];
+ int pid;
+ sprintf(buf, "%-.8d\n", getpid());
+ write(lockfd, buf, strlen(buf));
+ close(lockfd);
+ }
+ for (;;) {
+ if (!initial_bbs(NULL)) {
+ fprintf(stderr, "Initial BBS failed\n");
+ exit(1);
+ }
+ initsockets(server, &BBSNNRP, inputtype);
+ ptr = (char *)strrchr(active, '/');
+ if (ptr != NULL)
+ ptr++;
+ else
+ ptr = active;
+ sprintf(BBSNNRP.rcfile, "%s/.newsrc.%s.%s", INNDHOME, server, ptr);
+ initrcfiles(&BBSNNRP);
+
+ signal(SIGTERM, doterm);
+ signal(SIGKILL, doterm);
+ signal(SIGHUP, doterm);
+ signal(SIGPIPE, doterm);
+
+ readnews(server, &BBSNNRP);
+ writerc(&BBSNNRP);
+ closesockets();
+
+ if (RunOnce)
+ break;
+ sleep(DefaultWait);
+ }
unlink(LockFile);
- }
- close(lockfd);
- }
- if ((lockfd = open(LockFile, O_RDWR|O_CREAT|O_EXCL,0644)) < 0) {
- fprintf( stderr, "maybe another %s process running\n",argv[0]);
- exit(1);
- } else {
- char buf[10];
- int pid;
- sprintf(buf,"%-.8d\n",getpid());
- write(lockfd, buf, strlen(buf));
- close(lockfd);
- }
- for (;;) {
- if (!initial_bbs(NULL)) {
- fprintf(stderr, "Initial BBS failed\n");
- exit(1);
- }
- initsockets(server, &BBSNNRP, inputtype);
- ptr = (char*)strrchr(active,'/');
- if (ptr != NULL)
- ptr++;
- else
- ptr = active;
- sprintf(BBSNNRP.rcfile,"%s/.newsrc.%s.%s",INNDHOME, server, ptr);
- initrcfiles(&BBSNNRP);
-
- signal(SIGTERM, doterm);
- signal(SIGKILL, doterm);
- signal(SIGHUP, doterm);
- signal(SIGPIPE, doterm);
-
- readnews(server, &BBSNNRP);
- writerc(&BBSNNRP);
- closesockets();
-
- if (RunOnce) break;
- sleep(DefaultWait);
- }
- unlink(LockFile);
- } /* NntpInputType */
+ }
+ /* NntpInputType */
else {
- if (!initial_bbs(NULL)) {
- fprintf(stderr, "Initial BBS failed\n");
- exit(1);
- }
- initsockets(server, &BBSNNRP, inputtype);
- signal(SIGTERM, doterm);
- signal(SIGKILL, doterm);
- signal(SIGHUP, doterm);
- signal(SIGPIPE, doterm);
-
- stdinreadnews(&BBSNNRP);
- closesockets();
- } /* stdin input type */
+ if (!initial_bbs(NULL)) {
+ fprintf(stderr, "Initial BBS failed\n");
+ exit(1);
+ }
+ initsockets(server, &BBSNNRP, inputtype);
+ signal(SIGTERM, doterm);
+ signal(SIGKILL, doterm);
+ signal(SIGHUP, doterm);
+ signal(SIGPIPE, doterm);
+
+ stdinreadnews(&BBSNNRP);
+ closesockets();
+ } /* stdin input type */
return 0;
}
headbegin(buffer)
-char *buffer;
+ char *buffer;
{
- if (strncmp(buffer,"Path: ",6)==0 ) {
- if (strchr(buffer+6,'!') != NULL)
- return 1;
- }
- if (strncmp(buffer,"From ",5)== 0 ) {
- if (strchr(buffer+5,':') != NULL)
- return 1;
- }
- return 0;
+ if (strncmp(buffer, "Path: ", 6) == 0) {
+ if (strchr(buffer + 6, '!') != NULL)
+ return 1;
+ }
+ if (strncmp(buffer, "From ", 5) == 0) {
+ if (strchr(buffer + 5, ':') != NULL)
+ return 1;
+ }
+ return 0;
}
stdinreadnews(bbsnnrp)
-nnrp_t *bbsnnrp;
+ nnrp_t *bbsnnrp;
{
- int i;
- char buffer[4096];
- ULONG low, high;
- char tmpfilename[MAXPATHLEN];
- FILE *tmpfp = NULL;
- char mid[1024];
- int pathagain;
- int ngmet, submet, midmet, pathmet, orgmet, approvedmet;
- int discard;
- char sending_path[MAXPATHLEN];
- int sending_path_len=0;
-
- strncpy(tmpfilename,(char*)fileglue("/tmp/bbsnnrp-stdin-%d-%d",getuid(),getpid()),sizeof tmpfilename);
- fgets(buffer, sizeof buffer, bbsnnrp->innbbsin);
- verboselog("innbbsGet: %s", buffer);
- if (atoi(buffer) != INNBBSconnectOK) {
- fprintf(stderr, "INNBBS server not OK\n");
- return;
- }
-
- if ( DefaultNntpProtocol == NntpPostProtocol ) {
- fputs("MODE READER\r\n", bbsnnrp->innbbsout);
- fflush(bbsnnrp->innbbsout);
- verboselog("innbbsPut: MODE READER\n");
- fgets(buffer, sizeof buffer, bbsnnrp->innbbsin);
- verboselog("innbbsGet: %s",buffer);
- }
-
- if (StatHistory == 0) {
- fputs("MIDCHECK OFF\r\n", bbsnnrp->innbbsout);
- fflush(bbsnnrp->innbbsout);
- verboselog("innbbsPut: MIDCHECK OFF\n");
- fgets(buffer, sizeof buffer, bbsnnrp->innbbsin);
- verboselog("innbbsGet: %s",buffer);
- }
- tmpfp = fopen(tmpfilename,"w");
- if (tmpfp == NULL) return;
- *mid = '\0';
- for (;;) {
- fprintf(stderr,"Try to read from stdin ...\n");
- ngmet = 0, submet = 0, midmet = 0, pathmet = 0, orgmet = 0, approvedmet=0;
- discard = 0;
- while (fgets(buffer, sizeof buffer, stdin) != NULL) {
- char *tmpptr;
- tmpptr = strchr(buffer,'\n');
- if (tmpptr != NULL) *tmpptr = '\0';
- if (strncasecmp(buffer,"Message-ID: ",12)==0) {
- strncpy(mid, buffer+12,sizeof mid);
- midmet = 1;
- } else if (strncmp(buffer,"Subject: ",9)==0) {
- submet = 1;
- } else if (strncmp(buffer,"Path: ",6)==0) {
- pathmet = 1;
- } else if (strncmp(buffer,"Organization: ",14)==0) {
- orgmet = 1;
- } else if (strncmp(buffer,"Approved: ",10) == 0) {
- approvedmet = 1;
- } else if (strncmp(buffer,"From: ",6)==0 && *DefaultTrustfrom ) {
- if (strstr(buffer+6, DefaultTrustfrom)==NULL) {
- discard = 1;
- verboselog("Discard: %s for %s",buffer, DefaultTrustfrom);
- }
- } else if (strncmp(buffer,"From ",5)==0 && *DefaultTrustFrom ) {
- if (strstr(buffer+5, DefaultTrustFrom)==NULL) {
- discard = 1;
- verboselog("Discard: %s for %s",buffer, DefaultTrustFrom);
- }
- } else if (strncmp(buffer,"Received: ",10)==0) {
- char *rptr=buffer+10, *rrptr;
- int savech, len;
- if (strncmp(buffer+10,"from ",5)==0) {
- rptr +=5;
- rrptr = strchr(rptr,'(');
- if (rrptr != NULL) rptr = rrptr + 1;
- rrptr = strchr(rptr,' ');
- savech = *rrptr;
- if (rrptr != NULL) *rrptr = '\0';
- } else if (strncmp(buffer+10,"(from ",6)==0) {
- rptr +=6;
- rrptr = strchr(rptr,')');
- savech = *rrptr;
- if (rrptr != NULL) *rrptr = '\0';
- }
- len = strlen(rptr) +1;
- if (*rptr && sending_path_len + len < sizeof(sending_path)) {
- if (*sending_path)
- strcat(sending_path, "!");
- strcat(sending_path, rptr);
- sending_path_len += len ;
- }
- if (rrptr != NULL) *rrptr = savech;
- }
-
- if (strncmp(buffer,"Newsgroups: ",12)==0) {
- if (*DefaultNewsgroups){
- fprintf(tmpfp,"Newsgroups: %s\r\n",DefaultNewsgroups);
- } else {
- fprintf(tmpfp,"%s\r\n",buffer);
- }
- ngmet = 1;
- } else {
- if (buffer[0] == '\0') {
- if (!ngmet && *DefaultNewsgroups) {
- fprintf(tmpfp,"Newsgroups: %s\r\n",DefaultNewsgroups);
- }
- if (!submet) {
- fprintf(tmpfp,"Subject: (no subject)\r\n");
- }
- if (!pathmet) {
- fprintf(tmpfp,"Path: from-mail\r\n");
- }
- if (!midmet) {
- static int seed;
- time_t now;
- time(&now);
- fprintf(tmpfp,"Message-ID: <%d@%d.%d.%d>\r\n",now,getpid(), getuid(), seed);
- sprintf(mid, "<%d@%d.%d.%d>", now, getpid(), getuid(), seed);
- seed++;
- }
- if (!orgmet && *DefaultOrganization) {
- fprintf(tmpfp,"Organization: %s\r\n", DefaultOrganization);
- }
- if (!approvedmet && *DefaultModerator) {
- fprintf(tmpfp,"Approved: %s\r\n", DefaultModerator);
- }
- }
- if (strncmp(buffer,"From ",5) != 0 && strncmp(buffer,"To: ",4) !=0) {
- if (buffer[0] == '\0') {
- if (*sending_path) {
- fprintf(tmpfp,"X-Sending-Path: %s\r\n",sending_path);
- }
- }
- fprintf(tmpfp,"%s\r\n",buffer);
- }
- }
- if (buffer[0]=='\0') break;
- }
- fprintf(stderr,"Article Body begin ...\n");
- pathagain = 0;
- while (fgets(buffer, sizeof buffer, stdin) != NULL) {
- char *tmpptr;
- tmpptr = strchr(buffer,'\n');
- if (tmpptr != NULL) *tmpptr = '\0';
- if ( headbegin(buffer) ) {
- FILE *oldfp = bbsnnrp->nnrpin;
- pathagain = 1;
- fputs(".\r\n",tmpfp);
- fclose(tmpfp);
- fprintf(stderr,"Try to post ...\n");
- tmpfp = fopen(tmpfilename,"r");
- bbsnnrp->nnrpin = tmpfp;
- if (!discard)
- if (INNBBSihave(bbsnnrp, -1, mid)== -1) {
- fprintf(stderr,"post failed\n");
- }
- bbsnnrp->nnrpin = oldfp;
- fclose(tmpfp);
- *mid = '\0';
- tmpfp = fopen(tmpfilename,"w");
- fprintf(tmpfp,"%s\r\n",buffer);
- break;
- } else {
- fprintf(tmpfp,"%s\r\n",buffer);
- }
- }
- if (!pathagain) break;
- }
- if (!pathagain && tmpfp) {
- FILE *oldfp = bbsnnrp->nnrpin;
- fputs(".\r\n",tmpfp);
- fclose(tmpfp);
- fprintf(stderr,"Try to post ...\n");
- tmpfp = fopen(tmpfilename,"r");
- bbsnnrp->nnrpin = tmpfp;
- if (!discard)
- if (INNBBSihave(bbsnnrp, -1, mid)== -1) {
- fprintf(stderr,"post failed\n");
- }
- bbsnnrp->nnrpin = oldfp;
- fclose(tmpfp);
- }
- if (isfile(tmpfilename)) {
- unlink(tmpfilename);
- }
+ int i;
+ char buffer[4096];
+ ULONG low, high;
+ char tmpfilename[MAXPATHLEN];
+ FILE *tmpfp = NULL;
+ char mid[1024];
+ int pathagain;
+ int ngmet, submet, midmet, pathmet, orgmet, approvedmet;
+ int discard;
+ char sending_path[MAXPATHLEN];
+ int sending_path_len = 0;
+
+ strncpy(tmpfilename, (char *)fileglue("/tmp/bbsnnrp-stdin-%d-%d", getuid(), getpid()), sizeof tmpfilename);
+ fgets(buffer, sizeof buffer, bbsnnrp->innbbsin);
+ verboselog("innbbsGet: %s", buffer);
+ if (atoi(buffer) != INNBBSconnectOK) {
+ fprintf(stderr, "INNBBS server not OK\n");
+ return;
+ }
+ if (DefaultNntpProtocol == NntpPostProtocol) {
+ fputs("MODE READER\r\n", bbsnnrp->innbbsout);
+ fflush(bbsnnrp->innbbsout);
+ verboselog("innbbsPut: MODE READER\n");
+ fgets(buffer, sizeof buffer, bbsnnrp->innbbsin);
+ verboselog("innbbsGet: %s", buffer);
+ }
+ if (StatHistory == 0) {
+ fputs("MIDCHECK OFF\r\n", bbsnnrp->innbbsout);
+ fflush(bbsnnrp->innbbsout);
+ verboselog("innbbsPut: MIDCHECK OFF\n");
+ fgets(buffer, sizeof buffer, bbsnnrp->innbbsin);
+ verboselog("innbbsGet: %s", buffer);
+ }
+ tmpfp = fopen(tmpfilename, "w");
+ if (tmpfp == NULL)
+ return;
+ *mid = '\0';
+ for (;;) {
+ fprintf(stderr, "Try to read from stdin ...\n");
+ ngmet = 0, submet = 0, midmet = 0, pathmet = 0, orgmet = 0, approvedmet = 0;
+ discard = 0;
+ while (fgets(buffer, sizeof buffer, stdin) != NULL) {
+ char *tmpptr;
+ tmpptr = strchr(buffer, '\n');
+ if (tmpptr != NULL)
+ *tmpptr = '\0';
+ if (strncasecmp(buffer, "Message-ID: ", 12) == 0) {
+ strncpy(mid, buffer + 12, sizeof mid);
+ midmet = 1;
+ } else if (strncmp(buffer, "Subject: ", 9) == 0) {
+ submet = 1;
+ } else if (strncmp(buffer, "Path: ", 6) == 0) {
+ pathmet = 1;
+ } else if (strncmp(buffer, "Organization: ", 14) == 0) {
+ orgmet = 1;
+ } else if (strncmp(buffer, "Approved: ", 10) == 0) {
+ approvedmet = 1;
+ } else if (strncmp(buffer, "From: ", 6) == 0 && *DefaultTrustfrom) {
+ if (strstr(buffer + 6, DefaultTrustfrom) == NULL) {
+ discard = 1;
+ verboselog("Discard: %s for %s", buffer, DefaultTrustfrom);
+ }
+ } else if (strncmp(buffer, "From ", 5) == 0 && *DefaultTrustFrom) {
+ if (strstr(buffer + 5, DefaultTrustFrom) == NULL) {
+ discard = 1;
+ verboselog("Discard: %s for %s", buffer, DefaultTrustFrom);
+ }
+ } else if (strncmp(buffer, "Received: ", 10) == 0) {
+ char *rptr = buffer + 10, *rrptr;
+ int savech, len;
+ if (strncmp(buffer + 10, "from ", 5) == 0) {
+ rptr += 5;
+ rrptr = strchr(rptr, '(');
+ if (rrptr != NULL)
+ rptr = rrptr + 1;
+ rrptr = strchr(rptr, ' ');
+ savech = *rrptr;
+ if (rrptr != NULL)
+ *rrptr = '\0';
+ } else if (strncmp(buffer + 10, "(from ", 6) == 0) {
+ rptr += 6;
+ rrptr = strchr(rptr, ')');
+ savech = *rrptr;
+ if (rrptr != NULL)
+ *rrptr = '\0';
+ }
+ len = strlen(rptr) + 1;
+ if (*rptr && sending_path_len + len < sizeof(sending_path)) {
+ if (*sending_path)
+ strcat(sending_path, "!");
+ strcat(sending_path, rptr);
+ sending_path_len += len;
+ }
+ if (rrptr != NULL)
+ *rrptr = savech;
+ }
+ if (strncmp(buffer, "Newsgroups: ", 12) == 0) {
+ if (*DefaultNewsgroups) {
+ fprintf(tmpfp, "Newsgroups: %s\r\n", DefaultNewsgroups);
+ } else {
+ fprintf(tmpfp, "%s\r\n", buffer);
+ }
+ ngmet = 1;
+ } else {
+ if (buffer[0] == '\0') {
+ if (!ngmet && *DefaultNewsgroups) {
+ fprintf(tmpfp, "Newsgroups: %s\r\n", DefaultNewsgroups);
+ }
+ if (!submet) {
+ fprintf(tmpfp, "Subject: (no subject)\r\n");
+ }
+ if (!pathmet) {
+ fprintf(tmpfp, "Path: from-mail\r\n");
+ }
+ if (!midmet) {
+ static int seed;
+ time_t now;
+ time(&now);
+ fprintf(tmpfp, "Message-ID: <%d@%d.%d.%d>\r\n", now, getpid(), getuid(), seed);
+ sprintf(mid, "<%d@%d.%d.%d>", now, getpid(), getuid(), seed);
+ seed++;
+ }
+ if (!orgmet && *DefaultOrganization) {
+ fprintf(tmpfp, "Organization: %s\r\n", DefaultOrganization);
+ }
+ if (!approvedmet && *DefaultModerator) {
+ fprintf(tmpfp, "Approved: %s\r\n", DefaultModerator);
+ }
+ }
+ if (strncmp(buffer, "From ", 5) != 0 && strncmp(buffer, "To: ", 4) != 0) {
+ if (buffer[0] == '\0') {
+ if (*sending_path) {
+ fprintf(tmpfp, "X-Sending-Path: %s\r\n", sending_path);
+ }
+ }
+ fprintf(tmpfp, "%s\r\n", buffer);
+ }
+ }
+ if (buffer[0] == '\0')
+ break;
+ }
+ fprintf(stderr, "Article Body begin ...\n");
+ pathagain = 0;
+ while (fgets(buffer, sizeof buffer, stdin) != NULL) {
+ char *tmpptr;
+ tmpptr = strchr(buffer, '\n');
+ if (tmpptr != NULL)
+ *tmpptr = '\0';
+ if (headbegin(buffer)) {
+ FILE *oldfp = bbsnnrp->nnrpin;
+ pathagain = 1;
+ fputs(".\r\n", tmpfp);
+ fclose(tmpfp);
+ fprintf(stderr, "Try to post ...\n");
+ tmpfp = fopen(tmpfilename, "r");
+ bbsnnrp->nnrpin = tmpfp;
+ if (!discard)
+ if (INNBBSihave(bbsnnrp, -1, mid) == -1) {
+ fprintf(stderr, "post failed\n");
+ }
+ bbsnnrp->nnrpin = oldfp;
+ fclose(tmpfp);
+ *mid = '\0';
+ tmpfp = fopen(tmpfilename, "w");
+ fprintf(tmpfp, "%s\r\n", buffer);
+ break;
+ } else {
+ fprintf(tmpfp, "%s\r\n", buffer);
+ }
+ }
+ if (!pathagain)
+ break;
+ }
+ if (!pathagain && tmpfp) {
+ FILE *oldfp = bbsnnrp->nnrpin;
+ fputs(".\r\n", tmpfp);
+ fclose(tmpfp);
+ fprintf(stderr, "Try to post ...\n");
+ tmpfp = fopen(tmpfilename, "r");
+ bbsnnrp->nnrpin = tmpfp;
+ if (!discard)
+ if (INNBBSihave(bbsnnrp, -1, mid) == -1) {
+ fprintf(stderr, "post failed\n");
+ }
+ bbsnnrp->nnrpin = oldfp;
+ fclose(tmpfp);
+ }
+ if (isfile(tmpfilename)) {
+ unlink(tmpfilename);
+ }
}
-static char *ACT_BUF, *RC_BUF;
-int ACT_COUNT;
+static char *ACT_BUF, *RC_BUF;
+int ACT_COUNT;
initrcfiles(bbsnnrp)
-nnrp_t *bbsnnrp;
+ nnrp_t *bbsnnrp;
{
- FILE *actfp, *rcfp;
- char buff[1024];
- int actfd, i, count, actcount=0, rcount=0, maxcount;
- struct stat st;
- char *actlistptr, *ptr;
-
- actfd = open(bbsnnrp->activefile, O_RDWR);
- if (actfd < 0) {
- fprintf( stderr, "can't read/write %s\n", bbsnnrp->activefile );
- exit(1);
- }
- if (fstat(actfd, &st) != 0) {
- fprintf( stderr, "can't stat %s\n", bbsnnrp->activefile );
- exit(1);
- }
-
- bbsnnrp->actfd = actfd;
- bbsnnrp->actsize = st.st_size;
+ FILE *actfp, *rcfp;
+ char buff[1024];
+ int actfd, i, count, actcount = 0, rcount = 0, maxcount;
+ struct stat st;
+ char *actlistptr, *ptr;
+
+ actfd = open(bbsnnrp->activefile, O_RDWR);
+ if (actfd < 0) {
+ fprintf(stderr, "can't read/write %s\n", bbsnnrp->activefile);
+ exit(1);
+ }
+ if (fstat(actfd, &st) != 0) {
+ fprintf(stderr, "can't stat %s\n", bbsnnrp->activefile);
+ exit(1);
+ }
+ bbsnnrp->actfd = actfd;
+ bbsnnrp->actsize = st.st_size;
#ifdef USE_MMAP
- bbsnnrp->actpointer = mmap(0, st.st_size, PROT_WRITE | PROT_READ,
- MAP_SHARED, actfd, 0);
- if (bbsnnrp->actpointer == (char*)-1) {
- fprintf( stderr, "mmap error \n");
- exit(1);
- }
+ bbsnnrp->actpointer = mmap(0, st.st_size, PROT_WRITE | PROT_READ,
+ MAP_SHARED, actfd, 0);
+ if (bbsnnrp->actpointer == (char *)-1) {
+ fprintf(stderr, "mmap error \n");
+ exit(1);
+ }
#else
- if (bbsnnrp->actpointer == NULL) {
- bbsnnrp->actpointer = (char*)mymalloc(st.st_size);
- } else {
- bbsnnrp->actpointer = (char*)myrealloc(bbsnnrp->actpointer,st.st_size);
- }
- if (bbsnnrp->actpointer == NULL || read(actfd, bbsnnrp->actpointer, st.st_size) <= 0) {
- fprintf( stderr, "read act error \n");
- exit(1);
- }
+ if (bbsnnrp->actpointer == NULL) {
+ bbsnnrp->actpointer = (char *)mymalloc(st.st_size);
+ } else {
+ bbsnnrp->actpointer = (char *)myrealloc(bbsnnrp->actpointer, st.st_size);
+ }
+ if (bbsnnrp->actpointer == NULL || read(actfd, bbsnnrp->actpointer, st.st_size) <= 0) {
+ fprintf(stderr, "read act error \n");
+ exit(1);
+ }
#endif
- bbsnnrp->actend = bbsnnrp->actpointer + st.st_size;
- i = 0, count = 0;
- for (ptr = bbsnnrp->actpointer; ptr < bbsnnrp->actend && (actlistptr = (char*)strchr(ptr,'\n')) != NULL; ptr = actlistptr +1, ACT_COUNT++) {
- if (*ptr == '\n') continue;
- if (*ptr == '#') continue;
- count ++;
- }
- bbsnnrp->newsrc = (newsrc_t*) mymalloc( sizeof(newsrc_t) * count);
- ACT_COUNT = 0;
- for (ptr = bbsnnrp->actpointer; ptr < bbsnnrp->actend && (actlistptr = (char*)strchr(ptr,'\n')) != NULL; ptr = actlistptr +1 ) {
- register newsrc_t *rcptr;
- char *nptr;
- /**actlistptr = '\0';*/
- if (*ptr == '\n') continue;
- if (*ptr == '#') continue;
- rcptr = &bbsnnrp->newsrc[ACT_COUNT];
- rcptr->nameptr = NULL;
- rcptr->namelen = 0;
- rcptr->lowptr = NULL;
- rcptr->lowlen = 0;
- rcptr->highptr = NULL;
- rcptr->highlen = 0;
- rcptr->modeptr = NULL;
- rcptr->low = 0;
- rcptr->high = 0;
- rcptr->mode = 'y';
- for (nptr= ptr ;*nptr && isspace(*nptr); ) nptr++;
- if ( nptr == actlistptr ) continue;
- rcptr->nameptr = nptr;
- for (nptr++; *nptr && !isspace(*nptr); ) nptr++;
- rcptr->namelen = (int)(nptr - rcptr->nameptr);
- if ( nptr == actlistptr) continue;
- for (nptr++ ;*nptr && isspace(*nptr); ) nptr++;
- if ( nptr == actlistptr) continue;
- rcptr->highptr = nptr;
- rcptr->high = atol(nptr);
- for (nptr++; *nptr && !isspace(*nptr); ) nptr++;
- rcptr->highlen = (int)(nptr - rcptr->highptr);
- if ( nptr == actlistptr) continue;
- for (nptr++ ;*nptr && isspace(*nptr); ) nptr++;
- if ( nptr == actlistptr) continue;
- rcptr->lowptr = nptr;
- rcptr->low = atol(nptr);
- for (nptr++; *nptr && !isspace(*nptr); ) nptr++;
- rcptr->lowlen = (int)(nptr - rcptr->lowptr);
- if ( nptr == actlistptr) continue;
- for (nptr++ ;*nptr && isspace(*nptr); ) nptr++;
- if ( nptr == actlistptr) continue;
- rcptr->mode = *nptr;
- rcptr->modeptr = nptr;
- ACT_COUNT ++;
- }
+ bbsnnrp->actend = bbsnnrp->actpointer + st.st_size;
+ i = 0, count = 0;
+ for (ptr = bbsnnrp->actpointer; ptr < bbsnnrp->actend && (actlistptr = (char *)strchr(ptr, '\n')) != NULL; ptr = actlistptr + 1, ACT_COUNT++) {
+ if (*ptr == '\n')
+ continue;
+ if (*ptr == '#')
+ continue;
+ count++;
+ }
+ bbsnnrp->newsrc = (newsrc_t *) mymalloc(sizeof(newsrc_t) * count);
+ ACT_COUNT = 0;
+ for (ptr = bbsnnrp->actpointer; ptr < bbsnnrp->actend && (actlistptr = (char *)strchr(ptr, '\n')) != NULL; ptr = actlistptr + 1) {
+ register newsrc_t *rcptr;
+ char *nptr;
+ /**actlistptr = '\0';*/
+ if (*ptr == '\n')
+ continue;
+ if (*ptr == '#')
+ continue;
+ rcptr = &bbsnnrp->newsrc[ACT_COUNT];
+ rcptr->nameptr = NULL;
+ rcptr->namelen = 0;
+ rcptr->lowptr = NULL;
+ rcptr->lowlen = 0;
+ rcptr->highptr = NULL;
+ rcptr->highlen = 0;
+ rcptr->modeptr = NULL;
+ rcptr->low = 0;
+ rcptr->high = 0;
+ rcptr->mode = 'y';
+ for (nptr = ptr; *nptr && isspace(*nptr);)
+ nptr++;
+ if (nptr == actlistptr)
+ continue;
+ rcptr->nameptr = nptr;
+ for (nptr++; *nptr && !isspace(*nptr);)
+ nptr++;
+ rcptr->namelen = (int)(nptr - rcptr->nameptr);
+ if (nptr == actlistptr)
+ continue;
+ for (nptr++; *nptr && isspace(*nptr);)
+ nptr++;
+ if (nptr == actlistptr)
+ continue;
+ rcptr->highptr = nptr;
+ rcptr->high = atol(nptr);
+ for (nptr++; *nptr && !isspace(*nptr);)
+ nptr++;
+ rcptr->highlen = (int)(nptr - rcptr->highptr);
+ if (nptr == actlistptr)
+ continue;
+ for (nptr++; *nptr && isspace(*nptr);)
+ nptr++;
+ if (nptr == actlistptr)
+ continue;
+ rcptr->lowptr = nptr;
+ rcptr->low = atol(nptr);
+ for (nptr++; *nptr && !isspace(*nptr);)
+ nptr++;
+ rcptr->lowlen = (int)(nptr - rcptr->lowptr);
+ if (nptr == actlistptr)
+ continue;
+ for (nptr++; *nptr && isspace(*nptr);)
+ nptr++;
+ if (nptr == actlistptr)
+ continue;
+ rcptr->mode = *nptr;
+ rcptr->modeptr = nptr;
+ ACT_COUNT++;
+ }
}
initsockets(server, bbsnnrp, type)
-char *server;
-nnrp_t *bbsnnrp;
-char *type;
+ char *server;
+ nnrp_t *bbsnnrp;
+ char *type;
{
- int nnrpfd ;
- int innbbsfd;
- if (AskLocal) {
- innbbsfd = unixclient(DefaultPath,"tcp");
- if (innbbsfd < 0) {
- fprintf(stderr, "Connect to %s error. You may not run innbbsd\n", LOCALDAEMON);
- /* unix connect fail, may run by inetd, try to connect to local once */
- innbbsfd = inetclient("localhost",DefaultPort,"tcp");
+ int nnrpfd;
+ int innbbsfd;
+ if (AskLocal) {
+ innbbsfd = unixclient(DefaultPath, "tcp");
+ if (innbbsfd < 0) {
+ fprintf(stderr, "Connect to %s error. You may not run innbbsd\n", LOCALDAEMON);
+ /*
+ * unix connect fail, may run by inetd, try to connect to local
+ * once
+ */
+ innbbsfd = inetclient("localhost", DefaultPort, "tcp");
+ if (innbbsfd < 0) {
+ exit(2);
+ }
+ close(innbbsfd);
+ /* try again */
+ innbbsfd = unixclient(DefaultPath, "tcp");
+ if (innbbsfd < 0) {
+ exit(3);
+ }
+ }
+ verboselog("INNBBS connect to %s\n", DefaultPath);
+ } else {
+ innbbsfd = inetclient(DefaultRemoteHost, DefaultPort, "tcp");
if (innbbsfd < 0) {
- exit(2);
+ fprintf(stderr, "Connect to %s at %s error. Remote Server not Ready\n", DefaultRemoteHost, DefaultPort);
+ exit(2);
}
- close(innbbsfd);
- /* try again */
- innbbsfd = unixclient(DefaultPath,"tcp");
- if (innbbsfd < 0) {
- exit(3);
+ verboselog("INNBBS connect to %s\n", DefaultRemoteHost);
+ }
+ if (type == StdinInputType) {
+ bbsnnrp->nnrpfd = 0;
+ bbsnnrp->innbbsfd = innbbsfd;
+ if ((bbsnnrp->nnrpin = fdopen(0, "r")) == NULL ||
+ (bbsnnrp->nnrpout = fdopen(1, "w")) == NULL ||
+ (bbsnnrp->innbbsin = fdopen(innbbsfd, "r")) == NULL ||
+ (bbsnnrp->innbbsout = fdopen(innbbsfd, "w")) == NULL) {
+ fprintf(stderr, "fdopen error\n");
+ exit(3);
}
- }
- verboselog("INNBBS connect to %s\n",DefaultPath);
- } else {
- innbbsfd = inetclient(DefaultRemoteHost,DefaultPort,"tcp");
- if (innbbsfd < 0) {
- fprintf(stderr, "Connect to %s at %s error. Remote Server not Ready\n", DefaultRemoteHost, DefaultPort);
- exit(2);
- }
- verboselog("INNBBS connect to %s\n",DefaultRemoteHost);
- }
- if (type == StdinInputType) {
- bbsnnrp->nnrpfd = 0;
- bbsnnrp->innbbsfd = innbbsfd;
- if ((bbsnnrp->nnrpin = fdopen(0,"r")) == NULL ||
- (bbsnnrp->nnrpout= fdopen(1,"w")) == NULL ||
- (bbsnnrp->innbbsin= fdopen(innbbsfd,"r")) == NULL ||
- (bbsnnrp->innbbsout= fdopen(innbbsfd,"w"))== NULL ) {
- fprintf( stderr, "fdopen error\n");
- exit(3);
- }
- return;
- }
- nnrpfd = inetclient(server, "nntp","tcp");
- if (nnrpfd < 0) {
- fprintf(stderr, " connect to %s error \n", server);
- exit(2);
- }
- verboselog("NNRP connect to %s\n", server);
- bbsnnrp->nnrpfd = nnrpfd;
- bbsnnrp->innbbsfd = innbbsfd;
- if ((bbsnnrp->nnrpin = fdopen(nnrpfd,"r")) == NULL ||
- (bbsnnrp->nnrpout= fdopen(nnrpfd,"w")) == NULL ||
- (bbsnnrp->innbbsin= fdopen(innbbsfd,"r")) == NULL ||
- (bbsnnrp->innbbsout= fdopen(innbbsfd,"w"))== NULL ) {
- fprintf( stderr, "fdopen error\n");
- exit(3);
- }
+ return;
+ }
+ nnrpfd = inetclient(server, "nntp", "tcp");
+ if (nnrpfd < 0) {
+ fprintf(stderr, " connect to %s error \n", server);
+ exit(2);
+ }
+ verboselog("NNRP connect to %s\n", server);
+ bbsnnrp->nnrpfd = nnrpfd;
+ bbsnnrp->innbbsfd = innbbsfd;
+ if ((bbsnnrp->nnrpin = fdopen(nnrpfd, "r")) == NULL ||
+ (bbsnnrp->nnrpout = fdopen(nnrpfd, "w")) == NULL ||
+ (bbsnnrp->innbbsin = fdopen(innbbsfd, "r")) == NULL ||
+ (bbsnnrp->innbbsout = fdopen(innbbsfd, "w")) == NULL) {
+ fprintf(stderr, "fdopen error\n");
+ exit(3);
+ }
}
closesockets()
{
- fclose(BBSNNRP.nnrpin);
- fclose(BBSNNRP.nnrpout);
- fclose(BBSNNRP.innbbsin);
- fclose(BBSNNRP.innbbsout);
- close(BBSNNRP.nnrpfd);
- close(BBSNNRP.innbbsfd);
+ fclose(BBSNNRP.nnrpin);
+ fclose(BBSNNRP.nnrpout);
+ fclose(BBSNNRP.innbbsin);
+ fclose(BBSNNRP.innbbsout);
+ close(BBSNNRP.nnrpfd);
+ close(BBSNNRP.innbbsfd);
}
updaterc(actptr, len, value)
-char *actptr;
-int len;
-ULONG value;
+ char *actptr;
+ int len;
+ ULONG value;
{
- for (actptr += len -1; len -- >0; ) {
- *actptr-- = value % 10 + '0';
- value /= 10;
- }
+ for (actptr += len - 1; len-- > 0;) {
+ *actptr-- = value % 10 + '0';
+ value /= 10;
+ }
}
-/*
- if old file is empty, don't need to update
- prevent from disk full
-*/
+/*
+ * if old file is empty, don't need to update prevent from disk full
+ */
int
-myrename(old,new)
-char *old, *new;
+myrename(old, new)
+ char *old, *new;
{
- struct stat st;
- if (stat(old,&st) != 0) return -1;
- if (st.st_size <= 0) return -1;
- return rename(old,new);
+ struct stat st;
+ if (stat(old, &st) != 0)
+ return -1;
+ if (st.st_size <= 0)
+ return -1;
+ return rename(old, new);
}
flushrc(bbsnnrp)
-nnrp_t *bbsnnrp;
+ nnrp_t *bbsnnrp;
{
- int backfd;
- char *bak1;
- if (bbsnnrp->actdirty == 0) return;
- bak1 = (char*)strdup((char*)fileglue("%s.BAK",bbsnnrp->activefile));
- if (isfile(bak1)) {
- myrename(bak1, (char*)fileglue("%s.BAK.OLD",bbsnnrp->activefile));
- }
+ int backfd;
+ char *bak1;
+ if (bbsnnrp->actdirty == 0)
+ return;
+ bak1 = (char *)strdup((char *)fileglue("%s.BAK", bbsnnrp->activefile));
+ if (isfile(bak1)) {
+ myrename(bak1, (char *)fileglue("%s.BAK.OLD", bbsnnrp->activefile));
+ }
#ifdef USE_MMAP
- if ((backfd=open((char*)fileglue("%s.BAK",bbsnnrp->activefile),O_WRONLY | O_TRUNC | O_CREAT, 0664)) < 0 || write(backfd, bbsnnrp->actpointer, bbsnnrp->actsize) < bbsnnrp->actsize)
+ if ((backfd = open((char *)fileglue("%s.BAK", bbsnnrp->activefile), O_WRONLY | O_TRUNC | O_CREAT, 0664)) < 0 || write(backfd, bbsnnrp->actpointer, bbsnnrp->actsize) < bbsnnrp->actsize)
#else
- myrename(bbsnnrp->activefile, bak1);
- if ((backfd=open(bbsnnrp->activefile,O_WRONLY | O_TRUNC | O_CREAT, 0664)) < 0 || write(backfd, bbsnnrp->actpointer, bbsnnrp->actsize) < bbsnnrp->actsize)
+ myrename(bbsnnrp->activefile, bak1);
+ if ((backfd = open(bbsnnrp->activefile, O_WRONLY | O_TRUNC | O_CREAT, 0664)) < 0 || write(backfd, bbsnnrp->actpointer, bbsnnrp->actsize) < bbsnnrp->actsize)
#endif
- {
- char emergent[128];
- sprintf(emergent,"/tmp/bbsnnrp.%d.active",getpid());
+ {
+ char emergent[128];
+ sprintf(emergent, "/tmp/bbsnnrp.%d.active", getpid());
fprintf(stderr, "write to backup active fail. Maybe disk full\n");
- fprintf(stderr, "try to write in %s\n",emergent);
- if ((backfd = open(emergent,O_WRONLY | O_TRUNC | O_CREAT, 0644))<0 || write(backfd, bbsnnrp->actpointer, bbsnnrp->actsize) < bbsnnrp->actsize)
- {
- fprintf(stderr, "write to %sfail.\n", emergent);
+ fprintf(stderr, "try to write in %s\n", emergent);
+ if ((backfd = open(emergent, O_WRONLY | O_TRUNC | O_CREAT, 0644)) < 0 || write(backfd, bbsnnrp->actpointer, bbsnnrp->actsize) < bbsnnrp->actsize) {
+ fprintf(stderr, "write to %sfail.\n", emergent);
} else {
- close(backfd);
+ close(backfd);
}
/* if write fail, should leave */
- /*exit(1);*/
- } else {
- close(backfd);
- }
- free(bak1);
- bbsnnrp->actdirty = 0;
+ /* exit(1); */
+ } else {
+ close(backfd);
+ }
+ free(bak1);
+ bbsnnrp->actdirty = 0;
}
writerc(bbsnnrp)
-nnrp_t *bbsnnrp;
+ nnrp_t *bbsnnrp;
{
- if (bbsnnrp->actpointer) {
- flushrc(bbsnnrp);
+ if (bbsnnrp->actpointer) {
+ flushrc(bbsnnrp);
#ifdef USE_MMAP
- if (munmap(bbsnnrp->actpointer, bbsnnrp->actsize) < 0)
- fprintf(stderr, "can't unmap\n");
- /*free(bbsnnrp->actpointer);*/
- bbsnnrp->actpointer = NULL;
+ if (munmap(bbsnnrp->actpointer, bbsnnrp->actsize) < 0)
+ fprintf(stderr, "can't unmap\n");
+ /* free(bbsnnrp->actpointer); */
+ bbsnnrp->actpointer = NULL;
#endif
- if (close(bbsnnrp->actfd) < 0)
- fprintf(stderr, "can't close actfd\n");
- }
+ if (close(bbsnnrp->actfd) < 0)
+ fprintf(stderr, "can't close actfd\n");
+ }
}
-static FILE* Xhdrfp;
-static char NNRPbuffer[4096];
-static char INNBBSbuffer[4096];
+static FILE *Xhdrfp;
+static char NNRPbuffer[4096];
+static char INNBBSbuffer[4096];
-char *
+char *
NNRPgets(string, len, fp)
-char *string;
-int len;
-FILE *fp;
+ char *string;
+ int len;
+ FILE *fp;
{
- char* re = fgets(string, len, fp);
- char *ptr;
- if (re != NULL) {
- if ((ptr = (char*)strchr(string,'\r'))!=NULL)
- *ptr = '\0';
- if ((ptr = (char*)strchr(string,'\n'))!=NULL)
- *ptr = '\0';
- }
- return re;
+ char *re = fgets(string, len, fp);
+ char *ptr;
+ if (re != NULL) {
+ if ((ptr = (char *)strchr(string, '\r')) != NULL)
+ *ptr = '\0';
+ if ((ptr = (char *)strchr(string, '\n')) != NULL)
+ *ptr = '\0';
+ }
+ return re;
}
-int NNRPstat(bbsnnrp, artno, mid)
-nnrp_t *bbsnnrp;
- ULONG artno;
-char **mid;
+int
+NNRPstat(bbsnnrp, artno, mid)
+ nnrp_t *bbsnnrp;
+ ULONG artno;
+ char **mid;
{
- char *ptr;
- int code;
-
- *mid = NULL;
- fprintf(bbsnnrp->nnrpout,"STAT %d\r\n",artno);
- fflush(bbsnnrp->nnrpout);
- verboselog("nnrpPut: STAT %d\n",artno);
- NNRPgets(NNRPbuffer, sizeof NNRPbuffer, bbsnnrp->nnrpin);
- verboselog("nnrpGet: %s\n",NNRPbuffer);
+ char *ptr;
+ int code;
- ptr = (char*) strchr(NNRPbuffer, ' ');
- if (ptr != NULL) *ptr++ = '\0';
- code = atoi(NNRPbuffer);
- ptr = (char*) strchr(ptr, ' ');
- if (ptr != NULL) *ptr++ = '\0';
- *mid = ptr;
- ptr = (char*) strchr(ptr, ' ');
- if (ptr != NULL) *ptr++ = '\0';
- return code;
+ *mid = NULL;
+ fprintf(bbsnnrp->nnrpout, "STAT %d\r\n", artno);
+ fflush(bbsnnrp->nnrpout);
+ verboselog("nnrpPut: STAT %d\n", artno);
+ NNRPgets(NNRPbuffer, sizeof NNRPbuffer, bbsnnrp->nnrpin);
+ verboselog("nnrpGet: %s\n", NNRPbuffer);
+
+ ptr = (char *)strchr(NNRPbuffer, ' ');
+ if (ptr != NULL)
+ *ptr++ = '\0';
+ code = atoi(NNRPbuffer);
+ ptr = (char *)strchr(ptr, ' ');
+ if (ptr != NULL)
+ *ptr++ = '\0';
+ *mid = ptr;
+ ptr = (char *)strchr(ptr, ' ');
+ if (ptr != NULL)
+ *ptr++ = '\0';
+ return code;
}
int
NNRPxhdr(pattern, bbsnnrp, i, low, high)
-char *pattern;
-nnrp_t *bbsnnrp;
-int i;
-ULONG low, high;
+ char *pattern;
+ nnrp_t *bbsnnrp;
+ int i;
+ ULONG low, high;
{
- newsrc_t *rcptr = &bbsnnrp->newsrc[i];
- int size, code;
+ newsrc_t *rcptr = &bbsnnrp->newsrc[i];
+ int size, code;
- Xhdrfp = bbsnnrp->nnrpin;
- fprintf(bbsnnrp->nnrpout,"XHDR %s %d-%d\r\n",pattern,low, high );
+ Xhdrfp = bbsnnrp->nnrpin;
+ fprintf(bbsnnrp->nnrpout, "XHDR %s %d-%d\r\n", pattern, low, high);
#ifdef BBSNNRPDEBUG
- printf("XHDR %s %d-%d\r\n",pattern,low, high );
+ printf("XHDR %s %d-%d\r\n", pattern, low, high);
#endif
- fflush(bbsnnrp->nnrpout);
- verboselog("nnrpPut: XHDR %s %d-%d\n",pattern,low, high );
- NNRPgets(NNRPbuffer, sizeof NNRPbuffer, bbsnnrp->nnrpin);
- verboselog("nnrpGet: %s\n", NNRPbuffer);
- code = atoi(NNRPbuffer);
- return code;
+ fflush(bbsnnrp->nnrpout);
+ verboselog("nnrpPut: XHDR %s %d-%d\n", pattern, low, high);
+ NNRPgets(NNRPbuffer, sizeof NNRPbuffer, bbsnnrp->nnrpin);
+ verboselog("nnrpGet: %s\n", NNRPbuffer);
+ code = atoi(NNRPbuffer);
+ return code;
}
-int NNRPxhdrget(artno, mid, iscontrol)
-int *artno;
-char **mid;
-int iscontrol;
+int
+NNRPxhdrget(artno, mid, iscontrol)
+ int *artno;
+ char **mid;
+ int iscontrol;
{
*mid = NULL;
*artno = 0;
if (NNRPgets(NNRPbuffer, sizeof NNRPbuffer, Xhdrfp) == NULL)
- return 0;
+ return 0;
else {
- char *ptr, *s;
- if (strcmp(NNRPbuffer,".")==0) return 0;
- ptr = (char*)strchr(NNRPbuffer,' ');
- if (!ptr) return 1;
- *ptr++ = '\0';
- *artno = atol(NNRPbuffer);
- if (iscontrol) {
- ptr = (char*)strchr(s=ptr,' ');
- if (!ptr) return 1;
- *ptr++ = '\0';
- if (strcmp(s,"cancel") != 0) return 1;
- }
- *mid = ptr;
- return 1;
+ char *ptr, *s;
+ if (strcmp(NNRPbuffer, ".") == 0)
+ return 0;
+ ptr = (char *)strchr(NNRPbuffer, ' ');
+ if (!ptr)
+ return 1;
+ *ptr++ = '\0';
+ *artno = atol(NNRPbuffer);
+ if (iscontrol) {
+ ptr = (char *)strchr(s = ptr, ' ');
+ if (!ptr)
+ return 1;
+ *ptr++ = '\0';
+ if (strcmp(s, "cancel") != 0)
+ return 1;
+ }
+ *mid = ptr;
+ return 1;
}
}
-int INNBBSstat(bbsnnrp, i, mid)
-nnrp_t *bbsnnrp;
-int i;
-char *mid;
+int
+INNBBSstat(bbsnnrp, i, mid)
+ nnrp_t *bbsnnrp;
+ int i;
+ char *mid;
{
- newsrc_t *rcptr = &bbsnnrp->newsrc[i];
- int size, code;
-
- fprintf(bbsnnrp->innbbsout,"STAT %s\r\n", mid);
- fflush(bbsnnrp->innbbsout);
- verboselog("innbbsPut: STAT %s\n", mid);
- NNRPgets(INNBBSbuffer, sizeof INNBBSbuffer, bbsnnrp->innbbsin);
- verboselog("innbbsGet: %s\n", INNBBSbuffer);
- return atol(INNBBSbuffer);
+ newsrc_t *rcptr = &bbsnnrp->newsrc[i];
+ int size, code;
+
+ fprintf(bbsnnrp->innbbsout, "STAT %s\r\n", mid);
+ fflush(bbsnnrp->innbbsout);
+ verboselog("innbbsPut: STAT %s\n", mid);
+ NNRPgets(INNBBSbuffer, sizeof INNBBSbuffer, bbsnnrp->innbbsin);
+ verboselog("innbbsGet: %s\n", INNBBSbuffer);
+ return atol(INNBBSbuffer);
}
-int INNBBSihave(bbsnnrp, artno, mid)
-nnrp_t *bbsnnrp;
-ULONG artno;
-char *mid;
+int
+INNBBSihave(bbsnnrp, artno, mid)
+ nnrp_t *bbsnnrp;
+ ULONG artno;
+ char *mid;
{
- int size, code;
- int header=1;
-
- if (DefaultNntpProtocol == NntpPostProtocol) {
- fprintf(bbsnnrp->innbbsout,"POST\r\n");
- fflush(bbsnnrp->innbbsout);
- verboselog("innbbsPut: POST %s\n", mid);
- } else {
- fprintf(bbsnnrp->innbbsout,"IHAVE %s\r\n", mid);
- fflush(bbsnnrp->innbbsout);
- verboselog("innbbsPut: IHAVE %s\n", mid);
- }
- if (NNRPgets(INNBBSbuffer, sizeof INNBBSbuffer, bbsnnrp->innbbsin)==NULL){
+ int size, code;
+ int header = 1;
+
+ if (DefaultNntpProtocol == NntpPostProtocol) {
+ fprintf(bbsnnrp->innbbsout, "POST\r\n");
+ fflush(bbsnnrp->innbbsout);
+ verboselog("innbbsPut: POST %s\n", mid);
+ } else {
+ fprintf(bbsnnrp->innbbsout, "IHAVE %s\r\n", mid);
+ fflush(bbsnnrp->innbbsout);
+ verboselog("innbbsPut: IHAVE %s\n", mid);
+ }
+ if (NNRPgets(INNBBSbuffer, sizeof INNBBSbuffer, bbsnnrp->innbbsin) == NULL) {
return -1;
- }
- verboselog("innbbsGet: %s\n", INNBBSbuffer);
+ }
+ verboselog("innbbsGet: %s\n", INNBBSbuffer);
#ifdef BBSNNRPDEBUG
- printf("ihave got %s\n", INNBBSbuffer);
+ printf("ihave got %s\n", INNBBSbuffer);
#endif
- if (DefaultNntpProtocol == NntpPostProtocol) {
- if ((code=atol(INNBBSbuffer)) != NNTP_START_POST_VAL) {
- if (code == NNTP_POSTFAIL_VAL)
- return 0;
- else
- return -1;
- }
- } else {
- if ((code=atol(INNBBSbuffer)) != INNBBSihaveOK) {
- if (code == 435 || code == 437)
- return 0;
- else
- return -1;
- }
- }
- if (artno != -1) {
- fprintf(bbsnnrp->nnrpout,"ARTICLE %d\r\n", artno);
- verboselog("nnrpPut: ARTICLE %d\n", artno);
+ if (DefaultNntpProtocol == NntpPostProtocol) {
+ if ((code = atol(INNBBSbuffer)) != NNTP_START_POST_VAL) {
+ if (code == NNTP_POSTFAIL_VAL)
+ return 0;
+ else
+ return -1;
+ }
+ } else {
+ if ((code = atol(INNBBSbuffer)) != INNBBSihaveOK) {
+ if (code == 435 || code == 437)
+ return 0;
+ else
+ return -1;
+ }
+ }
+ if (artno != -1) {
+ fprintf(bbsnnrp->nnrpout, "ARTICLE %d\r\n", artno);
+ verboselog("nnrpPut: ARTICLE %d\n", artno);
#ifdef BBSNNRPDEBUG
- printf("ARTICLE %d\r\n", artno);
+ printf("ARTICLE %d\r\n", artno);
#endif
- fflush(bbsnnrp->nnrpout);
- if (NNRPgets(NNRPbuffer, sizeof NNRPbuffer, bbsnnrp->nnrpin)==NULL) {
- return -1;
- }
- verboselog("nnrpGet: %s\n", NNRPbuffer);
+ fflush(bbsnnrp->nnrpout);
+ if (NNRPgets(NNRPbuffer, sizeof NNRPbuffer, bbsnnrp->nnrpin) == NULL) {
+ return -1;
+ }
+ verboselog("nnrpGet: %s\n", NNRPbuffer);
#ifdef BBSNNRPDEBUG
- printf("article got %s\n", NNRPbuffer);
+ printf("article got %s\n", NNRPbuffer);
#endif
- if (atol(NNRPbuffer) != NNRParticleOK) {
- fputs(".\r\n",bbsnnrp->innbbsout);
- fflush(bbsnnrp->innbbsout);
- NNRPgets(INNBBSbuffer, sizeof INNBBSbuffer, bbsnnrp->innbbsin);
- verboselog("innbbsGet: %s\n",INNBBSbuffer);
- return 0;
- }
- }
- header = 1;
- while ( fgets(NNRPbuffer, sizeof NNRPbuffer, bbsnnrp->nnrpin) != NULL)
- {
- if (strcmp(NNRPbuffer,"\r\n") == 0)
+ if (atol(NNRPbuffer) != NNRParticleOK) {
+ fputs(".\r\n", bbsnnrp->innbbsout);
+ fflush(bbsnnrp->innbbsout);
+ NNRPgets(INNBBSbuffer, sizeof INNBBSbuffer, bbsnnrp->innbbsin);
+ verboselog("innbbsGet: %s\n", INNBBSbuffer);
+ return 0;
+ }
+ }
+ header = 1;
+ while (fgets(NNRPbuffer, sizeof NNRPbuffer, bbsnnrp->nnrpin) != NULL) {
+ if (strcmp(NNRPbuffer, "\r\n") == 0)
header = 0;
- if (strcmp(NNRPbuffer,".\r\n")==0) {
- verboselog("nnrpGet: .\n");
- fputs(NNRPbuffer,bbsnnrp->innbbsout);
- fflush(bbsnnrp->innbbsout);
- verboselog("innbbsPut: .\n");
- if (NNRPgets(INNBBSbuffer, sizeof INNBBSbuffer, bbsnnrp->innbbsin)==NULL)
+ if (strcmp(NNRPbuffer, ".\r\n") == 0) {
+ verboselog("nnrpGet: .\n");
+ fputs(NNRPbuffer, bbsnnrp->innbbsout);
+ fflush(bbsnnrp->innbbsout);
+ verboselog("innbbsPut: .\n");
+ if (NNRPgets(INNBBSbuffer, sizeof INNBBSbuffer, bbsnnrp->innbbsin) == NULL)
return -1;
- verboselog("innbbsGet: %s\n",INNBBSbuffer);
+ verboselog("innbbsGet: %s\n", INNBBSbuffer);
#ifdef BBSNNRPDEBUG
printf("end ihave got %s\n", INNBBSbuffer);
#endif
code = atol(INNBBSbuffer);
- if (DefaultNntpProtocol == NntpPostProtocol) {
- if (code == NNTP_POSTEDOK_VAL)
- return 1;
- if (code == NNTP_POSTFAIL_VAL)
- return 0;
+ if (DefaultNntpProtocol == NntpPostProtocol) {
+ if (code == NNTP_POSTEDOK_VAL)
+ return 1;
+ if (code == NNTP_POSTFAIL_VAL)
+ return 0;
} else {
- if (code == 235)
- return 1;
- if (code == 437 || code == 435)
- return 0;
- }
- break;
- }
- if ( DefaultNntpProtocol == NntpPostProtocol &&
- header && strncasecmp(NNRPbuffer,"NNTP-Posting-Host: ",19)==0) {
- fprintf(bbsnnrp->innbbsout,"X-%s",NNRPbuffer);
- } else {
- fputs(NNRPbuffer,bbsnnrp->innbbsout);
- }
- }
- fflush(bbsnnrp->innbbsout);
- return -1;
+ if (code == 235)
+ return 1;
+ if (code == 437 || code == 435)
+ return 0;
+ }
+ break;
+ }
+ if (DefaultNntpProtocol == NntpPostProtocol &&
+ header && strncasecmp(NNRPbuffer, "NNTP-Posting-Host: ", 19) == 0) {
+ fprintf(bbsnnrp->innbbsout, "X-%s", NNRPbuffer);
+ } else {
+ fputs(NNRPbuffer, bbsnnrp->innbbsout);
+ }
+ }
+ fflush(bbsnnrp->innbbsout);
+ return -1;
}
int
NNRPgroup(bbsnnrp, i, low, high)
-nnrp_t *bbsnnrp;
-int i;
-ULONG *low, *high;
+ nnrp_t *bbsnnrp;
+ int i;
+ ULONG *low, *high;
{
- newsrc_t *rcptr = &bbsnnrp->newsrc[i];
- int size, code;
- ULONG tmp;
-
- fprintf(bbsnnrp->nnrpout,"GROUP %-.*s\r\n",
- rcptr->namelen, rcptr->nameptr );
- printf("GROUP %-.*s\r\n", rcptr->namelen, rcptr->nameptr );
- verboselog("nnrpPut: GROUP %-.*s\n", rcptr->namelen, rcptr->nameptr );
- fflush(bbsnnrp->nnrpout);
- NNRPgets(NNRPbuffer, sizeof NNRPbuffer, bbsnnrp->nnrpin);
- verboselog("nnrpGet: %s\n",NNRPbuffer);
- printf("%s\n",NNRPbuffer);
- sscanf(NNRPbuffer, "%d %d %ld %ld", &code, &size, low, high);
- if (*low > *high) {
- tmp = *low;
- *low = *high;
- *high = tmp;
- }
- return code;
+ newsrc_t *rcptr = &bbsnnrp->newsrc[i];
+ int size, code;
+ ULONG tmp;
+
+ fprintf(bbsnnrp->nnrpout, "GROUP %-.*s\r\n",
+ rcptr->namelen, rcptr->nameptr);
+ printf("GROUP %-.*s\r\n", rcptr->namelen, rcptr->nameptr);
+ verboselog("nnrpPut: GROUP %-.*s\n", rcptr->namelen, rcptr->nameptr);
+ fflush(bbsnnrp->nnrpout);
+ NNRPgets(NNRPbuffer, sizeof NNRPbuffer, bbsnnrp->nnrpin);
+ verboselog("nnrpGet: %s\n", NNRPbuffer);
+ printf("%s\n", NNRPbuffer);
+ sscanf(NNRPbuffer, "%d %d %ld %ld", &code, &size, low, high);
+ if (*low > *high) {
+ tmp = *low;
+ *low = *high;
+ *high = tmp;
+ }
+ return code;
}
-readnews(server,bbsnnrp)
-char *server;
-nnrp_t *bbsnnrp;
+readnews(server, bbsnnrp)
+ char *server;
+ nnrp_t *bbsnnrp;
{
- int i;
- char buffer[4096];
- ULONG low, high;
-
- fgets(buffer, sizeof buffer, bbsnnrp->innbbsin);
- verboselog("innbbsGet: %s", buffer);
- if (atoi(buffer) != INNBBSconnectOK) {
- fprintf(stderr, "INNBBS server not OK\n");
- return;
- }
+ int i;
+ char buffer[4096];
+ ULONG low, high;
+
+ fgets(buffer, sizeof buffer, bbsnnrp->innbbsin);
+ verboselog("innbbsGet: %s", buffer);
+ if (atoi(buffer) != INNBBSconnectOK) {
+ fprintf(stderr, "INNBBS server not OK\n");
+ return;
+ }
#ifdef BBSNNRPDEBUG
- printf("%s",buffer);
+ printf("%s", buffer);
#endif
- fgets(buffer, sizeof buffer, bbsnnrp->nnrpin);
- verboselog("nnrpGet: %s", buffer);
- if (buffer[0] != '2') {
- /*if (atoi(buffer) != NNRPconnectOK && atoi(buffer) != NNTP_NOPOSTOK_VAL) {*/
- fprintf(stderr, "NNRP server not OK\n");
- return;
- }
+ fgets(buffer, sizeof buffer, bbsnnrp->nnrpin);
+ verboselog("nnrpGet: %s", buffer);
+ if (buffer[0] != '2') {
+ /*
+ * if (atoi(buffer) != NNRPconnectOK && atoi(buffer) !=
+ * NNTP_NOPOSTOK_VAL) {
+ */
+ fprintf(stderr, "NNRP server not OK\n");
+ return;
+ }
#ifdef BBSNNRPDEBUG
- printf("%s",buffer);
+ printf("%s", buffer);
#endif
- fputs("MODE READER\r\n", bbsnnrp->nnrpout);
- fflush(bbsnnrp->nnrpout);
- verboselog("nnrpPut: MODE READER\n");
- fgets(buffer, sizeof buffer, bbsnnrp->nnrpin);
- verboselog("nnrpGet: %s",buffer);
-
- if ( DefaultNntpProtocol == NntpPostProtocol ) {
- fputs("MODE READER\r\n", bbsnnrp->innbbsout);
- fflush(bbsnnrp->innbbsout);
- verboselog("innbbsPut: MODE READER\n");
- fgets(buffer, sizeof buffer, bbsnnrp->innbbsin);
- verboselog("innbbsGet: %s",buffer);
- }
-
+ fputs("MODE READER\r\n", bbsnnrp->nnrpout);
+ fflush(bbsnnrp->nnrpout);
+ verboselog("nnrpPut: MODE READER\n");
+ fgets(buffer, sizeof buffer, bbsnnrp->nnrpin);
+ verboselog("nnrpGet: %s", buffer);
+
+ if (DefaultNntpProtocol == NntpPostProtocol) {
+ fputs("MODE READER\r\n", bbsnnrp->innbbsout);
+ fflush(bbsnnrp->innbbsout);
+ verboselog("innbbsPut: MODE READER\n");
+ fgets(buffer, sizeof buffer, bbsnnrp->innbbsin);
+ verboselog("innbbsGet: %s", buffer);
+ }
#ifdef BBSNNRPDEBUG
- printf("%s",buffer);
+ printf("%s", buffer);
#endif
-
- if (StatHistory == 0) {
- fputs("MIDCHECK OFF\r\n", bbsnnrp->innbbsout);
- fflush(bbsnnrp->innbbsout);
- verboselog("innbbsPut: MIDCHECK OFF\n");
- fgets(buffer, sizeof buffer, bbsnnrp->innbbsin);
- verboselog("innbbsGet: %s",buffer);
- }
- bbsnnrp->actdirty = 0;
- for (i =0; i< ACT_COUNT; i++) {
- int code = NNRPgroup(bbsnnrp, i, &low, &high);
- newsrc_t *rcptr = &bbsnnrp->newsrc[i];
- int j;
- ULONG artno;
- char *mid;
- int artcount;
+
+ if (StatHistory == 0) {
+ fputs("MIDCHECK OFF\r\n", bbsnnrp->innbbsout);
+ fflush(bbsnnrp->innbbsout);
+ verboselog("innbbsPut: MIDCHECK OFF\n");
+ fgets(buffer, sizeof buffer, bbsnnrp->innbbsin);
+ verboselog("innbbsGet: %s", buffer);
+ }
+ bbsnnrp->actdirty = 0;
+ for (i = 0; i < ACT_COUNT; i++) {
+ int code = NNRPgroup(bbsnnrp, i, &low, &high);
+ newsrc_t *rcptr = &bbsnnrp->newsrc[i];
+ int j;
+ ULONG artno;
+ char *mid;
+ int artcount;
#ifdef BBSNNRPDEBUG
- printf("got reply %d %ld %ld\n",code, low, high);
+ printf("got reply %d %ld %ld\n", code, low, high);
#endif
- artcount = 0;
- if (code == 411)
- {
- FILE *ff=fopen(BBSHOME"/innd/log/badgroup.log","a");
- fprintf(ff,"%s\t%-.*s\r\n", server, rcptr->namelen, rcptr->nameptr);
- fclose(ff);
- }
- else if (code == NNRPGroupOK) {
- int xcount;
- ULONG maxartno= rcptr->high;
- int isCancelControl = (strncmp(rcptr->nameptr,"control",rcptr->namelen)==0)
- ||
- (strncmp(rcptr->nameptr,"control.cancel",rcptr->namelen)==0) ;
-
-/* less than or equal to high, for server renumber */
- if (rcptr->low != low) {
+ artcount = 0;
+ if (code == 411) {
+ FILE *ff = fopen(BBSHOME "/innd/log/badgroup.log", "a");
+ fprintf(ff, "%s\t%-.*s\r\n", server, rcptr->namelen, rcptr->nameptr);
+ fclose(ff);
+ } else if (code == NNRPGroupOK) {
+ int xcount;
+ ULONG maxartno = rcptr->high;
+ int isCancelControl = (strncmp(rcptr->nameptr, "control", rcptr->namelen) == 0)
+ ||
+ (strncmp(rcptr->nameptr, "control.cancel", rcptr->namelen) == 0);
+
+ /* less than or equal to high, for server renumber */
+ if (rcptr->low != low) {
bbsnnrp->actdirty = 1;
rcptr->low = low;
updaterc(rcptr->lowptr, rcptr->lowlen, rcptr->low);
- }
- if (ResetActive) {
- if (rcptr->high != high) {
- bbsnnrp->actdirty = 1;
- rcptr->high = high;
- updaterc(rcptr->highptr, rcptr->highlen, rcptr->high);
- }
- } else if (rcptr->high < high) {
- int xhdrcode;
- ULONG maxget=high;
- int exception=0;
- if (rcptr->high < low) {
- bbsnnrp->actdirty = 1;
- rcptr->high = low;
- updaterc(rcptr->highptr, rcptr->highlen, low);
- }
- if (high > rcptr->high + Max_Stats) {
- maxget = rcptr->high + Max_Stats;
- }
- if ( isCancelControl )
- xhdrcode = NNRPxhdr("Control",bbsnnrp, i, rcptr->high+1, maxget);
- else
- xhdrcode = NNRPxhdr("Message-ID",bbsnnrp, i, rcptr->high+1, maxget);
-
- maxartno = maxget;
- if ( xhdrcode == NNRPXhdrOK) {
- while (NNRPxhdrget(&artno, &mid, isCancelControl)) {
-/*#define DEBUG*/
+ }
+ if (ResetActive) {
+ if (rcptr->high != high) {
+ bbsnnrp->actdirty = 1;
+ rcptr->high = high;
+ updaterc(rcptr->highptr, rcptr->highlen, rcptr->high);
+ }
+ } else if (rcptr->high < high) {
+ int xhdrcode;
+ ULONG maxget = high;
+ int exception = 0;
+ if (rcptr->high < low) {
+ bbsnnrp->actdirty = 1;
+ rcptr->high = low;
+ updaterc(rcptr->highptr, rcptr->highlen, low);
+ }
+ if (high > rcptr->high + Max_Stats) {
+ maxget = rcptr->high + Max_Stats;
+ }
+ if (isCancelControl)
+ xhdrcode = NNRPxhdr("Control", bbsnnrp, i, rcptr->high + 1, maxget);
+ else
+ xhdrcode = NNRPxhdr("Message-ID", bbsnnrp, i, rcptr->high + 1, maxget);
+
+ maxartno = maxget;
+ if (xhdrcode == NNRPXhdrOK) {
+ while (NNRPxhdrget(&artno, &mid, isCancelControl)) {
+ /* #define DEBUG */
#ifdef DEBUG
- printf("no %d id %s\n",artno, mid);
+ printf("no %d id %s\n", artno, mid);
#endif
- if (artcount < Max_Arts) {
- if (mid != NULL && !isCancelControl) {
- if (!StatHistory || INNBBSstat(bbsnnrp,i,mid) != INNBBSstatOK) {
- printf("** %d ** %d need it %s\n", artcount, artno,mid);
- XHDR[artcount].artno = artno;
- XHDR[artcount].header = restrdup(XHDR[artcount].header,mid);
- /*INNBBSihave(bbsnnrp,i,artno,mid);*/
- /* to get it */
- artcount++;
- }
- } else if (mid != NULL) {
- if (INNBBSstat(bbsnnrp,i,mid) == INNBBSstatOK) {
- printf("** %d ** %d need cancel %s\n", artcount, artno,mid);
- XHDR[artcount].artno = artno;
- XHDR[artcount].header = restrdup(XHDR[artcount].header,mid);
- artcount++;
- }
- }
- maxartno = artno;
- }
- }
- }/* while xhdr OK */
- exception = 0;
- for (xcount = 0; xcount < artcount; xcount++) {
- ULONG artno;
- char *mid;
- artno = XHDR[xcount].artno;
- mid = XHDR[xcount].header;
- if (isCancelControl) {
- if (NNRPstat(bbsnnrp,artno,&mid) == NNRPstatOK) {
- }
- }
- printf("** %d ** %d i have it %s\n", xcount, artno, mid);
- if (!ResetActive && mid != NULL)
- exception = INNBBSihave(bbsnnrp,artno,mid);
- if (exception == -1) break;
- if (rcptr->high != artno) {
- rcptr->high = artno;
- updaterc(rcptr->highptr, rcptr->highlen, rcptr->high);
+ if (artcount < Max_Arts) {
+ if (mid != NULL && !isCancelControl) {
+ if (!StatHistory || INNBBSstat(bbsnnrp, i, mid) != INNBBSstatOK) {
+ printf("** %d ** %d need it %s\n", artcount, artno, mid);
+ XHDR[artcount].artno = artno;
+ XHDR[artcount].header = restrdup(XHDR[artcount].header, mid);
+ /* INNBBSihave(bbsnnrp,i,artno,mid); */
+ /* to get it */
+ artcount++;
+ }
+ } else if (mid != NULL) {
+ if (INNBBSstat(bbsnnrp, i, mid) == INNBBSstatOK) {
+ printf("** %d ** %d need cancel %s\n", artcount, artno, mid);
+ XHDR[artcount].artno = artno;
+ XHDR[artcount].header = restrdup(XHDR[artcount].header, mid);
+ artcount++;
+ }
+ }
+ maxartno = artno;
+ }
+ }
+ } /* while xhdr OK */
+ exception = 0;
+ for (xcount = 0; xcount < artcount; xcount++) {
+ ULONG artno;
+ char *mid;
+ artno = XHDR[xcount].artno;
+ mid = XHDR[xcount].header;
+ if (isCancelControl) {
+ if (NNRPstat(bbsnnrp, artno, &mid) == NNRPstatOK) {
+ }
+ }
+ printf("** %d ** %d i have it %s\n", xcount, artno, mid);
+ if (!ResetActive && mid != NULL)
+ exception = INNBBSihave(bbsnnrp, artno, mid);
+ if (exception == -1)
+ break;
+ if (rcptr->high != artno) {
+ rcptr->high = artno;
+ updaterc(rcptr->highptr, rcptr->highlen, rcptr->high);
+ }
+ }
+ if (rcptr->high != maxartno && exception != -1) {
+ bbsnnrp->actdirty = 1;
+ rcptr->high = maxartno;
+ updaterc(rcptr->highptr, rcptr->highlen, maxartno);
+ }
}
- }
- if (rcptr->high != maxartno && exception != -1) {
- bbsnnrp->actdirty = 1;
- rcptr->high = maxartno;
- updaterc(rcptr->highptr, rcptr->highlen, maxartno);
- }
- }
- }
- /*
- flushrc(bbsnnrp);
- */
- }
- fprintf(bbsnnrp->innbbsout,"quit\r\n");
- fprintf(bbsnnrp->nnrpout,"quit\r\n");
- fflush(bbsnnrp->innbbsout);
- fflush(bbsnnrp->nnrpout);
- fgets(NNRPbuffer, sizeof NNRPbuffer, bbsnnrp->nnrpin);
- fgets(INNBBSbuffer, sizeof INNBBSbuffer, bbsnnrp->innbbsin);
-
-/* bbsnnrp->newsrc[0].high = 1900;
- updaterc(bbsnnrp->newsrc[0].highptr, bbsnnrp->newsrc[0].highlen,
- bbsnnrp->newsrc[0].high);
-*/
+ }
+ /*
+ * flushrc(bbsnnrp);
+ */
+ }
+ fprintf(bbsnnrp->innbbsout, "quit\r\n");
+ fprintf(bbsnnrp->nnrpout, "quit\r\n");
+ fflush(bbsnnrp->innbbsout);
+ fflush(bbsnnrp->nnrpout);
+ fgets(NNRPbuffer, sizeof NNRPbuffer, bbsnnrp->nnrpin);
+ fgets(INNBBSbuffer, sizeof INNBBSbuffer, bbsnnrp->innbbsin);
+
+ /*
+ * bbsnnrp->newsrc[0].high = 1900; updaterc(bbsnnrp->newsrc[0].highptr,
+ * bbsnnrp->newsrc[0].highlen, bbsnnrp->newsrc[0].high);
+ */
}
INNBBSDhalt()