content_pipe_file.c

Go to the documentation of this file.

#include "content_pipe_file.h"

static CPresult Create( CPhandle *hContent, CPstring szURI )
{
  file_ContentPipe* pFilePipe = (file_ContentPipe*) hContent;
  char* pathname = szURI + 7;
  CPresult err = 0;
  int flags, ret;

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

  if(0 != strncmp(szURI, "file://", 7))
    err = KD_EINVAL;

  flags = O_WRONLY | O_CREAT;

  if(0 == err) {
    ret = open(pathname, flags, 0);
    if(-1 != ret) {
      pFilePipe->fd = ret;
    } else {
      err = KD_EIO;  /* ??? */
    }
  }

  return err;
}

static CPresult Open( CPhandle* hContent, CPstring szURI, CP_ACCESSTYPE eAccess )
{
  file_ContentPipe* pFilePipe = (file_ContentPipe*) hContent;
  CPresult err = 0;
  int flags, ret;

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

  if(0 != strncmp(szURI, "file://", 7))
    err = KD_EINVAL;

  if(0 == err)
    switch(eAccess) {
    case CP_AccessRead:
      flags = O_RDONLY;
      break;
    case CP_AccessWrite:
      flags = O_WRONLY;
      break;
    case CP_AccessReadWrite:
      flags = O_RDWR;
      break;
    default:
      err = KD_EINVAL;  /* ??? */
      break;
    }

  if(0 == err) {
    char* pathname = szURI + 7;
    ret = open(pathname, flags);
    if(-1 != ret) {
      pFilePipe->fd = ret;
    } else {
      /* Map errno */
      err = KD_EIO;  /* ??? */
    }
  }

  return err;
}

static CPresult Close( CPhandle hContent )
{
  file_ContentPipe* pFilePipe = (file_ContentPipe*) hContent;
  CPresult err = 0;
  int ret;

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

  ret = close(pFilePipe->fd);
  if(ret == -1) {
    /* Map errno */
    err = KD_EIO;  /* ??? */
  }

  return err;
}

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

  return KD_EBADF;
}

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

  return KD_EBADF;
}

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

  return KD_EBADF;
}

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

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

  count = read(pFilePipe->fd, (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_file:%s \n", __func__);

  return KD_EBADF;
}

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

  return KD_EBADF;
}

static CPresult Write( CPhandle hContent, CPbyte *pData, CPuint nSize)
{
  file_ContentPipe* pFilePipe = (file_ContentPipe*) hContent;
  CPresult err = 0;
  ssize_t ret;

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

  ret = write(pFilePipe->fd, (void*) pData, (size_t) nSize);

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

  return err;
}

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

  return KD_EBADF;
}

static CPresult WriteBuffer( CPhandle hContent, CPbyte *pBuffer, CPuint nFilledSize)
{
  DEBUG(DEB_LEV_FUNCTION_NAME, "content_pipe_file:%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_file:%s \n", __func__);

  return KD_EBADF;
}

CPresult file_pipe_Constructor(CP_PIPETYPE **ppPipe, CPstring szURI)
{
  file_ContentPipe* pFilePipe;

  pFilePipe = (file_ContentPipe*) calloc(1, sizeof(file_ContentPipe));

  if(NULL != pFilePipe) {

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

    pFilePipe->fd = -1; /* An invalid value */

    *ppPipe = (CP_PIPETYPE*) pFilePipe;
  }

  return 0;
}