fastbuffer.c

Go to the documentation of this file.

/***************************************************************************
    begin       : Tue Apr 27 2010
    copyright   : (C) 2010 by Martin Preuss
    email       : martin@libchipcard.de
 
 ***************************************************************************
 *          Please see toplevel file COPYING for license details           *
 ***************************************************************************/
 
#ifdef HAVE_CONFIG_H
# include <config.h>
#endif
 
 
#define DISABLE_DEBUGLOG
 
 
#include "fastbuffer.h"
 
#include "i18n_l.h"
#include <gwenhywfar/misc.h>
#include <gwenhywfar/debug.h>
 
#include <assert.h>
 
 
GWEN_FAST_BUFFER *GWEN_FastBuffer_new(uint32_t bsize, GWEN_SYNCIO *io)
{
  GWEN_FAST_BUFFER *fb;
 
  assert(bsize);
 
  fb=(GWEN_FAST_BUFFER *) GWEN_Memory_malloc(sizeof(GWEN_FAST_BUFFER)+bsize);
  assert(fb);
  memset(fb, 0, sizeof(GWEN_FAST_BUFFER)+bsize);
 
  fb->bufferSize=bsize;
 
  fb->io=io;
 
  return fb;
}
 
 
 
void GWEN_FastBuffer_free(GWEN_FAST_BUFFER *fb)
{
  if (fb) {
    GWEN_Memory_dealloc(fb);
  }
}
 
 
 
int GWEN_FastBuffer_ReadLine(GWEN_FAST_BUFFER *fb, uint8_t *p, int len)
{
  int bytes;
  int copied=0;
 
  if (fb->bufferReadPos>=fb->bufferWritePos) {
    int rv;
 
    rv=GWEN_SyncIo_Read(fb->io, fb->buffer, fb->bufferSize);
    if (rv<0) {
      DBG_DEBUG(GWEN_LOGDOMAIN, "here (%d)", rv);
      return rv;
    }
  }
 
  bytes=fb->bufferWritePos-fb->bufferReadPos;
  if (bytes>len)
    bytes=len;
  while (bytes) {
    uint8_t c;
 
    c=fb->buffer[fb->bufferReadPos++];
    fb->bytesRead++;
    if (c==10) {
      *(p++)=c;
      copied++;
      break;
    }
    else if (c!=13) {
      *(p++)=c;
      copied++;
    }
    bytes--;
  } /* while */
 
  return copied;
}
 
 
 
int GWEN_FastBuffer_ReadLineToBuffer(GWEN_FAST_BUFFER *fb, GWEN_BUFFER *buf)
{
  int lineComplete=0;
  int hadSome=0;
 
  while (!lineComplete) {
    int bytes;
    int copied=0;
    uint8_t *p;
 
    if (fb->bufferReadPos>=fb->bufferWritePos) {
      int rv;
 
      rv=GWEN_SyncIo_Read(fb->io, fb->buffer, fb->bufferSize);
      if (rv<0) {
        if (rv==GWEN_ERROR_EOF && hadSome) {
          /* done */
          return 0;
        }
        DBG_INFO(GWEN_LOGDOMAIN, "here (%d)", rv);
        return rv;
      }
      else if (rv==0) {
        DBG_DEBUG(GWEN_LOGDOMAIN, "EOF met");
        if (!hadSome)
          return GWEN_ERROR_EOF;
        lineComplete=1;
        /* TODO: maybe we should have a flag that indicates that we met EOF here... */
      }
      else {
        fb->bufferWritePos=rv;
        fb->bufferReadPos=0;
      }
    }
 
    bytes=fb->bufferWritePos-fb->bufferReadPos;
    p=fb->buffer+fb->bufferReadPos;
    while (bytes) {
      uint8_t c;
 
      hadSome=1;
 
      c=fb->buffer[fb->bufferReadPos++];
      fb->bytesRead++;
      bytes--;
      if (c==10) {
        lineComplete=1;
        /* don't include this character */
        break;
      }
      else if (c==13) {
        break;
      }
      else {
        copied++;
      }
    } /* while */
 
    if (copied)
      GWEN_Buffer_AppendBytes(buf, (const char *)p, copied);
  }
 
  return 0;
}
 
 
 
uint32_t GWEN_FastBuffer_GetFlags(const GWEN_FAST_BUFFER *fb)
{
  assert(fb);
  return fb->flags;
}
 
 
 
void GWEN_FastBuffer_SetFlags(GWEN_FAST_BUFFER *fb, uint32_t fl)
{
  assert(fb);
  fb->flags=fl;
}
 
 
 
void GWEN_FastBuffer_AddFlags(GWEN_FAST_BUFFER *fb, uint32_t fl)
{
  assert(fb);
  fb->flags|=fl;
}
 
 
 
void GWEN_FastBuffer_SubFlags(GWEN_FAST_BUFFER *fb, uint32_t fl)
{
  assert(fb);
  fb->flags&=~fl;
}
 
 
 
uint32_t GWEN_FastBuffer_GetBytesWritten(const GWEN_FAST_BUFFER *fb)
{
  assert(fb);
  return fb->bytesWritten;
}
 
 
 
uint32_t GWEN_FastBuffer_GetBytesRead(const GWEN_FAST_BUFFER *fb)
{
  assert(fb);
  return fb->bytesRead;
}