}
static memcached_return_t memcached_send_binary(Memcached *ptr,
- org::libmemcached::Instance* server,
+ memcached_instance_st* server,
uint32_t server_key,
const char *key,
const size_t key_length,
memcached_return_t rc;
if ((rc= memcached_vdo(server, vector, 5, flush)) != MEMCACHED_SUCCESS)
{
- memcached_io_reset(server);
-
-#if 0
- if (memcached_has_error(ptr))
- {
- memcached_set_error(*server, rc, MEMCACHED_AT);
- }
-#endif
-
assert(memcached_last_error(server->root) != MEMCACHED_SUCCESS);
return memcached_last_error(server->root);
}
server_key= 0;
}
- org::libmemcached::Instance* instance= memcached_instance_fetch(ptr, server_key);
+ memcached_instance_st* instance= memcached_instance_fetch(ptr, server_key);
- if (memcached_vdo(instance, vector, 5, false) != MEMCACHED_SUCCESS)
- {
- memcached_io_reset(instance);
- }
- else
+ if (memcached_success(memcached_vdo(instance, vector, 5, false)))
{
memcached_server_response_decrement(instance);
}
}
static memcached_return_t memcached_send_ascii(Memcached *ptr,
- org::libmemcached::Instance* instance,
+ memcached_instance_st* instance,
const char *key,
const size_t key_length,
const char *value,
}
}
- if (rc == MEMCACHED_WRITE_FAILURE)
- {
- memcached_io_reset(instance);
- }
-
assert(memcached_failed(rc));
#if 0
if (memcached_has_error(ptr) == false)
}
uint32_t server_key= memcached_generate_hash_with_redistribution(ptr, group_key, group_key_length);
- org::libmemcached::Instance* instance= memcached_instance_fetch(ptr, server_key);
+ memcached_instance_st* instance= memcached_instance_fetch(ptr, server_key);
WATCHPOINT_SET(instance->io_wait_count.read= 0);
WATCHPOINT_SET(instance->io_wait_count.write= 0);
-
bool flush= true;
if (memcached_is_buffering(instance->root) and verb == SET_OP)
{