content_pipe_inet.c

Go to the documentation of this file.

#include "content_pipe_inet.h"

/*
 * Create a socket
*/

static CPresult Create( CPhandle *hContent, CPstring szURI )
{
  inet_ContentPipe* pPipe = (inet_ContentPipe*) hContent;
  CPresult err = 0;
  int nHostPort;
  struct sockaddr_in sAddress;  /* Internet socket address stuct */
  int nAddressSize=sizeof(struct sockaddr_in);

  DEBUG(DEB_LEV_FUNCTION_NAME, "content_pipe_inet:%s \n", __func__);

  if(1 != sscanf(szURI, "inet://%d", &nHostPort))
    err = KD_EINVAL;

  pPipe->sfd = socket(AF_INET, SOCK_STREAM, IPPROTO_TCP);
  if(SOCKET_ERROR == pPipe->sfd) {
    printf("\nCould not make a socket\n");
    err = KD_EIO;
  }

  if(0 == err) {

    /* fill address struct */
    sAddress.sin_addr.s_addr = INADDR_ANY;
    sAddress.sin_port = htons(nHostPort);
    sAddress.sin_family = AF_INET;

    /* bind to a port */
    if(SOCKET_ERROR == bind(pPipe->sfd ,(struct sockaddr*) &sAddress, sizeof(sAddress))) {
      printf("\nCould not connect to host\n");
      err = KD_EIO;
    }

  }

  if(0 == err) /* establish listen queue */
    if(listen(pPipe->sfd, QUEUE_SIZE) == SOCKET_ERROR) {
      printf("\nCould not listen\n");
      err = KD_EIO;
    }

  if(0 == err) /* get the connected socket */
    pPipe->cfd = accept(pPipe->sfd, (struct sockaddr*) &sAddress, (socklen_t*) &nAddressSize);

  return err;
}

static CPresult Open( CPhandle* hContent, CPstring szURI, CP_ACCESSTYPE eAccess )
{
  inet_ContentPipe* pPipe = (inet_ContentPipe*) hContent;
  CPresult err = 0;
  char strHostName[80];
  int nHostPort = 0;

  DEBUG(DEB_LEV_FUNCTION_NAME, "content_pipe_inet:%s \n", __func__);

  {
    char *pc = strrchr(szURI, ':');
    if(pc != NULL) {
      strncpy(strHostName, szURI+7, (long) pc - (long) szURI - 7);
      strHostName[(long) pc - (long) szURI - 7] = '\0';
      nHostPort = atoi(++pc);
    }
  }

  /* make a socket */
  pPipe->cfd = socket(AF_INET, SOCK_STREAM, IPPROTO_TCP);
  if(SOCKET_ERROR == pPipe->cfd) {
    err = KD_EIO;
  }

  if(0 == err) {

    struct hostent* pHostInfo;    /* holds info about a machine */
    long nHostAddress;
    struct sockaddr_in sAddress;  /* Internet socket address stuct */

    /* get IP address from name */
    pHostInfo = gethostbyname(strHostName);

    /* copy address into long */
    memcpy(&nHostAddress, pHostInfo->h_addr, pHostInfo->h_length);

    /* fill address struct */
    sAddress.sin_addr.s_addr = nHostAddress;
    sAddress.sin_port = htons(nHostPort);
    sAddress.sin_family = AF_INET;

    /* connect to host */
    if(SOCKET_ERROR == connect(pPipe->cfd, (struct sockaddr*) &sAddress, sizeof(sAddress))) {
      printf("\nCould not connect to host\n");
      err = KD_EIO;
    }

  }

  return err;
}

static CPresult Close( CPhandle hContent )
{
  inet_ContentPipe* pPipe = (inet_ContentPipe*) hContent;
  CPresult err = 0;

  DEBUG(DEB_LEV_FUNCTION_NAME, "content_pipe_inet:%s \n", __func__);

  /* close socket */
  if(SOCKET_ERROR == close(pPipe->cfd)) {
    printf("\nCould not close client socket\n");
    err = KD_EIO;
  }

  return err;
}

static CPresult CheckAvailableBytes( CPhandle hContent, CPuint nBytesRequested, CP_CHECKBYTESRESULTTYPE *eResult )
{
  DEBUG(DEB_LEV_FUNCTION_NAME, "content_pipe_inet:%s \n", __func__);

  return KD_EBADF;
}

