]>
git.proxmox.com Git - ceph.git/blob - ceph/src/pmdk/src/common/vecq.h
1 /* SPDX-License-Identifier: BSD-3-Clause */
2 /* Copyright 2018-2020, Intel Corporation */
5 * vecq.h -- vector queue (FIFO) interface
20 #define VECQ_INIT_SIZE (64)
22 #define VECQ(name, type)\
30 #define VECQ_INIT(vec) do {\
31 (vec)->buffer = NULL;\
37 #define VECQ_REINIT(vec) do {\
38 VALGRIND_ANNOTATE_NEW_MEMORY((vec), sizeof(*vec));\
39 VALGRIND_ANNOTATE_NEW_MEMORY((vec)->buffer,\
40 (sizeof(*(vec)->buffer) * ((vec)->capacity)));\
45 #define VECQ_FRONT_POS(vec)\
46 ((vec)->front & ((vec)->capacity - 1))
48 #define VECQ_BACK_POS(vec)\
49 ((vec)->back & ((vec)->capacity - 1))
51 #define VECQ_FRONT(vec)\
52 (vec)->buffer[VECQ_FRONT_POS(vec)]
54 #define VECQ_BACK(vec)\
55 (vec)->buffer[VECQ_BACK_POS(vec)]
57 #define VECQ_DEQUEUE(vec)\
58 ((vec)->buffer[(((vec)->front++) & ((vec)->capacity - 1))])
60 #define VECQ_SIZE(vec)\
61 ((vec)->back - (vec)->front)
64 realloc_set(void **buf
, size_t s
)
66 void *tbuf
= Realloc(*buf
, s
);
75 #define VECQ_NCAPACITY(vec)\
76 ((vec)->capacity == 0 ? VECQ_INIT_SIZE : (vec)->capacity * 2)
77 #define VECQ_GROW(vec)\
78 (realloc_set((void **)&(vec)->buffer,\
79 VECQ_NCAPACITY(vec) * sizeof(*(vec)->buffer)) ? -1 :\
80 (memcpy((vec)->buffer + (vec)->capacity, (vec)->buffer,\
81 VECQ_FRONT_POS(vec) * sizeof(*(vec)->buffer)),\
82 (vec)->front = VECQ_FRONT_POS(vec),\
83 (vec)->back = (vec)->front + (vec)->capacity,\
84 (vec)->capacity = VECQ_NCAPACITY(vec),\
88 #define VECQ_INSERT(vec, element)\
89 (VECQ_BACK(vec) = element, (vec)->back += 1, 0)
91 #define VECQ_ENQUEUE(vec, element)\
92 ((vec)->capacity == VECQ_SIZE(vec) ?\
93 (VECQ_GROW(vec) == 0 ? VECQ_INSERT(vec, element) : -1) :\
94 VECQ_INSERT(vec, element))
96 #define VECQ_CAPACITY(vec)\
99 #define VECQ_FOREACH(el, vec)\
100 for (size_t _vec_i = 0;\
101 _vec_i < VECQ_SIZE(vec) &&\
102 (((el) = (vec)->buffer[_vec_i & ((vec)->capacity - 1)]), 1);\
105 #define VECQ_FOREACH_REVERSE(el, vec)\
106 for (size_t _vec_i = VECQ_SIZE(vec);\
108 (((el) = (vec)->buffer[(_vec_i - 1) & ((vec)->capacity - 1)]), 1);\
111 #define VECQ_CLEAR(vec) do {\
116 #define VECQ_DELETE(vec) do {\
117 Free((vec)->buffer);\
118 (vec)->buffer = NULL;\
119 (vec)->capacity = 0;\
128 #endif /* PMDK_VECQ_H */