#include "config.h"
+#include <inttypes.h>
+
#include "ms_thread.h"
#include "ms_setting.h"
+#include "ms_atomic.h"
/* command distribution adjustment cycle */
#define CMD_DISTR_ADJUST_CYCLE 1000
* item in the window. This factor shows it.
*/
-extern __thread ms_thread_t ms_thread;
-
/* get item from task window */
static ms_task_item_t *ms_get_cur_opt_item(ms_conn_t *c);
static ms_task_item_t *ms_get_next_get_item(ms_conn_t *c);
}
else if (c->precmd.cmd == CMD_SET && c->precmd.retstat != MCD_STORED)
{
- printf("key: %lx didn't set success\n", item->key_prefix);
+ printf("key: %" PRIx64 " didn't set success\n", item->key_prefix);
}
}
/* update get miss counter */
if (mlget_item->get_miss)
{
- __sync_fetch_and_add(&ms_stats.get_misses, 1);
+ atomic_add_size(&ms_stats.get_misses, 1);
}
/* get nothing from server for this task item */
if (curr_time.tv_sec - item->client_time
< item->exp_time - EXPIRE_TIME_ERROR)
{
- __sync_fetch_and_add(&ms_stats.unexp_unget, 1);
+ atomic_add_size(&ms_stats.unexp_unget, 1);
if (ms_setting.verbose)
{
"\n\t<%d expire time verification failed, object "
"doesn't expire but can't get it now\n"
"\tkey len: %d\n"
- "\tkey: %lx %.*s\n"
+ "\tkey: %" PRIx64 " %.*s\n"
"\tset time: %s current time: %s "
"diff time: %d expire time: %d\n"
"\texpected data len: %d\n"
}
else
{
- __sync_fetch_and_add(&ms_stats.vef_miss, 1);
+ atomic_add_size(&ms_stats.vef_miss, 1);
if (ms_setting.verbose)
{
fprintf(stderr, "\n<%d data verification failed\n"
"\tkey len: %d\n"
- "\tkey: %lx %.*s\n"
+ "\tkey: %" PRIx64 " %.*s\n"
"\texpected data len: %d\n"
"\texpected data: %.*s\n"
"\treceived data: \n",
/* update get miss counter */
if ((c->precmd.cmd == CMD_GET) && c->curr_task.get_miss)
{
- __sync_fetch_and_add(&ms_stats.get_misses, 1);
+ atomic_add_size(&ms_stats.get_misses, 1);
}
/* get nothing from server for this task item */
if (curr_time.tv_sec - item->client_time
< item->exp_time - EXPIRE_TIME_ERROR)
{
- __sync_fetch_and_add(&ms_stats.unexp_unget, 1);
+ atomic_add_size(&ms_stats.unexp_unget, 1);
if (ms_setting.verbose)
{
"\n\t<%d expire time verification failed, object "
"doesn't expire but can't get it now\n"
"\tkey len: %d\n"
- "\tkey: %lx %.*s\n"
+ "\tkey: %" PRIx64 " %.*s\n"
"\tset time: %s current time: %s "
"diff time: %d expire time: %d\n"
"\texpected data len: %d\n"
}
else
{
- __sync_fetch_and_add(&ms_stats.vef_miss, 1);
+ atomic_add_size(&ms_stats.vef_miss, 1);
if (ms_setting.verbose)
{
fprintf(stderr, "\n<%d data verification failed\n"
"\tkey len: %d\n"
- "\tkey: %lx %.*s\n"
+ "\tkey: %" PRIx64 " %.*s\n"
"\texpected data len: %d\n"
"\texpected data: %.*s\n"
"\treceived data: \n",