ucx: ucx/buffer.c@6814aea8462d (annotated)

ucx/buffer.c@6814aea8462d (annotated)

ucx/buffer.c

Wed, 10 Oct 2012 10:46:20 +0200

author: Mike Becker <universe@uap-core.de>
date: Wed, 10 Oct 2012 10:46:20 +0200
changeset 62: 6814aea8462d
parent 61: fb07a0ab9a17
child 63: 1d3500806565
permissions: -rw-r--r--

added extract function

 #include "buffer.h"
 #include <stdarg.h>
 #include <stdlib.h>
 #include <string.h>
 struct UcxBuffer {
     void *space;
     size_t pos;
     size_t size;
     int flags;
 };
 UcxBuffer *ucx_buffer_new(void *space, size_t length, int flags) {
     UcxBuffer *buffer = (UcxBuffer*) malloc(sizeof(UcxBuffer));
     if (buffer) {
         buffer->flags = flags;
         if (!space) {
             buffer->space = malloc(length);
             if (!buffer->space) {
                 free(buffer);
                 return NULL;
             }
             memset(buffer->space, 0, length);
             buffer->flags |= UCX_BUFFER_AUTOFREE;
         } else {
             buffer->space = space;
         }
         buffer->size = length;
         buffer->pos = 0;
     }
     return buffer;
 }
 void ucx_buffer_free(UcxBuffer *buffer) {
     if (ucx_buffer_testflags(buffer, UCX_BUFFER_AUTOFREE)) {
         free(buffer->space);
     }
     free(buffer);
 }
 UcxBuffer *ucx_buffer_extract(
         UcxBuffer *src, size_t start, size_t length, int flags) {
     if (length == 0) {
         length = src->size - start;
     }
     if (start+length > src->size) {
         return NULL;
     }
     UcxBuffer *dst = (UcxBuffer*) malloc(sizeof(UcxBuffer));
     if (dst) {
         dst->space = malloc(length);
         if (!dst->space) {
             free(dst);
             return NULL;
         }
         dst->size = length;
         dst->flags = flags | UCX_BUFFER_AUTOFREE;
         dst->pos = 0;
         memcpy(dst->space, (char*)src->space+start, length);
     }
     return dst;
 }
 int ucx_buffer_seek(UcxBuffer *buffer, off_t offset, int whence) {
     off_t npos;
     switch (whence) {
     case SEEK_SET:
         npos = 0;
         break;
     case SEEK_CUR:
         npos = buffer->pos;
         break;
     case SEEK_END:
         npos = strlen(buffer->space);
         break;
     }
     npos += offset;
     if (npos < 0 || npos > buffer->size) {
         return -1;
     } else {
         buffer->pos = npos;
         return 0;
     }
 }
 int ucx_buffer_eof(UcxBuffer *buffer) {
     return buffer->pos >= buffer->size;
 }
 size_t ucx_buffer_tell(UcxBuffer *buffer) {
     return buffer->pos;
 }
 size_t ucx_buffer_size(UcxBuffer *buffer) {
     return buffer->size;
 }
 int ucx_buffer_testflags(UcxBuffer *buffer, int flags) {
     return (buffer->flags & flags) == flags;
 }
 size_t ucx_bufio(void* d, size_t s, size_t n, UcxBuffer *b, _Bool read) {
     size_t len;
     if (b->pos + s*n > b->size) {
         len = b->size - b->pos;
         if (s > 1) len -= len%s;
     } else {
         len = s*n;
     }
     if (len == 0) {
         return 0;
     }
     if (read) {
         memcpy(d, (char*)b->space+b->pos, len);
     } else {
         memcpy((char*)b->space+b->pos, d, len);
     }
     b->pos += len;
     return len;
 }
 int ucx_buffer_putc(UcxBuffer *buffer, int c) {
     if (ucx_buffer_eof(buffer)) {
         return EOF;
     } else {
         c &= 0xFF;
         ((char*)(buffer->space))[buffer->pos] = (char) c;
         buffer->pos++;
         return c;
     }
 }
 int ucx_buffer_getc(UcxBuffer *buffer) {
     if (ucx_buffer_eof(buffer)) {
         return EOF;
     } else {
         int c = ((char*)(buffer->space))[buffer->pos];
         buffer->pos++;
         return c;
     }
 }

Mercurial > hg > ucx / annotate

ucx/buffer.c@6814aea8462d (annotated)

ucx/buffer.c