static CPresult SetPosition( CPhandle  hContent, CPint nOffset, CP_ORIGINTYPE eOrigin)
{
  DEBUG(DEB_LEV_FUNCTION_NAME, "content_pipe_inet:%s \n", __func__);

  return KD_EBADF;
}

static CPresult GetPosition( CPhandle hContent, CPuint *pPosition)
{
  DEBUG(DEB_LEV_FUNCTION_NAME, "content_pipe_inet:%s \n", __func__);

  return KD_EBADF;
}

static CPresult Read( CPhandle hContent, CPbyte *pData, CPuint nSize)
{
  inet_ContentPipe* pPipe = (inet_ContentPipe*) hContent;
  CPresult err = 0;
  ssize_t count;

  DEBUG(DEB_LEV_FUNCTION_NAME, "content_pipe_inet:%s \n", __func__);

  count = read(pPipe->cfd, (void*) pData, (size_t) nSize);

  if(count < nSize) {
    err = KD_EIO;  /* ??? */
  } else if(count == -1) {
    err = KD_EIO;  /* ??? */
  }

  return err;
}

static CPresult ReadBuffer( CPhandle hContent, CPbyte **ppBuffer, CPuint *nSize, CPbool bForbidCopy)
{
  DEBUG(DEB_LEV_FUNCTION_NAME, "content_pipe_inet:%s \n", __func__);

  return KD_EBADF;
}

static CPresult ReleaseReadBuffer(CPhandle hContent, CPbyte *pBuffer)
{
  DEBUG(DEB_LEV_FUNCTION_NAME, "content_pipe_inet:%s \n", __func__);

  return KD_EBADF;
}

static CPresult Write( CPhandle hContent, CPbyte *pData, CPuint nSize)
{
  inet_ContentPipe* pPipe = (inet_ContentPipe*) hContent;
  CPresult err = 0;
  ssize_t count;

  DEBUG(DEB_LEV_FUNCTION_NAME, "content_pipe_inet:%s \n", __func__);

  count = write(pPipe->cfd, (void*) pData, (size_t) nSize);

  if(count < nSize) {
    err = KD_EIO;  /* ??? */
  } else if(count == -1) {
    err = KD_EIO;  /* ??? */
  }

  return err;
}

static CPresult GetWriteBuffer( CPhandle hContent, CPbyte **ppBuffer, CPuint nSize)
{
  DEBUG(DEB_LEV_FUNCTION_NAME, "content_pipe_inet:%s \n", __func__);

  return KD_EBADF;
}

static CPresult WriteBuffer( CPhandle hContent, CPbyte *pBuffer, CPuint nFilledSize)
{
  DEBUG(DEB_LEV_FUNCTION_NAME, "content_pipe_inet:%s \n", __func__);

  return KD_EBADF;
}

static CPresult RegisterCallback( CPhandle hContent, CPresult (*ClientCallback)(CP_EVENTTYPE eEvent, CPuint iParam))
{
  DEBUG(DEB_LEV_FUNCTION_NAME, "content_pipe_inet:%s \n", __func__);

  return KD_EBADF;
}

CPresult inet_pipe_Constructor(CP_PIPETYPE **ppPipe, CPstring szURI)
{
  inet_ContentPipe* pPipe;

  pPipe = (inet_ContentPipe*) calloc(1, sizeof(inet_ContentPipe));

  if(NULL != pPipe) {

    pPipe->pipe.Open = Open;
    pPipe->pipe.Close = Close;
    pPipe->pipe.Create = Create;
    pPipe->pipe.CheckAvailableBytes = CheckAvailableBytes;
    pPipe->pipe.SetPosition = SetPosition;
    pPipe->pipe.GetPosition = GetPosition;
    pPipe->pipe.Read = Read;
    pPipe->pipe.ReadBuffer = ReadBuffer;
    pPipe->pipe.ReleaseReadBuffer = ReleaseReadBuffer;
    pPipe->pipe.Write = Write;
    pPipe->pipe.GetWriteBuffer = GetWriteBuffer;
    pPipe->pipe.WriteBuffer = WriteBuffer;
    pPipe->pipe.RegisterCallback = RegisterCallback;

    pPipe->sfd = SOCKET_ERROR; /* Server file descriptor */
    pPipe->cfd = SOCKET_ERROR; /* Client file descriptor */

    *ppPipe = (CP_PIPETYPE*) pPipe;
  }

  return 0;
}