WebSVN – wimsdev – Diff – /trunk/wims/src/Misc/ccsum.c

 #define MIN_ADD 1
 /* Accounting discontinues after this number of idle minutes */
 #define MAX_LAPSE 15
 struct {
-    char s[4], u[32];
+  char s[4], u[32];
-    int cl, start, end, cnt;
+  int cl, start, end, cnt;
 } ses[MAX_SESSIONS];
 int sescnt;
 char *datestr;
 struct cls {
-    int cl, cnt;
+  int cl, cnt;
 } cls[MAX_CLASSES];
 int clscnt;
 /* Read/write to a file with variable parms to print filename */
 /* same in Interfaces/common.c and wlogdaccessfile */
 static
 void accessfile(char *content, char *type, char *s,...)
+{
-    va_list vp;
+  va_list vp;
-    char buf[MAX_LINELEN+1];
+  char buf[MAX_LINELEN+1];
-    FILE *f;
+  FILE *f;
-    int l;
+  int l;
-    va_start(vp,s);
+  va_start(vp,s);
-    vsnprintf(buf,sizeof(buf),s,vp);
+  vsnprintf(buf,sizeof(buf),s,vp);
-    va_end(vp);
+  va_end(vp);
-    f=fopen(buf,type); if(f==NULL) {
+  f=fopen(buf,type); if(f==NULL) {
-      if(*type=='r') content[0]=0;
+    if(*type=='r') content[0]=0;
-      return;
+    return;
+  }
+  switch(*type) {
+    case 'a':
+    case 'w': {
+      l=strlen(content); fwrite(content,1,l,f); break;
+    }
-    switch(*type) {
-      case 'a':
-      case 'w': {
-        l=strlen(content); fwrite(content,1,l,f); break;
-      }
-      case 'r': {
+    case 'r': {
-        l=fread(content,1,MAX_LINELEN-1,f);
+      l=fread(content,1,MAX_LINELEN-1,f);
-        if(l>0 && l<MAX_LINELEN) content[l]=0;
+      if(l>0 && l<MAX_LINELEN) content[l]=0;
-        else content[0]=0;
+      else content[0]=0;
-        break;
+      break;
-      }
-     default: {
-        content[0]=0; break;
-     }
+    }
+   default: {
+      content[0]=0; break;
+   }
+  }
-    fclose(f);
+  fclose(f);
+}
 /* recursively generate a directory structure */
 void mkdirs2(char *s)
+{
-    struct stat st;
+  struct stat st;
-    char *buf;
+  char *buf;
-    if(stat(s,&st)==-1) {
+  if(stat(s,&st)==-1) {
-    if(strrchr(s,'/')!=NULL) {
+  if(strrchr(s,'/')!=NULL) {
-        buf=xmalloc(strlen(s)+1);
+    buf=xmalloc(strlen(s)+1);
-        ovlstrcpy(buf,s); *strrchr(buf,'/')=0;
+    ovlstrcpy(buf,s); *strrchr(buf,'/')=0;
-        mkdirs2(buf); free(buf);
+    mkdirs2(buf); free(buf);
-    }
+  }
-    mkdir(s,-1);
+  mkdir(s,-1);
-    }
+  }
+}
 static
 void oneline(char *p)
 {
-    char tbuf[8], sbuf[8], ubuf[256], cbuf[64];
+  char tbuf[8], sbuf[8], ubuf[256], cbuf[64];
-    char *p1, *p2;
+  char *p1, *p2;
-    int i,t,cl;
+  int i,t,cl;
-    memmove(tbuf,p+9,6); tbuf[2]=tbuf[5]=0;
+  memmove(tbuf,p+9,6); tbuf[2]=tbuf[5]=0;
-    t=atoi(tbuf)*60+atoi(tbuf+3);
+  t=atoi(tbuf)*60+atoi(tbuf+3);
-    memmove(sbuf,p+18,4); sbuf[4]=0;
+  memmove(sbuf,p+18,4); sbuf[4]=0;
-    p1=strchr(p,','); if(p1==NULL) return;
+  p1=strchr(p,','); if(p1==NULL) return;
-    if(!isdigit(*(p1+1))) return;
+  if(!isdigit(*(p1+1))) return;
-    snprintf(cbuf,sizeof(cbuf),"%s",p1+1);
+  snprintf(cbuf,sizeof(cbuf),"%s",p1+1);
-    for(p2=cbuf;isdigit(*p2); p2++){};
+  for(p2=cbuf;isdigit(*p2); p2++){};
-    *p2=0; cl=atoi(cbuf);
+  *p2=0; cl=atoi(cbuf);
-    *p1=0; for(p1--;p1>p && !isspace(*(p1-1)); p1--);
+  *p1=0; for(p1--;p1>p && !isspace(*(p1-1)); p1--);
-    snprintf(ubuf,sizeof(ubuf),"%s",p1);
+  snprintf(ubuf,sizeof(ubuf),"%s",p1);
-    for(i=0;i<sescnt;i++) {
+  for(i=0;i<sescnt;i++) {
     if(cl==ses[i].cl && memcmp(sbuf,ses[i].s,4)==0 &&
-       ses[i].end>=t-MAX_LAPSE) {
+        ses[i].end>=t-MAX_LAPSE) {
-        ses[i].end=t; return;
+      ses[i].end=t; return;
     }
-    }
+  }
-    if(sescnt>=MAX_SESSIONS) return;
+  if(sescnt>=MAX_SESSIONS) return;
-    memmove(ses[sescnt].s,sbuf,4); ses[sescnt].cl=cl;
+  memmove(ses[sescnt].s,sbuf,4); ses[sescnt].cl=cl;
-    ses[sescnt].start=ses[sescnt].end=t;
+  ses[sescnt].start=ses[sescnt].end=t;
-    snprintf(ses[sescnt].u,sizeof(ses[sescnt].u),"%s",ubuf);
+  snprintf(ses[sescnt].u,sizeof(ses[sescnt].u),"%s",ubuf);
-    sescnt++;
+  sescnt++;
+}
+void onefile(char *fname)
+{
+  FILE *f;
+  long l;
+  char *fbuf, *p1, *p2, *p3;
+  l=filelength(fname); if(l<=0) return;
+  f=fopen(fname,"r"); if(f==NULL) return;
+  fbuf=xmalloc(l+16); (void)fread(fbuf,1,l,f); fclose(f); fbuf[l]=0;
+  for(p1=fbuf; *p1; p1=p2) {
+  p2=strchr(p1,'\n'); if(p2==NULL) p2=p1+strlen(p1); else *p2++=0;
+  p3=strchr(p1,','); if(p3==NULL) continue;
+  if(strncmp(p1,datestr,8)!=0) continue;
+  oneline(p1);
+  }
+}
-void onefile(char *fname)
+void classaccount(void)
+{
-    FILE *f;
-    long l;
-    char *fbuf, *p1, *p2, *p3;
-    l=filelength(fname); if(l<=0) return;
-    f=fopen(fname,"r"); if(f==NULL) return;
-    fbuf=xmalloc(l+16); (void)fread(fbuf,1,l,f); fclose(f); fbuf[l]=0;
-    for(p1=fbuf; *p1; p1=p2) {
-    p2=strchr(p1,'\n'); if(p2==NULL) p2=p1+strlen(p1); else *p2++=0;
-    p3=strchr(p1,','); if(p3==NULL) continue;
-    if(strncmp(p1,datestr,8)!=0) continue;
-    oneline(p1);
-    }
-}
-void classaccount(void)
-{
-    int i,j;
+  int i,j;
-    clscnt=0;
+  clscnt=0;
-    for(i=0;i<sescnt;i++) {
+  for(i=0;i<sescnt;i++) {
-    ses[i].cnt=ses[i].end-ses[i].start+MIN_ADD;
+  ses[i].cnt=ses[i].end-ses[i].start+MIN_ADD;
-    if(ses[i].cnt<MIN_CONNECT) ses[i].cnt=MIN_CONNECT;
+  if(ses[i].cnt<MIN_CONNECT) ses[i].cnt=MIN_CONNECT;
-    for(j=0;j<clscnt && ses[i].cl!=cls[j].cl;j++);
+  for(j=0;j<clscnt && ses[i].cl!=cls[j].cl;j++);
-    if(j<clscnt) cls[j].cnt+=ses[i].cnt;
+  if(j<clscnt) cls[j].cnt+=ses[i].cnt;
+  else
-    else if(clscnt<MAX_CLASSES) {
+    if(clscnt<MAX_CLASSES) {
-        cls[clscnt].cl=ses[i].cl;
+      cls[clscnt].cl=ses[i].cl;
-        cls[clscnt].cnt=ses[i].cnt;
+      cls[clscnt].cnt=ses[i].cnt;
-        clscnt++;
+      clscnt++;
-    }
+    }
+  }
+}
 int clscmp(const void *c1, const void *c2)
+{
-    struct cls *cl1, *cl2;
+  struct cls *cl1, *cl2;
-    cl1=(struct cls *) c1; cl2=(struct cls *) c2;
+  cl1=(struct cls *) c1; cl2=(struct cls *) c2;
-    return cl1->cl-cl2->cl;
+  return cl1->cl-cl2->cl;
+}
 void output(void)
+{
-    char *p, buf[1024], dbuf[1024];
+  char *p, buf[1024], dbuf[1024];
-    int i,t;
+  int i,t;
-    p=getenv("ccsum_outdir"); if(p==NULL || *p==0) return;
+  p=getenv("ccsum_outdir"); if(p==NULL || *p==0) return;
-    for(i=0;i<sescnt;i++) {
+  for(i=0;i<sescnt;i++) {
     snprintf(dbuf,sizeof(dbuf),"%s/%d",p,ses[i].cl);
     mkdirs2(dbuf);
     snprintf(buf,sizeof(buf),"%s.%02d:%02d %d\n",
-         datestr,ses[i].start/60,ses[i].start%60,ses[i].cnt);
+       datestr,ses[i].start/60,ses[i].start%60,ses[i].cnt);
     accessfile(buf,"a","%s/%s",dbuf,ses[i].u);
-    }
+  }
-    snprintf(dbuf,sizeof(dbuf),"%s/bydate/%.4s",p,datestr);
+  snprintf(dbuf,sizeof(dbuf),"%s/bydate/%.4s",p,datestr);
-    mkdirs2(dbuf);
+  mkdirs2(dbuf);
-    snprintf(dbuf+strlen(dbuf),sizeof(dbuf)-strlen(dbuf),"/%.2s",datestr+4);
+  snprintf(dbuf+strlen(dbuf),sizeof(dbuf)-strlen(dbuf),"/%.2s",datestr+4);
-    t=0;
+  t=0;
-    qsort(cls,clscnt,sizeof(cls[0]),clscmp);
+  qsort(cls,clscnt,sizeof(cls[0]),clscmp);
-    for(i=0;i<clscnt;i++) {
+  for(i=0;i<clscnt;i++) {
     snprintf(buf,sizeof(buf),"%s %d\n",datestr,cls[i].cnt);
     accessfile(buf,"a","%s/%d/.total",p,cls[i].cl);
     snprintf(buf,sizeof(buf),"%s %d %d\n",datestr+4,cls[i].cl,cls[i].cnt);
     accessfile(buf,"a","%s",dbuf);
     t+=cls[i].cnt;
-    }
+  }
-    snprintf(buf,sizeof(buf),"%s %d %d\n",datestr,t,(t+30)/60);
+  snprintf(buf,sizeof(buf),"%s %d %d\n",datestr,t,(t+30)/60);
-    accessfile(buf,"a","%s/done",p);
+  accessfile(buf,"a","%s/done",p);
+}
 int main(int argc, char *argv[])
+{
-    sescnt=0;
+  sescnt=0;
-    if(argc<2) return 1;
+  if(argc<2) return 1;
-    datestr=getenv("ccsum_date");
+  datestr=getenv("ccsum_date");
-    if(datestr==NULL || strlen(datestr)!=8) return 2;
+  if(datestr==NULL || strlen(datestr)!=8) return 2;
-    onefile(argv[1]);
+  onefile(argv[1]);
-    classaccount();
+  classaccount();
-    output();
+  output();
-    return 0;
+  return 0;
+}

Subversion Repositories wimsdev

(root)/trunk/wims/src/Misc/ccsum.c – Rev 11124 → 12248