changes

[IRC.git] / Robust / src / Runtime / socket.c

diff --git a/Robust/src/Runtime/socket.c b/Robust/src/Runtime/socket.c
index 6e05e63aa2a5ab72c12d569db81d8ff27607acbb..17e189c62f8c5d3cc56099ab5f46e7349528871d 100644 (file)
--- a/Robust/src/Runtime/socket.c
+++ b/Robust/src/Runtime/socket.c
@@ -5,18 +5,141 @@
 #include <arpa/inet.h>
 #include <strings.h>
 #include <errno.h>
+#include <netdb.h>
 #include "SimpleHash.h"
 #include "GenericHashtable.h"
 
 extern struct RuntimeHash *fdtoobject;
 
+int CALL23(___Socket______nativeConnect____I__AR_B_I, int ___fd___, int ___port___, int ___fd___, struct ArrayObject * ___address___ ,int ___port___) {
+  struct sockaddr_in sin;
+  int rc;
+  
+  bzero(&sin, sizeof(sin));
+  sin.sin_family= AF_INET;
+  sin.sin_port=htons(___port___);
+  sin.sin_addr.s_addr=htonl(*(((char *)&VAR(___address___)->___length___)+sizeof(int)));
+  do {
+    rc = connect(___fd___, (struct sockaddr *) &sin, sizeof(sin));
+  } while (rc<0 && errno==EINTR); /* repeat if interrupted */
+  
+  if (rc<0) goto error;
+  return 0;
+  
+ error:
+  close(___fd___);
+  return -1;
+}
+
+
+int CALL12(___Socket______nativeBind_____AR_B_I, int ___port___,  struct ArrayObject * ___address___, int ___port___) {
+  int fd;
+  int rc;
+  socklen_t sa_size;
+  struct sockaddr_in sin;
+  bzero(&sin, sizeof(sin));
+  sin.sin_family= AF_INET;
+  sin.sin_port=htons(___port___);
+  sin.sin_addr.s_addr=htonl(*(((char *) &VAR(___address___)->___length___)+sizeof(int)));
+  
+  fd=socket(AF_INET, SOCK_STREAM, 0);
+  if (fd<0) {
+#ifdef DEBUG
+    perror(NULL);
+    printf("createSocket error in nativeBind\n");
+#endif
+#ifdef TASK
+    longjmp(error_handler,12);
+#else
+#ifdef THREADS
+    threadexit();
+#else
+    exit(-1);
+#endif
+#endif
+  }
+  
+#ifdef TASK
+  //Make non-blocking
+  fcntl(fd, F_SETFD, 1);
+  fcntl(fd, F_SETFL, fcntl(fd, F_GETFL)|O_NONBLOCK);
+#endif
+
+  rc = bind(fd, (struct sockaddr *) &sin, sizeof(sin));
+  if (rc<0) goto error;
+
+  sa_size = sizeof(sin);
+  rc = getsockname(fd, (struct sockaddr *) &sin, &sa_size);
+  if (rc<0) goto error;
+
+  return fd;
+
+ error:
+  close(fd);
+#ifdef DEBUG
+  perror(NULL);
+  printf("createSocket error #2 in nativeBind\n");
+#endif
+#ifdef TASK
+  longjmp(error_handler,13);
+#else
+#ifdef THREADS
+  threadexit();
+#else
+  exit(-1);
+#endif
+#endif
+}
+
+struct ArrayObject * CALL01(___InetAddress______getHostByName_____AR_B, struct ___ArrayObject___ * ___hostname___) {
+  int length=VAR(___hostname___)->___length___;
+  int i,j,n;
+  char * str=malloc(length+1);
+  struct hostent *h;
+  struct ArrayObject * arraybytearray;
+
+  for(i=0;i<length;i++) {
+    str[i]=(((char *)&VAR(___hostname___)->___length___)+sizeof(int))[i];
+  }
+  str[length]=0;
+  h=gethostbyname(str);
+  free(str);
+  
+  for (n=0; h->h_addr_list[n]; n++) /* do nothing */ ;
+  
+#ifdef PRECISE_GC
+  arraybytearray=allocate_newarray(___params___,BYTEARRAYARRAYTYPE,n);
+#else
+  arraybytearray=allocate_newarray(BYTEARRAYARRAYTYPE,n);
+#endif
+  for(i=0;i<n;i++) {
+    struct ArrayObject *bytearray;
+#ifdef PRECISE_GC
+    {
+      int ptrarray[]={1, (int) ___params___, (int)arraybytearray};
+      bytearray=allocate_newarray(&ptrarray,BYTEARRAYTYPE,h->h_length);
+      arraybytearray=(struct ArrayObject *) ptrarray[2];
+    }
+#else
+    bytearray=allocate_newarray(BYTEARRAYTYPE,h->h_length);
+#endif
+    ((void **)&((&arraybytearray->___length___)[1]))[i]=bytearray;
+    for(j=0;j<h->h_length;j++) {
+      ((char *)&((&bytearray->___length___)[1]))[j]=h->h_addr_list[i][j];
+    }
+  }
+  
+  return arraybytearray;
+}
+
+
 int CALL12(___ServerSocket______createSocket____I, int port, struct ___ServerSocket___ * ___this___, int port) {
   int fd;
 
   int n=1;
   struct sockaddr_in sin;
 
-  bzero (&sin, sizeof (sin));
+  bzero(&sin, sizeof(sin));
   sin.sin_family = AF_INET;
   sin.sin_port = htons (port);
   sin.sin_addr.s_addr = htonl (INADDR_ANY);
@@ -40,7 +163,7 @@ int CALL12(___ServerSocket______createSocket____I, int port, struct ___ServerSoc
   if (setsockopt (fd, SOL_SOCKET, SO_REUSEADDR, (char *)&n, sizeof (n)) < 0) {
     close(fd);
 #ifdef DEBUG
-    perror(NULL);
+    perror("");
     printf("createSocket error #2\n");
 #endif
 #ifdef TASK
@@ -61,9 +184,9 @@ int CALL12(___ServerSocket______createSocket____I, int port, struct ___ServerSoc
 
   /* bind to port */
   if (bind(fd, (struct sockaddr *) &sin, sizeof(sin))<0) { 
-    close (fd);
+    close(fd);
 #ifdef DEBUG
-    perror(NULL);
+    perror("");
     printf("createSocket error #3\n");
 #endif
 #ifdef TASK
@@ -81,7 +204,7 @@ int CALL12(___ServerSocket______createSocket____I, int port, struct ___ServerSoc
   if (listen(fd, 5)<0) { 
     close (fd);
 #ifdef DEBUG
-    perror(NULL);
+    perror("");
     printf("createSocket error #4\n");
 #endif
 #ifdef TASK
@@ -188,6 +311,7 @@ int CALL02(___Socket______nativeRead_____AR_B, struct ___Socket___ * ___this___,
 
   if (byteread<0) {
     printf("ERROR IN NATIVEREAD\n");
+    return 0;
   }
 #ifdef TASK
   flagorand(VAR(___this___),0,0xFFFFFFFE);