Data Structures | Macros | Typedefs | Functions | Variables
silink.h File Reference
#include <singularconfig.h>
#include <kernel/structs.h>
#include <Singular/links/sing_dbm.h>
#include <Singular/lists.h>
#include <Singular/attrib.h>
#include <omalloc/omalloc.h>

Go to the source code of this file.

Data Structures

Macros

#define SI_LINK_CLOSE   0
 
#define SI_LINK_OPEN   1
 
#define SI_LINK_READ   2
 
#define SI_LINK_WRITE   4
 
#define SI_LINK_CLOSE_P(l)   (!(l)->flags)
 
#define SI_LINK_OPEN_P(l)   ((l)->flags & SI_LINK_OPEN)
 
#define SI_LINK_W_OPEN_P(l)   ((l)->flags & SI_LINK_WRITE)
 
#define SI_LINK_R_OPEN_P(l)   ((l)->flags & SI_LINK_READ)
 
#define SI_LINK_RW_OPEN_P(l)   (SI_LINK_W_OPEN_P(l) && SI_LINK_R_OPEN_P(l))
 
#define SI_LINK_SET_CLOSE_P(l)   ((l)->flags = SI_LINK_CLOSE)
 
#define SI_LINK_SET_OPEN_P(l, flag)   ((l)->flags |= SI_LINK_OPEN |flag)
 
#define SI_LINK_SET_W_OPEN_P(l)   ((l)->flags |= (SI_LINK_OPEN | SI_LINK_WRITE))
 
#define SI_LINK_SET_R_OPEN_P(l)   ((l)->flags |= (SI_LINK_OPEN | SI_LINK_READ))
 
#define SI_LINK_SET_RW_OPEN_P(l)   ((l)->flags |= (SI_LINK_OPEN | SI_LINK_READ | SI_LINK_WRITE))
 

Typedefs

typedef ip_link * si_link
 
typedef BOOLEAN(* slOpenProc) (si_link l, short flag, leftv h)
 
typedef BOOLEAN(* slWriteProc) (si_link l, leftv lv)
 
typedef BOOLEAN(* slCloseProc) (si_link l)
 
typedef BOOLEAN(* slPrepCloseProc) (si_link l)
 
typedef BOOLEAN(* slKillProc) (si_link l)
 
typedef leftv(* slReadProc) (si_link l)
 
typedef leftv(* slRead2Proc) (si_link l, leftv a)
 
typedef BOOLEAN(* slDumpProc) (si_link l)
 
typedef BOOLEAN(* slGetDumpProc) (si_link l)
 
typedef const char *(* slStatusProc) (si_link l, const char *request)
 
typedef BOOLEAN(* slSetRingProc) (si_link l, ring r, BOOLEAN send)
 
typedef link_structlink_list
 

Functions

BOOLEAN slOpen (si_link l, short flag, leftv h)
 
BOOLEAN slClose (si_link l)
 
BOOLEAN slPrepClose (si_link l)
 
leftv slRead (si_link l, leftv a=NULL)
 
BOOLEAN slWrite (si_link l, leftv v)
 
BOOLEAN slDump (si_link l)
 
BOOLEAN slGetDump (si_link l)
 
const char * slStatus (si_link l, const char *request)
 
BOOLEAN slInit (si_link l, char *str)
 
void slKill (si_link l)
 
void slCleanUp (si_link l)
 
void slStandardInit ()
 
si_link slCopy (si_link l)
 
char * slString (si_link l)
 
int slStatusSsiL (lists L, int timeout)
 
int ssiBatch (const char *host, const char *port)
 

Variables

omBin s_si_link_extension_bin
 
omBin sip_link_bin
 
omBin ip_link_bin
 
link_list ssiToBeClosed
 
volatile BOOLEAN ssiToBeClosed_inactive
 

Data Structure Documentation

◆ s_si_link_extension

struct s_si_link_extension

Definition at line 35 of file silink.h.

Data Fields
slCloseProc Close
slDumpProc Dump
slGetDumpProc GetDump
slKillProc Kill
si_link_extension next
slOpenProc Open
slPrepCloseProc PrepClose
slReadProc Read
slRead2Proc Read2
slSetRingProc SetRing
slStatusProc Status
const char * type
slWriteProc Write

◆ sip_link

struct sip_link

Definition at line 52 of file silink.h.

Data Fields
void * data
BITSET flags
si_link_extension m
char * mode
char * name
short ref

◆ link_struct

struct link_struct

Definition at line 120 of file silink.h.

Data Fields
si_link l
void * next
leftv u

Macro Definition Documentation

