Chiebot-Mirror
/
grpc
8
0
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity

Remove unused-parameter warnings, round 2 (8 of 19)

Browse Source
pull/20714/head
Vijay Pai 5 years ago
parent 2d80e830c0
commit e4c03b1391
10 changed files with 75 additions and 45 deletions
Whitespace
Show all changes Ignore whitespace when comparing lines Ignore changes in amount of whitespace Ignore changes in whitespace at EOL
Unified View
Diff Options
Show Stats Download Patch File Download Diff File
  1. 28
      src/core/lib/iomgr/ev_epollex_linux.cc
  2. 27
      src/core/lib/iomgr/ev_poll_posix.cc
  3. 2
      src/core/lib/iomgr/iomgr_custom.cc
  4. 8
      src/core/lib/iomgr/pollset_custom.cc
  5. 18
      src/core/lib/iomgr/pollset_set_custom.cc
  6. 2
      src/core/lib/iomgr/resolve_address_custom.cc
  7. 4
      src/core/lib/iomgr/resolve_address_posix.cc
  8. 18
      src/core/lib/iomgr/resource_quota.cc
  9. 11
      src/core/lib/iomgr/socket_utils_common_posix.cc
  10. 2
      src/core/lib/iomgr/tcp_client_custom.cc

28
src/core/lib/iomgr/ev_epollex_linux.cc
Unescape View File

