1 --- memcached.c.orig	2023-03-08 21:34:27 UTC
2 +++ memcached.c
3 @@ -707,7 +707,7 @@ conn *conn_new(const int sfd, enum conn_states init_st
4          if (init_state == conn_listening) {
5              fprintf(stderr, "<%d server listening (%s)\n", sfd,
6                  prot_text(c->protocol));
7 -        } else if (IS_UDP(transport)) {
8 +        } else if IS_UDP(transport) {
9              fprintf(stderr, "<%d server listening (udp)\n", sfd);
10          } else if (c->protocol == negotiating_prot) {
11              fprintf(stderr, "<%d new auto-negotiating client connection\n",
12 @@ -772,7 +772,7 @@ conn *conn_new(const int sfd, enum conn_states init_st
13          c->write = tcp_write;
14      }
15 
16 -    if (IS_UDP(transport)) {
17 +    if IS_UDP(transport) {
18          c->try_read_command = try_read_command_udp;
19      } else {
20          switch (c->protocol) {
21 @@ -871,7 +871,7 @@ static void conn_cleanup(conn *c) {
22          c->sasl_conn = NULL;
23      }
24 
25 -    if (IS_UDP(c->transport)) {
26 +    if IS_UDP(c->transport) {
27          conn_set_state(c, conn_read);
28      }
29  }
30 @@ -1171,7 +1171,7 @@ bool resp_start(conn *c) {
31          c->resp->next = resp;
32          c->resp = resp;
33      }
34 -    if (IS_UDP(c->transport)) {
35 +    if IS_UDP(c->transport) {
36          // need to hold on to some data for async responses.
37          c->resp->request_id = c->request_id;
38          c->resp->request_addr = c->request_addr;
39 @@ -2166,7 +2166,7 @@ void process_stats_conns(ADD_STAT add_stats, void *c)
40               * output -- not worth the complexity of the locking that'd be
41               * required to prevent it.
42               */
43 -            if (IS_UDP(conns[i]->transport)) {
44 +            if IS_UDP(conns[i]->transport) {
45                  APPEND_NUM_STAT(i, "UDP", "%s", "UDP");
46              }
47              if (conns[i]->state != conn_closed) {
48 @@ -3317,8 +3317,8 @@ static void drive_machine(conn *c) {
49              break;
50 
51          case conn_closing:
52              if (!c->resps_suspended) {
53 -                if (IS_UDP(c->transport))
54 +                if IS_UDP(c->transport)
55                      conn_cleanup(c);
56                  else
57                      conn_close(c);
58 @@ -3552,7 +3552,7 @@ static int server_socket(const char *interface,
59  #endif
60 
61          setsockopt(sfd, SOL_SOCKET, SO_REUSEADDR, (void *)&flags, sizeof(flags));
62 -        if (IS_UDP(transport)) {
63 +        if IS_UDP(transport) {
64              maximize_sndbuf(sfd);
65          } else {
66              error = setsockopt(sfd, SOL_SOCKET, SO_KEEPALIVE, (void *)&flags, sizeof(flags));
67 @@ -3607,7 +3607,7 @@ static int server_socket(const char *interface,
68              }
69          }
70 
71 -        if (IS_UDP(transport)) {
72 +        if IS_UDP(transport) {
73              int c;
74 
75              for (c = 0; c < settings.num_threads_per_udp; c++) {
76