Function executor_start

cpp/deeplake_pg/extension_init.cpp:1271–1315

}

static void executor_start(QueryDesc* query_desc, int32_t eflags)
{
    pg::init_deeplake();
    if (prev_executor_start != nullptr) {
        prev_executor_start(query_desc, eflags);
    } else {
        standard_ExecutorStart(query_desc, eflags);
    }

    if (!pg::query_info::is_in_top_context() || pg::utils::spi_connector::is_execution_in_progress()) {
        return;
    }

    pg::query_info::push_context(query_desc);
    pg::query_info::current().set_command_type(static_cast<enum pg::command_type>(query_desc->operation));

    if (!pg::query_info::current().is_deeplake_table_referenced()) {
        pg::analyze_plan(query_desc->plannedstmt);
    }
    if (query_desc->operation == CMD_SELECT && !pg::query_info::current().is_deeplake_table_referenced()) {
        return;
    }

    Plan* plan = query_desc->plannedstmt->planTree;
    if (plan != nullptr && IsA(plan, Limit)) {
        Limit* limitNode = (Limit*)plan;
        if (limitNode->limitCount != nullptr) {
            const auto limit = DatumGetInt32(((Const*)limitNode->limitCount)->constvalue);
            pg::query_info::current().set_limit(limit);
        }
        plan = plan->lefttree;
    }

    if (plan != nullptr) {
        List* targetList = plan->targetlist;
        ListCell* lc = nullptr;
        foreach (lc, targetList) {
            TargetEntry* tle = (TargetEntry*)lfirst(lc);
            if (::is_count_star(tle)) {
                pg::query_info::current().set_count_star(true);
                break;
            }
        }
    }
}

struct ReceiverState
{