WebSVN – wimsdev – Diff – /trunk/wims/src/Wimslogd/wimslogd.c

 int cwdtype;
 /* check whether there is anything to execute */
 void logexec(void)
+{
-    struct stat st;
+  struct stat st;
-    pid_t pid;
+  pid_t pid;
-    if(stat("log/wimslogd.exec",&st)) return;
+  if(stat("log/wimslogd.exec",&st)) return;
-    fflush(NULL);
+  fflush(NULL);
-    pid=fork(); if(pid>0) {addfork(pid,1); return;}
+  pid=fork(); if(pid>0) {addfork(pid,1); return;}
-    close(commsock); msleep(100);
+  close(commsock); msleep(100);
-    call_ssh(1,"sh log/wimslogd.exec >tmp/log/wimslogdexec.out 2>tmp/log/wimslogdexec.err");
+  call_ssh(1,"sh log/wimslogd.exec >tmp/log/wimslogdexec.out 2>tmp/log/wimslogdexec.err");
-    unlink("log/wimslogd.exec"); exit(0);
+  unlink("log/wimslogd.exec"); exit(0);
+}
 void local(void)
+{
-    struct stat st;
+  struct stat st;
-    if(stat("log/wimslogd.local",&st)) return;
+  if(stat("log/wimslogd.local",&st)) return;
-    if(!(S_IXUSR&st.st_mode)) return;
+  if(!(S_IXUSR&st.st_mode)) return;
-    call_ssh(0,"sh log/wimslogd.local");
+  call_ssh(0,"sh log/wimslogd.local");
+}
 void getnow(void)
+{
-    nowtime=time(NULL); thismin=(nowtime-rshift)/MINLENGTH;
+  nowtime=time(NULL); thismin=(nowtime-rshift)/MINLENGTH;
-    now=localtime(&nowtime);
+  now=localtime(&nowtime);
-    nowsec=now->tm_sec;
+  nowsec=now->tm_sec;
-    nowmin=now->tm_min; nowhr=now->tm_hour;
+  nowmin=now->tm_min; nowhr=now->tm_hour;
-    nowday=now->tm_mday; nowwday=now->tm_wday;
+  nowday=now->tm_mday; nowwday=now->tm_wday;
-    nowmon=now->tm_mon+1; nowyear=now->tm_year+1900;
+  nowmon=now->tm_mon+1; nowyear=now->tm_year+1900;
-    snprintf(nowstr,sizeof(nowstr),"%04d%02d%02d.%02d:%02d:%02d",
+  snprintf(nowstr,sizeof(nowstr),"%04d%02d%02d.%02d:%02d:%02d",
-           nowyear,nowmon,nowday,nowhr,nowmin,nowsec);
+         nowyear,nowmon,nowday,nowhr,nowmin,nowsec);
+}
 void parms(void)
+{
-    char *p, *p1, *p2, *parm[16];
+  char *p, *p1, *p2, *parm[16];
-    char buf[16];
+  char buf[16];
-    int t,r;
+  int t,r;
-    p=getenv("wimslogd");
+  p=getenv("wimslogd");
-    if(p==NULL || *p==0) return;
+  if(p==NULL || *p==0) return;
-    for(t=0, p1=find_word_start(p); *p1; p1=find_word_start(p2)) {
+  for(t=0, p1=find_word_start(p); *p1; p1=find_word_start(p2)) {
-      p2=find_word_end(p1); if(*p2) *p2++=0;
+    p2=find_word_end(p1); if(*p2) *p2++=0;
-      parm[t++]=p1;
+    parm[t++]=p1;
-    }
+  }
-    idle_time=atoi(parm[0]); if(idle_time<=10) idle_time=5000;
+  idle_time=atoi(parm[0]); if(idle_time<=10) idle_time=5000;
-    idle_time2=atoi(parm[1]); if(idle_time2<=10) idle_time2=idle_time;
+  idle_time2=atoi(parm[1]); if(idle_time2<=10) idle_time2=idle_time;
-    idle_time3=atoi(parm[2]); if(idle_time3<=10) idle_time3=idle_time2;
+  idle_time3=atoi(parm[2]); if(idle_time3<=10) idle_time3=idle_time2;
-    if(idle_time2>idle_time) idle_time2=idle_time;
+  if(idle_time2>idle_time) idle_time2=idle_time;
-    if(idle_time3>idle_time2) idle_time3=idle_time2;
+  if(idle_time3>idle_time2) idle_time3=idle_time2;
-    OLD_LOG_FILES=atoi(parm[3]);
+  OLD_LOG_FILES=atoi(parm[3]);
-    if(OLD_LOG_FILES>100) OLD_LOG_FILES=100;
+  if(OLD_LOG_FILES>100) OLD_LOG_FILES=100;
-    if(parm[4]) GEN_LOG_LIMIT=atoi(parm[4]);
+  if(parm[4]) GEN_LOG_LIMIT=atoi(parm[4]);
-    if(parm[5]) MODULE_LOG_LIMIT=atoi(parm[5]);
+  if(parm[5]) MODULE_LOG_LIMIT=atoi(parm[5]);
-    if(parm[6]) backup_hour=atoi(parm[6]);
+  if(parm[6]) backup_hour=atoi(parm[6]);
-    if(parm[7]) site_accounting=atoi(parm[7]);
+  if(parm[7]) site_accounting=atoi(parm[7]);
-    if(parm[8]) r=atoi(parm[8])+1; else r=8;
+  if(parm[8]) r=atoi(parm[8])+1; else r=8;
-    if(r<2) r=2;
+  if(r<2) r=2;
-    if(r>100) r=100;
+  if(r>100) r=100;
-    snprintf(buf,sizeof(buf),"%d",r); setenv("examlog_lim2",buf,1);
+  snprintf(buf,sizeof(buf),"%d",r); setenv("examlog_lim2",buf,1);
-    if(site_accounting>0) setenv("site_accounting","yes",1);
+  if(site_accounting>0) setenv("site_accounting","yes",1);
+}
 /* This is run only when manually invoking the program.
  * Verifies the orderedness of various list tables.
  */
 int verify_tables(void)
+{
-    if(verify_order(cmdlist,cmdcnt,sizeof(cmdlist[0]))) return -1;
+  if(verify_order(cmdlist,cmdcnt,sizeof(cmdlist[0]))) return -1;
-    return 0;
+  return 0;
+}
 int main(int argc, char *argv[])
+{
-    char *p;
+  char *p;
-    struct stat st;
+  struct stat st;
-    uid_t myid;
+  uid_t myid;
-    int /*mfd,*/rsock,mincnt;
+  int /*mfd,*/rsock,mincnt;
-    char buf[MAX_LINELEN+1];
+  char buf[MAX_LINELEN+1];
-    forkcnt=0; exec_wait=1; mincnt=0;
+  forkcnt=0; exec_wait=1; mincnt=0;
-    classcaches=sheetcaches=0;
+  classcaches=sheetcaches=0;
-    (void)freopen("/dev/null","r",stdin);
+  (void)freopen("/dev/null","r",stdin);
-    (void)freopen("../tmp/log/wimslogd.out","w",stdout);
+  (void)freopen("../tmp/log/wimslogd.out","w",stdout);
-    (void)freopen("../tmp/log/wimslogd.err","w",stderr);
+  (void)freopen("../tmp/log/wimslogd.err","w",stderr);
-/*    mfd=shm_open(SHM_NAME,O_RDWR|O_CREAT|O_TRUNC,S_IRUSR|S_IWUSR);
+  /*    mfd=shm_open(SHM_NAME,O_RDWR|O_CREAT|O_TRUNC,S_IRUSR|S_IWUSR);
     write(mfd,buf,SHM_SIZE);
     shmptr=mmap(0,SHM_SIZE,PROT_READ|PROT_WRITE,MAP_SHARED,mfd,0);
     if(shmptr==MAP_FAILED) {
       fprintf(stderr,"wimslogd: mmap() failure. %s\n",
             strerror(errno));
       exit(1);
     }
-*/
+  */
-    verify_tables();
+  verify_tables();
-    init_random();
+  init_random();
-    modupdatetime=(double) random()*350/RAND_MAX;
+  modupdatetime=(double) random()*350/RAND_MAX;
-    rshift=(double) random()*MINLENGTH/RAND_MAX;
+  rshift=(double) random()*MINLENGTH/RAND_MAX;
-    parms();
+  parms();
-    if(getcwd(cwd,sizeof(cwd))==NULL) {      /* directory missing */
+  if(getcwd(cwd,sizeof(cwd))==NULL) {      /* directory missing */
-      fprintf(stderr,"wimslogd: getcwd() failure. %s\n",
+    fprintf(stderr,"wimslogd: getcwd() failure. %s\n",
-            strerror(errno));
+          strerror(errno));
+    return 1;
+  }
+  p=strstr(cwd,"/public_html");
+  if(p!=NULL && *(p+strlen("/public_html"))==0) {
+    *p=0;
+    if(chdir(cwd)<0) {      /* strong error */
+      fprintf(stderr,"wimslogd: Unable to change directory. %s\n",
+                strerror(errno));
       return 1;
+    }
+  }
+  opensock();
+  mypid=getpid();
+  myid=geteuid(); setreuid(myid,myid);
+  myid=getegid(); setregid(myid,myid);
+  stat("/sysmask/notice/init-end",&st);
+  snprintf(pidstr,sizeof(pidstr),"%u",mypid);
+  getnow(); printf("wimslogd %s started at %s.\n",pidstr,nowstr);
+  startdate=nowday;
+  fflush(NULL);
+  starttime=nowtime; startmin=lastmin=thismin;
+  wlogdaccessfile(qbuf,"r","log/cquota/lim.host");
+  wlogdaccessfile(buf,"r","log/myip"); mystrncpy(ipbuf,find_word_start(buf),sizeof(ipbuf));
+  wlogdaccessfile(buf,"r","tmp/log/wimslogd.relax"); /* if yes then it is a cluster child */
+  if(strstr(buf,"yes")!=NULL) {      /* register my real IP */
+    wlogdaccessfile(nodeipbuf,"r","/etc/myip");
+    wlogdaccessfile(nodeipbuf,"w","tmp/log/myip");
+  }
+  do {
+    fd_set rset;
-    p=strstr(cwd,"/public_html");
+    struct timeval tv;
+    int t, selectcnt;
+    if(getpid()!=mypid) return 0;      /* leaked child */
+    if(stat(debugfile,&st)==0 && st.st_size<MAX_DEBUGLENGTH) debugging=1;
+    else debugging=0;
+    wlogdaccessfile(loadavg,"r","/proc/loadavg");
-    if(p!=NULL && *(p+strlen("/public_html"))==0) {
+    for(selectcnt=0; selectcnt<100; selectcnt++) {
-      *p=0; if(chdir(cwd)<0) {      /* strong error */
+      tv.tv_sec=0; tv.tv_usec=50000; /* a pause every 50 ms. */
+      FD_ZERO(&rset); FD_SET(commsock,&rset);
+      t=select(commsock+1,&rset,NULL,NULL,&tv);
+        if(t==0) {forkman(0); continue;}
-          fprintf(stderr,"wimslogd: Unable to change directory. %s\n",
+        if(t<0) {wimslogd_error("select() error."); continue;}
-                strerror(errno));
+        rsock=accept(commsock,NULL,NULL);
+        if(rsock==-1) {wimslogd_error("accept() error."); continue;}
-          return 1;
+        answer(rsock);
-      }
+    }
+    forkman(1);
+    getnow();
+    if(thismin==lastmin) continue;
+    mincnt++; /* if(mincnt>MAX_MIN) return 0; Refreshment. */
+    if(nowday!=startdate) return 0; /* Daily refreshment. */
+    lastmin=thismin;
+    wlogdaccessfile(buf,"r",pidfile); strip_trailing_spaces(buf);
+    if(strcmp(buf,pidstr)!=0) {      /* wrong pid: abandon. */
+      wait_children();
+      return 0;
+    }
-    opensock();
-    mypid=getpid();
-    myid=geteuid(); setreuid(myid,myid);
-    myid=getegid(); setregid(myid,myid);
+    if(getpid()!=mypid) return 0;      /* leaked child */
-    stat("/sysmask/notice/init-end",&st);
-    snprintf(pidstr,sizeof(pidstr),"%u",mypid);
-    getnow(); printf("wimslogd %s started at %s.\n",pidstr,nowstr);
-    startdate=nowday;
-    fflush(NULL);
-    starttime=nowtime; startmin=lastmin=thismin;
     wlogdaccessfile(qbuf,"r","log/cquota/lim.host");
     wlogdaccessfile(buf,"r","log/myip"); mystrncpy(ipbuf,find_word_start(buf),sizeof(ipbuf));
+    cleancache();
+    if((thismin%127)==6) homedir();      /* update home directory setup */
-    wlogdaccessfile(buf,"r","tmp/log/wimslogd.relax"); /* if yes then it is a cluster child */
+    wlogdaccessfile(buf,"r","tmp/log/wimslogd.relax"); /* if yes then no housekeeping */
-    if(strstr(buf,"yes")!=NULL) {      /* register my real IP */
+    if(strstr(buf,"yes")==NULL) {
+      dispatch_log();
-      wlogdaccessfile(nodeipbuf,"r","/etc/myip");
+      if((thismin%2)==1) local();
+      /* if((thismin%9)==0) */ cleaning(1);       /* clean up session directories */
+      if((thismin%5)==0 && nowmin>15) housekeep();      /* daily housekeeping */
-      wlogdaccessfile(nodeipbuf,"w","tmp/log/myip");
+      if(getpid()!=mypid) return 0;      /* leaked child */
+      if(nowhr*60+nowmin>modupdatetime && (thismin%17)==11) modupdate();
+      if(backup_hour>0 && backup_hour<23 && (thismin%17)==3 && nowhr>=backup_hour)
+        backup();      /* daily backup */
+      fflush(NULL);
+      logexec();
+    }
-    do {
-      fd_set rset;
-      struct timeval tv;
-      int t, selectcnt;
-      if(getpid()!=mypid) return 0;      /* leaked child */
-      if(stat(debugfile,&st)==0 && st.st_size<MAX_DEBUGLENGTH) debugging=1;
-      else debugging=0;
-      wlogdaccessfile(loadavg,"r","/proc/loadavg");
-      for(selectcnt=0; selectcnt<100; selectcnt++) {
-          tv.tv_sec=0; tv.tv_usec=50000; /* a pause every 50 ms. */
-          FD_ZERO(&rset); FD_SET(commsock,&rset);
-          t=select(commsock+1,&rset,NULL,NULL,&tv);
-          if(t==0) {forkman(0); continue;}
-          if(t<0) {wimslogd_error("select() error."); continue;}
-          rsock=accept(commsock,NULL,NULL);
-          if(rsock==-1) {wimslogd_error("accept() error."); continue;}
-          answer(rsock);
-      }
-      forkman(1);
-      getnow();
-      if(thismin==lastmin) continue;
-      mincnt++; /* if(mincnt>MAX_MIN) return 0; Refreshment. */
-      if(nowday!=startdate) return 0; /* Daily refreshment. */
-      lastmin=thismin;
-        wlogdaccessfile(buf,"r",pidfile); strip_trailing_spaces(buf);
-      if(strcmp(buf,pidstr)!=0) {      /* wrong pid: abandon. */
-          wait_children();
-          return 0;
-      }
-      if(getpid()!=mypid) return 0;      /* leaked child */
-      wlogdaccessfile(qbuf,"r","log/cquota/lim.host");
-      wlogdaccessfile(buf,"r","log/myip"); mystrncpy(ipbuf,find_word_start(buf),sizeof(ipbuf));
-      cleancache();
-      if((thismin%127)==6) homedir();      /* update home directory setup */
-      wlogdaccessfile(buf,"r","tmp/log/wimslogd.relax"); /* if yes then no housekeeping */
-      if(strstr(buf,"yes")==NULL) {
-          dispatch_log();
-          if((thismin%2)==1) local();
-          /* if((thismin%9)==0) */ cleaning(1);       /* clean up session directories */
-          if((thismin%5)==0 && nowmin>15) housekeep();      /* daily housekeeping */
-          if(getpid()!=mypid) return 0;      /* leaked child */
-          if(nowhr*60+nowmin>modupdatetime && (thismin%17)==11) modupdate();
-          if(backup_hour>0 && backup_hour<23 && (thismin%17)==3 && nowhr>=backup_hour)
-            backup();      /* daily backup */
-          fflush(NULL);
-          logexec();
-      }
-      else {      /* cluster child */
+    else {      /* cluster child */
-          if((thismin%9)==0) cleaning(0);       /* clean up session directories */
+      if((thismin%9)==0) cleaning(0);       /* clean up session directories */
-      }
+    }
+  }
-    while(1==1);
+  while(1==1);
-    return 0;
+  return 0;
+}

Subversion Repositories wimsdev

(root)/trunk/wims/src/Wimslogd/wimslogd.c – Rev 11125 → 12472