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 : /* Author(s) M.L. Kersten, N. Nes
14 : * This module takes the statically defined modules, atoms, commands and patterns
15 : * and populate the internal structures.
16 : *
17 : */
18 :
19 : #include "monetdb_config.h"
20 : #include "mal_import.h"
21 : #include "mal_interpreter.h" /* for showErrors() */
22 : #include "mal_linker.h" /* for loadModuleLibrary() */
23 : #include "mal_scenario.h"
24 : #include "mal_parser.h"
25 : #include "mal_authorize.h"
26 : #include "mal_private.h"
27 : #include "mutils.h"
28 :
29 : #include "mal_prelude.h"
30 :
31 : #define MAX_MAL_MODULES 128
32 : static int mel_modules = 0, mel_modules_loaded = 0;
33 : static struct mel_module {
34 : const char *name;
35 : mel_atom *atoms;
36 : mel_func *funcs;
37 : mel_init inits;
38 : const char *code;
39 : } mel_module[MAX_MAL_MODULES];
40 :
41 : int
42 328 : mal_startup(void)
43 : {
44 : /* clean up the MAL internal structures before restart */
45 328 : mel_modules_loaded = 0;
46 328 : return 0;
47 : }
48 :
49 : /* all MAL related functions register themselves
50 : * the order in which these registrations happen is significant
51 : * because there may be dependencies among the definitions.
52 : * For example, you better know the atoms before you use them
53 : */
54 :
55 : void
56 3217 : mal_module2(const char *name, mel_atom *atoms, mel_func *funcs,
57 : mel_init initfunc, const char *code)
58 : {
59 3217 : assert(mel_modules < MAX_MAL_MODULES);
60 3217 : mel_module[mel_modules].name = name;
61 3217 : mel_module[mel_modules].atoms = atoms;
62 3217 : mel_module[mel_modules].funcs = funcs;
63 3217 : mel_module[mel_modules].inits = initfunc;
64 3217 : mel_module[mel_modules].code = code;
65 3217 : mel_modules++;
66 3217 : }
67 :
68 : void
69 14753 : mal_module(const char *name, mel_atom *atoms, mel_func *funcs)
70 : {
71 14753 : assert(mel_modules < MAX_MAL_MODULES);
72 14753 : mel_module[mel_modules].name = name;
73 14753 : mel_module[mel_modules].atoms = atoms;
74 14753 : mel_module[mel_modules].funcs = funcs;
75 14753 : mel_module[mel_modules].inits = NULL;
76 14753 : mel_module[mel_modules].code = NULL;
77 14753 : mel_modules++;
78 14753 : }
79 :
80 : static char *
81 15371 : initModule(Client c, const char *name, const char *initpasswd)
82 : {
83 15371 : char *msg = MAL_SUCCEED;
84 :
85 15371 : if (!getName(name))
86 : return msg;
87 15371 : if ((name = putName(name)) == NULL)
88 0 : throw(LOADER, __func__, SQLSTATE(HY013) MAL_MALLOC_FAIL);
89 15371 : Module m = getModule(name);
90 15371 : if (m) { /* run prelude */
91 12419 : const char *prelude = putName("prelude");
92 12419 : if (prelude == NULL)
93 0 : throw(LOADER, __func__, SQLSTATE(HY013) MAL_MALLOC_FAIL);
94 12419 : Symbol s = findSymbolInModule(m, prelude);
95 :
96 12419 : if (s) {
97 654 : if (s && s->kind == COMMANDsymbol && s->func && s->func->argc == 1) {
98 0 : int ret = 0;
99 :
100 0 : assert(s->func != NULL);
101 0 : msg = (*(str (*)(int *)) s->func->imp) (&ret);
102 0 : (void) ret;
103 654 : } else if (s && s->kind == PATTERNsymbol) {
104 654 : void *mb = NULL;
105 654 : assert(s->func->fcn != NULL);
106 654 : if (strcmp(name, "sql") == 0) {
107 : /* HACK ALERT: temporarily use sqlcontext to pass
108 : * the initial password to the prelude function */
109 328 : assert(c->sqlcontext == NULL);
110 328 : c->sqlcontext = (void *) initpasswd;
111 : /* HACK ALERT: use mb (MalBlkPtr) to pass revision
112 : * string in order to check that in the callee */
113 328 : mb = (void *) mercurial_revision();
114 : }
115 654 : msg = (*(str (*)(Client, MalBlkPtr, MalStkPtr, InstrPtr)) s->func->pimp) (c, mb, NULL, NULL);
116 : }
117 : }
118 : }
119 : return msg;
120 : }
121 :
122 : /*
123 : * The statically description of the MAL structures call for a translation into
124 : * their underlying structure.
125 : */
126 : static str
127 2940 : addAtom(mel_atom *atoms)
128 : {
129 6840 : for (; atoms && atoms->name[0]; atoms++) {
130 3900 : int i = ATOMallocate(atoms->name);
131 3900 : if (is_int_nil(i))
132 0 : throw(TYPE, __func__, GDK_EXCEPTION);
133 3900 : if (atoms->basetype[0]) {
134 2940 : int tpe = ATOMindex(atoms->basetype);
135 2940 : if (tpe < 0)
136 0 : throw(TYPE, __func__, TYPE_NOT_SUPPORTED);
137 2940 : BATatoms[i] = BATatoms[tpe];
138 2940 : strcpy_len(BATatoms[i].name, atoms->name, sizeof(BATatoms[i].name));
139 2940 : BATatoms[i].storage = ATOMstorage(tpe);
140 : } else { /* cannot overload void atoms */
141 960 : BATatoms[i].storage = i;
142 960 : BATatoms[i].linear = false;
143 : }
144 3900 : if (atoms->del)
145 632 : BATatoms[i].atomDel = atoms->del;
146 3900 : if (atoms->cmp) {
147 1276 : BATatoms[i].atomCmp = atoms->cmp;
148 1276 : BATatoms[i].linear = true;
149 : }
150 3900 : if (atoms->fromstr)
151 2916 : BATatoms[i].atomFromStr = atoms->fromstr;
152 3900 : if (atoms->tostr)
153 2916 : BATatoms[i].atomToStr = atoms->tostr;
154 3900 : if (atoms->heap) {
155 632 : BATatoms[i].size = sizeof(var_t);
156 632 : assert_shift_width(ATOMelmshift(ATOMsize(i)), ATOMsize(i));
157 632 : BATatoms[i].atomHeap = atoms->heap;
158 : }
159 3900 : if (atoms->hash)
160 948 : BATatoms[i].atomHash = atoms->hash;
161 3900 : if (atoms->length)
162 632 : BATatoms[i].atomLen = atoms->length;
163 3900 : if (atoms->null) {
164 1276 : const void *atmnull = (*atoms->null) ();
165 :
166 1276 : BATatoms[i].atomNull = atmnull;
167 : }
168 3900 : if (atoms->nequal)
169 0 : BATatoms[i].atomCmp = atoms->nequal;
170 3900 : if (atoms->put)
171 632 : BATatoms[i].atomPut = atoms->put;
172 3900 : if (atoms->storage)
173 0 : BATatoms[i].storage = (*atoms->storage) ();
174 3900 : if (atoms->read)
175 948 : BATatoms[i].atomRead = atoms->read;
176 3900 : if (atoms->write)
177 948 : BATatoms[i].atomWrite = atoms->write;
178 : }
179 : return MAL_SUCCEED;
180 : }
181 :
182 : static malType
183 12777646 : makeMalType(mel_arg *a)
184 : {
185 12777646 : malType tpe = TYPE_any;
186 :
187 12777646 : if (!a->type[0]) {
188 415890 : a->typeid = tpe;
189 415890 : if (a->isbat)
190 328652 : tpe = newBatType(tpe);
191 415890 : if (a->nr > 0)
192 383100 : setTypeIndex(tpe, a->nr);
193 : } else {
194 12361756 : tpe = getAtomIndex(a->type, strlen(a->type), -1);
195 12361756 : a->typeid = tpe;
196 12361756 : if (a->isbat)
197 7393091 : tpe = newBatType(tpe);
198 : }
199 12777646 : if (a->opt == 1)
200 154816 : setOptBat(tpe);
201 12777646 : return tpe;
202 : }
203 :
204 : void
205 738974 : setPoly(mel_func *f, malType tpe)
206 : {
207 724236 : int any = isAnyExpression(tpe) || tpe == TYPE_any || getOptBat(tpe);
208 1274282 : unsigned int index = 0;
209 : if (!any)
210 : return;
211 550046 : if (getTypeIndex(tpe) > 0)
212 : index = getTypeIndex(tpe);
213 535308 : if (any && (index + 1) > f->poly)
214 304998 : f->poly = index + 1;
215 : }
216 :
217 : static str
218 18323 : addFunctions(mel_func *fcn)
219 : {
220 18323 : str msg = MAL_SUCCEED;
221 18323 : Module c;
222 18323 : Symbol s;
223 :
224 1723875 : for (; fcn && fcn->mod; fcn++) {
225 1705552 : const char *mod = fcn->mod = putName(fcn->mod);
226 1705552 : fcn->fcn = putName(fcn->fcn);
227 1705552 : if (mod == NULL)
228 0 : throw(LOADER, __func__, SQLSTATE(HY013) MAL_MALLOC_FAIL);
229 1705552 : c = getModule(mod);
230 1705552 : if (c == NULL && (c = globalModule(mod)) == NULL)
231 0 : throw(LOADER, __func__, "Module %s can not be created", fcn->mod);
232 :
233 2879212 : s = newSymbol(fcn->fcn, (fcn->command) ? COMMANDsymbol : PATTERNsymbol);
234 1705552 : if (s == NULL)
235 0 : throw(LOADER, __func__, "Can not create symbol for %s.%s missing", fcn->mod,
236 : fcn->fcn);
237 1705552 : s->def = NULL;
238 1705552 : s->func = fcn;
239 1705552 : s->allocated = false;
240 :
241 : /* add the return variables */
242 1705552 : unsigned int i;
243 3516144 : for (i = 0; i < fcn->retc; i++) {
244 1810592 : mel_arg *a = fcn->args + i;
245 1810592 : malType tpe = makeMalType(a);
246 1810592 : if (a->nr > 0 || a->opt)
247 56764 : setPoly(fcn, tpe);
248 1810592 : if (a->vargs) {
249 3118 : fcn->vrets = true;
250 3118 : setPoly(fcn, TYPE_any);
251 : }
252 1810592 : if (a->opt && fcn->command)
253 0 : throw(LOADER, __func__, "Can not have command symbol with dynamic types, ie bat vs scalar in %s.%s", fcn->mod, fcn->fcn);
254 : /*
255 : if (a->nr >= 2)
256 : printf("%s.%s\n", fcn->mod, fcn->fcn);
257 : */
258 : }
259 : /* add the arguments */
260 6123102 : for (i = fcn->retc; i < fcn->argc; i++) {
261 4417550 : mel_arg *a = fcn->args + i;
262 4417550 : malType tpe = makeMalType(a);
263 :
264 4417550 : if (a->nr > 0 || a->opt)
265 447040 : setPoly(fcn, tpe);
266 4417550 : if (a->vargs) {
267 11620 : fcn->vargs = true;
268 11620 : setPoly(fcn, TYPE_any);
269 : }
270 4417550 : if (a->opt && fcn->command)
271 0 : throw(LOADER, __func__, "Can not have command symbol with dynamic types, ie bat vs scalar in %s.%s", fcn->mod, fcn->fcn);
272 : /*
273 : if (a->nr >= 2)
274 : printf("%s.%s\n", fcn->mod, fcn->fcn);
275 : */
276 : }
277 1705552 : insertSymbol(c, s);
278 : }
279 : return msg;
280 : }
281 :
282 : static void
283 6549504 : argCopy( mel_arg *ap, mel_func_arg *a)
284 : {
285 6549504 : ap->typeid = a->type;
286 6549504 : ap->nr = a->nr;
287 6549504 : ap->isbat = a->isbat;
288 6549504 : ap->vargs = a->vargs;
289 6549504 : ap->opt = a->opt;
290 6549504 : if (a->type != TYPE_any)
291 6517360 : strcpy(ap->type, BATatoms[a->type].name);
292 : else
293 32144 : ap->type[0] = 0;
294 6549504 : }
295 :
296 : int
297 1633112 : melFunction(bool command, const char *mod, const char *fcn, MALfcn imp,
298 : const char *fname, bool unsafe, const char *comment, int retc,
299 : int argc, ...)
300 : {
301 1633112 : int i;
302 1633112 : Module c;
303 1633112 : Symbol s;
304 1633112 : mel_func *f = NULL;
305 1633112 : va_list va;
306 :
307 1633112 : assert(mod && fcn);
308 1633112 : mod = putName(mod);
309 1633112 : fcn = putName(fcn);
310 1633112 : c = getModule(mod);
311 1633112 : if (c == NULL && (c = globalModule(mod)) == NULL)
312 : return MEL_ERR;
313 :
314 3266224 : s = newSymbol(fcn, command ? COMMANDsymbol : PATTERNsymbol);
315 1633112 : if (s == NULL)
316 : return MEL_ERR;
317 1633112 : fcn = s->name;
318 1633112 : s->allocated = true;
319 :
320 1633112 : f = (mel_func*)GDKmalloc(sizeof(mel_func));
321 1633112 : mel_arg *args = (mel_arg*)GDKmalloc(sizeof(mel_arg)*argc);
322 1633112 : if (!f || !args) {
323 0 : if(!f) GDKfree(f);
324 0 : freeSymbol(s);
325 0 : return MEL_ERR;
326 : }
327 1633112 : f->mod = mod;
328 1633112 : f->fcn = fcn;
329 1633112 : f->command = command;
330 1633112 : f->unsafe = unsafe;
331 1633112 : f->vargs = 0;
332 1633112 : f->vrets = 0;
333 1633112 : f->poly = 0;
334 1633112 : f->retc = retc;
335 1633112 : f->argc = argc;
336 1633112 : f->args = args;
337 1633112 : f->imp = imp;
338 1633112 : f->comment = comment?GDKstrdup(comment):NULL;
339 1633112 : f->cname = fname?GDKstrdup(fname):NULL;
340 1633112 : s->def = NULL;
341 1633112 : s->func = f;
342 :
343 1633112 : va_start(va, argc);
344 3275408 : for (i = 0; i < retc; i++) {
345 1642296 : mel_func_arg a = va_arg(va, mel_func_arg);
346 1642296 : mel_arg *ap = f->args+i;
347 1642296 : argCopy(ap, &a);
348 1642296 : malType tpe = makeMalType(ap);
349 1642296 : if (a.nr > 0 || a.opt)
350 0 : setPoly(f, tpe);
351 1642296 : if (a.vargs) {
352 0 : f->vrets = true;
353 0 : setPoly(f, TYPE_any);
354 : }
355 1642296 : if (a.opt && f->command)
356 0 : return MEL_ERR;
357 : /*
358 : if (a.nr >= 2)
359 : printf("%s.%s\n", f->mod, f->fcn);
360 : */
361 : }
362 : /* add the arguments */
363 6540320 : for (i = retc; i < argc; i++) {
364 4907208 : mel_func_arg a = va_arg(va, mel_func_arg);
365 4907208 : mel_arg *ap = f->args+i;
366 4907208 : argCopy(ap, &a);
367 4907208 : malType tpe = makeMalType(ap);
368 4907208 : if (a.nr > 0 || a.opt)
369 220416 : setPoly(f, tpe);
370 4907208 : if (a.vargs) {
371 0 : f->vargs = true;
372 0 : setPoly(f, TYPE_any);
373 : }
374 4907208 : if (a.opt && f->command)
375 0 : return MEL_ERR;
376 : /*
377 : if (a.nr >= 2)
378 : printf("%s.%s\n", f->mod, f->fcn);
379 : */
380 : }
381 1633112 : insertSymbol(c, s);
382 1633112 : va_end(va);
383 1633112 : return MEL_OK;
384 : }
385 :
386 : static str
387 328 : malPrelude(Client c, int listing, int *sql, int *mapi)
388 : {
389 328 : int i;
390 328 : str msg = MAL_SUCCEED;
391 :
392 328 : (void) listing;
393 : /* Add all atom definitions */
394 18651 : for (i = mel_modules_loaded; i < mel_modules; i++) {
395 18323 : if (mel_module[i].atoms) {
396 2940 : msg = addAtom(mel_module[i].atoms);
397 2940 : if (msg)
398 0 : return msg;
399 : }
400 : }
401 :
402 : /* Add the signatures, where we now have access to all atoms */
403 18651 : for (i = mel_modules_loaded; i < mel_modules; i++) {
404 18323 : const char *name = putName(mel_module[i].name);
405 18323 : if (!malLibraryEnabled(name))
406 0 : continue;
407 18323 : if (mel_module[i].funcs) {
408 18323 : msg = addFunctions(mel_module[i].funcs);
409 18323 : if (!msg && mel_module[i].code) /* some modules may also have some function definitions */
410 0 : msg = malIncludeString(c, name, (str) mel_module[i].code, listing, NULL);
411 18323 : if (msg)
412 0 : return msg;
413 :
414 : /* mapi should be last, and sql last before mapi */
415 18323 : if (strcmp(name, "sql") == 0) {
416 328 : *sql = i;
417 328 : continue;
418 : }
419 17995 : if (strcmp(name, "mapi") == 0) {
420 328 : *mapi = i;
421 328 : continue;
422 : }
423 17667 : if (!mel_module[i].inits) {
424 15043 : msg = initModule(c, name, NULL);
425 15043 : if (msg)
426 0 : return msg;
427 : }
428 : }
429 17667 : if (mel_module[i].inits) {
430 : /* mapi should be last, and sql last before mapi */
431 2624 : if (strcmp(name, "sql") == 0 || strcmp(name, "mapi") == 0)
432 0 : continue;
433 2624 : msg = mel_module[i].inits();
434 2624 : if (msg)
435 0 : return msg;
436 : }
437 : }
438 328 : mel_modules_loaded = mel_modules;
439 328 : return MAL_SUCCEED;
440 : }
441 :
442 : str
443 328 : malIncludeModules(Client c, char *modules[], int listing, bool no_mapi_server,
444 : const char *initpasswd)
445 : {
446 328 : str msg;
447 328 : int sql = -1, mapi = -1;
448 :
449 3509 : for (int i = 0; modules[i]; i++) {
450 : /* load library */
451 3181 : if (!malLibraryEnabled(modules[i]))
452 926 : continue;
453 2255 : if ((msg = loadLibrary(modules[i], listing)) != NULL)
454 0 : return msg;
455 : }
456 : /* load the mal code for these modules and execute preludes */
457 328 : if ((msg = malPrelude(c, listing, &sql, &mapi)) != NULL)
458 : return msg;
459 : /* mapi should be last, and sql last before mapi */
460 328 : if (sql >= 0) {
461 328 : if (mel_module[sql].inits)
462 0 : msg = mel_module[sql].inits();
463 : else
464 328 : msg = initModule(c, "sql", initpasswd);
465 327 : if (msg)
466 : return msg;
467 : }
468 327 : if (!no_mapi_server && mapi >= 0 && initpasswd == NULL) {
469 315 : if (mel_module[mapi].inits)
470 315 : msg = mel_module[mapi].inits();
471 : else
472 0 : msg = initModule(c, "mapi", NULL);
473 315 : if (msg)
474 : return msg;
475 : }
476 : return MAL_SUCCEED;
477 : }
|
