|
|
|
@ -161,7 +161,7 @@ static void tcp_handle_write(void* arg /* grpc_tcp */, grpc_error* error); |
|
|
|
|
static void tcp_drop_uncovered_then_handle_write(void* arg /* grpc_tcp */, |
|
|
|
|
grpc_error* error); |
|
|
|
|
|
|
|
|
|
static void done_poller(void* bp, grpc_error* error_ignored) { |
|
|
|
|
static void done_poller(void* bp, grpc_error* /*error_ignored*/) { |
|
|
|
|
backup_poller* p = static_cast<backup_poller*>(bp); |
|
|
|
|
if (GRPC_TRACE_FLAG_ENABLED(grpc_tcp_trace)) { |
|
|
|
|
gpr_log(GPR_INFO, "BACKUP_POLLER:%p destroy", p); |
|
|
|
@ -170,7 +170,7 @@ static void done_poller(void* bp, grpc_error* error_ignored) { |
|
|
|
|
gpr_free(p); |
|
|
|
|
} |
|
|
|
|
|
|
|
|
|
static void run_poller(void* bp, grpc_error* error_ignored) { |
|
|
|
|
static void run_poller(void* bp, grpc_error* /*error_ignored*/) { |
|
|
|
|
backup_poller* p = static_cast<backup_poller*>(bp); |
|
|
|
|
if (GRPC_TRACE_FLAG_ENABLED(grpc_tcp_trace)) { |
|
|
|
|
gpr_log(GPR_INFO, "BACKUP_POLLER:%p run", p); |
|
|
|
@ -206,7 +206,7 @@ static void run_poller(void* bp, grpc_error* error_ignored) { |
|
|
|
|
} |
|
|
|
|
} |
|
|
|
|
|
|
|
|
|
static void drop_uncovered(grpc_tcp* tcp) { |
|
|
|
|
static void drop_uncovered(grpc_tcp* /*tcp*/) { |
|
|
|
|
backup_poller* p = (backup_poller*)gpr_atm_acq_load(&g_backup_poller); |
|
|
|
|
gpr_atm old_count = |
|
|
|
|
gpr_atm_full_fetch_add(&g_uncovered_notifications_pending, -1); |
|
|
|
@ -876,15 +876,16 @@ static void tcp_handle_error(void* arg /* grpc_tcp */, grpc_error* error) { |
|
|
|
|
} |
|
|
|
|
|
|
|
|
|
#else /* GRPC_LINUX_ERRQUEUE */ |
|
|
|
|
static bool tcp_write_with_timestamps(grpc_tcp* tcp, struct msghdr* msg, |
|
|
|
|
size_t sending_length, |
|
|
|
|
ssize_t* sent_length) { |
|
|
|
|
static bool tcp_write_with_timestamps(grpc_tcp* /*tcp*/, struct msghdr* /*msg*/, |
|
|
|
|
size_t /*sending_length*/, |
|
|
|
|
ssize_t* /*sent_length*/) { |
|
|
|
|
gpr_log(GPR_ERROR, "Write with timestamps not supported for this platform"); |
|
|
|
|
GPR_ASSERT(0); |
|
|
|
|
return false; |
|
|
|
|
} |
|
|
|
|
|
|
|
|
|
static void tcp_handle_error(void* arg /* grpc_tcp */, grpc_error* error) { |
|
|
|
|
static void tcp_handle_error(void* /*arg*/ /* grpc_tcp */, |
|
|
|
|
grpc_error* /*error*/) { |
|
|
|
|
gpr_log(GPR_ERROR, "Error handling is not supported for this platform"); |
|
|
|
|
GPR_ASSERT(0); |
|
|
|
|
} |
|
|
|
|