◆ SI_LINK_CLOSE

#define SI_LINK_CLOSE   0

Definition at line 63 of file silink.h.

◆ SI_LINK_CLOSE_P

#define SI_LINK_CLOSE_P (   l)    (!(l)->flags)

Definition at line 69 of file silink.h.

◆ SI_LINK_OPEN

#define SI_LINK_OPEN   1

Definition at line 64 of file silink.h.

◆ SI_LINK_OPEN_P

#define SI_LINK_OPEN_P (   l)    ((l)->flags & SI_LINK_OPEN)

Definition at line 70 of file silink.h.

◆ SI_LINK_R_OPEN_P

#define SI_LINK_R_OPEN_P (   l)    ((l)->flags & SI_LINK_READ)

Definition at line 72 of file silink.h.

◆ SI_LINK_READ

#define SI_LINK_READ   2

Definition at line 65 of file silink.h.

◆ SI_LINK_RW_OPEN_P

#define SI_LINK_RW_OPEN_P (   l)    (SI_LINK_W_OPEN_P(l) && SI_LINK_R_OPEN_P(l))

Definition at line 73 of file silink.h.

◆ SI_LINK_SET_CLOSE_P

#define SI_LINK_SET_CLOSE_P (   l)    ((l)->flags = SI_LINK_CLOSE)

Definition at line 75 of file silink.h.

◆ SI_LINK_SET_OPEN_P

#define SI_LINK_SET_OPEN_P (   l,
  flag 
)    ((l)->flags |= SI_LINK_OPEN |flag)

Definition at line 76 of file silink.h.

◆ SI_LINK_SET_R_OPEN_P

#define SI_LINK_SET_R_OPEN_P (   l)    ((l)->flags |= (SI_LINK_OPEN | SI_LINK_READ))

Definition at line 78 of file silink.h.

◆ SI_LINK_SET_RW_OPEN_P

#define SI_LINK_SET_RW_OPEN_P (   l)    ((l)->flags |= (SI_LINK_OPEN | SI_LINK_READ | SI_LINK_WRITE))

Definition at line 79 of file silink.h.

◆ SI_LINK_SET_W_OPEN_P

#define SI_LINK_SET_W_OPEN_P (   l)    ((l)->flags |= (SI_LINK_OPEN | SI_LINK_WRITE))

Definition at line 77 of file silink.h.

◆ SI_LINK_W_OPEN_P

#define SI_LINK_W_OPEN_P (   l)    ((l)->flags & SI_LINK_WRITE)

Definition at line 71 of file silink.h.

◆ SI_LINK_WRITE

#define SI_LINK_WRITE   4

Definition at line 66 of file silink.h.

Typedef Documentation

◆ link_list

Definition at line 127 of file silink.h.

◆ si_link

typedef ip_link* si_link

Definition at line 19 of file silink.h.

◆ slCloseProc

typedef BOOLEAN(* slCloseProc) (si_link l)

Definition at line 25 of file silink.h.

◆ slDumpProc

typedef BOOLEAN(* slDumpProc) (si_link l)

Definition at line 30 of file silink.h.

◆ slGetDumpProc

typedef BOOLEAN(* slGetDumpProc) (si_link l)

Definition at line 31 of file silink.h.

◆ slKillProc

typedef BOOLEAN(* slKillProc) (si_link l)

Definition at line 27 of file silink.h.

◆ slOpenProc

typedef BOOLEAN(* slOpenProc) (si_link l, short flag, leftv h)

Definition at line 23 of file silink.h.

◆ slPrepCloseProc

typedef BOOLEAN(* slPrepCloseProc) (si_link l)

Definition at line 26 of file silink.h.

◆ slRead2Proc

typedef leftv(* slRead2Proc) (si_link l, leftv a)

Definition at line 29 of file silink.h.

◆ slReadProc

typedef leftv(* slReadProc) (si_link l)

Definition at line 28 of file silink.h.

◆ slSetRingProc

typedef BOOLEAN(* slSetRingProc) (si_link l, ring r, BOOLEAN send)

Definition at line 33 of file silink.h.

◆ slStatusProc

typedef const char*(* slStatusProc) (si_link l, const char *request)

Definition at line 32 of file silink.h.

◆ slWriteProc

typedef BOOLEAN(* slWriteProc) (si_link l, leftv lv)

Definition at line 24 of file silink.h.

Function Documentation

◆ slCleanUp()

void slCleanUp ( si_link  l)

Definition at line 132 of file silink.cc.

