![[BACK]](/cvsweb/icons/back.gif){kind=icon}
Return to dial.c CVS log ![[TXT]](/cvsweb/icons/text.gif){kind=icon}
![[DIR]](/cvsweb/icons/dir.gif){kind=icon}
Up to [Research Unix] / researchv9 / ipc / src / mgrs / tcpmgr|
Return to dial.c CVS log | Up to [Research Unix] / researchv9 / ipc / src / mgrs / tcpmgr |
1.1 ! root 1: #include <stdio.h> ! 2: #include <signal.h> ! 3: #include <errno.h> ! 4: #include <ipc.h> ! 5: #include "defs.h" ! 6: #include <sys/inet/tcp_user.h> ! 7: #include <libc.h> ! 8: #include <sys/param.h> ! 9: #include <sys/ioctl.h> ! 10: ! 11: #define CSPORT 1 ! 12: ! 13: /* imported */ ! 14: extern char *in_ntoa(); ! 15: extern int tcp_connect(); ! 16: extern int tcp_accept(); ! 17: extern int tcp_listen(); ! 18: extern char *in_host(); ! 19: extern in_addr in_address(); ! 20: extern int rmesg_ld; ! 21: ! 22: /* dial a service on the internet - try first via cs, then direct */ ! 23: int ! 24: net_dial(ip) ! 25: ipcinfo *ip; ! 26: { ! 27: char *service; ! 28: struct tcpuser tu; ! 29: in_addr faddr; ! 30: int fd; ! 31: ! 32: /* parse the name */ ! 33: service = strchr(ip->name, '!'); ! 34: if (service != NULL) ! 35: *service++ = '\0'; ! 36: else ! 37: return ABORT(ENOENT, "unassigned destination", NULLINFO); ! 38: faddr = in_address(ip->name); ! 39: if (faddr==INADDR_ANY) ! 40: return ABORT(ENOENT, "unassigned destination", NULLINFO); ! 41: ! 42: /* get a channel for the connection */ ! 43: fd = tcp_sock(); ! 44: if (fd < 0) ! 45: return ABORT(EBUSY, "out of output channels", NULLINFO); ! 46: ! 47: /* connect to the remote connection server */ ! 48: tu.laddr = INADDR_ANY; ! 49: tu.lport = 0; ! 50: tu.faddr = faddr; ! 51: tu.fport = CSPORT; ! 52: tu.param = 0; ! 53: errstr = "destination not answering"; ! 54: if (tcp_connect(fd, &tu)>=0) { ! 55: /* send the request */ ! 56: ip->name = service; ! 57: if (_info_write(fd, ip)==0) { ! 58: condition(fd, ip); ! 59: if (_reply_read(fd)==0 && errno==0) { ! 60: ip->myname = in_ntoa(tu.laddr); ! 61: return fd; ! 62: } ! 63: } ! 64: } ! 65: close(fd); ! 66: ! 67: /* no connection server, try the port directly */ ! 68: fd = tcp_sock(); ! 69: if (fd < 0) ! 70: return ABORT(EBUSY, "out of output channels", NULLINFO); ! 71: tu.laddr = INADDR_ANY; ! 72: tu.lport = 0; ! 73: tu.faddr = faddr; ! 74: tu.fport = fstotcp(service); ! 75: if (tu.fport<=0) { ! 76: close(fd); ! 77: return ABORT(ENOENT, errstr, NULLINFO); ! 78: } ! 79: tu.param = 0; ! 80: if (tcp_connect(fd, &tu)<0) { ! 81: close(fd); ! 82: return ABORT(ENOENT, errstr, NULLINFO); ! 83: } ! 84: condition(fd, ip); ! 85: ip->myname = in_ntoa(tu.laddr); ! 86: return fd; ! 87: } ! 88: ! 89: /* condition the connection as requested */ ! 90: condition(fd, ip) ! 91: int fd; ! 92: ipcinfo *ip; ! 93: { ! 94: char *fields[10]; ! 95: char param[128]; ! 96: int i; ! 97: int dohup=0; ! 98: int domesg=0; ! 99: ! 100: strcpy(param, ip->param); ! 101: setfields(" \t"); ! 102: getmfields(param, fields, 10); ! 103: for (i=0; i<10 && fields[i]; i++) { ! 104: if (strcmp(fields[i], "hup")==0) ! 105: dohup = 1; ! 106: if (strcmp(fields[i], "delim")==0) ! 107: domesg = 1; ! 108: } ! 109: if (dohup) ! 110: ioctl(fd, TCPIOHUP, 0); ! 111: if (domesg) ! 112: ioctl(fd, FIOPUSHLD, &rmesg_ld); ! 113: } ! 114: ! 115: /* announce onto the internet - only the first one gets there */ ! 116: int ! 117: net_announce(ip) ! 118: ipcinfo *ip; ! 119: { ! 120: int fd; ! 121: struct tcpuser tu; ! 122: ! 123: USE(ip); ! 124: fd = tcp_sock(); ! 125: if (fd < 0) ! 126: return ABORT(EBUSY, "no more output channels", NULLINFO); ! 127: tu.lport = TCPPORT_ANY; ! 128: tu.laddr = 0; ! 129: tu.fport = 0; ! 130: tu.faddr = 0; ! 131: tu.param = 0; ! 132: if (tcp_listen(fd, &tu)<0) { ! 133: close(fd); ! 134: return ABORT(EEXIST, "server already exists", NULLINFO); ! 135: } ! 136: return fd; ! 137: } ! 138: ! 139: /* listen for a call in */ ! 140: ipcinfo * ! 141: net_listen(fd) ! 142: int fd; ! 143: { ! 144: static ipcinfo info; ! 145: static char myname[PATHLEN]; ! 146: static char name[PATHLEN]; ! 147: static char machine[PATHLEN]; ! 148: struct tcpuser tu; ! 149: extern char *tcptofs(); ! 150: ! 151: info.flags = 0; ! 152: for(;;) { ! 153: tu.param = 0; ! 154: if ((fd = tcp_accept(fd, &tu))<0) ! 155: return NULL; ! 156: if (tu.lport == CSPORT) { ! 157: if (tu.fport > 1023) ! 158: info.uid = info.gid = -1; ! 159: else ! 160: info.uid = info.gid = 0; ! 161: info.user = "_unknown_"; ! 162: if (_info_read(fd, &info)<0) { ! 163: close(fd); ! 164: return (ipcinfo *)NULL; ! 165: } ! 166: info.flags |= IPC_HANDOFF; ! 167: condition(fd, &info); ! 168: } else { ! 169: info.user = "_unknown_"; ! 170: info.param = ""; ! 171: strcpy(name, tcptofs(tu.lport)); ! 172: info.name = name; ! 173: } ! 174: strcpy(machine, in_host(tu.faddr)); ! 175: info.machine = machine; ! 176: strcpy(myname, in_ntoa(tu.laddr)); ! 177: info.myname = myname; ! 178: info.flags |= IPC_OPEN; ! 179: info.rfd = fd; ! 180: info.cfd = -1; ! 181: return &info; ! 182: } ! 183: } ! 184: ! 185: /* accept a call */ ! 186: void ! 187: net_accept(ip) ! 188: ipcinfo *ip; ! 189: { ! 190: USE(ip); ! 191: } ! 192: ! 193: /* reject a call - null if a non-cs call */ ! 194: void ! 195: net_reject(ip, no, str) ! 196: ipcinfo *ip; ! 197: int no; ! 198: char *str; ! 199: { ! 200: if (ip->flags&IPC_HANDOFF && ip->rfd>=0) ! 201: _reply_write(ip->rfd, no, str); ! 202: if (ip->rfd>=0) { ! 203: close(ip->rfd); ! 204: ip->rfd = -1; ! 205: } ! 206: }
This archive runs on limited infrastructure. Preserving old code on modern bandwidth. Automated agents are requested to crawl responsibly.