src/ucx/buffer.h

Sat, 28 Oct 2017 15:43:51 +0200

author
Mike Becker <universe@uap-core.de>
date
Sat, 28 Oct 2017 15:43:51 +0200
changeset 259
2f5dea574a75
parent 251
fae240d633fc
child 289
a5eabd407774
permissions
-rw-r--r--

modules documentation

universe@103 1 /*
universe@103 2 * DO NOT ALTER OR REMOVE COPYRIGHT NOTICES OR THIS HEADER.
universe@103 3 *
universe@259 4 * Copyright 2017 Mike Becker, 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@259 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@169 100 * @param capacity the capacity of the buffer
universe@140 101 * @param flags buffer features (see UcxBuffer.flags)
universe@140 102 * @return the new buffer
universe@140 103 */
universe@169 104 UcxBuffer *ucx_buffer_new(void *space, size_t capacity, 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@168 123 * @param length the count of bytes to extract (must not be zero)
universe@140 124 * @param flags feature mask for the new buffer
universe@163 125 * @return a new buffer containing the extraction
universe@62 126 */
olaf@76 127 UcxBuffer* ucx_buffer_extract(UcxBuffer *src,
universe@62 128 size_t start, size_t length, int flags);
universe@140 129
universe@140 130 /**
universe@140 131 * A shorthand macro for the full extraction of the buffer.
universe@140 132 *
universe@140 133 * @param src the source buffer
universe@140 134 * @param flags feature mask for the new buffer
universe@140 135 * @return a new buffer with the extracted content
universe@140 136 */
universe@62 137 #define ucx_buffer_clone(src,flags) \
universe@168 138 ucx_buffer_extract(src, 0, (src)->capacity, flags)
universe@62 139
universe@140 140 /**
universe@140 141 * Moves the position of the buffer.
universe@140 142 *
universe@140 143 * The new position is relative to the <code>whence</code> argument.
universe@56 144 *
universe@140 145 * SEEK_SET marks the start of the buffer.
universe@140 146 * SEEK_CUR marks the current position.
universe@165 147 * SEEK_END marks the end of the buffer.
universe@165 148 *
universe@165 149 * With an offset of zero, this function sets the buffer position to zero
universe@165 150 * (SEEK_SET), the buffer size (SEEK_END) or leaves the buffer position
universe@165 151 * unchanged (SEEK_CUR).
universe@140 152 *
universe@140 153 * @param buffer
universe@140 154 * @param offset position offset relative to <code>whence</code>
universe@140 155 * @param whence one of SEEK_SET, SEEK_CUR or SEEK_END
universe@140 156 * @return 0 on success, non-zero if the position is invalid
universe@56 157 *
universe@56 158 */
universe@60 159 int ucx_buffer_seek(UcxBuffer *buffer, off_t offset, int whence);
universe@56 160
universe@140 161 /**
universe@140 162 * Clears the buffer by resetting the position and deleting the data.
universe@140 163 *
universe@140 164 * The data is deleted by a zeroing it with call to <code>memset()</code>.
universe@140 165 *
universe@140 166 * @param buffer the buffer to be cleared
universe@140 167 */
universe@140 168 #define ucx_buffer_clear(buffer) memset(buffer->space, 0, buffer->size); \
universe@140 169 buffer->size = 0; buffer->pos = 0;
universe@85 170
universe@140 171 /**
universe@140 172 * Tests, if the buffer position has exceeded the buffer capacity.
universe@140 173 *
universe@140 174 * @param buffer the buffer to test
universe@140 175 * @return non-zero, if the current buffer position has exceeded the last
universe@140 176 * available byte of the buffer.
universe@56 177 */
universe@60 178 int ucx_buffer_eof(UcxBuffer *buffer);
universe@56 179
olaf@76 180
universe@140 181 /**
universe@140 182 * Extends the capacity of the buffer.
universe@140 183 *
universe@140 184 * <b>Note:</b> The buffer capacity increased by a power of two. I.e.
universe@140 185 * the buffer capacity is doubled, as long as it would not hold the current
universe@140 186 * content plus the additional required bytes.
universe@140 187 *
universe@168 188 * <b>Attention:</b> the argument provided is the number of <i>additional</i>
universe@168 189 * bytes the buffer shall hold. It is <b>NOT</b> the total number of bytes the
universe@140 190 * buffer shall hold.
universe@140 191 *
universe@140 192 * @param buffer the buffer to extend
universe@168 193 * @param additional_bytes the number of additional bytes the buffer shall
universe@140 194 * <i>at least</i> hold
universe@140 195 * @return 0 on success or a non-zero value on failure
universe@140 196 */
universe@140 197 int ucx_buffer_extend(UcxBuffer *buffer, size_t additional_bytes);
olaf@76 198
universe@140 199 /**
universe@225 200 * Writes data to a UcxBuffer.
universe@140 201 *
universe@215 202 * The position of the buffer is increased by the number of bytes written.
universe@140 203 *
universe@140 204 * @param ptr a pointer to the memory area containing the bytes to be written
universe@140 205 * @param size the length of one element
universe@140 206 * @param nitems the element count
universe@140 207 * @param buffer the UcxBuffer to write to
universe@140 208 * @return the total count of bytes written
universe@140 209 */
olaf@76 210 size_t ucx_buffer_write(const void *ptr, size_t size, size_t nitems,
olaf@76 211 UcxBuffer *buffer);
olaf@76 212
universe@140 213 /**
universe@225 214 * Reads data from a UcxBuffer.
universe@140 215 *
universe@140 216 * The position of the buffer is increased by the number of bytes read.
universe@140 217 *
universe@140 218 * @param ptr a pointer to the memory area where to store the read data
universe@140 219 * @param size the length of one element
universe@140 220 * @param nitems the element count
universe@140 221 * @param buffer the UcxBuffer to read from
universe@166 222 * @return the total number of elements read
universe@140 223 */
olaf@76 224 size_t ucx_buffer_read(void *ptr, size_t size, size_t nitems,
olaf@76 225 UcxBuffer *buffer);
olaf@76 226
universe@140 227 /**
universe@140 228 * Writes a character to a buffer.
universe@140 229 *
universe@140 230 * The least significant byte of the argument is written to the buffer. If the
universe@140 231 * end of the buffer is reached and #UCX_BUFFER_AUTOEXTEND feature is enabled,
universe@140 232 * the buffer capacity is extended by ucx_buffer_extend(). If the feature is
universe@140 233 * disabled or buffer extension fails, <code>EOF</code> is returned.
universe@140 234 *
universe@140 235 * On successful write the position of the buffer is increased.
universe@140 236 *
universe@140 237 * @param buffer the buffer to write to
universe@140 238 * @param c the character to write as <code>int</code> value
universe@140 239 * @return the byte that has bean written as <code>int</code> value or
universe@140 240 * <code>EOF</code> when the end of the stream is reached and automatic
universe@140 241 * extension is not enabled or not possible
universe@140 242 */
universe@140 243 int ucx_buffer_putc(UcxBuffer *buffer, int c);
universe@56 244
universe@140 245 /**
universe@140 246 * Gets a character from a buffer.
universe@140 247 *
universe@140 248 * The current position of the buffer is increased after a successful read.
universe@140 249 *
universe@140 250 * @param buffer the buffer to read from
universe@140 251 * @return the character as <code>int</code> value or <code>EOF</code>, if the
universe@140 252 * end of the buffer is reached
universe@140 253 */
universe@140 254 int ucx_buffer_getc(UcxBuffer *buffer);
olaf@76 255
universe@140 256 /**
universe@140 257 * Writes a string to a buffer.
universe@140 258 *
universe@140 259 * @param buffer the buffer
universe@140 260 * @param str the string
universe@140 261 * @return the number of bytes written
olaf@76 262 */
universe@140 263 size_t ucx_buffer_puts(UcxBuffer *buffer, char *str);
olaf@86 264
universe@56 265 #ifdef __cplusplus
universe@56 266 }
universe@56 267 #endif
universe@56 268
olaf@120 269 #endif /* UCX_BUFFER_H */
universe@56 270

mercurial