133 {
134  defer_shutdown++;
135  (l->ref)--;
136  if (l->ref == 0)
137  {
138  if (SI_LINK_OPEN_P(l))
139  {
140  if (l->m->Close != NULL) l->m->Close(l);
141  }
142  if ((l->data != NULL) && (l->m->Kill != NULL)) l->m->Kill(l);
143  omFree((ADDRESS)l->name);
144  omFree((ADDRESS)l->mode);
145  memset((void *) l, 0, sizeof(ip_link));
146  }
147  defer_shutdown--;
148  if (!defer_shutdown && do_shutdown) m2_end(1);
149 }
void m2_end(int i)
Definition: misc_ip.cc:1074
void * ADDRESS
Definition: auxiliary.h:115
volatile BOOLEAN do_shutdown
Definition: cntrlc.cc:83
#define omFree(addr)
Definition: omAllocDecl.h:261
#define NULL
Definition: omList.c:10
volatile int defer_shutdown
Definition: cntrlc.cc:84
int l
Definition: cfEzgcd.cc:94

◆ slClose()

BOOLEAN slClose ( si_link  l)

Definition at line 247 of file silink.cc.

248 {
249 
250  if(! SI_LINK_OPEN_P(l))
251  return FALSE;
252 
253  defer_shutdown++;
254  BOOLEAN res = TRUE;
255  if (l->m->Close != NULL)
256  {
257  res = l->m->Close(l);
258  if (res)
259  Werror("close: Error for link of type: %s, mode: %s, name: %s",
260  l->m->type, l->mode, l->name);
261  }
262  defer_shutdown--;
263  if (!defer_shutdown && do_shutdown) m2_end(1);
265  return res;
266 }
#define FALSE
Definition: auxiliary.h:94
void m2_end(int i)
Definition: misc_ip.cc:1074
#define TRUE
Definition: auxiliary.h:98
poly res
Definition: myNF.cc:322
volatile BOOLEAN do_shutdown
Definition: cntrlc.cc:83
#define NULL
Definition: omList.c:10
volatile int defer_shutdown
Definition: cntrlc.cc:84
int BOOLEAN
Definition: auxiliary.h:85
void Werror(const char *fmt,...)
Definition: reporter.cc:189
int l
Definition: cfEzgcd.cc:94

◆ slCopy()

si_link slCopy ( si_link  l)
inline

Definition at line 93 of file silink.h.

94 {
95  l->ref++;
96  return l;
97 }
int l
Definition: cfEzgcd.cc:94

◆ slDump()

BOOLEAN slDump ( si_link  l)

Definition at line 351 of file silink.cc.

352 {
353  BOOLEAN res;
354 
355  if(! SI_LINK_W_OPEN_P(l)) // open w ?
356  {
357  if (slOpen(l, SI_LINK_WRITE,NULL)) return TRUE;
358  }
359 
360  if(SI_LINK_W_OPEN_P(l))
361  { // now open w
362  if (l->m->Dump != NULL)
363  res = l->m->Dump(l);
364  else
365  res = TRUE;
366 
367  if (res)
368  Werror("dump: Error for link of type %s, mode: %s, name: %s",
369  l->m->type, l->mode, l->name);
370  if (!SI_LINK_R_OPEN_P(l)) slClose(l); // do not close r/w links
371  return res;
372  }
373  else
374  {
375  Werror("dump: Error to open link of type %s, mode: %s, name: %s for writing",
376  l->m->type, l->mode, l->name);
377  return TRUE;
378  }
379 }
#define TRUE
Definition: auxiliary.h:98
poly res
Definition: myNF.cc:322
#define NULL
Definition: omList.c:10
int BOOLEAN
Definition: auxiliary.h:85
void Werror(const char *fmt,...)
Definition: reporter.cc:189
int l
Definition: cfEzgcd.cc:94

◆ slGetDump()

BOOLEAN slGetDump ( si_link  l)

Definition at line 381 of file silink.cc.

382 {
383  BOOLEAN res;
384 
385  if(! SI_LINK_R_OPEN_P(l)) // open r ?
386  {
387  if (slOpen(l, SI_LINK_READ,NULL)) return TRUE;
388  }
389 
390  if(SI_LINK_R_OPEN_P(l))
391  { // now open r
392  if (l->m->GetDump != NULL)
393  res = l->m->GetDump(l);
394  else
395  res = TRUE;
396 
397  if (res)
398  Werror("getdump: Error for link of type %s, mode: %s, name: %s",
399  l->m->type, l->mode, l->name);
400  //res|=slClose(l);
401  return res;
402  }
403  else
404  {
405  Werror("dump: Error open link of type %s, mode: %s, name: %s for reading",
406  l->m->type, l->mode, l->name);
407  return TRUE;
408  }
409 }
#define TRUE
Definition: auxiliary.h:98
poly res
Definition: myNF.cc:322
#define NULL
Definition: omList.c:10
int BOOLEAN
Definition: auxiliary.h:85
void Werror(const char *fmt,...)
Definition: reporter.cc:189
int l
Definition: cfEzgcd.cc:94

