Function ExtendBlockPool

src/brpc/rdma/block_pool.cpp:185–211

Extend the block pool with a new region (with different region ID)

// Extend the block pool with a new region (with different region ID)
static void* ExtendBlockPool(size_t region_size, int block_type) {
    if (region_size < 1) {
        errno = EINVAL;
        return NULL;
    }

    if (FLAGS_rdma_memory_pool_user_specified_memory) {
        LOG_EVERY_SECOND(ERROR) << "Fail to extend new region, "
                                   "rdma_memory_pool_user_specified_memory is "
                                   "true, ExtendBlockPool is disabled";
        return NULL;
    }

    // Regularize region size
    region_size = region_size * BYTES_IN_MB / g_block_size[block_type] / g_buckets;
    region_size *= g_block_size[block_type] * g_buckets;

    LOG(INFO) << "Start extend rdma memory " << region_size / BYTES_IN_MB << "MB";

    void* region_base = NULL;
    if (posix_memalign(&region_base, 4096, region_size) != 0) {
        PLOG_EVERY_SECOND(ERROR) << "Memory not enough";
        return NULL;
    }

    return ExtendBlockPoolImpl(region_base, region_size, block_type);
}

void* ExtendBlockPoolByUser(void* region_base, size_t region_size, int block_type) {
    auto region_base_guard = butil::MakeScopeGuard([region_base]() {