LCOV - code coverage report
Current view: top level - monetdb5/mal - mal_resolve.c (source / functions) Hit Total Coverage
Test: coverage.info Lines: 355 368 96.5 %
Date: 2024-04-25 21:43:30 Functions: 11 11 100.0 %

          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) M. Kersten
      15             :  *
      16             :  * Search the first definition of the operator in the current module
      17             :  * and check the parameter types.
      18             :  * For a polymorphic MAL function we make a fully instantiated clone.
      19             :  * It will be prepended to the symbol list as it is more restrictive.
      20             :  * This effectively overloads the MAL procedure.
      21             :  */
      22             : #include "monetdb_config.h"
      23             : #include "mal_resolve.h"
      24             : #include "mal_namespace.h"
      25             : #include "mal_private.h"
      26             : #include "mal_linker.h"
      27             : 
      28             : #define MAXTYPEVAR  4
      29             : 
      30             : static malType getPolyType(malType t, int *polytype);
      31             : static int updateTypeMap(int formal, int actual, int polytype[MAXTYPEVAR]);
      32             : static bool typeResolved(MalBlkPtr mb, InstrPtr p, int i);
      33             : 
      34             : int
      35   195136748 : resolvedType(int dsttype, int srctype)
      36             : {
      37   195136748 :         if (dsttype == srctype || dsttype == TYPE_any || srctype == TYPE_any)
      38             :                 return 0;
      39             : 
      40   121575056 :         if (getOptBat(dsttype) && isaBatType(srctype)) {
      41        2400 :                 int t1 = getBatType(dsttype);
      42        2400 :                 int t2 = getBatType(srctype);
      43        2400 :                 if (t1 == t2 || t1 == TYPE_any || t2 == TYPE_any)
      44             :                         return 0;
      45             :         }
      46       12281 :         if (getOptBat(dsttype) && !isaBatType(srctype)) {
      47       10357 :                 int t1 = getBatType(dsttype);
      48       10357 :                 int t2 = srctype;
      49       10357 :                 if (t1 == t2 || t1 == TYPE_any || t2 == TYPE_any)
      50             :                         return 0;
      51             :         }
      52             : 
      53   121574429 :         if (isaBatType(dsttype) && isaBatType(srctype)) {
      54    83855677 :                 int t1 = getBatType(dsttype);
      55    83855677 :                 int t2 = getBatType(srctype);
      56    83855677 :                 if (t1 == t2 || t1 == TYPE_any || t2 == TYPE_any)
      57    47863551 :                         return 0;
      58             :         }
      59             :         return -1;
      60             : }
      61             : 
      62             : static int
      63    54855719 : resolveType(int *rtype, int dsttype, int srctype)
      64             : {
      65    54855719 :         if (dsttype == srctype) {
      66    23363052 :                 *rtype = dsttype;
      67    23363052 :                 return 0;
      68             :         }
      69    31492667 :         if (dsttype == TYPE_any) {
      70     3591037 :                 *rtype = srctype;
      71     3591037 :                 return 0;
      72             :         }
      73    27901630 :         if (srctype == TYPE_any) {
      74    19746036 :                 *rtype = dsttype;
      75    19746036 :                 return 0;
      76             :         }
      77             :         /*
      78             :          * A bat reference can be coerced to bat type.
      79             :          */
      80     8155594 :         if (isaBatType(dsttype) && isaBatType(srctype)) {
      81     8127089 :                 int t1, t2, t3;
      82     8127089 :                 t1 = getBatType(dsttype);
      83     8127089 :                 t2 = getBatType(srctype);
      84     8127089 :                 if (t1 == t2)
      85             :                         t3 = t1;
      86     8127086 :                 else if (t1 == TYPE_any)
      87             :                         t3 = t2;
      88      116778 :                 else if (t2 == TYPE_any)
      89             :                         t3 = t1;
      90             :                 else {
      91             :                         return -1;
      92             :                 }
      93     8010317 :                 *rtype = newBatType(t3);
      94     8010317 :                 return 0;
      95             :         }
      96             :         return -1;
      97             : }
      98             : 
      99             : 
     100             : /*
     101             :  * Since we now know the storage type of the receiving variable, we can
     102             :  * set the garbage collection flag.
     103             :  */
     104             : #define prepostProcess(tp, p, b, mb)                                    \
     105             :         do {                                                                                            \
     106             :                 if( isaBatType(tp) ||                                                   \
     107             :                         ATOMtype(tp) == TYPE_str ||                                     \
     108             :                         (!isPolyType(tp) && tp < TYPE_any &&         \
     109             :                          tp >= 0 && ATOMextern(tp))) {                               \
     110             :                         getInstrPtr(mb, 0)->gc = true;                               \
     111             :                         setVarCleanup(mb, getArg(p, b));                        \
     112             :                         p->gc = true;                                                                \
     113             :                 }                                                                                               \
     114             :         } while (0)
     115             : 
     116             : static malType
     117   313671126 : getFormalArgType( Symbol s, int arg)
     118             : {
     119   313671126 :         if (s->kind == FUNCTIONsymbol)
     120       38907 :                 return getArgType(s->def, getSignature(s), arg);
     121   313632219 :         mel_arg *a = s->func->args+arg;
     122   313632219 :         malType tpe = TYPE_any;
     123   313632219 :         if (a->nr || !a->type[0]) {
     124   118257782 :                 if (a->isbat)
     125             :                         tpe = newBatType(TYPE_any);
     126             :                 else
     127    17877534 :                         tpe = a->typeid;
     128   118257782 :                 setTypeIndex(tpe, a->nr);
     129             :         } else {
     130   195374437 :                 if (a->isbat)
     131    74139348 :                         tpe = newBatType(a->typeid);
     132             :                 else
     133   121235089 :                         tpe = a->typeid;
     134             :         }
     135   313632219 :         if (a->opt == 1)
     136       30663 :                 setOptBat(tpe);
     137             :         return tpe;
     138             : }
     139             : 
     140             : static malType
     141    55767023 : findFunctionType(Module scope, MalBlkPtr mb, InstrPtr p, int idx, int silent)
     142             : {
     143    55767023 :         Module m;
     144    55767023 :         Symbol s;
     145    55767023 :         int i, k, unmatched = 0, s1;
     146    55767023 :         int polytype[MAXTYPEVAR];
     147    55767023 :         int returns[256];
     148    55767023 :         int *returntype = NULL;
     149             :         /*
     150             :          * Within a module find the element in its list
     151             :          * of symbols. A skiplist is used to speed up the search for the
     152             :          * definition of the function.
     153             :          *
     154             :          * For the implementation we should be aware that over 90% of the
     155             :          * functions in the kernel have just a few arguments and a single
     156             :          * return value.
     157             :          * A point of concern is that polymorphic arithmetic operations
     158             :          * lead to an explosion in the symbol table. This increase the
     159             :          * loop to find a candidate.
     160             :          *
     161             :          * Consider to collect the argument type into a separate structure, because
     162             :          * it will be looked up multiple types to resolve the instruction.[todo]
     163             :          * Simplify polytype using a map into the concrete argument table.
     164             :          */
     165             : 
     166    55767023 :         m = scope;
     167    55767023 :         s = m->space[(int) (getSymbolIndex(getFunctionId(p)))];
     168    55767023 :         if (s == 0)
     169             :                 return -1;
     170             : 
     171    55766793 :         if (p->retc < 256) {
     172   115081762 :                 for (i = 0; i < p->retc; i++)
     173    59315009 :                         returns[i] = 0;
     174    55766793 :                 returntype = returns;
     175             :         } else {
     176          40 :                 returntype = (int *) GDKzalloc(p->retc * sizeof(int));
     177          40 :                 if (returntype == 0)
     178             :                         return -1;
     179             :         }
     180             : 
     181   358679408 :         while (s != NULL) {                     /* single scope element check */
     182   358678722 :                 if (getFunctionId(p) != s->name) {
     183   107119734 :                         s = s->skip;
     184   107119734 :                         continue;
     185             :                 }
     186             :                 /*
     187             :                  * Perform a strong type-check on the actual arguments. If it
     188             :                  * turns out to be a polymorphic MAL function, we have to
     189             :                  * clone it.  Provided the actual/formal parameters are
     190             :                  * compliant throughout the function call.
     191             :                  *
     192             :                  * Also look out for variable argument lists. This means that
     193             :                  * we have to keep two iterators, one for the caller (i) and
     194             :                  * one for the callee (k). Since a variable argument only
     195             :                  * occurs as the last one, we simple avoid an increment when
     196             :                  * running out of formal arguments.
     197             :                  *
     198             :                  * A call of the form (X1,..., Xi) := f(Y1,....,Yn) can be
     199             :                  * matched against the function signature (B1,...,Bk):=
     200             :                  * f(A1,...,Am) where i==k , n<=m and
     201             :                  * type(Ai)=type(Yi). Furthermore, the variables Xi obtain
     202             :                  * their type from Bi (or type(Bi)==type(Xi)).
     203             :                  */
     204   251558988 :                 int argc = 0, argcc = 0, retc = 0, varargs = 0, varrets = 0, unsafe = 0, inlineprop = 0, polymorphic = 0;
     205   251558988 :                 if (s->kind == FUNCTIONsymbol) {
     206        9730 :                         InstrPtr sig = getSignature(s);
     207        9730 :                         retc = sig->retc;
     208        9730 :                         argc = sig->argc;
     209        9730 :                         varargs = (sig->varargs & (VARARGS | VARRETS));
     210        9730 :                         varrets = (sig->varargs & VARRETS);
     211        9730 :                         unsafe = s->def->unsafeProp;
     212        9730 :                         inlineprop = s->def->inlineProp;
     213        9730 :                         polymorphic = sig->polymorphic;
     214        9730 :                         argcc = argc;
     215             :                 } else {
     216   251549258 :                         retc = s->func->retc;
     217   251549258 :                         argc = s->func->argc;
     218   251549258 :                         varargs = /*retc == 0 ||*/ s->func->vargs || s->func->vrets;
     219   251549258 :                         varrets = retc == 0 || s->func->vrets;
     220   251549258 :                         unsafe = s->func->unsafe;
     221   251549258 :                         inlineprop = 0;
     222   251549258 :                         polymorphic = s->func->poly;
     223   251549258 :                         if (!retc && !polymorphic)
     224     2288052 :                                 polymorphic = 1;
     225   251549258 :                         argcc = argc + ((retc == 0)?1:0);
     226             :                 }
     227   251558988 :                 unmatched = 0;
     228             : 
     229             :                 /*
     230             :                  * The simple case could be taken care of separately to
     231             :                  * speedup processing
     232             :                  * However, it turned out not to make a big difference.  The
     233             :                  * first time we encounter a polymorphic argument in the
     234             :                  * signature.
     235             :                  * Subsequently, the polymorphic arguments update this table
     236             :                  * and check for any type mismatches that might occur.  There
     237             :                  * are at most 2 type variables involved per argument due to
     238             :                  * the limited type nesting permitted.  Note, each function
     239             :                  * returns at least one value.
     240             :                  */
     241   251558988 :                 if (polymorphic) {
     242    66754097 :                         int limit = polymorphic;
     243    66754097 :                         if (!(argcc == p->argc || (argc < p->argc && varargs))) {
     244    28788503 :                                 s = s->peer;
     245    28788503 :                                 continue;
     246             :                         }
     247    37965594 :                         if (retc != p->retc && !varrets) {
     248      315850 :                                 s = s->peer;
     249      315850 :                                 continue;
     250             :                         }
     251             : 
     252   106997291 :                         for (k = 0; k < limit; k++)
     253    69347547 :                                 polytype[k] = TYPE_any;
     254             :                         /*
     255             :                          * Most polymorphic functions don't have a variable argument
     256             :                          * list. So we save some instructions factoring this caise out.
     257             :                          * Be careful, the variable number of return arguments should
     258             :                          * be considered as well.
     259             :                          */
     260             :                         i = p->retc;
     261             :                         /* first handle the variable argument list */
     262   187176048 :                         for (k = retc; i < p->argc; k++, i++) {
     263   152934774 :                                 int actual = getArgType(mb, p, i);
     264   152934774 :                                 int formal = getFormalArgType(s, k);
     265   152934774 :                                 if (k == argc - 1 && varargs)
     266    54678487 :                                         k--;
     267             :                                 /*
     268             :                                  * Take care of variable argument lists.
     269             :                                  * They are allowed as the last in the signature only.
     270             :                                  * Furthermore, for patterns if the formal type is
     271             :                                  * 'any' then all remaining arguments are acceptable
     272             :                                  * and detailed type analysis becomes part of the
     273             :                                  * pattern implementation.
     274             :                                  * In all other cases the type should apply to all
     275             :                                  * remaining arguments.
     276             :                                  */
     277   152934774 :                                 if (getOptBat(formal) && !isAnyExpression(formal) && getBatType(actual) == getBatType(formal))
     278   152934774 :                                         formal = actual;
     279   152934774 :                                 if (formal == actual)
     280    62059548 :                                         continue;
     281    90875226 :                                 if (updateTypeMap(formal, actual, polytype)) {
     282             :                                         unmatched = i;
     283             :                                         break;
     284             :                                 }
     285    88826807 :                                 formal = getPolyType(formal, polytype);
     286             :                                 /*
     287             :                                  * Collect the polymorphic types and resolve them.
     288             :                                  * If it fails, we know this isn't the function we are
     289             :                                  * looking for.
     290             :                                  */
     291    88826807 :                                 if (resolvedType(formal, actual) < 0) {
     292             :                                         unmatched = i;
     293             :                                         break;
     294             :                                 }
     295             :                         }
     296             :                         /*
     297             :                          * The last argument/result type could be a polymorphic
     298             :                          * variable list.  It should only be allowed for patterns,
     299             :                          * where it can deal with the stack.  If the type is
     300             :                          * specified as :any then any mix of arguments is allowed.
     301             :                          * If the type is a new numbered type variable then the
     302             :                          * first element in the list determines the required type
     303             :                          * of all.
     304             :                          */
     305    37644172 :                         if (varargs) {
     306     6868141 :                                 if (s->kind != PATTERNsymbol && retc)
     307             :                                         unmatched = i;
     308             :                                 else {
     309             :                                         /* resolve the arguments */
     310     6869989 :                                         for (; i < p->argc; i++) {
     311             :                                                 /* the type of the last one has already been set */
     312     1456676 :                                                 int actual = getArgType(mb, p, i);
     313     1456676 :                                                 int formal = getFormalArgType(s, k);
     314     1456676 :                                                 if (k == argc - 1 && varargs)
     315           0 :                                                         k--;
     316             : 
     317     1456676 :                                                 formal = getPolyType(formal, polytype);
     318     1456676 :                                                 if (getOptBat(formal) && !isAnyExpression(formal) && getBatType(actual) == getBatType(formal))
     319     1456676 :                                                         formal = actual;
     320     1456676 :                                                 if (formal == actual || formal == TYPE_any)
     321        1044 :                                                         continue;
     322     1455632 :                                                 if (resolvedType(formal, actual) < 0) {
     323             :                                                         unmatched = i;
     324             :                                                         break;
     325             :                                                 }
     326             :                                         }
     327             :                                 }
     328             :                         }
     329             :                 } else {
     330             :                         /*
     331             :                          * We have to check the argument types to determine a
     332             :                          * possible match for the non-polymorphic case.
     333             :                          */
     334   184804891 :                         if (argc != p->argc || retc != p->retc) {
     335    92244105 :                                 s = s->peer;
     336    92244105 :                                 continue;
     337             :                         }
     338             : 
     339             : 
     340   126536702 :                         for (i = p->retc; i < p->argc; i++) {
     341   104871662 :                                 int actual = getArgType(mb, p, i);
     342   104871662 :                                 int formal = getFormalArgType(s, i);
     343   104871662 :                                 if (resolvedType(formal, actual) < 0) {
     344             :                                         unmatched = i;
     345             :                                         break;
     346             :                                 }
     347             :                         }
     348             :                 }
     349             :                 /*
     350             :                  * It is possible that you may have to coerce the value to
     351             :                  * another type.  We assume that coercions are explicit at the
     352             :                  * MAL level. (e.g. var2:= var0:int). This avoids repeated
     353             :                  * type analysis just before you execute a function.
     354             :                  * An optimizer may at a later stage automatically insert such
     355             :                  * coercion requests.
     356             :                  */
     357             : 
     358   130206270 :                 if (unmatched) {
     359    74299151 :                         s = s->peer;
     360    74299151 :                         continue;
     361             :                 }
     362             :                 /*
     363             :                  * At this stage we know all arguments are type compatible
     364             :                  * with the signature.
     365             :                  * We should assure that also the target variables have the
     366             :                  * proper types or can inherit them from the signature. The
     367             :                  * result type vector should be build separately first,
     368             :                  * because we may encounter an error later on.
     369             :                  *
     370             :                  * If any of the arguments refer to a constraint type, any_x,
     371             :                  * then the resulting type can not be determined.
     372             :                  */
     373    55907119 :                 s1 = 0;
     374    55907119 :                 if (polymorphic) {
     375    66733740 :                         for (k = i = 0; i < p->retc && k < retc; k++, i++) {
     376    32499512 :                                 int actual = getArgType(mb, p, i);
     377    32499512 :                                 int formal = getFormalArgType(s, k);
     378             : 
     379    32499512 :                                 if (k == retc - 1 && varrets)
     380      338146 :                                         k--;
     381             : 
     382    32499512 :                                 s1 = getPolyType(formal, polytype);
     383             : 
     384    32499512 :                                 if (getOptBat(formal) && !isAnyExpression(formal) && getBatType(actual) == getBatType(formal))
     385    32499512 :                                         s1 = actual;
     386    32499512 :                                 if (resolveType(returntype+i, s1, actual) < 0) {
     387             :                                         s1 = -1;
     388             :                                         break;
     389             :                                 }
     390             :                         }
     391             :                 } else {
     392             :                         /* check for non-polymorphic return */
     393    43572942 :                         for (k = i = 0; i < p->retc; i++) {
     394    22049992 :                                 int actual = getArgType(mb, p, i);
     395    22049992 :                                 int formal = getFormalArgType(s, i);
     396             : 
     397    22049992 :                                 if (k == retc - 1 && varrets)
     398             :                                         k--;
     399             : 
     400    22049992 :                                 if (actual == formal) {
     401     7212163 :                                         returntype[i] = actual;
     402             :                                 } else {
     403    14837829 :                                         if (resolveType(returntype+i, formal, actual) < 0) {
     404             :                                                 s1 = -1;
     405             :                                                 break;
     406             :                                         }
     407             :                                 }
     408             :                         }
     409             :                 }
     410    55902450 :                 if (s1 < 0) {
     411      145272 :                         s = s->peer;
     412      145272 :                         continue;
     413             :                 }
     414             :                 /*
     415             :                  * If the return types are correct, copy them in place.
     416             :                  * Beware that signatures should be left untouched, which
     417             :                  * means that we may not overwrite any formal argument.
     418             :                  * Using the knowledge dat the arguments occupy the header
     419             :                  * of the symbol stack, it is easy to filter such errors.
     420             :                  * Also mark all variables that are subject to garbage control.
     421             :                  * Beware, this is not yet effectuated in the interpreter.
     422             :                  */
     423             : 
     424    55757178 :                 p->typeresolved = true;
     425    55757178 :                 p->inlineProp = inlineprop;
     426    55757178 :                 p->unsafeProp = unsafe;
     427   115086093 :                 for (i = 0; i < p->retc; i++) {
     428    59328915 :                         int ts = returntype[i];
     429    59328915 :                         if (isVarConstant(mb, getArg(p, i))) {
     430           0 :                                 if (!silent) {
     431           0 :                                         mb->errors = createMalException(mb, idx, TYPE,
     432             :                                                                                                         "Assignment to constant");
     433             :                                 }
     434           0 :                                 p->typeresolved = false;
     435           0 :                                 goto wrapup;
     436             :                         }
     437    59328915 :                         if (!isVarFixed(mb, getArg(p, i)) && ts >= 0) {
     438    31367237 :                                 setVarType(mb, getArg(p, i), ts);
     439    31367237 :                                 setVarFixed(mb, getArg(p, i));
     440             :                         }
     441    59328915 :                         prepostProcess(ts, p, i, mb);
     442             :                 }
     443             :                 /*
     444             :                  * Also the arguments may contain constants
     445             :                  * to be garbage collected.
     446             :                  */
     447   228275276 :                 for (i = p->retc; i < p->argc; i++)
     448   172518098 :                         if (ATOMtype(getArgType(mb, p, i)) == TYPE_str ||
     449   136325277 :                                 isaBatType(getArgType(mb, p, i)) ||
     450    41347839 :                                 (!isPolyType(getArgType(mb, p, i)) &&
     451    41347810 :                                  getArgType(mb, p, i) < TYPE_any &&
     452    41347810 :                                  getArgType(mb, p, i) >= 0 &&
     453    41347810 :                                  ATOMstorage(getArgType(mb, p, i)) == TYPE_str)) {
     454   131173419 :                                 getInstrPtr(mb, 0)->gc = true;
     455   131173419 :                                 p->gc = true;
     456             :                         }
     457             :                 /*
     458             :                  * It may happen that an argument was still untyped and as a
     459             :                  * result of the polymorphism matching became strongly
     460             :                  * typed. This should be reflected in the symbol table.
     461             :                  */
     462    55757178 :                 s1 = returntype[0];             /* for those interested */
     463             :                 /*
     464             :                  * If the call refers to a polymorphic function, we clone it
     465             :                  * to arrive at a bounded instance. Polymorphic patterns and
     466             :                  * commands are responsible for type resolution themselves.
     467             :                  * Note that cloning pre-supposes that the function being
     468             :                  * cloned does not contain errors detected earlier in the
     469             :                  * process, nor does it contain polymorphic actual arguments.
     470             :                  */
     471    55757178 :                 if (polymorphic) {
     472             :                         int cnt = 0;
     473   180292092 :                         for (k = i = p->retc; i < p->argc; i++) {
     474   146056558 :                                 int actual = getArgType(mb, p, i);
     475   146056558 :                                 if (isAnyExpression(actual))
     476          10 :                                         cnt++;
     477             :                         }
     478    34235534 :                         if (cnt == 0 && s->kind != COMMANDsymbol
     479    17507766 :                                 && s->kind != PATTERNsymbol) {
     480          11 :                                 assert(s->kind == FUNCTIONsymbol);
     481          11 :                                 s = cloneFunction(scope, s, mb, p);
     482          11 :                                 if (mb->errors)
     483           3 :                                         goto wrapup;
     484             :                         }
     485             :                 }
     486             :                 /* Any previousely found error in the block
     487             :                  * turns the complete block into erroneous.
     488             :                  if (mb->errors) {
     489             :                  p->typeresolved = false;
     490             :                  goto wrapup;
     491             :                  }
     492             :                  */
     493             : 
     494             :                 /*
     495             :                  * We found the proper function. Copy some properties. In
     496             :                  * particular, determine the calling strategy, i.e. FCNcall,
     497             :                  * CMDcall, PATcall Beware that polymorphic functions
     498             :                  * may produce type-incorrect clones.  This piece of code may be
     499             :                  * shared by the separate binder
     500             :                  */
     501    55757175 :                 if (p->token == ASSIGNsymbol) {
     502    55765605 :                         switch (s->kind) {
     503    17416769 :                         case COMMANDsymbol:
     504    17416769 :                                 p->token = CMDcall;
     505    17416769 :                                 p->fcn = s->func->imp;                         /* C implementation mandatory */
     506    17416769 :                                 if (p->fcn == NULL) {
     507           1 :                                         if (!silent)
     508           1 :                                                 mb->errors = createMalException(mb, idx, TYPE,
     509             :                                                                                                                 "object code for command %s.%s missing",
     510             :                                                                                                                 p->modname, p->fcnname);
     511           1 :                                         p->typeresolved = false;
     512           1 :                                         goto wrapup;
     513             :                                 }
     514             :                                 break;
     515    38339145 :                         case PATTERNsymbol:
     516    38339145 :                                 p->token = PATcall;
     517    38339145 :                                 p->fcn = s->func->imp;                         /* C implementation optional */
     518    38339145 :                                 break;
     519        9691 :                         case FUNCTIONsymbol:
     520        9691 :                                 p->token = FCNcall;
     521        9691 :                                 if (getSignature(s)->fcn)
     522           0 :                                         p->fcn = getSignature(s)->fcn;    /* C implementation optional */
     523             :                                 break;
     524           0 :                         default:
     525           0 :                                 if (!silent)
     526           0 :                                         mb->errors = createMalException(mb, idx, MAL,
     527             :                                                                                                         "MALresolve: unexpected token type");
     528           0 :                                 goto wrapup;
     529             :                         }
     530    55765604 :                         p->blk = s->def;
     531             :                 }
     532             : 
     533    55757174 :                 if (returntype != returns)
     534          40 :                         GDKfree(returntype);
     535             :                 return s1;
     536             :         }                                                       /* while */
     537             :         /*
     538             :          * We haven't found the correct function.  To ease debugging, we
     539             :          * may reveal that we found an instruction with the proper
     540             :          * arguments, but that clashes with one of the target variables.
     541             :          */
     542         686 :   wrapup:
     543         690 :         if (returntype != returns)
     544           0 :                 GDKfree(returntype);
     545             :         return -3;
     546             : }
     547             : 
     548             : /*
     549             :  * We try to clear the type check flag by looking up the
     550             :  * functions. Errors are simply ignored at this point of the game,
     551             :  * because they may be resolved as part of the calling sequence.
     552             :  */
     553             : static void
     554           5 : typeMismatch(MalBlkPtr mb, InstrPtr p, int idx, int lhs, int rhs, int silent)
     555             : {
     556           5 :         str n1;
     557           5 :         str n2;
     558             : 
     559           5 :         if (!silent) {
     560           5 :                 n1 = getTypeName(lhs);
     561           5 :                 n2 = getTypeName(rhs);
     562           5 :                 mb->errors = createMalException(mb, idx, TYPE, "type mismatch %s := %s", n1,
     563             :                                                                                 n2);
     564           5 :                 GDKfree(n1);
     565           5 :                 GDKfree(n2);
     566             :         }
     567           5 :         p->typeresolved = false;
     568           5 : }
     569             : 
     570             : /*
     571             :  * A function search should inspect all modules unless a specific module
     572             :  * is given. Preference is given to the lower scopes.
     573             :  * The type check is set to TYPE_UNKNOWN first to enforce a proper
     574             :  * analysis. This way it forms a cheap mechanism to resolve
     575             :  * the type after a change by an optimizer.
     576             :  * If we can not find the function, the type check returns unsuccessfully.
     577             :  * In this case we should issue an error message to the user.
     578             :  *
     579             :  * A re-check after the optimizer call should reset the token
     580             :  * to assignment.
     581             :  */
     582             : void
     583    67079674 : typeChecker(Module scope, MalBlkPtr mb, InstrPtr p, int idx, int silent)
     584             : {
     585    67079674 :         int s1 = -1, i, k;
     586    67079674 :         Module m = 0;
     587             : 
     588    67079674 :         p->typeresolved = false;
     589    67079674 :         if ((p->fcn || p->blk) && p->token >= FCNcall && p->token <= PATcall) {
     590    43716476 :                 p->token = ASSIGNsymbol;
     591    43716476 :                 p->fcn = NULL;
     592    43716476 :                 p->blk = NULL;
     593             :         }
     594             : 
     595    67079674 :         if (isaSignature(p)) {
     596     4371616 :                 for (k = 0; k < p->argc; k++)
     597     2190346 :                         setVarFixed(mb, getArg(p, k));
     598     2184287 :                 for (k = p->retc; k < p->argc; k++) {
     599        3017 :                         prepostProcess(getArgType(mb, p, k), p, k, mb);
     600             :                 }
     601     2181270 :                 p->typeresolved = true;
     602     4368631 :                 for (k = 0; k < p->retc; k++)
     603     2187361 :                         p->typeresolved &= typeResolved(mb, p, 0);
     604    57939356 :                 return;
     605             :         }
     606    64898404 :         if (getFunctionId(p) && getModuleId(p)) {
     607    55763789 :                 m = findModule(scope, getModuleId(p));
     608             : 
     609    55762704 :                 if (!m || strcmp(m->name, getModuleId(p)) != 0) {
     610         180 :                         if (!silent)
     611           2 :                                 mb->errors = createMalException(mb, idx, TYPE, "'%s%s%s' undefined",
     612             :                                         (getModuleId(p) ?  getModuleId(p) : ""),
     613           1 :                                         (getModuleId(p) ? "." : ""),
     614             :                                         getFunctionId(p));
     615         180 :                         return;
     616             :                 }
     617    55762524 :                 s1 = findFunctionType(m, mb, p, idx, silent);
     618             : 
     619    55758064 :                 if (s1 >= 0)
     620             :                         return;
     621             :                 /*
     622             :                  * Could not find a function that statisfies the constraints.
     623             :                  * If the instruction is just a function header we may
     624             :                  * continue.  Likewise, the function and module may refer to
     625             :                  * string variables known only at runtime.
     626             :                  *
     627             :                  * In all other cases we should generate a message, but only
     628             :                  * if we know that the error was not caused by checking the
     629             :                  * definition of a polymorphic function or the module or
     630             :                  * function name are variables, In those cases, the detailed
     631             :                  * analysis is performed upon an actual call.
     632             :                  */
     633         920 :                 if (!isaSignature(p) && !getInstrPtr(mb, 0)->polymorphic) {
     634         909 :                         if (!silent) {
     635          41 :                                 char *errsig = NULL;
     636          41 :                                 if (!malLibraryEnabled(p->modname)) {
     637           0 :                                         mb->errors = createMalException(mb, idx, TYPE,
     638             :                                                                                                         "'%s%s%s' library error in: %s",
     639             :                                                                                                         (getModuleId(p) ?
     640             :                                                                                                          getModuleId(p) : ""),
     641           0 :                                                                                                         (getModuleId(p) ? "." : ""),
     642             :                                                                                                         getFunctionId(p),
     643             :                                                                                                         malLibraryHowToEnable(p->
     644             :                                                                                                                                                   modname));
     645             :                                 } else {
     646          41 :                                         bool free_errsig = false, special_undefined = false;
     647          41 :                                         errsig = malLibraryHowToEnable(p->modname);
     648          41 :                                         if (!strcmp(errsig, "")) {
     649          41 :                                                 errsig = instruction2str(mb, 0, p,
     650             :                                                                                                  (LIST_MAL_NAME | LIST_MAL_TYPE
     651             :                                                                                                   | LIST_MAL_VALUE));
     652          41 :                                                 free_errsig = true;
     653             :                                         } else {
     654             :                                                 special_undefined = true;
     655             :                                         }
     656         123 :                                         mb->errors = createMalException(mb, idx, TYPE,
     657             :                                                                                                         "'%s%s%s' undefined%s: %s",
     658             :                                                                                                         (getModuleId(p) ?
     659             :                                                                                                          getModuleId(p) : ""),
     660          41 :                                                                                                         (getModuleId(p) ? "." : ""),
     661             :                                                                                                         getFunctionId(p),
     662             :                                                                                                         special_undefined ? "" :
     663             :                                                                                                         " in",
     664             :                                                                                                         errsig ? errsig :
     665             :                                                                                                         "failed instruction2str()");
     666          41 :                                         if (free_errsig)
     667          41 :                                                 GDKfree(errsig);
     668             :                                 }
     669             :                         }
     670         909 :                         p->typeresolved = false;
     671             :                 } else
     672          11 :                         p->typeresolved = true;
     673         920 :                 return;
     674             :         }
     675             :         /*
     676             :          * When we arrive here the operator is an assignment.
     677             :          * The language should also recognize (a,b):=(1,2);
     678             :          * This is achieved by propagation of the rhs types to the lhs
     679             :          * variables.
     680             :          */
     681     9134615 :         if (getFunctionId(p)) {
     682             :                 return;
     683             :         }
     684     9134778 :         if (p->retc >= 1 && p->argc > p->retc && p->argc != 2 * p->retc) {
     685           7 :                 if (!silent) {
     686           7 :                         mb->errors = createMalException(mb, idx, TYPE,
     687             :                                                                                         "Multiple assignment mismatch");
     688             :                 }
     689           7 :                 p->typeresolved = true;
     690             :         } else
     691     9134771 :                 p->typeresolved = true;
     692    16643513 :         for (k = 0, i = p->retc; k < p->retc && i < p->argc; i++, k++) {
     693     7508458 :                 int rhs = getArgType(mb, p, i);
     694     7508458 :                 int lhs = getArgType(mb, p, k);
     695             : 
     696     7508458 :                 if (rhs != TYPE_void) {
     697     7508307 :                         if (resolveType(&s1, lhs, rhs) < 0) {
     698           5 :                                 typeMismatch(mb, p, idx, lhs, rhs, silent);
     699           5 :                                 return;
     700             :                         }
     701             :                 } else {
     702             :                         /*
     703             :                          * The language permits assignment of 'nil' to any variable,
     704             :                          * using the target type.
     705             :                          */
     706         151 :                         if (lhs != TYPE_void && lhs != TYPE_any) {
     707           3 :                                 ValRecord cst = { .vtype = TYPE_void, .val.oval = void_nil, .bat = isaBatType(lhs) };
     708           3 :                                 int k;
     709             : 
     710           3 :                                 k = defConstant(mb, lhs, &cst);
     711           3 :                                 if (k >= 0)
     712           3 :                                         p->argv[i] = k;
     713           3 :                                 rhs = lhs;
     714             :                         }
     715             :                 }
     716             : 
     717     7508735 :                 if (!isVarFixed(mb, getArg(p, k))) {
     718     3332648 :                         setVarType(mb, getArg(p, k), rhs);
     719     3332648 :                         setVarFixed(mb, getArg(p, k));
     720             :                 }
     721     7508735 :                 prepostProcess(s1, p, i, mb);
     722     7508735 :                 prepostProcess(s1, p, k, mb);
     723             :         }
     724             :         /* the case where we have no rhs */
     725     9135055 :         if (p->barrier && p->retc == p->argc)
     726      505807 :                 for (k = 0; k < p->retc; k++) {
     727      253471 :                         int tpe = getArgType(mb, p, k);
     728      253471 :                         if (isaBatType(tpe) ||
     729      250994 :                                 ATOMtype(tpe) == TYPE_str ||
     730      250994 :                                 (!isPolyType(tpe) && tpe < MAXATOMS && ATOMextern(tpe)))
     731        2483 :                                 setVarCleanup(mb, getArg(p, k));
     732             :                 }
     733             : }
     734             : 
     735             : /*
     736             :  * After the parser finishes, we have to look for semantic errors,
     737             :  * such as flow of control problems and possible typeing conflicts.
     738             :  * The nesting of BARRIER and CATCH statements with their associated
     739             :  * flow of control primitives LEAVE and RETRY should form a valid
     740             :  * hierarchy. Failure to comply is considered a structural error
     741             :  * and leads to flagging the function as erroneous.
     742             :  * Also check general conformaty of the ML block structure.
     743             :  * It should start with a signature and finish with and ENDsymbol
     744             :  *
     745             :  * Type checking a program is limited to those instructions that are
     746             :  * not resolved yet. Once the program is completely checked, further calls
     747             :  * should be ignored. This should be separately administered for the flow
     748             :  * as well, because a dynamically typed instruction should later on not
     749             :  * lead to a re-check when it was already fully analyzed.
     750             :  */
     751             : str
     752     2946569 : chkTypes(Module s, MalBlkPtr mb, int silent)
     753             : {
     754     2946569 :         InstrPtr p = 0;
     755     2946569 :         int i;
     756     2946569 :         str msg = MAL_SUCCEED;
     757             : 
     758   161377936 :         for (i = 0; mb->errors == NULL && i < mb->stop; i++) {
     759   158431582 :                 p = getInstrPtr(mb, i);
     760   158431582 :                 assert(p != NULL);
     761   158431582 :                 if (!p->typeresolved)
     762    66135308 :                         typeChecker(s, mb, p, i, silent);
     763             :         }
     764     2946354 :         if (mb->errors) {
     765          54 :                 msg = mb->errors;
     766          54 :                 mb->errors = NULL;
     767             :         }
     768     2946354 :         return msg;
     769             : }
     770             : 
     771             : /*
     772             :  * Type checking an individual instruction is dangerous,
     773             :  * because it ignores data flow and variable declarations.
     774             :  */
     775             : int
     776          11 : chkInstruction(Module s, MalBlkPtr mb, InstrPtr p)
     777             : {
     778          11 :         if (mb->errors == MAL_SUCCEED) {
     779          11 :                 p->typeresolved = false;
     780          11 :                 typeChecker(s, mb, p, getPC(mb, p), TRUE);
     781             :         }
     782          11 :         return mb->errors != MAL_SUCCEED;
     783             : }
     784             : 
     785             : /*
     786             :  * Perform silent check on the program, merely setting the error flag.
     787             :  */
     788             : str
     789      568323 : chkProgram(Module s, MalBlkPtr mb)
     790             : {
     791      568323 :         str msg;
     792             : /* it is not ready yet, too fragile
     793             :                 mb->typefixed = mb->stop == chk; ignored END */
     794             : /*      if( mb->flowfixed == 0)*/
     795             : 
     796      568323 :         if (mb->errors) {
     797          23 :                 msg = mb->errors;
     798          23 :                 mb->errors = NULL;
     799          23 :                 return msg;
     800             :         }
     801      568300 :         msg = chkTypes(s, mb, FALSE);
     802      568297 :         if (msg == MAL_SUCCEED)
     803      568249 :                 msg = chkFlow(mb);
     804      568268 :         if (msg == MAL_SUCCEED)
     805      568255 :                 msg = chkDeclarations(mb);
     806             :         return msg;
     807             : }
     808             : 
     809             : /*
     810             :  * Polymorphic type analysis
     811             :  * MAL provides for type variables of the form any$N. This feature
     812             :  * supports polymorphic types, but also complicates the subsequent
     813             :  * analysis. A variable typed with any$N not occuring in the function
     814             :  * header leads to a dynamic typed statement. In principle we have
     815             :  * to type check the function upon each call.
     816             :  */
     817             : static bool
     818     2187361 : typeResolved(MalBlkPtr mb, InstrPtr p, int i)
     819             : {
     820     2187361 :         malType t = getArgType(mb, p, i);
     821     2187361 :         if (t == TYPE_any || isAnyExpression(t)) {
     822      553359 :                 return false;
     823             :         }
     824             :         return true;
     825             : }
     826             : 
     827             : /*
     828             :  * For a polymorphic commands we do not generate a cloned version.
     829             :  * It suffices to determine the actual return value taking into
     830             :  * account the type variable constraints.
     831             :  */
     832             : static malType
     833   122788349 : getPolyType(malType t, int *polytype)
     834             : {
     835   122788349 :         int ti;
     836   122788349 :         malType tail;
     837             : 
     838   122788349 :         ti = getTypeIndex(t);
     839   122788349 :         if (!isaBatType(t) && ti > 0) {
     840    13593098 :                 tail = polytype[ti];
     841    13593098 :                 if (getOptBat(t))
     842         382 :                         setOptBat(tail);
     843    13593098 :                 return tail;
     844             :         }
     845             : 
     846   109195251 :         tail = ti == 0 ? getBatType(t) : polytype[ti];
     847   109195251 :         if (isaBatType(t)) {
     848   106431284 :                 tail = newBatType(tail);
     849             :         }
     850   109195251 :         if (getOptBat(t))
     851       12402 :                 setOptBat(tail);
     852             :         return tail;
     853             : }
     854             : 
     855             : /*
     856             :  * Each argument is checked for binding of polymorphic arguments.
     857             :  * This routine assumes that the type index is indeed smaller than maxarg.
     858             :  * (The parser currently enforces a single digit from 1-2 )
     859             :  * The polymorphic type 'any', i.e. any_0, does never constraint an operation
     860             :  * it can match with all polymorphic types.
     861             :  * The routine returns the instanciated formal type for subsequent
     862             :  * type resolution.
     863             :  */
     864             : static int
     865    90884470 : updateTypeMap(int formal, int actual, int polytype[MAXTYPEVAR])
     866             : {
     867    90884470 :         int h, t, ret = 0;
     868             : 
     869    90884470 :         if (!isAnyExpression(formal) && isaBatType(formal) && isaBatType(actual))
     870             :                 return 0;
     871             : 
     872    44902075 :         if ((h = getTypeIndex(formal))) {
     873    42531048 :                 if (isaBatType(actual) && !isaBatType(formal) && !getOptBat(formal) &&
     874     3499410 :                         (polytype[h] == TYPE_any || polytype[h] == actual)) {
     875     2728036 :                         polytype[h] = actual;
     876     2728036 :                         return 0;
     877             :                 }
     878    39803012 :                 t = getBatType(actual);
     879    39803012 :                 if (t != polytype[h]) {
     880    23958516 :                         if (isaBatType(polytype[h]) && isaBatType(actual))
     881             :                                 ret = 0;
     882    23957251 :                         else if (polytype[h] == TYPE_any)
     883    23624899 :                                 polytype[h] = t;
     884             :                         else {
     885             :                                 return -1;
     886             :                         }
     887             :                 }
     888             :         }
     889    41841687 :         if (isaBatType(formal)) {
     890    29759853 :                 if (!isaBatType(actual))
     891             :                         return -1;
     892             :         }
     893             :         return ret;
     894             : }

Generated by: LCOV version 1.14