◆ slInit()

BOOLEAN slInit ( si_link  l,
char *  str 
)

Definition at line 53 of file silink.cc.

54 {
55  char *type = NULL, *mode = NULL, *name = NULL;
56  int i = 0, j;
57 
58  // set mode and type
59  if (istr != NULL)
60  {
61  // find the first colon char in istr
62  i = 0;
63  while (istr[i] != ':' && istr[i] != '\0') i++;
64  if (istr[i] == ':')
65  {
66  // if found, set type
67  if (i > 0)
68  {
69  istr[i] = '\0';
70  type = omStrDup(istr);
71  istr[i] = ':';
72  }
73  // and check for mode
74  j = ++i;
75  while (istr[j] != ' ' && istr[j] != '\0') j++;
76  if (j > i)
77  {
78  mode = omStrDup(&(istr[i]));
79  mode[j - i] = '\0';
80  }
81  // and for the name
82  while (istr[j] == ' '&& istr[j] != '\0') j++;
83  if (istr[j] != '\0') name = omStrDup(&(istr[j]));
84  }
85  else // no colon find -- string is entire name
86  {
87  j=0;
88  while (istr[j] == ' '&& istr[j] != '\0') j++;
89  if (istr[j] != '\0') name = omStrDup(&(istr[j]));
90  }
91  }
92 
93  // set the link extension
94  if (type != NULL)
95  {
96  si_link_extension s = si_link_root;
97  si_link_extension prev = s;
98 
99  while (strcmp(s->type, type) != 0)
100  {
101  if (s->next == NULL)
102  {
103  prev = s;
104  s = NULL;
105  break;
106  }
107  else
108  {
109  s = s->next;
110  }
111  }
112 
113  if (s != NULL)
114  l->m = s;
115  else
116  {
117  l->m = slTypeInit(prev, type);
118  }
119  omFree(type);
120  }
121  else
122  l->m = si_link_root;
123 
124  if (l->m == NULL) return TRUE;
125 
126  l->name = (name != NULL ? name : omStrDup(""));
127  l->mode = (mode != NULL ? mode : omStrDup(""));
128  l->ref = 1;
129  return FALSE;
130 }
const CanonicalForm int s
Definition: facAbsFact.cc:55
#define FALSE
Definition: auxiliary.h:94
#define TRUE
Definition: auxiliary.h:98
int j
Definition: myNF.cc:70
#define omFree(addr)
Definition: omAllocDecl.h:261
int i
Definition: cfEzgcd.cc:123
char name(const Variable &v)
Definition: factory.h:178
#define NULL
Definition: omList.c:10
int l
Definition: cfEzgcd.cc:94
#define omStrDup(s)
Definition: omAllocDecl.h:263

◆ slKill()

void slKill ( si_link  l)

Definition at line 151 of file silink.cc.

152 {
153  defer_shutdown++;
154  slCleanUp(l);
155  if ((l!=NULL) &&(l->ref == 0))
157  defer_shutdown--;
158  if (!defer_shutdown && do_shutdown) m2_end(1);
159 }
void m2_end(int i)
Definition: misc_ip.cc:1074
void * ADDRESS
Definition: auxiliary.h:115
volatile BOOLEAN do_shutdown
Definition: cntrlc.cc:83
#define NULL
Definition: omList.c:10
volatile int defer_shutdown
Definition: cntrlc.cc:84
#define omFreeBin(addr, bin)
Definition: omAllocDecl.h:259
int l
Definition: cfEzgcd.cc:94

◆ slOpen()

BOOLEAN slOpen ( si_link  l,
short  flag,
leftv  h 
)

Definition at line 199 of file silink.cc.

