Line data Source code
1 : /*
2 : * SPDX-License-Identifier: MPL-2.0
3 : *
4 : * This Source Code Form is subject to the terms of the Mozilla Public
5 : * License, v. 2.0. If a copy of the MPL was not distributed with this
6 : * file, You can obtain one at http://mozilla.org/MPL/2.0/.
7 : *
8 : * Copyright 2024 MonetDB Foundation;
9 : * Copyright August 2008 - 2023 MonetDB B.V.;
10 : * Copyright 1997 - July 2008 CWI.
11 : */
12 :
13 : /*
14 : * @a Martin L. Kersten & Peter Boncz
15 : * @v 2.0
16 : * @+ Value representation
17 : *
18 : *
19 : * When manipulating values, MonetDB puts them into value records.
20 : * The built-in types have a direct entry in the union. Others should
21 : * be represented as a pointer of memory in pval or as a string, which
22 : * is basically the same. In such cases the len field indicates the
23 : * size of this piece of memory.
24 : *
25 : * MonetDB extenders will use value records for passing parameters to
26 : * their new operators. MonetDB algebraic commands receive an (argc,
27 : * argv) combination, where argc is an integer indicating the size of
28 : * the the argv array of value records. On call, the first record,
29 : * argv[0], is always empty. The routine must place its return value -
30 : * if any - there. The other values are the parameters.
31 : *
32 : * Actually, the gdk value type defined here should become a built-in
33 : * type in the kernel. Next step will be to define the corresponding
34 : * extension module.
35 : *
36 : * @+ Value operations
37 : * The following primitives are required to manipulate value records.
38 : * Note that binding a BAT requires upgrading its reference count.
39 : * The receiver of the value should have been cleared or represent
40 : * free space.
41 : */
42 : #include "monetdb_config.h"
43 : #include "gdk.h"
44 : #include "gdk_private.h"
45 :
46 : /* Set V to the type/value combination in T/P. Also see VALinit. In
47 : * this version, if P refers to an external type, no new memory is
48 : * allocated, but instead the pointer P is given to V. */
49 : ValPtr
50 5405549 : VALset(ValPtr v, int t, ptr p)
51 : {
52 5405549 : assert(t < TYPE_any);
53 5405549 : v->bat = false;
54 5405549 : switch (ATOMstorage(v->vtype = t)) {
55 105286 : case TYPE_void:
56 105286 : v->val.oval = *(oid *) p;
57 105286 : break;
58 0 : case TYPE_msk:
59 0 : v->val.mval = *(msk *) p;
60 0 : break;
61 19758 : case TYPE_bte:
62 19758 : v->val.btval = *(bte *) p;
63 19758 : break;
64 15356 : case TYPE_sht:
65 15356 : v->val.shval = *(sht *) p;
66 15356 : break;
67 238021 : case TYPE_int:
68 238021 : v->val.ival = *(int *) p;
69 238021 : break;
70 2759 : case TYPE_flt:
71 2759 : v->val.fval = *(flt *) p;
72 2759 : break;
73 2828 : case TYPE_dbl:
74 2828 : v->val.dval = *(dbl *) p;
75 2828 : break;
76 294859 : case TYPE_lng:
77 294859 : v->val.lval = *(lng *) p;
78 294859 : break;
79 : #ifdef HAVE_HGE
80 1819 : case TYPE_hge:
81 1819 : v->val.hval = *(hge *) p;
82 1819 : break;
83 : #endif
84 105 : case TYPE_uuid:
85 105 : v->val.uval = *(uuid *) p;
86 105 : break;
87 4456112 : case TYPE_str:
88 4456112 : v->val.sval = (str) p;
89 4456112 : break;
90 268286 : case TYPE_ptr:
91 268286 : v->val.pval = *(ptr *) p;
92 268286 : break;
93 360 : default:
94 360 : v->val.pval = p;
95 360 : break;
96 : }
97 5405549 : v->len = ATOMlen(v->vtype, VALptr(v));
98 5405484 : return v;
99 : }
100 :
101 : /* Return a pointer to the value contained in V. Also see VALptr
102 : * which returns a const void *. */
103 : void *
104 9125396 : VALget(ValPtr v)
105 : {
106 9125396 : assert(!v->bat);
107 9125396 : switch (ATOMstorage(v->vtype)) {
108 244 : case TYPE_void: return (void *) &v->val.oval;
109 0 : case TYPE_msk: return (void *) &v->val.mval;
110 4834714 : case TYPE_bte: return (void *) &v->val.btval;
111 183398 : case TYPE_sht: return (void *) &v->val.shval;
112 2183056 : case TYPE_int: return (void *) &v->val.ival;
113 1135 : case TYPE_flt: return (void *) &v->val.fval;
114 23539 : case TYPE_dbl: return (void *) &v->val.dval;
115 1234105 : case TYPE_lng: return (void *) &v->val.lval;
116 : #ifdef HAVE_HGE
117 5423 : case TYPE_hge: return (void *) &v->val.hval;
118 : #endif
119 72 : case TYPE_uuid: return (void *) &v->val.uval;
120 1 : case TYPE_ptr: return (void *) &v->val.pval;
121 659574 : case TYPE_str: return (void *) v->val.sval;
122 135 : default: return (void *) v->val.pval;
123 : }
124 : }
125 :
126 : /* Clear V to an empty value (type void, value nil), freeing any
127 : * memory allocated for external types. See VALempty for when V does
128 : * not yet contain a value. */
129 : void
130 49137014 : VALclear(ValPtr v)
131 : {
132 49137014 : if (!v->bat && ATOMextern(v->vtype)) {
133 7224785 : if (v->val.pval && v->val.pval != ATOMnilptr(v->vtype))
134 7068530 : GDKfree(v->val.pval);
135 : }
136 49137629 : VALempty(v);
137 49137960 : }
138 :
139 : /* Initialize V to an empty value (type void, value nil). See
140 : * VALclear for when V already contains a value. */
141 : void
142 67431258 : VALempty(ValPtr v)
143 : {
144 67431258 : *v = (ValRecord) {
145 : .bat = false,
146 : .val.oval = oid_nil,
147 : .vtype = TYPE_void,
148 : };
149 67431258 : }
150 :
151 : /* Create a copy of S into D, allocating space for external values
152 : * (non-fixed sized values). See VALinit for a version where the
153 : * source is not in a VALRecord.
154 : *
155 : * Returns NULL In case of (malloc) failure. */
156 : ValPtr
157 40038405 : VALcopy(ValPtr d, const ValRecord *s)
158 : {
159 40038405 : if (d == s)
160 : return d;
161 40035486 : d->bat = false;
162 40035486 : if (s->bat || !ATOMextern(s->vtype)) {
163 26233589 : *d = *s;
164 13801897 : } else if (s->val.pval == NULL) {
165 0 : return VALinit(d, s->vtype, ATOMnilptr(s->vtype));
166 13801897 : } else if (s->vtype == TYPE_str) {
167 13799330 : const char *p = s->val.sval;
168 13799330 : d->vtype = TYPE_str;
169 13799330 : d->len = strLen(p);
170 13799330 : d->val.sval = GDKmalloc(d->len);
171 13799576 : if (d->val.sval == NULL)
172 : return NULL;
173 13799576 : memcpy(d->val.sval, p, d->len);
174 : } else {
175 2567 : const void *p = s->val.pval;
176 2567 : d->vtype = s->vtype;
177 2567 : d->len = ATOMlen(d->vtype, p);
178 2567 : d->val.pval = GDKmalloc(d->len);
179 2567 : if (d->val.pval == NULL)
180 : return NULL;
181 2567 : memcpy(d->val.pval, p, d->len);
182 : }
183 : return d;
184 : }
185 :
186 : /* Create a copy of the type value combination in TPE/S, allocating
187 : * space for external values (non-fixed sized values). See VALcopy
188 : * for a version where the source is in a ValRecord, and see VALset
189 : * for a version where ownership of the source is transferred.
190 : *
191 : * Returns NULL in case of (malloc) failure. */
192 : ValPtr
193 9239708 : VALinit(ValPtr d, int tpe, const void *s)
194 : {
195 9239708 : d->bat = false;
196 9239708 : switch (ATOMstorage(d->vtype = tpe)) {
197 0 : case TYPE_void:
198 0 : d->val.oval = *(const oid *) s;
199 0 : break;
200 0 : case TYPE_msk:
201 0 : d->val.mval = *(const msk *) s;
202 0 : break;
203 191809 : case TYPE_bte:
204 191809 : d->val.btval = *(const bte *) s;
205 191809 : break;
206 531959 : case TYPE_sht:
207 531959 : d->val.shval = *(const sht *) s;
208 531959 : break;
209 2842471 : case TYPE_int:
210 2842471 : d->val.ival = *(const int *) s;
211 2842471 : break;
212 12632 : case TYPE_flt:
213 12632 : d->val.fval = *(const flt *) s;
214 12632 : break;
215 10765 : case TYPE_dbl:
216 10765 : d->val.dval = *(const dbl *) s;
217 10765 : break;
218 277075 : case TYPE_lng:
219 277075 : d->val.lval = *(const lng *) s;
220 277075 : break;
221 : #ifdef HAVE_HGE
222 2108 : case TYPE_hge:
223 2108 : d->val.hval = *(const hge *) s;
224 2108 : break;
225 : #endif
226 118 : case TYPE_uuid:
227 118 : d->val.uval = *(const uuid *) s;
228 118 : break;
229 4959843 : case TYPE_str:
230 4959843 : d->len = strLen(s);
231 4959843 : d->val.sval = GDKmalloc(d->len);
232 4960100 : if (d->val.sval == NULL)
233 : return NULL;
234 4960100 : memcpy(d->val.sval, s, d->len);
235 4960100 : return d;
236 410652 : case TYPE_ptr:
237 410652 : d->val.pval = *(const ptr *) s;
238 410652 : d->len = ATOMlen(tpe, *(const ptr *) s);
239 410652 : return d;
240 276 : default:
241 276 : assert(ATOMextern(ATOMstorage(tpe)));
242 276 : d->len = ATOMlen(tpe, s);
243 276 : d->val.pval = GDKmalloc(d->len);
244 276 : if (d->val.pval == NULL)
245 : return NULL;
246 276 : memcpy(d->val.pval, s, d->len);
247 276 : return d;
248 : }
249 3868937 : d->len = ATOMsize(d->vtype);
250 3868937 : return d;
251 : }
252 :
253 : /* Format the value in RES in the standard way for the type of RES
254 : * into a newly allocated buffer. Also see ATOMformat. */
255 : char *
256 20328 : VALformat(const ValRecord *res)
257 : {
258 20328 : if (res->bat) {
259 3333 : if (is_bat_nil(res->val.bval))
260 333 : return GDKstrdup("nil");
261 : else
262 3000 : return ATOMformat(TYPE_int, (const void *) &res->val.ival);
263 : } else
264 16995 : return ATOMformat(res->vtype, VALptr(res));
265 : }
266 :
267 : /* Convert (cast) the value in T to the type TYP, do this in place.
268 : * Return a pointer to the converted value, or NULL if the conversion
269 : * didn't succeed. If the conversion didn't succeed, the original
270 : * value is not modified. Also see VARconvert. */
271 : ptr
272 279735 : VALconvert(int typ, ValPtr t)
273 : {
274 279735 : int src_tpe = t->vtype;
275 279735 : ValRecord dst = { .vtype = typ };
276 :
277 : /* first convert into a new location */
278 279735 : if (VARconvert(&dst, t, 0, 0, 0) != GDK_SUCCEED)
279 : return NULL;
280 :
281 : /* then maybe free the old */
282 279730 : if (src_tpe != dst.vtype &&
283 279720 : t->vtype != typ &&
284 279720 : dst.vtype != TYPE_void &&
285 279545 : (src_tpe >= TYPE_str || dst.vtype >= TYPE_str))
286 32446 : VALclear(t);
287 : /* and finally copy the result */
288 279730 : *t = dst;
289 : /* make sure we return the correct type (not the storage type) */
290 279730 : t->vtype = typ;
291 279730 : return VALget(t);
292 : }
293 :
294 : /* Compare two values in P and Q and return -1/0/1 depending on
295 : * whether P is less than, equal to, or larger than Q. Also return -1
296 : * if P or Q is NULL or NIL, or if the types of P and Q are not
297 : * equal. */
298 : int
299 1586065 : VALcmp(const ValRecord *p, const ValRecord *q)
300 : {
301 :
302 1586065 : int (*cmp)(const void *, const void *);
303 1586065 : int tpe;
304 1586065 : const void *nilptr, *pp, *pq;
305 :
306 1586065 : if (p == 0 || q == 0)
307 : return -1;
308 1586065 : if ((tpe = p->vtype) != q->vtype)
309 : return -1;
310 :
311 1586017 : if (tpe == TYPE_ptr)
312 : return 0; /* ignore comparing C pointers */
313 1586017 : cmp = ATOMcompare(tpe);
314 1586017 : nilptr = ATOMnilptr(tpe);
315 1586017 : pp = VALptr(p);
316 1586017 : pq = VALptr(q);
317 1586017 : if ((*cmp)(pp, nilptr) == 0 && (*cmp)(pq, nilptr) == 0)
318 : return 0; /* eq nil val */
319 1586017 : if ((*cmp)(pp, nilptr) == 0 || (*cmp)(pq, nilptr) == 0)
320 0 : return -1;
321 1586017 : return (*cmp)(pp, pq);
322 :
323 : }
324 :
325 : /* Return TRUE if the value in V is NIL. */
326 : bool
327 10536810 : VALisnil(const ValRecord *v)
328 : {
329 10536810 : if (v->bat)
330 0 : return is_bat_nil(v->val.bval);
331 10536810 : switch (v->vtype) {
332 : case TYPE_void:
333 : return true;
334 0 : case TYPE_msk:
335 0 : return false;
336 90794 : case TYPE_bte:
337 90794 : return is_bte_nil(v->val.btval);
338 1023441 : case TYPE_sht:
339 1023441 : return is_sht_nil(v->val.shval);
340 5557401 : case TYPE_int:
341 5557401 : return is_int_nil(v->val.ival);
342 260307 : case TYPE_lng:
343 260307 : return is_lng_nil(v->val.lval);
344 : #ifdef HAVE_HGE
345 2895 : case TYPE_hge:
346 2895 : return is_hge_nil(v->val.hval);
347 : #endif
348 5 : case TYPE_uuid:
349 5 : return is_uuid_nil(v->val.uval);
350 18600 : case TYPE_flt:
351 18600 : return is_flt_nil(v->val.fval);
352 9401 : case TYPE_dbl:
353 9401 : return is_dbl_nil(v->val.dval);
354 10 : case TYPE_oid:
355 10 : return is_oid_nil(v->val.oval);
356 0 : case TYPE_ptr:
357 0 : return v->val.pval == NULL;
358 : default:
359 3573954 : break;
360 : }
361 3573954 : return (*ATOMcompare(v->vtype))(VALptr(v), ATOMnilptr(v->vtype)) == 0;
362 : }
|
