sockets.h

Go to the documentation of this file.

#ifndef __LIB3195_SOCKETS_H_INCLUDED__
#define __LIB3195_SOCKETS_H_INCLUDED__ 1

#include "config.h"
#ifdef SROS_WIN32
#  include <winsock2.h>
#else
#include <sys/types.h>
#include <sys/time.h>
#include <sys/socket.h>
#include <sys/select.h>
#include <unistd.h>
#include <netinet/in.h>
#include <netdb.h>
#include <errno.h>
#endif

#define sbSockCHECKVALIDOBJECT(x) {assert(x != NULL); assert(x->OID == OIDsbSock);}

#define sbSOCK_NO_CHAR -1

struct sbSockObject 
{       
        srObjID OID;            
        srRetVal iLastErr;  
        SR_SOCKET sock;         
        int bIsInError;         
        int     dwLastError;    
        char szInBuf[SOCKETMAXINBUFSIZE]; 
        int iCurInBufPos;       
        int iInBufLen;          
        fd_set fdset;           
#       if FEATURE_LISTENER == 1
        struct sockaddr_in RemoteHostAddr;
        char *pRemoteHostIP;    
        int iRemHostIPBufLen;   
#       endif
};
typedef struct sbSockObject sbSockObj;


/* The following three macros could also be inline code.
 * For now, I have kept them to be macros to make 
 * facilitate porting.
 */

#define sbSockGetLastError(pThis) pThis->iLastErr

#define sbSockSetLastError(pThis, iRet) pThis->iLastErr = iRet

#define sbSockResetLastError(pThis) pThis->iLastErr = SR_RET_OK


srRetVal sbSockLayerInit(int bInitOSStack);     
srRetVal sbSockLayerExit(int bExitOSStack);

sbSockObj* sbSockInit(void);    
sbSockObj* sbSockInitEx(int af, int iSockType); 
srRetVal sbSockExit(sbSockObj*);        
int sbSockGetLastSockError(sbSockObj*); 
srRetVal sbSockConnectoToHost(sbSockObj* pThis, char* pszHost, int iPort);

int sbSockHasReceiveData(sbSockObj* pThis);

int sbSockReceive(sbSockObj* pThis, char * pszBuf, int iLen);

int sbSockSend(sbSockObj* pThis, const char* pszBuf, int iLen);

int sbSockGetRcvChar(sbSockObj *pThis);

int sbSockPeekRcvChar(sbSockObj *pThis);

srRetVal sbSockClosesocket(sbSockObj *pThis);


srRetVal sbSockWaitReceiveData(struct sbSockObject* pThis);

typedef fd_set srSock_fd_set;

#define sbSockFD_ZERO(fdset) FD_ZERO(fdset)

#define sbSockFD_SET(sock, fdset) FD_SET(sock, fdset)

#define sbSockFD_ISSET(sock, fdset) FD_ISSET(sock, fdset)


#       ifdef SROS_WIN32
                int sbSockSelectMulti(srSock_fd_set *fdsetRD, srSock_fd_set *fdsetWR, int iTimOutSecs, int iTimOutMSecs);
#       else
                int sbSockSelectMulti(srSock_fd_set *fdsetRD, srSock_fd_set *fdsetWR, int iTimOutSecs, int iTimOutMSecs, int iHighestDesc);
#       endif

srRetVal sbSockListen(sbSockObj*pThis);

sbSockObj*      sbSockInitListenSock(srRetVal *iRet, int iType, char *szBindToAddress, unsigned uBindToPort);

srRetVal sbSockAcceptConnection(sbSockObj* pThis, sbSockObj** pNew);

srRetVal sbSockSetNonblocking(sbSockObj*pThis);

srRetVal sbSockGetRemoteHostIP(sbSockObj *pThis, char **ppszHost);

srRetVal sbSock_gethostname(char **psz);

srRetVal sbSockGetIPusedForSending(sbSockObj* pThis, char**ppsz);


srRetVal sbSockRecvFrom(sbSockObj *pThis, char* pRecvBuf, int *piBufLen, char** ppFrom);


#ifdef SROS_WIN32
#       define SBSOCK_EWOULDBLOCK WSAEWOULDBLOCK
#else
#       define SBSOCK_EWOULDBLOCK EWOULDBLOCK
#       define SOCKET_ERROR -1
#endif

#endif

---