Method Return

library/cpp/netliba/v6/ib_mem.cpp:104–117

    }

    void TIBMemPool::Return(TPtrArg<TIBMemSuperBlock> blk) {
        TGuard<TMutex> gg(CacheLock);
        Y_ASSERT(AtomicGet(blk->UseCount) == 0);
        size_t sz = 1ull << blk->SzLog;
        if (sz + AllocCacheSize > IB_MEM_POOL_SIZE) {
            AllocCache.clear();
            AllocCacheSize = 0;
        }
        {
            TVector<TIntrusivePtr<TIBMemSuperBlock>>& cc = AllocCache[blk->SzLog];
            cc.push_back(blk.Get());
            AllocCacheSize += sz;
        }
    }

    void* TIBMemPool::ThreadFunc(void* param) {
        BindToSocket(0);