coverage_window_calculation()

static Datum coverage_window_calculation ( PG_FUNCTION_ARGS  , int  mode  )

static

Definition at line 627 of file lwgeom_window.c.

{
        WindowObject winobj = PG_WINDOW_OBJECT();
        int64 curpos = WinGetCurrentPosition(winobj);
        int64 rowcount = WinGetPartitionRowCount(winobj);
        coverage_context *context = coverage_context_fetch(winobj, rowcount);
        GSERIALIZED* result;
        MemoryContext uppercontext = fcinfo->flinfo->fn_mcxt;
        MemoryContext oldcontext;
        const LWGEOM* subgeom;
 
        if (!context->isdone)
        {
                bool isnull;
                Datum d;
                double tolerance = 0.0;
                bool simplifyBoundary = true;
                GEOSGeometry *output = NULL;
                GEOSGeometry *input = NULL;
 
                if (!fcinfo->flinfo)
                        elog(ERROR, "%s: Could not find upper context", __func__);
 
                if (rowcount == 0)
                {
                        context->isdone = true;
                        context->isnull = true;
                        PG_RETURN_NULL();
                }
 
                /* Get the tolerance argument from second postition */
                d = WinGetFuncArgCurrent(winobj, 1, &isnull);
                if (!isnull)
                        tolerance = DatumGetFloat8(d);
 
                /* The third position "preserve boundary" argument */
                /* is only for the simplify mode */
                if (mode == COVERAGE_SIMPLIFY)
                {
                        d = WinGetFuncArgCurrent(winobj, 2, &isnull);
                        if (!isnull)
                                simplifyBoundary = DatumGetBool(d);
                }
 
                initGEOS(lwnotice, lwgeom_geos_error);
 
                input = coverage_read_partition_into_collection(winobj, context);
                if (!input)
                        HANDLE_GEOS_ERROR("Failed to create collection");
 
                /* Run the correct GEOS function for the calling mode */
                if (mode == COVERAGE_SIMPLIFY)
                {
                        /* GEOSCoverageSimplifyVW is "preserveBoundary" so we invert simplifyBoundary */
                        output = GEOSCoverageSimplifyVW(input, tolerance, !simplifyBoundary);
                }
                else if (mode == COVERAGE_ISVALID)
                {
                        GEOSCoverageIsValid(input, tolerance, &output);
                }
                else
                {
                        elog(ERROR, "Unknown mode, never get here");
                }
 
                GEOSGeom_destroy(input);
 
                if (!output)
                {
                        HANDLE_GEOS_ERROR("Failed to process collection");
                }
 
                oldcontext = MemoryContextSwitchTo(uppercontext);
                context->geom = (LWCOLLECTION *) GEOS2LWGEOM(output, GEOSHasZ(output));
                MemoryContextSwitchTo(oldcontext);
                GEOSGeom_destroy(output);
 
                context->isdone = true;
        }
 
        /* Bomb out of any errors */
        if (context->isnull)
                PG_RETURN_NULL();
 
        /* Propogate the null entries */
        if (context->idx[curpos] < 0)
                PG_RETURN_NULL();
 
        /*
         * Geometry serialization is not const-safe! (we
         * calculate bounding boxes on demand) so we need
         * to make sure we have a persistent context when
         * we call the serialization, lest we create dangling
         * pointers in the object. It's possible we could
         * ignore them, skip the manual lwcollection_free
         * and let the aggcontext deletion take
         * care of the memory.
         */
        oldcontext = MemoryContextSwitchTo(uppercontext);
        subgeom = lwcollection_getsubgeom(context->geom, context->idx[curpos]);
        if (mode == COVERAGE_ISVALID && lwgeom_is_empty(subgeom))
        {
                result = NULL;
        }
        else
        {
                result = geometry_serialize((LWGEOM*)subgeom);
        }
        MemoryContextSwitchTo(oldcontext);
 
        /* When at the end of the partition, release the */
        /* simplified collection we have been reading. */
        if (curpos == rowcount - 1)
                lwcollection_free(context->geom);
 
        if (!result) PG_RETURN_NULL();
 
        PG_RETURN_POINTER(result);
 
}

References coverage_context_fetch(), COVERAGE_ISVALID, coverage_read_partition_into_collection(), COVERAGE_SIMPLIFY, coverage_context::geom, GEOS2LWGEOM(), HANDLE_GEOS_ERROR, coverage_context::idx, coverage_context::isdone, coverage_context::isnull, lwcollection_free(), lwcollection_getsubgeom(), lwgeom_geos_error(), lwgeom_is_empty(), lwnotice(), and result.

Referenced by ST_CoverageInvalidEdges(), and ST_CoverageSimplify().

Here is the call graph for this function:

Here is the caller graph for this function: