explicit worker_ctx(memcached_st *memc)
: pool{memcached_pool_create(memc, 5, 10)}
explicit worker_ctx(memcached_st *memc)
: pool{memcached_pool_create(memc, 5, 10)}
- ctx->err() << "failed to fetch connection from pool: "
- << memcached_strerror(nullptr, rc);
- this_thread::sleep_for(100ms);
+ cerr << "failed to fetch connection from pool: "
+ << memcached_strerror(nullptr, rc)
+ << endl;
+ continue;
}
auto rs = random_ascii_string(12);
rc = memcached_set(mc, rs.c_str(), rs.length(), rs.c_str(), rs.length(), 0, 0);
if (memcached_failed(rc)) {
}
auto rs = random_ascii_string(12);
rc = memcached_set(mc, rs.c_str(), rs.length(), rs.c_str(), rs.length(), 0, 0);
if (memcached_failed(rc)) {
}
rc = memcached_pool_release(ctx->pool, mc);
if (memcached_failed(rc)) {
}
rc = memcached_pool_release(ctx->pool, mc);
if (memcached_failed(rc)) {
- ctx->err() << "failed to release connection to pool: "
- << memcached_strerror(nullptr, rc);
+ cerr << "failed to release connection to pool: "
+ << memcached_strerror(nullptr, rc)
+ << endl;
REQUIRE(0 == pthread_create(&t, nullptr, worker, &ctx));
}
REQUIRE(0 == pthread_create(&t, nullptr, worker, &ctx));
}