Function _PG_init

cpp/deeplake_pg/extension_init.cpp:1568–1626

This will be called when when extension is loaded

/// This will be called when when extension is loaded
PGDLLEXPORT void _PG_init()
{
    if (!process_shared_preload_libraries_in_progress) {
        ereport(ERROR,
                (errmsg("pg_deeplake should be loaded with shared_preload_libraries"),
                 errhint("Add pg_deeplake to shared_preload_libraries.")));
    }

    // Set up shared memory request hook (must be first)
    prev_shmem_request_hook = shmem_request_hook;
    shmem_request_hook = deeplake_shmem_request;

    // Set up shared memory startup hook
    prev_shmem_startup_hook = shmem_startup_hook;
    shmem_startup_hook = deeplake_shmem_startup;

    register_deeplake_executor();

    prev_executor_start = ExecutorStart_hook;
    ExecutorStart_hook = executor_start;

    prev_executor_run = ExecutorRun_hook;
    ExecutorRun_hook = executor_run;

    prev_executor_end = ExecutorEnd_hook;
    ExecutorEnd_hook = executor_end;

    prev_process_utility_hook = ProcessUtility_hook;
    ProcessUtility_hook = process_utility;

    prev_planner_hook = planner_hook;
    planner_hook = deeplake_planner;

    prev_set_rel_pathlist_hook = set_rel_pathlist_hook;
    set_rel_pathlist_hook = set_rel_pathlist;

    // Initialize GUC parameters first (needed for sync worker config)
    ::initialize_guc_parameters();

    // Register background sync worker for stateless multi-instance support
    BackgroundWorker worker;
    memset(&worker, 0, sizeof(worker));

    snprintf(worker.bgw_name, BGW_MAXLEN, "pg_deeplake sync worker");
    snprintf(worker.bgw_type, BGW_MAXLEN, "pg_deeplake sync worker");
    snprintf(worker.bgw_library_name, BGW_MAXLEN, "pg_deeplake");
    snprintf(worker.bgw_function_name, BGW_MAXLEN, "deeplake_sync_worker_main");

    worker.bgw_flags = BGWORKER_SHMEM_ACCESS | BGWORKER_BACKEND_DATABASE_CONNECTION;
    worker.bgw_start_time = BgWorkerStart_RecoveryFinished;
    worker.bgw_restart_time = 5;  // Restart after 5 seconds if it crashes
    worker.bgw_notify_pid = 0;
    worker.bgw_main_arg = (Datum)0;

    RegisterBackgroundWorker(&worker);

    pg::install_signal_handlers();
    pg::deeplake_table_am_routine::initialize();