src/cx/buffer.h

Sat, 30 Apr 2022 08:40:40 +0200

author
Mike Becker <universe@uap-core.de>
date
Sat, 30 Apr 2022 08:40:40 +0200
changeset 537
16219eba3a0a
parent 531
1b8624c8448e
child 539
9cd98da9ee17
permissions
-rw-r--r--

fix doc error for cxBufferWrite

universe@483 1 /*
universe@483 2 * DO NOT ALTER OR REMOVE COPYRIGHT NOTICES OR THIS HEADER.
universe@483 3 *
universe@483 4 * Copyright 2021 Mike Becker, Olaf Wintermann All rights reserved.
universe@483 5 *
universe@483 6 * Redistribution and use in source and binary forms, with or without
universe@483 7 * modification, are permitted provided that the following conditions are met:
universe@483 8 *
universe@483 9 * 1. Redistributions of source code must retain the above copyright
universe@483 10 * notice, this list of conditions and the following disclaimer.
universe@483 11 *
universe@483 12 * 2. Redistributions in binary form must reproduce the above copyright
universe@483 13 * notice, this list of conditions and the following disclaimer in the
universe@483 14 * documentation and/or other materials provided with the distribution.
universe@483 15 *
universe@483 16 * THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS "AS IS"
universe@483 17 * AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE
universe@483 18 * IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE
universe@483 19 * ARE DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT HOLDER OR CONTRIBUTORS BE
universe@483 20 * LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR
universe@483 21 * CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF
universe@483 22 * SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS
universe@483 23 * INTERRUPTION) HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN
universe@483 24 * CONTRACT, STRICT LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE)
universe@483 25 * ARISING IN ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE
universe@483 26 * POSSIBILITY OF SUCH DAMAGE.
universe@483 27 */
universe@483 28
universe@483 29 /**
universe@483 30 * \file buffer.h
universe@483 31 *
universe@483 32 * \brief Advanced buffer implementation.
universe@483 33 *
universe@483 34 * Instances of CxBuffer can be used to read from or to write to like one
universe@483 35 * would do with a stream.
universe@483 36 *
universe@483 37 * Some features for convenient use of the buffer
universe@483 38 * can be enabled. See the documentation of the macro constants for more
universe@483 39 * information.
universe@483 40 *
universe@483 41 * \author Mike Becker
universe@483 42 * \author Olaf Wintermann
universe@483 43 * \version 3.0
universe@483 44 * \copyright 2-Clause BSD License
universe@483 45 */
universe@483 46
universe@483 47 #ifndef UCX_BUFFER_H
universe@484 48 #define UCX_BUFFER_H
universe@483 49
universe@484 50 #include "common.h"
universe@501 51 #include "allocator.h"
universe@483 52
universe@483 53 #ifdef __cplusplus
universe@483 54 extern "C" {
universe@483 55 #endif
universe@483 56
universe@483 57 /**
universe@483 58 * No buffer features enabled (all flags cleared).
universe@483 59 */
universe@483 60 #define CX_BUFFER_DEFAULT 0x00
universe@483 61
universe@483 62 /**
universe@483 63 * If this flag is enabled, the buffer will automatically free its contents when destroyed.
universe@483 64 */
universe@483 65 #define CX_BUFFER_FREE_CONTENTS 0x01
universe@483 66
universe@483 67 /**
universe@483 68 * If this flag is enabled, the buffer will automatically extends its capacity.
universe@483 69 */
universe@483 70 #define CX_BUFFER_AUTO_EXTEND 0x02
universe@483 71
universe@483 72 /** Structure for the UCX buffer data. */
universe@483 73 typedef struct {
universe@483 74 /** A pointer to the buffer contents. */
universe@483 75 union {
universe@483 76 /**
universe@483 77 * Data is interpreted as text.
universe@483 78 */
universe@483 79 char *space;
universe@483 80 /**
universe@483 81 * Data is interpreted as binary.
universe@483 82 */
universe@483 83 unsigned char *bytes;
universe@483 84 };
universe@501 85 /** The allocator to use for automatic memory management. */
universe@529 86 CxAllocator const *allocator;
universe@483 87 /** Current position of the buffer. */
universe@483 88 size_t pos;
universe@483 89 /** Current capacity (i.e. maximum size) of the buffer. */
universe@483 90 size_t capacity;
universe@483 91 /** Current size of the buffer content. */
universe@483 92 size_t size;
universe@483 93 /**
universe@483 94 * Flag register for buffer features.
universe@485 95 * @see #CX_BUFFER_DEFAULT
universe@485 96 * @see #CX_BUFFER_FREE_CONTENTS
universe@485 97 * @see #CX_BUFFER_AUTO_EXTEND
universe@483 98 */
universe@483 99 int flags;
universe@483 100 } cx_buffer_s;
universe@483 101
universe@483 102 /**
universe@483 103 * UCX buffer.
universe@483 104 */
universe@500 105 typedef cx_buffer_s CxBuffer;
universe@483 106
universe@483 107 /**
universe@501 108 * Initializes a fresh buffer.
universe@483 109 *
universe@483 110 * \note You may provide \c NULL as argument for \p space.
universe@483 111 * Then this function will allocate the space and enforce
universe@483 112 * the #CX_BUFFER_FREE_CONTENTS flag.
universe@483 113 *
universe@501 114 * @param buffer the buffer to initialize
universe@501 115 * @param space pointer to the memory area, or \c NULL to allocate
universe@483 116 * new memory
universe@485 117 * @param capacity the capacity of the buffer
universe@501 118 * @param allocator the allocator this buffer shall use for automatic memory management
universe@485 119 * @param flags buffer features (see cx_buffer_s.flags)
universe@501 120 * @return zero on success, non-zero if a required allocation failed
universe@483 121 */
universe@529 122 __attribute__((__nonnull__(1, 4)))
universe@501 123 int cxBufferInit(
universe@501 124 CxBuffer *buffer,
universe@483 125 void *space,
universe@483 126 size_t capacity,
universe@529 127 CxAllocator const *allocator,
universe@483 128 int flags
universe@483 129 );
universe@483 130
universe@483 131 /**
universe@501 132 * Destroys the buffer contents.
universe@483 133 *
universe@501 134 * Has no effect if the #CX_BUFFER_FREE_CONTENTS feature is not enabled.
universe@483 135 *
universe@501 136 * @param buffer the buffer which contents shall be destroyed
universe@483 137 */
universe@529 138 __attribute__((__nonnull__))
universe@500 139 void cxBufferDestroy(CxBuffer *buffer);
universe@483 140
universe@483 141 /**
universe@483 142 * Shifts the contents of the buffer by the given offset.
universe@483 143 *
universe@483 144 * If the offset is positive, the contents are shifted to the right.
universe@483 145 * If auto extension is enabled, the buffer grows, if necessary.
universe@483 146 * In case the auto extension fails, this function returns a non-zero value and
universe@483 147 * no contents are changed.
universe@483 148 * If auto extension is disabled, the contents that do not fit into the buffer
universe@483 149 * are discarded.
universe@483 150 *
universe@483 151 * If the offset is negative, the contents are shifted to the left where the
universe@483 152 * first \p shift bytes are discarded.
universe@483 153 * The new size of the buffer is the old size minus the absolute shift value.
universe@483 154 * If this value is larger than the buffer size, the buffer is emptied (but
universe@483 155 * not cleared, see the security note below).
universe@483 156 *
universe@483 157 * The buffer position gets shifted alongside with the content but is kept
universe@483 158 * within the boundaries of the buffer.
universe@483 159 *
universe@483 160 * \note For situations where \c off_t is not large enough, there are specialized cxBufferShiftLeft() and
universe@483 161 * cxBufferShiftRight() functions using a \c size_t as parameter type.
universe@483 162 *
universe@485 163 * \attention
universe@485 164 * Security Note: The shifting operation does \em not erase the previously occupied memory cells.
universe@485 165 * But you can easily do that manually, e.g. by calling
universe@483 166 * <code>memset(buffer->bytes, 0, shift)</code> for a right shift or
universe@531 167 * <code>memset(buffer->bytes + buffer->size, 0, buffer->capacity - buffer->size)</code>
universe@483 168 * for a left shift.
universe@483 169 *
universe@485 170 * @param buffer the buffer
universe@485 171 * @param shift the shift offset (negative means left shift)
universe@485 172 * @return 0 on success, non-zero if a required auto-extension fails
universe@483 173 */
universe@529 174 __attribute__((__nonnull__))
universe@483 175 int cxBufferShift(
universe@500 176 CxBuffer *buffer,
universe@483 177 off_t shift
universe@483 178 );
universe@483 179
universe@483 180 /**
universe@483 181 * Shifts the buffer to the right.
universe@483 182 * See cxBufferShift() for details.
universe@483 183 *
universe@485 184 * @param buffer the buffer
universe@485 185 * @param shift the shift offset
universe@485 186 * @return 0 on success, non-zero if a required auto-extension fails
universe@485 187 * @see cxBufferShift()
universe@483 188 */
universe@529 189 __attribute__((__nonnull__))
universe@483 190 int cxBufferShiftRight(
universe@500 191 CxBuffer *buffer,
universe@483 192 size_t shift
universe@483 193 );
universe@483 194
universe@483 195 /**
universe@483 196 * Shifts the buffer to the left.
universe@483 197 * See cxBufferShift() for details.
universe@483 198 *
universe@483 199 * \note Since a left shift cannot fail due to memory allocation problems, this
universe@483 200 * function always returns zero.
universe@483 201 *
universe@485 202 * @param buffer the buffer
universe@485 203 * @param shift the positive shift offset
universe@485 204 * @return always zero
universe@485 205 * @see cxBufferShift()
universe@483 206 */
universe@529 207 __attribute__((__nonnull__))
universe@483 208 int cxBufferShiftLeft(
universe@500 209 CxBuffer *buffer,
universe@483 210 size_t shift
universe@483 211 );
universe@483 212
universe@483 213
universe@483 214 /**
universe@483 215 * Moves the position of the buffer.
universe@483 216 *
universe@483 217 * The new position is relative to the \p whence argument.
universe@483 218 *
universe@483 219 * \li \c SEEK_SET marks the start of the buffer.
universe@483 220 * \li \c SEEK_CUR marks the current position.
universe@483 221 * \li \c SEEK_END marks the end of the buffer.
universe@483 222 *
universe@483 223 * With an offset of zero, this function sets the buffer position to zero
universe@483 224 * (\c SEEK_SET), the buffer size (\c SEEK_END) or leaves the buffer position
universe@483 225 * unchanged (\c SEEK_CUR).
universe@483 226 *
universe@485 227 * @param buffer the buffer
universe@485 228 * @param offset position offset relative to \p whence
universe@485 229 * @param whence one of \c SEEK_SET, \c SEEK_CUR or \c SEEK_END
universe@485 230 * @return 0 on success, non-zero if the position is invalid
universe@483 231 *
universe@483 232 */
universe@529 233 __attribute__((__nonnull__))
universe@483 234 int cxBufferSeek(
universe@500 235 CxBuffer *buffer,
universe@483 236 off_t offset,
universe@483 237 int whence
universe@483 238 );
universe@483 239
universe@483 240 /**
universe@483 241 * Clears the buffer by resetting the position and deleting the data.
universe@483 242 *
universe@483 243 * The data is deleted by zeroing it with a call to memset().
universe@483 244 *
universe@485 245 * @param buffer the buffer to be cleared
universe@483 246 */
universe@529 247 __attribute__((__nonnull__))
universe@529 248 void cxBufferClear(CxBuffer *buffer);
universe@483 249
universe@483 250 /**
universe@483 251 * Tests, if the buffer position has exceeded the buffer capacity.
universe@483 252 *
universe@485 253 * @param buffer the buffer to test
universe@485 254 * @return non-zero, if the current buffer position has exceeded the last
universe@483 255 * available byte of the buffer.
universe@483 256 */
universe@529 257 __attribute__((__nonnull__))
universe@529 258 int cxBufferEof(CxBuffer const *buffer);
universe@483 259
universe@483 260
universe@483 261 /**
universe@483 262 * Ensures that the buffer has a minimum capacity.
universe@483 263 *
universe@483 264 * If the current capacity is not sufficient, the buffer will be extended.
universe@483 265 *
universe@485 266 * @param buffer the buffer
universe@485 267 * @param capacity the minimum required capacity for this buffer
universe@485 268 * @return 0 on success or a non-zero value on failure
universe@483 269 */
universe@529 270 __attribute__((__nonnull__))
universe@483 271 int cxBufferMinimumCapacity(
universe@500 272 CxBuffer *buffer,
universe@483 273 size_t capacity
universe@483 274 );
universe@483 275
universe@483 276 /**
universe@483 277 * Writes data to a CxBuffer.
universe@483 278 *
universe@483 279 * The position of the buffer is increased by the number of bytes written.
universe@483 280 *
universe@483 281 * \note The signature is compatible with the fwrite() family of functions.
universe@483 282 *
universe@485 283 * @param ptr a pointer to the memory area containing the bytes to be written
universe@485 284 * @param size the length of one element
universe@485 285 * @param nitems the element count
universe@485 286 * @param buffer the CxBuffer to write to
universe@537 287 * @return the total count of elements written
universe@483 288 */
universe@529 289 __attribute__((__nonnull__))
universe@483 290 size_t cxBufferWrite(
universe@489 291 void const *ptr,
universe@483 292 size_t size,
universe@483 293 size_t nitems,
universe@500 294 CxBuffer *buffer
universe@483 295 );
universe@483 296
universe@483 297 /**
universe@483 298 * Reads data from a CxBuffer.
universe@483 299 *
universe@483 300 * The position of the buffer is increased by the number of bytes read.
universe@483 301 *
universe@483 302 * \note The signature is compatible with the fread() family of functions.
universe@483 303 *
universe@485 304 * @param ptr a pointer to the memory area where to store the read data
universe@485 305 * @param size the length of one element
universe@485 306 * @param nitems the element count
universe@485 307 * @param buffer the CxBuffer to read from
universe@485 308 * @return the total number of elements read
universe@483 309 */
universe@529 310 __attribute__((__nonnull__))
universe@483 311 size_t cxBufferRead(
universe@483 312 void *ptr,
universe@483 313 size_t size,
universe@483 314 size_t nitems,
universe@500 315 CxBuffer *buffer
universe@483 316 );
universe@483 317
universe@483 318 /**
universe@483 319 * Writes a character to a buffer.
universe@483 320 *
universe@483 321 * The least significant byte of the argument is written to the buffer. If the
universe@483 322 * end of the buffer is reached and #CX_BUFFER_AUTO_EXTEND feature is enabled,
universe@483 323 * the buffer capacity is extended by cxBufferMinimumCapacity(). If the feature is
universe@483 324 * disabled or buffer extension fails, \c EOF is returned.
universe@483 325 *
universe@483 326 * On successful write, the position of the buffer is increased.
universe@483 327 *
universe@485 328 * @param buffer the buffer to write to
universe@485 329 * @param c the character to write
universe@485 330 * @return the byte that has bean written or \c EOF when the end of the stream is
universe@483 331 * reached and automatic extension is not enabled or not possible
universe@483 332 */
universe@529 333 __attribute__((__nonnull__))
universe@483 334 int cxBufferPut(
universe@500 335 CxBuffer *buffer,
universe@483 336 int c
universe@483 337 );
universe@483 338
universe@483 339 /**
universe@529 340 * Writes a string to a buffer.
universe@529 341 *
universe@529 342 * @param buffer the buffer
universe@529 343 * @param str the zero-terminated string
universe@529 344 * @return the number of bytes written
universe@529 345 */
universe@529 346 __attribute__((__nonnull__))
universe@529 347 size_t cxBufferPutString(
universe@529 348 CxBuffer *buffer,
universe@529 349 const char *str
universe@529 350 );
universe@529 351
universe@529 352 /**
universe@483 353 * Gets a character from a buffer.
universe@483 354 *
universe@483 355 * The current position of the buffer is increased after a successful read.
universe@483 356 *
universe@485 357 * @param buffer the buffer to read from
universe@485 358 * @return the character or \c EOF, if the end of the buffer is reached
universe@483 359 */
universe@529 360 __attribute__((__nonnull__))
universe@500 361 int cxBufferGet(CxBuffer *buffer);
universe@483 362
universe@483 363 #ifdef __cplusplus
universe@483 364 }
universe@483 365 #endif
universe@483 366
universe@483 367 #endif /* UCX_BUFFER_H */

mercurial