Annotation of OpenXM/src/kan96xx/plugin/mytcpio.c, Revision 1.4.2.2
1.4.2.2 ! maekawa 1: /* $OpenXM: OpenXM/src/kan96xx/plugin/mytcpio.c,v 1.4.2.1 2000/11/10 20:12:08 maekawa Exp $ */
1.1 maekawa 2: #include <stdio.h>
3: #include <sys/types.h>
4: #include <sys/socket.h>
5: #include <sys/time.h>
6: #include <netinet/in.h>
7: #include <netdb.h>
8: #include <setjmp.h>
9: /* -lnsl -lsocket /usr/ucblib/libucb.a */
10: #include "ox_kan.h"
11: /*
12: MyEnv_oxmisc is used in oxmisc.c.
13: It cannot be put in oxmisc.c for the case of sun.
14: */
15: #if defined(sun)
16: int MyEnv_oxmisc[2000];
17: #else
18: jmp_buf MyEnv_oxmisc; /* may cause a trouble in Solaris. */
19: #endif
20:
21: #define READBUFSIZE 10000
22: static void errorMsg1s(char *s) {
23: fprintf(stderr,"%s\n",s);
24: }
25:
1.3 takayama 26: #define SET_TCPIOERROR { if (TcpioError == NULL) TcpioError = stdout; }
27: FILE *TcpioError = NULL;
1.1 maekawa 28: int OpenedSocket = 0;
29: extern int Quiet;
30:
31: socketOpen(char *serverName,int portNumber) {
1.4.2.1 maekawa 32: struct addrinfo hints, *res, *ai;
33: struct sockaddr_storage ss;
34: socklen_t len;
35: char pstr[BUFSIZ], *errstr;
36: int s, p, opt, error;
37:
38: SET_TCPIOERROR;
39: fprintf(TcpioError, "Hello from open. serverName is %s and "
40: "portnumber is %d\n", serverName, portNumber);
41:
42: memset(&hints, 0, sizeof(hints));
43: hints.ai_family = PF_UNSPEC;
44: hints.ai_socktype = SOCK_STREAM;
45:
46: memset(pstr, 0, sizeof(pstr));
47: snprintf(pstr, sizeof(pstr), "%u", portNumber);
48:
49: error = getaddrinfo(serverName, pstr, &hints, &res);
50: if (error) {
51: errorMsg1s("Bad server name.");
52: return (-1);
53: }
54:
55: s = -1;
56: p = -1;
57: errstr = NULL;
58:
59: for (ai = res ; ai != NULL ; ai = ai->ai_next) {
60: s = socket(ai->ai_family, ai->ai_socktype, ai->ai_protocol);
61: if (s < 0) {
62: errstr = "socket";
63: continue;
64: }
65:
66: opt = 1;
67: setsockopt(s, SOL_SOCKET, SO_REUSEADDR, &opt, sizeof(opt));
68:
69: if (bind(s, ai->ai_addr, ai->ai_addrlen) < 0) {
70: errstr = "bind";
71: close(s);
72: s = -1;
73: continue;
74: }
75:
76: len = sizeof(ss);
77: if (getsockname(s, (struct sockaddr *)&ss, &len) < 0) {
78: errstr = "getsockname";
79: close(s);
80: s = -1;
81: continue;
82: }
83:
84: switch (ss.ss_family) {
85: case AF_INET:
86: {
87: struct sockaddr_in *sin;
88: sin = (struct sockaddr_in *)&ss;
89: p = ntohs(sin->sin_port);
90: break;
91: }
92: case AF_INET6:
93: {
94: struct sockaddr_in6 *sin6;
95: sin6 = (struct sockaddr_in6 *)&ss;
96: p = ntohs(sin6->sin6_port);
97: break;
98: }
99: default:
100: p = -1;
101: }
102: if (p < 0) {
103: errstr = "AF";
104: close(s);
105: s = -1;
106: continue;
107: }
108:
109: if (listen(s, 1) < 0) {
110: errstr = "listen";
111: close(s);
112: s = -1;
113: continue;
114: }
115:
116: break;
117: }
118:
119: freeaddrinfo(res);
120:
121: if (s < 0) {
122: fprintf(TcpioError, "Error: %s", errstr);
123: errorMsg1s(errstr);
124: } else {
125: OpenedSocket = p;
126: }
1.1 maekawa 127:
1.4.2.1 maekawa 128: return (s);
1.1 maekawa 129: }
130:
131:
132: socketAccept(int snum) {
133: int s, news;
134:
1.3 takayama 135: SET_TCPIOERROR;
1.1 maekawa 136: s = snum;
137: fprintf(TcpioError,"Trying to accept... "); fflush(TcpioError);
138: if ((news = accept(s,NULL,NULL)) < 0) {
139: errorMsg1s("Error in accept.");
140: return(-1);
141: }
142: fprintf(TcpioError,"Accepted.\n"); fflush(TcpioError);
143: if (close(s) < 0) {
144: errorMsg1s("Error in closing the old socket.");
145: return(-1);
146: }
147: return(news);
148: }
149:
1.4.2.2 ! maekawa 150: socketAcceptLocal(int s) {
! 151: struct sockaddr_storage ss;
! 152: socklen_t len;
! 153: int ps, accepted, error;
1.3 takayama 154:
1.4.2.2 ! maekawa 155: SET_TCPIOERROR;
1.1 maekawa 156:
1.4.2.2 ! maekawa 157: fprintf(TcpioError,"Trying to accept from localhost... ");
! 158: fflush(TcpioError);
1.1 maekawa 159:
1.4.2.2 ! maekawa 160: len = sizeof(ss);
! 161: if ((ps = accept(s, (struct sockaddr *)&ss, &len)) < 0) {
! 162: errorMsg1s("Error in accept.");
! 163: close(s);
! 164: return (-1);
! 165: }
! 166:
! 167: len = sizeof(ss);
! 168: if (getpeername(ps, (struct sockaddr *)&ss, &len) < 0) {
! 169: close(s);
! 170: close(ps);
! 171: errorMsg1s("Error in getpeername.");
! 172: return (-1);
! 173: }
! 174:
! 175: accepted = 0;
! 176: switch (ss.ss_family) {
! 177: case AF_INET:
! 178: {
! 179: #ifndef INADDR_LOOPBACK
! 180: #define INADDR_LOOPBACK 0x7f000001 /* 127.0.0.1 */
! 181: #endif /* INADDR_LOOPBACK */
! 182: struct sockaddr_in *sin;
! 183: sin = (struct sockaddr_in *)&ss;
! 184: if (sin->sin_addr.s_addr == INADDR_LOOPBACK)
! 185: accepted = 1;
! 186: break;
! 187: }
! 188: case AF_INET6:
! 189: {
! 190: struct sockaddr_in6 *sin6;
! 191: sin6 = (struct sockaddr_in6 *)&ss;
! 192: if (IN6_IS_ADDR_LOOPBACK(sin6->sin6_addr))
! 193: accepted = 1;
! 194: break;
! 195: }
! 196: default:
! 197: accepted = 0;
! 198: }
! 199:
! 200: if (accepted) {
! 201: fprintf(stderr, "Authentication: "
! 202: "localhost is allowed to be accepted.\n");
! 203: } else {
! 204: errorMsg1s("Authentication: "
! 205: "The connection is not from the localhost.");
! 206: close(s);
! 207: close(ps);
! 208: fprintf(stderr, "The connection is refused.");
! 209: return (-1);
! 210: }
! 211:
! 212: fprintf(TcpioError, "Accepted.\n");
! 213: fflush(TcpioError);
! 214: if (close(s) < 0) {
! 215: errorMsg1s("Error in closing the old socket.");
! 216: close(ps);
! 217: return(-1);
! 218: }
! 219:
! 220: return(ps);
1.1 maekawa 221: }
222:
223: int oxSocketSelect0(int fd,int t) {
224: fd_set readfds;
225: struct timeval timeout;
226: int debug = 0;
227: extern int errno;
1.3 takayama 228: SET_TCPIOERROR;
1.1 maekawa 229: FD_ZERO(&readfds);
230: FD_SET(fd,&readfds);
231: timeout.tv_sec = 0;
232: timeout.tv_usec = (long) t;
233: if (t >= 0) {
234: if (debug) {printf("select t>=0 for fd = %d\n",fd); fflush(NULL);}
235: if (select(fd+1,&readfds,(fd_set *)NULL,(fd_set *)NULL,&timeout)<0) {
236: /* It must be fd+1 !, Not fd. */
237: fprintf(TcpioError,"select (non-block) error. Error no is %d. See /usr/include/sys/errno.h (asm/errno.h).\n",errno);
238: errorMsg1s("oxSocketSelect0() : select failed.");
239: return(0);
240: }
241: if(debug){printf("Return from select t>=0 for fd = %d\n",fd);fflush(NULL);}
242: }else{ /* block */
243: if (select(fd+1,&readfds,(fd_set *)NULL,(fd_set *)NULL,(struct timeval *)NULL)<0) {
244: fprintf(TcpioError,"select (block) error. Error no is %d. See /usr/include/sys/errno.h (asm/errno.h).\n",errno);
245: errorMsg1s("socketSelect0() : select failed.");
246: return(0);
247: }
248: }
249: if (FD_ISSET(fd,&readfds)) return(1);
250: else return(0);
251: }
252:
253: oxSocketMultiSelect(int sid[],int size,int t,int result[])
254: {
255: int i,fd,p;
256: fd_set readfds;
257: struct timeval timeout;
258: int isdata = 0;
259: extern errno;
260:
1.3 takayama 261: SET_TCPIOERROR;
1.1 maekawa 262: FD_ZERO(&readfds);
263: timeout.tv_sec = 0;
264: timeout.tv_usec = (long)t;
265:
266: fd = 0;
267:
268: for (i=0; i<size; i++) {
269: if (sid[i] >= 0) {
270: p = sid[i];
271: if (p > fd) fd = p;
272: FD_SET(p,&readfds);
273: /* printf("p = %d, fd=%d",p,fd); */
274: }
275: }
276:
277: /* printf("MultiSelect..\n"); fflush(NULL); */
278: if (t >= 0) {
279: if (select(fd+1,&readfds,(fd_set *)NULL,(fd_set *)NULL,&timeout)<0) {
280: /* It must be fd+1 !, Not fd. */
281: fprintf(TcpioError,"Select error. Error no is %d. See /usr/include/sys/errno.h (asm/errno.h).\n",errno);
282: errorMsg1s("oxSocketMultiSelect() : select failed.");
283: return(0);
284: }
285: }else{ /* block */
286: if (select(fd+1,&readfds,(fd_set *)NULL,(fd_set *)NULL,(struct timeval *)NULL)<0) {
287: fprintf(TcpioError,"Select error. Error no is %d. See /usr/include/sys/errno.h (asm/errno.h).\n",errno);
288: errorMsg1s("oxSocketMultiSelect() : (block) select failed.");
289: return(0);
290: }
291: }
292: /* printf("Done. MultiSelect.\n"); fflush(NULL); */
293: for (i=0; i<size; i++) {
294: p = sid[i];
295: if ((sid[i] >=0) && FD_ISSET(p,&readfds)) {
296: result[i] = 1; isdata = 1;
297: }else{
298: result[i] = 0;
299: }
300: }
301: return(isdata);
302: }
303:
304:
305: socketConnect(char *serverName,int portNumber) {
306: struct hostent *servhost;
307: struct sockaddr_in server;
308: int socketid;
309: int on;
310:
1.3 takayama 311: SET_TCPIOERROR;
1.1 maekawa 312: if ((servhost = gethostbyname(serverName)) == NULL) {
313: errorMsg1s("bad server name.\n");
314: return(-1);
315: }
316: bzero((char *)&server,sizeof(server));
317: server.sin_family = AF_INET;
318: server.sin_port = htons(portNumber);
319: bcopy(servhost->h_addr,
320: (char *)&server.sin_addr,servhost->h_length);
321:
322: if ((socketid = socket(AF_INET,SOCK_STREAM,0)) <0) {
323: errorMsg1s("socket allocation is failed.\n");
324: return(-1);
325: }
326: /* on=1; setsockopt(socketid,SOL_SOCKET,SO_REUSEADDR,&on,sizeof(on)); */
327: if (!Quiet) {
328: fprintf(TcpioError,"Trying to connect port %d, ip=%x\n",ntohs(server.sin_port),server.sin_addr);
329: }
330: if (connect(socketid,(struct sockaddr *)&server,sizeof(server)) == -1) {
331: errorMsg1s("cannot connect");
332: return(-1);
333: }
334: if (!Quiet) fprintf(TcpioError,"connected.\n");
335: return(socketid);
336: }
337:
338: socketConnectWithPass(char *servername,int port,char *pass)
339: {
340: int fd;
341: int m;
1.3 takayama 342: SET_TCPIOERROR;
1.1 maekawa 343: fd = socketConnect(servername,port);
344: if (fd >= 0) {
1.2 takayama 345: m = write(fd,pass,strlen(pass)+1);
346: if (m != strlen(pass)+1) {
1.1 maekawa 347: fprintf(TcpioError,"Fail to send password to fd=%d.\n",fd);
348: return(-1);
349: }
350: return(fd);
351: }else{
352: return(-1);
353: }
354: }
355:
FreeBSD-CVSweb <freebsd-cvsweb@FreeBSD.org>
![[BACK]](/icons/cvsweb/back.gif){kind=icon}
Return to mytcpio.c CVS log ![[TXT]](/icons/cvsweb/text.gif){kind=icon}
![[DIR]](/icons/cvsweb/dir.gif){kind=icon}
Up to [local] / OpenXM / src / kan96xx / plugin