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             : #include "monetdb_config.h"
      14             : #include "mal_instruction.h"
      15             : #include "opt_aliases.h"
      16             : 
      17             : /* an alias is recognized by a simple assignment */
      18             : #define OPTisAlias(X) (X->argc == 2 && X->token == ASSIGNsymbol && X->barrier == 0 )
      19             : 
      20             : str
      21     1487093 : OPTaliasesImplementation(Client cntxt, MalBlkPtr mb, MalStkPtr stk, InstrPtr pci)
      22             : {
      23     1487093 :         int i, j, k = 1, limit, actions = 0;
      24     1487093 :         int *alias = 0;
      25     1487093 :         str msg = MAL_SUCCEED;
      26     1487093 :         InstrPtr p;
      27             : 
      28     1487093 :         (void) stk;
      29     1487093 :         (void) cntxt;
      30             : 
      31     1487093 :         limit = mb->stop;
      32    44439663 :         for (i = 1; i < limit; i++) {
      33    43485021 :                 p = getInstrPtr(mb, i);
      34    43485021 :                 if (OPTisAlias(p))
      35             :                         break;
      36             :         }
      37     1487093 :         if (i == limit) {
      38             :                 // we didn't found a simple assignment that warrants a rewrite
      39      954642 :                 goto wrapup;
      40             :         }
      41      532451 :         k = i;
      42      532451 :         if (i < limit) {
      43      532451 :                 alias = GDKzalloc(sizeof(int) * mb->vtop);
      44      532451 :                 if (alias == NULL)
      45           0 :                         throw(MAL, "optimizer.aliases", SQLSTATE(HY013) MAL_MALLOC_FAIL);
      46      532451 :                 setVariableScope(mb);
      47    50206350 :                 for (j = 1; j < mb->vtop; j++)
      48    49141448 :                         alias[j] = j;
      49             :         }
      50    28622443 :         for (; i < limit; i++) {
      51    28089966 :                 p = getInstrPtr(mb, i);
      52    28089966 :                 mb->stmt[k++] = p;
      53    28089966 :                 if (OPTisAlias(p) && getLastUpdate(mb, getArg(p, 0)) == i
      54     3256062 :                         && getBeginScope(mb, getArg(p, 0)) == i
      55     3254935 :                         && getLastUpdate(mb, getArg(p, 1)) <= i) {
      56     3254523 :                         alias[getArg(p, 0)] = alias[getArg(p, 1)];
      57     3254523 :                         freeInstruction(p);
      58     3254549 :                         actions++;
      59     3254549 :                         k--;
      60     3254549 :                         mb->stmt[k] = 0;
      61             :                 } else {
      62    85359248 :                         for (int i = 0; i < p->argc; i++)
      63    60523805 :                                 getArg(p, i) = alias[getArg(p, i)];
      64             :                 }
      65             :         }
      66             : 
      67     3786945 :         for (i = k; i < limit; i++)
      68     3254468 :                 mb->stmt[i] = NULL;
      69             : 
      70      532477 :         mb->stop = k;
      71      532477 :         GDKfree(alias);
      72             : 
      73             :         /* Defense line against incorrect plans */
      74             :         /* Plan is unaffected */
      75             :         // msg = chkTypes(cntxt->usermodule, mb, FALSE);
      76             :         // if ( msg == MAL_SUCCEED)
      77             :         //      msg = chkFlow(mb);
      78             :         // if ( msg == MAL_SUCCEED)
      79             :         //      msg = chkDeclarations(mb);
      80     1487094 :   wrapup:
      81             :         /* keep actions taken as a fake argument */
      82     1487094 :         (void) pushInt(mb, pci, actions);
      83     1487094 :         return msg;
      84             : }