@ -352,15 +352,23 @@ static void ref_by(grpc_fd* fd, int n, const char* reason, const char* file,
gpr_atm_no_barrier_load(&fd->refst) + n, reason, file, line); gpr_atm_no_barrier_load(&fd->refst) + n, reason, file, line);
} }
#else #else
#define REF_BY(fd, n, reason) ref_by(fd, n) #define REF_BY(fd, n, reason) \
#define UNREF_BY(fd, n, reason) unref_by(fd, n) do { \
ref_by(fd, n); \
(void)(reason); \
} while (0)
#define UNREF_BY(fd, n, reason) \
do { \
unref_by(fd, n); \
(void)(reason); \
} while (0)
static void ref_by(grpc_fd* fd, int n) { static void ref_by(grpc_fd* fd, int n) {
#endif #endif
GPR_ASSERT(gpr_atm_no_barrier_fetch_add(&fd->refst, n) > 0); GPR_ASSERT(gpr_atm_no_barrier_fetch_add(&fd->refst, n) > 0);
} }
/* Uninitialize and add to the freelist */ /* Uninitialize and add to the freelist */
static void fd_destroy(void* arg, grpc_error* error) { static void fd_destroy(void* arg, grpc_error* /*error*/) {
grpc_fd* fd = static_cast<grpc_fd*>(arg); grpc_fd* fd = static_cast<grpc_fd*>(arg);
fd->destroy(); fd->destroy();
@ -1042,7 +1050,7 @@ static bool begin_worker(grpc_pollset* pollset, grpc_pollset_worker* worker,
} }
static void end_worker(grpc_pollset* pollset, grpc_pollset_worker* worker, static void end_worker(grpc_pollset* pollset, grpc_pollset_worker* worker,
grpc_pollset_worker** worker_hdl) { grpc_pollset_worker** /*worker_hdl*/) {
GPR_TIMER_SCOPE("end_worker", 0); GPR_TIMER_SCOPE("end_worker", 0);
gpr_mu_lock(&pollset->mu); gpr_mu_lock(&pollset->mu);
gpr_mu_lock(&worker->pollable_obj->mu); gpr_mu_lock(&worker->pollable_obj->mu);
@ -1542,8 +1550,8 @@ static void pollset_set_add_pollset_set(grpc_pollset_set* a,
gpr_mu_unlock(&b->mu); gpr_mu_unlock(&b->mu);
} }
static void pollset_set_del_pollset_set(grpc_pollset_set* bag, static void pollset_set_del_pollset_set(grpc_pollset_set* /*bag*/,
grpc_pollset_set* item) {} grpc_pollset_set* /*item*/) {}
/******************************************************************************* /*******************************************************************************
* Event engine binding * Event engine binding
@ -1553,8 +1561,8 @@ static bool is_any_background_poller_thread(void) { return false; }
static void shutdown_background_closure(void) {} static void shutdown_background_closure(void) {}
static bool add_closure_to_background_poller(grpc_closure* closure, static bool add_closure_to_background_poller(grpc_closure* /*closure*/,
grpc_error* error) { grpc_error* /*error*/) {
return false; return false;
} }
@ -1603,7 +1611,7 @@ static const grpc_event_engine_vtable vtable = {
}; };
const grpc_event_engine_vtable* grpc_init_epollex_linux( const grpc_event_engine_vtable* grpc_init_epollex_linux(
bool explicitly_requested) { bool /*explicitly_requested*/) {
if (!grpc_has_wakeup_fd()) { if (!grpc_has_wakeup_fd()) {
gpr_log(GPR_ERROR, "Skipping epollex because of no wakeup fd."); gpr_log(GPR_ERROR, "Skipping epollex because of no wakeup fd.");
return nullptr; return nullptr;
@ -1631,7 +1639,7 @@ const grpc_event_engine_vtable* grpc_init_epollex_linux(
/* If GRPC_LINUX_EPOLL_CREATE1 is not defined, it means /* If GRPC_LINUX_EPOLL_CREATE1 is not defined, it means
epoll_create1 is not available. Return NULL */ epoll_create1 is not available. Return NULL */
const grpc_event_engine_vtable* grpc_init_epollex_linux( const grpc_event_engine_vtable* grpc_init_epollex_linux(
bool explicitly_requested) { bool /*explicitly_requested*/) {
return nullptr; return nullptr;
} }
#endif /* defined(GRPC_POSIX_SOCKET_EV_EPOLLEX) */ #endif /* defined(GRPC_POSIX_SOCKET_EV_EPOLLEX) */

27
src/core/lib/iomgr/ev_poll_posix.cc
Unescape View File

@ -323,8 +323,16 @@ static void ref_by(grpc_fd* fd, int n, const char* reason, const char* file,
gpr_atm_no_barrier_load(&fd->refst) + n, reason, file, line); gpr_atm_no_barrier_load(&fd->refst) + n, reason, file, line);
} }
#else #else
#define REF_BY(fd, n, reason) ref_by(fd, n) #define REF_BY(fd, n, reason) \
#define UNREF_BY(fd, n, reason) unref_by(fd, n) do { \
ref_by(fd, n); \
(void)(reason); \
} while (0)
#define UNREF_BY(fd, n, reason) \
do { \
unref_by(fd, n); \
(void)(reason); \
} while (0)
static void ref_by(grpc_fd* fd, int n) { static void ref_by(grpc_fd* fd, int n) {
#endif #endif
GPR_ASSERT(gpr_atm_no_barrier_fetch_add(&fd->refst, n) > 0); GPR_ASSERT(gpr_atm_no_barrier_fetch_add(&fd->refst, n) > 0);
@ -355,6 +363,8 @@ static void unref_by(grpc_fd* fd, int n) {
} }
static grpc_fd* fd_create(int fd, const char* name, bool track_err) { static grpc_fd* fd_create(int fd, const char* name, bool track_err) {
// Avoid unused-parameter warning for debug-only parameter
(void)track_err;
GPR_DEBUG_ASSERT(track_err == false); GPR_DEBUG_ASSERT(track_err == false);
grpc_fd* r = static_cast<grpc_fd*>(gpr_malloc(sizeof(*r))); grpc_fd* r = static_cast<grpc_fd*>(gpr_malloc(sizeof(*r)));
gpr_mu_init(&r->mu); gpr_mu_init(&r->mu);
@ -560,7 +570,7 @@ static void fd_notify_on_write(grpc_fd* fd, grpc_closure* closure) {
gpr_mu_unlock(&fd->mu); gpr_mu_unlock(&fd->mu);
} }
static void fd_notify_on_error(grpc_fd* fd, grpc_closure* closure) { static void fd_notify_on_error(grpc_fd* /*fd*/, grpc_closure* closure) {
if (GRPC_TRACE_FLAG_ENABLED(grpc_polling_trace)) { if (GRPC_TRACE_FLAG_ENABLED(grpc_polling_trace)) {
gpr_log(GPR_ERROR, "Polling engine does not support tracking errors."); gpr_log(GPR_ERROR, "Polling engine does not support tracking errors.");
} }
@ -579,7 +589,7 @@ static void fd_set_writable(grpc_fd* fd) {
gpr_mu_unlock(&fd->mu); gpr_mu_unlock(&fd->mu);
} }
static void fd_set_error(grpc_fd* fd) { static void fd_set_error(grpc_fd* /*fd*/) {
if (GRPC_TRACE_FLAG_ENABLED(grpc_polling_trace)) { if (GRPC_TRACE_FLAG_ENABLED(grpc_polling_trace)) {
gpr_log(GPR_ERROR, "Polling engine does not support tracking errors."); gpr_log(GPR_ERROR, "Polling engine does not support tracking errors.");
} }
@ -696,7 +706,7 @@ static void fd_end_poll(grpc_fd_watcher* watcher, int got_read, int got_write) {
GPR_TLS_DECL(g_current_thread_poller); GPR_TLS_DECL(g_current_thread_poller);
GPR_TLS_DECL(g_current_thread_worker); GPR_TLS_DECL(g_current_thread_worker);
static void remove_worker(grpc_pollset* p, grpc_pollset_worker* worker) { static void remove_worker(grpc_pollset* /*p*/, grpc_pollset_worker* worker) {
worker->prev->next = worker->next; worker->prev->next = worker->next;
worker->next->prev = worker->prev; worker->next->prev = worker->prev;
} }
@ -1320,8 +1330,8 @@ static bool is_any_background_poller_thread(void) { return false; }
static void shutdown_background_closure(void) {} static void shutdown_background_closure(void) {}
static bool add_closure_to_background_poller(grpc_closure* closure, static bool add_closure_to_background_poller(grpc_closure* /*closure*/,
grpc_error* error) { grpc_error* /*error*/) {
return false; return false;
} }
@ -1392,7 +1402,8 @@ static void reset_event_manager_on_fork() {
gpr_mu_unlock(&fork_fd_list_mu); gpr_mu_unlock(&fork_fd_list_mu);
} }
const grpc_event_engine_vtable* grpc_init_poll_posix(bool explicit_request) { const grpc_event_engine_vtable* grpc_init_poll_posix(
bool /*explicit_request*/) {
if (!grpc_has_wakeup_fd()) { if (!grpc_has_wakeup_fd()) {
gpr_log(GPR_ERROR, "Skipping poll because of no wakeup fd."); gpr_log(GPR_ERROR, "Skipping poll because of no wakeup fd.");
return nullptr; return nullptr;

2
src/core/lib/iomgr/iomgr_custom.cc
Unescape View File

@ -45,7 +45,7 @@ static bool iomgr_platform_is_any_background_poller_thread(void) {
return false; return false;
} }
static bool iomgr_platform_add_closure_to_background_poller( static bool iomgr_platform_add_closure_to_background_poller(
grpc_closure* closure, grpc_error* error) { grpc_closure* /*closure*/, grpc_error* /*error*/) {
return false; return false;
} }

8
src/core/lib/iomgr/pollset_custom.cc
Unescape View File

@ -53,7 +53,7 @@ static void pollset_init(grpc_pollset* pollset, gpr_mu** mu) {
*mu = &pollset->mu; *mu = &pollset->mu;
} }
static void pollset_shutdown(grpc_pollset* pollset, grpc_closure* closure) { static void pollset_shutdown(grpc_pollset* /*pollset*/, grpc_closure* closure) {
GRPC_CUSTOM_IOMGR_ASSERT_SAME_THREAD(); GRPC_CUSTOM_IOMGR_ASSERT_SAME_THREAD();
GRPC_CLOSURE_SCHED(closure, GRPC_ERROR_NONE); GRPC_CLOSURE_SCHED(closure, GRPC_ERROR_NONE);
} }
@ -64,7 +64,7 @@ static void pollset_destroy(grpc_pollset* pollset) {
} }
static grpc_error* pollset_work(grpc_pollset* pollset, static grpc_error* pollset_work(grpc_pollset* pollset,
grpc_pollset_worker** worker_hdl, grpc_pollset_worker** /*worker_hdl*/,
grpc_millis deadline) { grpc_millis deadline) {
GRPC_CUSTOM_IOMGR_ASSERT_SAME_THREAD(); GRPC_CUSTOM_IOMGR_ASSERT_SAME_THREAD();
gpr_mu_unlock(&pollset->mu); gpr_mu_unlock(&pollset->mu);
@ -87,8 +87,8 @@ static grpc_error* pollset_work(grpc_pollset* pollset,
return GRPC_ERROR_NONE; return GRPC_ERROR_NONE;
} }
static grpc_error* pollset_kick(grpc_pollset* pollset, static grpc_error* pollset_kick(grpc_pollset* /*pollset*/,
grpc_pollset_worker* specific_worker) { grpc_pollset_worker* /*specific_worker*/) {
GRPC_CUSTOM_IOMGR_ASSERT_SAME_THREAD(); GRPC_CUSTOM_IOMGR_ASSERT_SAME_THREAD();
poller_vtable->kick(); poller_vtable->kick();
return GRPC_ERROR_NONE; return GRPC_ERROR_NONE;

18
src/core/lib/iomgr/pollset_set_custom.cc
Unescape View File

@ -26,19 +26,19 @@ grpc_pollset_set* pollset_set_create(void) {
return (grpc_pollset_set*)((intptr_t)0xdeafbeef); return (grpc_pollset_set*)((intptr_t)0xdeafbeef);
} }
void pollset_set_destroy(grpc_pollset_set* pollset_set) {} void pollset_set_destroy(grpc_pollset_set* /*pollset_set*/) {}
void pollset_set_add_pollset(grpc_pollset_set* pollset_set, void pollset_set_add_pollset(grpc_pollset_set* /*pollset_set*/,
grpc_pollset* pollset) {} grpc_pollset* /*pollset*/) {}
void pollset_set_del_pollset(grpc_pollset_set* pollset_set, void pollset_set_del_pollset(grpc_pollset_set* /*pollset_set*/,
grpc_pollset* pollset) {} grpc_pollset* /*pollset*/) {}
void pollset_set_add_pollset_set(grpc_pollset_set* bag, void pollset_set_add_pollset_set(grpc_pollset_set* /*bag*/,
grpc_pollset_set* item) {} grpc_pollset_set* /*item*/) {}
void pollset_set_del_pollset_set(grpc_pollset_set* bag, void pollset_set_del_pollset_set(grpc_pollset_set* /*bag*/,
grpc_pollset_set* item) {} grpc_pollset_set* /*item*/) {}
static grpc_pollset_set_vtable vtable = { static grpc_pollset_set_vtable vtable = {
pollset_set_create, pollset_set_destroy, pollset_set_create, pollset_set_destroy,

2
src/core/lib/iomgr/resolve_address_custom.cc
Unescape View File

@ -151,7 +151,7 @@ static grpc_error* blocking_resolve_address_impl(
} }
static void resolve_address_impl(const char* name, const char* default_port, static void resolve_address_impl(const char* name, const char* default_port,
grpc_pollset_set* interested_parties, grpc_pollset_set* /*interested_parties*/,
grpc_closure* on_done, grpc_closure* on_done,
grpc_resolved_addresses** addrs) { grpc_resolved_addresses** addrs) {
grpc_custom_resolver* r = nullptr; grpc_custom_resolver* r = nullptr;

4
src/core/lib/iomgr/resolve_address_posix.cc
Unescape View File

@ -150,7 +150,7 @@ typedef struct {
/* Callback to be passed to grpc Executor to asynch-ify /* Callback to be passed to grpc Executor to asynch-ify
* grpc_blocking_resolve_address */ * grpc_blocking_resolve_address */
static void do_request_thread(void* rp, grpc_error* error) { static void do_request_thread(void* rp, grpc_error* /*error*/) {
request* r = static_cast<request*>(rp); request* r = static_cast<request*>(rp);
GRPC_CLOSURE_SCHED(r->on_done, grpc_blocking_resolve_address( GRPC_CLOSURE_SCHED(r->on_done, grpc_blocking_resolve_address(
r->name, r->default_port, r->addrs_out)); r->name, r->default_port, r->addrs_out));
@ -160,7 +160,7 @@ static void do_request_thread(void* rp, grpc_error* error) {
} }
static void posix_resolve_address(const char* name, const char* default_port, static void posix_resolve_address(const char* name, const char* default_port,
grpc_pollset_set* interested_parties, grpc_pollset_set* /*interested_parties*/,
grpc_closure* on_done, grpc_closure* on_done,
grpc_resolved_addresses** addrs) { grpc_resolved_addresses** addrs) {
request* r = static_cast<request*>(gpr_malloc(sizeof(request))); request* r = static_cast<request*>(gpr_malloc(sizeof(request)));

18
src/core/lib/iomgr/resource_quota.cc
Unescape View File

@ -274,7 +274,7 @@ static bool rq_reclaim_from_per_user_free_pool(
grpc_resource_quota* resource_quota); grpc_resource_quota* resource_quota);
static bool rq_reclaim(grpc_resource_quota* resource_quota, bool destructive); static bool rq_reclaim(grpc_resource_quota* resource_quota, bool destructive);
static void rq_step(void* rq, grpc_error* error) { static void rq_step(void* rq, grpc_error* /*error*/) {
grpc_resource_quota* resource_quota = static_cast<grpc_resource_quota*>(rq); grpc_resource_quota* resource_quota = static_cast<grpc_resource_quota*>(rq);
resource_quota->step_scheduled = false; resource_quota->step_scheduled = false;
do { do {
@ -479,7 +479,7 @@ static grpc_slice ru_slice_create(grpc_resource_user* resource_user,
* the combiner * the combiner
*/ */
static void ru_allocate(void* ru, grpc_error* error) { static void ru_allocate(void* ru, grpc_error* /*error*/) {
grpc_resource_user* resource_user = static_cast<grpc_resource_user*>(ru); grpc_resource_user* resource_user = static_cast<grpc_resource_user*>(ru);
if (rulist_empty(resource_user->resource_quota, if (rulist_empty(resource_user->resource_quota,
GRPC_RULIST_AWAITING_ALLOCATION)) { GRPC_RULIST_AWAITING_ALLOCATION)) {
@ -488,7 +488,7 @@ static void ru_allocate(void* ru, grpc_error* error) {
rulist_add_tail(resource_user, GRPC_RULIST_AWAITING_ALLOCATION); rulist_add_tail(resource_user, GRPC_RULIST_AWAITING_ALLOCATION);
} }
static void ru_add_to_free_pool(void* ru, grpc_error* error) { static void ru_add_to_free_pool(void* ru, grpc_error* /*error*/) {
grpc_resource_user* resource_user = static_cast<grpc_resource_user*>(ru); grpc_resource_user* resource_user = static_cast<grpc_resource_user*>(ru);
if (!rulist_empty(resource_user->resource_quota, if (!rulist_empty(resource_user->resource_quota,
GRPC_RULIST_AWAITING_ALLOCATION) && GRPC_RULIST_AWAITING_ALLOCATION) &&
@ -513,7 +513,7 @@ static bool ru_post_reclaimer(grpc_resource_user* resource_user,
return true; return true;
} }
static void ru_post_benign_reclaimer(void* ru, grpc_error* error) { static void ru_post_benign_reclaimer(void* ru, grpc_error* /*error*/) {
grpc_resource_user* resource_user = static_cast<grpc_resource_user*>(ru); grpc_resource_user* resource_user = static_cast<grpc_resource_user*>(ru);
if (!ru_post_reclaimer(resource_user, false)) return; if (!ru_post_reclaimer(resource_user, false)) return;
if (!rulist_empty(resource_user->resource_quota, if (!rulist_empty(resource_user->resource_quota,
@ -527,7 +527,7 @@ static void ru_post_benign_reclaimer(void* ru, grpc_error* error) {
rulist_add_tail(resource_user, GRPC_RULIST_RECLAIMER_BENIGN); rulist_add_tail(resource_user, GRPC_RULIST_RECLAIMER_BENIGN);
} }
static void ru_post_destructive_reclaimer(void* ru, grpc_error* error) { static void ru_post_destructive_reclaimer(void* ru, grpc_error* /*error*/) {
grpc_resource_user* resource_user = static_cast<grpc_resource_user*>(ru); grpc_resource_user* resource_user = static_cast<grpc_resource_user*>(ru);
if (!ru_post_reclaimer(resource_user, true)) return; if (!ru_post_reclaimer(resource_user, true)) return;
if (!rulist_empty(resource_user->resource_quota, if (!rulist_empty(resource_user->resource_quota,
@ -543,7 +543,7 @@ static void ru_post_destructive_reclaimer(void* ru, grpc_error* error) {
rulist_add_tail(resource_user, GRPC_RULIST_RECLAIMER_DESTRUCTIVE); rulist_add_tail(resource_user, GRPC_RULIST_RECLAIMER_DESTRUCTIVE);
} }
static void ru_shutdown(void* ru, grpc_error* error) { static void ru_shutdown(void* ru, grpc_error* /*error*/) {
if (GRPC_TRACE_FLAG_ENABLED(grpc_resource_quota_trace)) { if (GRPC_TRACE_FLAG_ENABLED(grpc_resource_quota_trace)) {
gpr_log(GPR_INFO, "RU shutdown %p", ru); gpr_log(GPR_INFO, "RU shutdown %p", ru);
} }
@ -561,7 +561,7 @@ static void ru_shutdown(void* ru, grpc_error* error) {
gpr_mu_unlock(&resource_user->mu); gpr_mu_unlock(&resource_user->mu);
} }
static void ru_destroy(void* ru, grpc_error* error) { static void ru_destroy(void* ru, grpc_error* /*error*/) {
grpc_resource_user* resource_user = static_cast<grpc_resource_user*>(ru); grpc_resource_user* resource_user = static_cast<grpc_resource_user*>(ru);
GPR_ASSERT(gpr_atm_no_barrier_load(&resource_user->refs) == 0); GPR_ASSERT(gpr_atm_no_barrier_load(&resource_user->refs) == 0);
// Free all the remaining thread quota // Free all the remaining thread quota
@ -611,7 +611,7 @@ typedef struct {
grpc_closure closure; grpc_closure closure;
} rq_resize_args; } rq_resize_args;
static void rq_resize(void* args, grpc_error* error) { static void rq_resize(void* args, grpc_error* /*error*/) {
rq_resize_args* a = static_cast<rq_resize_args*>(args); rq_resize_args* a = static_cast<rq_resize_args*>(args);
int64_t delta = a->size - a->resource_quota->size; int64_t delta = a->size - a->resource_quota->size;
a->resource_quota->size += delta; a->resource_quota->size += delta;
@ -622,7 +622,7 @@ static void rq_resize(void* args, grpc_error* error) {
gpr_free(a); gpr_free(a);
} }
static void rq_reclamation_done(void* rq, grpc_error* error) { static void rq_reclamation_done(void* rq, grpc_error* /*error*/) {
grpc_resource_quota* resource_quota = static_cast<grpc_resource_quota*>(rq); grpc_resource_quota* resource_quota = static_cast<grpc_resource_quota*>(rq);
resource_quota->reclaiming = false; resource_quota->reclaiming = false;
rq_step_sched(resource_quota); rq_step_sched(resource_quota);

11
src/core/lib/iomgr/socket_utils_common_posix.cc
Unescape View File

@ -84,11 +84,16 @@ grpc_error* grpc_set_socket_no_sigpipe_if_possible(int fd) {
if ((newval != 0) != (val != 0)) { if ((newval != 0) != (val != 0)) {
return GRPC_ERROR_CREATE_FROM_STATIC_STRING("Failed to set SO_NOSIGPIPE"); return GRPC_ERROR_CREATE_FROM_STATIC_STRING("Failed to set SO_NOSIGPIPE");
} }
#else
// Avoid unused parameter warning for conditional parameter
(void)fd;
#endif #endif
return GRPC_ERROR_NONE; return GRPC_ERROR_NONE;
} }
grpc_error* grpc_set_socket_ip_pktinfo_if_possible(int fd) { grpc_error* grpc_set_socket_ip_pktinfo_if_possible(int fd) {
// Use conditionally-important parameter to avoid warning
(void)fd;
#ifdef GRPC_HAVE_IP_PKTINFO #ifdef GRPC_HAVE_IP_PKTINFO
int get_local_ip = 1; int get_local_ip = 1;
if (0 != setsockopt(fd, IPPROTO_IP, IP_PKTINFO, &get_local_ip, if (0 != setsockopt(fd, IPPROTO_IP, IP_PKTINFO, &get_local_ip,
@ -100,6 +105,8 @@ grpc_error* grpc_set_socket_ip_pktinfo_if_possible(int fd) {
} }
grpc_error* grpc_set_socket_ipv6_recvpktinfo_if_possible(int fd) { grpc_error* grpc_set_socket_ipv6_recvpktinfo_if_possible(int fd) {
// Use conditionally-important parameter to avoid warning
(void)fd;
#ifdef GRPC_HAVE_IPV6_RECVPKTINFO #ifdef GRPC_HAVE_IPV6_RECVPKTINFO
int get_local_ip = 1; int get_local_ip = 1;
if (0 != setsockopt(fd, IPPROTO_IPV6, IPV6_RECVPKTINFO, &get_local_ip, if (0 != setsockopt(fd, IPPROTO_IPV6, IPV6_RECVPKTINFO, &get_local_ip,
@ -256,6 +263,10 @@ void config_default_tcp_user_timeout(bool enable, int timeout, bool is_client) {
/* Set TCP_USER_TIMEOUT */ /* Set TCP_USER_TIMEOUT */
grpc_error* grpc_set_socket_tcp_user_timeout( grpc_error* grpc_set_socket_tcp_user_timeout(
int fd, const grpc_channel_args* channel_args, bool is_client) { int fd, const grpc_channel_args* channel_args, bool is_client) {
// Use conditionally-important parameter to avoid warning
(void)fd;
(void)channel_args;
(void)is_client;
#ifdef GRPC_HAVE_TCP_USER_TIMEOUT #ifdef GRPC_HAVE_TCP_USER_TIMEOUT
bool enable; bool enable;
int timeout; int timeout;

2
src/core/lib/iomgr/tcp_client_custom.cc
Unescape View File

@ -58,7 +58,7 @@ static void custom_tcp_connect_cleanup(grpc_custom_tcp_connect* connect) {
} }
} }
static void custom_close_callback(grpc_custom_socket* socket) {} static void custom_close_callback(grpc_custom_socket* /*socket*/) {}
static void on_alarm(void* acp, grpc_error* error) { static void on_alarm(void* acp, grpc_error* error) {
int done; int done;

Write Preview
Loading…
Cancel
Save