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             :  * Constant Duplicate Removal
      15             :  * The compilers may generate an abundance of constants on
      16             :  * the stack. This simple optimizer merges them into a single reference.
      17             :  * This makes it easier to search for statement duplicates
      18             :  * and alias their variables.
      19             :  */
      20             : /* We should not look at constants in simple, side-effect functions, because
      21             :  * they can not be removed later on.
      22             : */
      23             : /*
      24             :  * We have to keep an alias table to reorganize the program
      25             :  * after the variable stack has changed.
      26             :  * The plan may contain many constants and to check them all would be quadratic
      27             :  * in the size of the constant list.
      28             :  * The heuristic is to look back into the list only partially.
      29             :  * A hash structure could help out with further reduction.
      30             :  */
      31             : #include "monetdb_config.h"
      32             : #include "mal_instruction.h"
      33             : #include "opt_constants.h"
      34             : 
      35             : str
      36      445871 : OPTconstantsImplementation(Client cntxt, MalBlkPtr mb, MalStkPtr stk,
      37             :                                                    InstrPtr pci)
      38             : {
      39      445871 :         int i, j, k = 1, n = 0, fnd = 0, actions = 0, limit = 0;
      40      445871 :         int *alias = NULL, *index = NULL, *cand = NULL;
      41      445871 :         VarPtr x, y, *cst = NULL;
      42      445871 :         str msg = MAL_SUCCEED;
      43      445871 :         InstrPtr p, q;
      44             : 
      45      445871 :         if (isSimpleSQL(mb)) {
      46      283635 :                 goto wrapup;
      47             :         }
      48      162259 :         alias = (int *) GDKzalloc(sizeof(int) * mb->vtop);
      49      162298 :         cand = (int *) GDKzalloc(sizeof(int) * mb->vtop);
      50      162287 :         cst = (VarPtr *) GDKzalloc(sizeof(VarPtr) * mb->vtop);
      51      162294 :         index = (int *) GDKzalloc(sizeof(int) * mb->vtop);
      52             : 
      53      162295 :         if (alias == NULL || cst == NULL || index == NULL || cand == NULL) {
      54           0 :                 msg = createException(MAL, "optimizer.constants",
      55             :                                                           SQLSTATE(HY013) MAL_MALLOC_FAIL);
      56           0 :                 goto wrapup;
      57             :         }
      58             : 
      59             :         (void) stk;
      60             :         (void) cntxt;
      61             : 
      62    18872356 :         for (i = 0; i < mb->stop; i++) {
      63    18709567 :                 q = getInstrPtr(mb, i);
      64    18709567 :                 if (!q) {
      65           0 :                         continue;
      66             :                 }
      67    18709567 :                 if (getModuleId(q) == sqlRef && getFunctionId(q) != tidRef) {
      68     3177278 :                         continue;
      69             :                 }
      70    15532289 :                 if (hasSideEffects(mb, q, 1))
      71     4684648 :                         continue;
      72    39882562 :                 for (k = q->retc; k < q->argc; k++) {
      73    29034427 :                         j = getArg(q, k);
      74    29034427 :                         if (cand[j] == 0) {
      75    22927967 :                                 cand[j] = isVarConstant(mb, j) && isVarFixed(mb, j)
      76    22927967 :                                                 && getVarType(mb, j) != TYPE_ptr;
      77             :                         }
      78             :                 }
      79             :         }
      80             : 
      81    33680439 :         for (i = 0; i < mb->vtop; i++)
      82    33517650 :                 alias[i] = i;
      83    33686040 :         for (i = 0; i < mb->vtop; i++)
      84    33523753 :                 if (cand[i]) {
      85     2646331 :                         x = getVar(mb, i);
      86     2646331 :                         fnd = 0;
      87     2646331 :                         limit = n - 128;        // don't look to far back
      88     2646331 :                         if (x->type && x->value.vtype)
      89    71995065 :                                 for (k = n - 1; k >= 0 && k > limit; k--) {
      90    70295297 :                                         y = cst[k];
      91    70295297 :                                         if (x->type == y->type && x->rowcnt == y->rowcnt
      92    36240356 :                                                 && x->value.vtype == y->value.vtype
      93    36239027 :                                                 && (x->value.vtype == TYPE_any
      94    36238777 :                                                 || ATOMcmp(x->value.vtype, VALptr(&x->value),
      95             :                                                                    VALptr(&y->value)) == 0)) {
      96             : 
      97             :                                                 /* reuse a constant */
      98      553397 :                                                 alias[i] = index[k];
      99      553397 :                                                 fnd = 1;
     100      553397 :                                                 actions++;
     101      553397 :                                                 break;
     102             :                                         }
     103             :                                 }
     104      553397 :                         if (fnd == 0) {
     105     2092432 :                                 cst[n] = x;
     106     2092432 :                                 index[n] = i;
     107     2092432 :                                 n++;
     108             :                         }
     109             :                 }
     110             : 
     111      162287 :         if (actions)
     112    14969174 :                 for (i = 0; i < mb->stop; i++) {
     113    14915759 :                         p = getInstrPtr(mb, i);
     114    78020109 :                         for (k = 0; k < p->argc; k++)
     115    63104350 :                                 getArg(p, k) = alias[getArg(p, k)];
     116             :                 }
     117             : 
     118             :         /* Defense line against incorrect plans */
     119             :         /* Plan remains unaffected */
     120             :         // msg = chkTypes(cntxt->usermodule, mb, FALSE);
     121             :         // if (!msg)
     122             :         //      msg = chkFlow(mb);
     123             :         // if(!msg)
     124             :         //      msg = chkDeclarations(mb);
     125             :         /* keep all actions taken as a post block comment */
     126      162287 :   wrapup:
     127             :         /* keep actions taken as a fake argument */
     128      445922 :         (void) pushInt(mb, pci, actions);
     129             : 
     130      445915 :         if (cand)
     131      162280 :                 GDKfree(cand);
     132      445935 :         if (alias)
     133      162300 :                 GDKfree(alias);
     134      445937 :         if (cst)
     135      162302 :                 GDKfree(cst);
     136      445929 :         if (index)
     137      162294 :                 GDKfree(index);
     138      445936 :         return msg;
     139             : }