Annotation of OpenXM/src/kan96xx/plugin/sm1Socket.c, Revision 1.1
1.1 ! maekawa 1: /* msg0s.c */
! 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:
! 9:
! 10: #include "datatype.h"
! 11: #include "stackm.h"
! 12: #include "extern.h"
! 13: #include "sm1Socket.h"
! 14:
! 15: extern int Quiet;
! 16: static void errorMsg1s(char *s);
! 17:
! 18: /* [(sm1.socket) (open) [optional integer port, optional string name] ] extension ; */
! 19: struct object KsocketOpen(struct object obj) {
! 20: char serverName[1024];
! 21: int portNumber;
! 22: struct object rob = NullObject;
! 23: struct hostent *myhost;
! 24: struct sockaddr_in me;
! 25: int s_waiting;
! 26: int on;
! 27: int tt;
! 28: extern int errno;
! 29:
! 30: if (obj.tag != Sarray) {
! 31: errorMsg1s("KsocketOpen([optional integer,optional string name])");
! 32: }
! 33: strcpy(serverName,"localhost");
! 34: portNumber = 0;
! 35: if (getoaSize(obj) >= 1) {
! 36: if ((getoa(obj,0)).tag != Sinteger) {
! 37: errorMsg1s("KsocketOpen([optional integer,optional string name]), the first argument must be an integer.");
! 38: }
! 39: portNumber = KopInteger(getoa(obj,0));
! 40: }
! 41: if (getoaSize(obj) >= 2) {
! 42: if ((getoa(obj,1)).tag != Sdollar) {
! 43: errorMsg1s("KsocketOpen([optional integer,optional string name]), the second argument must be a string.");
! 44: }
! 45: if (strlen(KopString(getoa(obj,1))) > 1023) {
! 46: errorMsg1s("Too long server name");
! 47: }
! 48: strcpy(serverName,KopString(getoa(obj,1)));
! 49: }
! 50:
! 51:
! 52: /* fprintf(stderr,"Hello from open.\n"); */
! 53: if ((myhost = gethostbyname(serverName)) == NULL) {
! 54: errorMsg1s("Bad server name.");
! 55: }
! 56: bzero((char *)&me,sizeof(me));
! 57: me.sin_family = AF_INET;
! 58: me.sin_port = htons(portNumber);
! 59: bcopy(myhost->h_addr,
! 60: &me.sin_addr,myhost->h_length);
! 61:
! 62: if ((s_waiting = socket(AF_INET,SOCK_STREAM,0)) < 0) {
! 63: errorMsg1s("Socket allocation is failed.");
! 64: }
! 65:
! 66: on=1; setsockopt(s_waiting,SOL_SOCKET,SO_REUSEADDR,&on,sizeof(on));
! 67: /* important */
! 68: if (bind(s_waiting,(struct sockaddr *) &me,sizeof(me)) == -1) {
! 69: fprintf(stderr,"Bind error. Error no is %d. See /usr/include/sys/errno.h.\n",errno);
! 70: errorMsg1s("cannot bind");
! 71: }
! 72:
! 73: tt = sizeof(me);
! 74: if (getsockname(s_waiting,(struct sockaddr *)&me,&tt) < 0) {
! 75: fprintf(stderr,"getsockname error. Error no is %d. See /usr/include/sys/errno.h.\n",errno);
! 76: errorMsg1s("cannot getsockname");
! 77: }
! 78:
! 79:
! 80: if (listen(s_waiting,1) < 0) {
! 81: errorMsg1s("Listen failed");
! 82: }
! 83: /*
! 84: fprintf(stderr,"Done the initialization. port =%d\n",ntohs(me.sin_port));
! 85: fprintf(stderr,"socket id = %d",accept(s_waiting,NULL,NULL)); */
! 86: rob = newObjectArray(2);
! 87: putoa(rob,0,KpoInteger(s_waiting));
! 88: putoa(rob,1,KpoInteger(ntohs(me.sin_port)));
! 89: return(rob);
! 90:
! 91: }
! 92:
! 93: /* [ integer port, optional string host default localhost]
! 94: [ integer socketid, integer port ] */
! 95: struct object KsocketConnect(struct object obj) {
! 96: char serverName[1024];
! 97: int portNumber;
! 98: struct hostent *servhost;
! 99: struct sockaddr_in server;
! 100: int socketid;
! 101: struct object robj = NullObject;
! 102:
! 103: if (obj.tag != Sarray) {
! 104: errorMsg1s("KsocketConnect( [ integer port, optional string host default localhost])");
! 105: }
! 106: strcpy(serverName,"localhost");
! 107: if (getoaSize(obj) < 1) {
! 108: errorMsg1s("You need to specify port number.\n");
! 109: }
! 110: if (getoaSize(obj) >= 1) {
! 111: if ((getoa(obj,0)).tag != Sinteger) {
! 112: errorMsg1s("KsocketConnect([integer port,optional string host]), the first argument must be an integer.");
! 113: }
! 114: portNumber = KopInteger(getoa(obj,0));
! 115: }
! 116: if (getoaSize(obj) >= 2) {
! 117: if ((getoa(obj,1)).tag != Sdollar) {
! 118: errorMsg1s("KsocketConnect([integer port,optional string host]), the second argument must be a string.");
! 119: }
! 120: if (strlen(KopString(getoa(obj,1))) > 1023) {
! 121: errorMsg1s("Too long server name");
! 122: }
! 123: strcpy(serverName,KopString(getoa(obj,1)));
! 124: }
! 125:
! 126:
! 127: if ((servhost = gethostbyname(serverName)) == NULL) {
! 128: errorMsg1s("bad server name.\n");
! 129: }
! 130: bzero((char *)&server,sizeof(server));
! 131: server.sin_family = AF_INET;
! 132: server.sin_port = htons(portNumber);
! 133: bcopy(servhost->h_addr,
! 134: (char *)&server.sin_addr,servhost->h_length);
! 135:
! 136: if ((socketid = socket(AF_INET,SOCK_STREAM,0)) <0) {
! 137: errorMsg1s("socket allocation is failed.\n");
! 138: }
! 139: if (!Quiet) {
! 140: fprintf(stderr,"Trying to connect port %d, ip=%x\n",ntohs(server.sin_port),server.sin_addr);
! 141: }
! 142: if (connect(socketid,(struct sockaddr *)&server,sizeof(server)) == -1) {
! 143: errorMsg1s("cannot connect");
! 144: }
! 145: /* fprintf(stderr,"connected.\n"); */
! 146: robj = newObjectArray(2);
! 147: putoa(robj,0,KpoInteger(socketid));
! 148: putoa(robj,1,KpoInteger(portNumber));
! 149: return(robj);
! 150: }
! 151:
! 152: /* [ integer socketid ]
! 153: [ integer newsocketid ] */
! 154: struct object KsocketAccept(struct object obj) {
! 155: struct object obj1;
! 156: struct object obj2;
! 157: struct object robj;
! 158: int s, news;
! 159:
! 160: if (obj.tag != Sarray) {
! 161: errorMsg1s("KsocketAccept([integer socketid])");
! 162: }
! 163: if (getoaSize(obj) < 1) {
! 164: errorMsg1s("KsocketAccept([integer socketid])");
! 165: }
! 166: obj1 = getoa(obj,0);
! 167: if (obj1.tag != Sinteger ) {
! 168: errorMsg1s("KsocketAccept([integer socketid]), argument must be integer.");
! 169: }
! 170: s = KopInteger(obj1);
! 171: if ((news = accept(s,NULL,NULL)) < 0) {
! 172: errorMsg1s("Error in accept.");
! 173: }
! 174: if (close(s) < 0) {
! 175: errorMsg1s("Error in closing the old socket.");
! 176: }
! 177: robj = newObjectArray(1);
! 178: putoa(robj,0,KpoInteger(news));
! 179: return(robj);
! 180: }
! 181:
! 182: int KsocketSelect0(int fd,int t) {
! 183: fd_set readfds;
! 184: struct timeval timeout;
! 185: extern int errno;
! 186: FD_ZERO(&readfds);
! 187: FD_SET(fd,&readfds);
! 188: timeout.tv_sec = 0;
! 189: timeout.tv_usec = (long) t;
! 190: if (t >= 0) {
! 191: if (select(fd+1,&readfds,(fd_set *)NULL,(fd_set *)NULL,&timeout)<0) {
! 192: /* It must be fd+1 !, Not fd. */
! 193: fprintf(stderr,"Select error. Error no is %d. See /usr/include/sys/errno.h.\n",errno);
! 194: errorMsg1s("KsocketSelect0() : select failed.");
! 195: return(0);
! 196: }
! 197: }else{ /* block */
! 198: if (select(fd+1,&readfds,(fd_set *)NULL,(fd_set *)NULL,(struct timeval *)NULL)<0) {
! 199: errorMsg1s("KsocketSelect0() : select failed.");
! 200: fprintf(stderr,"Select error. Error no is %d. See /usr/include/sys/errno.h.\n",errno);
! 201: return(0);
! 202: }
! 203: }
! 204: if (FD_ISSET(fd,&readfds)) return(1);
! 205: else return(0);
! 206: }
! 207:
! 208: /* [ integer socketid optional integer timeout default 0]
! 209: integer true or false
! 210: */
! 211: struct object KsocketSelect(struct object obj) {
! 212: struct object robj;
! 213: struct object ob1;
! 214: struct object ob2;
! 215: if (obj.tag != Sarray) {
! 216: errorMsg1s("KsocketSelect([ integer socketid optional integer timeout default 0]");
! 217: }
! 218: if (getoaSize(obj) < 1) {
! 219: errorMsg1s("KsocketSelect([ integer socketid optional integer timeout default 0]");
! 220: }
! 221: if (getoaSize(obj) >= 1) {
! 222: ob1 = getoa(obj,0);
! 223: ob2 = KpoInteger(0); /* default value */
! 224: }
! 225: if (getoaSize(obj) >= 2) {
! 226: ob2 = getoa(obj,1);
! 227: }
! 228: if (ob1.tag != Sinteger) {
! 229: errorMsg1s("KsocketSelect([ integer socketid optional integer timeout default 0] : the first argument must be an integer.");
! 230: }
! 231: if (ob2.tag != Sinteger) {
! 232: errorMsg1s("KsocketSelect([ integer socketid optional integer timeout default 0] : the second argument must be an integer.");
! 233: }
! 234: robj = KpoInteger( KsocketSelect0(KopInteger(ob1),KopInteger(ob2)) );
! 235: return(robj);
! 236: }
! 237:
! 238: struct object KsocketSelectMulti(struct object obj)
! 239: /* [ [integer socketid1, integer socketid2, ...]
! 240: optional integer timeout default 0]
! 241: [ result1, result2, ....]
! 242: */
! 243: {
! 244: struct object robj;
! 245: struct object ob1;
! 246: struct object ob2;
! 247: struct object ob3;
! 248: int size,i,fd,p,t;
! 249: fd_set readfds;
! 250: struct timeval timeout;
! 251: extern errno;
! 252: if (obj.tag != Sarray) {
! 253: errorMsg1s("KsocketSelectMulti([[sid1, sid2,...] optional integer timeout default 0]");
! 254: }
! 255: if (getoaSize(obj) < 1) {
! 256: errorMsg1s("KsocketSelectMulti([[sid1, sid2,...] optional integer timeout default 0]");
! 257: }
! 258: if (getoaSize(obj) >= 1) {
! 259: ob1 = getoa(obj,0);
! 260: ob2 = KpoInteger(0); /* default value */
! 261: }
! 262: if (getoaSize(obj) >= 2) {
! 263: ob2 = getoa(obj,1);
! 264: }
! 265: if (ob1.tag != Sarray) {
! 266: errorMsg1s("KsocketSelectMulti([[sid1, sid2, ...] optional integer timeout default 0] : the first argument must be an array.");
! 267: }
! 268: if (ob2.tag != Sinteger) {
! 269: errorMsg1s("KsocketSelectMulti([[sid1, sid2, ...] optional integer timeout default 0] : the second argument must be an integer.");
! 270: }
! 271: FD_ZERO(&readfds);
! 272: timeout.tv_sec = 0; t = KopInteger(ob2);
! 273: timeout.tv_usec = (long)t;
! 274:
! 275: size = getoaSize(ob1);
! 276: if (size < 1) {
! 277: errorMsg1s("KsocketSelectMulti: the first argument must be a non-empty array of integers.");
! 278: }
! 279: fd = 0;
! 280:
! 281: for (i=0; i<size; i++) {
! 282: ob3 = getoa(ob1,i);
! 283: if (ob3.tag != Sinteger) {
! 284: errorMsg1s("KsocketSelectMulti: the first argument must be an array of integers.");
! 285: }
! 286: p = KopInteger(ob3);
! 287: if (p > fd) fd = p;
! 288: FD_SET(p,&readfds);
! 289: /* printf("p = %d, fd=%d",p,fd); */
! 290: }
! 291:
! 292: if (t >= 0) {
! 293: if (select(fd+1,&readfds,(fd_set *)NULL,(fd_set *)NULL,&timeout)<0) {
! 294: /* It must be fd+1 !, Not fd. */
! 295: fprintf(stderr,"Select error. Error no is %d. See /usr/include/sys/errno.h.\n",errno);
! 296: errorMsg1s("KsocketSelectMulti() : select failed.");
! 297: }
! 298: }else{ /* block */
! 299: if (select(fd+1,&readfds,(fd_set *)NULL,(fd_set *)NULL,(struct timeval *)NULL)<0) {
! 300: fprintf(stderr,"Select error. Error no is %d. See /usr/include/sys/errno.h.\n",errno);
! 301: errorMsg1s("KsocketSelectMulti() : (block) select failed.");
! 302: }
! 303: }
! 304: robj = newObjectArray(size);
! 305: for (i=0; i<size; i++) {
! 306: if (FD_ISSET(KopInteger(getoa(ob1,i)),&readfds)) {
! 307: putoa(robj,i,KpoInteger(1));
! 308: }else{
! 309: putoa(robj,i,KpoInteger(0));
! 310: }
! 311: }
! 312:
! 313: return(robj);
! 314: }
! 315:
! 316:
! 317:
! 318:
! 319: static char Data00[1024];
! 320: /* [ integer socketid ]
! 321: string data
! 322: */
! 323: struct object KsocketRead(struct object obj) {
! 324: struct object ob1;
! 325: struct object robj = NullObject;
! 326: static int datasize = 1024;
! 327: static char *data = Data00;
! 328: char *tmp;
! 329: char *r;
! 330: int n;
! 331: int socketid;
! 332: int totalsize;
! 333:
! 334: if (obj.tag != Sarray) {
! 335: errorMsg1s("KsocketRead([integer socketid])");
! 336: }
! 337: if (getoaSize(obj) < 1) {
! 338: errorMsg1s("KsocketRead([integer socketid])");
! 339: }
! 340: ob1 = getoa(obj,0);
! 341: if (ob1.tag != Sinteger) {
! 342: errorMsg1s("KsocketRead([integer socketid]) : the argument must be integer.");
! 343: }
! 344: socketid = KopInteger(ob1);
! 345:
! 346: totalsize = 0;
! 347:
! 348: while (KsocketSelect0(socketid,0)) {
! 349: if (datasize - totalsize > 0) {
! 350: n = read(socketid,data+totalsize,datasize-totalsize);
! 351: if (n < 0) {
! 352: errorMsg1s("Read error.");
! 353: }
! 354: if (n < datasize-totalsize) {
! 355: totalsize += n;
! 356: break;
! 357: }else{ totalsize += n; }
! 358: if (totalsize == 0) {
! 359: errorMsg1s("Select returns 1, but there is no data to read.");
! 360: }
! 361: }else { /* increase the datasize */
! 362: tmp = (char *)GC_malloc(sizeof(char)*2*datasize);
! 363: /*I should use GC_malloc_atomic and free after finishing this function?*/
! 364: if (tmp == (char *)NULL) errorMsg1s("Out of Memory.");
! 365: bcopy(data,tmp,totalsize);
! 366: data = tmp;
! 367: datasize = 2*datasize;
! 368: }
! 369: }
! 370:
! 371: r = (char *)GC_malloc(sizeof(char)*(n+1));
! 372: if (r == (char *)NULL) errorMsg1s("Out of Memory.");
! 373: bcopy(data,r,totalsize);
! 374: robj = KpoString(r);
! 375:
! 376: return(robj);
! 377:
! 378: }
! 379:
! 380: /* [ integer socketid, string data ]
! 381: integer */
! 382: struct object KsocketWrite(struct object obj) {
! 383: struct object ob1;
! 384: struct object ob2;
! 385: int socketid;
! 386: int r;
! 387: if (obj.tag != Sarray) {
! 388: errorMsg1s("KsocketWrite([integer socketid, string data])");
! 389: }
! 390: if (getoaSize(obj) < 2) {
! 391: errorMsg1s("KsocketWrite([integer socketid, string data])");
! 392: }
! 393: ob1 = getoa(obj,0);
! 394: ob2 = getoa(obj,1);
! 395: if (ob1.tag != Sinteger) {
! 396: errorMsg1s("KsocketWrite([integer socketid, string data]) : the first argument must be an integer.");
! 397: }
! 398: socketid = KopInteger(ob1);
! 399: if (ob2.tag != Sdollar) {
! 400: errorMsg1s("KsocketWrite([integer socketid, string data]) : the second argument must be a string.");
! 401: }
! 402: r = write(socketid,KopString(ob2), strlen(KopString(ob2)));
! 403: return(KpoInteger(r));
! 404:
! 405: }
! 406: struct object KsocketClose(struct object obj) {
! 407: int socketid;
! 408: struct object ob1;
! 409: if (obj.tag != Sarray) {
! 410: errorMsg1s("KsocketClose([ integer socketid ])");
! 411: }
! 412: if (getoaSize(obj) != 1) {
! 413: errorMsg1s("KsocketClose([ integer socketid ])");
! 414: }
! 415: ob1 = getoa(obj,0);
! 416: if (ob1.tag != Sinteger) {
! 417: errorMsg1s("KsocketClose([ INTEGER socketid ])");
! 418: }
! 419: socketid = KopInteger(ob1);
! 420: return(KpoInteger(close(socketid)));
! 421: }
! 422:
! 423:
! 424: static void errorMsg1s(char *s) {
! 425: fprintf(stderr,"%s\n",s);
! 426: errorKan1("msg1s.c: %s\n",s);
! 427: }
! 428:
! 429:
! 430: /**************** new 1997, 11/23 *******************/
! 431: struct object KsocketReadByte(struct object obj);
! 432: struct object KsocketWriteByte(struct object obj);
! 433:
! 434: struct object KsocketReadByte(struct object obj) {
! 435: struct object ob1;
! 436: struct object robj = NullObject;
! 437: char data[2];
! 438: char *tmp;
! 439: char *r;
! 440: int n;
! 441: int socketid;
! 442:
! 443:
! 444: if (obj.tag != Sarray) {
! 445: errorMsg1s("KsocketReadByte([integer socketid])");
! 446: }
! 447: if (getoaSize(obj) < 1) {
! 448: errorMsg1s("KsocketReadByte([integer socketid])");
! 449: }
! 450: ob1 = getoa(obj,0);
! 451: if (ob1.tag != Sinteger) {
! 452: errorMsg1s("KsocketReadByte([integer socketid]) : the argument must be integer.");
! 453: }
! 454: socketid = KopInteger(ob1);
! 455:
! 456:
! 457: n = read(socketid,data,1);
! 458: if (n < 0) {
! 459: errorMsg1s("Read error.");
! 460: robj = KpoInteger(-1);
! 461: return(robj);
! 462: }
! 463: if (n == 0) {
! 464: errorMsg1s("Read returned without data.");
! 465: }
! 466:
! 467: robj = KpoInteger((int)((unsigned char)data[0]));
! 468: return(robj);
! 469:
! 470: }
! 471:
! 472: /* [ integer socketid, int ]
! 473: integer */
! 474: struct object KsocketWriteByte(struct object obj) {
! 475: struct object ob1;
! 476: struct object ob2;
! 477: int socketid;
! 478: int r;
! 479: char data[2];
! 480: if (obj.tag != Sarray) {
! 481: errorMsg1s("KsocketWriteByte([integer socketid, int])");
! 482: }
! 483: if (getoaSize(obj) < 2) {
! 484: errorMsg1s("KsocketWriteByte([integer socketid, int])");
! 485: }
! 486: ob1 = getoa(obj,0);
! 487: ob2 = getoa(obj,1);
! 488: if (ob1.tag != Sinteger) {
! 489: errorMsg1s("KsocketWriteByte([integer socketid, int]) : the first argument must be an integer.");
! 490: }
! 491: socketid = KopInteger(ob1);
! 492: if (ob2.tag != Sinteger) {
! 493: errorMsg1s("KsocketWriteByte([integer socketid, int]) : the second argument must be a string.");
! 494: }
! 495: data[0] = KopInteger(ob2);
! 496: r = write(socketid,data, 1);
! 497: return(KpoInteger(r));
! 498: }
! 499:
! 500: struct object Kplugin_sm1Socket(char *key,struct object obj) {
! 501: struct object robj = NullObject;
! 502: if (strcmp(key,"open") == 0) {
! 503: robj = KsocketOpen(obj);
! 504: }else if (strcmp(key,"connect") == 0) {
! 505: robj = KsocketConnect(obj);
! 506: }else if (strcmp(key,"accept") == 0) {
! 507: robj = KsocketAccept(obj);
! 508: }else if (strcmp(key,"select") == 0) {
! 509: robj = KsocketSelect(obj);
! 510: }else if (strcmp(key,"mselect") == 0) {
! 511: robj = KsocketSelectMulti(obj);
! 512: }else if (strcmp(key,"read") == 0) {
! 513: robj = KsocketRead(obj);
! 514: }else if (strcmp(key,"write") == 0) {
! 515: robj = KsocketWrite(obj);
! 516: }else if (strcmp(key,"read") == 0) {
! 517: robj = KsocketRead(obj);
! 518: }else if (strcmp(key,"readByte") == 0) {
! 519: robj = KsocketReadByte(obj);
! 520: }else if (strcmp(key,"writeByte") == 0) {
! 521: robj = KsocketWriteByte(obj);
! 522: }else if (strcmp(key,"close") == 0) {
! 523: robj = KsocketClose(obj);
! 524: }else {
! 525: errorMsg1s("Unknown tag for sm1.socket");
! 526: }
! 527: return(robj);
! 528: }
! 529:
! 530:
! 531:
! 532:
! 533:
! 534:
! 535:
! 536:
! 537:
! 538:
FreeBSD-CVSweb <freebsd-cvsweb@FreeBSD.org>
![[BACK]](/icons/cvsweb/back.gif){kind=icon}
Return to sm1Socket.c CVS log ![[TXT]](/icons/cvsweb/text.gif){kind=icon}
![[DIR]](/icons/cvsweb/dir.gif){kind=icon}
Up to [local] / OpenXM / src / kan96xx / plugin