Mon, 26 May 2025 21:02:30 +0200
memset threadpool object
| 436 | 1 | /* |
| 2 | * DO NOT ALTER OR REMOVE COPYRIGHT NOTICES OR THIS HEADER. | |
| 3 | * | |
| 4 | * Copyright 2021 Mike Becker, Olaf Wintermann All rights reserved. | |
| 5 | * | |
| 6 | * Redistribution and use in source and binary forms, with or without | |
| 7 | * modification, are permitted provided that the following conditions are met: | |
| 8 | * | |
| 9 | * 1. Redistributions of source code must retain the above copyright | |
| 10 | * notice, this list of conditions and the following disclaimer. | |
| 11 | * | |
| 12 | * 2. Redistributions in binary form must reproduce the above copyright | |
| 13 | * notice, this list of conditions and the following disclaimer in the | |
| 14 | * documentation and/or other materials provided with the distribution. | |
| 15 | * | |
| 16 | * THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS "AS IS" | |
| 17 | * AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE | |
| 18 | * IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE | |
| 19 | * ARE DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT HOLDER OR CONTRIBUTORS BE | |
| 20 | * LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR | |
| 21 | * CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF | |
| 22 | * SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS | |
| 23 | * INTERRUPTION) HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN | |
| 24 | * CONTRACT, STRICT LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) | |
| 25 | * ARISING IN ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE | |
| 26 | * POSSIBILITY OF SUCH DAMAGE. | |
| 27 | */ | |
| 28 | ||
| 29 | #include "cx/array_list.h" | |
| 579 | 30 | #include "cx/compare.h" |
| 436 | 31 | #include <assert.h> |
| 32 | #include <string.h> | |
| 579 | 33 | #include <errno.h> |
| 34 | ||
| 35 | // Default array reallocator | |
| 36 | ||
| 37 | static void *cx_array_default_realloc( | |
| 38 | void *array, | |
| 39 | size_t capacity, | |
| 40 | size_t elem_size, | |
| 41 | cx_attr_unused CxArrayReallocator *alloc | |
| 42 | ) { | |
| 43 | size_t n; | |
| 44 | if (cx_szmul(capacity, elem_size, &n)) { | |
| 45 | errno = EOVERFLOW; | |
| 46 | return NULL; | |
| 47 | } | |
| 48 | return realloc(array, n); | |
| 49 | } | |
| 50 | ||
| 51 | CxArrayReallocator cx_array_default_reallocator_impl = { | |
| 52 | cx_array_default_realloc, NULL, NULL, 0, 0 | |
| 53 | }; | |
| 54 | ||
| 55 | CxArrayReallocator *cx_array_default_reallocator = &cx_array_default_reallocator_impl; | |
| 56 | ||
| 57 | // Stack-aware array reallocator | |
| 58 | ||
| 59 | static void *cx_array_advanced_realloc( | |
| 60 | void *array, | |
| 61 | size_t capacity, | |
| 62 | size_t elem_size, | |
| 63 | cx_attr_unused CxArrayReallocator *alloc | |
| 64 | ) { | |
| 65 | // check for overflow | |
| 66 | size_t n; | |
| 67 | if (cx_szmul(capacity, elem_size, &n)) { | |
| 68 | errno = EOVERFLOW; | |
| 69 | return NULL; | |
| 70 | } | |
| 71 | ||
| 72 | // retrieve the pointer to the actual allocator | |
| 73 | const CxAllocator *al = alloc->ptr1; | |
| 74 | ||
| 75 | // check if the array is still located on the stack | |
| 76 | void *newmem; | |
| 77 | if (array == alloc->ptr2) { | |
| 78 | newmem = cxMalloc(al, n); | |
| 79 | if (newmem != NULL && array != NULL) { | |
| 80 | memcpy(newmem, array, n); | |
| 81 | } | |
| 82 | } else { | |
| 83 | newmem = cxRealloc(al, array, n); | |
| 84 | } | |
| 85 | return newmem; | |
| 86 | } | |
| 87 | ||
| 88 | struct cx_array_reallocator_s cx_array_reallocator( | |
| 89 | const struct cx_allocator_s *allocator, | |
| 90 | const void *stackmem | |
| 91 | ) { | |
| 92 | if (allocator == NULL) { | |
| 93 | allocator = cxDefaultAllocator; | |
| 94 | } | |
| 95 | return (struct cx_array_reallocator_s) { | |
| 96 | cx_array_advanced_realloc, | |
| 97 | (void*) allocator, (void*) stackmem, | |
| 98 | 0, 0 | |
| 99 | }; | |
| 100 | } | |
| 436 | 101 | |
|
438
22eca559aded
refactore http listener creation
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
436
diff
changeset
|
102 | // LOW LEVEL ARRAY LIST FUNCTIONS |
| 436 | 103 | |
| 579 | 104 | static size_t cx_array_align_capacity( |
| 105 | size_t cap, | |
| 106 | size_t alignment, | |
| 107 | size_t max | |
| 108 | ) { | |
| 109 | if (cap > max - alignment) { | |
| 110 | return cap; | |
| 111 | } else { | |
| 112 | return cap - (cap % alignment) + alignment; | |
| 113 | } | |
| 114 | } | |
| 115 | ||
| 116 | int cx_array_reserve( | |
| 117 | void **array, | |
| 118 | void *size, | |
| 119 | void *capacity, | |
| 120 | unsigned width, | |
| 436 | 121 | size_t elem_size, |
| 122 | size_t elem_count, | |
| 579 | 123 | CxArrayReallocator *reallocator |
| 124 | ) { | |
| 125 | // assert pointers | |
| 126 | assert(array != NULL); | |
| 127 | assert(size != NULL); | |
| 128 | assert(capacity != NULL); | |
| 129 | ||
| 130 | // default reallocator | |
| 131 | if (reallocator == NULL) { | |
| 132 | reallocator = cx_array_default_reallocator; | |
| 133 | } | |
| 134 | ||
| 135 | // determine size and capacity | |
| 136 | size_t oldcap; | |
| 137 | size_t oldsize; | |
| 138 | size_t max_size; | |
| 139 | if (width == 0 || width == sizeof(size_t)) { | |
| 140 | oldcap = *(size_t*) capacity; | |
| 141 | oldsize = *(size_t*) size; | |
| 142 | max_size = SIZE_MAX; | |
| 143 | } else if (width == sizeof(uint16_t)) { | |
| 144 | oldcap = *(uint16_t*) capacity; | |
| 145 | oldsize = *(uint16_t*) size; | |
| 146 | max_size = UINT16_MAX; | |
| 147 | } else if (width == sizeof(uint8_t)) { | |
| 148 | oldcap = *(uint8_t*) capacity; | |
| 149 | oldsize = *(uint8_t*) size; | |
| 150 | max_size = UINT8_MAX; | |
| 151 | } | |
| 152 | #if CX_WORDSIZE == 64 | |
| 153 | else if (width == sizeof(uint32_t)) { | |
| 154 | oldcap = *(uint32_t*) capacity; | |
| 155 | oldsize = *(uint32_t*) size; | |
| 156 | max_size = UINT32_MAX; | |
| 157 | } | |
| 158 | #endif | |
| 159 | else { | |
| 160 | errno = EINVAL; | |
| 161 | return 1; | |
| 162 | } | |
| 163 | ||
| 164 | // assert that the array is allocated when it has capacity | |
| 165 | assert(*array != NULL || oldcap == 0); | |
| 166 | ||
| 167 | // check for overflow | |
| 168 | if (elem_count > max_size - oldsize) { | |
| 169 | errno = EOVERFLOW; | |
| 170 | return 1; | |
| 171 | } | |
| 172 | ||
| 173 | // determine new capacity | |
| 174 | size_t newcap = oldsize + elem_count; | |
| 175 | ||
| 176 | // reallocate if possible | |
| 177 | if (newcap > oldcap) { | |
| 178 | // calculate new capacity (next number divisible by 16) | |
| 179 | newcap = cx_array_align_capacity(newcap, 16, max_size); | |
| 180 | ||
| 181 | // perform reallocation | |
| 182 | void *newmem = reallocator->realloc( | |
| 183 | *array, newcap, elem_size, reallocator | |
| 184 | ); | |
| 185 | if (newmem == NULL) { | |
| 186 | return 1; // LCOV_EXCL_LINE | |
| 187 | } | |
| 188 | ||
| 189 | // store new pointer | |
| 190 | *array = newmem; | |
| 191 | ||
| 192 | // store new capacity | |
| 193 | if (width == 0 || width == sizeof(size_t)) { | |
| 194 | *(size_t*) capacity = newcap; | |
| 195 | } else if (width == sizeof(uint16_t)) { | |
| 196 | *(uint16_t*) capacity = (uint16_t) newcap; | |
| 197 | } else if (width == sizeof(uint8_t)) { | |
| 198 | *(uint8_t*) capacity = (uint8_t) newcap; | |
| 199 | } | |
| 200 | #if CX_WORDSIZE == 64 | |
| 201 | else if (width == sizeof(uint32_t)) { | |
| 202 | *(uint32_t*) capacity = (uint32_t) newcap; | |
| 203 | } | |
| 204 | #endif | |
| 205 | } | |
| 206 | ||
| 207 | return 0; | |
| 208 | } | |
| 209 | ||
| 210 | int cx_array_copy( | |
| 211 | void **target, | |
| 212 | void *size, | |
| 213 | void *capacity, | |
| 214 | unsigned width, | |
| 215 | size_t index, | |
| 216 | const void *src, | |
| 217 | size_t elem_size, | |
| 218 | size_t elem_count, | |
| 219 | CxArrayReallocator *reallocator | |
| 436 | 220 | ) { |
|
438
22eca559aded
refactore http listener creation
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
436
diff
changeset
|
221 | // assert pointers |
| 436 | 222 | assert(target != NULL); |
| 223 | assert(size != NULL); | |
| 579 | 224 | assert(capacity != NULL); |
| 436 | 225 | assert(src != NULL); |
| 226 | ||
| 579 | 227 | // default reallocator |
| 228 | if (reallocator == NULL) { | |
| 229 | reallocator = cx_array_default_reallocator; | |
| 230 | } | |
| 231 | ||
| 232 | // determine size and capacity | |
| 233 | size_t oldcap; | |
| 234 | size_t oldsize; | |
| 235 | size_t max_size; | |
| 236 | if (width == 0 || width == sizeof(size_t)) { | |
| 237 | oldcap = *(size_t*) capacity; | |
| 238 | oldsize = *(size_t*) size; | |
| 239 | max_size = SIZE_MAX; | |
| 240 | } else if (width == sizeof(uint16_t)) { | |
| 241 | oldcap = *(uint16_t*) capacity; | |
| 242 | oldsize = *(uint16_t*) size; | |
| 243 | max_size = UINT16_MAX; | |
| 244 | } else if (width == sizeof(uint8_t)) { | |
| 245 | oldcap = *(uint8_t*) capacity; | |
| 246 | oldsize = *(uint8_t*) size; | |
| 247 | max_size = UINT8_MAX; | |
| 248 | } | |
| 249 | #if CX_WORDSIZE == 64 | |
| 250 | else if (width == sizeof(uint32_t)) { | |
| 251 | oldcap = *(uint32_t*) capacity; | |
| 252 | oldsize = *(uint32_t*) size; | |
| 253 | max_size = UINT32_MAX; | |
| 254 | } | |
| 255 | #endif | |
| 256 | else { | |
| 257 | errno = EINVAL; | |
| 258 | return 1; | |
| 259 | } | |
| 260 | ||
| 261 | // assert that the array is allocated when it has capacity | |
| 262 | assert(*target != NULL || oldcap == 0); | |
| 263 | ||
| 264 | // check for overflow | |
| 265 | if (index > max_size || elem_count > max_size - index) { | |
| 266 | errno = EOVERFLOW; | |
| 267 | return 1; | |
| 268 | } | |
| 436 | 269 | |
|
438
22eca559aded
refactore http listener creation
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
436
diff
changeset
|
270 | // check if resize is required |
|
22eca559aded
refactore http listener creation
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
436
diff
changeset
|
271 | size_t minsize = index + elem_count; |
| 579 | 272 | size_t newsize = oldsize < minsize ? minsize : oldsize; |
| 436 | 273 | |
|
438
22eca559aded
refactore http listener creation
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
436
diff
changeset
|
274 | // reallocate if possible |
| 579 | 275 | size_t newcap = oldcap; |
| 276 | if (newsize > oldcap) { | |
|
438
22eca559aded
refactore http listener creation
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
436
diff
changeset
|
277 | // check, if we need to repair the src pointer |
| 436 | 278 | uintptr_t targetaddr = (uintptr_t) *target; |
| 279 | uintptr_t srcaddr = (uintptr_t) src; | |
| 280 | bool repairsrc = targetaddr <= srcaddr | |
| 579 | 281 | && srcaddr < targetaddr + oldcap * elem_size; |
| 436 | 282 | |
|
438
22eca559aded
refactore http listener creation
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
436
diff
changeset
|
283 | // calculate new capacity (next number divisible by 16) |
| 579 | 284 | newcap = cx_array_align_capacity(newsize, 16, max_size); |
| 285 | assert(newcap > newsize); | |
| 436 | 286 | |
|
438
22eca559aded
refactore http listener creation
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
436
diff
changeset
|
287 | // perform reallocation |
| 436 | 288 | void *newmem = reallocator->realloc( |
| 579 | 289 | *target, newcap, elem_size, reallocator |
| 436 | 290 | ); |
| 291 | if (newmem == NULL) { | |
| 579 | 292 | return 1; |
| 436 | 293 | } |
| 294 | ||
|
438
22eca559aded
refactore http listener creation
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
436
diff
changeset
|
295 | // repair src pointer, if necessary |
| 436 | 296 | if (repairsrc) { |
| 297 | src = ((char *) newmem) + (srcaddr - targetaddr); | |
| 298 | } | |
| 299 | ||
| 579 | 300 | // store new pointer |
| 436 | 301 | *target = newmem; |
| 302 | } | |
| 303 | ||
|
438
22eca559aded
refactore http listener creation
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
436
diff
changeset
|
304 | // determine target pointer |
| 436 | 305 | char *start = *target; |
| 306 | start += index * elem_size; | |
| 307 | ||
|
438
22eca559aded
refactore http listener creation
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
436
diff
changeset
|
308 | // copy elements and set new size |
| 579 | 309 | // note: no overflow check here, b/c we cannot get here w/o allocation |
| 436 | 310 | memmove(start, src, elem_count * elem_size); |
| 579 | 311 | |
| 312 | // if any of size or capacity changed, store them back | |
| 313 | if (newsize != oldsize || newcap != oldcap) { | |
| 314 | if (width == 0 || width == sizeof(size_t)) { | |
| 315 | *(size_t*) capacity = newcap; | |
| 316 | *(size_t*) size = newsize; | |
| 317 | } else if (width == sizeof(uint16_t)) { | |
| 318 | *(uint16_t*) capacity = (uint16_t) newcap; | |
| 319 | *(uint16_t*) size = (uint16_t) newsize; | |
| 320 | } else if (width == sizeof(uint8_t)) { | |
| 321 | *(uint8_t*) capacity = (uint8_t) newcap; | |
| 322 | *(uint8_t*) size = (uint8_t) newsize; | |
| 323 | } | |
| 324 | #if CX_WORDSIZE == 64 | |
| 325 | else if (width == sizeof(uint32_t)) { | |
| 326 | *(uint32_t*) capacity = (uint32_t) newcap; | |
| 327 | *(uint32_t*) size = (uint32_t) newsize; | |
| 328 | } | |
| 329 | #endif | |
| 330 | } | |
| 436 | 331 | |
|
438
22eca559aded
refactore http listener creation
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
436
diff
changeset
|
332 | // return successfully |
| 579 | 333 | return 0; |
| 334 | } | |
| 335 | ||
| 336 | int cx_array_insert_sorted( | |
| 337 | void **target, | |
| 338 | size_t *size, | |
| 339 | size_t *capacity, | |
| 340 | cx_compare_func cmp_func, | |
| 341 | const void *sorted_data, | |
| 342 | size_t elem_size, | |
| 343 | size_t elem_count, | |
| 344 | CxArrayReallocator *reallocator | |
| 345 | ) { | |
| 346 | // assert pointers | |
| 347 | assert(target != NULL); | |
| 348 | assert(size != NULL); | |
| 349 | assert(capacity != NULL); | |
| 350 | assert(cmp_func != NULL); | |
| 351 | assert(sorted_data != NULL); | |
| 352 | ||
| 353 | // default reallocator | |
| 354 | if (reallocator == NULL) { | |
| 355 | reallocator = cx_array_default_reallocator; | |
| 356 | } | |
| 357 | ||
| 358 | // corner case | |
| 359 | if (elem_count == 0) return 0; | |
| 360 | ||
| 361 | // overflow check | |
| 362 | if (elem_count > SIZE_MAX - *size) { | |
| 363 | errno = EOVERFLOW; | |
| 364 | return 1; | |
| 365 | } | |
| 366 | ||
| 367 | // store some counts | |
| 368 | size_t old_size = *size; | |
| 369 | size_t needed_capacity = old_size + elem_count; | |
| 370 | ||
| 371 | // if we need more than we have, try a reallocation | |
| 372 | if (needed_capacity > *capacity) { | |
| 373 | size_t new_capacity = cx_array_align_capacity(needed_capacity, 16, SIZE_MAX); | |
| 374 | void *new_mem = reallocator->realloc( | |
| 375 | *target, new_capacity, elem_size, reallocator | |
| 376 | ); | |
| 377 | if (new_mem == NULL) { | |
| 378 | // give it up right away, there is no contract | |
| 379 | // that requires us to insert as much as we can | |
| 380 | return 1; // LCOV_EXCL_LINE | |
| 381 | } | |
| 382 | *target = new_mem; | |
| 383 | *capacity = new_capacity; | |
| 384 | } | |
| 385 | ||
| 386 | // now we have guaranteed that we can insert everything | |
| 387 | size_t new_size = old_size + elem_count; | |
| 388 | *size = new_size; | |
| 389 | ||
| 390 | // declare the source and destination indices/pointers | |
| 391 | size_t si = 0, di = 0; | |
| 392 | const char *src = sorted_data; | |
| 393 | char *dest = *target; | |
| 394 | ||
| 395 | // find the first insertion point | |
| 396 | di = cx_array_binary_search_sup(dest, old_size, elem_size, src, cmp_func); | |
| 397 | dest += di * elem_size; | |
| 398 | ||
| 399 | // move the remaining elements in the array completely to the right | |
| 400 | // we will call it the "buffer" for parked elements | |
| 401 | size_t buf_size = old_size - di; | |
| 402 | size_t bi = new_size - buf_size; | |
| 403 | char *bptr = ((char *) *target) + bi * elem_size; | |
| 404 | memmove(bptr, dest, buf_size * elem_size); | |
| 405 | ||
| 406 | // while there are both source and buffered elements left, | |
| 407 | // copy them interleaving | |
| 408 | while (si < elem_count && bi < new_size) { | |
| 409 | // determine how many source elements can be inserted | |
| 410 | size_t copy_len, bytes_copied; | |
| 411 | copy_len = cx_array_binary_search_sup( | |
| 412 | src, | |
| 413 | elem_count - si, | |
| 414 | elem_size, | |
| 415 | bptr, | |
| 416 | cmp_func | |
| 417 | ); | |
| 418 | ||
| 419 | // copy the source elements | |
| 420 | bytes_copied = copy_len * elem_size; | |
| 421 | memcpy(dest, src, bytes_copied); | |
| 422 | dest += bytes_copied; | |
| 423 | src += bytes_copied; | |
| 424 | si += copy_len; | |
| 425 | ||
| 426 | // when all source elements are in place, we are done | |
| 427 | if (si >= elem_count) break; | |
| 428 | ||
| 429 | // determine how many buffered elements need to be restored | |
| 430 | copy_len = cx_array_binary_search_sup( | |
| 431 | bptr, | |
| 432 | new_size - bi, | |
| 433 | elem_size, | |
| 434 | src, | |
| 435 | cmp_func | |
| 436 | ); | |
| 437 | ||
| 438 | // restore the buffered elements | |
| 439 | bytes_copied = copy_len * elem_size; | |
| 440 | memmove(dest, bptr, bytes_copied); | |
| 441 | dest += bytes_copied; | |
| 442 | bptr += bytes_copied; | |
| 443 | bi += copy_len; | |
| 444 | } | |
| 445 | ||
| 446 | // still source elements left? simply append them | |
| 447 | if (si < elem_count) { | |
| 448 | memcpy(dest, src, elem_size * (elem_count - si)); | |
| 449 | } | |
| 450 | ||
| 451 | // still buffer elements left? | |
| 452 | // don't worry, we already moved them to the correct place | |
| 453 | ||
| 454 | return 0; | |
| 455 | } | |
| 456 | ||
| 457 | size_t cx_array_binary_search_inf( | |
| 458 | const void *arr, | |
| 459 | size_t size, | |
| 460 | size_t elem_size, | |
| 461 | const void *elem, | |
| 462 | cx_compare_func cmp_func | |
| 463 | ) { | |
| 464 | // special case: empty array | |
| 465 | if (size == 0) return 0; | |
| 466 | ||
| 467 | // declare a variable that will contain the compare results | |
| 468 | int result; | |
| 469 | ||
| 470 | // cast the array pointer to something we can use offsets with | |
| 471 | const char *array = arr; | |
| 472 | ||
| 473 | // check the first array element | |
| 474 | result = cmp_func(elem, array); | |
| 475 | if (result < 0) { | |
| 476 | return size; | |
| 477 | } else if (result == 0) { | |
| 478 | return 0; | |
| 479 | } | |
| 480 | ||
| 481 | // special case: there is only one element and that is smaller | |
| 482 | if (size == 1) return 0; | |
| 483 | ||
| 484 | // check the last array element | |
| 485 | result = cmp_func(elem, array + elem_size * (size - 1)); | |
| 486 | if (result >= 0) { | |
| 487 | return size - 1; | |
| 488 | } | |
| 489 | ||
| 490 | // the element is now guaranteed to be somewhere in the list | |
| 491 | // so start the binary search | |
| 492 | size_t left_index = 1; | |
| 493 | size_t right_index = size - 1; | |
| 494 | size_t pivot_index; | |
| 495 | ||
| 496 | while (left_index <= right_index) { | |
| 497 | pivot_index = left_index + (right_index - left_index) / 2; | |
| 498 | const char *arr_elem = array + pivot_index * elem_size; | |
| 499 | result = cmp_func(elem, arr_elem); | |
| 500 | if (result == 0) { | |
| 501 | // found it! | |
| 502 | return pivot_index; | |
| 503 | } else if (result < 0) { | |
| 504 | // element is smaller than pivot, continue search left | |
| 505 | right_index = pivot_index - 1; | |
| 506 | } else { | |
| 507 | // element is larger than pivot, continue search right | |
| 508 | left_index = pivot_index + 1; | |
| 509 | } | |
| 510 | } | |
| 511 | ||
| 512 | // report the largest upper bound | |
| 513 | return result < 0 ? (pivot_index - 1) : pivot_index; | |
| 514 | } | |
| 515 | ||
| 516 | size_t cx_array_binary_search( | |
| 517 | const void *arr, | |
| 518 | size_t size, | |
| 519 | size_t elem_size, | |
| 520 | const void *elem, | |
| 521 | cx_compare_func cmp_func | |
| 522 | ) { | |
| 523 | size_t index = cx_array_binary_search_inf( | |
| 524 | arr, size, elem_size, elem, cmp_func | |
| 525 | ); | |
| 526 | if (index < size && | |
| 527 | cmp_func(((const char *) arr) + index * elem_size, elem) == 0) { | |
| 528 | return index; | |
| 529 | } else { | |
| 530 | return size; | |
| 531 | } | |
| 532 | } | |
| 533 | ||
| 534 | size_t cx_array_binary_search_sup( | |
| 535 | const void *arr, | |
| 536 | size_t size, | |
| 537 | size_t elem_size, | |
| 538 | const void *elem, | |
| 539 | cx_compare_func cmp_func | |
| 540 | ) { | |
| 541 | size_t inf = cx_array_binary_search_inf( | |
| 542 | arr, size, elem_size, elem, cmp_func | |
| 543 | ); | |
| 544 | if (inf == size) { | |
| 545 | // no infimum means, first element is supremum | |
| 546 | return 0; | |
| 547 | } else if (cmp_func(((const char *) arr) + inf * elem_size, elem) == 0) { | |
| 548 | return inf; | |
| 549 | } else { | |
| 550 | return inf + 1; | |
| 551 | } | |
| 436 | 552 | } |
| 553 | ||
| 490 | 554 | #ifndef CX_ARRAY_SWAP_SBO_SIZE |
| 504 | 555 | #define CX_ARRAY_SWAP_SBO_SIZE 128 |
| 490 | 556 | #endif |
| 579 | 557 | const unsigned cx_array_swap_sbo_size = CX_ARRAY_SWAP_SBO_SIZE; |
|
438
22eca559aded
refactore http listener creation
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
436
diff
changeset
|
558 | |
|
22eca559aded
refactore http listener creation
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
436
diff
changeset
|
559 | void cx_array_swap( |
|
22eca559aded
refactore http listener creation
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
436
diff
changeset
|
560 | void *arr, |
|
22eca559aded
refactore http listener creation
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
436
diff
changeset
|
561 | size_t elem_size, |
|
22eca559aded
refactore http listener creation
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
436
diff
changeset
|
562 | size_t idx1, |
|
22eca559aded
refactore http listener creation
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
436
diff
changeset
|
563 | size_t idx2 |
|
22eca559aded
refactore http listener creation
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
436
diff
changeset
|
564 | ) { |
| 490 | 565 | assert(arr != NULL); |
| 566 | ||
|
438
22eca559aded
refactore http listener creation
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
436
diff
changeset
|
567 | // short circuit |
|
22eca559aded
refactore http listener creation
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
436
diff
changeset
|
568 | if (idx1 == idx2) return; |
|
22eca559aded
refactore http listener creation
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
436
diff
changeset
|
569 | |
|
22eca559aded
refactore http listener creation
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
436
diff
changeset
|
570 | char sbo_mem[CX_ARRAY_SWAP_SBO_SIZE]; |
|
22eca559aded
refactore http listener creation
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
436
diff
changeset
|
571 | void *tmp; |
|
22eca559aded
refactore http listener creation
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
436
diff
changeset
|
572 | |
|
22eca559aded
refactore http listener creation
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
436
diff
changeset
|
573 | // decide if we can use the local buffer |
|
22eca559aded
refactore http listener creation
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
436
diff
changeset
|
574 | if (elem_size > CX_ARRAY_SWAP_SBO_SIZE) { |
|
22eca559aded
refactore http listener creation
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
436
diff
changeset
|
575 | tmp = malloc(elem_size); |
|
22eca559aded
refactore http listener creation
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
436
diff
changeset
|
576 | // we don't want to enforce error handling |
|
22eca559aded
refactore http listener creation
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
436
diff
changeset
|
577 | if (tmp == NULL) abort(); |
|
22eca559aded
refactore http listener creation
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
436
diff
changeset
|
578 | } else { |
|
22eca559aded
refactore http listener creation
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
436
diff
changeset
|
579 | tmp = sbo_mem; |
|
22eca559aded
refactore http listener creation
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
436
diff
changeset
|
580 | } |
|
22eca559aded
refactore http listener creation
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
436
diff
changeset
|
581 | |
|
22eca559aded
refactore http listener creation
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
436
diff
changeset
|
582 | // calculate memory locations |
|
22eca559aded
refactore http listener creation
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
436
diff
changeset
|
583 | char *left = arr, *right = arr; |
|
22eca559aded
refactore http listener creation
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
436
diff
changeset
|
584 | left += idx1 * elem_size; |
|
22eca559aded
refactore http listener creation
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
436
diff
changeset
|
585 | right += idx2 * elem_size; |
|
22eca559aded
refactore http listener creation
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
436
diff
changeset
|
586 | |
|
22eca559aded
refactore http listener creation
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
436
diff
changeset
|
587 | // three-way swap |
|
22eca559aded
refactore http listener creation
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
436
diff
changeset
|
588 | memcpy(tmp, left, elem_size); |
|
22eca559aded
refactore http listener creation
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
436
diff
changeset
|
589 | memcpy(left, right, elem_size); |
|
22eca559aded
refactore http listener creation
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
436
diff
changeset
|
590 | memcpy(right, tmp, elem_size); |
|
22eca559aded
refactore http listener creation
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
436
diff
changeset
|
591 | |
|
22eca559aded
refactore http listener creation
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
436
diff
changeset
|
592 | // free dynamic memory, if it was needed |
|
22eca559aded
refactore http listener creation
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
436
diff
changeset
|
593 | if (tmp != sbo_mem) { |
|
22eca559aded
refactore http listener creation
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
436
diff
changeset
|
594 | free(tmp); |
|
22eca559aded
refactore http listener creation
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
436
diff
changeset
|
595 | } |
|
22eca559aded
refactore http listener creation
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
436
diff
changeset
|
596 | } |
|
22eca559aded
refactore http listener creation
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
436
diff
changeset
|
597 | |
|
22eca559aded
refactore http listener creation
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
436
diff
changeset
|
598 | // HIGH LEVEL ARRAY LIST FUNCTIONS |
| 436 | 599 | |
| 600 | typedef struct { | |
| 601 | struct cx_list_s base; | |
| 602 | void *data; | |
| 490 | 603 | size_t capacity; |
| 579 | 604 | CxArrayReallocator reallocator; |
| 436 | 605 | } cx_array_list; |
| 606 | ||
| 607 | static void cx_arl_destructor(struct cx_list_s *list) { | |
| 608 | cx_array_list *arl = (cx_array_list *) list; | |
| 504 | 609 | |
| 610 | char *ptr = arl->data; | |
| 611 | ||
| 579 | 612 | if (list->collection.simple_destructor) { |
| 613 | for (size_t i = 0; i < list->collection.size; i++) { | |
| 504 | 614 | cx_invoke_simple_destructor(list, ptr); |
| 579 | 615 | ptr += list->collection.elem_size; |
| 504 | 616 | } |
| 617 | } | |
| 579 | 618 | if (list->collection.advanced_destructor) { |
| 619 | for (size_t i = 0; i < list->collection.size; i++) { | |
| 504 | 620 | cx_invoke_advanced_destructor(list, ptr); |
| 579 | 621 | ptr += list->collection.elem_size; |
| 504 | 622 | } |
| 623 | } | |
| 624 | ||
| 579 | 625 | cxFree(list->collection.allocator, arl->data); |
| 626 | cxFree(list->collection.allocator, list); | |
| 436 | 627 | } |
| 628 | ||
| 490 | 629 | static size_t cx_arl_insert_array( |
| 436 | 630 | struct cx_list_s *list, |
| 490 | 631 | size_t index, |
| 579 | 632 | const void *array, |
|
438
22eca559aded
refactore http listener creation
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
436
diff
changeset
|
633 | size_t n |
|
22eca559aded
refactore http listener creation
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
436
diff
changeset
|
634 | ) { |
| 490 | 635 | // out of bounds and special case check |
| 579 | 636 | if (index > list->collection.size || n == 0) return 0; |
| 490 | 637 | |
| 638 | // get a correctly typed pointer to the list | |
|
438
22eca559aded
refactore http listener creation
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
436
diff
changeset
|
639 | cx_array_list *arl = (cx_array_list *) list; |
| 490 | 640 | |
| 641 | // do we need to move some elements? | |
| 579 | 642 | if (index < list->collection.size) { |
| 643 | const char *first_to_move = (const char *) arl->data; | |
| 644 | first_to_move += index * list->collection.elem_size; | |
| 645 | size_t elems_to_move = list->collection.size - index; | |
| 490 | 646 | size_t start_of_moved = index + n; |
| 647 | ||
| 579 | 648 | if (cx_array_copy( |
| 490 | 649 | &arl->data, |
| 579 | 650 | &list->collection.size, |
| 490 | 651 | &arl->capacity, |
| 579 | 652 | 0, |
| 490 | 653 | start_of_moved, |
| 654 | first_to_move, | |
| 579 | 655 | list->collection.elem_size, |
| 490 | 656 | elems_to_move, |
| 657 | &arl->reallocator | |
| 658 | )) { | |
| 659 | // if moving existing elems is unsuccessful, abort | |
| 660 | return 0; | |
| 661 | } | |
| 662 | } | |
| 663 | ||
| 664 | // note that if we had to move the elements, the following operation | |
| 665 | // is guaranteed to succeed, because we have the memory already allocated | |
| 666 | // therefore, it is impossible to leave this function with an invalid array | |
| 667 | ||
| 668 | // place the new elements | |
| 579 | 669 | if (cx_array_copy( |
|
438
22eca559aded
refactore http listener creation
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
436
diff
changeset
|
670 | &arl->data, |
| 579 | 671 | &list->collection.size, |
| 490 | 672 | &arl->capacity, |
| 579 | 673 | 0, |
| 490 | 674 | index, |
|
438
22eca559aded
refactore http listener creation
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
436
diff
changeset
|
675 | array, |
| 579 | 676 | list->collection.elem_size, |
|
438
22eca559aded
refactore http listener creation
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
436
diff
changeset
|
677 | n, |
|
22eca559aded
refactore http listener creation
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
436
diff
changeset
|
678 | &arl->reallocator |
|
22eca559aded
refactore http listener creation
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
436
diff
changeset
|
679 | )) { |
|
22eca559aded
refactore http listener creation
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
436
diff
changeset
|
680 | // array list implementation is "all or nothing" |
|
22eca559aded
refactore http listener creation
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
436
diff
changeset
|
681 | return 0; |
| 579 | 682 | } else { |
| 683 | return n; | |
| 684 | } | |
| 685 | } | |
| 686 | ||
| 687 | static size_t cx_arl_insert_sorted( | |
| 688 | struct cx_list_s *list, | |
| 689 | const void *sorted_data, | |
| 690 | size_t n | |
| 691 | ) { | |
| 692 | // get a correctly typed pointer to the list | |
| 693 | cx_array_list *arl = (cx_array_list *) list; | |
| 694 | ||
| 695 | if (cx_array_insert_sorted( | |
| 696 | &arl->data, | |
| 697 | &list->collection.size, | |
| 698 | &arl->capacity, | |
| 699 | list->collection.cmpfunc, | |
| 700 | sorted_data, | |
| 701 | list->collection.elem_size, | |
| 702 | n, | |
| 703 | &arl->reallocator | |
| 704 | )) { | |
| 705 | // array list implementation is "all or nothing" | |
| 706 | return 0; | |
| 707 | } else { | |
| 708 | return n; | |
|
438
22eca559aded
refactore http listener creation
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
436
diff
changeset
|
709 | } |
|
22eca559aded
refactore http listener creation
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
436
diff
changeset
|
710 | } |
|
22eca559aded
refactore http listener creation
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
436
diff
changeset
|
711 | |
| 490 | 712 | static int cx_arl_insert_element( |
| 436 | 713 | struct cx_list_s *list, |
| 714 | size_t index, | |
| 579 | 715 | const void *element |
| 436 | 716 | ) { |
| 490 | 717 | return 1 != cx_arl_insert_array(list, index, element, 1); |
| 436 | 718 | } |
| 719 | ||
| 720 | static int cx_arl_insert_iter( | |
| 579 | 721 | struct cx_iterator_s *iter, |
| 722 | const void *elem, | |
| 436 | 723 | int prepend |
| 724 | ) { | |
| 579 | 725 | struct cx_list_s *list = iter->src_handle.m; |
| 726 | if (iter->index < list->collection.size) { | |
| 490 | 727 | int result = cx_arl_insert_element( |
|
438
22eca559aded
refactore http listener creation
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
436
diff
changeset
|
728 | list, |
|
22eca559aded
refactore http listener creation
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
436
diff
changeset
|
729 | iter->index + 1 - prepend, |
|
22eca559aded
refactore http listener creation
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
436
diff
changeset
|
730 | elem |
|
22eca559aded
refactore http listener creation
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
436
diff
changeset
|
731 | ); |
| 579 | 732 | if (result == 0) { |
| 733 | iter->elem_count++; | |
| 734 | if (prepend != 0) { | |
| 735 | iter->index++; | |
| 736 | iter->elem_handle = ((char *) iter->elem_handle) + list->collection.elem_size; | |
| 737 | } | |
|
438
22eca559aded
refactore http listener creation
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
436
diff
changeset
|
738 | } |
|
22eca559aded
refactore http listener creation
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
436
diff
changeset
|
739 | return result; |
|
22eca559aded
refactore http listener creation
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
436
diff
changeset
|
740 | } else { |
| 579 | 741 | int result = cx_arl_insert_element(list, list->collection.size, elem); |
| 742 | if (result == 0) { | |
| 743 | iter->elem_count++; | |
| 744 | iter->index = list->collection.size; | |
| 745 | } | |
|
438
22eca559aded
refactore http listener creation
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
436
diff
changeset
|
746 | return result; |
|
22eca559aded
refactore http listener creation
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
436
diff
changeset
|
747 | } |
| 436 | 748 | } |
| 749 | ||
| 579 | 750 | static size_t cx_arl_remove( |
| 436 | 751 | struct cx_list_s *list, |
| 579 | 752 | size_t index, |
| 753 | size_t num, | |
| 754 | void *targetbuf | |
| 436 | 755 | ) { |
| 490 | 756 | cx_array_list *arl = (cx_array_list *) list; |
| 757 | ||
|
438
22eca559aded
refactore http listener creation
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
436
diff
changeset
|
758 | // out-of-bounds check |
| 579 | 759 | size_t remove; |
| 760 | if (index >= list->collection.size) { | |
| 761 | remove = 0; | |
| 762 | } else if (index + num > list->collection.size) { | |
| 763 | remove = list->collection.size - index; | |
| 764 | } else { | |
| 765 | remove = num; | |
|
438
22eca559aded
refactore http listener creation
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
436
diff
changeset
|
766 | } |
| 436 | 767 | |
| 579 | 768 | // easy exit |
| 769 | if (remove == 0) return 0; | |
| 770 | ||
| 771 | // destroy or copy contents | |
| 772 | if (targetbuf == NULL) { | |
| 773 | for (size_t idx = index; idx < index + remove; idx++) { | |
| 774 | cx_invoke_destructor( | |
| 775 | list, | |
| 776 | ((char *) arl->data) + idx * list->collection.elem_size | |
| 777 | ); | |
| 778 | } | |
| 779 | } else { | |
| 780 | memcpy( | |
| 781 | targetbuf, | |
| 782 | ((char *) arl->data) + index * list->collection.elem_size, | |
| 783 | remove * list->collection.elem_size | |
| 784 | ); | |
| 785 | } | |
| 786 | ||
| 787 | // short-circuit removal of last elements | |
| 788 | if (index + remove == list->collection.size) { | |
| 789 | list->collection.size -= remove; | |
| 790 | return remove; | |
| 791 | } | |
| 792 | ||
| 793 | // just move the elements to the left | |
| 794 | cx_array_copy( | |
| 436 | 795 | &arl->data, |
| 579 | 796 | &list->collection.size, |
| 490 | 797 | &arl->capacity, |
| 579 | 798 | 0, |
| 436 | 799 | index, |
| 579 | 800 | ((char *) arl->data) + (index + remove) * list->collection.elem_size, |
| 801 | list->collection.elem_size, | |
| 802 | list->collection.size - index - remove, | |
| 436 | 803 | &arl->reallocator |
| 804 | ); | |
| 579 | 805 | |
| 806 | // decrease the size | |
| 807 | list->collection.size -= remove; | |
| 808 | ||
| 809 | return remove; | |
| 436 | 810 | } |
| 811 | ||
| 490 | 812 | static void cx_arl_clear(struct cx_list_s *list) { |
| 579 | 813 | if (list->collection.size == 0) return; |
| 490 | 814 | |
| 815 | cx_array_list *arl = (cx_array_list *) list; | |
| 816 | char *ptr = arl->data; | |
| 817 | ||
| 579 | 818 | if (list->collection.simple_destructor) { |
| 819 | for (size_t i = 0; i < list->collection.size; i++) { | |
| 490 | 820 | cx_invoke_simple_destructor(list, ptr); |
| 579 | 821 | ptr += list->collection.elem_size; |
| 490 | 822 | } |
| 823 | } | |
| 579 | 824 | if (list->collection.advanced_destructor) { |
| 825 | for (size_t i = 0; i < list->collection.size; i++) { | |
| 490 | 826 | cx_invoke_advanced_destructor(list, ptr); |
| 579 | 827 | ptr += list->collection.elem_size; |
| 490 | 828 | } |
| 829 | } | |
| 830 | ||
| 579 | 831 | memset(arl->data, 0, list->collection.size * list->collection.elem_size); |
| 832 | list->collection.size = 0; | |
| 490 | 833 | } |
| 834 | ||
| 835 | static int cx_arl_swap( | |
| 836 | struct cx_list_s *list, | |
| 837 | size_t i, | |
| 838 | size_t j | |
| 839 | ) { | |
| 579 | 840 | if (i >= list->collection.size || j >= list->collection.size) return 1; |
| 490 | 841 | cx_array_list *arl = (cx_array_list *) list; |
| 579 | 842 | cx_array_swap(arl->data, list->collection.elem_size, i, j); |
| 490 | 843 | return 0; |
| 844 | } | |
| 845 | ||
| 436 | 846 | static void *cx_arl_at( |
| 579 | 847 | const struct cx_list_s *list, |
| 436 | 848 | size_t index |
| 849 | ) { | |
| 579 | 850 | if (index < list->collection.size) { |
| 851 | const cx_array_list *arl = (const cx_array_list *) list; | |
| 436 | 852 | char *space = arl->data; |
| 579 | 853 | return space + index * list->collection.elem_size; |
| 436 | 854 | } else { |
| 855 | return NULL; | |
| 856 | } | |
| 857 | } | |
| 858 | ||
| 579 | 859 | static size_t cx_arl_find_remove( |
| 860 | struct cx_list_s *list, | |
| 861 | const void *elem, | |
| 862 | bool remove | |
| 436 | 863 | ) { |
| 579 | 864 | assert(list != NULL); |
| 865 | assert(list->collection.cmpfunc != NULL); | |
| 866 | if (list->collection.size == 0) return 0; | |
| 867 | char *cur = ((const cx_array_list *) list)->data; | |
| 436 | 868 | |
| 579 | 869 | // optimize with binary search, when sorted |
| 870 | if (list->collection.sorted) { | |
| 871 | size_t i = cx_array_binary_search( | |
| 872 | cur, | |
| 873 | list->collection.size, | |
| 874 | list->collection.elem_size, | |
| 875 | elem, | |
| 876 | list->collection.cmpfunc | |
| 877 | ); | |
| 878 | if (remove && i < list->collection.size) { | |
| 879 | cx_arl_remove(list, i, 1, NULL); | |
| 880 | } | |
| 881 | return i; | |
| 882 | } | |
| 883 | ||
| 884 | // fallback: linear search | |
| 885 | for (size_t i = 0; i < list->collection.size; i++) { | |
| 886 | if (0 == list->collection.cmpfunc(elem, cur)) { | |
| 887 | if (remove) { | |
| 888 | cx_arl_remove(list, i, 1, NULL); | |
| 889 | } | |
| 436 | 890 | return i; |
| 891 | } | |
| 579 | 892 | cur += list->collection.elem_size; |
| 436 | 893 | } |
| 579 | 894 | return list->collection.size; |
| 436 | 895 | } |
| 896 | ||
| 897 | static void cx_arl_sort(struct cx_list_s *list) { | |
| 579 | 898 | assert(list->collection.cmpfunc != NULL); |
| 436 | 899 | qsort(((cx_array_list *) list)->data, |
| 579 | 900 | list->collection.size, |
| 901 | list->collection.elem_size, | |
| 902 | list->collection.cmpfunc | |
| 436 | 903 | ); |
| 904 | } | |
| 905 | ||
| 906 | static int cx_arl_compare( | |
| 579 | 907 | const struct cx_list_s *list, |
| 908 | const struct cx_list_s *other | |
| 436 | 909 | ) { |
| 579 | 910 | assert(list->collection.cmpfunc != NULL); |
| 911 | if (list->collection.size == other->collection.size) { | |
| 912 | const char *left = ((const cx_array_list *) list)->data; | |
| 913 | const char *right = ((const cx_array_list *) other)->data; | |
| 914 | for (size_t i = 0; i < list->collection.size; i++) { | |
| 915 | int d = list->collection.cmpfunc(left, right); | |
|
438
22eca559aded
refactore http listener creation
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
436
diff
changeset
|
916 | if (d != 0) { |
|
22eca559aded
refactore http listener creation
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
436
diff
changeset
|
917 | return d; |
|
22eca559aded
refactore http listener creation
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
436
diff
changeset
|
918 | } |
| 579 | 919 | left += list->collection.elem_size; |
| 920 | right += other->collection.elem_size; | |
|
438
22eca559aded
refactore http listener creation
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
436
diff
changeset
|
921 | } |
|
22eca559aded
refactore http listener creation
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
436
diff
changeset
|
922 | return 0; |
|
22eca559aded
refactore http listener creation
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
436
diff
changeset
|
923 | } else { |
| 579 | 924 | return list->collection.size < other->collection.size ? -1 : 1; |
|
438
22eca559aded
refactore http listener creation
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
436
diff
changeset
|
925 | } |
| 436 | 926 | } |
| 927 | ||
| 928 | static void cx_arl_reverse(struct cx_list_s *list) { | |
| 579 | 929 | if (list->collection.size < 2) return; |
| 930 | void *data = ((const cx_array_list *) list)->data; | |
| 931 | size_t half = list->collection.size / 2; | |
|
438
22eca559aded
refactore http listener creation
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
436
diff
changeset
|
932 | for (size_t i = 0; i < half; i++) { |
| 579 | 933 | cx_array_swap(data, list->collection.elem_size, i, list->collection.size - 1 - i); |
|
438
22eca559aded
refactore http listener creation
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
436
diff
changeset
|
934 | } |
| 436 | 935 | } |
| 936 | ||
| 579 | 937 | static bool cx_arl_iter_valid(const void *it) { |
| 938 | const struct cx_iterator_s *iter = it; | |
| 939 | const struct cx_list_s *list = iter->src_handle.c; | |
| 940 | return iter->index < list->collection.size; | |
| 436 | 941 | } |
| 942 | ||
| 579 | 943 | static void *cx_arl_iter_current(const void *it) { |
| 944 | const struct cx_iterator_s *iter = it; | |
| 436 | 945 | return iter->elem_handle; |
| 946 | } | |
| 947 | ||
|
438
22eca559aded
refactore http listener creation
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
436
diff
changeset
|
948 | static void cx_arl_iter_next(void *it) { |
| 579 | 949 | struct cx_iterator_s *iter = it; |
| 950 | if (iter->base.remove) { | |
| 951 | iter->base.remove = false; | |
| 952 | cx_arl_remove(iter->src_handle.m, iter->index, 1, NULL); | |
| 436 | 953 | } else { |
| 954 | iter->index++; | |
|
438
22eca559aded
refactore http listener creation
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
436
diff
changeset
|
955 | iter->elem_handle = |
|
22eca559aded
refactore http listener creation
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
436
diff
changeset
|
956 | ((char *) iter->elem_handle) |
| 579 | 957 | + ((const struct cx_list_s *) iter->src_handle.c)->collection.elem_size; |
| 490 | 958 | } |
| 959 | } | |
| 960 | ||
| 961 | static void cx_arl_iter_prev(void *it) { | |
| 579 | 962 | struct cx_iterator_s *iter = it; |
| 963 | const cx_array_list *list = iter->src_handle.c; | |
| 964 | if (iter->base.remove) { | |
| 965 | iter->base.remove = false; | |
| 966 | cx_arl_remove(iter->src_handle.m, iter->index, 1, NULL); | |
| 490 | 967 | } |
| 968 | iter->index--; | |
| 579 | 969 | if (iter->index < list->base.collection.size) { |
| 490 | 970 | iter->elem_handle = ((char *) list->data) |
| 579 | 971 | + iter->index * list->base.collection.elem_size; |
|
438
22eca559aded
refactore http listener creation
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
436
diff
changeset
|
972 | } |
|
22eca559aded
refactore http listener creation
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
436
diff
changeset
|
973 | } |
|
22eca559aded
refactore http listener creation
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
436
diff
changeset
|
974 | |
| 436 | 975 | |
| 976 | static struct cx_iterator_s cx_arl_iterator( | |
| 579 | 977 | const struct cx_list_s *list, |
| 490 | 978 | size_t index, |
| 979 | bool backwards | |
| 436 | 980 | ) { |
| 981 | struct cx_iterator_s iter; | |
| 982 | ||
| 983 | iter.index = index; | |
| 579 | 984 | iter.src_handle.c = list; |
| 436 | 985 | iter.elem_handle = cx_arl_at(list, index); |
| 579 | 986 | iter.elem_size = list->collection.elem_size; |
| 987 | iter.elem_count = list->collection.size; | |
|
438
22eca559aded
refactore http listener creation
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
436
diff
changeset
|
988 | iter.base.valid = cx_arl_iter_valid; |
|
22eca559aded
refactore http listener creation
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
436
diff
changeset
|
989 | iter.base.current = cx_arl_iter_current; |
| 490 | 990 | iter.base.next = backwards ? cx_arl_iter_prev : cx_arl_iter_next; |
|
438
22eca559aded
refactore http listener creation
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
436
diff
changeset
|
991 | iter.base.remove = false; |
|
22eca559aded
refactore http listener creation
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
436
diff
changeset
|
992 | iter.base.mutating = false; |
|
22eca559aded
refactore http listener creation
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
436
diff
changeset
|
993 | |
|
22eca559aded
refactore http listener creation
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
436
diff
changeset
|
994 | return iter; |
|
22eca559aded
refactore http listener creation
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
436
diff
changeset
|
995 | } |
| 436 | 996 | |
| 997 | static cx_list_class cx_array_list_class = { | |
| 998 | cx_arl_destructor, | |
| 490 | 999 | cx_arl_insert_element, |
| 1000 | cx_arl_insert_array, | |
| 579 | 1001 | cx_arl_insert_sorted, |
| 436 | 1002 | cx_arl_insert_iter, |
| 1003 | cx_arl_remove, | |
| 490 | 1004 | cx_arl_clear, |
| 1005 | cx_arl_swap, | |
| 436 | 1006 | cx_arl_at, |
| 579 | 1007 | cx_arl_find_remove, |
| 436 | 1008 | cx_arl_sort, |
| 1009 | cx_arl_compare, | |
| 1010 | cx_arl_reverse, | |
| 1011 | cx_arl_iterator, | |
| 1012 | }; | |
| 1013 | ||
| 1014 | CxList *cxArrayListCreate( | |
| 579 | 1015 | const CxAllocator *allocator, |
| 490 | 1016 | cx_compare_func comparator, |
| 579 | 1017 | size_t elem_size, |
| 436 | 1018 | size_t initial_capacity |
| 1019 | ) { | |
| 490 | 1020 | if (allocator == NULL) { |
| 1021 | allocator = cxDefaultAllocator; | |
| 1022 | } | |
| 1023 | ||
| 436 | 1024 | cx_array_list *list = cxCalloc(allocator, 1, sizeof(cx_array_list)); |
| 1025 | if (list == NULL) return NULL; | |
| 579 | 1026 | cx_list_init((CxList*)list, &cx_array_list_class, |
| 1027 | allocator, comparator, elem_size); | |
| 490 | 1028 | list->capacity = initial_capacity; |
| 1029 | ||
| 579 | 1030 | // allocate the array after the real elem_size is known |
| 1031 | list->data = cxCalloc(allocator, initial_capacity, | |
| 1032 | list->base.collection.elem_size); | |
| 1033 | if (list->data == NULL) { // LCOV_EXCL_START | |
| 436 | 1034 | cxFree(allocator, list); |
| 1035 | return NULL; | |
| 579 | 1036 | } // LCOV_EXCL_STOP |
| 436 | 1037 | |
|
438
22eca559aded
refactore http listener creation
Olaf Wintermann <olaf.wintermann@gmail.com>
parents:
436
diff
changeset
|
1038 | // configure the reallocator |
| 579 | 1039 | list->reallocator = cx_array_reallocator(allocator, NULL); |
| 436 | 1040 | |
| 1041 | return (CxList *) list; | |
| 1042 | } |