geobuf_agg_transfn()

void geobuf_agg_transfn

(

struct geobuf_agg_context *

ctx

)

Aggregation step.

Expands features array if needed by a factor of 2. Allocates a new feature, increment feature counter and encode properties into it.  

Definition at line 578 of file geobuf.c.

{
        LWGEOM *lwgeom;
        bool isnull = false;
        Datum datum;
        Data__FeatureCollection *fc = ctx->data->feature_collection;
/*      Data__Feature **features = fc->features; */
        Data__Feature *feature;
        GSERIALIZED *gs;
        if (fc->n_features >= ctx->features_capacity) {
                size_t new_capacity = ctx->features_capacity * 2;
                fc->features = repalloc(fc->features, new_capacity *
                        sizeof(*fc->features));
                ctx->lwgeoms = repalloc(ctx->lwgeoms, new_capacity *
                        sizeof(*ctx->lwgeoms));
                ctx->features_capacity = new_capacity;
        }
 
        /* inspect row and encode keys assuming static schema */
        if (fc->n_features == 0)
                encode_keys(ctx);
 
        datum = GetAttributeByNum(ctx->row, ctx->geom_index + 1, &isnull);
        if (isnull)
                return;
 
        gs = (GSERIALIZED *) PG_DETOAST_DATUM_COPY(datum);
        lwgeom = lwgeom_from_gserialized(gs);
 
        feature = encode_feature(ctx);
 
        /* inspect geometry flags assuming static schema */
        if (fc->n_features == 0)
                analyze_geometry_flags(ctx, lwgeom);
 
        analyze_geometry(ctx, lwgeom);
 
        ctx->lwgeoms[fc->n_features] = lwgeom;
        fc->features[fc->n_features++] = feature;
}

References analyze_geometry(), analyze_geometry_flags(), geobuf_agg_context::data, encode_feature(), encode_keys(), geobuf_agg_context::features_capacity, geobuf_agg_context::geom_index, lwgeom_from_gserialized(), geobuf_agg_context::lwgeoms, and geobuf_agg_context::row.

Referenced by pgis_asgeobuf_transfn().

Here is the call graph for this function:

Here is the caller graph for this function: