#include <cassert>
#include <cerrno>
+#include <cstring>
#include <pthread.h>
#include <memory>
_timeout.tv_nsec = 0;
}
- const struct timespec &timeout() const { return _timeout; }
+ const struct timespec &timeout() const {
+ return _timeout;
+ }
bool release(memcached_st *, memcached_return_t &rc);
}
int error;
- if ((error = pthread_mutex_destroy(&mutex)) != 0) {
- assert_vmsg(error != 0, "pthread_mutex_destroy() %s(%d)", strerror(error), error);
+ if ((error = pthread_mutex_destroy(&mutex))) {
+ assert_vmsg(error, "pthread_mutex_destroy() %s(%d)", strerror(error), error);
}
- if ((error = pthread_cond_destroy(&cond)) != 0) {
- assert_vmsg(error != 0, "pthread_cond_destroy() %s", strerror(error));
+ if ((error = pthread_cond_destroy(&cond))) {
+ assert_vmsg(error, "pthread_cond_destroy() %s", strerror(error));
}
delete[] server_pool;
}
}
- void increment_version() { ++master->configure.version; }
+ void increment_version() {
+ ++master->configure.version;
+ }
bool compare_version(const memcached_st *arg) const {
return (arg->configure.version == version());
}
- int32_t version() const { return master->configure.version; }
+ int32_t version() const {
+ return master->configure.version;
+ }
};
/**
rc = MEMCACHED_SUCCESS;
int error;
- if ((error = pthread_mutex_lock(&mutex)) != 0) {
+ if ((error = pthread_mutex_lock(&mutex))) {
rc = MEMCACHED_IN_PROGRESS;
return NULL;
}
time_to_wait.tv_nsec = relative_time.tv_nsec;
int thread_ret;
- if ((thread_ret = pthread_cond_timedwait(&cond, &mutex, &time_to_wait)) != 0) {
+ if ((thread_ret = pthread_cond_timedwait(&cond, &mutex, &time_to_wait))) {
int unlock_error;
- if ((unlock_error = pthread_mutex_unlock(&mutex)) != 0) {
- assert_vmsg(error != 0, "pthread_mutex_unlock() %s", strerror(error));
+ if ((unlock_error = pthread_mutex_unlock(&mutex))) {
+ assert_vmsg(error, "pthread_mutex_unlock() %s", strerror(error));
}
if (thread_ret == ETIMEDOUT) {
}
} else if (grow_pool(this) == false) {
int unlock_error;
- if ((unlock_error = pthread_mutex_unlock(&mutex)) != 0) {
- assert_vmsg(error != 0, "pthread_mutex_unlock() %s", strerror(error));
+ if ((unlock_error = pthread_mutex_unlock(&mutex))) {
+ assert_vmsg(error, "pthread_mutex_unlock() %s", strerror(error));
}
return NULL;
}
} while (ret == NULL);
- if ((error = pthread_mutex_unlock(&mutex)) != 0) {
- assert_vmsg(error != 0, "pthread_mutex_unlock() %s", strerror(error));
+ if ((error = pthread_mutex_unlock(&mutex))) {
+ assert_vmsg(error, "pthread_mutex_unlock() %s", strerror(error));
}
return ret;
if (firstfree == 0 and current_size == size) {
/* we might have people waiting for a connection.. wake them up :-) */
- if ((error = pthread_cond_broadcast(&cond)) != 0) {
- assert_vmsg(error != 0, "pthread_cond_broadcast() %s", strerror(error));
+ if ((error = pthread_cond_broadcast(&cond))) {
+ assert_vmsg(error, "pthread_cond_broadcast() %s", strerror(error));
}
}
- if ((error = pthread_mutex_unlock(&mutex)) != 0) {
+ if ((error = pthread_mutex_unlock(&mutex))) {
}
return true;
/* update the master */
memcached_return_t rc = memcached_behavior_set(pool->master, flag, data);
if (memcached_failed(rc)) {
- if ((error = pthread_mutex_unlock(&pool->mutex)) != 0) {
- assert_vmsg(error != 0, "pthread_mutex_unlock() %s", strerror(error));
+ if ((error = pthread_mutex_unlock(&pool->mutex))) {
+ assert_vmsg(error, "pthread_mutex_unlock() %s", strerror(error));
}
return rc;
}
}
}
- if ((error = pthread_mutex_unlock(&pool->mutex)) != 0) {
- assert_vmsg(error != 0, "pthread_mutex_unlock() %s", strerror(error));
+ if ((error = pthread_mutex_unlock(&pool->mutex))) {
+ assert_vmsg(error, "pthread_mutex_unlock() %s", strerror(error));
}
return rc;
*value = memcached_behavior_get(pool->master, flag);
- if ((error = pthread_mutex_unlock(&pool->mutex)) != 0) {
- assert_vmsg(error != 0, "pthread_mutex_unlock() %s", strerror(error));
+ if ((error = pthread_mutex_unlock(&pool->mutex))) {
+ assert_vmsg(error, "pthread_mutex_unlock() %s", strerror(error));
}
return MEMCACHED_SUCCESS;