--- memcached.c.orig 2025-07-29 01:17:34 UTC +++ memcached.c @@ -686,7 +686,7 @@ conn *conn_new(const int sfd, enum conn_states init_st if (init_state == conn_listening) { fprintf(stderr, "<%d server listening (%s)\n", sfd, prot_text(c->protocol)); - } else if (IS_UDP(transport)) { + } else if IS_UDP(transport) { fprintf(stderr, "<%d server listening (udp)\n", sfd); } else if (c->protocol == negotiating_prot) { fprintf(stderr, "<%d new auto-negotiating client connection\n", @@ -741,7 +741,7 @@ conn *conn_new(const int sfd, enum conn_states init_st c->ssl_enabled = false; } - if (IS_UDP(transport)) { + if IS_UDP(transport) { c->try_read_command = try_read_command_udp; } else { switch (c->protocol) { @@ -839,7 +839,7 @@ static void conn_cleanup(conn *c) { c->sasl_conn = NULL; } - if (IS_UDP(c->transport)) { + if IS_UDP(c->transport) { conn_set_state(c, conn_read); } } @@ -1147,7 +1147,7 @@ bool resp_start(conn *c) { c->resp->next = resp; c->resp = resp; } - if (IS_UDP(c->transport)) { + if IS_UDP(c->transport) { // need to hold on to some data for async responses. c->resp->request_id = c->request_id; c->resp->request_addr = c->request_addr; @@ -2160,7 +2160,7 @@ void process_stats_conns(ADD_STAT add_stats, void *c) * output -- not worth the complexity of the locking that'd be * required to prevent it. */ - if (IS_UDP(conns[i]->transport)) { + if IS_UDP(conns[i]->transport) { APPEND_NUM_STAT(i, "UDP", "%s", "UDP"); } if (conns[i]->state != conn_closed) { @@ -3322,7 +3322,7 @@ static void drive_machine(conn *c) { case conn_closing: if (!c->resps_suspended) { - if (IS_UDP(c->transport)) + if IS_UDP(c->transport) conn_cleanup(c); else conn_close(c); @@ -3524,7 +3524,7 @@ static int server_socket(const char *interface, #endif setsockopt(sfd, SOL_SOCKET, SO_REUSEADDR, (void *)&flags, sizeof(flags)); - if (IS_UDP(transport)) { + if IS_UDP(transport) { maximize_sndbuf(sfd); } else { error = setsockopt(sfd, SOL_SOCKET, SO_KEEPALIVE, (void *)&flags, sizeof(flags)); @@ -3579,7 +3579,7 @@ static int server_socket(const char *interface, } } - if (IS_UDP(transport)) { + if IS_UDP(transport) { int c; for (c = 0; c < settings.num_threads_per_udp; c++) {