Changeset a00221d in git for Singular/ssiLink.cc

Timestamp:

Sep 17, 2010, 4:18:56 PM (13 years ago)

Author:

Hans Schoenemann <hannes@…>

Branches:

(u'spielwiese', '8e0ad00ce244dfd0756200662572aef8402f13d5')

Children:

db71a2daf9759c0893a178e8e78e2b4779930cbc

Parents:

7194edf653bb54e050d46f0f8090b86b6ac49d1c

Message:

int slStatusSsiL(lists L, int timeout)

git-svn-id: file:///usr/local/Singular/svn/trunk@13212 2c84dea3-7e68-4137-9b89-c4e89433aadc

File:

• Singular/ssiLink.cc (modified) (1 diff)

Singular/ssiLink.cc

@@ -999 +999 @@
 }
 
+int slStatusSsiL(lists L, int timeout)
+{
+  si_link l;
+  ssiInfo *d;
+  fd_set  mask, fdmask;
+  FD_ZERO(&mask);
+  int max_fd=0; /* max fd in fd_set */
+  struct timeval wt;
+  int i;
+  for(i=L->nr-1; i>=0; i--)
+  {
+    if (L->m[i].Typ()!=LINK_CMD)
+    { WerrorS("all elements must be of type link"); return -2;}
+    l=(si_link)L->m[i].Data();
+    if(!SI_LINK_OPEN_P(l))
+    { WerrorS("all links must be open"); return -2;}
+    if ((strcmp(l->m->type,"ssi")!=0)
+    && (strcmp(l->mode,"fork")!=0) || (strcmp(l->mode,"tcp")!=NULL))
+    { WerrorS("all links must be of type ssi:fork or ssi:tcp"); return -2;}
+    d=(ssiInfo*)l->data;
+    FD_SET(d->fd_read, &mask);
+    if (d->fd_read> max_fd) max_fd=d->fd_read;
+  }
+  struct timeval *wt_ptr=&wt;
+  if (timeout== -1)
+  {
+    wt_ptr=NULL;
+  }
+  else
+  {
+    wt.tv_sec  = timeout / 1000000;
+    wt.tv_usec = timeout % 1000000;
+  }
+  /* check with select: chars waiting: no -> not ready */
+  int s= select(max_fd, &mask, NULL, NULL, wt_ptr);
+  if (s==-1) return -2; /*error*/
+  if (s==0) 
+  {
+    return -1; /*poll: not ready */
+  }
+  else /* s>0, at least one ready */
+  {
+    int j=0;
+    while (j<=max_fd) { if (FD_ISSET(j,&mask)) break; j++; }
+    for(i=L->nr-1; i>=0; i--)
+    {
+      l=(si_link)L->m[i].Data();
+      d=(ssiInfo*)l->data;
+      if(j==d->fd_read) break;
+    }
+    loop
+    {
+      /* yes: read 1 char*/
+      /* if \n, check again with select else ungetc(c), ready*/
+      /* setting: d: current ssiInfo, j current fd, i current entry in L*/
+      int c=fgetc(d->f_read);
+      //Print("try c=%d\n",c);
+      if (c== -1) return 0;
+      else if (isdigit(c))
+      { ungetc(c,d->f_read); return i+1; }
+      else if (c>' ')
+      {
+        Werror("unknown char in ssiLink(%d)",c);
+        return -2;
+      }
+      /* else: next char */
+    }
+  }
+}
+
 int ssiBatch(const char *host, const char * port)
 /* return 0 on success, >0 else*/