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             :  * This simple module unrolls the mat.pack into an incremental sequence.
      15             :  * This could speedup parallel processing and releases resources faster.
      16             :  */
      17             : #include "monetdb_config.h"
      18             : #include "opt_matpack.h"
      19             : 
      20             : str
      21      445897 : OPTmatpackImplementation(Client cntxt, MalBlkPtr mb, MalStkPtr stk,
      22             :                                                  InstrPtr pci)
      23             : {
      24      445897 :         int v, i, j, limit, slimit;
      25      445897 :         InstrPtr p, q;
      26      445897 :         int actions = 0;
      27      445897 :         InstrPtr *old = NULL;
      28      445897 :         str msg = MAL_SUCCEED;
      29             : 
      30      445897 :         if (isOptimizerUsed(mb, pci, mergetableRef) <= 0) {
      31       31969 :                 goto wrapup;
      32             :         }
      33             : 
      34             :         (void) cntxt;
      35             :         (void) stk;                                     /* to fool compilers */
      36    19454754 :         for (i = 1; i < mb->stop; i++)
      37    19067809 :                 if (getModuleId(getInstrPtr(mb, i)) == matRef
      38       41869 :                         && getFunctionId(getInstrPtr(mb, i)) == packRef
      39       29340 :                         && isaBatType(getArgType(mb, getInstrPtr(mb, i), 1)))
      40             :                         break;
      41      413921 :         if (i == mb->stop)
      42      386945 :                 goto wrapup;
      43             : 
      44       26976 :         old = mb->stmt;
      45       26976 :         limit = mb->stop;
      46       26976 :         slimit = mb->ssize;
      47       26976 :         if (newMalBlkStmt(mb, mb->stop) < 0)
      48           0 :                 throw(MAL, "optimizer.matpack", SQLSTATE(HY013) MAL_MALLOC_FAIL);
      49             : 
      50     7757354 :         for (i = 0; mb->errors == NULL && i < limit; i++) {
      51     7730378 :                 p = old[i];
      52     7730378 :                 if (getModuleId(p) == matRef && getFunctionId(p) == packRef
      53      141026 :                         && isaBatType(getArgType(mb, p, 1))) {
      54      138900 :                         q = newInstruction(0, matRef, packIncrementRef);
      55      138900 :                         if (q == NULL) {
      56           0 :                                 msg = createException(MAL, "optimizer.matpack",
      57             :                                                                           SQLSTATE(HY013) MAL_MALLOC_FAIL);
      58           0 :                                 break;
      59             :                         }
      60      138900 :                         if (setDestVar(q, newTmpVariable(mb, getArgType(mb, p, 1))) < 0) {
      61           0 :                                 freeInstruction(q);
      62           0 :                                 msg = createException(MAL, "optimizer.matpack",
      63             :                                                                           SQLSTATE(HY013) MAL_MALLOC_FAIL);
      64           0 :                                 break;
      65             :                         }
      66      138900 :                         q = pushArgument(mb, q, getArg(p, 1));
      67      138900 :                         v = getArg(q, 0);
      68      138900 :                         q = pushInt(mb, q, p->argc - p->retc);
      69      138900 :                         pushInstruction(mb, q);
      70      138900 :                         typeChecker(cntxt->usermodule, mb, q, mb->stop - 1, TRUE);
      71             : 
      72     1206715 :                         for (j = 2; j < p->argc; j++) {
      73      928915 :                                 q = newInstruction(0, matRef, packIncrementRef);
      74      928915 :                                 if (q == NULL) {
      75           0 :                                         msg = createException(MAL, "optimizer.matpack",
      76             :                                                                                   SQLSTATE(HY013) MAL_MALLOC_FAIL);
      77           0 :                                         break;
      78             :                                 }
      79      928915 :                                 q = pushArgument(mb, q, v);
      80      928915 :                                 q = pushArgument(mb, q, getArg(p, j));
      81      928915 :                                 if (setDestVar(q, newTmpVariable(mb, getVarType(mb, v))) < 0) {
      82           0 :                                         freeInstruction(q);
      83           0 :                                         msg = createException(MAL, "optimizer.matpack",
      84             :                                                                                   SQLSTATE(HY013) MAL_MALLOC_FAIL);
      85           0 :                                         break;
      86             :                                 }
      87      928915 :                                 v = getArg(q, 0);
      88      928915 :                                 pushInstruction(mb, q);
      89      928915 :                                 typeChecker(cntxt->usermodule, mb, q, mb->stop - 1, TRUE);
      90             :                         }
      91           0 :                         if (msg)
      92             :                                 break;
      93      138900 :                         getArg(q, 0) = getArg(p, 0);
      94      138900 :                         freeInstruction(p);
      95      138900 :                         actions++;
      96      138900 :                         continue;
      97             :                 }
      98     7591478 :                 pushInstruction(mb, p);
      99     7591478 :                 old[i] = NULL;
     100             :         }
     101    21421718 :         for (; i < slimit; i++)
     102    21394742 :                 if (old[i])
     103           0 :                         pushInstruction(mb, old[i]);
     104       26976 :         GDKfree(old);
     105             : 
     106             :         /* Defense line against incorrect plans */
     107       26976 :         if (msg == MAL_SUCCEED && actions > 0) {
     108       26976 :                 msg = chkTypes(cntxt->usermodule, mb, FALSE);
     109       26976 :                 if (!msg)
     110       26976 :                         msg = chkFlow(mb);
     111       26976 :                 if (!msg)
     112       26976 :                         msg = chkDeclarations(mb);
     113             :         }
     114           0 :   wrapup:
     115             :         /* keep actions taken as a fake argument */
     116      445890 :         (void) pushInt(mb, pci, actions);
     117      445890 :         return msg;
     118             : }