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 : * (author) Author M. Kersten
15 : * For documentation see website
16 : */
17 : #include "monetdb_config.h"
18 : #include "mal_instruction.h"
19 : #include "mal_function.h" /* for getPC() */
20 : #include "mal_utils.h"
21 : #include "mal_exception.h"
22 : #include "mal_private.h"
23 :
24 : /* to avoid memory fragmentation stmt and var blocks are allocated in chunks */
25 : #define MALCHUNK 256
26 :
27 : /* If we encounter an error it can be left behind in the MalBlk
28 : * for the upper layers to abandon the track
29 : */
30 : void
31 0 : addMalException(MalBlkPtr mb, str msg)
32 : {
33 0 : if (msg == NULL)
34 : return;
35 0 : if (mb->errors) {
36 0 : mb->errors = concatErrors(mb->errors, msg);
37 : } else {
38 0 : mb->errors = dupError(msg);
39 : }
40 : }
41 :
42 : Symbol
43 3406551 : newSymbol(const char *nme, int kind)
44 : {
45 3406551 : Symbol cur;
46 :
47 3406551 : assert(kind == COMMANDsymbol || kind == PATTERNsymbol || kind == FUNCTIONsymbol);
48 3406551 : if (nme == NULL)
49 : return NULL;
50 3406551 : cur = (Symbol) GDKzalloc(sizeof(SymRecord));
51 3406551 : if (cur == NULL)
52 : return NULL;
53 3406551 : cur->name = putName(nme);
54 3406551 : if (cur->name == NULL) {
55 0 : GDKfree(cur);
56 0 : return NULL;
57 : }
58 3406551 : cur->kind = kind;
59 3406551 : cur->peer = NULL;
60 3406551 : if (kind == FUNCTIONsymbol) {
61 50462 : cur->def = newMalBlk(STMT_INCREMENT);
62 50462 : if (cur->def == NULL) {
63 0 : GDKfree(cur);
64 0 : return NULL;
65 : }
66 : }
67 : return cur;
68 : }
69 :
70 : void
71 3386540 : freeSymbol(Symbol s)
72 : {
73 3386540 : if (s == NULL)
74 : return;
75 3386540 : if (s->def) {
76 50461 : freeMalBlk(s->def);
77 50461 : s->def = NULL;
78 3336079 : } else if (s->allocated && s->func) {
79 1633125 : GDKfree(s->func->comment);
80 1633125 : GDKfree((char*)s->func->cname);
81 1633125 : GDKfree(s->func->args);
82 1633125 : GDKfree(s->func);
83 : }
84 3386540 : GDKfree(s);
85 : }
86 :
87 : void
88 198325 : freeSymbolList(Symbol s)
89 : {
90 198325 : Symbol t = s;
91 :
92 3584340 : while (s) {
93 3386015 : t = s->peer;
94 3386015 : s->peer = NULL;
95 3386015 : freeSymbol(s);
96 3386015 : s = t;
97 : }
98 198325 : }
99 :
100 : int
101 4032829 : newMalBlkStmt(MalBlkPtr mb, int maxstmts)
102 : {
103 4032829 : InstrPtr *p;
104 4032829 : maxstmts = maxstmts % MALCHUNK == 0 ? maxstmts : ((maxstmts / MALCHUNK) + 1) * MALCHUNK;
105 :
106 4032829 : p = (InstrPtr *) GDKzalloc(sizeof(InstrPtr) * maxstmts);
107 4032805 : if (p == NULL)
108 : return -1;
109 4032805 : mb->stmt = p;
110 4032805 : mb->stop = 0;
111 4032805 : mb->ssize = maxstmts;
112 4032805 : return 0;
113 : }
114 :
115 : MalBlkPtr
116 58757 : newMalBlk(int elements)
117 : {
118 58757 : MalBlkPtr mb;
119 58757 : VarRecord *v;
120 :
121 58757 : mb = (MalBlkPtr) GDKmalloc(sizeof(MalBlkRecord));
122 58756 : if (mb == NULL)
123 : return NULL;
124 :
125 : /* each MAL instruction implies at least one variable
126 : * we reserve some extra for constants */
127 58756 : assert(elements >= 0);
128 58756 : elements += 8;
129 58756 : if (elements % MALCHUNK != 0)
130 58756 : elements = (elements / MALCHUNK + 1) * MALCHUNK;
131 58756 : v = (VarRecord *) GDKzalloc(sizeof(VarRecord) * elements);
132 58757 : if (v == NULL) {
133 0 : GDKfree(mb);
134 0 : return NULL;
135 : }
136 58757 : *mb = (MalBlkRecord) {
137 : .var = v,
138 : .vsize = elements,
139 : .maxarg = MAXARG, /* the minimum for each instruction */
140 : .workers = ATOMIC_VAR_INIT(1),
141 : };
142 58757 : if (newMalBlkStmt(mb, elements) < 0) {
143 0 : GDKfree(mb->var);
144 0 : GDKfree(mb);
145 0 : return NULL;
146 : }
147 : return mb;
148 : }
149 :
150 : int
151 42740 : resizeMalBlk(MalBlkPtr mb, int elements)
152 : {
153 42740 : int i;
154 42740 : assert(elements >= 0);
155 42740 : if (elements % MALCHUNK != 0)
156 10472 : elements = (elements / MALCHUNK + 1) * MALCHUNK;
157 :
158 42740 : if (elements > mb->ssize) {
159 32268 : InstrPtr *ostmt = mb->stmt;
160 32268 : mb->stmt = GDKrealloc(mb->stmt, elements * sizeof(InstrPtr));
161 32268 : if (mb->stmt) {
162 8212754 : for (i = mb->ssize; i < elements; i++)
163 8180486 : mb->stmt[i] = 0;
164 32268 : mb->ssize = elements;
165 : } else {
166 0 : mb->stmt = ostmt; /* reinstate old pointer */
167 0 : mb->errors = createMalException(mb, 0, TYPE,
168 : SQLSTATE(HY013) MAL_MALLOC_FAIL);
169 0 : return -1;
170 : }
171 : }
172 : return 0;
173 : }
174 :
175 : /* For a MAL session we have to keep the variables around
176 : * and only need to reset the instruction pointer
177 : */
178 : void
179 586156 : resetMalTypes(MalBlkPtr mb, int stop)
180 : {
181 586156 : int i;
182 :
183 28303340 : for (i = 0; i < stop; i++)
184 27717184 : mb->stmt[i]->typeresolved = false;
185 586156 : mb->stop = stop;
186 586156 : mb->errors = NULL;
187 586156 : }
188 :
189 : /* For SQL operations we have to cleanup variables and trim the space
190 : * A portion is retained for the next query */
191 : void
192 571571 : resetMalBlk(MalBlkPtr mb)
193 : {
194 571571 : int i;
195 571571 : InstrPtr *new;
196 571571 : VarRecord *vnew;
197 :
198 149799187 : for (i = 1/*MALCHUNK*/; i < mb->ssize; i++) {
199 149227629 : freeInstruction(mb->stmt[i]);
200 149227616 : mb->stmt[i] = NULL;
201 : }
202 571558 : if (mb->ssize != MALCHUNK) {
203 8910 : new = GDKrealloc(mb->stmt, sizeof(InstrPtr) * MALCHUNK);
204 8910 : if (new == NULL) {
205 : /* the only place to return an error signal at this stage. */
206 : /* The Client context should be passed around more deeply */
207 0 : mb->errors = createMalException(mb, 0, TYPE,
208 : SQLSTATE(HY013) MAL_MALLOC_FAIL);
209 0 : return;
210 : }
211 8910 : mb->stmt = new;
212 8910 : mb->ssize = MALCHUNK;
213 : }
214 : /* Reuse the initial function statement */
215 571558 : mb->stop = 1;
216 :
217 57405093 : for (i = 0; i < mb->vtop; i++) {
218 56833540 : if (mb->var[i].name)
219 354518 : GDKfree(mb->var[i].name);
220 56833178 : mb->var[i].name = NULL;
221 56833178 : if (isVarConstant(mb, i))
222 18664759 : VALclear(&getVarConstant(mb, i));
223 : }
224 :
225 571553 : if (mb->vsize != MALCHUNK) {
226 23374 : vnew = GDKrealloc(mb->var, sizeof(VarRecord) * MALCHUNK);
227 23374 : if (vnew == NULL) {
228 : /* the only place to return an error signal at this stage. */
229 : /* The Client context should be passed around more deeply */
230 0 : mb->errors = createMalException(mb, 0, TYPE,
231 : SQLSTATE(HY013) MAL_MALLOC_FAIL);
232 0 : return;
233 : }
234 23374 : mb->var = vnew;
235 23374 : mb->vsize = MALCHUNK;
236 : }
237 571553 : mb->vtop = 0;
238 : }
239 :
240 :
241 : /* The freeMalBlk code is quite defensive. It is used to localize an
242 : * illegal reuse of a MAL blk. */
243 : void
244 58993 : freeMalBlk(MalBlkPtr mb)
245 : {
246 58993 : int i;
247 :
248 15259811 : for (i = 0; i < mb->ssize; i++)
249 15200818 : if (mb->stmt[i]) {
250 173046 : freeInstruction(mb->stmt[i]);
251 173046 : mb->stmt[i] = NULL;
252 : }
253 58993 : mb->stop = 0;
254 336933 : for (i = 0; i < mb->vtop; i++) {
255 277940 : if (mb->var[i].name)
256 10352 : GDKfree(mb->var[i].name);
257 277940 : mb->var[i].name = NULL;
258 277940 : if (isVarConstant(mb, i))
259 65229 : VALclear(&getVarConstant(mb, i));
260 : }
261 58993 : mb->vtop = 0;
262 58993 : GDKfree(mb->stmt);
263 58993 : mb->stmt = 0;
264 58993 : GDKfree(mb->var);
265 58993 : mb->var = 0;
266 :
267 58993 : mb->binding[0] = 0;
268 58993 : mb->tag = 0;
269 58993 : mb->memory = 0;
270 58993 : if (mb->help)
271 0 : GDKfree(mb->help);
272 58993 : mb->help = 0;
273 58993 : mb->inlineProp = 0;
274 58993 : mb->unsafeProp = 0;
275 58993 : freeException(mb->errors);
276 58993 : GDKfree(mb);
277 58993 : }
278 :
279 : /* The routine below should assure that all referenced structures are
280 : * private. The copying is memory conservative. */
281 : MalBlkPtr
282 237 : copyMalBlk(MalBlkPtr old)
283 : {
284 237 : MalBlkPtr mb;
285 237 : int i;
286 :
287 237 : mb = (MalBlkPtr) GDKzalloc(sizeof(MalBlkRecord));
288 237 : if (mb == NULL)
289 : return NULL;
290 :
291 237 : mb->var = (VarRecord *) GDKzalloc(sizeof(VarRecord) * old->vsize);
292 237 : if (mb->var == NULL) {
293 0 : GDKfree(mb);
294 0 : return NULL;
295 : }
296 :
297 237 : mb->vsize = old->vsize;
298 :
299 : /* copy all variable records */
300 12177 : for (i = 0; i < old->vtop; i++) {
301 11940 : mb->var[i] = old->var[i];
302 11940 : if (mb->var[i].name) {
303 631 : mb->var[i].name = GDKstrdup(mb->var[i].name);
304 631 : if (!mb->var[i].name)
305 0 : goto bailout;
306 : }
307 11940 : if (VALcopy(&(mb->var[i].value), &(old->var[i].value)) == NULL) {
308 0 : mb->vtop = i;
309 0 : goto bailout;
310 : }
311 : }
312 237 : mb->vtop = old->vtop;
313 :
314 237 : mb->stmt = (InstrPtr *) GDKzalloc(sizeof(InstrPtr) * old->ssize);
315 237 : if (mb->stmt == NULL) {
316 0 : goto bailout;
317 : }
318 :
319 237 : mb->ssize = old->ssize;
320 237 : assert(old->stop < old->ssize);
321 11213 : for (i = 0; i < old->stop; i++) {
322 10976 : mb->stmt[i] = copyInstruction(old->stmt[i]);
323 10976 : if (mb->stmt[i] == NULL) {
324 0 : mb->stop = i;
325 0 : goto bailout;
326 : }
327 : }
328 237 : mb->stop = old->stop;
329 237 : if (old->help && (mb->help = GDKstrdup(old->help)) == NULL) {
330 0 : goto bailout;
331 : }
332 :
333 237 : strcpy_len(mb->binding, old->binding, sizeof(mb->binding));
334 237 : mb->errors = old->errors ? GDKstrdup(old->errors) : 0;
335 237 : mb->tag = old->tag;
336 237 : mb->runtime = old->runtime;
337 237 : mb->calls = old->calls;
338 237 : mb->optimize = old->optimize;
339 237 : mb->maxarg = old->maxarg;
340 237 : mb->inlineProp = old->inlineProp;
341 237 : mb->unsafeProp = old->unsafeProp;
342 237 : return mb;
343 :
344 : bailout:
345 0 : for (i = 0; i < old->stop; i++)
346 0 : freeInstruction(mb->stmt[i]);
347 0 : for (i = 0; i < old->vtop; i++) {
348 0 : if (mb->var[i].name)
349 0 : GDKfree(mb->var[i].name);
350 0 : VALclear(&mb->var[i].value);
351 : }
352 0 : GDKfree(mb->var);
353 0 : GDKfree(mb->stmt);
354 0 : GDKfree(mb);
355 0 : return NULL;
356 : }
357 :
358 : /* The MAL records should be managed from a pool to
359 : * avoid repeated alloc/free and reduce probability of
360 : * memory fragmentation. (todo)
361 : * The complicating factor is their variable size,
362 : * which leads to growing records as a result of pushArguments
363 : * Allocation of an instruction should always succeed.
364 : */
365 : InstrPtr
366 32282707 : newInstructionArgs(MalBlkPtr mb, const char *modnme, const char *fcnnme,
367 : int args)
368 : {
369 32282707 : InstrPtr p;
370 :
371 32282707 : if (mb && mb->errors)
372 : return NULL;
373 32282692 : if (args <= 0)
374 : args = 1;
375 32282692 : p = GDKmalloc(args * sizeof(p->argv[0]) + offsetof(InstrRecord, argv));
376 32280454 : if (p == NULL) {
377 0 : if (mb)
378 0 : mb->errors = createMalException(mb, 0, TYPE,
379 : SQLSTATE(HY013) MAL_MALLOC_FAIL);
380 0 : return NULL;
381 : }
382 32280454 : *p = (InstrRecord) {
383 : .maxarg = args,
384 : .typeresolved = false,
385 : .modname = modnme,
386 : .fcnname = fcnnme,
387 : .argc = 1,
388 : .retc = 1,
389 : /* Flow of control instructions are always marked as an assignment
390 : * with modifier */
391 : .token = ASSIGNsymbol,
392 : };
393 32280454 : memset(p->argv, 0, args * sizeof(p->argv[0]));
394 32280454 : p->argv[0] = -1;
395 32280454 : return p;
396 : }
397 :
398 : InstrPtr
399 2811039 : newInstruction(MalBlkPtr mb, const char *modnme, const char *fcnnme)
400 : {
401 2811039 : return newInstructionArgs(mb, modnme, fcnnme, MAXARG);
402 : }
403 :
404 : InstrPtr
405 14338116 : copyInstructionArgs(const InstrRecord *p, int args)
406 : {
407 14338116 : if (args < p->maxarg)
408 : args = p->maxarg;
409 14338116 : InstrPtr new = (InstrPtr) GDKmalloc(offsetof(InstrRecord, argv) +
410 : args * sizeof(p->argv[0]));
411 14338349 : if (new == NULL)
412 : return new;
413 14338349 : memcpy(new, p,
414 14338349 : offsetof(InstrRecord, argv) + p->maxarg * sizeof(p->argv[0]));
415 14338349 : if (args > p->maxarg)
416 1655827 : memset(new->argv + p->maxarg, 0,
417 1655827 : (args - p->maxarg) * sizeof(new->argv[0]));
418 14338349 : new->typeresolved = false;
419 14338349 : new->maxarg = args;
420 14338349 : return new;
421 : }
422 :
423 : InstrPtr
424 10500085 : copyInstruction(const InstrRecord *p)
425 : {
426 10500085 : return copyInstructionArgs(p, p->maxarg);
427 : }
428 :
429 : void
430 558387 : clrFunction(InstrPtr p)
431 : {
432 558387 : p->token = ASSIGNsymbol;
433 558387 : p->fcn = 0;
434 558387 : p->blk = 0;
435 558387 : p->typeresolved = false;
436 558387 : setModuleId(p, NULL);
437 558384 : setFunctionId(p, NULL);
438 558388 : }
439 :
440 : void
441 0 : clrInstruction(InstrPtr p)
442 : {
443 0 : clrFunction(p);
444 0 : memset(p, 0, offsetof(InstrRecord, argv) + p->maxarg * sizeof(p->argv[0]));
445 0 : }
446 :
447 : void
448 170044297 : freeInstruction(InstrPtr p)
449 : {
450 170044297 : GDKfree(p);
451 170014773 : }
452 :
453 : /* Query optimizers walk their way through a MAL program block. They
454 : * require some primitives to move instructions around and to remove
455 : * superfluous instructions. The removal is based on the assumption
456 : * that indeed the instruction belonged to the block. */
457 : void
458 0 : removeInstruction(MalBlkPtr mb, InstrPtr p)
459 : {
460 0 : int i;
461 0 : for (i = 0; i < mb->stop - 1; i++)
462 0 : if (mb->stmt[i] == p)
463 : break;
464 0 : if (i == mb->stop)
465 : return;
466 0 : for (; i < mb->stop - 1; i++)
467 0 : mb->stmt[i] = mb->stmt[i + 1];
468 0 : mb->stmt[i] = 0;
469 0 : mb->stop--;
470 0 : assert(i == mb->stop); /* move statement after stop */
471 0 : mb->stmt[i] = p;
472 : }
473 :
474 : void
475 0 : removeInstructionBlock(MalBlkPtr mb, int pc, int cnt)
476 : {
477 0 : int i;
478 0 : InstrPtr p;
479 0 : for (i = pc; i < pc + cnt; i++) {
480 0 : p = getInstrPtr(mb, i);
481 0 : freeInstruction(p);
482 0 : mb->stmt[i] = NULL;
483 0 : } for (i = pc; i < mb->stop - cnt; i++)
484 0 : mb->stmt[i] = mb->stmt[i + cnt];
485 0 : mb->stop -= cnt;
486 0 : for (; i < mb->stop; i++)
487 : mb->stmt[i] = 0;
488 0 : }
489 :
490 : void
491 0 : moveInstruction(MalBlkPtr mb, int pc, int target)
492 : {
493 0 : InstrPtr p;
494 0 : int i;
495 0 : p = getInstrPtr(mb, pc);
496 0 : if (pc > target) {
497 0 : for (i = pc; i > target; i--)
498 0 : mb->stmt[i] = mb->stmt[i - 1];
499 0 : mb->stmt[i] = p;
500 : } else {
501 0 : for (i = target; i > pc; i--)
502 0 : mb->stmt[i] = mb->stmt[i - 1];
503 0 : mb->stmt[i] = p;
504 : }
505 0 : }
506 :
507 : /* Beware that the first argument of a signature is reserved for the
508 : * function return type , which should be equal to the destination
509 : * variable type.
510 : */
511 : int
512 667140 : findVariable(MalBlkPtr mb, const char *name)
513 : {
514 667140 : int i;
515 667140 : if (name == NULL)
516 : return -1;
517 5957357 : for (i = mb->vtop - 1; i >= 0; i--)
518 5640397 : if (mb->var[i].name && idcmp(name, mb->var[i].name) == 0)
519 350180 : return i;
520 : return -1;
521 : }
522 :
523 : /* The second version of findVariable assumes you have not yet
524 : * allocated a private structure. This is particularly useful during
525 : * parsing, because most variables are already defined. This way we
526 : * safe GDKmalloc/GDKfree. */
527 : int
528 54383 : findVariableLength(MalBlkPtr mb, const char *name, int len)
529 : {
530 54383 : int i;
531 2568967 : for (i = mb->vtop - 1; i >= 0; i--) {
532 2525874 : const char *s = mb->var[i].name;
533 2525874 : if (s && strncmp(name, s, len) == 0 && s[len] == 0)
534 11290 : return i;
535 : }
536 : return -1;
537 : }
538 :
539 : str
540 174 : getArgDefault(MalBlkPtr mb, InstrPtr p, int idx)
541 : {
542 174 : ValPtr v = &getVarConstant(mb, getArg(p, idx));
543 174 : if (v->vtype == TYPE_str)
544 174 : return v->val.sval;
545 : return NULL;
546 : }
547 :
548 : /* Beware, the symbol table structure assumes that it is relatively
549 : * cheap to perform a linear search to a variable or constant. */
550 : static int
551 56920183 : makeVarSpace(MalBlkPtr mb)
552 : {
553 56920183 : if (mb->vtop >= mb->vsize) {
554 62130 : VarRecord *new;
555 62130 : int s = (mb->vtop / MALCHUNK + 1) * MALCHUNK;
556 62130 : new = (VarRecord *) GDKrealloc(mb->var, s * sizeof(VarRecord));
557 62130 : if (new == NULL) {
558 : /* the only place to return an error signal at this stage. */
559 : /* The Client context should be passed around more deeply */
560 0 : mb->errors = createMalException(mb, 0, TYPE, SQLSTATE(HY013) MAL_MALLOC_FAIL);
561 0 : return -1;
562 : }
563 62130 : memset(new + mb->vsize, 0, (s - mb->vsize) * sizeof(VarRecord));
564 62130 : mb->vsize = s;
565 62130 : mb->var = new;
566 : }
567 : return 0;
568 : }
569 :
570 : /* create and initialize a variable record*/
571 : void
572 56917132 : setVariableType(MalBlkPtr mb, const int n, malType type)
573 : {
574 56917132 : assert(n >= 0 && n < mb->vtop);
575 56917132 : setVarType(mb, n, type);
576 56917132 : setRowCnt(mb, n, 0);
577 56917132 : clrVarFixed(mb, n);
578 56917132 : clrVarUsed(mb, n);
579 56917132 : clrVarInit(mb, n);
580 56917132 : clrVarDisabled(mb, n);
581 56917132 : clrVarConstant(mb, n);
582 56917132 : clrVarCleanup(mb, n);
583 56917132 : }
584 :
585 : char *
586 20471 : getVarNameIntoBuffer(MalBlkPtr mb, int idx, char *buf)
587 : {
588 20471 : char *s = mb->var[idx].name;
589 20471 : if (getVarKind(mb, idx) == 0)
590 0 : setVarKind(mb, idx, REFMARKER);
591 20471 : if (s == NULL) {
592 20332 : (void) snprintf(buf, IDLENGTH, "%c_%d", getVarKind(mb, idx), idx);
593 : } else {
594 139 : (void) snprintf(buf, IDLENGTH, "%s", s);
595 : }
596 20471 : return buf;
597 : }
598 :
599 : int
600 56920286 : newVariable(MalBlkPtr mb, const char *name, size_t len, malType type)
601 : {
602 56920286 : int n;
603 56920286 : int kind = REFMARKER;
604 56920286 : if (mb->errors)
605 : return -1;
606 56920286 : if (len >= IDLENGTH) {
607 1 : mb->errors = createMalException(mb, 0, TYPE, "newVariable: id too long");
608 1 : return -1;
609 : }
610 56920285 : if (makeVarSpace(mb)) { /* no space for a new variable */
611 : return -1;
612 : }
613 56915521 : n = mb->vtop;
614 56915521 : mb->var[n].name = NULL;
615 56915521 : if (name && len > 0) {
616 364242 : char *nme = GDKmalloc(len+1);
617 364242 : if (!nme) {
618 0 : mb->errors = createMalException(mb, 0, TYPE, SQLSTATE(HY013) MAL_MALLOC_FAIL);
619 0 : return -1;
620 : }
621 364242 : mb->var[n].name = nme;
622 3037895 : for (size_t i = 0; i < len; i++)
623 2673653 : nme[i] = name[i];
624 364242 : nme[len] = 0;
625 364242 : kind = nme[0];
626 : }
627 56915521 : mb->vtop++;
628 56915521 : setVarKind(mb, n, kind);
629 56915521 : setVariableType(mb, n, type);
630 56915521 : return n;
631 : }
632 :
633 : /* Simplified cloning. */
634 : int
635 0 : cloneVariable(MalBlkPtr tm, MalBlkPtr mb, int x)
636 : {
637 0 : int res;
638 0 : if (isVarConstant(mb, x))
639 0 : res = cpyConstant(tm, getVar(mb, x));
640 : else {
641 0 : res = newTmpVariable(tm, getVarType(mb, x));
642 0 : if (mb->var[x].name)
643 0 : tm->var[x].name = GDKstrdup(mb->var[x].name);
644 : }
645 0 : if (res < 0)
646 : return res;
647 0 : if (isVarFixed(mb, x))
648 0 : setVarFixed(tm, res);
649 0 : if (isVarUsed(mb, x))
650 0 : setVarUsed(tm, res);
651 0 : if (isVarInit(mb, x))
652 0 : setVarInit(tm, res);
653 0 : if (isVarDisabled(mb, x))
654 0 : setVarDisabled(tm, res);
655 0 : if (isVarCleanup(mb, x))
656 0 : setVarCleanup(tm, res);
657 0 : getVarSTC(tm, x) = getVarSTC(mb, x);
658 0 : setVarKind(tm, x, getVarKind(mb, x));
659 0 : return res;
660 : }
661 :
662 : int
663 56555517 : newTmpVariable(MalBlkPtr mb, malType type)
664 : {
665 56555517 : return newVariable(mb, 0, 0, type);
666 : }
667 :
668 : int
669 274 : newTypeVariable(MalBlkPtr mb, malType type)
670 : {
671 274 : int n, i;
672 1284 : for (i = 0; i < mb->vtop; i++)
673 1053 : if (isVarTypedef(mb, i) && getVarType(mb, i) == type)
674 : break;
675 274 : if (i < mb->vtop)
676 : return i;
677 231 : n = newTmpVariable(mb, type);
678 231 : if (n >= 0)
679 231 : setVarTypedef(mb, n);
680 : return n;
681 : }
682 :
683 : void
684 72643 : clearVariable(MalBlkPtr mb, int varid)
685 : {
686 72643 : VarPtr v;
687 72643 : v = getVar(mb, varid);
688 72643 : if (isVarConstant(mb, varid) || isVarDisabled(mb, varid))
689 28140 : VALclear(&v->value);
690 72643 : if (v->name)
691 0 : GDKfree(v->name);
692 72643 : v->name = NULL;
693 72643 : v->type = 0;
694 72643 : v->constant = 0;
695 72643 : v->typevar = 0;
696 72643 : v->fixedtype = 0;
697 72643 : v->cleanup = 0;
698 72643 : v->initialized = 0;
699 72643 : v->used = 0;
700 72643 : v->rowcnt = 0;
701 72643 : v->eolife = 0;
702 72643 : v->stc = 0;
703 72643 : }
704 :
705 : void
706 55 : freeVariable(MalBlkPtr mb, int varid)
707 : {
708 55 : clearVariable(mb, varid);
709 55 : }
710 :
711 : /* A special action is to reduce the variable space by removing all
712 : * that do not contribute.
713 : * All temporary variables are renamed in the process to trim the varid.
714 : */
715 : void
716 3 : trimMalVariables_(MalBlkPtr mb, MalStkPtr glb)
717 : {
718 3 : int *alias, cnt = 0, i, j;
719 3 : InstrPtr q;
720 3 : if (mb->vtop == 0)
721 : return;
722 3 : alias = (int *) GDKzalloc(mb->vtop * sizeof(int));
723 3 : if (alias == NULL)
724 : return; /* forget it if we run out of memory *//* build the alias table */
725 473 : for (i = 0; i < mb->vtop; i++) {
726 470 : if (isVarUsed(mb, i) == 0) {
727 55 : if (glb && i < glb->stktop && isVarConstant(mb, i))
728 0 : VALclear(&glb->stk[i]);
729 55 : freeVariable(mb, i);
730 55 : continue;
731 : }
732 415 : if (i > cnt) { /* remap temporary variables */
733 355 : VarRecord t = mb->var[cnt];
734 355 : mb->var[cnt] = mb->var[i];
735 355 : mb->var[i] = t;
736 : } /* valgrind finds a leak when we move these variable record * pointers around. */
737 415 : alias[i] = cnt;
738 415 : if (glb && i < glb->stktop && i != cnt) {
739 0 : glb->stk[cnt] = glb->stk[i];
740 0 : VALempty(&glb->stk[i]);
741 : }
742 415 : cnt++;
743 : } /* remap all variable references to their new position. */
744 3 : if (cnt < mb->vtop) {
745 277 : for (i = 0; i < mb->stop; i++) {
746 274 : q = getInstrPtr(mb, i);
747 1523 : for (j = 0; j < q->argc; j++) {
748 1249 : getArg(q, j) = alias[getArg(q, j)];
749 : }
750 : }
751 3 : mb->vtop = cnt;
752 : }
753 3 : GDKfree(alias);
754 : }
755 :
756 : void
757 3 : trimMalVariables(MalBlkPtr mb, MalStkPtr stk)
758 : {
759 3 : int i, j;
760 3 : InstrPtr q; /* reset the use bit for all non-signature arguments */
761 473 : for (i = 0; i < mb->vtop; i++)
762 470 : clrVarUsed(mb, i); /* build the use table */
763 277 : for (i = 0; i < mb->stop; i++) {
764 274 : q = getInstrPtr(mb, i);
765 1523 : for (j = 0; j < q->argc; j++)
766 1249 : setVarUsed(mb, getArg(q, j));
767 : }
768 3 : trimMalVariables_(mb, stk);
769 3 : }
770 :
771 : /* MAL constants
772 : * Constants are stored in the symbol table and referenced by a
773 : * variable identifier. This means that per MAL instruction, we may
774 : * end up with MAXARG entries in the symbol table. This may lead to
775 : * long searches for variables. An optimization strategy deployed in
776 : * the current implementation is to look around for a similar
777 : * (constant) definition and to reuse its identifier. This avoids an
778 : * exploding symbol table with a lot of temporary variables (as in
779 : * tst400cHuge)
780 : *
781 : * But then the question becomes how far to search? Searching through
782 : * all variables is only useful when the list remains short or when
783 : * the constant-variable-name is easily derivable from its literal
784 : * value and a hash-based index leads you quickly to it.
785 : *
786 : * For the time being, we use a MAL system parameter, MAL_VAR_WINDOW,
787 : * to indicate the number of symbol table entries to consider. Setting
788 : * it to >= MAXARG will at least capture repeated use of a constant
789 : * within a single function call or repeated use within a small block
790 : * of code.
791 : *
792 : * The final step is to prepare a GDK value record, from which the
793 : * internal representation can be obtained during MAL interpretation.
794 : *
795 : * The constant values are linked together to improve searching
796 : * them. This start of the constant list is kept in the MalBlk.
797 : *
798 : * Conversion of a constant to another type is limited to well-known
799 : * coercion rules. Errors are reported and the nil value is set. */
800 :
801 : /* Converts the constant in vr to the MAL type type. Conversion is
802 : * done in the vr struct. */
803 : str
804 278346 : convertConstant(int type, ValPtr vr)
805 : {
806 278346 : if (type > GDKatomcnt)
807 0 : throw(SYNTAX, "convertConstant", "type index out of bound");
808 278346 : if (vr->vtype == type)
809 : return MAL_SUCCEED;
810 278343 : if (isaBatType(type)) { /* BAT variables can only be set to nil */
811 0 : if (vr->vtype != TYPE_void)
812 0 : throw(SYNTAX, "convertConstant", "BAT conversion error");
813 0 : VALclear(vr);
814 0 : vr->vtype = getBatType(type);
815 0 : vr->bat = true;
816 0 : vr->val.bval = bat_nil;
817 0 : return MAL_SUCCEED;
818 : }
819 278343 : if (type == TYPE_ptr) { /* all coercions should be avoided to protect against memory probing */
820 32 : if (vr->vtype == TYPE_void) {
821 32 : VALclear(vr);
822 32 : vr->vtype = type;
823 32 : vr->val.pval = NULL;
824 32 : return MAL_SUCCEED;
825 : }
826 0 : if (vr->vtype != type)
827 0 : throw(SYNTAX, "convertConstant", "pointer conversion error");
828 : return MAL_SUCCEED;
829 : }
830 278311 : if (type == TYPE_any) {
831 : #ifndef DEBUG_MAL_INSTR
832 : assert(0);
833 : #endif
834 0 : throw(SYNTAX, "convertConstant", "missing type");
835 : }
836 278311 : if (VALconvert(type, vr) == NULL) {
837 3 : if (vr->vtype == TYPE_str)
838 0 : throw(SYNTAX, "convertConstant", "parse error in '%s'", vr->val.sval);
839 3 : throw(SYNTAX, "convertConstant", "coercion failed");
840 : }
841 : return MAL_SUCCEED;
842 : }
843 :
844 : int
845 49494571 : fndConstant(MalBlkPtr mb, const ValRecord *cst, int depth)
846 : {
847 49494571 : int i, k;
848 49494571 : const void *p; /* pointers never match */
849 49494571 : if (ATOMstorage(cst->vtype) == TYPE_ptr)
850 : return -1;
851 49337712 : p = VALptr(cst);
852 49337712 : k = mb->vtop - depth;
853 49337712 : if (k < 0)
854 : k = 0;
855 537658998 : for (i = k; i < mb->vtop - 1; i++) {
856 517511910 : VarPtr v = getVar(mb, i);
857 517511910 : if (v->constant) {
858 212995987 : if (v && v->type == cst->vtype &&
859 120712812 : v->value.len == cst->len &&
860 201012023 : isaBatType(v->type) == cst->bat &&
861 100510464 : ATOMcmp(cst->vtype, VALptr(&v->value), p) == 0)
862 29181845 : return i;
863 : }
864 : }
865 : return -1;
866 : }
867 :
868 : int
869 3334 : cpyConstant(MalBlkPtr mb, VarPtr vr)
870 : {
871 3334 : int i;
872 3334 : ValRecord cst;
873 3334 : if (VALcopy(&cst, &vr->value) == NULL)
874 : return -1;
875 3334 : i = defConstant(mb, vr->type, &cst);
876 3334 : if (i < 0)
877 : return -1;
878 : return i;
879 : }
880 :
881 : int
882 44344303 : defConstant(MalBlkPtr mb, int type, ValPtr cst)
883 : {
884 44344303 : int k;
885 44344303 : str msg;
886 :
887 44344303 : assert(!isaBatType(type) || cst->bat);
888 44344303 : cst->bat = false;
889 44344303 : if (isaBatType(type)) {
890 467711 : if (cst->vtype == TYPE_void) {
891 467710 : cst->vtype = getBatType(type);
892 467710 : cst->bat = true;
893 467710 : cst->val.bval = bat_nil;
894 : } else {
895 1 : mb->errors = createMalException(mb, 0, TYPE, "BAT coercion error");
896 1 : VALclear(cst); // it could contain allocated space
897 1 : return -1;
898 : }
899 43876592 : } else if (cst->vtype != type && !isPolyType(type)) {
900 1920 : int otype = cst->vtype;
901 1920 : assert(type != TYPE_any); /* help Coverity */
902 1920 : msg = convertConstant(getBatType(type), cst);
903 1920 : if (msg) {
904 3 : str ft, tt; /* free old value */
905 3 : ft = getTypeName(otype);
906 3 : tt = getTypeName(type);
907 3 : if (ft && tt)
908 3 : mb->errors = createMalException(mb, 0, TYPE,
909 : "constant coercion error from %s to %s",
910 : ft, tt);
911 : else
912 0 : mb->errors = createMalException(mb, 0, TYPE,
913 : "constant coercion error");
914 3 : GDKfree(ft);
915 3 : GDKfree(tt);
916 3 : freeException(msg);
917 3 : VALclear(cst); /* it could contain allocated space */
918 3 : return -1;
919 : } else {
920 1917 : assert(cst->vtype == type);
921 : }
922 : }
923 44344299 : if (cst->vtype != TYPE_any) {
924 44343354 : k = fndConstant(mb, cst, MAL_VAR_WINDOW);
925 44320104 : if (k >= 0) { /* protect against leaks coming from constant reuse */
926 25576845 : VALclear(cst);
927 25576845 : return k;
928 : }
929 : }
930 18744204 : k = newTmpVariable(mb, type);
931 18757764 : if (k < 0) {
932 0 : VALclear(cst);
933 0 : return -1;
934 : }
935 18757764 : setVarConstant(mb, k);
936 18757764 : setVarFixed(mb, k);
937 18757764 : if (type >= 0 && type < GDKatomcnt && ATOMextern(type))
938 4704519 : setVarCleanup(mb, k);
939 : else
940 14053245 : clrVarCleanup(mb, k); /* if cst is external, we give its allocated buffer away, so clear * it to avoid confusion */
941 18757764 : getVarConstant(mb, k) = *cst;
942 18757764 : VALempty(cst);
943 18757764 : return k;
944 : }
945 :
946 : /* Argument handling
947 : * The number of arguments for procedures is currently
948 : * limited. Furthermore, we should assure that no variable is
949 : * referenced before being assigned. Failure to obey should mark the
950 : * instruction as type-error. */
951 : static InstrPtr
952 319 : extendInstruction(MalBlkPtr mb, InstrPtr p)
953 : {
954 319 : InstrPtr pn = p;
955 319 : if (p->argc == p->maxarg) {
956 319 : int space = p->maxarg * sizeof(p->argv[0]) + offsetof(InstrRecord, argv);
957 319 : pn = (InstrPtr) GDKrealloc(p, space + MAXARG * sizeof(p->argv[0]));
958 319 : if (pn == NULL) { /* In the exceptional case we can not allocate more space * then we show an exception, mark the block as erroneous * and leave the instruction as is. */
959 0 : mb->errors = createMalException(mb, 0, TYPE,
960 : SQLSTATE(HY013) MAL_MALLOC_FAIL);
961 0 : return p;
962 : }
963 319 : memset(((char *) pn) + space, 0, MAXARG * sizeof(pn->argv[0]));
964 319 : pn->maxarg += MAXARG;
965 : }
966 : return pn;
967 : }
968 :
969 : InstrPtr
970 119544835 : pushArgument(MalBlkPtr mb, InstrPtr p, int varid)
971 : {
972 119544835 : if (p == NULL || mb->errors)
973 : return p;
974 119544835 : if (varid < 0) { /* leave everything as is in this exceptional programming error */
975 0 : mb->errors = createMalException(mb, 0, TYPE, "improper variable id");
976 0 : return p;
977 : }
978 119544835 : if (p->argc == p->maxarg) {
979 : #ifndef NDEBUG
980 1011 : for (int i = 0; i < mb->stop; i++)
981 692 : assert(mb->stmt[i] != p);
982 : #endif
983 319 : p = extendInstruction(mb, p);
984 319 : if (mb->errors)
985 : return p;
986 : } /* protect against the case that the instruction is malloced in isolation */
987 119544835 : if (mb->maxarg < p->maxarg)
988 13916 : mb->maxarg = p->maxarg;
989 119544835 : p->argv[p->argc++] = varid;
990 119544835 : return p;
991 : }
992 :
993 : InstrPtr
994 838863 : setArgument(MalBlkPtr mb, InstrPtr p, int idx, int varid)
995 : {
996 838863 : int i;
997 838863 : if (p == NULL || mb->errors)
998 : return p;
999 838864 : p = pushArgument(mb, p, varid); /* make space */
1000 842815 : for (i = p->argc - 1; i > idx; i--)
1001 3952 : getArg(p, i) = getArg(p, i - 1);
1002 838863 : getArg(p, i) = varid;
1003 838863 : return p;
1004 : }
1005 :
1006 : InstrPtr
1007 839794 : pushReturn(MalBlkPtr mb, InstrPtr p, int varid)
1008 : {
1009 839794 : if (p == NULL || mb->errors)
1010 : return p;
1011 839794 : if (p->retc == 1 && p->argv[0] == -1) {
1012 931 : p->argv[0] = varid;
1013 931 : return p;
1014 : }
1015 838863 : p = setArgument(mb, p, p->retc, varid);
1016 838862 : p->retc++;
1017 838862 : return p;
1018 : }
1019 :
1020 : /* Store the information of a destination variable in the signature
1021 : * structure of each instruction. This code is largely equivalent to
1022 : * pushArgument, but it is more efficient in searching and collecting
1023 : * the information.
1024 : * TODO */
1025 : /* swallows name argument */
1026 : InstrPtr
1027 5431 : pushArgumentId(MalBlkPtr mb, InstrPtr p, const char *name)
1028 : {
1029 5431 : int v;
1030 5431 : if (p == NULL || mb->errors)
1031 : return p;
1032 5431 : v = findVariable(mb, name);
1033 5431 : if (v < 0) {
1034 389 : size_t namelen = strlen(name);
1035 389 : if ((v = newVariable(mb, name, namelen, getAtomIndex(name, namelen, TYPE_any))) < 0) {
1036 : /* set the MAL block to erroneous and simply return without
1037 : * doing anything */
1038 : /* mb->errors already set */
1039 : return p;
1040 : }
1041 : }
1042 5430 : return pushArgument(mb, p, v);
1043 : }
1044 :
1045 : /* The alternative is to remove arguments from an instruction
1046 : * record. This is typically part of instruction constructions. */
1047 : void
1048 1401982 : delArgument(InstrPtr p, int idx)
1049 : {
1050 1401982 : int i;
1051 1784495 : for (i = idx; i < p->argc - 1; i++)
1052 382513 : p->argv[i] = p->argv[i + 1];
1053 1401982 : p->argc--;
1054 1401982 : if (idx < p->retc)
1055 98997 : p->retc--;
1056 1401982 : }
1057 :
1058 : void
1059 33015 : setArgType(MalBlkPtr mb, InstrPtr p, int i, int tpe)
1060 : {
1061 33015 : assert(p->argv[i] < mb->vsize);
1062 33015 : setVarType(mb, getArg(p, i), tpe);
1063 33015 : }
1064 :
1065 : void
1066 0 : setReturnArgument(InstrPtr p, int i)
1067 : {
1068 0 : setDestVar(p, i);
1069 0 : }
1070 :
1071 : malType
1072 0 : destinationType(MalBlkPtr mb, InstrPtr p)
1073 : {
1074 0 : if (p->argc > 0)
1075 0 : return getVarType(mb, getDestVar(p));
1076 : return TYPE_any;
1077 : }
1078 :
1079 : /* For polymorphic instructions we should keep around the maximal
1080 : * index to later allocate sufficient space for type resolutions maps.
1081 : * Beware, that we should only consider the instruction polymorphic if
1082 : * it has a positive index or belongs to the signature.
1083 : * BATs can only have a polymorphic type at the tail.
1084 : */
1085 : inline void
1086 9283 : setPolymorphic(InstrPtr p, int tpe, int force /* just any isn't polymorphic */)
1087 : {
1088 9283 : int any = isAnyExpression(tpe) || tpe == TYPE_any, index = 0;
1089 9283 : if ((force == FALSE && tpe == TYPE_any) || !any)
1090 : return;
1091 34 : if (getTypeIndex(tpe) > 0)
1092 : index = getTypeIndex(tpe);
1093 34 : if (any && (index + 1) >= p->polymorphic)
1094 31 : p->polymorphic = index + 1;
1095 : }
1096 :
1097 : /* Instructions are simply appended to a MAL block. It should always succeed.
1098 : * The assumption is to push it when you are completely done with its preparation.
1099 : */
1100 : void
1101 252543744 : pushInstruction(MalBlkPtr mb, InstrPtr p)
1102 : {
1103 252543744 : int i;
1104 252543744 : InstrPtr q;
1105 252543744 : if (p == NULL)
1106 : return;
1107 252543744 : if (mb->stop + 1 >= mb->ssize) {
1108 32268 : int s = (mb->ssize / MALCHUNK + 1) * MALCHUNK;
1109 32268 : if (resizeMalBlk(mb, s) < 0) {
1110 : /* we are now left with the situation that the new
1111 : * instruction is dangling. The hack is to take an
1112 : * instruction out of the block that is likely not
1113 : * referenced independently. The last resort is to take the
1114 : * first, which should always be there. This assumes that
1115 : * no references are kept elsewhere to the statement. */
1116 0 : assert(mb->errors != NULL);
1117 0 : for (i = 1; i < mb->stop; i++) {
1118 0 : q = getInstrPtr(mb, i);
1119 0 : if (q->token == REMsymbol) {
1120 0 : freeInstruction(q);
1121 0 : mb->stmt[i] = p;
1122 0 : return;
1123 : }
1124 : }
1125 0 : freeInstruction(getInstrPtr(mb, 0));
1126 0 : mb->stmt[0] = p;
1127 0 : return;
1128 : }
1129 : }
1130 252543744 : if (mb->stmt[mb->stop])
1131 19114 : freeInstruction(mb->stmt[mb->stop]);
1132 252536715 : p->pc = mb->stop;
1133 252536715 : mb->stmt[mb->stop++] = p;
1134 : }
|
