pdxx
/
libserverframe
mirror of https://github.com/happyfish100/libserverframe.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

remove debug info

replication_quorum
YuQing 2022-06-30 17:59:44 +08:00
parent f63ede788e
commit d95e3ed679
4 changed files with 6 additions and 15 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
src/idempotency/client/client_channel.h
View File

@ -87,10 +87,11 @@ static inline int idempotency_client_channel_check_wait_ex(
/* /*
logInfo("file: "__FILE__", line: %d, " logInfo("file: "__FILE__", line: %d, "
"channel_check fail, server %s:%u, in_ioevent: %d, " "channel_check fail, server %s:%u, in_ioevent: %d, "
"canceled: %d, req count: %"PRId64, __LINE__, channel->task->server_ip, "canceled: %d, req count: %"PRId64, __LINE__,
channel->task->port, __sync_add_and_fetch(&channel-> channel->task->server_ip, channel->task->port,
in_ioevent, 0), __sync_add_and_fetch(&channel-> __sync_add_and_fetch(&channel->in_ioevent, 0),
task->canceled, 0), channel->task->req_count); __sync_add_and_fetch(&channel->task->canceled, 0),
channel->task->req_count);
*/ */
return ETIMEDOUT; return ETIMEDOUT;
} }

3
src/idempotency/server/request_metadata.c
View File

@ -218,9 +218,6 @@ int idempotency_request_metadata_add(
} while (0); } while (0);
PTHREAD_MUTEX_UNLOCK(&ctx->lock); PTHREAD_MUTEX_UNLOCK(&ctx->lock);
logInfo("add req_id: %"PRId64", data_version: %"PRId64,
metadata->req_id, metadata->data_version);
return (idemp_meta != NULL ? 0 : ENOMEM); return (idemp_meta != NULL ? 0 : ENOMEM);
} }

2
src/sf_func.h
View File

@ -37,7 +37,7 @@ static inline void sf_terminate_myself_ex(const char *file,
{ {
g_sf_global_vars.continue_flag = false; g_sf_global_vars.continue_flag = false;
if (kill(getpid(), SIGQUIT) == 0) { //signal myself to quit if (kill(getpid(), SIGQUIT) == 0) { //signal myself to quit
logInfo("file: "__FILE__", line: %d, " logWarning("file: "__FILE__", line: %d, "
"kill myself from caller {file: %s, line: %d, func: %s}", "kill myself from caller {file: %s, line: %d, func: %s}",
__LINE__, file, line, func); __LINE__, file, line, func);
} else { } else {

7
src/sf_service.h
View File

@ -142,7 +142,6 @@ static inline struct fast_task_info *sf_alloc_init_task(
static inline void sf_release_task(struct fast_task_info *task) static inline void sf_release_task(struct fast_task_info *task)
{ {
//int reffer_count;
if (__sync_sub_and_fetch(&task->reffer_count, 1) == 0) { if (__sync_sub_and_fetch(&task->reffer_count, 1) == 0) {
/* /*
int free_count = free_queue_count(); int free_count = free_queue_count();
@ -153,12 +152,6 @@ static inline void sf_release_task(struct fast_task_info *task)
alloc_count, alloc_count - free_count, free_count); alloc_count, alloc_count - free_count, free_count);
*/ */
free_queue_push(task); free_queue_push(task);
} else {
/*
logInfo("file: "__FILE__", line: %d, "
"release task %p, current reffer: %d",
__LINE__, task, reffer_count);
*/
} }
} }