stmbl/shared/ringbuf.c

#include "ringbuf.h"

/**
 * Read a single byte from a buffer
 *
 * \param   rb    pointer to ringbuffer struct
 * \param   data  pointer to data byte
 * \return  number of bytes read (0 if buffer was empty)
 */
int rb_getc(struct ringbuf *rb, char *data)
{
    if (!rb->len)
        return 0;

    *data = rb->buf[rb->pos++];
	if (rb->pos >= rb->bufsize)
		rb->pos -= rb->bufsize;
	rb->len--;
    return 1;
}


/**
 * Write a single byte to a buffer
 *
 * \param   rb    pointer to ringbuffer struct
 * \param   data  pointer to data byte
 * \return  number of bytes written (0 if buffer was full)
 */
int rb_putc(struct ringbuf *rb, const char data)
{
    if (rb->len >= rb->bufsize)
        return 0;

	unsigned i = rb->pos + rb->len;
	if (i >= rb->bufsize)
		i -= rb->bufsize;

	rb->buf[i] = data;
	rb->len++;

    return 1;
}

/**
 * Read from a buffer
 *
 */
int rb_read(struct ringbuf *rb, void *data, int len)
{
    if (len > rb->len)
        len = rb->len;

    int len1 = len;
    if (rb->pos + len1 >= rb->bufsize) {
        int len2 = (rb->pos + len1) - rb->bufsize;
        len1 -= len2;
        memcpy((char*)data + len1, rb->buf, len2);
    }
    memcpy(data, rb->buf + rb->pos, len1);

    rb->len -= len;
    rb->pos += len;
    if (rb->pos > rb->bufsize)
        rb->pos -= rb->bufsize;

    return len;
}


/**
 * Write to a buffer
 *
 * \param   rb    pointer to ringbuffer struct
 * \param   data  pointer to data byte
 * \return  number of bytes written (0 if buffer was full)
 *
 */
int rb_write(struct ringbuf *rb, const void *data, int len)
{
   int i = 0;
   char* d_ptr = (char*)data;
   while(len > 0 && rb_putc(rb, *d_ptr++)){
      len--;
      i++;
   }
   return(i);
   //  if (len > rb->bufsize - rb->len)
   //      len = rb->bufsize - rb->len;
    // 
   //  int len1 = len;
   //  if (rb->pos + rb->len + len1 >= rb->bufsize) {
   //      int len2 = (rb->pos + rb->len + len1) - rb->bufsize;
   //      len1 -= len2;
   //      memcpy(rb->buf, (char*)data + len1, len2);
   //  }
    // 
   //  memcpy(rb->buf + rb->pos + rb->len, data, len1);
    // 
   //  rb->len += len;
   //  return len;
}

int rb_getline(struct ringbuf *rb, char *ptr, int len){
   int ret = 0;
   char c;
   if (rb->len == 0){ 
		return 0;
	}

   while(rb_getc(rb, &c) && ret < len){
      ret++;
      *ptr++ = c;
      if(c == '\n'){
         *--ptr = '\0';
         return ret;
      }
   }
	rb_undo(rb, ret);
	return 0;
}

int rb_undo(struct ringbuf *rb, int len){
   if(len == 0){
      return(0);
   }
   if (rb->len + len > rb->bufsize){
      return(0);
   }
   if(rb->pos < len){
      rb->pos = rb->pos + rb->bufsize - len;
   }
   else{
      rb->pos = rb->pos - len;
   }
   rb->len = rb->len + len;
   return(len);
}