File: [local] / OpenXM / src / kan96xx / plugin / sm1Socket.c (download)
Revision 1.4, Sun Aug 12 03:13:36 2001 UTC (23 years, 1 month ago) by takayama
Branch: MAIN
CVS Tags: RELEASE_1_2_1 Changes since 1.3: +38 -10
lines
[(fp2pushfile) name] extension : read the file "name" as an array of integers.
httpd-sm1 can send images to browsers.
|
/* $OpenXM: OpenXM/src/kan96xx/plugin/sm1Socket.c,v 1.4 2001/08/12 03:13:36 takayama Exp $ */
/* msg0s.c */
#include <stdio.h>
#include <sys/types.h>
#include <sys/socket.h>
#include <sys/time.h>
#include <netinet/in.h>
#include <netdb.h>
#include "datatype.h"
#include "stackm.h"
#include "extern.h"
#include "sm1Socket.h"
extern int Quiet;
static void errorMsg1s(char *s);
/* [(sm1.socket) (open) [optional integer port, optional string name] ] extension ; */
struct object KsocketOpen(struct object obj) {
char serverName[1024];
int portNumber;
struct object rob = NullObject;
struct hostent *myhost;
struct sockaddr_in me;
int s_waiting;
int on;
int tt;
extern int errno;
if (obj.tag != Sarray) {
errorMsg1s("KsocketOpen([optional integer,optional string name])");
}
strcpy(serverName,"localhost");
portNumber = 0;
if (getoaSize(obj) >= 1) {
if ((getoa(obj,0)).tag != Sinteger) {
errorMsg1s("KsocketOpen([optional integer,optional string name]), the first argument must be an integer.");
}
portNumber = KopInteger(getoa(obj,0));
}
if (getoaSize(obj) >= 2) {
if ((getoa(obj,1)).tag != Sdollar) {
errorMsg1s("KsocketOpen([optional integer,optional string name]), the second argument must be a string.");
}
if (strlen(KopString(getoa(obj,1))) > 1023) {
errorMsg1s("Too long server name");
}
strcpy(serverName,KopString(getoa(obj,1)));
}
/* fprintf(stderr,"Hello from open.\n"); */
if ((myhost = gethostbyname(serverName)) == NULL) {
errorMsg1s("Bad server name.");
}
bzero((char *)&me,sizeof(me));
me.sin_family = AF_INET;
me.sin_port = htons(portNumber);
bcopy(myhost->h_addr,
&me.sin_addr,myhost->h_length);
if ((s_waiting = socket(AF_INET,SOCK_STREAM,0)) < 0) {
errorMsg1s("Socket allocation is failed.");
}
on=1; setsockopt(s_waiting,SOL_SOCKET,SO_REUSEADDR,&on,sizeof(on));
/* important */
if (bind(s_waiting,(struct sockaddr *) &me,sizeof(me)) == -1) {
fprintf(stderr,"Bind error. Error no is %d. See /usr/include/sys/errno.h.\n",errno);
errorMsg1s("cannot bind");
}
tt = sizeof(me);
if (getsockname(s_waiting,(struct sockaddr *)&me,&tt) < 0) {
fprintf(stderr,"getsockname error. Error no is %d. See /usr/include/sys/errno.h.\n",errno);
errorMsg1s("cannot getsockname");
}
if (listen(s_waiting,1) < 0) {
errorMsg1s("Listen failed");
}
/*
fprintf(stderr,"Done the initialization. port =%d\n",ntohs(me.sin_port));
fprintf(stderr,"socket id = %d",accept(s_waiting,NULL,NULL)); */
rob = newObjectArray(2);
putoa(rob,0,KpoInteger(s_waiting));
putoa(rob,1,KpoInteger(ntohs(me.sin_port)));
return(rob);
}
/* [ integer port, optional string host default localhost]
[ integer socketid, integer port ] */
struct object KsocketConnect(struct object obj) {
char serverName[1024];
int portNumber;
struct hostent *servhost;
struct sockaddr_in server;
int socketid;
struct object robj = NullObject;
if (obj.tag != Sarray) {
errorMsg1s("KsocketConnect( [ integer port, optional string host default localhost])");
}
strcpy(serverName,"localhost");
if (getoaSize(obj) < 1) {
errorMsg1s("You need to specify port number.\n");
}
if (getoaSize(obj) >= 1) {
if ((getoa(obj,0)).tag != Sinteger) {
errorMsg1s("KsocketConnect([integer port,optional string host]), the first argument must be an integer.");
}
portNumber = KopInteger(getoa(obj,0));
}
if (getoaSize(obj) >= 2) {
if ((getoa(obj,1)).tag != Sdollar) {
errorMsg1s("KsocketConnect([integer port,optional string host]), the second argument must be a string.");
}
if (strlen(KopString(getoa(obj,1))) > 1023) {
errorMsg1s("Too long server name");
}
strcpy(serverName,KopString(getoa(obj,1)));
}
if ((servhost = gethostbyname(serverName)) == NULL) {
errorMsg1s("bad server name.\n");
}
bzero((char *)&server,sizeof(server));
server.sin_family = AF_INET;
server.sin_port = htons(portNumber);
bcopy(servhost->h_addr,
(char *)&server.sin_addr,servhost->h_length);
if ((socketid = socket(AF_INET,SOCK_STREAM,0)) <0) {
errorMsg1s("socket allocation is failed.\n");
}
if (!Quiet) {
fprintf(stderr,"Trying to connect port %d, ip=%x\n",ntohs(server.sin_port),server.sin_addr);
}
if (connect(socketid,(struct sockaddr *)&server,sizeof(server)) == -1) {
errorMsg1s("cannot connect");
}
/* fprintf(stderr,"connected.\n"); */
robj = newObjectArray(2);
putoa(robj,0,KpoInteger(socketid));
putoa(robj,1,KpoInteger(portNumber));
return(robj);
}
/* [ integer socketid ]
[ integer newsocketid ] */
struct object KsocketAccept(struct object obj) {
struct object obj1;
struct object obj2;
struct object robj;
int s, news;
if (obj.tag != Sarray) {
errorMsg1s("KsocketAccept([integer socketid])");
}
if (getoaSize(obj) < 1) {
errorMsg1s("KsocketAccept([integer socketid])");
}
obj1 = getoa(obj,0);
if (obj1.tag != Sinteger ) {
errorMsg1s("KsocketAccept([integer socketid]), argument must be integer.");
}
s = KopInteger(obj1);
if ((news = accept(s,NULL,NULL)) < 0) {
errorMsg1s("Error in accept.");
}
if (close(s) < 0) {
errorMsg1s("Error in closing the old socket.");
}
robj = newObjectArray(1);
putoa(robj,0,KpoInteger(news));
return(robj);
}
int KsocketSelect0(int fd,int t) {
fd_set readfds;
struct timeval timeout;
extern int errno;
FD_ZERO(&readfds);
FD_SET(fd,&readfds);
timeout.tv_sec = 0;
timeout.tv_usec = (long) t;
if (t >= 0) {
if (select(fd+1,&readfds,(fd_set *)NULL,(fd_set *)NULL,&timeout)<0) {
/* It must be fd+1 !, Not fd. */
fprintf(stderr,"Select error. Error no is %d. See /usr/include/sys/errno.h.\n",errno);
errorMsg1s("KsocketSelect0() : select failed.");
return(0);
}
}else{ /* block */
if (select(fd+1,&readfds,(fd_set *)NULL,(fd_set *)NULL,(struct timeval *)NULL)<0) {
errorMsg1s("KsocketSelect0() : select failed.");
fprintf(stderr,"Select error. Error no is %d. See /usr/include/sys/errno.h.\n",errno);
return(0);
}
}
if (FD_ISSET(fd,&readfds)) return(1);
else return(0);
}
/* [ integer socketid optional integer timeout default 0]
integer true or false
*/
struct object KsocketSelect(struct object obj) {
struct object robj;
struct object ob1;
struct object ob2;
if (obj.tag != Sarray) {
errorMsg1s("KsocketSelect([ integer socketid optional integer timeout default 0]");
}
if (getoaSize(obj) < 1) {
errorMsg1s("KsocketSelect([ integer socketid optional integer timeout default 0]");
}
if (getoaSize(obj) >= 1) {
ob1 = getoa(obj,0);
ob2 = KpoInteger(0); /* default value */
}
if (getoaSize(obj) >= 2) {
ob2 = getoa(obj,1);
}
if (ob1.tag != Sinteger) {
errorMsg1s("KsocketSelect([ integer socketid optional integer timeout default 0] : the first argument must be an integer.");
}
if (ob2.tag != Sinteger) {
errorMsg1s("KsocketSelect([ integer socketid optional integer timeout default 0] : the second argument must be an integer.");
}
robj = KpoInteger( KsocketSelect0(KopInteger(ob1),KopInteger(ob2)) );
return(robj);
}
struct object KsocketSelectMulti(struct object obj)
/* [ [integer socketid1, integer socketid2, ...]
optional integer timeout default 0]
[ result1, result2, ....]
*/
{
struct object robj;
struct object ob1;
struct object ob2;
struct object ob3;
int size,i,fd,p,t;
fd_set readfds;
struct timeval timeout;
extern errno;
if (obj.tag != Sarray) {
errorMsg1s("KsocketSelectMulti([[sid1, sid2,...] optional integer timeout default 0]");
}
if (getoaSize(obj) < 1) {
errorMsg1s("KsocketSelectMulti([[sid1, sid2,...] optional integer timeout default 0]");
}
if (getoaSize(obj) >= 1) {
ob1 = getoa(obj,0);
ob2 = KpoInteger(0); /* default value */
}
if (getoaSize(obj) >= 2) {
ob2 = getoa(obj,1);
}
if (ob1.tag != Sarray) {
errorMsg1s("KsocketSelectMulti([[sid1, sid2, ...] optional integer timeout default 0] : the first argument must be an array.");
}
if (ob2.tag != Sinteger) {
errorMsg1s("KsocketSelectMulti([[sid1, sid2, ...] optional integer timeout default 0] : the second argument must be an integer.");
}
FD_ZERO(&readfds);
timeout.tv_sec = 0; t = KopInteger(ob2);
timeout.tv_usec = (long)t;
size = getoaSize(ob1);
if (size < 1) {
errorMsg1s("KsocketSelectMulti: the first argument must be a non-empty array of integers.");
}
fd = 0;
for (i=0; i<size; i++) {
ob3 = getoa(ob1,i);
if (ob3.tag != Sinteger) {
errorMsg1s("KsocketSelectMulti: the first argument must be an array of integers.");
}
p = KopInteger(ob3);
if (p > fd) fd = p;
FD_SET(p,&readfds);
/* printf("p = %d, fd=%d",p,fd); */
}
if (t >= 0) {
if (select(fd+1,&readfds,(fd_set *)NULL,(fd_set *)NULL,&timeout)<0) {
/* It must be fd+1 !, Not fd. */
fprintf(stderr,"Select error. Error no is %d. See /usr/include/sys/errno.h.\n",errno);
errorMsg1s("KsocketSelectMulti() : select failed.");
}
}else{ /* block */
if (select(fd+1,&readfds,(fd_set *)NULL,(fd_set *)NULL,(struct timeval *)NULL)<0) {
fprintf(stderr,"Select error. Error no is %d. See /usr/include/sys/errno.h.\n",errno);
errorMsg1s("KsocketSelectMulti() : (block) select failed.");
}
}
robj = newObjectArray(size);
for (i=0; i<size; i++) {
if (FD_ISSET(KopInteger(getoa(ob1,i)),&readfds)) {
putoa(robj,i,KpoInteger(1));
}else{
putoa(robj,i,KpoInteger(0));
}
}
return(robj);
}
static char Data00[1024];
/* [ integer socketid ]
string data
*/
struct object KsocketRead(struct object obj) {
struct object ob1;
struct object robj = NullObject;
static int datasize = 1024;
static char *data = Data00;
char *tmp;
char *r;
int n;
int socketid;
int totalsize;
if (obj.tag != Sarray) {
errorMsg1s("KsocketRead([integer socketid])");
}
if (getoaSize(obj) < 1) {
errorMsg1s("KsocketRead([integer socketid])");
}
ob1 = getoa(obj,0);
if (ob1.tag != Sinteger) {
errorMsg1s("KsocketRead([integer socketid]) : the argument must be integer.");
}
socketid = KopInteger(ob1);
totalsize = 0;
while (KsocketSelect0(socketid,0)) {
if (datasize - totalsize > 0) {
n = read(socketid,data+totalsize,datasize-totalsize);
if (n < 0) {
errorMsg1s("Read error.");
}
if (n < datasize-totalsize) {
totalsize += n;
break;
}else{ totalsize += n; }
if (totalsize == 0) {
errorMsg1s("Select returns 1, but there is no data to read.");
}
}else { /* increase the datasize */
tmp = (char *)GC_malloc(sizeof(char)*2*datasize);
/*I should use GC_malloc_atomic and free after finishing this function?*/
if (tmp == (char *)NULL) errorMsg1s("Out of Memory.");
bcopy(data,tmp,totalsize);
data = tmp;
datasize = 2*datasize;
}
}
r = (char *)GC_malloc(sizeof(char)*(n+1));
if (r == (char *)NULL) errorMsg1s("Out of Memory.");
bcopy(data,r,totalsize);
robj = KpoString(r);
return(robj);
}
/* [ integer socketid, string data ]
integer */
struct object KsocketWrite(struct object obj) {
struct object ob1;
struct object ob2;
int socketid;
int r;
if (obj.tag != Sarray) {
errorMsg1s("KsocketWrite([integer socketid, string data])");
}
if (getoaSize(obj) < 2) {
errorMsg1s("KsocketWrite([integer socketid, string data])");
}
ob1 = getoa(obj,0);
ob2 = getoa(obj,1);
if (ob1.tag != Sinteger) {
errorMsg1s("KsocketWrite([integer socketid, string data]) : the first argument must be an integer.");
}
socketid = KopInteger(ob1);
if (ob2.tag != Sdollar) {
errorMsg1s("KsocketWrite([integer socketid, string data]) : the second argument must be a string.");
}
r = write(socketid,KopString(ob2), strlen(KopString(ob2)));
return(KpoInteger(r));
}
struct object KsocketClose(struct object obj) {
int socketid;
struct object ob1;
if (obj.tag != Sarray) {
errorMsg1s("KsocketClose([ integer socketid ])");
}
if (getoaSize(obj) != 1) {
errorMsg1s("KsocketClose([ integer socketid ])");
}
ob1 = getoa(obj,0);
if (ob1.tag != Sinteger) {
errorMsg1s("KsocketClose([ INTEGER socketid ])");
}
socketid = KopInteger(ob1);
return(KpoInteger(close(socketid)));
}
static void errorMsg1s(char *s) {
fprintf(stderr,"%s\n",s);
errorKan1("msg1s.c: %s\n",s);
}
/**************** new 1997, 11/23 *******************/
struct object KsocketReadByte(struct object obj);
struct object KsocketWriteByte(struct object obj);
struct object KsocketReadByte(struct object obj) {
struct object ob1;
struct object robj = NullObject;
char data[2];
char *tmp;
char *r;
int n;
int socketid;
if (obj.tag != Sarray) {
errorMsg1s("KsocketReadByte([integer socketid])");
}
if (getoaSize(obj) < 1) {
errorMsg1s("KsocketReadByte([integer socketid])");
}
ob1 = getoa(obj,0);
if (ob1.tag != Sinteger) {
errorMsg1s("KsocketReadByte([integer socketid]) : the argument must be integer.");
}
socketid = KopInteger(ob1);
n = read(socketid,data,1);
if (n < 0) {
errorMsg1s("Read error.");
robj = KpoInteger(-1);
return(robj);
}
if (n == 0) {
errorMsg1s("Read returned without data.");
}
robj = KpoInteger((int)((unsigned char)data[0]));
return(robj);
}
/* [ integer socketid, int ]
integer */
struct object KsocketWriteByte(struct object obj) {
struct object ob1;
struct object ob2;
int socketid;
int r,i,n,kk,r0;
#define DATA_SIZE 1024
char data[DATA_SIZE];
if (obj.tag != Sarray) {
errorMsg1s("KsocketWriteByte([integer socketid, int | array of int])");
}
if (getoaSize(obj) < 2) {
errorMsg1s("KsocketWriteByte([integer socketid, int | array of int])");
}
ob1 = getoa(obj,0);
ob2 = getoa(obj,1);
if (ob1.tag != Sinteger) {
errorMsg1s("KsocketWriteByte([integer socketid, int | array of int]) : the first argument must be an integer.");
}
socketid = KopInteger(ob1);
if (ob2.tag != Sinteger && ob2.tag != Sarray) {
errorMsg1s("KsocketWriteByte([integer socketid, int | array of int]) : the second argument must be an integer or an array of integers.");
}
if (ob2.tag == Sinteger) {
data[0] = KopInteger(ob2);
r = write(socketid,data, 1);
}else{
n = getoaSize(ob2); kk = 0; r = 0;
for (i=0; i<n; i++) {
if (getoa(ob2,i).tag != Sinteger)
errorMsg1s("KsocketWriteByte([integer socketid, int | array of int]) : elements of the second argument must be integers.");
data[kk] = KopInteger(getoa(ob2,i));
kk++;
if (kk >= DATA_SIZE) {
r0 = write(socketid,data,kk);
if (r0 != kk) {
fprintf(stderr,"Warning: Could not write to the socket.\n");
return(KpoInteger(r+r0));
}
r += r0;
kk = 0;
}
}
if (kk > 0) {
r0 = write(socketid,data,kk);
if (r0 != kk) {
fprintf(stderr,"Warning: Could not write to the socket.\n");
return(KpoInteger(r+r0));
}
r += r0;
}
}
return(KpoInteger(r));
}
struct object Kplugin_sm1Socket(char *key,struct object obj) {
struct object robj = NullObject;
if (strcmp(key,"open") == 0) {
robj = KsocketOpen(obj);
}else if (strcmp(key,"connect") == 0) {
robj = KsocketConnect(obj);
}else if (strcmp(key,"accept") == 0) {
robj = KsocketAccept(obj);
}else if (strcmp(key,"select") == 0) {
robj = KsocketSelect(obj);
}else if (strcmp(key,"mselect") == 0) {
robj = KsocketSelectMulti(obj);
}else if (strcmp(key,"read") == 0) {
robj = KsocketRead(obj);
}else if (strcmp(key,"write") == 0) {
robj = KsocketWrite(obj);
}else if (strcmp(key,"read") == 0) {
robj = KsocketRead(obj);
}else if (strcmp(key,"readByte") == 0) {
robj = KsocketReadByte(obj);
}else if (strcmp(key,"writeByte") == 0) {
robj = KsocketWriteByte(obj);
}else if (strcmp(key,"close") == 0) {
robj = KsocketClose(obj);
}else {
errorMsg1s("Unknown tag for sm1.socket");
}
return(robj);
}