Function deeplake_xact_callback

cpp/deeplake_pg/pg_deeplake.cpp:338–354

/// @}

void deeplake_xact_callback(XactEvent event, void *arg)
{
    switch (event) {
    case XACT_EVENT_PRE_COMMIT:
	case XACT_EVENT_PARALLEL_PRE_COMMIT:
        pg::table_storage::instance().commit_all();
        break;
    case XACT_EVENT_ABORT:
	case XACT_EVENT_PARALLEL_ABORT:
        // Handle transaction abort by rolling back changes
        // Don't throw ERROR here as it would trigger cascading abort loop
        pg::table_storage::instance().rollback_all();
        break;
    default:
        break;
    }
}

void init_deeplake()
{