/usr/include/tarantool/tnt_iter.h is in libtarantool-dev 1.5.1.218.g1a69fd6-1ubuntu1.
This file is owned by root:root, with mode 0o644.
The actual contents of the file can be viewed below.
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 68 69 70 71 72 73 74 75 76 77 78 79 80 81 82 83 84 85 86 87 88 89 90 91 92 93 94 95 96 97 98 99 100 101 102 103 104 105 106 107 108 109 110 111 112 113 114 115 116 117 118 119 120 121 122 123 124 125 126 127 128 129 130 131 132 133 134 135 136 137 138 139 140 141 142 143 144 145 146 147 148 149 150 151 152 153 | #ifndef TNT_ITER_H_INCLUDED
#define TNT_ITER_H_INCLUDED
/*
* Redistribution and use in source and binary forms, with or
* without modification, are permitted provided that the following
* conditions are met:
*
* 1. Redistributions of source code must retain the above
* copyright notice, this list of conditions and the
* following disclaimer.
*
* 2. Redistributions in binary form must reproduce the above
* copyright notice, this list of conditions and the following
* disclaimer in the documentation and/or other materials
* provided with the distribution.
*
* THIS SOFTWARE IS PROVIDED BY <COPYRIGHT HOLDER> ``AS IS'' AND
* ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED
* TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR
* A PARTICULAR PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL
* <COPYRIGHT HOLDER> OR CONTRIBUTORS BE LIABLE FOR ANY DIRECT,
* INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL
* DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF
* SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR
* BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY THEORY OF
* LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT
* (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF
* THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF
* SUCH DAMAGE.
*/
/* tuple iterator type */
enum tnt_iter_type {
TNT_ITER_FIELD,
TNT_ITER_LIST,
TNT_ITER_REQUEST,
TNT_ITER_REPLY,
TNT_ITER_STORAGE
};
/* tuple field iterator */
struct tnt_iter_field {
struct tnt_tuple *tu; /* tuple pointer */
char *fld_ptr; /* current iteration offset */
char *fld_ptr_prev; /* prev iteration offset */
uint32_t fld_index; /* current field index */
uint32_t fld_size; /* current field size */
int fld_esize; /* current field encoding size */
char *fld_data; /* current field data */
};
/* tuple field iterator accessors */
#define TNT_IFIELD(I) (&(I)->data.field)
#define TNT_IFIELD_TUPLE(I) TNT_IFIELD(I)->tu
#define TNT_IFIELD_IDX(I) TNT_IFIELD(I)->fld_index
#define TNT_IFIELD_DATA(I) TNT_IFIELD(I)->fld_data
#define TNT_IFIELD_SIZE(I) TNT_IFIELD(I)->fld_size
/* list iterator */
struct tnt_iter_list {
struct tnt_list *l; /* list pointer */
struct tnt_tuple *tu; /* current tuple pointer */
uint32_t tu_index; /* current tuple index */
};
/* list iterator accessors */
#define TNT_ILIST(I) (&(I)->data.list)
#define TNT_ILIST_TUPLE(I) TNT_ILIST(I)->tu
#define TNT_ILIST_INDEX(I) TNT_ILIST(I)->tu_index
/* request iterator */
struct tnt_iter_request {
struct tnt_stream *s; /* stream pointer */
struct tnt_request r; /* current request */
};
/* request iterator accessors */
#define TNT_IREQUEST(I) (&(I)->data.request)
#define TNT_IREQUEST_PTR(I) &TNT_IREQUEST(I)->r
#define TNT_IREQUEST_STREAM(I) TNT_IREQUEST(I)->s
/* storage iterator */
struct tnt_iter_storage {
struct tnt_stream *s; /* stream pointer */
struct tnt_tuple t; /* current fetched tuple */
};
/* request iterator accessors */
#define TNT_ISTORAGE(I) (&(I)->data.storage)
#define TNT_ISTORAGE_TUPLE(I) &TNT_ISTORAGE(I)->t
#define TNT_ISTORAGE_STREAM(I) TNT_ISTORAGE(I)->s
/* reply iterator */
struct tnt_iter_reply {
struct tnt_stream *s; /* stream pointer */
struct tnt_reply r; /* current reply */
};
/* reply iterator accessors */
#define TNT_IREPLY(I) (&(I)->data.reply)
#define TNT_IREPLY_PTR(I) &TNT_IREPLY(I)->r
enum tnt_iter_status {
TNT_ITER_OK,
TNT_ITER_FAIL
};
/* common iterator object */
struct tnt_iter {
enum tnt_iter_type type;
enum tnt_iter_status status;
int alloc;
/* interface callbacks */
int (*next)(struct tnt_iter *iter);
void (*rewind)(struct tnt_iter *iter);
void (*free)(struct tnt_iter *iter);
/* iterator data */
union {
struct tnt_iter_field field;
struct tnt_iter_list list;
struct tnt_iter_request request;
struct tnt_iter_reply reply;
struct tnt_iter_storage storage;
} data;
};
struct tnt_iter *tnt_iter(struct tnt_iter *i, struct tnt_tuple *t);
struct tnt_iter *tnt_iter_list(struct tnt_iter *i, struct tnt_list *l);
struct tnt_iter *tnt_iter_request(struct tnt_iter *i, struct tnt_stream *s);
struct tnt_iter *tnt_iter_reply(struct tnt_iter *i, struct tnt_stream *s);
struct tnt_iter *tnt_iter_storage(struct tnt_iter *i, struct tnt_stream *s);
void tnt_iter_free(struct tnt_iter *i);
int tnt_next(struct tnt_iter *i);
void tnt_rewind(struct tnt_iter *i);
struct tnt_iter *tnt_field(struct tnt_iter *i, struct tnt_tuple *t, uint32_t index);
#endif /* TNT_ITER_H_INCLUDED */
|