socket.c

一个很好用的解析

/*============================================================================
  socket.c
==============================================================================
  Implementation of TSocket class: A generic socket over which one can
  transport an HTTP stream or manage HTTP connections
============================================================================*/

#include <sys/types.h>
#include <assert.h>
#include <netinet/in.h>
#include <arpa/inet.h>
#include <stdio.h>
#include <stdlib.h>

#include "mallocvar.h"
#include "xmlrpc-c/util_int.h"
#include "xmlrpc-c/abyss.h"
#include "xmlrpc-c/util_int.h"
#ifdef WIN32
  #include "socket_win.h"
#else
  #include "socket_unix.h"
#endif
#include "socket.h"


#ifdef WIN32
  #include "socket_win.h"
#else
  #include "socket_unix.h"
#endif

#include "socket.h"


static void
socketOsInit(abyss_bool * const succeededP) {

#ifdef WIN32
    SocketWinInit(succeededP);
#else
    SocketUnixInit(succeededP);
#endif
}



static void
socketOsTerm(void) {

#ifdef WIN32
    SocketWinTerm();
#else
    SocketUnixTerm();
#endif
}
    


abyss_bool SocketTraceIsActive;

abyss_bool
SocketInit(void) {
    abyss_bool retval;

    socketOsInit(&retval);

    SocketTraceIsActive = (getenv("ABYSS_TRACE_SOCKET") != NULL);
    if (SocketTraceIsActive)
        fprintf(stderr, "Abyss socket layer will trace socket traffic "
                "due to ABYSS_TRACE_SOCKET environment variable\n");

    return retval;
}



void
SocketTerm(void) {

    socketOsTerm();
}



/* SocketCreate() is not exported to the Abyss user.  It is meant to
   be used by an implementation-specific TSocket generator which is
   exported to the Abyss user, e.g. SocketCreateUnix() in
   socket_unix.c

   The TSocket generator functions are the _only_ user-accessible
   functions that are particular to an implementation.
*/

static uint const socketSignature = 0x060609;

void
SocketCreate(const struct TSocketVtbl * const vtblP,
             void *                     const implP,
             TSocket **                 const socketPP) {

    TSocket * socketP;

    MALLOCVAR(socketP);

    if (socketP) {
        socketP->implP = implP;
        socketP->vtbl = *vtblP;
        socketP->signature = socketSignature;
        *socketPP = socketP;
    }
}



void
SocketDestroy(TSocket * const socketP) {

    assert(socketP->signature == socketSignature);

    socketP->vtbl.destroy(socketP);

    socketP->signature = 0;  /* For debuggability */

    free(socketP);
}



void
SocketWrite(TSocket *             const socketP,
            const unsigned char * const buffer,
            uint32_t              const len,
            abyss_bool *          const failedP) {

    (*socketP->vtbl.write)(socketP, buffer, len, failedP );
}



uint32_t
SocketRead(TSocket *       const socketP, 
           unsigned char * const buffer, 
           uint32_t        const len) {
    
    return (*socketP->vtbl.read)(socketP, buffer, len);
}



abyss_bool
SocketConnect(TSocket * const socketP,
              TIPAddr * const addrP,
              uint16_t  const portNumber) {

    return (*socketP->vtbl.connect)(socketP, addrP, portNumber);
}



abyss_bool
SocketBind(TSocket * const socketP,
           TIPAddr * const addrP,
           uint16_t  const portNumber) {

    return (*socketP->vtbl.bind)(socketP, addrP, portNumber);
}



abyss_bool
SocketListen(TSocket * const socketP,
             uint32_t  const backlog) {

    return (*socketP->vtbl.listen)(socketP, backlog);
}



void
SocketAccept(TSocket *    const listenSocketP,
             abyss_bool * const connectedP,
             abyss_bool * const failedP,
             TSocket **   const acceptedSocketPP,
             TIPAddr *    const ipAddrP) {

    (*listenSocketP->vtbl.accept)(listenSocketP,
                                  connectedP,
                                  failedP,
                                  acceptedSocketPP,
                                  ipAddrP);
}



uint32_t
SocketWait(TSocket *  const socketP,
           abyss_bool const rd,
           abyss_bool const wr,
           uint32_t   const timems) {

    return (*socketP->vtbl.wait)(socketP, rd, wr, timems);
}



uint32_t
SocketAvailableReadBytes(TSocket * const socketP) {

    return (*socketP->vtbl.availableReadBytes)(socketP);
}



void
SocketGetPeerName(TSocket *    const socketP,
                  TIPAddr *    const ipAddrP,
                  uint16_t *   const portNumberP,
                  abyss_bool * const successP) {

    (*socketP->vtbl.getPeerName)(socketP, ipAddrP, portNumberP, successP);
}



uint32_t
SocketError(TSocket * const socketP) {

    return (*socketP->vtbl.error)(socketP);
}