200 {
201  BOOLEAN res = TRUE;
202  if (l!=NULL)
203  {
204 
205  if (l->m == NULL) slInit(l, ((char*)""));
206 
207  if (feOptValue(FE_OPT_NO_SHELL)) {WerrorS("no links allowed");return TRUE;}
208 
209  const char *c="_";;
210  if (h!=NULL) c=h->Name();
211 
212  if (SI_LINK_OPEN_P(l))
213  {
214  Warn("open: link of type: %s, mode: %s, name: %s is already open",
215  l->m->type, l->mode, l->name);
216  return FALSE;
217  }
218  else if (l->m->Open != NULL)
219  {
220  res = l->m->Open(l, flag, h);
221  if (res)
222  Werror("open: Error for link %s of type: %s, mode: %s, name: %s",
223  c, l->m->type, l->mode, l->name);
224  }
225  if (l->m->SetRing==NULL) l->m->SetRing=slSetRingDummy;
226  }
227  return res;
228 }
static void * feOptValue(feOptIndex opt)
Definition: feOpt.h:40
#define FALSE
Definition: auxiliary.h:94
#define TRUE
Definition: auxiliary.h:98
void WerrorS(const char *s)
Definition: feFopen.cc:24
const char * Name()
Definition: subexpr.h:120
poly res
Definition: myNF.cc:322
#define NULL
Definition: omList.c:10
int BOOLEAN
Definition: auxiliary.h:85
void Werror(const char *fmt,...)
Definition: reporter.cc:189
int l
Definition: cfEzgcd.cc:94
#define Warn
Definition: emacs.cc:80

◆ slPrepClose()

BOOLEAN slPrepClose ( si_link  l)

Definition at line 230 of file silink.cc.

231 {
232 
233  if(! SI_LINK_OPEN_P(l))
234  return FALSE;
235 
236  BOOLEAN res = TRUE;
237  if (l->m->PrepClose != NULL)
238  {
239  res = l->m->PrepClose(l);
240  if (res)
241  Werror("close: Error for link of type: %s, mode: %s, name: %s",
242  l->m->type, l->mode, l->name);
243  }
244  return res;
245 }
#define FALSE
Definition: auxiliary.h:94
#define TRUE
Definition: auxiliary.h:98
poly res
Definition: myNF.cc:322
#define NULL
Definition: omList.c:10
int BOOLEAN
Definition: auxiliary.h:85
void Werror(const char *fmt,...)
Definition: reporter.cc:189
int l
Definition: cfEzgcd.cc:94

◆ slRead()

leftv slRead ( si_link  l,
leftv  a = NULL 
)

Definition at line 268 of file silink.cc.

269 {
270  leftv v = NULL;
271  if( ! SI_LINK_R_OPEN_P(l)) // open r ?
272  {
273 #ifdef HAVE_DBM
274 #ifdef USE_GDBM
275  if (! SI_LINK_CLOSE_P(l))
276  {
277  if (slClose(l)) return NULL;
278  }
279 #endif
280 #endif
281  if (slOpen(l, SI_LINK_READ,NULL)) return NULL;
282  }
283 
284  if (SI_LINK_R_OPEN_P(l))
285  { // open r
286  if (a==NULL)
287  {
288  if (l->m->Read != NULL) v = l->m->Read(l);
289  }
290  else
291  {
292  if (l->m->Read2 != NULL) v = l->m->Read2(l,a);
293  }
294  }
295  else
296  {
297  Werror("read: Error to open link of type %s, mode: %s, name: %s for reading",
298  l->m->type, l->mode, l->name);
299  return NULL;
300  }
301 
302  // here comes the eval:
303  if (v != NULL)
304  {
305  if (v->Eval() && !errorreported)
306  WerrorS("eval: failed");
307  }
308  else
309  Werror("read: Error for link of type %s, mode: %s, name: %s",
310  l->m->type, l->mode, l->name);
311  return v;
312 }
Class used for (list of) interpreter objects.
Definition: subexpr.h:82
int Eval()
Definition: subexpr.cc:1760
void WerrorS(const char *s)
Definition: feFopen.cc:24
short errorreported
Definition: feFopen.cc:23
const Variable & v
< [in] a sqrfree bivariate poly
Definition: facBivar.h:37
#define NULL
Definition: omList.c:10
void Werror(const char *fmt,...)
Definition: reporter.cc:189
int l
Definition: cfEzgcd.cc:94

◆ slStandardInit()

void slStandardInit ( )

Definition at line 575 of file asciiLink.cc.

576 {
577  si_link_extension s;
580  si_link_root->Close=slCloseAscii;
581  si_link_root->Kill=NULL;
583  si_link_root->Read2=slReadAscii2;
584  si_link_root->Write=slWriteAscii;
586  si_link_root->GetDump=slGetDumpAscii;
587  si_link_root->Status=slStatusAscii;
588  si_link_root->type="ASCII";
589  s = si_link_root;
590  s->next = NULL;
591 }
const CanonicalForm int s
Definition: facAbsFact.cc:55
#define omAlloc0Bin(bin)
Definition: omAllocDecl.h:206
#define NULL
Definition: omList.c:10

