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      483506 : OPTconstantsImplementation(Client cntxt, MalBlkPtr mb, MalStkPtr stk,
      37             :                                                    InstrPtr pci)
      38             : {
      39      483506 :         int i, j, k = 1, n = 0, fnd = 0, actions = 0, limit = 0;
      40      483506 :         int *alias = NULL, *index = NULL, *cand = NULL;
      41      483506 :         VarPtr x, y, *cst = NULL;
      42      483506 :         str msg = MAL_SUCCEED;
      43      483506 :         InstrPtr p, q;
      44             : 
      45      483506 :         if (isSimpleSQL(mb)) {
      46      283863 :                 goto wrapup;
      47             :         }
      48      199646 :         alias = (int *) GDKzalloc(sizeof(int) * mb->vtop);
      49      199646 :         cand = (int *) GDKzalloc(sizeof(int) * mb->vtop);
      50      199645 :         cst = (VarPtr *) GDKzalloc(sizeof(VarPtr) * mb->vtop);
      51      199645 :         index = (int *) GDKzalloc(sizeof(int) * mb->vtop);
      52             : 
      53      199646 :         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    15681029 :         for (i = 0; i < mb->stop; i++) {
      63    15481414 :                 q = getInstrPtr(mb, i);
      64    15481414 :                 if (!q) {
      65           0 :                         continue;
      66             :                 }
      67    15481414 :                 if (getModuleId(q) == sqlRef && getFunctionId(q) != tidRef) {
      68     2839746 :                         continue;
      69             :                 }
      70    12641668 :                 if (hasSideEffects(mb, q, 1))
      71     5807237 :                         continue;
      72    25132824 :                 for (k = q->retc; k < q->argc; k++) {
      73    18298424 :                         j = getArg(q, k);
      74    18298424 :                         if (cand[j] == 0) {
      75    14683721 :                                 cand[j] = isVarConstant(mb, j) && isVarFixed(mb, j)
      76    14683721 :                                                 && getVarType(mb, j) != TYPE_ptr;
      77             :                         }
      78             :                 }
      79             :         }
      80             : 
      81    31744663 :         for (i = 0; i < mb->vtop; i++)
      82    31545048 :                 alias[i] = i;
      83    31743943 :         for (i = 0; i < mb->vtop; i++)
      84    31544299 :                 if (cand[i]) {
      85     2724862 :                         x = getVar(mb, i);
      86     2724862 :                         fnd = 0;
      87     2724862 :                         limit = n - 128;        // don't look to far back
      88     2724862 :                         if (x->type && x->value.vtype)
      89    71136210 :                                 for (k = n - 1; k >= 0 && k > limit; k--) {
      90    69420663 :                                         y = cst[k];
      91    69420663 :                                         if (x->type == y->type && x->rowcnt == y->rowcnt
      92    35953942 :                                                 && x->value.vtype == y->value.vtype
      93    35953325 :                                                 && (x->value.vtype == TYPE_any
      94    35953239 :                                                 || ATOMcmp(x->value.vtype, VALptr(&x->value),
      95             :                                                                    VALptr(&y->value)) == 0)) {
      96             : 
      97             :                                                 /* reuse a constant */
      98      600993 :                                                 alias[i] = index[k];
      99      600993 :                                                 fnd = 1;
     100      600993 :                                                 actions++;
     101      600993 :                                                 break;
     102             :                                         }
     103             :                                 }
     104      600993 :                         if (fnd == 0) {
     105     2123898 :                                 cst[n] = x;
     106     2123898 :                                 index[n] = i;
     107     2123898 :                                 n++;
     108             :                         }
     109             :                 }
     110             : 
     111      199644 :         if (actions)
     112    10380893 :                 for (i = 0; i < mb->stop; i++) {
     113    10320840 :                         p = getInstrPtr(mb, i);
     114    52614822 :                         for (k = 0; k < p->argc; k++)
     115    42293982 :                                 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      199644 :   wrapup:
     127             :         /* keep actions taken as a fake argument */
     128      483507 :         (void) pushInt(mb, pci, actions);
     129             : 
     130      483509 :         if (cand)
     131      199646 :                 GDKfree(cand);
     132      483510 :         if (alias)
     133      199647 :                 GDKfree(alias);
     134      483510 :         if (cst)
     135      199647 :                 GDKfree(cst);
     136      483510 :         if (index)
     137      199647 :                 GDKfree(index);
     138      483510 :         return msg;
     139             : }