Minor interface tweaks:
authorOrion Lawlor <olawlor@acm.org>
Sat, 19 Jul 2003 00:32:26 +0000 (00:32 +0000)
committerOrion Lawlor <olawlor@acm.org>
Sat, 19 Jul 2003 00:32:26 +0000 (00:32 +0000)
Use "void *" for all pointer parameters
(instead of the more annoying "char *"),
get rid of "unsigned int" except where it's
really needed.

src/conv-ccs/ccs-client.c
src/conv-ccs/ccs-client.h
src/util/sockRoutines.c
src/util/sockRoutines.h

index 359d8b4bc133483565d3131f1fb117e7b1071bf7..6077edb160514f7494ad10637789698642a07ec3 100644 (file)
@@ -57,7 +57,7 @@ CCS Reply ----------------------------------
 
 /*Parse list of nodes given to us by conv-host.
 */
-static void parseInfo(CcsServer *svr,const char *data)
+static void parseInfo(CcsServer *svr,const void *data)
 {
   /*Data conv-host sends us is just a big list of integers*/
   const ChMessageInt_t *d=(const ChMessageInt_t *)data;
@@ -149,7 +149,7 @@ int CcsConnectIp(CcsServer *svr, skt_ip_t ip, int port,const CcsSec_secretKey *k
 int CcsConnectIpWithTimeout(CcsServer *svr, skt_ip_t ip, int port,
        const CcsSec_secretKey *key, int timeout)
 {
-  unsigned int msg_len;char *msg_data;/*Reply message*/
+  int msg_len;void *msg_data;/*Reply message*/
   skt_init();
   svr->hostIP = ip;
   svr->hostPort = port;
@@ -221,11 +221,11 @@ int CcsNodeSize(CcsServer *svr,int node)
   return svr->numProcs[node];
 }
 
-int CcsSendRequest(CcsServer *svr, const char *hdlrID, int pe, unsigned int size, const char *msg){
+int CcsSendRequest(CcsServer *svr, const char *hdlrID, int pe, int size, const void *msg){
     return CcsSendRequestWithTimeout(svr, hdlrID, pe, size, msg, 120);
 }
 
-int CcsSendRequestWithTimeout(CcsServer *svr, const char *hdlrID, int pe, unsigned int size, const char *msg, int timeout)
+int CcsSendRequestWithTimeout(CcsServer *svr, const char *hdlrID, int pe, int size, const void *msg, int timeout)
 {
   const void *bufs[3]; int lens[3]; int nBuffers=0;
   CcsMessageHeader hdr;/*CCS request header*/
@@ -286,17 +286,17 @@ int CcsImpl_recvReplyAuth(CcsServer *svr)
 
 /*Receive data back from the server. (Arbitrary length response)
 */
-int CcsRecvResponseMsg(CcsServer *svr, unsigned int *size,char **newBuf, int timeout)
+int CcsRecvResponseMsg(CcsServer *svr, int *size,void **newBuf, int timeout)
 {
   ChMessageInt_t netLen;
   unsigned int len;  
   SOCKET fd=svr->replyFd;
   if (-1==CcsImpl_recvReplyAuth(svr)) return -1;
   if (1!=skt_select1(fd,1000*timeout)) return -1;
-  if (-1==skt_recvN(fd,(char *)&netLen,sizeof(netLen))) return -1;
+  if (-1==skt_recvN(fd,&netLen,sizeof(netLen))) return -1;
   *size=len=ChMessageInt(netLen);
-  *newBuf=(char *)malloc(len);
-  if (-1==skt_recvN(fd,(char *)*newBuf,len)) return -1;
+  *newBuf=malloc(len);
+  if (-1==skt_recvN(fd,*newBuf,len)) return -1;
 
   /*Close the connection*/
   skt_close(svr->replyFd);svr->replyFd=-1;
@@ -305,19 +305,19 @@ int CcsRecvResponseMsg(CcsServer *svr, unsigned int *size,char **newBuf, int tim
 
 /*Receive data from the server. (In-place receive)
 */
-int CcsRecvResponse(CcsServer *svr,  unsigned int maxsize, char *recvBuffer,int timeout)
+int CcsRecvResponse(CcsServer *svr,  int maxsize, void *recvBuffer,int timeout)
 {
   ChMessageInt_t netLen;
   unsigned int len;
   SOCKET fd=svr->replyFd;
   if (-1==CcsImpl_recvReplyAuth(svr)) return -1;
   if (1!=skt_select1(fd,1000*timeout)) return -1;
-  if (-1==skt_recvN(fd,(char *)&netLen,sizeof(netLen))) return -1;
+  if (-1==skt_recvN(fd,&netLen,sizeof(netLen))) return -1;
   len=ChMessageInt(netLen);
   DEBUGF(("[%.3f] recv'd reply length\n",CmiWallTimer()));
   if (len>maxsize) 
     {skt_close(fd);return -1;/*Buffer too small*/}
-  if (-1==skt_recvN(fd,(char *)recvBuffer,len)) return -1;
+  if (-1==skt_recvN(fd,recvBuffer,len)) return -1;
 
   /*Close the connection*/
   skt_close(svr->replyFd);svr->replyFd=-1;
index 9beab491e7d645c5c2a7209b6f8518c64eff458f..357e36e71a2dd91b84e84e4304565a4b25e01307 100644 (file)
@@ -51,14 +51,14 @@ int CcsConnectIp(CcsServer *svr,skt_ip_t ip, int port,const CcsSec_secretKey *ke
 int CcsConnectIpWithTimeout(CcsServer *svr,skt_ip_t ip, int port,const CcsSec_secretKey *key, int timeout);
 
 int CcsSendRequest(CcsServer *svr, const char *hdlrID, int pe, 
-                   unsigned int size, const char *msg);
+                   int size, const void *msg);
 int CcsSendRequestWithTimeout(CcsServer *svr, const char *hdlrID, int pe, 
-                   unsigned int size, const char *msg, int timeout);
+                   int size, const void *msg, int timeout);
 
 int CcsRecvResponse(CcsServer *svr, 
-                   unsigned int maxsize, char *recvBuffer, int timeout);
+                   int maxsize, void *recvBuffer, int timeout);
 int CcsRecvResponseMsg(CcsServer *svr, 
-                   unsigned int *retSize,char **newBuf, int timeout);
+                   int *retSize,void **newBuf, int timeout);
 int CcsNumNodes(CcsServer *svr);
 int CcsNumPes(CcsServer *svr);
 int CcsNodeFirst(CcsServer *svr, int node);
index 5417c39c25afb5723849d1180acca41eb616f34c..2cfc67504267b66e2d963a50c3d7b2d3bcb4fb6c 100644 (file)
@@ -268,7 +268,7 @@ int skt_ip_match(skt_ip_t a,skt_ip_t b)
 {
   return 0==memcmp(&a,&b,sizeof(a));
 }
-struct sockaddr_in skt_build_addr(skt_ip_t IP,unsigned int port)
+struct sockaddr_in skt_build_addr(skt_ip_t IP,int port)
 {
   struct sockaddr_in ret={0};
   ret.sin_family=AF_INET;
@@ -277,7 +277,7 @@ struct sockaddr_in skt_build_addr(skt_ip_t IP,unsigned int port)
   return ret;  
 }
 
-SOCKET skt_datagram(unsigned int *port, unsigned int bufsize)
+SOCKET skt_datagram(int *port, int bufsize)
 {  
   int connPort=(port==NULL)?0:*port;
   struct sockaddr_in addr=skt_build_addr(skt_invalid_ip,connPort);
@@ -294,7 +294,7 @@ retry:
          return skt_abort(93491,"Error binding datagram socket.");
   
   len = sizeof(addr);
-  if (getsockname(ret, (struct sockaddr *)&addr , &len))
+  if (getsockname(ret, (struct sockaddr *)&addr , (socklen_t*)&len))
          return skt_abort(93492,"Error getting address on datagram socket.");
 
   if (bufsize) 
@@ -306,15 +306,15 @@ retry:
                return skt_abort(93496,"Error on SNDBUF sockopt for datagram socket.");
   }
   
-  if (port!=NULL) *port = ntohs(addr.sin_port);
+  if (port!=NULL) *port = (int)ntohs(addr.sin_port);
   return ret;
 }
-SOCKET skt_server(unsigned int *port)
+SOCKET skt_server(int *port)
 {
   return skt_server_ip(port,NULL);
 }
 
-SOCKET skt_server_ip(unsigned int *port,skt_ip_t *ip)
+SOCKET skt_server_ip(int *port,skt_ip_t *ip)
 {
   SOCKET             ret;
   int                len;
@@ -336,22 +336,22 @@ retry:
   if (listen(ret,5) == SOCKET_ERROR) 
          return skt_abort(93485,"Error listening on server socket.");
   len = sizeof(addr);
-  if (getsockname(ret, (struct sockaddr *)&addr, &len) == SOCKET_ERROR) 
+  if (getsockname(ret, (struct sockaddr *)&addr, (socklen_t*)&len) == SOCKET_ERROR) 
          return skt_abort(93486,"Error getting name on server socket.");
 
-  if (port!=NULL) *port = ntohs(addr.sin_port);
+  if (port!=NULL) *port = (int)ntohs(addr.sin_port);
   if (ip!=NULL) memcpy(ip, &addr.sin_addr, sizeof(*ip));
   return ret;
 }
 
-SOCKET skt_accept(SOCKET src_fd,skt_ip_t *pip, unsigned int *port)
+SOCKET skt_accept(SOCKET src_fd,skt_ip_t *pip, int *port)
 {
   int len;
   struct sockaddr_in addr={0};
   SOCKET ret;
   len = sizeof(addr);
 retry:
-  ret = accept(src_fd, (struct sockaddr *)&addr, &len);
+  ret = accept(src_fd, (struct sockaddr *)&addr, (socklen_t*)&len);
   if (ret == SOCKET_ERROR) {
     if (skt_should_retry()) goto retry;
     else return skt_abort(93523,"Error in accept.");
@@ -457,7 +457,7 @@ int skt_sendV(SOCKET fd,int nBuffers,const void **bufs,int *lens)
        int b,len=0;
        for (b=0;b<nBuffers;b++) len+=lens[b];
        if (len<=skt_sendV_max) { /*Short message: Copy and do one big send*/
-               char *buf=CmiTmpAlloc(skt_sendV_max);
+               char *buf=(char *)CmiTmpAlloc(skt_sendV_max);
                char *dest=buf;
                int ret;
                for (b=0;b<nBuffers;b++) {
@@ -520,7 +520,7 @@ unsigned int ChMessageInt(ChMessageInt_t src)
 { /*Convert bytes to integer*/
   int i; unsigned int ret=0;
   for (i=0;i<4;i++) {ret<<=8;ret+=src.data[i];}
-  return ret;
+  return (int)ret;
 }
 
 int ChMessage_recv(SOCKET fd,ChMessage *dst)
@@ -541,15 +541,13 @@ void ChMessage_free(ChMessage *doomed)
   doomed->data=NULL;
   doomed->len=-1234;
 }
-void ChMessageHeader_new(const char *type,unsigned int len,
-                  ChMessageHeader *dst)
+void ChMessageHeader_new(const char *type,int len,ChMessageHeader *dst)
 {
   dst->len=ChMessageInt_new(len);
   if (type==NULL) type="default";
   strncpy(dst->type,type,CH_TYPELEN);
 }
-void ChMessage_new(const char *type,unsigned int len,
-                  ChMessage *dst)
+void ChMessage_new(const char *type,int len,ChMessage *dst)
 {
   ChMessageHeader_new(type,len,&dst->header);
   dst->len=len;
index 36689eea9ebc807f97e6dcdf5b554a5202c22076..7a200d1e7def3a0a536a2b0b7cd64d506eb35a0e 100644 (file)
@@ -164,14 +164,15 @@ skt_ip_t skt_innode_lookup_ip(const char *name);
 
 char *skt_print_ip(char *dest,skt_ip_t addr);
 int skt_ip_match(skt_ip_t a,skt_ip_t b);
-struct sockaddr_in skt_build_addr(skt_ip_t IP,unsigned int port);
+struct sockaddr_in skt_build_addr(skt_ip_t IP,int port);
 
 /*UDP*/
-SOCKET skt_datagram(unsigned int *port, unsigned int bufsize);
+SOCKET skt_datagram(int *port, int bufsize);
 
 /*TCP*/
-SOCKET skt_server(unsigned int *port);
-SOCKET skt_accept(SOCKET src_fd, skt_ip_t *pip, unsigned int *port);
+SOCKET skt_server(int *port);
+SOCKET skt_server_ip(int *port,skt_ip_t *ip);
+SOCKET skt_accept(SOCKET src_fd, skt_ip_t *pip, int *port);
 SOCKET skt_connect(skt_ip_t ip, int port, int timeout);
 
 /*Utility*/
@@ -245,10 +246,8 @@ typedef struct ChMessage {
 } ChMessage;
 int ChMessage_recv(SOCKET fd,ChMessage *dst);
 void ChMessage_free(ChMessage *doomed);
-void ChMessageHeader_new(const char *type,unsigned int len,
-                  ChMessageHeader *dst);
-void ChMessage_new(const char *type,unsigned int len,
-                  ChMessage *dst);
+void ChMessageHeader_new(const char *type,int len,ChMessageHeader *dst);
+void ChMessage_new(const char *type,int len,ChMessage *dst);
 int ChMessage_send(SOCKET fd,const ChMessage *src); /*You must free after send*/
 
 typedef struct {