◆ slStatus()

const char* slStatus ( si_link  l,
const char *  request 
)

Definition at line 161 of file silink.cc.

162 {
163  if (l == NULL) return "empty link";
164  else if (l->m == NULL) return "unknown link type";
165  else if (strcmp(request, "type") == 0) return l->m->type;
166  else if (strcmp(request, "mode") == 0) return l->mode;
167  else if (strcmp(request, "name") == 0) return l->name;
168  else if (strcmp(request, "exists") ==0)
169  {
170  struct stat buf;
171  if (si_lstat(l->name,&buf)==0) return "yes";
172  else return "no";
173  }
174  else if (strcmp(request, "open") == 0)
175  {
176  if (SI_LINK_OPEN_P(l)) return "yes";
177  else return "no";
178  }
179  else if (strcmp(request, "openread") == 0)
180  {
181  if (SI_LINK_R_OPEN_P(l)) return "yes";
182  else return "no";
183  }
184  else if (strcmp(request, "openwrite") == 0)
185  {
186  if (SI_LINK_W_OPEN_P(l)) return "yes";
187  else return "no";
188  }
189  else if (l->m->Status == NULL) return "unknown status request";
190  else return l->m->Status(l, request);
191 }
int status int void * buf
Definition: si_signals.h:59
#define NULL
Definition: omList.c:10
int l
Definition: cfEzgcd.cc:94

◆ slStatusSsiL()

int slStatusSsiL ( lists  L,
int  timeout 
)

Definition at line 1643 of file ssiLink.cc.

