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 "opt_commonTerms.h"
15 : #include "mal_exception.h"
16 : /*
17 : * Caveat. A lot of time was lost due to constants that are indistinguisable
18 : * at the surface level. It requires the constant optimizer to be ran first.
19 : */
20 :
21 : /* The key for finding common terms is that they share variables.
22 : * Therefore we skip all constants, except for a constant only situation.
23 : */
24 :
25 : /*
26 : * Speed up simple insert operations by skipping the common terms.
27 : */
28 :
29 : static inline bool __attribute__((__pure__))
30 236631 : isProjectConst(const InstrRecord *p)
31 : {
32 236631 : return (getModuleId(p) == algebraRef && getFunctionId(p) == projectRef);
33 : }
34 :
35 : static int __attribute__((__pure__))
36 12188865 : hashInstruction(const MalBlkRecord *mb, const InstrRecord *p)
37 : {
38 12188865 : int i;
39 32371383 : for (i = p->argc - 1; i >= p->retc; i--)
40 32034441 : if (!isVarConstant(mb, getArg(p, i)))
41 11851923 : return getArg(p, i);
42 336942 : if (isVarConstant(mb, getArg(p, p->retc)))
43 336942 : return p->retc;
44 : return -1;
45 : }
46 :
47 : str
48 493392 : OPTcommonTermsImplementation(Client cntxt, MalBlkPtr mb, MalStkPtr stk,
49 : InstrPtr pci)
50 : {
51 493392 : int i, j, k, barrier = 0, bailout = 0;
52 493392 : InstrPtr p, q;
53 493392 : int actions = 0;
54 493392 : int limit, slimit;
55 493392 : int duplicate;
56 493392 : int *alias = NULL;
57 493392 : int *hash = NULL, h;
58 493392 : int *list = NULL;
59 493392 : str msg = MAL_SUCCEED;
60 :
61 493392 : InstrPtr *old = NULL;
62 :
63 : /* catch simple insert operations */
64 493392 : if (isSimpleSQL(mb)) {
65 283791 : goto wrapup;
66 : }
67 :
68 209641 : (void) cntxt;
69 209641 : (void) stk;
70 209641 : alias = (int *) GDKzalloc(sizeof(int) * mb->vtop);
71 209648 : list = (int *) GDKzalloc(sizeof(int) * mb->stop);
72 209656 : hash = (int *) GDKzalloc(sizeof(int) * mb->vtop);
73 209658 : if (alias == NULL || list == NULL || hash == NULL) {
74 0 : msg = createException(MAL, "optimizer.commonTerms",
75 : SQLSTATE(HY013) MAL_MALLOC_FAIL);
76 0 : goto wrapup;
77 : }
78 :
79 209658 : old = mb->stmt;
80 209658 : limit = mb->stop;
81 209658 : slimit = mb->ssize;
82 209658 : if (newMalBlkStmt(mb, mb->ssize) < 0) {
83 0 : msg = createException(MAL, "optimizer.commonTerms",
84 : SQLSTATE(HY013) MAL_MALLOC_FAIL);
85 0 : old = NULL;
86 0 : goto wrapup;
87 : }
88 :
89 15421132 : for (i = 0; mb->errors == NULL && i < limit; i++) {
90 15421132 : p = old[i];
91 15421132 : duplicate = 0;
92 :
93 84916713 : for (k = 0; k < p->argc; k++)
94 69495581 : if (alias[getArg(p, k)])
95 294961 : getArg(p, k) = alias[getArg(p, k)];
96 :
97 15421132 : if (p->token == ENDsymbol) {
98 209588 : pushInstruction(mb, p);
99 209617 : old[i] = NULL;
100 209617 : break;
101 : }
102 : /*
103 : * Any barrier block signals the end of this optimizer,
104 : * because the impact of the block can affect the common code eliminated.
105 : */
106 30423088 : barrier |= (p->barrier == BARRIERsymbol || p->barrier == CATCHsymbol
107 15211544 : || p->barrier == RETURNsymbol);
108 : /*
109 : * Also block further optimization when you have seen an assert().
110 : * This works particularly for SQL, because it is not easy to track
111 : * the BAT identifier aliases to look for updates. The sql.assert
112 : * at least tells us that an update is planned.
113 : * Like all optimizer decisions, it is safe to stop.
114 : */
115 15211544 : barrier |= getFunctionId(p) == assertRef;
116 15211544 : if (barrier || p->token == ASSIGNsymbol) {
117 257015 : TRC_DEBUG(MAL_OPTIMIZER, "Skipped[%d]: %d %d\n", i, barrier,
118 : p->retc == p->argc);
119 257015 : pushInstruction(mb, p);
120 257029 : old[i] = NULL;
121 257029 : continue;
122 : }
123 :
124 : /* when we enter a barrier block, we should ditch all previous instructions from consideration */
125 14954529 : if (p->barrier == BARRIERsymbol || p->barrier == CATCHsymbol
126 14954529 : || p->barrier == RETURNsymbol) {
127 0 : memset(list, 0, sizeof(int) * mb->stop);
128 0 : memset(hash, 0, sizeof(int) * mb->vtop);
129 : }
130 : /* side-effect producing operators can never be replaced */
131 : /* the same holds for function calls without an argument, it is
132 : * unclear where the results comes from (e.g. clock()) */
133 14954529 : if (mayhaveSideEffects(cntxt, mb, p, TRUE) || p->argc == p->retc) {
134 1701588 : TRC_DEBUG(MAL_OPTIMIZER, "Skipped[%d] side-effect: %d\n", i,
135 : p->retc == p->argc);
136 1701588 : pushInstruction(mb, p);
137 1701583 : old[i] = NULL;
138 1701583 : continue;
139 : }
140 : /* simple SQL bind operations need not be merged, they are cheap
141 : * and/or can be duplicated eliminated elsewhere cheaper */
142 13253629 : if (getModuleId(p) == sqlRef && (getFunctionId(p) != tidRef && getFunctionId(p) != bindRef)) {
143 834945 : pushInstruction(mb, p);
144 834945 : old[i] = NULL;
145 834945 : continue;
146 : }
147 12418684 : if (getModuleId(p) == matRef) { /* mat.packIncrement has requirement on number of instructions (or that needs an update */
148 230223 : pushInstruction(mb, p);
149 230223 : old[i] = NULL;
150 230223 : continue;
151 : }
152 :
153 : /* from here we have a candidate to look for a match */
154 :
155 12188461 : h = hashInstruction(mb, p);
156 :
157 12188461 : TRC_DEBUG(MAL_OPTIMIZER, "Candidate[%d] look at list[%d] => %d\n", i, h,
158 : hash[h]);
159 12188461 : traceInstruction(MAL_OPTIMIZER, mb, 0, p, LIST_MAL_ALL);
160 :
161 12188546 : if (h < 0) {
162 0 : pushInstruction(mb, p);
163 0 : old[i] = NULL;
164 0 : continue;
165 : }
166 :
167 12188546 : bailout = 1024; // don't run over long collision list
168 : /* Look into the hash structure for matching instructions */
169 102541567 : for (j = hash[h]; j > 0 && bailout-- > 0; j = list[j]) {
170 90571212 : if ((q = getInstrPtr(mb, j))
171 90571212 : && getFunctionId(q) == getFunctionId(p)
172 72051485 : && getModuleId(q) == getModuleId(p)) {
173 72054774 : TRC_DEBUG(MAL_OPTIMIZER,
174 : "Candidate[%d->%d] %d %d :%d %d %d=%d %d %d %d\n", j,
175 : list[j], hasSameSignature(mb, p, q),
176 : hasSameArguments(mb, p, q), q->token != ASSIGNsymbol,
177 : list[getArg(q, q->argc - 1)], i, !hasCommonResults(p,
178 : q),
179 : !isUnsafeFunction(q), !isUpdateInstruction(q),
180 : isLinearFlow(q));
181 72054774 : traceInstruction(MAL_OPTIMIZER, mb, 0, q, LIST_MAL_ALL);
182 :
183 : /*
184 : * Simple assignments are not replaced either. They should be
185 : * handled by the alias removal part. All arguments should
186 : * be assigned their value before instruction p.
187 : */
188 72059816 : if (hasSameArguments(mb, p, q)
189 236645 : && hasSameSignature(mb, p, q)
190 236631 : && !hasCommonResults(p, q)
191 236631 : && !isUnsafeFunction(q)
192 236631 : && !isUpdateInstruction(q)
193 236631 : && !isProjectConst(q) && /* disable project(x,val), as its used for the result of case statements */
194 216733 : isLinearFlow(q)) {
195 216733 : if (safetyBarrier(p, q)) {
196 0 : TRC_DEBUG(MAL_OPTIMIZER, "Safety barrier reached\n");
197 : break;
198 : }
199 216733 : duplicate = 1;
200 216733 : clrFunction(p);
201 216733 : p->argc = p->retc;
202 445223 : for (k = 0; k < q->retc; k++) {
203 228490 : alias[getArg(p, k)] = getArg(q, k);
204 : /* we know the arguments fit so the instruction can safely be patched */
205 228490 : p = pushArgument(mb, p, getArg(q, k));
206 : }
207 :
208 216733 : TRC_DEBUG(MAL_OPTIMIZER, "Modified expression %d -> %d ",
209 : getArg(p, 0), getArg(p, 1));
210 216733 : traceInstruction(MAL_OPTIMIZER, mb, 0, p, LIST_MAL_ALL);
211 :
212 216733 : actions++;
213 216733 : break; /* end of search */
214 : }
215 18516438 : } else if (isUpdateInstruction(p)) {
216 0 : TRC_DEBUG(MAL_OPTIMIZER, "Skipped: %d %d\n",
217 : mayhaveSideEffects(cntxt, mb, q, TRUE),
218 : isUpdateInstruction(p));
219 0 : traceInstruction(MAL_OPTIMIZER, mb, 0, q, LIST_MAL_ALL);
220 : }
221 : }
222 :
223 12187088 : if (duplicate) {
224 216733 : pushInstruction(mb, p);
225 216733 : old[i] = NULL;
226 216733 : continue;
227 : }
228 : /* update the hash structure with another candidate for reuse */
229 11970355 : TRC_DEBUG(MAL_OPTIMIZER,
230 : "Update hash[%d] - look at arg '%d' hash '%d' list '%d'\n", i,
231 : getArg(p, p->argc - 1), h, hash[h]);
232 11970355 : traceInstruction(MAL_OPTIMIZER, mb, 0, p, LIST_MAL_ALL);
233 :
234 11970594 : if (!mayhaveSideEffects(cntxt, mb, p, TRUE) && p->argc != p->retc
235 23941849 : && isLinearFlow(p) && !isUnsafeFunction(p)
236 11970939 : && !isUpdateInstruction(p)) {
237 11970769 : list[i] = hash[h];
238 11970769 : hash[h] = i;
239 11970769 : pushInstruction(mb, p);
240 11971221 : old[i] = NULL;
241 : }
242 : }
243 48135181 : for (; i < slimit; i++)
244 47925531 : if (old[i])
245 5355027 : pushInstruction(mb, old[i]);
246 : /* Defense line against incorrect plans */
247 209650 : if (actions > 0) {
248 9578 : msg = chkTypes(cntxt->usermodule, mb, FALSE);
249 9578 : if (!msg)
250 9578 : msg = chkFlow(mb);
251 9578 : if (!msg)
252 9578 : msg = chkDeclarations(mb);
253 : }
254 200072 : wrapup:
255 : /* keep actions taken as a fake argument */
256 493441 : (void) pushInt(mb, pci, actions);
257 :
258 493443 : if (alias)
259 209652 : GDKfree(alias);
260 493449 : if (list)
261 209658 : GDKfree(list);
262 493450 : if (hash)
263 209659 : GDKfree(hash);
264 493414 : if (old)
265 209623 : GDKfree(old);
266 493450 : return msg;
267 : }
|
