Age Owner Branch data TLA Line data Source code
1 : : /*-------------------------------------------------------------------------
2 : : *
3 : : * int.c
4 : : * Functions for the built-in integer types (except int8).
5 : : *
6 : : * Portions Copyright (c) 1996-2026, PostgreSQL Global Development Group
7 : : * Portions Copyright (c) 1994, Regents of the University of California
8 : : *
9 : : *
10 : : * IDENTIFICATION
11 : : * src/backend/utils/adt/int.c
12 : : *
13 : : *-------------------------------------------------------------------------
14 : : */
15 : : /*
16 : : * OLD COMMENTS
17 : : * I/O routines:
18 : : * int2in, int2out, int2recv, int2send
19 : : * int4in, int4out, int4recv, int4send
20 : : * int2vectorin, int2vectorout, int2vectorrecv, int2vectorsend
21 : : * Boolean operators:
22 : : * inteq, intne, intlt, intle, intgt, intge
23 : : * Arithmetic operators:
24 : : * intpl, intmi, int4mul, intdiv
25 : : *
26 : : * Arithmetic operators:
27 : : * intmod
28 : : */
29 : : #include "postgres.h"
30 : :
31 : : #include <ctype.h>
32 : : #include <limits.h>
33 : : #include <math.h>
34 : :
35 : : #include "catalog/pg_type.h"
36 : : #include "common/int.h"
37 : : #include "funcapi.h"
38 : : #include "libpq/pqformat.h"
39 : : #include "nodes/nodeFuncs.h"
40 : : #include "nodes/supportnodes.h"
41 : : #include "optimizer/optimizer.h"
42 : : #include "utils/array.h"
43 : : #include "utils/builtins.h"
44 : :
45 : : #define Int2VectorSize(n) (offsetof(int2vector, values) + (n) * sizeof(int16))
46 : :
47 : : typedef struct
48 : : {
49 : : int32 current;
50 : : int32 finish;
51 : : int32 step;
52 : : } generate_series_fctx;
53 : :
54 : :
55 : : /*****************************************************************************
56 : : * USER I/O ROUTINES *
57 : : *****************************************************************************/
58 : :
59 : : /*
60 : : * int2in - converts "num" to short
61 : : */
62 : : Datum
9414 tgl@sss.pgh.pa.us 63 :CBC 486335 : int2in(PG_FUNCTION_ARGS)
64 : : {
65 : 486335 : char *num = PG_GETARG_CSTRING(0);
66 : :
1192 67 : 486335 : PG_RETURN_INT16(pg_strtoint16_safe(num, fcinfo->context));
68 : : }
69 : :
70 : : /*
71 : : * int2out - converts short to "num"
72 : : */
73 : : Datum
9414 74 : 356069 : int2out(PG_FUNCTION_ARGS)
75 : : {
76 : 356069 : int16 arg1 = PG_GETARG_INT16(0);
9124 bruce@momjian.us 77 : 356069 : char *result = (char *) palloc(7); /* sign, 5 digits, '\0' */
78 : :
9357 tgl@sss.pgh.pa.us 79 : 356069 : pg_itoa(arg1, result);
9414 80 : 356069 : PG_RETURN_CSTRING(result);
81 : : }
82 : :
83 : : /*
84 : : * int2recv - converts external binary format to int2
85 : : */
86 : : Datum
8346 tgl@sss.pgh.pa.us 87 :UBC 0 : int2recv(PG_FUNCTION_ARGS)
88 : : {
89 : 0 : StringInfo buf = (StringInfo) PG_GETARG_POINTER(0);
90 : :
91 : 0 : PG_RETURN_INT16((int16) pq_getmsgint(buf, sizeof(int16)));
92 : : }
93 : :
94 : : /*
95 : : * int2send - converts int2 to binary format
96 : : */
97 : : Datum
8346 tgl@sss.pgh.pa.us 98 :CBC 8 : int2send(PG_FUNCTION_ARGS)
99 : : {
100 : 8 : int16 arg1 = PG_GETARG_INT16(0);
101 : : StringInfoData buf;
102 : :
103 : 8 : pq_begintypsend(&buf);
3077 andres@anarazel.de 104 : 8 : pq_sendint16(&buf, arg1);
8346 tgl@sss.pgh.pa.us 105 : 8 : PG_RETURN_BYTEA_P(pq_endtypsend(&buf));
106 : : }
107 : :
108 : : /*
109 : : * construct int2vector given a raw array of int2s
110 : : *
111 : : * If int2s is NULL then caller must fill values[] afterward
112 : : */
113 : : int2vector *
5011 peter_e@gmx.net 114 : 63710 : buildint2vector(const int16 *int2s, int n)
115 : : {
116 : : int2vector *result;
117 : :
7656 tgl@sss.pgh.pa.us 118 : 63710 : result = (int2vector *) palloc0(Int2VectorSize(n));
119 : :
120 [ + + + + ]: 63710 : if (n > 0 && int2s)
5011 peter_e@gmx.net 121 : 29985 : memcpy(result->values, int2s, n * sizeof(int16));
122 : :
123 : : /*
124 : : * Attach standard array header. For historical reasons, we set the index
125 : : * lower bound to 0 not 1.
126 : : */
6956 tgl@sss.pgh.pa.us 127 : 63710 : SET_VARSIZE(result, Int2VectorSize(n));
7656 128 : 63710 : result->ndim = 1;
7423 129 : 63710 : result->dataoffset = 0; /* never any nulls */
7656 130 : 63710 : result->elemtype = INT2OID;
131 : 63710 : result->dim1 = n;
132 : 63710 : result->lbound1 = 0;
133 : :
134 : 63710 : return result;
135 : : }
136 : :
137 : : /*
138 : : * validate that an array object meets the restrictions of int2vector
139 : : *
140 : : * We need this because there are pathways by which a general int2[] array can
141 : : * be cast to int2vector, allowing the type's restrictions to be violated.
142 : : * All code that receives an int2vector as a SQL parameter should check this.
143 : : */
144 : : static void
34 145 : 7091 : check_valid_int2vector(const int2vector *int2Array)
146 : : {
147 : : /*
148 : : * We insist on ndim == 1 and dataoffset == 0 (that is, no nulls) because
149 : : * otherwise the array's layout will not be what calling code expects. We
150 : : * needn't be picky about the index lower bound though. Checking elemtype
151 : : * is just paranoia.
152 : : */
153 [ + + ]: 7091 : if (int2Array->ndim != 1 ||
154 [ + - ]: 7088 : int2Array->dataoffset != 0 ||
155 [ - + ]: 7088 : int2Array->elemtype != INT2OID)
156 [ + - ]: 3 : ereport(ERROR,
157 : : (errcode(ERRCODE_DATATYPE_MISMATCH),
158 : : errmsg("array is not a valid int2vector")));
159 : 7088 : }
160 : :
161 : : /*
162 : : * int2vectorin - converts "num num ..." to internal form
163 : : */
164 : : Datum
9414 165 : 376 : int2vectorin(PG_FUNCTION_ARGS)
166 : : {
167 : 376 : char *intString = PG_GETARG_CSTRING(0);
1187 168 : 376 : Node *escontext = fcinfo->context;
169 : : int2vector *result;
170 : : int nalloc;
171 : : int n;
172 : :
1155 173 : 376 : nalloc = 32; /* arbitrary initial size guess */
174 : 376 : result = (int2vector *) palloc0(Int2VectorSize(nalloc));
175 : :
176 : 376 : for (n = 0;; n++)
10416 bruce@momjian.us 177 : 688 : {
178 : : long l;
179 : : char *endp;
180 : :
9233 tgl@sss.pgh.pa.us 181 [ + + + + ]: 1391 : while (*intString && isspace((unsigned char) *intString))
9561 bruce@momjian.us 182 : 327 : intString++;
5919 rhaas@postgresql.org 183 [ + + ]: 1064 : if (*intString == '\0')
5861 bruce@momjian.us 184 : 370 : break;
185 : :
1155 tgl@sss.pgh.pa.us 186 [ - + ]: 694 : if (n >= nalloc)
187 : : {
1155 tgl@sss.pgh.pa.us 188 :UBC 0 : nalloc *= 2;
189 : 0 : result = (int2vector *) repalloc(result, Int2VectorSize(nalloc));
190 : : }
191 : :
1490 peter@eisentraut.org 192 :CBC 694 : errno = 0;
193 : 694 : l = strtol(intString, &endp, 10);
194 : :
195 [ + + ]: 694 : if (intString == endp)
1187 tgl@sss.pgh.pa.us 196 [ + - ]: 6 : ereturn(escontext, (Datum) 0,
197 : : (errcode(ERRCODE_INVALID_TEXT_REPRESENTATION),
198 : : errmsg("invalid input syntax for type %s: \"%s\"",
199 : : "smallint", intString)));
200 : :
1490 peter@eisentraut.org 201 [ + - + - : 691 : if (errno == ERANGE || l < SHRT_MIN || l > SHRT_MAX)
+ + ]
1187 tgl@sss.pgh.pa.us 202 [ + - ]: 3 : ereturn(escontext, (Datum) 0,
203 : : (errcode(ERRCODE_NUMERIC_VALUE_OUT_OF_RANGE),
204 : : errmsg("value \"%s\" is out of range for type %s", intString,
205 : : "smallint")));
206 : :
1490 peter@eisentraut.org 207 [ + + - + ]: 688 : if (*endp && *endp != ' ')
1187 tgl@sss.pgh.pa.us 208 [ # # ]:UBC 0 : ereturn(escontext, (Datum) 0,
209 : : (errcode(ERRCODE_INVALID_TEXT_REPRESENTATION),
210 : : errmsg("invalid input syntax for type %s: \"%s\"",
211 : : "smallint", intString)));
212 : :
1490 peter@eisentraut.org 213 :CBC 688 : result->values[n] = l;
214 : 688 : intString = endp;
215 : : }
216 : :
6956 tgl@sss.pgh.pa.us 217 : 370 : SET_VARSIZE(result, Int2VectorSize(n));
7656 218 : 370 : result->ndim = 1;
7423 219 : 370 : result->dataoffset = 0; /* never any nulls */
7656 220 : 370 : result->elemtype = INT2OID;
221 : 370 : result->dim1 = n;
222 : 370 : result->lbound1 = 0;
223 : :
9414 224 : 370 : PG_RETURN_POINTER(result);
225 : : }
226 : :
227 : : /*
228 : : * int2vectorout - converts internal form to "num num ..."
229 : : */
230 : : Datum
231 : 7091 : int2vectorout(PG_FUNCTION_ARGS)
232 : : {
7656 233 : 7091 : int2vector *int2Array = (int2vector *) PG_GETARG_POINTER(0);
234 : : int num,
235 : : nnums;
236 : : char *rp;
237 : : char *result;
238 : :
239 : : /* validate input before fetching dim1 */
34 240 : 7091 : check_valid_int2vector(int2Array);
241 : 7088 : nnums = int2Array->dim1;
242 : :
243 : : /* assumes sign, 5 digits, ' ' */
7656 244 : 7088 : rp = result = (char *) palloc(nnums * 7 + 1);
245 [ + + ]: 18411 : for (num = 0; num < nnums; num++)
246 : : {
9561 bruce@momjian.us 247 [ + + ]: 11323 : if (num != 0)
248 : 4730 : *rp++ = ' ';
2101 drowley@postgresql.o 249 : 11323 : rp += pg_itoa(int2Array->values[num], rp);
250 : : }
9561 bruce@momjian.us 251 : 7088 : *rp = '\0';
9414 tgl@sss.pgh.pa.us 252 : 7088 : PG_RETURN_CSTRING(result);
253 : : }
254 : :
255 : : /*
256 : : * int2vectorrecv - converts external binary format to int2vector
257 : : */
258 : : Datum
8346 tgl@sss.pgh.pa.us 259 :UBC 0 : int2vectorrecv(PG_FUNCTION_ARGS)
260 : : {
2605 andres@anarazel.de 261 : 0 : LOCAL_FCINFO(locfcinfo, 3);
8346 tgl@sss.pgh.pa.us 262 : 0 : StringInfo buf = (StringInfo) PG_GETARG_POINTER(0);
263 : : int2vector *result;
264 : :
265 : : /*
266 : : * Normally one would call array_recv() using DirectFunctionCall3, but
267 : : * that does not work since array_recv wants to cache some data using
268 : : * fcinfo->flinfo->fn_extra. So we need to pass it our own flinfo
269 : : * parameter.
270 : : */
2605 andres@anarazel.de 271 : 0 : InitFunctionCallInfoData(*locfcinfo, fcinfo->flinfo, 3,
272 : : InvalidOid, NULL, NULL);
273 : :
274 : 0 : locfcinfo->args[0].value = PointerGetDatum(buf);
275 : 0 : locfcinfo->args[0].isnull = false;
276 : 0 : locfcinfo->args[1].value = ObjectIdGetDatum(INT2OID);
277 : 0 : locfcinfo->args[1].isnull = false;
278 : 0 : locfcinfo->args[2].value = Int32GetDatum(-1);
279 : 0 : locfcinfo->args[2].isnull = false;
280 : :
281 : 0 : result = (int2vector *) DatumGetPointer(array_recv(locfcinfo));
282 : :
283 [ # # ]: 0 : Assert(!locfcinfo->isnull);
284 : :
285 : : /* sanity checks: int2vector must be 1-D, 0-based, no nulls */
7423 tgl@sss.pgh.pa.us 286 [ # # ]: 0 : if (ARR_NDIM(result) != 1 ||
287 [ # # ]: 0 : ARR_HASNULL(result) ||
6036 heikki.linnakangas@i 288 [ # # ]: 0 : ARR_ELEMTYPE(result) != INT2OID ||
289 [ # # ]: 0 : ARR_LBOUND(result)[0] != 0)
7656 tgl@sss.pgh.pa.us 290 [ # # ]: 0 : ereport(ERROR,
291 : : (errcode(ERRCODE_INVALID_BINARY_REPRESENTATION),
292 : : errmsg("invalid int2vector data")));
293 : :
8346 294 : 0 : PG_RETURN_POINTER(result);
295 : : }
296 : :
297 : : /*
298 : : * int2vectorsend - converts int2vector to binary format
299 : : */
300 : : Datum
301 : 0 : int2vectorsend(PG_FUNCTION_ARGS)
302 : : {
303 : : /* We don't do check_valid_int2vector, since array_send won't care */
7656 304 : 0 : return array_send(fcinfo);
305 : : }
306 : :
307 : :
308 : : /*****************************************************************************
309 : : * PUBLIC ROUTINES *
310 : : *****************************************************************************/
311 : :
312 : : /*
313 : : * int4in - converts "num" to int4
314 : : */
315 : : Datum
9414 tgl@sss.pgh.pa.us 316 :CBC 2338363 : int4in(PG_FUNCTION_ARGS)
317 : : {
318 : 2338363 : char *num = PG_GETARG_CSTRING(0);
319 : :
1192 320 : 2338363 : PG_RETURN_INT32(pg_strtoint32_safe(num, fcinfo->context));
321 : : }
322 : :
323 : : /*
324 : : * int4out - converts int4 to "num"
325 : : */
326 : : Datum
9414 327 : 9664734 : int4out(PG_FUNCTION_ARGS)
328 : : {
329 : 9664734 : int32 arg1 = PG_GETARG_INT32(0);
9124 bruce@momjian.us 330 : 9664734 : char *result = (char *) palloc(12); /* sign, 10 digits, '\0' */
331 : :
9357 tgl@sss.pgh.pa.us 332 : 9664734 : pg_ltoa(arg1, result);
9414 333 : 9664734 : PG_RETURN_CSTRING(result);
334 : : }
335 : :
336 : : /*
337 : : * int4recv - converts external binary format to int4
338 : : */
339 : : Datum
8346 340 : 101619 : int4recv(PG_FUNCTION_ARGS)
341 : : {
342 : 101619 : StringInfo buf = (StringInfo) PG_GETARG_POINTER(0);
343 : :
344 : 101619 : PG_RETURN_INT32((int32) pq_getmsgint(buf, sizeof(int32)));
345 : : }
346 : :
347 : : /*
348 : : * int4send - converts int4 to binary format
349 : : */
350 : : Datum
351 : 104566 : int4send(PG_FUNCTION_ARGS)
352 : : {
353 : 104566 : int32 arg1 = PG_GETARG_INT32(0);
354 : : StringInfoData buf;
355 : :
356 : 104566 : pq_begintypsend(&buf);
3077 andres@anarazel.de 357 : 104566 : pq_sendint32(&buf, arg1);
8346 tgl@sss.pgh.pa.us 358 : 104566 : PG_RETURN_BYTEA_P(pq_endtypsend(&buf));
359 : : }
360 : :
361 : :
362 : : /*
363 : : * ===================
364 : : * CONVERSION ROUTINES
365 : : * ===================
366 : : */
367 : :
368 : : Datum
9414 369 : 18215 : i2toi4(PG_FUNCTION_ARGS)
370 : : {
371 : 18215 : int16 arg1 = PG_GETARG_INT16(0);
372 : :
373 : 18215 : PG_RETURN_INT32((int32) arg1);
374 : : }
375 : :
376 : : Datum
377 : 11667 : i4toi2(PG_FUNCTION_ARGS)
378 : : {
379 : 11667 : int32 arg1 = PG_GETARG_INT32(0);
380 : :
3015 andres@anarazel.de 381 [ + + + + ]: 11667 : if (unlikely(arg1 < SHRT_MIN) || unlikely(arg1 > SHRT_MAX))
8267 tgl@sss.pgh.pa.us 382 [ + - ]: 14 : ereport(ERROR,
383 : : (errcode(ERRCODE_NUMERIC_VALUE_OUT_OF_RANGE),
384 : : errmsg("smallint out of range")));
385 : :
9414 386 : 11653 : PG_RETURN_INT16((int16) arg1);
387 : : }
388 : :
389 : : /* Cast int4 -> bool */
390 : : Datum
7686 neilc@samurai.com 391 : 15 : int4_bool(PG_FUNCTION_ARGS)
392 : : {
393 [ + + ]: 15 : if (PG_GETARG_INT32(0) == 0)
394 : 6 : PG_RETURN_BOOL(false);
395 : : else
396 : 9 : PG_RETURN_BOOL(true);
397 : : }
398 : :
399 : : /* Cast bool -> int4 */
400 : : Datum
401 : 902 : bool_int4(PG_FUNCTION_ARGS)
402 : : {
403 [ + + ]: 902 : if (PG_GETARG_BOOL(0) == false)
404 : 509 : PG_RETURN_INT32(0);
405 : : else
406 : 393 : PG_RETURN_INT32(1);
407 : : }
408 : :
409 : : /*
410 : : * ============================
411 : : * COMPARISON OPERATOR ROUTINES
412 : : * ============================
413 : : */
414 : :
415 : : /*
416 : : * inteq - returns 1 iff arg1 == arg2
417 : : * intne - returns 1 iff arg1 != arg2
418 : : * intlt - returns 1 iff arg1 < arg2
419 : : * intle - returns 1 iff arg1 <= arg2
420 : : * intgt - returns 1 iff arg1 > arg2
421 : : * intge - returns 1 iff arg1 >= arg2
422 : : */
423 : :
424 : : Datum
9414 tgl@sss.pgh.pa.us 425 : 28496526 : int4eq(PG_FUNCTION_ARGS)
426 : : {
427 : 28496526 : int32 arg1 = PG_GETARG_INT32(0);
428 : 28496526 : int32 arg2 = PG_GETARG_INT32(1);
429 : :
430 : 28496526 : PG_RETURN_BOOL(arg1 == arg2);
431 : : }
432 : :
433 : : Datum
434 : 203205 : int4ne(PG_FUNCTION_ARGS)
435 : : {
436 : 203205 : int32 arg1 = PG_GETARG_INT32(0);
437 : 203205 : int32 arg2 = PG_GETARG_INT32(1);
438 : :
439 : 203205 : PG_RETURN_BOOL(arg1 != arg2);
440 : : }
441 : :
442 : : Datum
443 : 112146974 : int4lt(PG_FUNCTION_ARGS)
444 : : {
445 : 112146974 : int32 arg1 = PG_GETARG_INT32(0);
446 : 112146974 : int32 arg2 = PG_GETARG_INT32(1);
447 : :
448 : 112146974 : PG_RETURN_BOOL(arg1 < arg2);
449 : : }
450 : :
451 : : Datum
452 : 701798 : int4le(PG_FUNCTION_ARGS)
453 : : {
454 : 701798 : int32 arg1 = PG_GETARG_INT32(0);
455 : 701798 : int32 arg2 = PG_GETARG_INT32(1);
456 : :
457 : 701798 : PG_RETURN_BOOL(arg1 <= arg2);
458 : : }
459 : :
460 : : Datum
461 : 2490220 : int4gt(PG_FUNCTION_ARGS)
462 : : {
463 : 2490220 : int32 arg1 = PG_GETARG_INT32(0);
464 : 2490220 : int32 arg2 = PG_GETARG_INT32(1);
465 : :
466 : 2490220 : PG_RETURN_BOOL(arg1 > arg2);
467 : : }
468 : :
469 : : Datum
470 : 370909 : int4ge(PG_FUNCTION_ARGS)
471 : : {
472 : 370909 : int32 arg1 = PG_GETARG_INT32(0);
473 : 370909 : int32 arg2 = PG_GETARG_INT32(1);
474 : :
475 : 370909 : PG_RETURN_BOOL(arg1 >= arg2);
476 : : }
477 : :
478 : : Datum
479 : 1461965 : int2eq(PG_FUNCTION_ARGS)
480 : : {
481 : 1461965 : int16 arg1 = PG_GETARG_INT16(0);
482 : 1461965 : int16 arg2 = PG_GETARG_INT16(1);
483 : :
484 : 1461965 : PG_RETURN_BOOL(arg1 == arg2);
485 : : }
486 : :
487 : : Datum
488 : 16118 : int2ne(PG_FUNCTION_ARGS)
489 : : {
490 : 16118 : int16 arg1 = PG_GETARG_INT16(0);
491 : 16118 : int16 arg2 = PG_GETARG_INT16(1);
492 : :
493 : 16118 : PG_RETURN_BOOL(arg1 != arg2);
494 : : }
495 : :
496 : : Datum
497 : 463958 : int2lt(PG_FUNCTION_ARGS)
498 : : {
499 : 463958 : int16 arg1 = PG_GETARG_INT16(0);
500 : 463958 : int16 arg2 = PG_GETARG_INT16(1);
501 : :
502 : 463958 : PG_RETURN_BOOL(arg1 < arg2);
503 : : }
504 : :
505 : : Datum
506 : 2601 : int2le(PG_FUNCTION_ARGS)
507 : : {
508 : 2601 : int16 arg1 = PG_GETARG_INT16(0);
509 : 2601 : int16 arg2 = PG_GETARG_INT16(1);
510 : :
511 : 2601 : PG_RETURN_BOOL(arg1 <= arg2);
512 : : }
513 : :
514 : : Datum
515 : 2967003 : int2gt(PG_FUNCTION_ARGS)
516 : : {
517 : 2967003 : int16 arg1 = PG_GETARG_INT16(0);
518 : 2967003 : int16 arg2 = PG_GETARG_INT16(1);
519 : :
520 : 2967003 : PG_RETURN_BOOL(arg1 > arg2);
521 : : }
522 : :
523 : : Datum
524 : 1857 : int2ge(PG_FUNCTION_ARGS)
525 : : {
526 : 1857 : int16 arg1 = PG_GETARG_INT16(0);
527 : 1857 : int16 arg2 = PG_GETARG_INT16(1);
528 : :
529 : 1857 : PG_RETURN_BOOL(arg1 >= arg2);
530 : : }
531 : :
532 : : Datum
533 : 88413 : int24eq(PG_FUNCTION_ARGS)
534 : : {
535 : 88413 : int16 arg1 = PG_GETARG_INT16(0);
536 : 88413 : int32 arg2 = PG_GETARG_INT32(1);
537 : :
538 : 88413 : PG_RETURN_BOOL(arg1 == arg2);
539 : : }
540 : :
541 : : Datum
542 : 37706 : int24ne(PG_FUNCTION_ARGS)
543 : : {
544 : 37706 : int16 arg1 = PG_GETARG_INT16(0);
545 : 37706 : int32 arg2 = PG_GETARG_INT32(1);
546 : :
547 : 37706 : PG_RETURN_BOOL(arg1 != arg2);
548 : : }
549 : :
550 : : Datum
551 : 76141 : int24lt(PG_FUNCTION_ARGS)
552 : : {
553 : 76141 : int16 arg1 = PG_GETARG_INT16(0);
554 : 76141 : int32 arg2 = PG_GETARG_INT32(1);
555 : :
556 : 76141 : PG_RETURN_BOOL(arg1 < arg2);
557 : : }
558 : :
559 : : Datum
560 : 37246 : int24le(PG_FUNCTION_ARGS)
561 : : {
562 : 37246 : int16 arg1 = PG_GETARG_INT16(0);
563 : 37246 : int32 arg2 = PG_GETARG_INT32(1);
564 : :
565 : 37246 : PG_RETURN_BOOL(arg1 <= arg2);
566 : : }
567 : :
568 : : Datum
569 : 322086 : int24gt(PG_FUNCTION_ARGS)
570 : : {
571 : 322086 : int16 arg1 = PG_GETARG_INT16(0);
572 : 322086 : int32 arg2 = PG_GETARG_INT32(1);
573 : :
574 : 322086 : PG_RETURN_BOOL(arg1 > arg2);
575 : : }
576 : :
577 : : Datum
578 : 4966 : int24ge(PG_FUNCTION_ARGS)
579 : : {
580 : 4966 : int16 arg1 = PG_GETARG_INT16(0);
581 : 4966 : int32 arg2 = PG_GETARG_INT32(1);
582 : :
583 : 4966 : PG_RETURN_BOOL(arg1 >= arg2);
584 : : }
585 : :
586 : : Datum
587 : 12229 : int42eq(PG_FUNCTION_ARGS)
588 : : {
589 : 12229 : int32 arg1 = PG_GETARG_INT32(0);
590 : 12229 : int16 arg2 = PG_GETARG_INT16(1);
591 : :
592 : 12229 : PG_RETURN_BOOL(arg1 == arg2);
593 : : }
594 : :
595 : : Datum
596 : 15 : int42ne(PG_FUNCTION_ARGS)
597 : : {
598 : 15 : int32 arg1 = PG_GETARG_INT32(0);
599 : 15 : int16 arg2 = PG_GETARG_INT16(1);
600 : :
601 : 15 : PG_RETURN_BOOL(arg1 != arg2);
602 : : }
603 : :
604 : : Datum
605 : 9599 : int42lt(PG_FUNCTION_ARGS)
606 : : {
607 : 9599 : int32 arg1 = PG_GETARG_INT32(0);
608 : 9599 : int16 arg2 = PG_GETARG_INT16(1);
609 : :
610 : 9599 : PG_RETURN_BOOL(arg1 < arg2);
611 : : }
612 : :
613 : : Datum
614 : 9373 : int42le(PG_FUNCTION_ARGS)
615 : : {
616 : 9373 : int32 arg1 = PG_GETARG_INT32(0);
617 : 9373 : int16 arg2 = PG_GETARG_INT16(1);
618 : :
619 : 9373 : PG_RETURN_BOOL(arg1 <= arg2);
620 : : }
621 : :
622 : : Datum
623 : 1614 : int42gt(PG_FUNCTION_ARGS)
624 : : {
625 : 1614 : int32 arg1 = PG_GETARG_INT32(0);
626 : 1614 : int16 arg2 = PG_GETARG_INT16(1);
627 : :
628 : 1614 : PG_RETURN_BOOL(arg1 > arg2);
629 : : }
630 : :
631 : : Datum
632 : 1728 : int42ge(PG_FUNCTION_ARGS)
633 : : {
634 : 1728 : int32 arg1 = PG_GETARG_INT32(0);
635 : 1728 : int16 arg2 = PG_GETARG_INT16(1);
636 : :
637 : 1728 : PG_RETURN_BOOL(arg1 >= arg2);
638 : : }
639 : :
640 : :
641 : : /*----------------------------------------------------------
642 : : * in_range functions for int4 and int2,
643 : : * including cross-data-type comparisons.
644 : : *
645 : : * Note: we provide separate intN_int8 functions for performance
646 : : * reasons. This forces also providing intN_int2, else cases with a
647 : : * smallint offset value would fail to resolve which function to use.
648 : : * But that's an unlikely situation, so don't duplicate code for it.
649 : : *---------------------------------------------------------*/
650 : :
651 : : Datum
2958 652 : 1599 : in_range_int4_int4(PG_FUNCTION_ARGS)
653 : : {
654 : 1599 : int32 val = PG_GETARG_INT32(0);
655 : 1599 : int32 base = PG_GETARG_INT32(1);
656 : 1599 : int32 offset = PG_GETARG_INT32(2);
657 : 1599 : bool sub = PG_GETARG_BOOL(3);
658 : 1599 : bool less = PG_GETARG_BOOL(4);
659 : : int32 sum;
660 : :
661 [ + + ]: 1599 : if (offset < 0)
662 [ + - ]: 6 : ereport(ERROR,
663 : : (errcode(ERRCODE_INVALID_PRECEDING_OR_FOLLOWING_SIZE),
664 : : errmsg("invalid preceding or following size in window function")));
665 : :
666 [ + + ]: 1593 : if (sub)
667 : 720 : offset = -offset; /* cannot overflow */
668 : :
669 [ + + ]: 1593 : if (unlikely(pg_add_s32_overflow(base, offset, &sum)))
670 : : {
671 : : /*
672 : : * If sub is false, the true sum is surely more than val, so correct
673 : : * answer is the same as "less". If sub is true, the true sum is
674 : : * surely less than val, so the answer is "!less".
675 : : */
676 [ + + ]: 18 : PG_RETURN_BOOL(sub ? !less : less);
677 : : }
678 : :
679 [ + + ]: 1575 : if (less)
680 : 930 : PG_RETURN_BOOL(val <= sum);
681 : : else
682 : 645 : PG_RETURN_BOOL(val >= sum);
683 : : }
684 : :
685 : : Datum
686 : 453 : in_range_int4_int2(PG_FUNCTION_ARGS)
687 : : {
688 : : /* Doesn't seem worth duplicating code for, so just invoke int4_int4 */
689 : 453 : return DirectFunctionCall5(in_range_int4_int4,
690 : : PG_GETARG_DATUM(0),
691 : : PG_GETARG_DATUM(1),
692 : : Int32GetDatum((int32) PG_GETARG_INT16(2)),
693 : : PG_GETARG_DATUM(3),
694 : : PG_GETARG_DATUM(4));
695 : : }
696 : :
697 : : Datum
698 : 381 : in_range_int4_int8(PG_FUNCTION_ARGS)
699 : : {
700 : : /* We must do all the math in int64 */
701 : 381 : int64 val = (int64) PG_GETARG_INT32(0);
702 : 381 : int64 base = (int64) PG_GETARG_INT32(1);
703 : 381 : int64 offset = PG_GETARG_INT64(2);
704 : 381 : bool sub = PG_GETARG_BOOL(3);
705 : 381 : bool less = PG_GETARG_BOOL(4);
706 : : int64 sum;
707 : :
708 [ - + ]: 381 : if (offset < 0)
2958 tgl@sss.pgh.pa.us 709 [ # # ]:UBC 0 : ereport(ERROR,
710 : : (errcode(ERRCODE_INVALID_PRECEDING_OR_FOLLOWING_SIZE),
711 : : errmsg("invalid preceding or following size in window function")));
712 : :
2958 tgl@sss.pgh.pa.us 713 [ + + ]:CBC 381 : if (sub)
714 : 345 : offset = -offset; /* cannot overflow */
715 : :
716 [ - + ]: 381 : if (unlikely(pg_add_s64_overflow(base, offset, &sum)))
717 : : {
718 : : /*
719 : : * If sub is false, the true sum is surely more than val, so correct
720 : : * answer is the same as "less". If sub is true, the true sum is
721 : : * surely less than val, so the answer is "!less".
722 : : */
2958 tgl@sss.pgh.pa.us 723 [ # # ]:UBC 0 : PG_RETURN_BOOL(sub ? !less : less);
724 : : }
725 : :
2958 tgl@sss.pgh.pa.us 726 [ + + ]:CBC 381 : if (less)
727 : 36 : PG_RETURN_BOOL(val <= sum);
728 : : else
729 : 345 : PG_RETURN_BOOL(val >= sum);
730 : : }
731 : :
732 : : Datum
733 : 18 : in_range_int2_int4(PG_FUNCTION_ARGS)
734 : : {
735 : : /* We must do all the math in int32 */
736 : 18 : int32 val = (int32) PG_GETARG_INT16(0);
737 : 18 : int32 base = (int32) PG_GETARG_INT16(1);
738 : 18 : int32 offset = PG_GETARG_INT32(2);
739 : 18 : bool sub = PG_GETARG_BOOL(3);
740 : 18 : bool less = PG_GETARG_BOOL(4);
741 : : int32 sum;
742 : :
743 [ - + ]: 18 : if (offset < 0)
2958 tgl@sss.pgh.pa.us 744 [ # # ]:UBC 0 : ereport(ERROR,
745 : : (errcode(ERRCODE_INVALID_PRECEDING_OR_FOLLOWING_SIZE),
746 : : errmsg("invalid preceding or following size in window function")));
747 : :
2958 tgl@sss.pgh.pa.us 748 [ + + ]:CBC 18 : if (sub)
749 : 9 : offset = -offset; /* cannot overflow */
750 : :
751 [ + - ]: 18 : if (unlikely(pg_add_s32_overflow(base, offset, &sum)))
752 : : {
753 : : /*
754 : : * If sub is false, the true sum is surely more than val, so correct
755 : : * answer is the same as "less". If sub is true, the true sum is
756 : : * surely less than val, so the answer is "!less".
757 : : */
758 [ + + ]: 18 : PG_RETURN_BOOL(sub ? !less : less);
759 : : }
760 : :
2958 tgl@sss.pgh.pa.us 761 [ # # ]:UBC 0 : if (less)
762 : 0 : PG_RETURN_BOOL(val <= sum);
763 : : else
764 : 0 : PG_RETURN_BOOL(val >= sum);
765 : : }
766 : :
767 : : Datum
768 : 0 : in_range_int2_int2(PG_FUNCTION_ARGS)
769 : : {
770 : : /* Doesn't seem worth duplicating code for, so just invoke int2_int4 */
771 : 0 : return DirectFunctionCall5(in_range_int2_int4,
772 : : PG_GETARG_DATUM(0),
773 : : PG_GETARG_DATUM(1),
774 : : Int32GetDatum((int32) PG_GETARG_INT16(2)),
775 : : PG_GETARG_DATUM(3),
776 : : PG_GETARG_DATUM(4));
777 : : }
778 : :
779 : : Datum
780 : 0 : in_range_int2_int8(PG_FUNCTION_ARGS)
781 : : {
782 : : /* Doesn't seem worth duplicating code for, so just invoke int4_int8 */
783 : 0 : return DirectFunctionCall5(in_range_int4_int8,
784 : : Int32GetDatum((int32) PG_GETARG_INT16(0)),
785 : : Int32GetDatum((int32) PG_GETARG_INT16(1)),
786 : : PG_GETARG_DATUM(2),
787 : : PG_GETARG_DATUM(3),
788 : : PG_GETARG_DATUM(4));
789 : : }
790 : :
791 : :
792 : : /*
793 : : * int[24]pl - returns arg1 + arg2
794 : : * int[24]mi - returns arg1 - arg2
795 : : * int[24]mul - returns arg1 * arg2
796 : : * int[24]div - returns arg1 / arg2
797 : : */
798 : :
799 : : Datum
9414 tgl@sss.pgh.pa.us 800 :CBC 26472 : int4um(PG_FUNCTION_ARGS)
801 : : {
802 : 26472 : int32 arg = PG_GETARG_INT32(0);
803 : :
3015 andres@anarazel.de 804 [ - + ]: 26472 : if (unlikely(arg == PG_INT32_MIN))
7832 tgl@sss.pgh.pa.us 805 [ # # ]:UBC 0 : ereport(ERROR,
806 : : (errcode(ERRCODE_NUMERIC_VALUE_OUT_OF_RANGE),
807 : : errmsg("integer out of range")));
3015 andres@anarazel.de 808 :CBC 26472 : PG_RETURN_INT32(-arg);
809 : : }
810 : :
811 : : Datum
9047 bruce@momjian.us 812 : 3 : int4up(PG_FUNCTION_ARGS)
813 : : {
814 : 3 : int32 arg = PG_GETARG_INT32(0);
815 : :
816 : 3 : PG_RETURN_INT32(arg);
817 : : }
818 : :
819 : : Datum
9414 tgl@sss.pgh.pa.us 820 : 3664601 : int4pl(PG_FUNCTION_ARGS)
821 : : {
822 : 3664601 : int32 arg1 = PG_GETARG_INT32(0);
823 : 3664601 : int32 arg2 = PG_GETARG_INT32(1);
824 : : int32 result;
825 : :
3015 andres@anarazel.de 826 [ + + ]: 3664601 : if (unlikely(pg_add_s32_overflow(arg1, arg2, &result)))
7832 tgl@sss.pgh.pa.us 827 [ + - ]: 3 : ereport(ERROR,
828 : : (errcode(ERRCODE_NUMERIC_VALUE_OUT_OF_RANGE),
829 : : errmsg("integer out of range")));
830 : 3664598 : PG_RETURN_INT32(result);
831 : : }
832 : :
833 : : Datum
9414 834 : 1447604 : int4mi(PG_FUNCTION_ARGS)
835 : : {
836 : 1447604 : int32 arg1 = PG_GETARG_INT32(0);
837 : 1447604 : int32 arg2 = PG_GETARG_INT32(1);
838 : : int32 result;
839 : :
3015 andres@anarazel.de 840 [ + + ]: 1447604 : if (unlikely(pg_sub_s32_overflow(arg1, arg2, &result)))
7832 tgl@sss.pgh.pa.us 841 [ + - ]: 3 : ereport(ERROR,
842 : : (errcode(ERRCODE_NUMERIC_VALUE_OUT_OF_RANGE),
843 : : errmsg("integer out of range")));
844 : 1447601 : PG_RETURN_INT32(result);
845 : : }
846 : :
847 : : Datum
9414 848 : 1427248 : int4mul(PG_FUNCTION_ARGS)
849 : : {
850 : 1427248 : int32 arg1 = PG_GETARG_INT32(0);
851 : 1427248 : int32 arg2 = PG_GETARG_INT32(1);
852 : : int32 result;
853 : :
3015 andres@anarazel.de 854 [ + + ]: 1427248 : if (unlikely(pg_mul_s32_overflow(arg1, arg2, &result)))
7832 tgl@sss.pgh.pa.us 855 [ + - ]: 12 : ereport(ERROR,
856 : : (errcode(ERRCODE_NUMERIC_VALUE_OUT_OF_RANGE),
857 : : errmsg("integer out of range")));
858 : 1427236 : PG_RETURN_INT32(result);
859 : : }
860 : :
861 : : Datum
9414 862 : 753655 : int4div(PG_FUNCTION_ARGS)
863 : : {
864 : 753655 : int32 arg1 = PG_GETARG_INT32(0);
865 : 753655 : int32 arg2 = PG_GETARG_INT32(1);
866 : : int32 result;
867 : :
8405 868 [ + + ]: 753655 : if (arg2 == 0)
869 : : {
8267 870 [ + - ]: 151 : ereport(ERROR,
871 : : (errcode(ERRCODE_DIVISION_BY_ZERO),
872 : : errmsg("division by zero")));
873 : : /* ensure compiler realizes we mustn't reach the division (gcc bug) */
874 : : PG_RETURN_NULL();
875 : : }
876 : :
877 : : /*
878 : : * INT_MIN / -1 is problematic, since the result can't be represented on a
879 : : * two's-complement machine. Some machines produce INT_MIN, some produce
880 : : * zero, some throw an exception. We can dodge the problem by recognizing
881 : : * that division by -1 is the same as negation.
882 : : */
4864 883 [ + + ]: 753504 : if (arg2 == -1)
884 : : {
3015 andres@anarazel.de 885 [ + + ]: 8 : if (unlikely(arg1 == PG_INT32_MIN))
4864 tgl@sss.pgh.pa.us 886 [ + - ]: 3 : ereport(ERROR,
887 : : (errcode(ERRCODE_NUMERIC_VALUE_OUT_OF_RANGE),
888 : : errmsg("integer out of range")));
3015 andres@anarazel.de 889 : 5 : result = -arg1;
4864 tgl@sss.pgh.pa.us 890 : 5 : PG_RETURN_INT32(result);
891 : : }
892 : :
893 : : /* No overflow is possible */
894 : :
7832 895 : 753496 : result = arg1 / arg2;
896 : :
897 : 753496 : PG_RETURN_INT32(result);
898 : : }
899 : :
900 : : Datum
9414 tgl@sss.pgh.pa.us 901 :UBC 0 : int4inc(PG_FUNCTION_ARGS)
902 : : {
903 : 0 : int32 arg = PG_GETARG_INT32(0);
904 : : int32 result;
905 : :
3015 andres@anarazel.de 906 [ # # ]: 0 : if (unlikely(pg_add_s32_overflow(arg, 1, &result)))
7832 tgl@sss.pgh.pa.us 907 [ # # ]: 0 : ereport(ERROR,
908 : : (errcode(ERRCODE_NUMERIC_VALUE_OUT_OF_RANGE),
909 : : errmsg("integer out of range")));
910 : :
911 : 0 : PG_RETURN_INT32(result);
912 : : }
913 : :
914 : : Datum
9414 tgl@sss.pgh.pa.us 915 :CBC 9 : int2um(PG_FUNCTION_ARGS)
916 : : {
917 : 9 : int16 arg = PG_GETARG_INT16(0);
918 : :
3015 andres@anarazel.de 919 [ - + ]: 9 : if (unlikely(arg == PG_INT16_MIN))
7832 tgl@sss.pgh.pa.us 920 [ # # ]:UBC 0 : ereport(ERROR,
921 : : (errcode(ERRCODE_NUMERIC_VALUE_OUT_OF_RANGE),
922 : : errmsg("smallint out of range")));
3015 andres@anarazel.de 923 :CBC 9 : PG_RETURN_INT16(-arg);
924 : : }
925 : :
926 : : Datum
9047 bruce@momjian.us 927 :UBC 0 : int2up(PG_FUNCTION_ARGS)
928 : : {
929 : 0 : int16 arg = PG_GETARG_INT16(0);
930 : :
931 : 0 : PG_RETURN_INT16(arg);
932 : : }
933 : :
934 : : Datum
9414 tgl@sss.pgh.pa.us 935 :CBC 27 : int2pl(PG_FUNCTION_ARGS)
936 : : {
937 : 27 : int16 arg1 = PG_GETARG_INT16(0);
938 : 27 : int16 arg2 = PG_GETARG_INT16(1);
939 : : int16 result;
940 : :
3015 andres@anarazel.de 941 [ + + ]: 27 : if (unlikely(pg_add_s16_overflow(arg1, arg2, &result)))
7832 tgl@sss.pgh.pa.us 942 [ + - ]: 3 : ereport(ERROR,
943 : : (errcode(ERRCODE_NUMERIC_VALUE_OUT_OF_RANGE),
944 : : errmsg("smallint out of range")));
945 : 24 : PG_RETURN_INT16(result);
946 : : }
947 : :
948 : : Datum
9414 949 : 65 : int2mi(PG_FUNCTION_ARGS)
950 : : {
951 : 65 : int16 arg1 = PG_GETARG_INT16(0);
952 : 65 : int16 arg2 = PG_GETARG_INT16(1);
953 : : int16 result;
954 : :
3015 andres@anarazel.de 955 [ + + ]: 65 : if (unlikely(pg_sub_s16_overflow(arg1, arg2, &result)))
7832 tgl@sss.pgh.pa.us 956 [ + - ]: 3 : ereport(ERROR,
957 : : (errcode(ERRCODE_NUMERIC_VALUE_OUT_OF_RANGE),
958 : : errmsg("smallint out of range")));
959 : 62 : PG_RETURN_INT16(result);
960 : : }
961 : :
962 : : Datum
9414 963 : 27 : int2mul(PG_FUNCTION_ARGS)
964 : : {
965 : 27 : int16 arg1 = PG_GETARG_INT16(0);
966 : 27 : int16 arg2 = PG_GETARG_INT16(1);
967 : : int16 result;
968 : :
3015 andres@anarazel.de 969 [ + + ]: 27 : if (unlikely(pg_mul_s16_overflow(arg1, arg2, &result)))
7832 tgl@sss.pgh.pa.us 970 [ + - ]: 6 : ereport(ERROR,
971 : : (errcode(ERRCODE_NUMERIC_VALUE_OUT_OF_RANGE),
972 : : errmsg("smallint out of range")));
973 : :
3015 andres@anarazel.de 974 : 21 : PG_RETURN_INT16(result);
975 : : }
976 : :
977 : : Datum
9414 tgl@sss.pgh.pa.us 978 : 21 : int2div(PG_FUNCTION_ARGS)
979 : : {
980 : 21 : int16 arg1 = PG_GETARG_INT16(0);
981 : 21 : int16 arg2 = PG_GETARG_INT16(1);
982 : : int16 result;
983 : :
8405 984 [ - + ]: 21 : if (arg2 == 0)
985 : : {
8267 tgl@sss.pgh.pa.us 986 [ # # ]:UBC 0 : ereport(ERROR,
987 : : (errcode(ERRCODE_DIVISION_BY_ZERO),
988 : : errmsg("division by zero")));
989 : : /* ensure compiler realizes we mustn't reach the division (gcc bug) */
990 : : PG_RETURN_NULL();
991 : : }
992 : :
993 : : /*
994 : : * SHRT_MIN / -1 is problematic, since the result can't be represented on
995 : : * a two's-complement machine. Some machines produce SHRT_MIN, some
996 : : * produce zero, some throw an exception. We can dodge the problem by
997 : : * recognizing that division by -1 is the same as negation.
998 : : */
4864 tgl@sss.pgh.pa.us 999 [ + + ]:CBC 21 : if (arg2 == -1)
1000 : : {
3015 andres@anarazel.de 1001 [ + - ]: 3 : if (unlikely(arg1 == PG_INT16_MIN))
4864 tgl@sss.pgh.pa.us 1002 [ + - ]: 3 : ereport(ERROR,
1003 : : (errcode(ERRCODE_NUMERIC_VALUE_OUT_OF_RANGE),
1004 : : errmsg("smallint out of range")));
3015 andres@anarazel.de 1005 :UBC 0 : result = -arg1;
4864 tgl@sss.pgh.pa.us 1006 : 0 : PG_RETURN_INT16(result);
1007 : : }
1008 : :
1009 : : /* No overflow is possible */
1010 : :
4864 tgl@sss.pgh.pa.us 1011 :CBC 18 : result = arg1 / arg2;
1012 : :
7832 1013 : 18 : PG_RETURN_INT16(result);
1014 : : }
1015 : :
1016 : : Datum
9414 1017 : 1128 : int24pl(PG_FUNCTION_ARGS)
1018 : : {
1019 : 1128 : int16 arg1 = PG_GETARG_INT16(0);
1020 : 1128 : int32 arg2 = PG_GETARG_INT32(1);
1021 : : int32 result;
1022 : :
3015 andres@anarazel.de 1023 [ - + ]: 1128 : if (unlikely(pg_add_s32_overflow((int32) arg1, arg2, &result)))
7832 tgl@sss.pgh.pa.us 1024 [ # # ]:UBC 0 : ereport(ERROR,
1025 : : (errcode(ERRCODE_NUMERIC_VALUE_OUT_OF_RANGE),
1026 : : errmsg("integer out of range")));
7832 tgl@sss.pgh.pa.us 1027 :CBC 1128 : PG_RETURN_INT32(result);
1028 : : }
1029 : :
1030 : : Datum
9414 1031 : 12985 : int24mi(PG_FUNCTION_ARGS)
1032 : : {
1033 : 12985 : int16 arg1 = PG_GETARG_INT16(0);
1034 : 12985 : int32 arg2 = PG_GETARG_INT32(1);
1035 : : int32 result;
1036 : :
3015 andres@anarazel.de 1037 [ - + ]: 12985 : if (unlikely(pg_sub_s32_overflow((int32) arg1, arg2, &result)))
7832 tgl@sss.pgh.pa.us 1038 [ # # ]:UBC 0 : ereport(ERROR,
1039 : : (errcode(ERRCODE_NUMERIC_VALUE_OUT_OF_RANGE),
1040 : : errmsg("integer out of range")));
7832 tgl@sss.pgh.pa.us 1041 :CBC 12985 : PG_RETURN_INT32(result);
1042 : : }
1043 : :
1044 : : Datum
9414 1045 : 18 : int24mul(PG_FUNCTION_ARGS)
1046 : : {
1047 : 18 : int16 arg1 = PG_GETARG_INT16(0);
1048 : 18 : int32 arg2 = PG_GETARG_INT32(1);
1049 : : int32 result;
1050 : :
3015 andres@anarazel.de 1051 [ - + ]: 18 : if (unlikely(pg_mul_s32_overflow((int32) arg1, arg2, &result)))
7832 tgl@sss.pgh.pa.us 1052 [ # # ]:UBC 0 : ereport(ERROR,
1053 : : (errcode(ERRCODE_NUMERIC_VALUE_OUT_OF_RANGE),
1054 : : errmsg("integer out of range")));
7832 tgl@sss.pgh.pa.us 1055 :CBC 18 : PG_RETURN_INT32(result);
1056 : : }
1057 : :
1058 : : Datum
9414 1059 : 21 : int24div(PG_FUNCTION_ARGS)
1060 : : {
1061 : 21 : int16 arg1 = PG_GETARG_INT16(0);
1062 : 21 : int32 arg2 = PG_GETARG_INT32(1);
1063 : :
3015 andres@anarazel.de 1064 [ + + ]: 21 : if (unlikely(arg2 == 0))
1065 : : {
8267 tgl@sss.pgh.pa.us 1066 [ + - ]: 3 : ereport(ERROR,
1067 : : (errcode(ERRCODE_DIVISION_BY_ZERO),
1068 : : errmsg("division by zero")));
1069 : : /* ensure compiler realizes we mustn't reach the division (gcc bug) */
1070 : : PG_RETURN_NULL();
1071 : : }
1072 : :
1073 : : /* No overflow is possible */
7832 1074 : 18 : PG_RETURN_INT32((int32) arg1 / arg2);
1075 : : }
1076 : :
1077 : : Datum
9414 1078 : 24 : int42pl(PG_FUNCTION_ARGS)
1079 : : {
1080 : 24 : int32 arg1 = PG_GETARG_INT32(0);
1081 : 24 : int16 arg2 = PG_GETARG_INT16(1);
1082 : : int32 result;
1083 : :
3015 andres@anarazel.de 1084 [ + + ]: 24 : if (unlikely(pg_add_s32_overflow(arg1, (int32) arg2, &result)))
7832 tgl@sss.pgh.pa.us 1085 [ + - ]: 3 : ereport(ERROR,
1086 : : (errcode(ERRCODE_NUMERIC_VALUE_OUT_OF_RANGE),
1087 : : errmsg("integer out of range")));
1088 : 21 : PG_RETURN_INT32(result);
1089 : : }
1090 : :
1091 : : Datum
9414 1092 : 27 : int42mi(PG_FUNCTION_ARGS)
1093 : : {
1094 : 27 : int32 arg1 = PG_GETARG_INT32(0);
1095 : 27 : int16 arg2 = PG_GETARG_INT16(1);
1096 : : int32 result;
1097 : :
3015 andres@anarazel.de 1098 [ + + ]: 27 : if (unlikely(pg_sub_s32_overflow(arg1, (int32) arg2, &result)))
7832 tgl@sss.pgh.pa.us 1099 [ + - ]: 3 : ereport(ERROR,
1100 : : (errcode(ERRCODE_NUMERIC_VALUE_OUT_OF_RANGE),
1101 : : errmsg("integer out of range")));
1102 : 24 : PG_RETURN_INT32(result);
1103 : : }
1104 : :
1105 : : Datum
9414 1106 : 27 : int42mul(PG_FUNCTION_ARGS)
1107 : : {
1108 : 27 : int32 arg1 = PG_GETARG_INT32(0);
1109 : 27 : int16 arg2 = PG_GETARG_INT16(1);
1110 : : int32 result;
1111 : :
3015 andres@anarazel.de 1112 [ + + ]: 27 : if (unlikely(pg_mul_s32_overflow(arg1, (int32) arg2, &result)))
7832 tgl@sss.pgh.pa.us 1113 [ + - ]: 6 : ereport(ERROR,
1114 : : (errcode(ERRCODE_NUMERIC_VALUE_OUT_OF_RANGE),
1115 : : errmsg("integer out of range")));
1116 : 21 : PG_RETURN_INT32(result);
1117 : : }
1118 : :
1119 : : Datum
9414 1120 : 24 : int42div(PG_FUNCTION_ARGS)
1121 : : {
1122 : 24 : int32 arg1 = PG_GETARG_INT32(0);
1123 : 24 : int16 arg2 = PG_GETARG_INT16(1);
1124 : : int32 result;
1125 : :
3015 andres@anarazel.de 1126 [ + + ]: 24 : if (unlikely(arg2 == 0))
1127 : : {
8267 tgl@sss.pgh.pa.us 1128 [ + - ]: 3 : ereport(ERROR,
1129 : : (errcode(ERRCODE_DIVISION_BY_ZERO),
1130 : : errmsg("division by zero")));
1131 : : /* ensure compiler realizes we mustn't reach the division (gcc bug) */
1132 : : PG_RETURN_NULL();
1133 : : }
1134 : :
1135 : : /*
1136 : : * INT_MIN / -1 is problematic, since the result can't be represented on a
1137 : : * two's-complement machine. Some machines produce INT_MIN, some produce
1138 : : * zero, some throw an exception. We can dodge the problem by recognizing
1139 : : * that division by -1 is the same as negation.
1140 : : */
4864 1141 [ + + ]: 21 : if (arg2 == -1)
1142 : : {
3015 andres@anarazel.de 1143 [ + - ]: 3 : if (unlikely(arg1 == PG_INT32_MIN))
4864 tgl@sss.pgh.pa.us 1144 [ + - ]: 3 : ereport(ERROR,
1145 : : (errcode(ERRCODE_NUMERIC_VALUE_OUT_OF_RANGE),
1146 : : errmsg("integer out of range")));
3015 andres@anarazel.de 1147 :UBC 0 : result = -arg1;
4864 tgl@sss.pgh.pa.us 1148 : 0 : PG_RETURN_INT32(result);
1149 : : }
1150 : :
1151 : : /* No overflow is possible */
1152 : :
4864 tgl@sss.pgh.pa.us 1153 :CBC 18 : result = arg1 / arg2;
1154 : :
7832 1155 : 18 : PG_RETURN_INT32(result);
1156 : : }
1157 : :
1158 : : Datum
9414 1159 : 4353407 : int4mod(PG_FUNCTION_ARGS)
1160 : : {
1161 : 4353407 : int32 arg1 = PG_GETARG_INT32(0);
1162 : 4353407 : int32 arg2 = PG_GETARG_INT32(1);
1163 : :
3015 andres@anarazel.de 1164 [ - + ]: 4353407 : if (unlikely(arg2 == 0))
1165 : : {
8267 tgl@sss.pgh.pa.us 1166 [ # # ]:UBC 0 : ereport(ERROR,
1167 : : (errcode(ERRCODE_DIVISION_BY_ZERO),
1168 : : errmsg("division by zero")));
1169 : : /* ensure compiler realizes we mustn't reach the division (gcc bug) */
1170 : : PG_RETURN_NULL();
1171 : : }
1172 : :
1173 : : /*
1174 : : * Some machines throw a floating-point exception for INT_MIN % -1, which
1175 : : * is a bit silly since the correct answer is perfectly well-defined,
1176 : : * namely zero.
1177 : : */
4869 tgl@sss.pgh.pa.us 1178 [ + + ]:CBC 4353407 : if (arg2 == -1)
7012 bruce@momjian.us 1179 : 6 : PG_RETURN_INT32(0);
1180 : :
1181 : : /* No overflow is possible */
1182 : :
9414 tgl@sss.pgh.pa.us 1183 : 4353401 : PG_RETURN_INT32(arg1 % arg2);
1184 : : }
1185 : :
1186 : : Datum
1187 : 18 : int2mod(PG_FUNCTION_ARGS)
1188 : : {
1189 : 18 : int16 arg1 = PG_GETARG_INT16(0);
1190 : 18 : int16 arg2 = PG_GETARG_INT16(1);
1191 : :
3015 andres@anarazel.de 1192 [ - + ]: 18 : if (unlikely(arg2 == 0))
1193 : : {
8267 tgl@sss.pgh.pa.us 1194 [ # # ]:UBC 0 : ereport(ERROR,
1195 : : (errcode(ERRCODE_DIVISION_BY_ZERO),
1196 : : errmsg("division by zero")));
1197 : : /* ensure compiler realizes we mustn't reach the division (gcc bug) */
1198 : : PG_RETURN_NULL();
1199 : : }
1200 : :
1201 : : /*
1202 : : * Some machines throw a floating-point exception for INT_MIN % -1, which
1203 : : * is a bit silly since the correct answer is perfectly well-defined,
1204 : : * namely zero. (It's not clear this ever happens when dealing with
1205 : : * int16, but we might as well have the test for safety.)
1206 : : */
4869 tgl@sss.pgh.pa.us 1207 [ + + ]:CBC 18 : if (arg2 == -1)
1208 : 3 : PG_RETURN_INT16(0);
1209 : :
1210 : : /* No overflow is possible */
1211 : :
9414 1212 : 15 : PG_RETURN_INT16(arg1 % arg2);
1213 : : }
1214 : :
1215 : :
1216 : : /* int[24]abs()
1217 : : * Absolute value
1218 : : */
1219 : : Datum
1220 : 64521 : int4abs(PG_FUNCTION_ARGS)
1221 : : {
1222 : 64521 : int32 arg1 = PG_GETARG_INT32(0);
1223 : : int32 result;
1224 : :
3015 andres@anarazel.de 1225 [ - + ]: 64521 : if (unlikely(arg1 == PG_INT32_MIN))
7832 tgl@sss.pgh.pa.us 1226 [ # # ]:UBC 0 : ereport(ERROR,
1227 : : (errcode(ERRCODE_NUMERIC_VALUE_OUT_OF_RANGE),
1228 : : errmsg("integer out of range")));
3015 andres@anarazel.de 1229 :CBC 64521 : result = (arg1 < 0) ? -arg1 : arg1;
7832 tgl@sss.pgh.pa.us 1230 : 64521 : PG_RETURN_INT32(result);
1231 : : }
1232 : :
1233 : : Datum
9414 1234 : 15 : int2abs(PG_FUNCTION_ARGS)
1235 : : {
1236 : 15 : int16 arg1 = PG_GETARG_INT16(0);
1237 : : int16 result;
1238 : :
3015 andres@anarazel.de 1239 [ - + ]: 15 : if (unlikely(arg1 == PG_INT16_MIN))
7832 tgl@sss.pgh.pa.us 1240 [ # # ]:UBC 0 : ereport(ERROR,
1241 : : (errcode(ERRCODE_NUMERIC_VALUE_OUT_OF_RANGE),
1242 : : errmsg("smallint out of range")));
3015 andres@anarazel.de 1243 :CBC 15 : result = (arg1 < 0) ? -arg1 : arg1;
7832 tgl@sss.pgh.pa.us 1244 : 15 : PG_RETURN_INT16(result);
1245 : : }
1246 : :
1247 : : /*
1248 : : * Greatest Common Divisor
1249 : : *
1250 : : * Returns the largest positive integer that exactly divides both inputs.
1251 : : * Special cases:
1252 : : * - gcd(x, 0) = gcd(0, x) = abs(x)
1253 : : * because 0 is divisible by anything
1254 : : * - gcd(0, 0) = 0
1255 : : * complies with the previous definition and is a common convention
1256 : : *
1257 : : * Special care must be taken if either input is INT_MIN --- gcd(0, INT_MIN),
1258 : : * gcd(INT_MIN, 0) and gcd(INT_MIN, INT_MIN) are all equal to abs(INT_MIN),
1259 : : * which cannot be represented as a 32-bit signed integer.
1260 : : */
1261 : : static int32
2241 dean.a.rasheed@gmail 1262 : 132 : int4gcd_internal(int32 arg1, int32 arg2)
1263 : : {
1264 : : int32 swap;
1265 : : int32 a1,
1266 : : a2;
1267 : :
1268 : : /*
1269 : : * Put the greater absolute value in arg1.
1270 : : *
1271 : : * This would happen automatically in the loop below, but avoids an
1272 : : * expensive modulo operation, and simplifies the special-case handling
1273 : : * for INT_MIN below.
1274 : : *
1275 : : * We do this in negative space in order to handle INT_MIN.
1276 : : */
1277 : 132 : a1 = (arg1 < 0) ? arg1 : -arg1;
1278 : 132 : a2 = (arg2 < 0) ? arg2 : -arg2;
1279 [ + + ]: 132 : if (a1 > a2)
1280 : : {
1281 : 48 : swap = arg1;
1282 : 48 : arg1 = arg2;
1283 : 48 : arg2 = swap;
1284 : : }
1285 : :
1286 : : /* Special care needs to be taken with INT_MIN. See comments above. */
1287 [ + + ]: 132 : if (arg1 == PG_INT32_MIN)
1288 : : {
1289 [ + + + + ]: 45 : if (arg2 == 0 || arg2 == PG_INT32_MIN)
1290 [ + - ]: 6 : ereport(ERROR,
1291 : : (errcode(ERRCODE_NUMERIC_VALUE_OUT_OF_RANGE),
1292 : : errmsg("integer out of range")));
1293 : :
1294 : : /*
1295 : : * Some machines throw a floating-point exception for INT_MIN % -1,
1296 : : * which is a bit silly since the correct answer is perfectly
1297 : : * well-defined, namely zero. Guard against this and just return the
1298 : : * result, gcd(INT_MIN, -1) = 1.
1299 : : */
1300 [ + + ]: 39 : if (arg2 == -1)
1301 : 6 : return 1;
1302 : : }
1303 : :
1304 : : /* Use the Euclidean algorithm to find the GCD */
1305 [ + + ]: 471 : while (arg2 != 0)
1306 : : {
1307 : 351 : swap = arg2;
1308 : 351 : arg2 = arg1 % arg2;
1309 : 351 : arg1 = swap;
1310 : : }
1311 : :
1312 : : /*
1313 : : * Make sure the result is positive. (We know we don't have INT_MIN
1314 : : * anymore).
1315 : : */
1316 [ + + ]: 120 : if (arg1 < 0)
1317 : 51 : arg1 = -arg1;
1318 : :
1319 : 120 : return arg1;
1320 : : }
1321 : :
1322 : : Datum
1323 : 90 : int4gcd(PG_FUNCTION_ARGS)
1324 : : {
2131 tgl@sss.pgh.pa.us 1325 : 90 : int32 arg1 = PG_GETARG_INT32(0);
1326 : 90 : int32 arg2 = PG_GETARG_INT32(1);
1327 : : int32 result;
1328 : :
2241 dean.a.rasheed@gmail 1329 : 90 : result = int4gcd_internal(arg1, arg2);
1330 : :
1331 : 84 : PG_RETURN_INT32(result);
1332 : : }
1333 : :
1334 : : /*
1335 : : * Least Common Multiple
1336 : : */
1337 : : Datum
1338 : 78 : int4lcm(PG_FUNCTION_ARGS)
1339 : : {
2131 tgl@sss.pgh.pa.us 1340 : 78 : int32 arg1 = PG_GETARG_INT32(0);
1341 : 78 : int32 arg2 = PG_GETARG_INT32(1);
1342 : : int32 gcd;
1343 : : int32 result;
1344 : :
1345 : : /*
1346 : : * Handle lcm(x, 0) = lcm(0, x) = 0 as a special case. This prevents a
1347 : : * division-by-zero error below when x is zero, and an overflow error from
1348 : : * the GCD computation when x = INT_MIN.
1349 : : */
2241 dean.a.rasheed@gmail 1350 [ + + + + ]: 78 : if (arg1 == 0 || arg2 == 0)
1351 : 36 : PG_RETURN_INT32(0);
1352 : :
1353 : : /* lcm(x, y) = abs(x / gcd(x, y) * y) */
1354 : 42 : gcd = int4gcd_internal(arg1, arg2);
1355 : 42 : arg1 = arg1 / gcd;
1356 : :
1357 [ + + ]: 42 : if (unlikely(pg_mul_s32_overflow(arg1, arg2, &result)))
1358 [ + - ]: 3 : ereport(ERROR,
1359 : : (errcode(ERRCODE_NUMERIC_VALUE_OUT_OF_RANGE),
1360 : : errmsg("integer out of range")));
1361 : :
1362 : : /* If the result is INT_MIN, it cannot be represented. */
1363 [ + + ]: 39 : if (unlikely(result == PG_INT32_MIN))
1364 [ + - ]: 3 : ereport(ERROR,
1365 : : (errcode(ERRCODE_NUMERIC_VALUE_OUT_OF_RANGE),
1366 : : errmsg("integer out of range")));
1367 : :
1368 [ + + ]: 36 : if (result < 0)
1369 : 18 : result = -result;
1370 : :
1371 : 36 : PG_RETURN_INT32(result);
1372 : : }
1373 : :
1374 : : Datum
9414 tgl@sss.pgh.pa.us 1375 : 201 : int2larger(PG_FUNCTION_ARGS)
1376 : : {
1377 : 201 : int16 arg1 = PG_GETARG_INT16(0);
1378 : 201 : int16 arg2 = PG_GETARG_INT16(1);
1379 : :
1380 : 201 : PG_RETURN_INT16((arg1 > arg2) ? arg1 : arg2);
1381 : : }
1382 : :
1383 : : Datum
9414 tgl@sss.pgh.pa.us 1384 :UBC 0 : int2smaller(PG_FUNCTION_ARGS)
1385 : : {
1386 : 0 : int16 arg1 = PG_GETARG_INT16(0);
1387 : 0 : int16 arg2 = PG_GETARG_INT16(1);
1388 : :
1389 : 0 : PG_RETURN_INT16((arg1 < arg2) ? arg1 : arg2);
1390 : : }
1391 : :
1392 : : Datum
9414 tgl@sss.pgh.pa.us 1393 :CBC 461178 : int4larger(PG_FUNCTION_ARGS)
1394 : : {
1395 : 461178 : int32 arg1 = PG_GETARG_INT32(0);
1396 : 461178 : int32 arg2 = PG_GETARG_INT32(1);
1397 : :
1398 : 461178 : PG_RETURN_INT32((arg1 > arg2) ? arg1 : arg2);
1399 : : }
1400 : :
1401 : : Datum
1402 : 275973 : int4smaller(PG_FUNCTION_ARGS)
1403 : : {
1404 : 275973 : int32 arg1 = PG_GETARG_INT32(0);
1405 : 275973 : int32 arg2 = PG_GETARG_INT32(1);
1406 : :
1407 : 275973 : PG_RETURN_INT32((arg1 < arg2) ? arg1 : arg2);
1408 : : }
1409 : :
1410 : : /*
1411 : : * Bit-pushing operators
1412 : : *
1413 : : * int[24]and - returns arg1 & arg2
1414 : : * int[24]or - returns arg1 | arg2
1415 : : * int[24]xor - returns arg1 # arg2
1416 : : * int[24]not - returns ~arg1
1417 : : * int[24]shl - returns arg1 << arg2
1418 : : * int[24]shr - returns arg1 >> arg2
1419 : : */
1420 : :
1421 : : Datum
9273 peter_e@gmx.net 1422 : 2619 : int4and(PG_FUNCTION_ARGS)
1423 : : {
1424 : 2619 : int32 arg1 = PG_GETARG_INT32(0);
1425 : 2619 : int32 arg2 = PG_GETARG_INT32(1);
1426 : :
1427 : 2619 : PG_RETURN_INT32(arg1 & arg2);
1428 : : }
1429 : :
1430 : : Datum
1431 : 9 : int4or(PG_FUNCTION_ARGS)
1432 : : {
1433 : 9 : int32 arg1 = PG_GETARG_INT32(0);
1434 : 9 : int32 arg2 = PG_GETARG_INT32(1);
1435 : :
1436 : 9 : PG_RETURN_INT32(arg1 | arg2);
1437 : : }
1438 : :
1439 : : Datum
1440 : 9 : int4xor(PG_FUNCTION_ARGS)
1441 : : {
1442 : 9 : int32 arg1 = PG_GETARG_INT32(0);
1443 : 9 : int32 arg2 = PG_GETARG_INT32(1);
1444 : :
1445 : 9 : PG_RETURN_INT32(arg1 ^ arg2);
1446 : : }
1447 : :
1448 : : Datum
1449 : 774 : int4shl(PG_FUNCTION_ARGS)
1450 : : {
1451 : 774 : int32 arg1 = PG_GETARG_INT32(0);
1452 : 774 : int32 arg2 = PG_GETARG_INT32(1);
1453 : :
1454 : 774 : PG_RETURN_INT32(arg1 << arg2);
1455 : : }
1456 : :
1457 : : Datum
9273 peter_e@gmx.net 1458 :UBC 0 : int4shr(PG_FUNCTION_ARGS)
1459 : : {
1460 : 0 : int32 arg1 = PG_GETARG_INT32(0);
1461 : 0 : int32 arg2 = PG_GETARG_INT32(1);
1462 : :
1463 : 0 : PG_RETURN_INT32(arg1 >> arg2);
1464 : : }
1465 : :
1466 : : Datum
1467 : 0 : int4not(PG_FUNCTION_ARGS)
1468 : : {
1469 : 0 : int32 arg1 = PG_GETARG_INT32(0);
1470 : :
1471 : 0 : PG_RETURN_INT32(~arg1);
1472 : : }
1473 : :
1474 : : Datum
9273 peter_e@gmx.net 1475 :CBC 12 : int2and(PG_FUNCTION_ARGS)
1476 : : {
1477 : 12 : int16 arg1 = PG_GETARG_INT16(0);
1478 : 12 : int16 arg2 = PG_GETARG_INT16(1);
1479 : :
1480 : 12 : PG_RETURN_INT16(arg1 & arg2);
1481 : : }
1482 : :
1483 : : Datum
1484 : 12 : int2or(PG_FUNCTION_ARGS)
1485 : : {
1486 : 12 : int16 arg1 = PG_GETARG_INT16(0);
1487 : 12 : int16 arg2 = PG_GETARG_INT16(1);
1488 : :
1489 : 12 : PG_RETURN_INT16(arg1 | arg2);
1490 : : }
1491 : :
1492 : : Datum
1493 : 12 : int2xor(PG_FUNCTION_ARGS)
1494 : : {
1495 : 12 : int16 arg1 = PG_GETARG_INT16(0);
1496 : 12 : int16 arg2 = PG_GETARG_INT16(1);
1497 : :
1498 : 12 : PG_RETURN_INT16(arg1 ^ arg2);
1499 : : }
1500 : :
1501 : : Datum
9273 peter_e@gmx.net 1502 :UBC 0 : int2not(PG_FUNCTION_ARGS)
1503 : : {
1504 : 0 : int16 arg1 = PG_GETARG_INT16(0);
1505 : :
1506 : 0 : PG_RETURN_INT16(~arg1);
1507 : : }
1508 : :
1509 : :
1510 : : Datum
9273 peter_e@gmx.net 1511 :CBC 6 : int2shl(PG_FUNCTION_ARGS)
1512 : : {
1513 : 6 : int16 arg1 = PG_GETARG_INT16(0);
1514 : 6 : int32 arg2 = PG_GETARG_INT32(1);
1515 : :
1516 : 6 : PG_RETURN_INT16(arg1 << arg2);
1517 : : }
1518 : :
1519 : : Datum
9273 peter_e@gmx.net 1520 :UBC 0 : int2shr(PG_FUNCTION_ARGS)
1521 : : {
1522 : 0 : int16 arg1 = PG_GETARG_INT16(0);
1523 : 0 : int32 arg2 = PG_GETARG_INT32(1);
1524 : :
1525 : 0 : PG_RETURN_INT16(arg1 >> arg2);
1526 : : }
1527 : :
1528 : : /*
1529 : : * non-persistent numeric series generator
1530 : : */
1531 : : Datum
8076 mail@joeconway.com 1532 :CBC 9186056 : generate_series_int4(PG_FUNCTION_ARGS)
1533 : : {
1534 : 9186056 : return generate_series_step_int4(fcinfo);
1535 : : }
1536 : :
1537 : : Datum
1538 : 9371187 : generate_series_step_int4(PG_FUNCTION_ARGS)
1539 : : {
1540 : : FuncCallContext *funcctx;
1541 : : generate_series_fctx *fctx;
1542 : : int32 result;
1543 : : MemoryContext oldcontext;
1544 : :
1545 : : /* stuff done only on the first call of the function */
1546 [ + + ]: 9371187 : if (SRF_IS_FIRSTCALL())
1547 : : {
7868 bruce@momjian.us 1548 : 39862 : int32 start = PG_GETARG_INT32(0);
1549 : 39862 : int32 finish = PG_GETARG_INT32(1);
1550 : 39862 : int32 step = 1;
1551 : :
1552 : : /* see if we were given an explicit step size */
8076 mail@joeconway.com 1553 [ + + ]: 39862 : if (PG_NARGS() == 3)
1554 : 198 : step = PG_GETARG_INT32(2);
1555 [ - + ]: 39862 : if (step == 0)
8076 mail@joeconway.com 1556 [ # # ]:UBC 0 : ereport(ERROR,
1557 : : (errcode(ERRCODE_INVALID_PARAMETER_VALUE),
1558 : : errmsg("step size cannot equal zero")));
1559 : :
1560 : : /* create a function context for cross-call persistence */
8076 mail@joeconway.com 1561 :CBC 39862 : funcctx = SRF_FIRSTCALL_INIT();
1562 : :
1563 : : /*
1564 : : * switch to memory context appropriate for multiple function calls
1565 : : */
1566 : 39862 : oldcontext = MemoryContextSwitchTo(funcctx->multi_call_memory_ctx);
1567 : :
1568 : : /* allocate memory for user context */
95 michael@paquier.xyz 1569 :GNC 39862 : fctx = palloc_object(generate_series_fctx);
1570 : :
1571 : : /*
1572 : : * Use fctx to keep state from call to call. Seed current with the
1573 : : * original start value
1574 : : */
8076 mail@joeconway.com 1575 :CBC 39862 : fctx->current = start;
1576 : 39862 : fctx->finish = finish;
1577 : 39862 : fctx->step = step;
1578 : :
1579 : 39862 : funcctx->user_fctx = fctx;
1580 : 39862 : MemoryContextSwitchTo(oldcontext);
1581 : : }
1582 : :
1583 : : /* stuff done on every call of the function */
1584 : 9371187 : funcctx = SRF_PERCALL_SETUP();
1585 : :
1586 : : /*
1587 : : * get the saved state and use current as the result for this iteration
1588 : : */
1589 : 9371187 : fctx = funcctx->user_fctx;
1590 : 9371187 : result = fctx->current;
1591 : :
1592 [ + + + + ]: 9371187 : if ((fctx->step > 0 && fctx->current <= fctx->finish) ||
1593 [ + + + + ]: 139843 : (fctx->step < 0 && fctx->current >= fctx->finish))
1594 : : {
1595 : : /*
1596 : : * Increment current in preparation for next iteration. If next-value
1597 : : * computation overflows, this is the final result.
1598 : : */
3015 andres@anarazel.de 1599 [ - + ]: 9331349 : if (pg_add_s32_overflow(fctx->current, fctx->step, &fctx->current))
5385 rhaas@postgresql.org 1600 :UBC 0 : fctx->step = 0;
1601 : :
1602 : : /* do when there is more left to send */
8076 mail@joeconway.com 1603 :CBC 9331349 : SRF_RETURN_NEXT(funcctx, Int32GetDatum(result));
1604 : : }
1605 : : else
1606 : : /* do when there is no more left */
1607 : 39838 : SRF_RETURN_DONE(funcctx);
1608 : : }
1609 : :
1610 : : /*
1611 : : * Planner support function for generate_series(int4, int4 [, int4])
1612 : : */
1613 : : Datum
2591 tgl@sss.pgh.pa.us 1614 : 29143 : generate_series_int4_support(PG_FUNCTION_ARGS)
1615 : : {
1616 : 29143 : Node *rawreq = (Node *) PG_GETARG_POINTER(0);
1617 : 29143 : Node *ret = NULL;
1618 : :
1619 [ + + ]: 29143 : if (IsA(rawreq, SupportRequestRows))
1620 : : {
1621 : : /* Try to estimate the number of rows returned */
1622 : 7484 : SupportRequestRows *req = (SupportRequestRows *) rawreq;
1623 : :
1624 [ + - ]: 7484 : if (is_funcclause(req->node)) /* be paranoid */
1625 : : {
1626 : 7484 : List *args = ((FuncExpr *) req->node)->args;
1627 : : Node *arg1,
1628 : : *arg2,
1629 : : *arg3;
1630 : :
1631 : : /* We can use estimated argument values here */
1632 : 7484 : arg1 = estimate_expression_value(req->root, linitial(args));
1633 : 7484 : arg2 = estimate_expression_value(req->root, lsecond(args));
1634 [ + + ]: 7484 : if (list_length(args) >= 3)
1635 : 210 : arg3 = estimate_expression_value(req->root, lthird(args));
1636 : : else
1637 : 7274 : arg3 = NULL;
1638 : :
1639 : : /*
1640 : : * If any argument is constant NULL, we can safely assume that
1641 : : * zero rows are returned. Otherwise, if they're all non-NULL
1642 : : * constants, we can calculate the number of rows that will be
1643 : : * returned. Use double arithmetic to avoid overflow hazards.
1644 : : */
1645 [ + + ]: 7484 : if ((IsA(arg1, Const) &&
1646 [ + - ]: 7443 : ((Const *) arg1)->constisnull) ||
1647 [ + + ]: 7484 : (IsA(arg2, Const) &&
1648 [ + - + + ]: 7484 : ((Const *) arg2)->constisnull) ||
1649 [ + - ]: 210 : (arg3 != NULL && IsA(arg3, Const) &&
1650 [ - + ]: 210 : ((Const *) arg3)->constisnull))
1651 : : {
2591 tgl@sss.pgh.pa.us 1652 :UBC 0 : req->rows = 0;
1653 : 0 : ret = (Node *) req;
1654 : : }
2591 tgl@sss.pgh.pa.us 1655 [ + + ]:CBC 7484 : else if (IsA(arg1, Const) &&
1656 [ + + + + ]: 7443 : IsA(arg2, Const) &&
1657 [ + - ]: 210 : (arg3 == NULL || IsA(arg3, Const)))
1658 : : {
1659 : : double start,
1660 : : finish,
1661 : : step;
1662 : :
1663 : 5376 : start = DatumGetInt32(((Const *) arg1)->constvalue);
1664 : 5376 : finish = DatumGetInt32(((Const *) arg2)->constvalue);
1665 [ + + ]: 5376 : step = arg3 ? DatumGetInt32(((Const *) arg3)->constvalue) : 1;
1666 : :
1667 : : /* This equation works for either sign of step */
1668 [ + - ]: 5376 : if (step != 0)
1669 : : {
1670 : 5376 : req->rows = floor((finish - start + step) / step);
1671 : 5376 : ret = (Node *) req;
1672 : : }
1673 : : }
1674 : : }
1675 : : }
1676 : :
1677 : 29143 : PG_RETURN_POINTER(ret);
1678 : : }
|