1644 {
1645 // input: L: a list with links of type
1646 // ssi-connect, ssi-fork, ssi-tcp, MPtcp-fork or MPtcp-launch.
1647 // Note: Not every entry in L must be set.
1648 // timeout: timeout for select in micro-seconds
1649 // or -1 for infinity
1650 // or 0 for polling
1651 // returns: ERROR (via Werror): L has wrong elements or link not open
1652 // -2: select returns an error
1653 // -1: the read state of all links is eof
1654 // 0: timeout (or polling): none ready,
1655 // i>0: (at least) L[i] is ready
1656  si_link l;
1657  ssiInfo *d;
1658  int d_fd;
1659  fd_set mask, fdmask;
1660  FD_ZERO(&fdmask);
1661  FD_ZERO(&mask);
1662  int max_fd=0; /* 1 + max fd in fd_set */
1663 
1664  /* timeout */
1665  struct timeval wt;
1666  struct timeval *wt_ptr=&wt;
1667  int startingtime = getRTimer()/TIMER_RESOLUTION; // in seconds
1668  if (timeout== -1)
1669  {
1670  wt_ptr=NULL;
1671  }
1672  else
1673  {
1674  wt.tv_sec = timeout / 1000000;
1675  wt.tv_usec = timeout % 1000000;
1676  }
1677 
1678  /* auxiliary variables */
1679  int i;
1680  int j;
1681  int k;
1682  int s;
1683  char fdmaskempty;
1684 
1685  /* check the links and fill in fdmask */
1686  /* check ssi links for ungetc_buf */
1687  for(i=L->nr; i>=0; i--)
1688  {
1689  if (L->m[i].Typ()!=DEF_CMD)
1690  {
1691  if (L->m[i].Typ()!=LINK_CMD)
1692  { WerrorS("all elements must be of type link"); return -2;}
1693  l=(si_link)L->m[i].Data();
1694  if(SI_LINK_OPEN_P(l)==0)
1695  { WerrorS("all links must be open"); return -2;}
1696  if (((strcmp(l->m->type,"ssi")!=0) && (strcmp(l->m->type,"MPtcp")!=0))
1697  || ((strcmp(l->mode,"fork")!=0) && (strcmp(l->mode,"tcp")!=0)
1698  && (strcmp(l->mode,"launch")!=0) && (strcmp(l->mode,"connect")!=0)))
1699  {
1700  WerrorS("all links must be of type ssi:fork, ssi:tcp, ssi:connect");
1701  return -2;
1702  }
1703  if (strcmp(l->m->type,"ssi")==0)
1704  {
1705  d=(ssiInfo*)l->data;
1706  d_fd=d->fd_read;
1707  if (!s_isready(d->f_read))
1708  {
1709  FD_SET(d_fd, &fdmask);
1710  if (d_fd > max_fd) max_fd=d_fd;
1711  }
1712  else
1713  return i+1;
1714  }
1715  else
1716  {
1717  Werror("wrong link type >>%s<<",l->m->type);
1718  return -2;
1719  }
1720  }
1721  }
1722  max_fd++;
1723 
1724 do_select:
1725  /* copy fdmask to mask */
1726  FD_ZERO(&mask);
1727  for(k = 0; k < max_fd; k++)
1728  {
1729  if(FD_ISSET(k, &fdmask))
1730  {
1731  FD_SET(k, &mask);
1732  }
1733  }
1734 
1735  /* check with select: chars waiting: no -> not ready */
1736  s = si_select(max_fd, &mask, NULL, NULL, wt_ptr);
1737  if (s==-1)
1738  {
1739  WerrorS("error in select call");
1740  return -2; /*error*/
1741  }
1742  if (s==0)
1743  {
1744  return 0; /*poll: not ready */
1745  }
1746  else /* s>0, at least one ready (the number of fd which are ready is s)*/
1747  {
1748  j=0;
1749  while (j<=max_fd) { if (FD_ISSET(j,&mask)) break; j++; }
1750  for(i=L->nr; i>=0; i--)
1751  {
1752  if (L->m[i].rtyp==LINK_CMD)
1753  {
1754  l=(si_link)L->m[i].Data();
1755  if (strcmp(l->m->type,"ssi")==0)
1756  {
1757  d=(ssiInfo*)l->data;
1758  d_fd=d->fd_read;
1759  if(j==d_fd) break;
1760  }
1761  else
1762  {
1763  Werror("wrong link type >>%s<<",l->m->type);
1764  return -2;
1765  }
1766  }
1767  }
1768  // only ssi links:
1769  loop
1770  {
1771  /* yes: read 1 char*/
1772  /* if \n, check again with select else ungetc(c), ready*/
1773  /* setting: d: current ssiInfo, j current fd, i current entry in L*/
1774  int c=s_getc(d->f_read);
1775  //Print("try c=%d\n",c);
1776  if (c== -1) /* eof */
1777  {
1778  FD_CLR(j,&fdmask);
1779  fdmaskempty = 1;
1780  for(k = 0; k < max_fd; k++)
1781  {
1782  if(FD_ISSET(k, &fdmask))
1783  {
1784  fdmaskempty = 0;
1785  break;
1786  }
1787  }
1788  if(fdmaskempty)
1789  {
1790  return -1;
1791  }
1792  if(timeout != -1)
1793  {
1794  timeout = si_max(0,
1795  timeout - 1000000*(getRTimer()/TIMER_RESOLUTION - startingtime));
1796  wt.tv_sec = timeout / 1000000;
1797  wt.tv_usec = (timeout % 1000000);
1798  }
1799  goto do_select;
1800  }
1801 
1802  else if (isdigit(c))
1803  { s_ungetc(c,d->f_read); return i+1; }
1804  else if (c>' ')
1805  {
1806  Werror("unknown char in ssiLink(%d)",c);
1807  return -2;
1808  }
1809  /* else: next char */
1810  goto do_select;
1811  }
1812  }
1813 }
const CanonicalForm int s
Definition: facAbsFact.cc:55
sleftv * m
Definition: lists.h:45
loop
Definition: myNF.cc:98
if(0 > strat->sl)
Definition: myNF.cc:73
int getRTimer()
Definition: timer.cc:172
void WerrorS(const char *s)
Definition: feFopen.cc:24
int k
Definition: cfEzgcd.cc:93
int Typ()
Definition: subexpr.cc:995
int s_getc(s_buff F)
Definition: s_buff.cc:56
#define TIMER_RESOLUTION
Definition: mod2.h:32
int j
Definition: myNF.cc:70
Definition: tok.h:58
void s_ungetc(int c, s_buff F)
Definition: s_buff.cc:97
static int si_max(const int a, const int b)
Definition: auxiliary.h:120
int i
Definition: cfEzgcd.cc:123
int nr
Definition: lists.h:43
Definition: tok.h:116
#define NULL
Definition: omList.c:10
int rtyp
Definition: subexpr.h:91
void * Data()
Definition: subexpr.cc:1137
int s_isready(s_buff F)
Definition: s_buff.cc:83
void Werror(const char *fmt,...)
Definition: reporter.cc:189
int l
Definition: cfEzgcd.cc:94

◆ slString()

char* slString ( si_link  l)
inline

Definition at line 100 of file silink.h.

101 {
102  if (l->name != NULL)
103  {
104  return omStrDup(l->name);
105  }
106  else
107  {
108  return omStrDup("");
109  }
110 }
#define NULL
Definition: omList.c:10
int l
Definition: cfEzgcd.cc:94
#define omStrDup(s)
Definition: omAllocDecl.h:263

