ucx/buffer.h

Mon, 05 May 2014 15:56:39 +0200

author
Mike Becker <universe@uap-core.de>
date
Mon, 05 May 2014 15:56:39 +0200
changeset 166
350a0e3898bd
parent 165
4d85da1f98db
child 168
24a012440dee
permissions
-rw-r--r--

improved more buffer tests + some doc fixes

universe@103 1 /*
universe@103 2 * DO NOT ALTER OR REMOVE COPYRIGHT NOTICES OR THIS HEADER.
universe@103 3 *
universe@103 4 * Copyright 2013 Olaf Wintermann. All rights reserved.
universe@103 5 *
universe@103 6 * Redistribution and use in source and binary forms, with or without
universe@103 7 * modification, are permitted provided that the following conditions are met:
universe@103 8 *
universe@103 9 * 1. Redistributions of source code must retain the above copyright
universe@103 10 * notice, this list of conditions and the following disclaimer.
universe@103 11 *
universe@103 12 * 2. Redistributions in binary form must reproduce the above copyright
universe@103 13 * notice, this list of conditions and the following disclaimer in the
universe@103 14 * documentation and/or other materials provided with the distribution.
universe@103 15 *
universe@103 16 * THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS "AS IS"
universe@103 17 * AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE
universe@103 18 * IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE
universe@103 19 * ARE DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT HOLDER OR CONTRIBUTORS BE
universe@103 20 * LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR
universe@103 21 * CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF
universe@103 22 * SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS
universe@103 23 * INTERRUPTION) HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN
universe@103 24 * CONTRACT, STRICT LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE)
universe@103 25 * ARISING IN ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE
universe@103 26 * POSSIBILITY OF SUCH DAMAGE.
universe@103 27 */
universe@103 28
universe@140 29 /**
universe@140 30 * @file buffer.h
universe@140 31 *
universe@140 32 * Advanced buffer implementation.
universe@140 33 *
universe@140 34 * Instances of UcxBuffer can be used to read from or to write to like one
universe@140 35 * would do with a stream. This allows the use of ucx_stream_copy() to copy
universe@140 36 * contents from one buffer to another.
universe@140 37 *
universe@140 38 * Some features for convenient use of the buffer
universe@140 39 * can be enabled. See the documentation of the macro constants for more
universe@140 40 * information.
universe@140 41 *
universe@140 42 * @author Mike Becker
universe@140 43 * @author Olaf Wintermann
universe@140 44 */
universe@140 45
olaf@120 46 #ifndef UCX_BUFFER_H
olaf@120 47 #define UCX_BUFFER_H
universe@56 48
universe@69 49 #include "ucx.h"
universe@62 50 #include <sys/types.h>
universe@56 51 #include <stdio.h>
universe@56 52
universe@56 53 #ifdef __cplusplus
universe@56 54 extern "C" {
universe@56 55 #endif
universe@56 56
universe@140 57 /**
universe@140 58 * No buffer features enabled (all flags cleared).
universe@140 59 */
universe@61 60 #define UCX_BUFFER_DEFAULT 0x00
universe@146 61
universe@140 62 /**
universe@140 63 * If this flag is enabled, the buffer will automatically free its contents.
universe@140 64 */
universe@61 65 #define UCX_BUFFER_AUTOFREE 0x01
universe@146 66
universe@140 67 /**
universe@140 68 * If this flag is enabled, the buffer will automatically extends its capacity.
universe@140 69 */
universe@63 70 #define UCX_BUFFER_AUTOEXTEND 0x02
universe@56 71
universe@140 72 /** UCX Buffer. */
universe@63 73 typedef struct {
universe@140 74 /** A pointer to the buffer contents. */
olaf@76 75 char *space;
universe@140 76 /** Current position of the buffer. */
universe@63 77 size_t pos;
universe@140 78 /** Current capacity (i.e. maximum size) of the buffer. */
olaf@76 79 size_t capacity;
universe@140 80 /** Current size of the buffer content. */
universe@63 81 size_t size;
universe@140 82 /**
universe@140 83 * Flag register for buffer features.
universe@140 84 * @see #UCX_BUFFER_DEFAULT
universe@140 85 * @see #UCX_BUFFER_AUTOFREE
universe@140 86 * @see #UCX_BUFFER_AUTOEXTEND
universe@140 87 */
universe@63 88 int flags;
universe@63 89 } UcxBuffer;
universe@56 90
universe@140 91 /**
universe@140 92 * Creates a new buffer.
universe@140 93 *
universe@140 94 * <b>Note:</b> you may provide <code>NULL</code> as argument for
universe@140 95 * <code>space</code>. Then this function will allocate the space and enforce
universe@140 96 * the #UCX_BUFFER_AUTOFREE flag.
universe@140 97 *
universe@140 98 * @param space pointer to the memory area, or <code>NULL</code> to allocate
universe@140 99 * new memory
universe@140 100 * @param size the size of the buffer
universe@140 101 * @param flags buffer features (see UcxBuffer.flags)
universe@140 102 * @return the new buffer
universe@140 103 */
olaf@76 104 UcxBuffer *ucx_buffer_new(void *space, size_t size, int flags);
universe@140 105
universe@140 106 /**
universe@140 107 * Destroys a buffer.
universe@140 108 *
universe@140 109 * If the #UCX_BUFFER_AUTOFREE feature is enabled, the contents of the buffer
universe@140 110 * are also freed.
universe@140 111 *
universe@140 112 * @param buffer the buffer to destroy
universe@140 113 */
universe@60 114 void ucx_buffer_free(UcxBuffer* buffer);
universe@56 115
universe@140 116 /**
universe@140 117 * Creates a new buffer and fills it with extracted content from another buffer.
universe@140 118 *
universe@140 119 * <b>Note:</b> the #UCX_BUFFER_AUTOFREE feature is enforced for the new buffer.
universe@140 120 *
universe@140 121 * @param src the source buffer
universe@140 122 * @param start the start position of extraction
universe@140 123 * @param length the count of bytes to extract or 0 if all of the remaining
universe@140 124 * bytes shall be extracted
universe@140 125 * @param flags feature mask for the new buffer
universe@163 126 * @return a new buffer containing the extraction
universe@62 127 */
olaf@76 128 UcxBuffer* ucx_buffer_extract(UcxBuffer *src,
universe@62 129 size_t start, size_t length, int flags);
universe@140 130
universe@140 131 /**
universe@140 132 * A shorthand macro for the full extraction of the buffer.
universe@140 133 *
universe@140 134 * @param src the source buffer
universe@140 135 * @param flags feature mask for the new buffer
universe@140 136 * @return a new buffer with the extracted content
universe@140 137 */
universe@62 138 #define ucx_buffer_clone(src,flags) \
universe@62 139 ucx_buffer_extract(src, 0, 0, flags)
universe@62 140
universe@140 141 /**
universe@140 142 * Moves the position of the buffer.
universe@140 143 *
universe@140 144 * The new position is relative to the <code>whence</code> argument.
universe@56 145 *
universe@140 146 * SEEK_SET marks the start of the buffer.
universe@140 147 * SEEK_CUR marks the current position.
universe@165 148 * SEEK_END marks the end of the buffer.
universe@165 149 *
universe@165 150 * With an offset of zero, this function sets the buffer position to zero
universe@165 151 * (SEEK_SET), the buffer size (SEEK_END) or leaves the buffer position
universe@165 152 * unchanged (SEEK_CUR).
universe@140 153 *
universe@140 154 * @param buffer
universe@140 155 * @param offset position offset relative to <code>whence</code>
universe@140 156 * @param whence one of SEEK_SET, SEEK_CUR or SEEK_END
universe@140 157 * @return 0 on success, non-zero if the position is invalid
universe@56 158 *
universe@56 159 */
universe@60 160 int ucx_buffer_seek(UcxBuffer *buffer, off_t offset, int whence);
universe@56 161
universe@140 162 /**
universe@140 163 * Clears the buffer by resetting the position and deleting the data.
universe@140 164 *
universe@140 165 * The data is deleted by a zeroing it with call to <code>memset()</code>.
universe@140 166 *
universe@140 167 * @param buffer the buffer to be cleared
universe@140 168 */
universe@140 169 #define ucx_buffer_clear(buffer) memset(buffer->space, 0, buffer->size); \
universe@140 170 buffer->size = 0; buffer->pos = 0;
universe@85 171
universe@140 172 /**
universe@140 173 * Tests, if the buffer position has exceeded the buffer capacity.
universe@140 174 *
universe@140 175 * @param buffer the buffer to test
universe@140 176 * @return non-zero, if the current buffer position has exceeded the last
universe@140 177 * available byte of the buffer.
universe@56 178 */
universe@60 179 int ucx_buffer_eof(UcxBuffer *buffer);
universe@56 180
olaf@76 181
universe@140 182 /**
universe@140 183 * Extends the capacity of the buffer.
universe@140 184 *
universe@140 185 * <b>Note:</b> The buffer capacity increased by a power of two. I.e.
universe@140 186 * the buffer capacity is doubled, as long as it would not hold the current
universe@140 187 * content plus the additional required bytes.
universe@140 188 *
universe@140 189 * <b>Attention:</b> the argument provided is the count of <i>additional</i>
universe@140 190 * bytes the buffer shall hold. It is <b>NOT</b> the total count of bytes the
universe@140 191 * buffer shall hold.
universe@140 192 *
universe@140 193 * @param buffer the buffer to extend
universe@140 194 * @param additional_bytes the count of additional bytes the buffer shall
universe@140 195 * <i>at least</i> hold
universe@140 196 * @return 0 on success or a non-zero value on failure
universe@140 197 */
universe@140 198 int ucx_buffer_extend(UcxBuffer *buffer, size_t additional_bytes);
olaf@76 199
universe@140 200 /**
universe@140 201 * Writes data to an UcxBuffer.
universe@140 202 *
universe@140 203 * The position of the buffer is increased by the number of bytes read.
universe@140 204 *
universe@140 205 * @param ptr a pointer to the memory area containing the bytes to be written
universe@140 206 * @param size the length of one element
universe@140 207 * @param nitems the element count
universe@140 208 * @param buffer the UcxBuffer to write to
universe@140 209 * @return the total count of bytes written
universe@140 210 */
olaf@76 211 size_t ucx_buffer_write(const void *ptr, size_t size, size_t nitems,
olaf@76 212 UcxBuffer *buffer);
olaf@76 213
universe@140 214 /**
universe@140 215 * Reads data from an UcxBuffer.
universe@140 216 *
universe@140 217 * The position of the buffer is increased by the number of bytes read.
universe@140 218 *
universe@140 219 * @param ptr a pointer to the memory area where to store the read data
universe@140 220 * @param size the length of one element
universe@140 221 * @param nitems the element count
universe@140 222 * @param buffer the UcxBuffer to read from
universe@166 223 * @return the total number of elements read
universe@140 224 */
olaf@76 225 size_t ucx_buffer_read(void *ptr, size_t size, size_t nitems,
olaf@76 226 UcxBuffer *buffer);
olaf@76 227
universe@140 228 /**
universe@140 229 * Writes a character to a buffer.
universe@140 230 *
universe@140 231 * The least significant byte of the argument is written to the buffer. If the
universe@140 232 * end of the buffer is reached and #UCX_BUFFER_AUTOEXTEND feature is enabled,
universe@140 233 * the buffer capacity is extended by ucx_buffer_extend(). If the feature is
universe@140 234 * disabled or buffer extension fails, <code>EOF</code> is returned.
universe@140 235 *
universe@140 236 * On successful write the position of the buffer is increased.
universe@140 237 *
universe@140 238 * @param buffer the buffer to write to
universe@140 239 * @param c the character to write as <code>int</code> value
universe@140 240 * @return the byte that has bean written as <code>int</code> value or
universe@140 241 * <code>EOF</code> when the end of the stream is reached and automatic
universe@140 242 * extension is not enabled or not possible
universe@140 243 */
universe@140 244 int ucx_buffer_putc(UcxBuffer *buffer, int c);
universe@56 245
universe@140 246 /**
universe@140 247 * Gets a character from a buffer.
universe@140 248 *
universe@140 249 * The current position of the buffer is increased after a successful read.
universe@140 250 *
universe@140 251 * @param buffer the buffer to read from
universe@140 252 * @return the character as <code>int</code> value or <code>EOF</code>, if the
universe@140 253 * end of the buffer is reached
universe@140 254 */
universe@140 255 int ucx_buffer_getc(UcxBuffer *buffer);
olaf@76 256
universe@140 257 /**
universe@140 258 * Writes a string to a buffer.
universe@140 259 *
universe@140 260 * @param buffer the buffer
universe@140 261 * @param str the string
universe@140 262 * @return the number of bytes written
olaf@76 263 */
universe@140 264 size_t ucx_buffer_puts(UcxBuffer *buffer, char *str);
olaf@86 265
universe@56 266 #ifdef __cplusplus
universe@56 267 }
universe@56 268 #endif
universe@56 269
olaf@120 270 #endif /* UCX_BUFFER_H */
universe@56 271

mercurial