#DEFINES = -UNDEBUG -DHADESSTD_NEXITSTAT -DHADESSTD_NGETOPT -DNOATM
# Linux
-CC = gcc
-RPCGEN = rpcgen -k
-LOADLIBES = -L$(HOME)/lib/$(SYSTYPE) -lhadesstd -llvme
-INCLUDES = -I$(HOME)/include
-DEFINES = -UNDEBUG -DHADESSTD_NEXITSTAT -DHADESSTD_NGETOPT -DNOATM
+#CC = gcc
+#RPCGEN = rpcgen -k
+#LOADLIBES = -L$(HOME)/lib/$(SYSTYPE) -lhadesstd -llvme
+#INCLUDES = -I$(HOME)/include
+#DEFINES = -UNDEBUG -DHADESSTD_NEXITSTAT -DHADESSTD_NGETOPT -DNOATM
# LynxOS
-#CC = gcc
-#RPCGEN = rpcgen
-#LOADLIBES = -L/usr/local/lib -L$(HOME)/lib/$(SYSTYPE) -lhadesstd -llvme -ltcl -lm -lrpc -lnetinet -L/lib/ces -lvme -lbma -luio
-#INCLUDES = -I/usr/local/include -I$(HOME)/include
-#DEFINES = -UNDEBUG -DHADESSTD_NEXITSTAT
+CC = gcc
+RPCGEN = rpcgen
+LOADLIBES = -L/usr/local/lib -L$(HOME)/lib/$(SYSTYPE) -lhadesstd -llvme -ltcl -lm -lrpc -lnetinet -L/usr/ATM/lib -latm -L/lib/ces -lvme -lbma -luio
+INCLUDES = -I/usr/local/include -I$(HOME)/include -I/usr/ATM/include
+DEFINES = -UNDEBUG -DHADESSTD_NEXITSTAT
# LynxOS
#CC = gcc
online.h online_clnt.c online_svc.c online_xdr.c
latm.o: latm.c latm.h
- cc $(CFLAGS) -c latm.c
+ $(CC) $(CFLAGS) -c latm.c
online_clnt.c: online.x
$(RPCGEN) -l online.x >online_clnt.c
*data++ = 0x55aa00FF;
*data++ = 0x55aa00FF;
#if 0
- data += (int) ((100.0 * rand()) / RAND_MAX);
- data += (int) ((100.0 * rand()) / RAND_MAX);
- data += (int) ((100.0 * rand()) / RAND_MAX);
- data += (int) ((100.0 * rand()) / RAND_MAX);
+ data += (int) ((10000.0 * rand()) / RAND_MAX);
+ data += (int) ((10000.0 * rand()) / RAND_MAX);
+ data += (int) ((10000.0 * rand()) / RAND_MAX);
+ data += (int) ((10000.0 * rand()) / RAND_MAX);
#endif
break;
}
-static char rcsId[] = "$Header: /misc/hadesprojects/daq/cvsroot/eventbuilder/hadaq/nettrans.c,v 6.3 1999-11-02 05:53:24 muench Exp $";
+static char rcsId[] = "$Header: /misc/hadesprojects/daq/cvsroot/eventbuilder/hadaq/nettrans.c,v 6.4 1999-11-15 16:30:00 hades Exp $";
#define _XOPEN_SOURCE_EXTENDED
#include <unistd.h>
msglog(LOG_DEBUG, "aal: %d; vpi: %d; vci: %d; bandwidth: %d\n",
lAtmAttr->aal, lAtmAttr->vpi, lAtmAttr->vci, lAtmAttr->peakBandwidth);
- my->fd = lAtmOpen("/dev/fa0", fl);
+ my->lAtm = newLAtm("/dev/fa0", fl);
- if (0 > my->fd) {
+ if (NULL == my->lAtm) {
retVal = -1;
} else {
switch (fl) {
case O_RDONLY:
- retVal = lAtmBind(my->fd, lAtmAttr);
+ retVal = LAtm_bind(my->lAtm, lAtmAttr);
break;
case O_WRONLY:
- retVal = lAtmConnect(my->fd, lAtmAttr);
+ retVal = LAtm_connect(my->lAtm, lAtmAttr);
break;
default:
errno = EINVAL;
}
if (0 > retVal) {
- lAtmClose(my->fd);
+ deleteLAtm(my->lAtm);
} else {
my->mtuSize = 8192;
}
switch (my->type) {
case NetTransType_atm:
- retVal = lAtmClose(my->fd);
+ deleteLAtm(my->lAtm);
+ retVal = 0;
break;
}
switch (my->type) {
case NetTransType_atm:
- retVal = lAtmSend(my->fd, my->pkt, Pkt_size(my->pkt));
+ retVal = LAtm_send(my->lAtm, my->pkt, Pkt_size(my->pkt));
break;
}
switch (my->type) {
case NetTransType_atm:
- retVal = lAtmRecv(my->fd, my->pkt, my->mtuSize);
+ retVal = LAtm_recv(my->lAtm, my->pkt, my->mtuSize);
break;
}
NetTrans *my;
char *vpi;
char *vci;
- LAtmAttr lAtmAttrS, *lAtmAttr = &lAtmAttrS;
char buf[80];
my = allocMem(sizeof(NetTrans));
do {
FD_ZERO(fdSet);
for (i = 0; i < nrOfMsgs; i++) {
- FD_SET(my[i]->fd, fdSet);
+ FD_SET(my[i]->lAtm->fd, fdSet);
}
if (0 > (getdtablesize(), fdSet, NULL, NULL, NULL)) {
abort();
}
for (i = 0; i < nrOfMsgs; i++) {
- if (FD_ISSET(my[i]->fd, fdSet)) {
+ if (FD_ISSET(my[i]->lAtm->fd, fdSet)) {
if (assembleMsg(my[i], hadTu[i], size[i])) {
msgIsComplete |= 1 << i;
}