◆ slWrite()

BOOLEAN slWrite ( si_link  l,
leftv  v 
)

Definition at line 314 of file silink.cc.

315 {
316  BOOLEAN res;
317 
318  if(! SI_LINK_W_OPEN_P(l)) // open w ?
319  {
320 #ifdef HAVE_DBM
321 #ifdef USE_GDBM
322  if (! SI_LINK_CLOSE_P(l))
323  {
324  if (slClose(l)) return TRUE;
325  }
326 #endif
327 #endif
328  if (slOpen(l, SI_LINK_WRITE,NULL)) return TRUE;
329  }
330 
331  if (SI_LINK_W_OPEN_P(l))
332  { // now open w
333  if (l->m->Write != NULL)
334  res = l->m->Write(l,v);
335  else
336  res = TRUE;
337 
338  if (res)
339  Werror("write: Error for link of type %s, mode: %s, name: %s",
340  l->m->type, l->mode, l->name);
341  return res;
342  }
343  else
344  {
345  Werror("write: Error to open link of type %s, mode: %s, name: %s for writing",
346  l->m->type, l->mode, l->name);
347  return TRUE;
348  }
349 }
#define TRUE
Definition: auxiliary.h:98
poly res
Definition: myNF.cc:322
#define NULL
Definition: omList.c:10
int BOOLEAN
Definition: auxiliary.h:85
void Werror(const char *fmt,...)
Definition: reporter.cc:189
int l
Definition: cfEzgcd.cc:94

◆ ssiBatch()

int ssiBatch ( const char *  host,
const char *  port 
)

Definition at line 1815 of file ssiLink.cc.

1817 {
1819  char *buf=(char*)omAlloc(256);
1820  sprintf(buf,"ssi:connect %s:%s",host,port);
1821  slInit(l, buf);
1822  omFreeSize(buf,256);
1823  if (slOpen(l,SI_LINK_OPEN,NULL)) return 1;
1825 
1826  idhdl id = enterid(omStrDup("link_ll"), 0, LINK_CMD, &IDROOT, FALSE);
1827  IDLINK(id) = l;
1828 
1829  loop
1830  {
1831  leftv h=ssiRead1(l); /*contains an exit.... */
1832  if (feErrors != NULL && *feErrors != '\0')
1833  {
1834  // handle errors:
1835  PrintS(feErrors); /* currently quite simple */
1836  *feErrors = '\0';
1837  }
1838  ssiWrite(l,h);
1839  h->CleanUp();
1840  omFreeBin(h, sleftv_bin);
1841  }
1842  /* never reached*/
1843  exit(0);
1844 }
Class used for (list of) interpreter objects.
Definition: subexpr.h:82
#define IDLINK(a)
Definition: ipid.h:135
loop
Definition: myNF.cc:98
#define FALSE
Definition: auxiliary.h:94
#define omFreeSize(addr, size)
Definition: omAllocDecl.h:260
#define IDROOT
Definition: ipid.h:20
#define omAlloc(size)
Definition: omAllocDecl.h:210
Definition: idrec.h:34
idhdl enterid(const char *s, int lev, int t, idhdl *root, BOOLEAN init, BOOLEAN search)
Definition: ipid.cc:258
char * feErrors
Definition: reporter.cc:47
int status int void * buf
Definition: si_signals.h:59
omBin sleftv_bin
Definition: subexpr.cc:50
void PrintS(const char *s)
Definition: reporter.cc:284
#define omAlloc0Bin(bin)
Definition: omAllocDecl.h:206
Definition: tok.h:116
#define NULL
Definition: omList.c:10
void CleanUp(ring r=currRing)
Definition: subexpr.cc:332
#define omFreeBin(addr, bin)
Definition: omAllocDecl.h:259
static Poly * h
Definition: janet.cc:978
int l
Definition: cfEzgcd.cc:94
#define omStrDup(s)
Definition: omAllocDecl.h:263

Variable Documentation

◆ ip_link_bin

omBin ip_link_bin

Definition at line 47 of file silink.cc.

◆ s_si_link_extension_bin

omBin s_si_link_extension_bin

Definition at line 45 of file silink.cc.

◆ sip_link_bin

omBin sip_link_bin

Definition at line 46 of file silink.cc.

◆ ssiToBeClosed

link_list ssiToBeClosed

Definition at line 70 of file ssiLink.cc.

◆ ssiToBeClosed_inactive

volatile BOOLEAN ssiToBeClosed_inactive

Definition at line 71 of file ssiLink.cc.