pgis_geometry_accum_transfn()

Datum pgis_geometry_accum_transfn

(

PG_FUNCTION_ARGS

)

Definition at line 68 of file lwgeom_accum.c.

{
        MemoryContext aggcontext, old;
        CollectionBuildState *state;
        LWGEOM *geom = NULL;
        GSERIALIZED *gser = NULL;
        Datum argType = get_fn_expr_argtype(fcinfo->flinfo, 1);
        double gridSize = -1.0;
 
        if (argType == InvalidOid)
                ereport(ERROR,
                        (errcode(ERRCODE_INVALID_PARAMETER_VALUE),
                         errmsg("could not determine input data type")));
 
        if ( ! AggCheckCallContext(fcinfo, &aggcontext) )
        {
                /* cannot be called directly because of dummy-type argument */
                elog(ERROR, "%s called in non-aggregate context", __func__);
                aggcontext = NULL;  /* keep compiler quiet */
        }
 
        if ( PG_ARGISNULL(0) )
        {
                int n = ((PG_NARGS()-2) <= CollectionBuildStateDataSize) ? (PG_NARGS()-2) : CollectionBuildStateDataSize;
 
                state = MemoryContextAlloc(aggcontext, sizeof(CollectionBuildState));
                state->geoms = NULL;
                state->geomOid = argType;
                state->gridSize = gridSize;
 
                for (int i = 0; i < n; i++)
                {
                        Datum argument = PG_GETARG_DATUM(i+2);
                        Oid dataOid = get_fn_expr_argtype(fcinfo->flinfo, i+2);
                        old = MemoryContextSwitchTo(aggcontext);
                        state->data[i] = datumCopy(argument, get_typbyval(dataOid), get_typlen(dataOid));
                        MemoryContextSwitchTo(old);
                }
        }
        else
        {
                state = (CollectionBuildState*) PG_GETARG_POINTER(0);
        }
 
        if (!PG_ARGISNULL(1))
                gser = PG_GETARG_GSERIALIZED_P(1);
 
        if (PG_NARGS()>2 && !PG_ARGISNULL(2))
        {
                gridSize = PG_GETARG_FLOAT8(2);
                /*lwnotice("Passed gridSize %g", gridSize);*/
                if ( gridSize > state->gridSize ) state->gridSize = gridSize;
        }
 
        /* Take a copy of the geometry into the aggregate context */
        old = MemoryContextSwitchTo(aggcontext);
        if (gser)
                geom = lwgeom_clone_deep(lwgeom_from_gserialized(gser));
 
        /* Initialize or append to list as necessary */
        if (state->geoms)
                state->geoms = lappend(state->geoms, geom);
        else
                state->geoms = list_make1(geom);
 
        MemoryContextSwitchTo(old);
 
        PG_RETURN_POINTER(state);
}

References CollectionBuildStateDataSize, CollectionBuildState::data, CollectionBuildState::geomOid, CollectionBuildState::geoms, CollectionBuildState::gridSize, lwgeom_clone_deep(), and lwgeom_from_gserialized().

Here is the call graph for this function: