blob: fa428d3a6e6b97f4f1ffc1faac465dcc80cf460b [file] [log] [blame]
Emeric Brun2b920a12010-09-23 18:30:22 +02001/*
Emeric Brunb3971ab2015-05-12 18:49:09 +02002 * Peer synchro management.
Emeric Brun2b920a12010-09-23 18:30:22 +02003 *
4 * Copyright 2010 EXCELIANCE, Emeric Brun <ebrun@exceliance.fr>
5 *
6 * This program is free software; you can redistribute it and/or
7 * modify it under the terms of the GNU General Public License
8 * as published by the Free Software Foundation; either version
9 * 2 of the License, or (at your option) any later version.
10 *
11 */
12
13#include <errno.h>
14#include <fcntl.h>
15#include <stdio.h>
16#include <stdlib.h>
17#include <string.h>
18
19#include <sys/socket.h>
20#include <sys/stat.h>
21#include <sys/types.h>
22
Willy Tarreau4c7e4b72020-05-27 12:58:42 +020023#include <haproxy/api.h>
Willy Tarreaub2551052020-06-09 09:07:15 +020024#include <haproxy/applet.h>
Willy Tarreauf1d32c42020-06-04 21:07:02 +020025#include <haproxy/channel.h>
Willy Tarreau83487a82020-06-04 20:19:54 +020026#include <haproxy/cli.h>
Willy Tarreau3afc4c42020-06-03 18:23:19 +020027#include <haproxy/dict.h>
Willy Tarreau36979d92020-06-05 17:27:29 +020028#include <haproxy/errors.h>
Willy Tarreaudfd3de82020-06-04 23:46:14 +020029#include <haproxy/fd.h>
Willy Tarreau762d7a52020-06-04 11:23:07 +020030#include <haproxy/frontend.h>
Willy Tarreau6131d6a2020-06-02 16:48:09 +020031#include <haproxy/net_helper.h>
Willy Tarreau8efbdfb2020-06-04 11:29:21 +020032#include <haproxy/obj_type-t.h>
Willy Tarreau3c2a7c22020-06-04 18:38:21 +020033#include <haproxy/peers.h>
Willy Tarreaua264d962020-06-04 22:29:18 +020034#include <haproxy/proxy.h>
Willy Tarreau48d25b32020-06-04 18:58:52 +020035#include <haproxy/session-t.h>
Willy Tarreau3727a8a2020-06-04 17:37:26 +020036#include <haproxy/signal.h>
Willy Tarreau2eec9b52020-06-04 19:58:55 +020037#include <haproxy/stats-t.h>
Willy Tarreaudfd3de82020-06-04 23:46:14 +020038#include <haproxy/stick_table.h>
39#include <haproxy/stream.h>
Willy Tarreau5e539c92020-06-04 20:45:39 +020040#include <haproxy/stream_interface.h>
Willy Tarreaub2551052020-06-09 09:07:15 +020041#include <haproxy/task.h>
42#include <haproxy/thread.h>
Willy Tarreau92b4f132020-06-01 11:05:15 +020043#include <haproxy/time.h>
Willy Tarreau48fbcae2020-06-03 18:09:46 +020044#include <haproxy/tools.h>
Frédéric Lécailled8659352020-11-10 16:18:03 +010045#include <haproxy/trace.h>
Emeric Brun2b920a12010-09-23 18:30:22 +020046
Emeric Brun2b920a12010-09-23 18:30:22 +020047
48/*******************************/
49/* Current peer learning state */
50/*******************************/
51
52/******************************/
Emeric Brunb3971ab2015-05-12 18:49:09 +020053/* Current peers section resync state */
Emeric Brun2b920a12010-09-23 18:30:22 +020054/******************************/
Emeric Brunccdfbae2021-04-28 12:59:35 +020055#define PEERS_F_RESYNC_LOCAL 0x00000001 /* Learn from local finished or no more needed */
56#define PEERS_F_RESYNC_REMOTE 0x00000002 /* Learn from remote finished or no more needed */
57#define PEERS_F_RESYNC_ASSIGN 0x00000004 /* A peer was assigned to learn our lesson */
58#define PEERS_F_RESYNC_PROCESS 0x00000008 /* The assigned peer was requested for resync */
59#define PEERS_F_RESYNC_LOCALTIMEOUT 0x00000010 /* Timeout waiting for a full resync from a local node */
60#define PEERS_F_RESYNC_REMOTETIMEOUT 0x00000020 /* Timeout waiting for a full resync from a remote node */
61#define PEERS_F_RESYNC_LOCALABORT 0x00000040 /* Session aborted learning from a local node */
62#define PEERS_F_RESYNC_REMOTEABORT 0x00000080 /* Session aborted learning from a remote node */
63#define PEERS_F_RESYNC_LOCALFINISHED 0x00000100 /* A local node teach us and was fully up to date */
64#define PEERS_F_RESYNC_REMOTEFINISHED 0x00000200 /* A remote node teach us and was fully up to date */
65#define PEERS_F_RESYNC_LOCALPARTIAL 0x00000400 /* A local node teach us but was partially up to date */
66#define PEERS_F_RESYNC_REMOTEPARTIAL 0x00000800 /* A remote node teach us but was partially up to date */
67#define PEERS_F_RESYNC_LOCALASSIGN 0x00001000 /* A local node was assigned for a full resync */
68#define PEERS_F_RESYNC_REMOTEASSIGN 0x00002000 /* A remote node was assigned for a full resync */
69#define PEERS_F_RESYNC_REQUESTED 0x00004000 /* A resync was explicitly requested */
70#define PEERS_F_DONOTSTOP 0x00010000 /* Main table sync task block process during soft stop
71 to push data to new process */
Emeric Brun2b920a12010-09-23 18:30:22 +020072
Frédéric Lécailleaba44a22019-03-26 10:18:07 +010073#define PEERS_RESYNC_STATEMASK (PEERS_F_RESYNC_LOCAL|PEERS_F_RESYNC_REMOTE)
74#define PEERS_RESYNC_FROMLOCAL 0x00000000
75#define PEERS_RESYNC_FROMREMOTE PEERS_F_RESYNC_LOCAL
76#define PEERS_RESYNC_FINISHED (PEERS_F_RESYNC_LOCAL|PEERS_F_RESYNC_REMOTE)
Emeric Brunb3971ab2015-05-12 18:49:09 +020077
78/***********************************/
79/* Current shared table sync state */
80/***********************************/
Frédéric Lécailleaba44a22019-03-26 10:18:07 +010081#define SHTABLE_F_TEACH_STAGE1 0x00000001 /* Teach state 1 complete */
82#define SHTABLE_F_TEACH_STAGE2 0x00000002 /* Teach state 2 complete */
Emeric Brun2b920a12010-09-23 18:30:22 +020083
84/******************************/
85/* Remote peer teaching state */
86/******************************/
Frédéric Lécailleaba44a22019-03-26 10:18:07 +010087#define PEER_F_TEACH_PROCESS 0x00000001 /* Teach a lesson to current peer */
88#define PEER_F_TEACH_FINISHED 0x00000008 /* Teach conclude, (wait for confirm) */
89#define PEER_F_TEACH_COMPLETE 0x00000010 /* All that we know already taught to current peer, used only for a local peer */
90#define PEER_F_LEARN_ASSIGN 0x00000100 /* Current peer was assigned for a lesson */
91#define PEER_F_LEARN_NOTUP2DATE 0x00000200 /* Learn from peer finished but peer is not up to date */
92#define PEER_F_ALIVE 0x20000000 /* Used to flag a peer a alive. */
93#define PEER_F_HEARTBEAT 0x40000000 /* Heartbeat message to send. */
94#define PEER_F_DWNGRD 0x80000000 /* When this flag is enabled, we must downgrade the supported version announced during peer sessions. */
Emeric Brun2b920a12010-09-23 18:30:22 +020095
Frédéric Lécailleaba44a22019-03-26 10:18:07 +010096#define PEER_TEACH_RESET ~(PEER_F_TEACH_PROCESS|PEER_F_TEACH_FINISHED) /* PEER_F_TEACH_COMPLETE should never be reset */
97#define PEER_LEARN_RESET ~(PEER_F_LEARN_ASSIGN|PEER_F_LEARN_NOTUP2DATE)
Emeric Brun2b920a12010-09-23 18:30:22 +020098
Frédéric Lécaille54bff832019-03-26 10:25:20 +010099#define PEER_RESYNC_TIMEOUT 5000 /* 5 seconds */
100#define PEER_RECONNECT_TIMEOUT 5000 /* 5 seconds */
Christopher Fauletd73a5cc2022-07-26 19:14:36 +0200101#define PEER_LOCAL_RECONNECT_TIMEOUT 500 /* 500ms */
Frédéric Lécaille645635d2019-02-11 17:49:39 +0100102#define PEER_HEARTBEAT_TIMEOUT 3000 /* 3 seconds */
103
Willy Tarreau49962b52021-02-12 16:56:22 +0100104/* flags for "show peers" */
105#define PEERS_SHOW_F_DICT 0x00000001 /* also show the contents of the dictionary */
106
Emeric Brunb3971ab2015-05-12 18:49:09 +0200107/*****************************/
108/* Sync message class */
109/*****************************/
110enum {
111 PEER_MSG_CLASS_CONTROL = 0,
112 PEER_MSG_CLASS_ERROR,
113 PEER_MSG_CLASS_STICKTABLE = 10,
114 PEER_MSG_CLASS_RESERVED = 255,
115};
116
117/*****************************/
118/* control message types */
119/*****************************/
120enum {
121 PEER_MSG_CTRL_RESYNCREQ = 0,
122 PEER_MSG_CTRL_RESYNCFINISHED,
123 PEER_MSG_CTRL_RESYNCPARTIAL,
124 PEER_MSG_CTRL_RESYNCCONFIRM,
Frédéric Lécaille645635d2019-02-11 17:49:39 +0100125 PEER_MSG_CTRL_HEARTBEAT,
Emeric Brunb3971ab2015-05-12 18:49:09 +0200126};
127
128/*****************************/
129/* error message types */
130/*****************************/
131enum {
132 PEER_MSG_ERR_PROTOCOL = 0,
133 PEER_MSG_ERR_SIZELIMIT,
134};
135
Emeric Brun530ba382020-06-02 11:17:42 +0200136/* network key types;
137 * network types were directly and mistakenly
138 * mapped on sample types, to keep backward
139 * compatiblitiy we keep those values but
140 * we now use a internal/network mapping
141 * to avoid further mistakes adding or
142 * modifying internals types
143 */
144enum {
145 PEER_KT_ANY = 0, /* any type */
146 PEER_KT_RESV1, /* UNUSED */
147 PEER_KT_SINT, /* signed 64bits integer type */
148 PEER_KT_RESV3, /* UNUSED */
149 PEER_KT_IPV4, /* ipv4 type */
150 PEER_KT_IPV6, /* ipv6 type */
151 PEER_KT_STR, /* char string type */
152 PEER_KT_BIN, /* buffer type */
153 PEER_KT_TYPES /* number of types, must always be last */
154};
155
156/* Map used to retrieve network type from internal type
157 * Note: Undeclared mapping maps entry to PEER_KT_ANY == 0
158 */
159static int peer_net_key_type[SMP_TYPES] = {
160 [SMP_T_SINT] = PEER_KT_SINT,
161 [SMP_T_IPV4] = PEER_KT_IPV4,
162 [SMP_T_IPV6] = PEER_KT_IPV6,
163 [SMP_T_STR] = PEER_KT_STR,
164 [SMP_T_BIN] = PEER_KT_BIN,
165};
166
167/* Map used to retrieve internal type from external type
168 * Note: Undeclared mapping maps entry to SMP_T_ANY == 0
169 */
170static int peer_int_key_type[PEER_KT_TYPES] = {
171 [PEER_KT_SINT] = SMP_T_SINT,
172 [PEER_KT_IPV4] = SMP_T_IPV4,
173 [PEER_KT_IPV6] = SMP_T_IPV6,
174 [PEER_KT_STR] = SMP_T_STR,
175 [PEER_KT_BIN] = SMP_T_BIN,
176};
177
Frédéric Lécailled5fe14b2019-01-24 10:33:40 +0100178/*
179 * Parameters used by functions to build peer protocol messages. */
180struct peer_prep_params {
181 struct {
Frédéric Lécaille7d0ceee2019-01-24 14:24:05 +0100182 struct peer *peer;
183 } hello;
184 struct {
185 unsigned int st1;
186 } error_status;
187 struct {
Frédéric Lécailled5fe14b2019-01-24 10:33:40 +0100188 struct stksess *stksess;
189 struct shared_table *shared_table;
190 unsigned int updateid;
191 int use_identifier;
192 int use_timed;
Frédéric Lécaille8d78fa72019-05-20 18:22:52 +0200193 struct peer *peer;
Frédéric Lécailled5fe14b2019-01-24 10:33:40 +0100194 } updt;
195 struct {
196 struct shared_table *shared_table;
197 } swtch;
198 struct {
199 struct shared_table *shared_table;
200 } ack;
Frédéric Lécaille7d0ceee2019-01-24 14:24:05 +0100201 struct {
202 unsigned char head[2];
203 } control;
204 struct {
205 unsigned char head[2];
206 } error;
Frédéric Lécailled5fe14b2019-01-24 10:33:40 +0100207};
Emeric Brunb3971ab2015-05-12 18:49:09 +0200208
209/*******************************/
210/* stick table sync mesg types */
211/* Note: ids >= 128 contains */
Ilya Shipitsinc02a23f2020-05-06 00:53:22 +0500212/* id message contains data */
Emeric Brunb3971ab2015-05-12 18:49:09 +0200213/*******************************/
Olivier Houchard33992262018-10-16 18:49:26 +0200214#define PEER_MSG_STKT_UPDATE 0x80
215#define PEER_MSG_STKT_INCUPDATE 0x81
216#define PEER_MSG_STKT_DEFINE 0x82
217#define PEER_MSG_STKT_SWITCH 0x83
218#define PEER_MSG_STKT_ACK 0x84
219#define PEER_MSG_STKT_UPDATE_TIMED 0x85
220#define PEER_MSG_STKT_INCUPDATE_TIMED 0x86
Frédéric Lécaille36fb77e2019-06-04 08:28:19 +0200221/* All the stick-table message identifiers abova have the #7 bit set */
222#define PEER_MSG_STKT_BIT 7
223#define PEER_MSG_STKT_BIT_MASK (1 << PEER_MSG_STKT_BIT)
Emeric Brun2b920a12010-09-23 18:30:22 +0200224
Frédéric Lécaille39143342019-05-24 14:32:27 +0200225/* The maximum length of an encoded data length. */
226#define PEER_MSG_ENC_LENGTH_MAXLEN 5
227
Frédéric Lécaille32b55732019-06-03 18:29:51 +0200228/* Minimum 64-bits value encoded with 2 bytes */
229#define PEER_ENC_2BYTES_MIN 0xf0 /* 0xf0 (or 240) */
230/* 3 bytes */
231#define PEER_ENC_3BYTES_MIN ((1ULL << 11) | PEER_ENC_2BYTES_MIN) /* 0x8f0 (or 2288) */
232/* 4 bytes */
233#define PEER_ENC_4BYTES_MIN ((1ULL << 18) | PEER_ENC_3BYTES_MIN) /* 0x408f0 (or 264432) */
234/* 5 bytes */
235#define PEER_ENC_5BYTES_MIN ((1ULL << 25) | PEER_ENC_4BYTES_MIN) /* 0x20408f0 (or 33818864) */
236/* 6 bytes */
237#define PEER_ENC_6BYTES_MIN ((1ULL << 32) | PEER_ENC_5BYTES_MIN) /* 0x1020408f0 (or 4328786160) */
238/* 7 bytes */
239#define PEER_ENC_7BYTES_MIN ((1ULL << 39) | PEER_ENC_6BYTES_MIN) /* 0x81020408f0 (or 554084600048) */
240/* 8 bytes */
241#define PEER_ENC_8BYTES_MIN ((1ULL << 46) | PEER_ENC_7BYTES_MIN) /* 0x4081020408f0 (or 70922828777712) */
242/* 9 bytes */
243#define PEER_ENC_9BYTES_MIN ((1ULL << 53) | PEER_ENC_8BYTES_MIN) /* 0x204081020408f0 (or 9078122083518704) */
244/* 10 bytes */
245#define PEER_ENC_10BYTES_MIN ((1ULL << 60) | PEER_ENC_9BYTES_MIN) /* 0x10204081020408f0 (or 1161999626690365680) */
246
247/* #7 bit used to detect the last byte to be encoded */
248#define PEER_ENC_STOP_BIT 7
249/* The byte minimum value with #7 bit set */
250#define PEER_ENC_STOP_BYTE (1 << PEER_ENC_STOP_BIT)
251/* The left most number of bits set for PEER_ENC_2BYTES_MIN */
252#define PEER_ENC_2BYTES_MIN_BITS 4
253
Frédéric Lécaille39143342019-05-24 14:32:27 +0200254#define PEER_MSG_HEADER_LEN 2
255
Frédéric Lécaille8d78fa72019-05-20 18:22:52 +0200256#define PEER_STKT_CACHE_MAX_ENTRIES 128
257
Emeric Brun2b920a12010-09-23 18:30:22 +0200258/**********************************/
259/* Peer Session IO handler states */
260/**********************************/
261
Willy Tarreaue4d927a2013-12-01 12:47:35 +0100262enum {
263 PEER_SESS_ST_ACCEPT = 0, /* Initial state for session create by an accept, must be zero! */
264 PEER_SESS_ST_GETVERSION, /* Validate supported protocol version */
265 PEER_SESS_ST_GETHOST, /* Validate host ID correspond to local host id */
266 PEER_SESS_ST_GETPEER, /* Validate peer ID correspond to a known remote peer id */
Willy Tarreaue4d927a2013-12-01 12:47:35 +0100267 /* after this point, data were possibly exchanged */
268 PEER_SESS_ST_SENDSUCCESS, /* Send ret code 200 (success) and wait for message */
269 PEER_SESS_ST_CONNECT, /* Initial state for session create on a connect, push presentation into buffer */
270 PEER_SESS_ST_GETSTATUS, /* Wait for the welcome message */
271 PEER_SESS_ST_WAITMSG, /* Wait for data messages */
272 PEER_SESS_ST_EXIT, /* Exit with status code */
Emeric Brunb3971ab2015-05-12 18:49:09 +0200273 PEER_SESS_ST_ERRPROTO, /* Send error proto message before exit */
274 PEER_SESS_ST_ERRSIZE, /* Send error size message before exit */
Willy Tarreaue4d927a2013-12-01 12:47:35 +0100275 PEER_SESS_ST_END, /* Killed session */
276};
Emeric Brun2b920a12010-09-23 18:30:22 +0200277
Willy Tarreaue4d927a2013-12-01 12:47:35 +0100278/***************************************************/
279/* Peer Session status code - part of the protocol */
280/***************************************************/
Emeric Brun2b920a12010-09-23 18:30:22 +0200281
Frédéric Lécailleaba44a22019-03-26 10:18:07 +0100282#define PEER_SESS_SC_CONNECTCODE 100 /* connect in progress */
283#define PEER_SESS_SC_CONNECTEDCODE 110 /* tcp connect success */
Emeric Brun2b920a12010-09-23 18:30:22 +0200284
Frédéric Lécailleaba44a22019-03-26 10:18:07 +0100285#define PEER_SESS_SC_SUCCESSCODE 200 /* accept or connect successful */
Emeric Brun2b920a12010-09-23 18:30:22 +0200286
Frédéric Lécailleaba44a22019-03-26 10:18:07 +0100287#define PEER_SESS_SC_TRYAGAIN 300 /* try again later */
Emeric Brun2b920a12010-09-23 18:30:22 +0200288
Frédéric Lécailleaba44a22019-03-26 10:18:07 +0100289#define PEER_SESS_SC_ERRPROTO 501 /* error protocol */
290#define PEER_SESS_SC_ERRVERSION 502 /* unknown protocol version */
291#define PEER_SESS_SC_ERRHOST 503 /* bad host name */
292#define PEER_SESS_SC_ERRPEER 504 /* unknown peer */
Emeric Brun2b920a12010-09-23 18:30:22 +0200293
294#define PEER_SESSION_PROTO_NAME "HAProxyS"
Frédéric Lécaille523cc9e2016-10-12 17:30:30 +0200295#define PEER_MAJOR_VER 2
296#define PEER_MINOR_VER 1
297#define PEER_DWNGRD_MINOR_VER 0
Emeric Brun2b920a12010-09-23 18:30:22 +0200298
Willy Tarreau6254a922019-01-29 17:45:23 +0100299static size_t proto_len = sizeof(PEER_SESSION_PROTO_NAME) - 1;
Frédéric Lécailleed2b4a62017-07-13 09:07:09 +0200300struct peers *cfg_peers = NULL;
Emeric Brun9ef2ad72019-04-02 17:22:01 +0200301static void peer_session_forceshutdown(struct peer *peer);
Emeric Brun2b920a12010-09-23 18:30:22 +0200302
Frédéric Lécaille6c391982019-06-06 11:34:03 +0200303static struct ebpt_node *dcache_tx_insert(struct dcache *dc,
304 struct dcache_tx_entry *i);
Frédéric Lécaille8d78fa72019-05-20 18:22:52 +0200305static inline void flush_dcache(struct peer *peer);
306
Frédéric Lécailled8659352020-11-10 16:18:03 +0100307/* trace source and events */
308static void peers_trace(enum trace_level level, uint64_t mask,
309 const struct trace_source *src,
310 const struct ist where, const struct ist func,
311 const void *a1, const void *a2, const void *a3, const void *a4);
312
313static const struct trace_event peers_trace_events[] = {
314#define PEERS_EV_UPDTMSG (1 << 0)
315 { .mask = PEERS_EV_UPDTMSG, .name = "updtmsg", .desc = "update message received" },
Frédéric Lécailleda2b0842021-01-15 16:21:28 +0100316#define PEERS_EV_ACKMSG (1 << 1)
317 { .mask = PEERS_EV_ACKMSG, .name = "ackmsg", .desc = "ack message received" },
318#define PEERS_EV_SWTCMSG (1 << 2)
319 { .mask = PEERS_EV_SWTCMSG, .name = "swtcmsg", .desc = "switch message received" },
320#define PEERS_EV_DEFMSG (1 << 3)
321 { .mask = PEERS_EV_DEFMSG, .name = "defmsg", .desc = "definition message received" },
322#define PEERS_EV_CTRLMSG (1 << 4)
323 { .mask = PEERS_EV_CTRLMSG, .name = "ctrlmsg", .desc = "control message sent/received" },
324#define PEERS_EV_SESSREL (1 << 5)
325 { .mask = PEERS_EV_SESSREL, .name = "sessrl", .desc = "peer session releasing" },
326#define PEERS_EV_PROTOERR (1 << 6)
327 { .mask = PEERS_EV_PROTOERR, .name = "protoerr", .desc = "protocol error" },
Frédéric Lécailled8659352020-11-10 16:18:03 +0100328};
329
330static const struct name_desc peers_trace_lockon_args[4] = {
331 /* arg1 */ { /* already used by the connection */ },
332 /* arg2 */ { .name="peers", .desc="Peers protocol" },
333 /* arg3 */ { },
334 /* arg4 */ { }
335};
336
337static const struct name_desc peers_trace_decoding[] = {
338#define PEERS_VERB_CLEAN 1
339 { .name="clean", .desc="only user-friendly stuff, generally suitable for level \"user\"" },
340 { /* end */ }
341};
342
343
344struct trace_source trace_peers = {
345 .name = IST("peers"),
346 .desc = "Peers protocol",
347 .arg_def = TRC_ARG1_CONN, /* TRACE()'s first argument is always a connection */
348 .default_cb = peers_trace,
349 .known_events = peers_trace_events,
350 .lockon_args = peers_trace_lockon_args,
351 .decoding = peers_trace_decoding,
352 .report_events = ~0, /* report everything by default */
353};
354
Frédéric Lécailleda2b0842021-01-15 16:21:28 +0100355/* Return peer control message types as strings (only for debugging purpose). */
356static inline char *ctrl_msg_type_str(unsigned int type)
357{
358 switch (type) {
359 case PEER_MSG_CTRL_RESYNCREQ:
360 return "RESYNCREQ";
361 case PEER_MSG_CTRL_RESYNCFINISHED:
362 return "RESYNCFINISHED";
363 case PEER_MSG_CTRL_RESYNCPARTIAL:
364 return "RESYNCPARTIAL";
365 case PEER_MSG_CTRL_RESYNCCONFIRM:
366 return "RESYNCCONFIRM";
367 case PEER_MSG_CTRL_HEARTBEAT:
368 return "HEARTBEAT";
369 default:
370 return "???";
371 }
372}
373
Frédéric Lécailled8659352020-11-10 16:18:03 +0100374#define TRACE_SOURCE &trace_peers
375INITCALL1(STG_REGISTER, trace_register_source, TRACE_SOURCE);
376
377static void peers_trace(enum trace_level level, uint64_t mask,
378 const struct trace_source *src,
379 const struct ist where, const struct ist func,
380 const void *a1, const void *a2, const void *a3, const void *a4)
381{
Frédéric Lécailleda2b0842021-01-15 16:21:28 +0100382 if (mask & (PEERS_EV_UPDTMSG|PEERS_EV_ACKMSG|PEERS_EV_SWTCMSG)) {
Frédéric Lécailled8659352020-11-10 16:18:03 +0100383 if (a2) {
384 const struct peer *peer = a2;
385
386 chunk_appendf(&trace_buf, " peer=%s", peer->id);
387 }
388 if (a3) {
389 const char *p = a3;
390
391 chunk_appendf(&trace_buf, " @%p", p);
392 }
393 if (a4) {
394 const size_t *val = a4;
395
396 chunk_appendf(&trace_buf, " %llu", (unsigned long long)*val);
397 }
398 }
Frédéric Lécailleda2b0842021-01-15 16:21:28 +0100399
400 if (mask & PEERS_EV_DEFMSG) {
401 if (a2) {
402 const struct peer *peer = a2;
403
404 chunk_appendf(&trace_buf, " peer=%s", peer->id);
405 }
406 if (a3) {
407 const char *p = a3;
408
409 chunk_appendf(&trace_buf, " @%p", p);
410 }
411 if (a4) {
412 const int *val = a4;
413
414 chunk_appendf(&trace_buf, " %d", *val);
415 }
416 }
417
418 if (mask & PEERS_EV_CTRLMSG) {
419 if (a2) {
420 const unsigned char *ctrl_msg_type = a2;
421
422 chunk_appendf(&trace_buf, " %s", ctrl_msg_type_str(*ctrl_msg_type));
423
424 }
425 if (a3) {
426 const char *local_peer = a3;
427
428 chunk_appendf(&trace_buf, " %s", local_peer);
429 }
430
431 if (a4) {
432 const char *remote_peer = a4;
433
434 chunk_appendf(&trace_buf, " -> %s", remote_peer);
435 }
436 }
437
438 if (mask & (PEERS_EV_SESSREL|PEERS_EV_PROTOERR)) {
439 if (a2) {
440 const struct peer *peer = a2;
441 struct peers *peers = NULL;
442
Frédéric Lécaille4b1a05f2021-01-17 13:08:39 +0100443 if (peer && peer->appctx) {
Frédéric Lécailleda2b0842021-01-15 16:21:28 +0100444 struct stream_interface *si;
445
446 si = peer->appctx->owner;
447 if (si) {
448 struct stream *s = si_strm(si);
449
450 peers = strm_fe(s)->parent;
451 }
452 }
453
454 if (peers)
455 chunk_appendf(&trace_buf, " %s", peers->local->id);
456 if (peer)
457 chunk_appendf(&trace_buf, " -> %s", peer->id);
458 }
459
460 if (a3) {
461 const int *prev_state = a3;
462
463 chunk_appendf(&trace_buf, " prev_state=%d\n", *prev_state);
464 }
465 }
Frédéric Lécailled8659352020-11-10 16:18:03 +0100466}
467
Frédéric Lécaille95679dc2019-04-15 10:25:27 +0200468static const char *statuscode_str(int statuscode)
469{
470 switch (statuscode) {
471 case PEER_SESS_SC_CONNECTCODE:
472 return "CONN";
473 case PEER_SESS_SC_CONNECTEDCODE:
474 return "HSHK";
475 case PEER_SESS_SC_SUCCESSCODE:
476 return "ESTA";
477 case PEER_SESS_SC_TRYAGAIN:
478 return "RETR";
479 case PEER_SESS_SC_ERRPROTO:
480 return "PROT";
481 case PEER_SESS_SC_ERRVERSION:
482 return "VERS";
483 case PEER_SESS_SC_ERRHOST:
484 return "NAME";
485 case PEER_SESS_SC_ERRPEER:
486 return "UNKN";
487 default:
488 return "NONE";
489 }
490}
491
Emeric Brun18928af2017-03-29 16:32:53 +0200492/* This function encode an uint64 to 'dynamic' length format.
493 The encoded value is written at address *str, and the
Ilya Shipitsinc02a23f2020-05-06 00:53:22 +0500494 caller must assure that size after *str is large enough.
Emeric Brun18928af2017-03-29 16:32:53 +0200495 At return, the *str is set at the next Byte after then
496 encoded integer. The function returns then length of the
497 encoded integer in Bytes */
Emeric Brunb3971ab2015-05-12 18:49:09 +0200498int intencode(uint64_t i, char **str) {
499 int idx = 0;
500 unsigned char *msg;
501
Emeric Brunb3971ab2015-05-12 18:49:09 +0200502 msg = (unsigned char *)*str;
Frédéric Lécaille32b55732019-06-03 18:29:51 +0200503 if (i < PEER_ENC_2BYTES_MIN) {
Emeric Brunb3971ab2015-05-12 18:49:09 +0200504 msg[0] = (unsigned char)i;
505 *str = (char *)&msg[idx+1];
506 return (idx+1);
507 }
508
Frédéric Lécaille32b55732019-06-03 18:29:51 +0200509 msg[idx] =(unsigned char)i | PEER_ENC_2BYTES_MIN;
510 i = (i - PEER_ENC_2BYTES_MIN) >> PEER_ENC_2BYTES_MIN_BITS;
511 while (i >= PEER_ENC_STOP_BYTE) {
512 msg[++idx] = (unsigned char)i | PEER_ENC_STOP_BYTE;
513 i = (i - PEER_ENC_STOP_BYTE) >> PEER_ENC_STOP_BIT;
Emeric Brunb3971ab2015-05-12 18:49:09 +0200514 }
515 msg[++idx] = (unsigned char)i;
516 *str = (char *)&msg[idx+1];
517 return (idx+1);
518}
519
520
521/* This function returns the decoded integer or 0
522 if decode failed
523 *str point on the beginning of the integer to decode
524 at the end of decoding *str point on the end of the
525 encoded integer or to null if end is reached */
Emeric Brun18928af2017-03-29 16:32:53 +0200526uint64_t intdecode(char **str, char *end)
527{
Emeric Brunb3971ab2015-05-12 18:49:09 +0200528 unsigned char *msg;
Emeric Brun18928af2017-03-29 16:32:53 +0200529 uint64_t i;
530 int shift;
Emeric Brunb3971ab2015-05-12 18:49:09 +0200531
532 if (!*str)
533 return 0;
534
535 msg = (unsigned char *)*str;
Emeric Brun18928af2017-03-29 16:32:53 +0200536 if (msg >= (unsigned char *)end)
537 goto fail;
Emeric Brunb3971ab2015-05-12 18:49:09 +0200538
Emeric Brun18928af2017-03-29 16:32:53 +0200539 i = *(msg++);
Frédéric Lécaille32b55732019-06-03 18:29:51 +0200540 if (i >= PEER_ENC_2BYTES_MIN) {
541 shift = PEER_ENC_2BYTES_MIN_BITS;
Emeric Brun18928af2017-03-29 16:32:53 +0200542 do {
543 if (msg >= (unsigned char *)end)
544 goto fail;
545 i += (uint64_t)*msg << shift;
Frédéric Lécaille32b55732019-06-03 18:29:51 +0200546 shift += PEER_ENC_STOP_BIT;
547 } while (*(msg++) >= PEER_ENC_STOP_BYTE);
Emeric Brunb3971ab2015-05-12 18:49:09 +0200548 }
Frédéric Lécaillea8725ec2019-01-22 10:31:39 +0100549 *str = (char *)msg;
550 return i;
Emeric Brun18928af2017-03-29 16:32:53 +0200551
Frédéric Lécaillea8725ec2019-01-22 10:31:39 +0100552 fail:
553 *str = NULL;
554 return 0;
Emeric Brunb3971ab2015-05-12 18:49:09 +0200555}
Emeric Brun2b920a12010-09-23 18:30:22 +0200556
Frédéric Lécaille7d0ceee2019-01-24 14:24:05 +0100557/*
558 * Build a "hello" peer protocol message.
559 * Return the number of written bytes written to build this messages if succeeded,
560 * 0 if not.
561 */
562static int peer_prepare_hellomsg(char *msg, size_t size, struct peer_prep_params *p)
563{
564 int min_ver, ret;
565 struct peer *peer;
566
567 peer = p->hello.peer;
568 min_ver = (peer->flags & PEER_F_DWNGRD) ? PEER_DWNGRD_MINOR_VER : PEER_MINOR_VER;
569 /* Prepare headers */
570 ret = snprintf(msg, size, PEER_SESSION_PROTO_NAME " %u.%u\n%s\n%s %d %d\n",
571 PEER_MAJOR_VER, min_ver, peer->id, localpeer, (int)getpid(), relative_pid);
572 if (ret >= size)
573 return 0;
574
575 return ret;
576}
577
578/*
579 * Build a "handshake succeeded" status message.
580 * Return the number of written bytes written to build this messages if succeeded,
581 * 0 if not.
582 */
583static int peer_prepare_status_successmsg(char *msg, size_t size, struct peer_prep_params *p)
584{
585 int ret;
586
587 ret = snprintf(msg, size, "%d\n", PEER_SESS_SC_SUCCESSCODE);
588 if (ret >= size)
589 return 0;
590
591 return ret;
592}
593
594/*
595 * Build an error status message.
596 * Return the number of written bytes written to build this messages if succeeded,
597 * 0 if not.
598 */
599static int peer_prepare_status_errormsg(char *msg, size_t size, struct peer_prep_params *p)
600{
601 int ret;
602 unsigned int st1;
603
604 st1 = p->error_status.st1;
605 ret = snprintf(msg, size, "%d\n", st1);
606 if (ret >= size)
607 return 0;
608
609 return ret;
610}
611
Frédéric Lécaille523cc9e2016-10-12 17:30:30 +0200612/* Set the stick-table UPDATE message type byte at <msg_type> address,
613 * depending on <use_identifier> and <use_timed> boolean parameters.
614 * Always successful.
615 */
616static inline void peer_set_update_msg_type(char *msg_type, int use_identifier, int use_timed)
617{
618 if (use_timed) {
619 if (use_identifier)
620 *msg_type = PEER_MSG_STKT_UPDATE_TIMED;
621 else
622 *msg_type = PEER_MSG_STKT_INCUPDATE_TIMED;
623 }
624 else {
625 if (use_identifier)
626 *msg_type = PEER_MSG_STKT_UPDATE;
627 else
628 *msg_type = PEER_MSG_STKT_INCUPDATE;
629 }
Frédéric Lécaille523cc9e2016-10-12 17:30:30 +0200630}
Emeric Brun2b920a12010-09-23 18:30:22 +0200631/*
Emeric Brunb3971ab2015-05-12 18:49:09 +0200632 * This prepare the data update message on the stick session <ts>, <st> is the considered
633 * stick table.
Joseph Herlant82b2f542018-11-15 12:19:14 -0800634 * <msg> is a buffer of <size> to receive data message content
Emeric Brunb3971ab2015-05-12 18:49:09 +0200635 * If function returns 0, the caller should consider we were unable to encode this message (TODO:
636 * check size)
Emeric Brun2b920a12010-09-23 18:30:22 +0200637 */
Frédéric Lécailled5fe14b2019-01-24 10:33:40 +0100638static int peer_prepare_updatemsg(char *msg, size_t size, struct peer_prep_params *p)
Emeric Brun2b920a12010-09-23 18:30:22 +0200639{
640 uint32_t netinteger;
Emeric Brunb3971ab2015-05-12 18:49:09 +0200641 unsigned short datalen;
642 char *cursor, *datamsg;
Emeric Brun94900952015-06-11 18:25:54 +0200643 unsigned int data_type;
644 void *data_ptr;
Frédéric Lécailled5fe14b2019-01-24 10:33:40 +0100645 struct stksess *ts;
646 struct shared_table *st;
647 unsigned int updateid;
648 int use_identifier;
649 int use_timed;
Frédéric Lécaille8d78fa72019-05-20 18:22:52 +0200650 struct peer *peer;
Frédéric Lécailled5fe14b2019-01-24 10:33:40 +0100651
652 ts = p->updt.stksess;
653 st = p->updt.shared_table;
654 updateid = p->updt.updateid;
655 use_identifier = p->updt.use_identifier;
656 use_timed = p->updt.use_timed;
Frédéric Lécaille8d78fa72019-05-20 18:22:52 +0200657 peer = p->updt.peer;
Emeric Brunb3971ab2015-05-12 18:49:09 +0200658
Frédéric Lécaille0e8db972019-05-24 14:34:34 +0200659 cursor = datamsg = msg + PEER_MSG_HEADER_LEN + PEER_MSG_ENC_LENGTH_MAXLEN;
Emeric Brunb3971ab2015-05-12 18:49:09 +0200660
Emeric Brun2b920a12010-09-23 18:30:22 +0200661 /* construct message */
Emeric Brunb3971ab2015-05-12 18:49:09 +0200662
Ilya Shipitsinc02a23f2020-05-06 00:53:22 +0500663 /* check if we need to send the update identifier */
Emeric Brun819fc6f2017-06-13 19:37:32 +0200664 if (!st->last_pushed || updateid < st->last_pushed || ((updateid - st->last_pushed) != 1)) {
Emeric Bruna6a09982015-09-22 15:34:19 +0200665 use_identifier = 1;
Emeric Brun2b920a12010-09-23 18:30:22 +0200666 }
Emeric Brunb3971ab2015-05-12 18:49:09 +0200667
668 /* encode update identifier if needed */
669 if (use_identifier) {
Emeric Brun819fc6f2017-06-13 19:37:32 +0200670 netinteger = htonl(updateid);
Emeric Brunb3971ab2015-05-12 18:49:09 +0200671 memcpy(cursor, &netinteger, sizeof(netinteger));
672 cursor += sizeof(netinteger);
Emeric Brun2b920a12010-09-23 18:30:22 +0200673 }
674
Frédéric Lécaille523cc9e2016-10-12 17:30:30 +0200675 if (use_timed) {
676 netinteger = htonl(tick_remain(now_ms, ts->expire));
677 memcpy(cursor, &netinteger, sizeof(netinteger));
678 cursor += sizeof(netinteger);
679 }
680
Emeric Brunb3971ab2015-05-12 18:49:09 +0200681 /* encode the key */
Thierry FOURNIER5d24ebc2015-07-24 08:46:42 +0200682 if (st->table->type == SMP_T_STR) {
Emeric Brun2b920a12010-09-23 18:30:22 +0200683 int stlen = strlen((char *)ts->key.key);
684
Emeric Brunb3971ab2015-05-12 18:49:09 +0200685 intencode(stlen, &cursor);
686 memcpy(cursor, ts->key.key, stlen);
687 cursor += stlen;
Emeric Brun2b920a12010-09-23 18:30:22 +0200688 }
Thierry FOURNIER5d24ebc2015-07-24 08:46:42 +0200689 else if (st->table->type == SMP_T_SINT) {
Willy Tarreau6cde5d82020-02-25 09:41:22 +0100690 netinteger = htonl(read_u32(ts->key.key));
Emeric Brunb3971ab2015-05-12 18:49:09 +0200691 memcpy(cursor, &netinteger, sizeof(netinteger));
692 cursor += sizeof(netinteger);
Emeric Brun2b920a12010-09-23 18:30:22 +0200693 }
694 else {
Emeric Brunb3971ab2015-05-12 18:49:09 +0200695 memcpy(cursor, ts->key.key, st->table->key_size);
696 cursor += st->table->key_size;
Emeric Brun2b920a12010-09-23 18:30:22 +0200697 }
698
Christopher Faulet2a944ee2017-11-07 10:42:54 +0100699 HA_RWLOCK_RDLOCK(STK_SESS_LOCK, &ts->lock);
Emeric Brunb3971ab2015-05-12 18:49:09 +0200700 /* encode values */
Emeric Brun94900952015-06-11 18:25:54 +0200701 for (data_type = 0 ; data_type < STKTABLE_DATA_TYPES ; data_type++) {
Emeric Brunb3971ab2015-05-12 18:49:09 +0200702
Emeric Brun94900952015-06-11 18:25:54 +0200703 data_ptr = stktable_data_ptr(st->table, ts, data_type);
704 if (data_ptr) {
705 switch (stktable_data_types[data_type].std_type) {
706 case STD_T_SINT: {
707 int data;
708
709 data = stktable_data_cast(data_ptr, std_t_sint);
710 intencode(data, &cursor);
711 break;
712 }
713 case STD_T_UINT: {
714 unsigned int data;
715
716 data = stktable_data_cast(data_ptr, std_t_uint);
717 intencode(data, &cursor);
718 break;
719 }
720 case STD_T_ULL: {
721 unsigned long long data;
722
723 data = stktable_data_cast(data_ptr, std_t_ull);
724 intencode(data, &cursor);
725 break;
726 }
727 case STD_T_FRQP: {
Willy Tarreaufa1258f2021-04-10 23:00:53 +0200728 struct freq_ctr *frqp;
Emeric Brun94900952015-06-11 18:25:54 +0200729
730 frqp = &stktable_data_cast(data_ptr, std_t_frqp);
731 intencode((unsigned int)(now_ms - frqp->curr_tick), &cursor);
732 intencode(frqp->curr_ctr, &cursor);
733 intencode(frqp->prev_ctr, &cursor);
734 break;
735 }
Frédéric Lécaille8d78fa72019-05-20 18:22:52 +0200736 case STD_T_DICT: {
737 struct dict_entry *de;
Frédéric Lécaille6c391982019-06-06 11:34:03 +0200738 struct ebpt_node *cached_de;
Willy Tarreau237f8ae2019-06-06 16:40:43 +0200739 struct dcache_tx_entry cde = { };
Frédéric Lécaille8d78fa72019-05-20 18:22:52 +0200740 char *beg, *end;
741 size_t value_len, data_len;
742 struct dcache *dc;
743
744 de = stktable_data_cast(data_ptr, std_t_dict);
Frédéric Lécailleaf9990f2019-11-13 17:50:34 +0100745 if (!de) {
746 /* No entry */
747 intencode(0, &cursor);
Frédéric Lécaille8d78fa72019-05-20 18:22:52 +0200748 break;
Frédéric Lécailleaf9990f2019-11-13 17:50:34 +0100749 }
Frédéric Lécaille8d78fa72019-05-20 18:22:52 +0200750
751 dc = peer->dcache;
Frédéric Lécaille6c391982019-06-06 11:34:03 +0200752 cde.entry.key = de;
Frédéric Lécaille8d78fa72019-05-20 18:22:52 +0200753 cached_de = dcache_tx_insert(dc, &cde);
Frédéric Lécaillefd827932019-06-07 10:34:04 +0200754 if (cached_de == &cde.entry) {
755 if (cde.id + 1 >= PEER_ENC_2BYTES_MIN)
756 break;
757 /* Encode the length of the remaining data -> 1 */
758 intencode(1, &cursor);
759 /* Encode the cache entry ID */
760 intencode(cde.id + 1, &cursor);
761 }
762 else {
763 /* Leave enough room to encode the remaining data length. */
764 end = beg = cursor + PEER_MSG_ENC_LENGTH_MAXLEN;
765 /* Encode the dictionary entry key */
766 intencode(cde.id + 1, &end);
Frédéric Lécaille8d78fa72019-05-20 18:22:52 +0200767 /* Encode the length of the dictionary entry data */
Frédéric Lécaillefd827932019-06-07 10:34:04 +0200768 value_len = de->len;
Frédéric Lécaille8d78fa72019-05-20 18:22:52 +0200769 intencode(value_len, &end);
770 /* Copy the data */
771 memcpy(end, de->value.key, value_len);
772 end += value_len;
Frédéric Lécaillefd827932019-06-07 10:34:04 +0200773 /* Encode the length of the data */
774 data_len = end - beg;
775 intencode(data_len, &cursor);
776 memmove(cursor, beg, data_len);
777 cursor += data_len;
Frédéric Lécaille8d78fa72019-05-20 18:22:52 +0200778 }
Frédéric Lécaille8d78fa72019-05-20 18:22:52 +0200779 break;
780 }
Emeric Brun94900952015-06-11 18:25:54 +0200781 }
782 }
Emeric Brunb3971ab2015-05-12 18:49:09 +0200783 }
Christopher Faulet2a944ee2017-11-07 10:42:54 +0100784 HA_RWLOCK_RDUNLOCK(STK_SESS_LOCK, &ts->lock);
Emeric Brunb3971ab2015-05-12 18:49:09 +0200785
786 /* Compute datalen */
787 datalen = (cursor - datamsg);
788
789 /* prepare message header */
790 msg[0] = PEER_MSG_CLASS_STICKTABLE;
Frédéric Lécaille523cc9e2016-10-12 17:30:30 +0200791 peer_set_update_msg_type(&msg[1], use_identifier, use_timed);
Emeric Brunb3971ab2015-05-12 18:49:09 +0200792 cursor = &msg[2];
793 intencode(datalen, &cursor);
794
795 /* move data after header */
796 memmove(cursor, datamsg, datalen);
797
798 /* return header size + data_len */
799 return (cursor - msg) + datalen;
800}
801
802/*
803 * This prepare the switch table message to targeted share table <st>.
Joseph Herlant82b2f542018-11-15 12:19:14 -0800804 * <msg> is a buffer of <size> to receive data message content
Emeric Brunb3971ab2015-05-12 18:49:09 +0200805 * If function returns 0, the caller should consider we were unable to encode this message (TODO:
806 * check size)
807 */
Frédéric Lécailled5fe14b2019-01-24 10:33:40 +0100808static int peer_prepare_switchmsg(char *msg, size_t size, struct peer_prep_params *params)
Emeric Brunb3971ab2015-05-12 18:49:09 +0200809{
810 int len;
811 unsigned short datalen;
Willy Tarreau83061a82018-07-13 11:56:34 +0200812 struct buffer *chunk;
Frédéric Lécaille37a72542017-07-06 15:02:16 +0200813 char *cursor, *datamsg, *chunkp, *chunkq;
Emeric Brunb3971ab2015-05-12 18:49:09 +0200814 uint64_t data = 0;
Emeric Brun94900952015-06-11 18:25:54 +0200815 unsigned int data_type;
Frédéric Lécailled5fe14b2019-01-24 10:33:40 +0100816 struct shared_table *st;
Emeric Brunb3971ab2015-05-12 18:49:09 +0200817
Frédéric Lécailled5fe14b2019-01-24 10:33:40 +0100818 st = params->swtch.shared_table;
Frédéric Lécaille39143342019-05-24 14:32:27 +0200819 cursor = datamsg = msg + PEER_MSG_HEADER_LEN + PEER_MSG_ENC_LENGTH_MAXLEN;
Emeric Brunb3971ab2015-05-12 18:49:09 +0200820
821 /* Encode data */
822
823 /* encode local id */
824 intencode(st->local_id, &cursor);
825
826 /* encode table name */
Frédéric Lécaille7fcc24d2019-03-20 15:09:45 +0100827 len = strlen(st->table->nid);
Emeric Brunb3971ab2015-05-12 18:49:09 +0200828 intencode(len, &cursor);
Frédéric Lécaille7fcc24d2019-03-20 15:09:45 +0100829 memcpy(cursor, st->table->nid, len);
Emeric Brunb3971ab2015-05-12 18:49:09 +0200830 cursor += len;
831
832 /* encode table type */
833
Emeric Brun530ba382020-06-02 11:17:42 +0200834 intencode(peer_net_key_type[st->table->type], &cursor);
Emeric Brunb3971ab2015-05-12 18:49:09 +0200835
836 /* encode table key size */
837 intencode(st->table->key_size, &cursor);
838
Frédéric Lécaille37a72542017-07-06 15:02:16 +0200839 chunk = get_trash_chunk();
Willy Tarreau843b7cb2018-07-13 10:54:26 +0200840 chunkp = chunkq = chunk->area;
Emeric Brun94900952015-06-11 18:25:54 +0200841 /* encode available known data types in table */
842 for (data_type = 0 ; data_type < STKTABLE_DATA_TYPES ; data_type++) {
843 if (st->table->data_ofs[data_type]) {
844 switch (stktable_data_types[data_type].std_type) {
845 case STD_T_SINT:
846 case STD_T_UINT:
847 case STD_T_ULL:
Frédéric Lécaille8d78fa72019-05-20 18:22:52 +0200848 case STD_T_DICT:
Emeric Brun45f12b02021-07-01 18:54:05 +0200849 data |= 1ULL << data_type;
Frédéric Lécaille37a72542017-07-06 15:02:16 +0200850 break;
Emeric Brun94900952015-06-11 18:25:54 +0200851 case STD_T_FRQP:
Emeric Brun45f12b02021-07-01 18:54:05 +0200852 data |= 1ULL << data_type;
Frédéric Lécaille37a72542017-07-06 15:02:16 +0200853 intencode(data_type, &chunkq);
854 intencode(st->table->data_arg[data_type].u, &chunkq);
Emeric Brun94900952015-06-11 18:25:54 +0200855 break;
856 }
857 }
Emeric Brunb3971ab2015-05-12 18:49:09 +0200858 }
859 intencode(data, &cursor);
860
Frédéric Lécaille37a72542017-07-06 15:02:16 +0200861 /* Encode stick-table entries duration. */
862 intencode(st->table->expire, &cursor);
863
864 if (chunkq > chunkp) {
Willy Tarreau843b7cb2018-07-13 10:54:26 +0200865 chunk->data = chunkq - chunkp;
866 memcpy(cursor, chunk->area, chunk->data);
867 cursor += chunk->data;
Frédéric Lécaille37a72542017-07-06 15:02:16 +0200868 }
869
Emeric Brunb3971ab2015-05-12 18:49:09 +0200870 /* Compute datalen */
871 datalen = (cursor - datamsg);
Emeric Brun2b920a12010-09-23 18:30:22 +0200872
Emeric Brunb3971ab2015-05-12 18:49:09 +0200873 /* prepare message header */
874 msg[0] = PEER_MSG_CLASS_STICKTABLE;
875 msg[1] = PEER_MSG_STKT_DEFINE;
876 cursor = &msg[2];
877 intencode(datalen, &cursor);
Emeric Brun2b920a12010-09-23 18:30:22 +0200878
Emeric Brunb3971ab2015-05-12 18:49:09 +0200879 /* move data after header */
880 memmove(cursor, datamsg, datalen);
881
882 /* return header size + data_len */
883 return (cursor - msg) + datalen;
Emeric Brun2b920a12010-09-23 18:30:22 +0200884}
885
Emeric Brunb3971ab2015-05-12 18:49:09 +0200886/*
887 * This prepare the acknowledge message on the stick session <ts>, <st> is the considered
888 * stick table.
Joseph Herlant82b2f542018-11-15 12:19:14 -0800889 * <msg> is a buffer of <size> to receive data message content
Emeric Brunb3971ab2015-05-12 18:49:09 +0200890 * If function returns 0, the caller should consider we were unable to encode this message (TODO:
891 * check size)
892 */
Frédéric Lécailled5fe14b2019-01-24 10:33:40 +0100893static int peer_prepare_ackmsg(char *msg, size_t size, struct peer_prep_params *p)
Emeric Brunb3971ab2015-05-12 18:49:09 +0200894{
895 unsigned short datalen;
896 char *cursor, *datamsg;
897 uint32_t netinteger;
Frédéric Lécailled5fe14b2019-01-24 10:33:40 +0100898 struct shared_table *st;
Emeric Brunb3971ab2015-05-12 18:49:09 +0200899
Frédéric Lécaille39143342019-05-24 14:32:27 +0200900 cursor = datamsg = msg + PEER_MSG_HEADER_LEN + PEER_MSG_ENC_LENGTH_MAXLEN;
Emeric Brunb3971ab2015-05-12 18:49:09 +0200901
Frédéric Lécailled5fe14b2019-01-24 10:33:40 +0100902 st = p->ack.shared_table;
Emeric Brunb3971ab2015-05-12 18:49:09 +0200903 intencode(st->remote_id, &cursor);
904 netinteger = htonl(st->last_get);
905 memcpy(cursor, &netinteger, sizeof(netinteger));
906 cursor += sizeof(netinteger);
907
908 /* Compute datalen */
909 datalen = (cursor - datamsg);
910
911 /* prepare message header */
912 msg[0] = PEER_MSG_CLASS_STICKTABLE;
Emeric Brune1ab8082015-08-21 11:48:54 +0200913 msg[1] = PEER_MSG_STKT_ACK;
Emeric Brunb3971ab2015-05-12 18:49:09 +0200914 cursor = &msg[2];
915 intencode(datalen, &cursor);
916
917 /* move data after header */
918 memmove(cursor, datamsg, datalen);
919
920 /* return header size + data_len */
921 return (cursor - msg) + datalen;
922}
Emeric Brun2b920a12010-09-23 18:30:22 +0200923
924/*
Emeric Brun9ef2ad72019-04-02 17:22:01 +0200925 * Function to deinit connected peer
926 */
927void __peer_session_deinit(struct peer *peer)
928{
929 struct stream_interface *si;
930 struct stream *s;
931 struct peers *peers;
932
933 if (!peer->appctx)
934 return;
935
936 si = peer->appctx->owner;
937 if (!si)
938 return;
939
940 s = si_strm(si);
941 if (!s)
942 return;
943
944 peers = strm_fe(s)->parent;
945 if (!peers)
946 return;
947
948 if (peer->appctx->st0 == PEER_SESS_ST_WAITMSG)
Willy Tarreau4781b152021-04-06 13:53:36 +0200949 HA_ATOMIC_DEC(&connected_peers);
Emeric Brun9ef2ad72019-04-02 17:22:01 +0200950
Willy Tarreau4781b152021-04-06 13:53:36 +0200951 HA_ATOMIC_DEC(&active_peers);
Emeric Brun9ef2ad72019-04-02 17:22:01 +0200952
Frédéric Lécaille8d78fa72019-05-20 18:22:52 +0200953 flush_dcache(peer);
954
Emeric Brun9ef2ad72019-04-02 17:22:01 +0200955 /* Re-init current table pointers to force announcement on re-connect */
956 peer->remote_table = peer->last_local_table = NULL;
957 peer->appctx = NULL;
958 if (peer->flags & PEER_F_LEARN_ASSIGN) {
959 /* unassign current peer for learning */
960 peer->flags &= ~(PEER_F_LEARN_ASSIGN);
961 peers->flags &= ~(PEERS_F_RESYNC_ASSIGN|PEERS_F_RESYNC_PROCESS);
962
Emeric Brunccdfbae2021-04-28 12:59:35 +0200963 if (peer->local)
964 peers->flags |= PEERS_F_RESYNC_LOCALABORT;
965 else
966 peers->flags |= PEERS_F_RESYNC_REMOTEABORT;
Emeric Brun9ef2ad72019-04-02 17:22:01 +0200967 /* reschedule a resync */
968 peers->resync_timeout = tick_add(now_ms, MS_TO_TICKS(5000));
969 }
970 /* reset teaching and learning flags to 0 */
971 peer->flags &= PEER_TEACH_RESET;
972 peer->flags &= PEER_LEARN_RESET;
973 task_wakeup(peers->sync_task, TASK_WOKEN_MSG);
974}
975
976/*
Emeric Brun2b920a12010-09-23 18:30:22 +0200977 * Callback to release a session with a peer
978 */
Willy Tarreau00a37f02015-04-13 12:05:19 +0200979static void peer_session_release(struct appctx *appctx)
Emeric Brun2b920a12010-09-23 18:30:22 +0200980{
Vincent Bernat3c2f2f22016-04-03 13:48:42 +0200981 struct peer *peer = appctx->ctx.peers.ptr;
Emeric Brun2b920a12010-09-23 18:30:22 +0200982
Frédéric Lécailleda2b0842021-01-15 16:21:28 +0100983 TRACE_PROTO("releasing peer session", PEERS_EV_SESSREL, NULL, peer);
Willy Tarreau7b4b4992013-12-01 09:15:12 +0100984 /* appctx->ctx.peers.ptr is not a peer session */
Willy Tarreaue4d927a2013-12-01 12:47:35 +0100985 if (appctx->st0 < PEER_SESS_ST_SENDSUCCESS)
Emeric Brun2b920a12010-09-23 18:30:22 +0200986 return;
987
988 /* peer session identified */
Emeric Brunb3971ab2015-05-12 18:49:09 +0200989 if (peer) {
Christopher Faulet2a944ee2017-11-07 10:42:54 +0100990 HA_SPIN_LOCK(PEER_LOCK, &peer->lock);
Emeric Brun9ef2ad72019-04-02 17:22:01 +0200991 if (peer->appctx == appctx)
992 __peer_session_deinit(peer);
Frédéric Lécaillebaeb9192020-10-14 11:50:26 +0200993 peer->flags &= ~PEER_F_ALIVE;
Christopher Faulet2a944ee2017-11-07 10:42:54 +0100994 HA_SPIN_UNLOCK(PEER_LOCK, &peer->lock);
Emeric Brun2b920a12010-09-23 18:30:22 +0200995 }
996}
997
Frédéric Lécaille523cc9e2016-10-12 17:30:30 +0200998/* Retrieve the major and minor versions of peers protocol
999 * announced by a remote peer. <str> is a null-terminated
1000 * string with the following format: "<maj_ver>.<min_ver>".
1001 */
1002static int peer_get_version(const char *str,
1003 unsigned int *maj_ver, unsigned int *min_ver)
1004{
1005 unsigned int majv, minv;
1006 const char *pos, *saved;
1007 const char *end;
1008
1009 saved = pos = str;
1010 end = str + strlen(str);
1011
1012 majv = read_uint(&pos, end);
1013 if (saved == pos || *pos++ != '.')
1014 return -1;
1015
1016 saved = pos;
1017 minv = read_uint(&pos, end);
1018 if (saved == pos || pos != end)
1019 return -1;
1020
1021 *maj_ver = majv;
1022 *min_ver = minv;
1023
1024 return 0;
1025}
Emeric Brun2b920a12010-09-23 18:30:22 +02001026
1027/*
Frédéric Lécaillece025572019-01-21 13:38:06 +01001028 * Parse a line terminated by an optional '\r' character, followed by a mandatory
1029 * '\n' character.
1030 * Returns 1 if succeeded or 0 if a '\n' character could not be found, and -1 if
1031 * a line could not be read because the communication channel is closed.
1032 */
1033static inline int peer_getline(struct appctx *appctx)
1034{
1035 int n;
1036 struct stream_interface *si = appctx->owner;
1037
1038 n = co_getline(si_oc(si), trash.area, trash.size);
1039 if (!n)
1040 return 0;
1041
1042 if (n < 0 || trash.area[n - 1] != '\n') {
1043 appctx->st0 = PEER_SESS_ST_END;
1044 return -1;
1045 }
1046
1047 if (n > 1 && (trash.area[n - 2] == '\r'))
1048 trash.area[n - 2] = 0;
1049 else
1050 trash.area[n - 1] = 0;
1051
1052 co_skip(si_oc(si), n);
1053
1054 return n;
1055}
1056
1057/*
Frédéric Lécailleec44ea82019-01-22 15:54:53 +01001058 * Send a message after having called <peer_prepare_msg> to build it.
1059 * Return 0 if the message could not be built modifying the appcxt st0 to PEER_SESS_ST_END value.
1060 * Returns -1 if there was not enough room left to send the message,
1061 * any other negative returned value must be considered as an error with an appcxt st0
1062 * returned value equal to PEER_SESS_ST_END.
1063 */
Frédéric Lécailled5fe14b2019-01-24 10:33:40 +01001064static inline int peer_send_msg(struct appctx *appctx,
1065 int (*peer_prepare_msg)(char *, size_t, struct peer_prep_params *),
1066 struct peer_prep_params *params)
Frédéric Lécailleec44ea82019-01-22 15:54:53 +01001067{
1068 int ret, msglen;
1069 struct stream_interface *si = appctx->owner;
1070
Frédéric Lécailled5fe14b2019-01-24 10:33:40 +01001071 msglen = peer_prepare_msg(trash.area, trash.size, params);
Frédéric Lécailleec44ea82019-01-22 15:54:53 +01001072 if (!msglen) {
1073 /* internal error: message does not fit in trash */
1074 appctx->st0 = PEER_SESS_ST_END;
1075 return 0;
1076 }
1077
1078 /* message to buffer */
1079 ret = ci_putblk(si_ic(si), trash.area, msglen);
1080 if (ret <= 0) {
1081 if (ret == -1) {
1082 /* No more write possible */
1083 si_rx_room_blk(si);
1084 return -1;
1085 }
1086 appctx->st0 = PEER_SESS_ST_END;
1087 }
1088
1089 return ret;
1090}
1091
1092/*
Frédéric Lécaille7d0ceee2019-01-24 14:24:05 +01001093 * Send a hello message.
1094 * Return 0 if the message could not be built modifying the appcxt st0 to PEER_SESS_ST_END value.
1095 * Returns -1 if there was not enough room left to send the message,
1096 * any other negative returned value must be considered as an error with an appcxt st0
1097 * returned value equal to PEER_SESS_ST_END.
1098 */
1099static inline int peer_send_hellomsg(struct appctx *appctx, struct peer *peer)
1100{
1101 struct peer_prep_params p = {
1102 .hello.peer = peer,
1103 };
1104
1105 return peer_send_msg(appctx, peer_prepare_hellomsg, &p);
1106}
1107
1108/*
1109 * Send a success peer handshake status message.
1110 * Return 0 if the message could not be built modifying the appcxt st0 to PEER_SESS_ST_END value.
1111 * Returns -1 if there was not enough room left to send the message,
1112 * any other negative returned value must be considered as an error with an appcxt st0
1113 * returned value equal to PEER_SESS_ST_END.
1114 */
1115static inline int peer_send_status_successmsg(struct appctx *appctx)
1116{
1117 return peer_send_msg(appctx, peer_prepare_status_successmsg, NULL);
1118}
1119
1120/*
1121 * Send a peer handshake status error message.
1122 * Return 0 if the message could not be built modifying the appcxt st0 to PEER_SESS_ST_END value.
1123 * Returns -1 if there was not enough room left to send the message,
1124 * any other negative returned value must be considered as an error with an appcxt st0
1125 * returned value equal to PEER_SESS_ST_END.
1126 */
1127static inline int peer_send_status_errormsg(struct appctx *appctx)
1128{
1129 struct peer_prep_params p = {
1130 .error_status.st1 = appctx->st1,
1131 };
1132
1133 return peer_send_msg(appctx, peer_prepare_status_errormsg, &p);
1134}
1135
1136/*
Frédéric Lécailleec44ea82019-01-22 15:54:53 +01001137 * Send a stick-table switch message.
1138 * Return 0 if the message could not be built modifying the appcxt st0 to PEER_SESS_ST_END value.
1139 * Returns -1 if there was not enough room left to send the message,
1140 * any other negative returned value must be considered as an error with an appcxt st0
1141 * returned value equal to PEER_SESS_ST_END.
1142 */
1143static inline int peer_send_switchmsg(struct shared_table *st, struct appctx *appctx)
1144{
Frédéric Lécailled5fe14b2019-01-24 10:33:40 +01001145 struct peer_prep_params p = {
1146 .swtch.shared_table = st,
1147 };
1148
1149 return peer_send_msg(appctx, peer_prepare_switchmsg, &p);
Frédéric Lécailleec44ea82019-01-22 15:54:53 +01001150}
1151
1152/*
1153 * Send a stick-table update acknowledgement message.
1154 * Return 0 if the message could not be built modifying the appcxt st0 to PEER_SESS_ST_END value.
1155 * Returns -1 if there was not enough room left to send the message,
1156 * any other negative returned value must be considered as an error with an appcxt st0
1157 * returned value equal to PEER_SESS_ST_END.
1158 */
1159static inline int peer_send_ackmsg(struct shared_table *st, struct appctx *appctx)
1160{
Frédéric Lécailled5fe14b2019-01-24 10:33:40 +01001161 struct peer_prep_params p = {
1162 .ack.shared_table = st,
1163 };
1164
1165 return peer_send_msg(appctx, peer_prepare_ackmsg, &p);
Frédéric Lécailleec44ea82019-01-22 15:54:53 +01001166}
1167
1168/*
Frédéric Lécaille87f554c2019-01-22 17:26:50 +01001169 * Send a stick-table update message.
1170 * Return 0 if the message could not be built modifying the appcxt st0 to PEER_SESS_ST_END value.
1171 * Returns -1 if there was not enough room left to send the message,
1172 * any other negative returned value must be considered as an error with an appcxt st0
1173 * returned value equal to PEER_SESS_ST_END.
1174 */
1175static inline int peer_send_updatemsg(struct shared_table *st, struct appctx *appctx, struct stksess *ts,
1176 unsigned int updateid, int use_identifier, int use_timed)
1177{
Frédéric Lécailled5fe14b2019-01-24 10:33:40 +01001178 struct peer_prep_params p = {
Willy Tarreaua898f0c2020-07-03 19:09:29 +02001179 .updt = {
1180 .stksess = ts,
1181 .shared_table = st,
1182 .updateid = updateid,
1183 .use_identifier = use_identifier,
1184 .use_timed = use_timed,
1185 .peer = appctx->ctx.peers.ptr,
1186 },
Frédéric Lécailled5fe14b2019-01-24 10:33:40 +01001187 };
1188
1189 return peer_send_msg(appctx, peer_prepare_updatemsg, &p);
Frédéric Lécaille87f554c2019-01-22 17:26:50 +01001190}
1191
Frédéric Lécaille7d0ceee2019-01-24 14:24:05 +01001192/*
1193 * Build a peer protocol control class message.
1194 * Returns the number of written bytes used to build the message if succeeded,
1195 * 0 if not.
1196 */
1197static int peer_prepare_control_msg(char *msg, size_t size, struct peer_prep_params *p)
1198{
1199 if (size < sizeof p->control.head)
1200 return 0;
1201
1202 msg[0] = p->control.head[0];
1203 msg[1] = p->control.head[1];
1204
1205 return 2;
1206}
Frédéric Lécaille6a8303d2019-01-22 22:25:17 +01001207
1208/*
Frédéric Lécaille7d0ceee2019-01-24 14:24:05 +01001209 * Send a stick-table synchronization request message.
1210 * Return 0 if the message could not be built modifying the appcxt st0 to PEER_SESS_ST_END value.
1211 * Returns -1 if there was not enough room left to send the message,
1212 * any other negative returned value must be considered as an error with an appctx st0
1213 * returned value equal to PEER_SESS_ST_END.
1214 */
Frédéric Lécailleda2b0842021-01-15 16:21:28 +01001215static inline int peer_send_resync_reqmsg(struct appctx *appctx,
1216 struct peer *peer, struct peers *peers)
Frédéric Lécaille7d0ceee2019-01-24 14:24:05 +01001217{
1218 struct peer_prep_params p = {
1219 .control.head = { PEER_MSG_CLASS_CONTROL, PEER_MSG_CTRL_RESYNCREQ, },
1220 };
1221
Frédéric Lécailleda2b0842021-01-15 16:21:28 +01001222 TRACE_PROTO("send control message", PEERS_EV_CTRLMSG,
1223 NULL, &p.control.head[1], peers->local->id, peer->id);
1224
Frédéric Lécaille7d0ceee2019-01-24 14:24:05 +01001225 return peer_send_msg(appctx, peer_prepare_control_msg, &p);
1226}
1227
1228/*
1229 * Send a stick-table synchronization confirmation message.
1230 * Return 0 if the message could not be built modifying the appcxt st0 to PEER_SESS_ST_END value.
1231 * Returns -1 if there was not enough room left to send the message,
1232 * any other negative returned value must be considered as an error with an appctx st0
1233 * returned value equal to PEER_SESS_ST_END.
1234 */
Frédéric Lécailleda2b0842021-01-15 16:21:28 +01001235static inline int peer_send_resync_confirmsg(struct appctx *appctx,
1236 struct peer *peer, struct peers *peers)
Frédéric Lécaille7d0ceee2019-01-24 14:24:05 +01001237{
1238 struct peer_prep_params p = {
1239 .control.head = { PEER_MSG_CLASS_CONTROL, PEER_MSG_CTRL_RESYNCCONFIRM, },
1240 };
1241
Frédéric Lécailleda2b0842021-01-15 16:21:28 +01001242 TRACE_PROTO("send control message", PEERS_EV_CTRLMSG,
1243 NULL, &p.control.head[1], peers->local->id, peer->id);
1244
Frédéric Lécaille7d0ceee2019-01-24 14:24:05 +01001245 return peer_send_msg(appctx, peer_prepare_control_msg, &p);
1246}
1247
1248/*
1249 * Send a stick-table synchronization finished message.
1250 * Return 0 if the message could not be built modifying the appcxt st0 to PEER_SESS_ST_END value.
1251 * Returns -1 if there was not enough room left to send the message,
1252 * any other negative returned value must be considered as an error with an appctx st0
1253 * returned value equal to PEER_SESS_ST_END.
1254 */
Frédéric Lécailleda2b0842021-01-15 16:21:28 +01001255static inline int peer_send_resync_finishedmsg(struct appctx *appctx,
1256 struct peer *peer, struct peers *peers)
Frédéric Lécaille7d0ceee2019-01-24 14:24:05 +01001257{
1258 struct peer_prep_params p = {
1259 .control.head = { PEER_MSG_CLASS_CONTROL, },
1260 };
1261
Emeric Brun70de43b2020-03-16 10:51:01 +01001262 p.control.head[1] = (peers->flags & PEERS_RESYNC_STATEMASK) == PEERS_RESYNC_FINISHED ?
Frédéric Lécaille7d0ceee2019-01-24 14:24:05 +01001263 PEER_MSG_CTRL_RESYNCFINISHED : PEER_MSG_CTRL_RESYNCPARTIAL;
1264
Frédéric Lécailleda2b0842021-01-15 16:21:28 +01001265 TRACE_PROTO("send control message", PEERS_EV_CTRLMSG,
1266 NULL, &p.control.head[1], peers->local->id, peer->id);
1267
Frédéric Lécaille7d0ceee2019-01-24 14:24:05 +01001268 return peer_send_msg(appctx, peer_prepare_control_msg, &p);
1269}
1270
1271/*
Frédéric Lécaille645635d2019-02-11 17:49:39 +01001272 * Send a heartbeat message.
1273 * Return 0 if the message could not be built modifying the appctx st0 to PEER_SESS_ST_END value.
1274 * Returns -1 if there was not enough room left to send the message,
1275 * any other negative returned value must be considered as an error with an appctx st0
1276 * returned value equal to PEER_SESS_ST_END.
1277 */
Frédéric Lécailleda2b0842021-01-15 16:21:28 +01001278static inline int peer_send_heartbeatmsg(struct appctx *appctx,
1279 struct peer *peer, struct peers *peers)
Frédéric Lécaille645635d2019-02-11 17:49:39 +01001280{
1281 struct peer_prep_params p = {
1282 .control.head = { PEER_MSG_CLASS_CONTROL, PEER_MSG_CTRL_HEARTBEAT, },
1283 };
1284
Frédéric Lécailleda2b0842021-01-15 16:21:28 +01001285 TRACE_PROTO("send control message", PEERS_EV_CTRLMSG,
1286 NULL, &p.control.head[1], peers->local->id, peer->id);
1287
Frédéric Lécaille645635d2019-02-11 17:49:39 +01001288 return peer_send_msg(appctx, peer_prepare_control_msg, &p);
1289}
1290
1291/*
Frédéric Lécaille7d0ceee2019-01-24 14:24:05 +01001292 * Build a peer protocol error class message.
1293 * Returns the number of written bytes used to build the message if succeeded,
1294 * 0 if not.
1295 */
1296static int peer_prepare_error_msg(char *msg, size_t size, struct peer_prep_params *p)
1297{
1298 if (size < sizeof p->error.head)
1299 return 0;
1300
1301 msg[0] = p->error.head[0];
1302 msg[1] = p->error.head[1];
1303
1304 return 2;
1305}
1306
1307/*
1308 * Send a "size limit reached" error message.
1309 * Return 0 if the message could not be built modifying the appcxt st0 to PEER_SESS_ST_END value.
1310 * Returns -1 if there was not enough room left to send the message,
1311 * any other negative returned value must be considered as an error with an appctx st0
1312 * returned value equal to PEER_SESS_ST_END.
1313 */
1314static inline int peer_send_error_size_limitmsg(struct appctx *appctx)
1315{
1316 struct peer_prep_params p = {
1317 .error.head = { PEER_MSG_CLASS_ERROR, PEER_MSG_ERR_SIZELIMIT, },
1318 };
1319
1320 return peer_send_msg(appctx, peer_prepare_error_msg, &p);
1321}
1322
1323/*
1324 * Send a "peer protocol" error message.
1325 * Return 0 if the message could not be built modifying the appcxt st0 to PEER_SESS_ST_END value.
1326 * Returns -1 if there was not enough room left to send the message,
1327 * any other negative returned value must be considered as an error with an appctx st0
1328 * returned value equal to PEER_SESS_ST_END.
1329 */
1330static inline int peer_send_error_protomsg(struct appctx *appctx)
1331{
1332 struct peer_prep_params p = {
1333 .error.head = { PEER_MSG_CLASS_ERROR, PEER_MSG_ERR_PROTOCOL, },
1334 };
1335
1336 return peer_send_msg(appctx, peer_prepare_error_msg, &p);
1337}
1338
1339/*
Frédéric Lécaille6a8303d2019-01-22 22:25:17 +01001340 * Function used to lookup for recent stick-table updates associated with
1341 * <st> shared stick-table when a lesson must be taught a peer (PEER_F_LEARN_ASSIGN flag set).
1342 */
1343static inline struct stksess *peer_teach_process_stksess_lookup(struct shared_table *st)
1344{
1345 struct eb32_node *eb;
1346
1347 eb = eb32_lookup_ge(&st->table->updates, st->last_pushed+1);
1348 if (!eb) {
1349 eb = eb32_first(&st->table->updates);
Emeric Brun8e7a13e2021-04-28 11:48:15 +02001350 if (!eb || (eb->key == st->last_pushed)) {
Frédéric Lécaille6a8303d2019-01-22 22:25:17 +01001351 st->table->commitupdate = st->last_pushed = st->table->localupdate;
1352 return NULL;
1353 }
1354 }
1355
Emeric Brun8e7a13e2021-04-28 11:48:15 +02001356 /* if distance between the last pushed and the retrieved key
1357 * is greater than the distance last_pushed and the local_update
1358 * this means we are beyond localupdate.
1359 */
1360 if ((eb->key - st->last_pushed) > (st->table->localupdate - st->last_pushed)) {
Frédéric Lécaille6a8303d2019-01-22 22:25:17 +01001361 st->table->commitupdate = st->last_pushed = st->table->localupdate;
1362 return NULL;
1363 }
1364
1365 return eb32_entry(eb, struct stksess, upd);
1366}
1367
1368/*
1369 * Function used to lookup for recent stick-table updates associated with
1370 * <st> shared stick-table during teach state 1 step.
1371 */
1372static inline struct stksess *peer_teach_stage1_stksess_lookup(struct shared_table *st)
1373{
1374 struct eb32_node *eb;
1375
1376 eb = eb32_lookup_ge(&st->table->updates, st->last_pushed+1);
1377 if (!eb) {
1378 st->flags |= SHTABLE_F_TEACH_STAGE1;
1379 eb = eb32_first(&st->table->updates);
1380 if (eb)
1381 st->last_pushed = eb->key - 1;
1382 return NULL;
1383 }
1384
1385 return eb32_entry(eb, struct stksess, upd);
1386}
1387
1388/*
1389 * Function used to lookup for recent stick-table updates associated with
1390 * <st> shared stick-table during teach state 2 step.
1391 */
1392static inline struct stksess *peer_teach_stage2_stksess_lookup(struct shared_table *st)
1393{
1394 struct eb32_node *eb;
1395
1396 eb = eb32_lookup_ge(&st->table->updates, st->last_pushed+1);
1397 if (!eb || eb->key > st->teaching_origin) {
1398 st->flags |= SHTABLE_F_TEACH_STAGE2;
1399 return NULL;
1400 }
1401
1402 return eb32_entry(eb, struct stksess, upd);
1403}
1404
1405/*
1406 * Generic function to emit update messages for <st> stick-table when a lesson must
1407 * be taught to the peer <p>.
1408 * <locked> must be set to 1 if the shared table <st> is already locked when entering
1409 * this function, 0 if not.
1410 *
1411 * This function temporary unlock/lock <st> when it sends stick-table updates or
1412 * when decrementing its refcount in case of any error when it sends this updates.
1413 *
1414 * Return 0 if any message could not be built modifying the appcxt st0 to PEER_SESS_ST_END value.
1415 * Returns -1 if there was not enough room left to send the message,
1416 * any other negative returned value must be considered as an error with an appcxt st0
1417 * returned value equal to PEER_SESS_ST_END.
1418 * If it returns 0 or -1, this function leave <st> locked if already locked when entering this function
1419 * unlocked if not already locked when entering this function.
1420 */
1421static inline int peer_send_teachmsgs(struct appctx *appctx, struct peer *p,
1422 struct stksess *(*peer_stksess_lookup)(struct shared_table *),
1423 struct shared_table *st, int locked)
1424{
1425 int ret, new_pushed, use_timed;
1426
1427 ret = 1;
1428 use_timed = 0;
1429 if (st != p->last_local_table) {
1430 ret = peer_send_switchmsg(st, appctx);
1431 if (ret <= 0)
1432 return ret;
1433
1434 p->last_local_table = st;
1435 }
1436
1437 if (peer_stksess_lookup != peer_teach_process_stksess_lookup)
1438 use_timed = !(p->flags & PEER_F_DWNGRD);
1439
1440 /* We force new pushed to 1 to force identifier in update message */
1441 new_pushed = 1;
1442
1443 if (!locked)
1444 HA_SPIN_LOCK(STK_TABLE_LOCK, &st->table->lock);
1445
1446 while (1) {
1447 struct stksess *ts;
1448 unsigned updateid;
1449
1450 /* push local updates */
1451 ts = peer_stksess_lookup(st);
1452 if (!ts)
1453 break;
1454
1455 updateid = ts->upd.key;
1456 ts->ref_cnt++;
1457 HA_SPIN_UNLOCK(STK_TABLE_LOCK, &st->table->lock);
1458
1459 ret = peer_send_updatemsg(st, appctx, ts, updateid, new_pushed, use_timed);
1460 if (ret <= 0) {
1461 HA_SPIN_LOCK(STK_TABLE_LOCK, &st->table->lock);
1462 ts->ref_cnt--;
1463 if (!locked)
1464 HA_SPIN_UNLOCK(STK_TABLE_LOCK, &st->table->lock);
1465 return ret;
1466 }
1467
1468 HA_SPIN_LOCK(STK_TABLE_LOCK, &st->table->lock);
1469 ts->ref_cnt--;
1470 st->last_pushed = updateid;
1471
1472 if (peer_stksess_lookup == peer_teach_process_stksess_lookup &&
1473 (int)(st->last_pushed - st->table->commitupdate) > 0)
1474 st->table->commitupdate = st->last_pushed;
1475
1476 /* identifier may not needed in next update message */
1477 new_pushed = 0;
1478 }
1479
1480 out:
1481 if (!locked)
1482 HA_SPIN_UNLOCK(STK_TABLE_LOCK, &st->table->lock);
1483 return 1;
1484}
1485
1486/*
1487 * Function to emit update messages for <st> stick-table when a lesson must
1488 * be taught to the peer <p> (PEER_F_LEARN_ASSIGN flag set).
1489 *
1490 * Note that <st> shared stick-table is locked when calling this function.
1491 *
1492 * Return 0 if any message could not be built modifying the appcxt st0 to PEER_SESS_ST_END value.
1493 * Returns -1 if there was not enough room left to send the message,
1494 * any other negative returned value must be considered as an error with an appcxt st0
1495 * returned value equal to PEER_SESS_ST_END.
1496 */
1497static inline int peer_send_teach_process_msgs(struct appctx *appctx, struct peer *p,
1498 struct shared_table *st)
1499{
1500 return peer_send_teachmsgs(appctx, p, peer_teach_process_stksess_lookup, st, 1);
1501}
1502
1503/*
1504 * Function to emit update messages for <st> stick-table when a lesson must
1505 * be taught to the peer <p> during teach state 1 step.
1506 *
1507 * Return 0 if any message could not be built modifying the appcxt st0 to PEER_SESS_ST_END value.
1508 * Returns -1 if there was not enough room left to send the message,
1509 * any other negative returned value must be considered as an error with an appcxt st0
1510 * returned value equal to PEER_SESS_ST_END.
1511 */
1512static inline int peer_send_teach_stage1_msgs(struct appctx *appctx, struct peer *p,
1513 struct shared_table *st)
1514{
1515 return peer_send_teachmsgs(appctx, p, peer_teach_stage1_stksess_lookup, st, 0);
1516}
1517
1518/*
1519 * Function to emit update messages for <st> stick-table when a lesson must
1520 * be taught to the peer <p> during teach state 1 step.
1521 *
1522 * Return 0 if any message could not be built modifying the appcxt st0 to PEER_SESS_ST_END value.
1523 * Returns -1 if there was not enough room left to send the message,
1524 * any other negative returned value must be considered as an error with an appcxt st0
1525 * returned value equal to PEER_SESS_ST_END.
1526 */
1527static inline int peer_send_teach_stage2_msgs(struct appctx *appctx, struct peer *p,
1528 struct shared_table *st)
1529{
1530 return peer_send_teachmsgs(appctx, p, peer_teach_stage2_stksess_lookup, st, 0);
1531}
1532
Frédéric Lécaille168a34b2019-01-23 11:16:57 +01001533
1534/*
1535 * Function used to parse a stick-table update message after it has been received
1536 * by <p> peer with <msg_cur> as address of the pointer to the position in the
1537 * receipt buffer with <msg_end> being position of the end of the stick-table message.
1538 * Update <msg_curr> accordingly to the peer protocol specs if no peer protocol error
1539 * was encountered.
1540 * <exp> must be set if the stick-table entry expires.
1541 * <updt> must be set for PEER_MSG_STKT_UPDATE or PEER_MSG_STKT_UPDATE_TIMED stick-table
Ilya Shipitsinc02a23f2020-05-06 00:53:22 +05001542 * messages, in this case the stick-table update message is received with a stick-table
Frédéric Lécaille168a34b2019-01-23 11:16:57 +01001543 * update ID.
1544 * <totl> is the length of the stick-table update message computed upon receipt.
1545 */
Frédéric Lécaille444243c2019-01-24 15:40:11 +01001546static int peer_treat_updatemsg(struct appctx *appctx, struct peer *p, int updt, int exp,
1547 char **msg_cur, char *msg_end, int msg_len, int totl)
Frédéric Lécaille168a34b2019-01-23 11:16:57 +01001548{
1549 struct stream_interface *si = appctx->owner;
1550 struct shared_table *st = p->remote_table;
1551 struct stksess *ts, *newts;
1552 uint32_t update;
1553 int expire;
1554 unsigned int data_type;
1555 void *data_ptr;
1556
Frédéric Lécailled8659352020-11-10 16:18:03 +01001557 TRACE_ENTER(PEERS_EV_UPDTMSG, NULL, p);
Frédéric Lécaille168a34b2019-01-23 11:16:57 +01001558 /* Here we have data message */
1559 if (!st)
1560 goto ignore_msg;
1561
1562 expire = MS_TO_TICKS(st->table->expire);
1563
1564 if (updt) {
Frédéric Lécailled8659352020-11-10 16:18:03 +01001565 if (msg_len < sizeof(update)) {
1566 TRACE_PROTO("malformed message", PEERS_EV_UPDTMSG, NULL, p);
Willy Tarreau1e82a142019-01-29 11:08:06 +01001567 goto malformed_exit;
Frédéric Lécailled8659352020-11-10 16:18:03 +01001568 }
Willy Tarreau1e82a142019-01-29 11:08:06 +01001569
Frédéric Lécaille168a34b2019-01-23 11:16:57 +01001570 memcpy(&update, *msg_cur, sizeof(update));
1571 *msg_cur += sizeof(update);
1572 st->last_get = htonl(update);
1573 }
1574 else {
1575 st->last_get++;
1576 }
1577
1578 if (exp) {
1579 size_t expire_sz = sizeof expire;
1580
Frédéric Lécailled8659352020-11-10 16:18:03 +01001581 if (*msg_cur + expire_sz > msg_end) {
1582 TRACE_PROTO("malformed message", PEERS_EV_UPDTMSG,
1583 NULL, p, *msg_cur);
1584 TRACE_PROTO("malformed message", PEERS_EV_UPDTMSG,
1585 NULL, p, msg_end, &expire_sz);
Willy Tarreau1e82a142019-01-29 11:08:06 +01001586 goto malformed_exit;
Frédéric Lécailled8659352020-11-10 16:18:03 +01001587 }
Willy Tarreau1e82a142019-01-29 11:08:06 +01001588
Frédéric Lécaille168a34b2019-01-23 11:16:57 +01001589 memcpy(&expire, *msg_cur, expire_sz);
1590 *msg_cur += expire_sz;
1591 expire = ntohl(expire);
1592 }
1593
1594 newts = stksess_new(st->table, NULL);
1595 if (!newts)
1596 goto ignore_msg;
1597
1598 if (st->table->type == SMP_T_STR) {
1599 unsigned int to_read, to_store;
1600
1601 to_read = intdecode(msg_cur, msg_end);
Frédéric Lécailled8659352020-11-10 16:18:03 +01001602 if (!*msg_cur) {
1603 TRACE_PROTO("malformed message", PEERS_EV_UPDTMSG, NULL, p);
Willy Tarreau1e82a142019-01-29 11:08:06 +01001604 goto malformed_free_newts;
Frédéric Lécailled8659352020-11-10 16:18:03 +01001605 }
Willy Tarreau1e82a142019-01-29 11:08:06 +01001606
Frédéric Lécaille168a34b2019-01-23 11:16:57 +01001607 to_store = MIN(to_read, st->table->key_size - 1);
Frédéric Lécailled8659352020-11-10 16:18:03 +01001608 if (*msg_cur + to_store > msg_end) {
1609 TRACE_PROTO("malformed message", PEERS_EV_UPDTMSG,
1610 NULL, p, *msg_cur);
1611 TRACE_PROTO("malformed message", PEERS_EV_UPDTMSG,
1612 NULL, p, msg_end, &to_store);
Willy Tarreau1e82a142019-01-29 11:08:06 +01001613 goto malformed_free_newts;
Frédéric Lécailled8659352020-11-10 16:18:03 +01001614 }
Frédéric Lécaille168a34b2019-01-23 11:16:57 +01001615
1616 memcpy(newts->key.key, *msg_cur, to_store);
1617 newts->key.key[to_store] = 0;
1618 *msg_cur += to_read;
1619 }
1620 else if (st->table->type == SMP_T_SINT) {
1621 unsigned int netinteger;
1622
Frédéric Lécailled8659352020-11-10 16:18:03 +01001623 if (*msg_cur + sizeof(netinteger) > msg_end) {
1624 TRACE_PROTO("malformed message", PEERS_EV_UPDTMSG,
1625 NULL, p, *msg_cur);
1626 TRACE_PROTO("malformed message", PEERS_EV_UPDTMSG,
1627 NULL, p, msg_end);
Willy Tarreau1e82a142019-01-29 11:08:06 +01001628 goto malformed_free_newts;
Frédéric Lécailled8659352020-11-10 16:18:03 +01001629 }
Willy Tarreau1e82a142019-01-29 11:08:06 +01001630
Frédéric Lécaille168a34b2019-01-23 11:16:57 +01001631 memcpy(&netinteger, *msg_cur, sizeof(netinteger));
1632 netinteger = ntohl(netinteger);
1633 memcpy(newts->key.key, &netinteger, sizeof(netinteger));
1634 *msg_cur += sizeof(netinteger);
1635 }
1636 else {
Frédéric Lécailled8659352020-11-10 16:18:03 +01001637 if (*msg_cur + st->table->key_size > msg_end) {
1638 TRACE_PROTO("malformed message", PEERS_EV_UPDTMSG,
1639 NULL, p, *msg_cur);
1640 TRACE_PROTO("malformed message", PEERS_EV_UPDTMSG,
1641 NULL, p, msg_end, &st->table->key_size);
Willy Tarreau1e82a142019-01-29 11:08:06 +01001642 goto malformed_free_newts;
Frédéric Lécailled8659352020-11-10 16:18:03 +01001643 }
Willy Tarreau1e82a142019-01-29 11:08:06 +01001644
Frédéric Lécaille168a34b2019-01-23 11:16:57 +01001645 memcpy(newts->key.key, *msg_cur, st->table->key_size);
1646 *msg_cur += st->table->key_size;
1647 }
1648
1649 /* lookup for existing entry */
1650 ts = stktable_set_entry(st->table, newts);
1651 if (ts != newts) {
1652 stksess_free(st->table, newts);
1653 newts = NULL;
1654 }
1655
1656 HA_RWLOCK_WRLOCK(STK_SESS_LOCK, &ts->lock);
1657
1658 for (data_type = 0 ; data_type < STKTABLE_DATA_TYPES ; data_type++) {
Willy Tarreau1e82a142019-01-29 11:08:06 +01001659 uint64_t decoded_int;
Frédéric Lécaille168a34b2019-01-23 11:16:57 +01001660
Emeric Brun45f12b02021-07-01 18:54:05 +02001661 if (!((1ULL << data_type) & st->remote_data))
Frédéric Lécaille168a34b2019-01-23 11:16:57 +01001662 continue;
1663
Willy Tarreau1e82a142019-01-29 11:08:06 +01001664 decoded_int = intdecode(msg_cur, msg_end);
Frédéric Lécailled8659352020-11-10 16:18:03 +01001665 if (!*msg_cur) {
1666 TRACE_PROTO("malformed message", PEERS_EV_UPDTMSG, NULL, p);
Willy Tarreau1e82a142019-01-29 11:08:06 +01001667 goto malformed_unlock;
Frédéric Lécailled8659352020-11-10 16:18:03 +01001668 }
Frédéric Lécaille168a34b2019-01-23 11:16:57 +01001669
Willy Tarreau1e82a142019-01-29 11:08:06 +01001670 switch (stktable_data_types[data_type].std_type) {
1671 case STD_T_SINT:
Frédéric Lécaille168a34b2019-01-23 11:16:57 +01001672 data_ptr = stktable_data_ptr(st->table, ts, data_type);
1673 if (data_ptr)
Willy Tarreau1e82a142019-01-29 11:08:06 +01001674 stktable_data_cast(data_ptr, std_t_sint) = decoded_int;
Frédéric Lécaille168a34b2019-01-23 11:16:57 +01001675 break;
Frédéric Lécaille168a34b2019-01-23 11:16:57 +01001676
Willy Tarreau1e82a142019-01-29 11:08:06 +01001677 case STD_T_UINT:
Frédéric Lécaille168a34b2019-01-23 11:16:57 +01001678 data_ptr = stktable_data_ptr(st->table, ts, data_type);
1679 if (data_ptr)
Willy Tarreau1e82a142019-01-29 11:08:06 +01001680 stktable_data_cast(data_ptr, std_t_uint) = decoded_int;
Frédéric Lécaille168a34b2019-01-23 11:16:57 +01001681 break;
Frédéric Lécaille168a34b2019-01-23 11:16:57 +01001682
Willy Tarreau1e82a142019-01-29 11:08:06 +01001683 case STD_T_ULL:
Frédéric Lécaille168a34b2019-01-23 11:16:57 +01001684 data_ptr = stktable_data_ptr(st->table, ts, data_type);
1685 if (data_ptr)
Willy Tarreau1e82a142019-01-29 11:08:06 +01001686 stktable_data_cast(data_ptr, std_t_ull) = decoded_int;
Frédéric Lécaille168a34b2019-01-23 11:16:57 +01001687 break;
Willy Tarreau1e82a142019-01-29 11:08:06 +01001688
Frédéric Lécaille168a34b2019-01-23 11:16:57 +01001689 case STD_T_FRQP: {
Willy Tarreaufa1258f2021-04-10 23:00:53 +02001690 struct freq_ctr data;
Frédéric Lécaille168a34b2019-01-23 11:16:57 +01001691
Willy Tarreaufa1258f2021-04-10 23:00:53 +02001692 /* First bit is reserved for the freq_ctr lock
Frédéric Lécaille168a34b2019-01-23 11:16:57 +01001693 Note: here we're still protected by the stksess lock
Willy Tarreaufa1258f2021-04-10 23:00:53 +02001694 so we don't need to update the update the freq_ctr
Frédéric Lécaille168a34b2019-01-23 11:16:57 +01001695 using its internal lock */
1696
Willy Tarreau1e82a142019-01-29 11:08:06 +01001697 data.curr_tick = tick_add(now_ms, -decoded_int) & ~0x1;
Frédéric Lécaille168a34b2019-01-23 11:16:57 +01001698 data.curr_ctr = intdecode(msg_cur, msg_end);
Frédéric Lécailled8659352020-11-10 16:18:03 +01001699 if (!*msg_cur) {
1700 TRACE_PROTO("malformed message", PEERS_EV_UPDTMSG, NULL, p);
Willy Tarreau1e82a142019-01-29 11:08:06 +01001701 goto malformed_unlock;
Frédéric Lécailled8659352020-11-10 16:18:03 +01001702 }
Willy Tarreau1e82a142019-01-29 11:08:06 +01001703
Frédéric Lécaille168a34b2019-01-23 11:16:57 +01001704 data.prev_ctr = intdecode(msg_cur, msg_end);
Frédéric Lécailled8659352020-11-10 16:18:03 +01001705 if (!*msg_cur) {
1706 TRACE_PROTO("malformed message", PEERS_EV_UPDTMSG, NULL, p);
Willy Tarreau1e82a142019-01-29 11:08:06 +01001707 goto malformed_unlock;
Frédéric Lécailled8659352020-11-10 16:18:03 +01001708 }
Frédéric Lécaille168a34b2019-01-23 11:16:57 +01001709
1710 data_ptr = stktable_data_ptr(st->table, ts, data_type);
1711 if (data_ptr)
1712 stktable_data_cast(data_ptr, std_t_frqp) = data;
1713 break;
1714 }
Frédéric Lécaille8d78fa72019-05-20 18:22:52 +02001715 case STD_T_DICT: {
1716 struct buffer *chunk;
1717 size_t data_len, value_len;
1718 unsigned int id;
1719 struct dict_entry *de;
1720 struct dcache *dc;
Frédéric Lécaille344e9482019-06-05 10:20:09 +02001721 char *end;
Frédéric Lécaille8d78fa72019-05-20 18:22:52 +02001722
Frédéric Lécailleaf9990f2019-11-13 17:50:34 +01001723 if (!decoded_int) {
1724 /* No entry. */
1725 break;
1726 }
Frédéric Lécaille8d78fa72019-05-20 18:22:52 +02001727 data_len = decoded_int;
Frédéric Lécailled8659352020-11-10 16:18:03 +01001728 if (*msg_cur + data_len > msg_end) {
1729 TRACE_PROTO("malformed message", PEERS_EV_UPDTMSG,
1730 NULL, p, *msg_cur);
1731 TRACE_PROTO("malformed message", PEERS_EV_UPDTMSG,
1732 NULL, p, msg_end, &data_len);
Frédéric Lécaille8d78fa72019-05-20 18:22:52 +02001733 goto malformed_unlock;
Frédéric Lécailled8659352020-11-10 16:18:03 +01001734 }
Frédéric Lécaille8d78fa72019-05-20 18:22:52 +02001735
Frédéric Lécaille344e9482019-06-05 10:20:09 +02001736 /* Compute the end of the current data, <msg_end> being at the end of
1737 * the entire message.
1738 */
1739 end = *msg_cur + data_len;
1740 id = intdecode(msg_cur, end);
Frédéric Lécailled8659352020-11-10 16:18:03 +01001741 if (!*msg_cur || !id) {
1742 TRACE_PROTO("malformed message", PEERS_EV_UPDTMSG,
1743 NULL, p, *msg_cur, &id);
Frédéric Lécaille8d78fa72019-05-20 18:22:52 +02001744 goto malformed_unlock;
Frédéric Lécailled8659352020-11-10 16:18:03 +01001745 }
Frédéric Lécaille8d78fa72019-05-20 18:22:52 +02001746
1747 dc = p->dcache;
Frédéric Lécaille344e9482019-06-05 10:20:09 +02001748 if (*msg_cur == end) {
Frédéric Lécaille8d78fa72019-05-20 18:22:52 +02001749 /* Dictionary entry key without value. */
Frédéric Lécaillef9e51be2020-11-12 19:53:11 +01001750 if (id > dc->max_entries) {
1751 TRACE_PROTO("malformed message", PEERS_EV_UPDTMSG,
1752 NULL, p, NULL, &id);
1753 goto malformed_unlock;
1754 }
Frédéric Lécaille8d78fa72019-05-20 18:22:52 +02001755 /* IDs sent over the network are numbered from 1. */
1756 de = dc->rx[id - 1].de;
1757 }
1758 else {
1759 chunk = get_trash_chunk();
Frédéric Lécaille344e9482019-06-05 10:20:09 +02001760 value_len = intdecode(msg_cur, end);
1761 if (!*msg_cur || *msg_cur + value_len > end ||
Frédéric Lécailled8659352020-11-10 16:18:03 +01001762 unlikely(value_len + 1 >= chunk->size)) {
1763 TRACE_PROTO("malformed message", PEERS_EV_UPDTMSG,
1764 NULL, p, *msg_cur, &value_len);
1765 TRACE_PROTO("malformed message", PEERS_EV_UPDTMSG,
1766 NULL, p, end, &chunk->size);
Frédéric Lécaille8d78fa72019-05-20 18:22:52 +02001767 goto malformed_unlock;
Frédéric Lécailled8659352020-11-10 16:18:03 +01001768 }
Frédéric Lécaille8d78fa72019-05-20 18:22:52 +02001769
1770 chunk_memcpy(chunk, *msg_cur, value_len);
1771 chunk->area[chunk->data] = '\0';
Frédéric Lécaille56aec0d2019-06-06 14:14:15 +02001772 *msg_cur += value_len;
1773
Thayne McCombs92149f92020-11-20 01:28:26 -07001774 de = dict_insert(&server_key_dict, chunk->area);
1775 dict_entry_unref(&server_key_dict, dc->rx[id - 1].de);
Frédéric Lécaille8d78fa72019-05-20 18:22:52 +02001776 dc->rx[id - 1].de = de;
1777 }
1778 if (de) {
1779 data_ptr = stktable_data_ptr(st->table, ts, data_type);
Thayne McCombs92149f92020-11-20 01:28:26 -07001780 if (data_ptr) {
Willy Tarreau4781b152021-04-06 13:53:36 +02001781 HA_ATOMIC_INC(&de->refcount);
Frédéric Lécaille8d78fa72019-05-20 18:22:52 +02001782 stktable_data_cast(data_ptr, std_t_dict) = de;
Thayne McCombs92149f92020-11-20 01:28:26 -07001783 }
Frédéric Lécaille8d78fa72019-05-20 18:22:52 +02001784 }
1785 break;
1786 }
Frédéric Lécaille168a34b2019-01-23 11:16:57 +01001787 }
1788 }
1789 /* Force new expiration */
1790 ts->expire = tick_add(now_ms, expire);
1791
1792 HA_RWLOCK_WRUNLOCK(STK_SESS_LOCK, &ts->lock);
1793 stktable_touch_remote(st->table, ts, 1);
Frédéric Lécailled8659352020-11-10 16:18:03 +01001794 TRACE_LEAVE(PEERS_EV_UPDTMSG, NULL, p);
Frédéric Lécaille168a34b2019-01-23 11:16:57 +01001795 return 1;
1796
1797 ignore_msg:
1798 /* skip consumed message */
1799 co_skip(si_oc(si), totl);
Frédéric Lécailled8659352020-11-10 16:18:03 +01001800 TRACE_DEVEL("leaving in error", PEERS_EV_UPDTMSG);
Frédéric Lécaille168a34b2019-01-23 11:16:57 +01001801 return 0;
Willy Tarreau1e82a142019-01-29 11:08:06 +01001802
1803 malformed_unlock:
1804 /* malformed message */
1805 HA_RWLOCK_WRUNLOCK(STK_SESS_LOCK, &ts->lock);
1806 stktable_touch_remote(st->table, ts, 1);
1807 appctx->st0 = PEER_SESS_ST_ERRPROTO;
Frédéric Lécailled8659352020-11-10 16:18:03 +01001808 TRACE_DEVEL("leaving in error", PEERS_EV_UPDTMSG);
Willy Tarreau1e82a142019-01-29 11:08:06 +01001809 return 0;
1810
1811 malformed_free_newts:
1812 /* malformed message */
1813 stksess_free(st->table, newts);
1814 malformed_exit:
1815 appctx->st0 = PEER_SESS_ST_ERRPROTO;
Frédéric Lécailled8659352020-11-10 16:18:03 +01001816 TRACE_DEVEL("leaving in error", PEERS_EV_UPDTMSG);
Willy Tarreau1e82a142019-01-29 11:08:06 +01001817 return 0;
Frédéric Lécaille168a34b2019-01-23 11:16:57 +01001818}
1819
Frédéric Lécaille87f554c2019-01-22 17:26:50 +01001820/*
Frédéric Lécailled27b0942019-01-23 17:31:37 +01001821 * Function used to parse a stick-table update acknowledgement message after it
1822 * has been received by <p> peer with <msg_cur> as address of the pointer to the position in the
1823 * receipt buffer with <msg_end> being the position of the end of the stick-table message.
1824 * Update <msg_curr> accordingly to the peer protocol specs if no peer protocol error
1825 * was encountered.
1826 * Return 1 if succeeded, 0 if not with the appctx state st0 set to PEER_SESS_ST_ERRPROTO.
1827 */
1828static inline int peer_treat_ackmsg(struct appctx *appctx, struct peer *p,
1829 char **msg_cur, char *msg_end)
1830{
1831 /* ack message */
1832 uint32_t table_id ;
1833 uint32_t update;
1834 struct shared_table *st;
1835
Emeric Brunb0d60be2021-03-04 10:27:10 +01001836 /* ignore ack during teaching process */
1837 if (p->flags & PEER_F_TEACH_PROCESS)
1838 return 1;
1839
Frédéric Lécailled27b0942019-01-23 17:31:37 +01001840 table_id = intdecode(msg_cur, msg_end);
1841 if (!*msg_cur || (*msg_cur + sizeof(update) > msg_end)) {
1842 /* malformed message */
Frédéric Lécailleda2b0842021-01-15 16:21:28 +01001843
1844 TRACE_PROTO("malformed message", PEERS_EV_ACKMSG,
1845 NULL, p, *msg_cur);
Frédéric Lécailled27b0942019-01-23 17:31:37 +01001846 appctx->st0 = PEER_SESS_ST_ERRPROTO;
1847 return 0;
1848 }
1849
1850 memcpy(&update, *msg_cur, sizeof(update));
1851 update = ntohl(update);
1852
1853 for (st = p->tables; st; st = st->next) {
1854 if (st->local_id == table_id) {
1855 st->update = update;
1856 break;
1857 }
1858 }
1859
1860 return 1;
1861}
1862
1863/*
1864 * Function used to parse a stick-table switch message after it has been received
1865 * by <p> peer with <msg_cur> as address of the pointer to the position in the
1866 * receipt buffer with <msg_end> being the position of the end of the stick-table message.
1867 * Update <msg_curr> accordingly to the peer protocol specs if no peer protocol error
1868 * was encountered.
1869 * Return 1 if succeeded, 0 if not with the appctx state st0 set to PEER_SESS_ST_ERRPROTO.
1870 */
1871static inline int peer_treat_switchmsg(struct appctx *appctx, struct peer *p,
1872 char **msg_cur, char *msg_end)
1873{
1874 struct shared_table *st;
1875 int table_id;
1876
1877 table_id = intdecode(msg_cur, msg_end);
1878 if (!*msg_cur) {
Frédéric Lécailleda2b0842021-01-15 16:21:28 +01001879 TRACE_PROTO("malformed message", PEERS_EV_SWTCMSG, NULL, p);
Frédéric Lécailled27b0942019-01-23 17:31:37 +01001880 /* malformed message */
1881 appctx->st0 = PEER_SESS_ST_ERRPROTO;
1882 return 0;
1883 }
1884
1885 p->remote_table = NULL;
1886 for (st = p->tables; st; st = st->next) {
1887 if (st->remote_id == table_id) {
1888 p->remote_table = st;
1889 break;
1890 }
1891 }
1892
1893 return 1;
1894}
1895
1896/*
1897 * Function used to parse a stick-table definition message after it has been received
1898 * by <p> peer with <msg_cur> as address of the pointer to the position in the
1899 * receipt buffer with <msg_end> being the position of the end of the stick-table message.
1900 * Update <msg_curr> accordingly to the peer protocol specs if no peer protocol error
1901 * was encountered.
1902 * <totl> is the length of the stick-table update message computed upon receipt.
1903 * Return 1 if succeeded, 0 if not with the appctx state st0 set to PEER_SESS_ST_ERRPROTO.
1904 */
1905static inline int peer_treat_definemsg(struct appctx *appctx, struct peer *p,
1906 char **msg_cur, char *msg_end, int totl)
1907{
1908 struct stream_interface *si = appctx->owner;
1909 int table_id_len;
1910 struct shared_table *st;
1911 int table_type;
1912 int table_keylen;
1913 int table_id;
1914 uint64_t table_data;
1915
1916 table_id = intdecode(msg_cur, msg_end);
Frédéric Lécailleda2b0842021-01-15 16:21:28 +01001917 if (!*msg_cur) {
1918 TRACE_PROTO("malformed message", PEERS_EV_DEFMSG, NULL, p);
Willy Tarreau6f731f32019-01-29 11:11:23 +01001919 goto malformed_exit;
Frédéric Lécailleda2b0842021-01-15 16:21:28 +01001920 }
Frédéric Lécailled27b0942019-01-23 17:31:37 +01001921
1922 table_id_len = intdecode(msg_cur, msg_end);
Frédéric Lécailleda2b0842021-01-15 16:21:28 +01001923 if (!*msg_cur) {
1924 TRACE_PROTO("malformed message", PEERS_EV_DEFMSG, NULL, p, *msg_cur);
Willy Tarreau6f731f32019-01-29 11:11:23 +01001925 goto malformed_exit;
Frédéric Lécailleda2b0842021-01-15 16:21:28 +01001926 }
Frédéric Lécailled27b0942019-01-23 17:31:37 +01001927
1928 p->remote_table = NULL;
Frédéric Lécailleda2b0842021-01-15 16:21:28 +01001929 if (!table_id_len || (*msg_cur + table_id_len) >= msg_end) {
1930 TRACE_PROTO("malformed message", PEERS_EV_DEFMSG, NULL, p, *msg_cur, &table_id_len);
Willy Tarreau6f731f32019-01-29 11:11:23 +01001931 goto malformed_exit;
Frédéric Lécailleda2b0842021-01-15 16:21:28 +01001932 }
Frédéric Lécailled27b0942019-01-23 17:31:37 +01001933
1934 for (st = p->tables; st; st = st->next) {
1935 /* Reset IDs */
1936 if (st->remote_id == table_id)
1937 st->remote_id = 0;
1938
Frédéric Lécaille7fcc24d2019-03-20 15:09:45 +01001939 if (!p->remote_table && (table_id_len == strlen(st->table->nid)) &&
1940 (memcmp(st->table->nid, *msg_cur, table_id_len) == 0))
Frédéric Lécailled27b0942019-01-23 17:31:37 +01001941 p->remote_table = st;
1942 }
1943
Frédéric Lécailleda2b0842021-01-15 16:21:28 +01001944 if (!p->remote_table) {
1945 TRACE_PROTO("ignored message", PEERS_EV_DEFMSG, NULL, p);
Frédéric Lécailled27b0942019-01-23 17:31:37 +01001946 goto ignore_msg;
Frédéric Lécailleda2b0842021-01-15 16:21:28 +01001947 }
Frédéric Lécailled27b0942019-01-23 17:31:37 +01001948
1949 *msg_cur += table_id_len;
Frédéric Lécailleda2b0842021-01-15 16:21:28 +01001950 if (*msg_cur >= msg_end) {
1951 TRACE_PROTO("malformed message", PEERS_EV_DEFMSG, NULL, p);
Willy Tarreau6f731f32019-01-29 11:11:23 +01001952 goto malformed_exit;
Frédéric Lécailleda2b0842021-01-15 16:21:28 +01001953 }
Frédéric Lécailled27b0942019-01-23 17:31:37 +01001954
1955 table_type = intdecode(msg_cur, msg_end);
Frédéric Lécailleda2b0842021-01-15 16:21:28 +01001956 if (!*msg_cur) {
1957 TRACE_PROTO("malformed message", PEERS_EV_DEFMSG, NULL, p);
Willy Tarreau6f731f32019-01-29 11:11:23 +01001958 goto malformed_exit;
Frédéric Lécailleda2b0842021-01-15 16:21:28 +01001959 }
Frédéric Lécailled27b0942019-01-23 17:31:37 +01001960
1961 table_keylen = intdecode(msg_cur, msg_end);
Frédéric Lécailleda2b0842021-01-15 16:21:28 +01001962 if (!*msg_cur) {
1963 TRACE_PROTO("malformed message", PEERS_EV_DEFMSG, NULL, p);
Willy Tarreau6f731f32019-01-29 11:11:23 +01001964 goto malformed_exit;
Frédéric Lécailleda2b0842021-01-15 16:21:28 +01001965 }
Frédéric Lécailled27b0942019-01-23 17:31:37 +01001966
1967 table_data = intdecode(msg_cur, msg_end);
Frédéric Lécailleda2b0842021-01-15 16:21:28 +01001968 if (!*msg_cur) {
1969 TRACE_PROTO("malformed message", PEERS_EV_DEFMSG, NULL, p);
Willy Tarreau6f731f32019-01-29 11:11:23 +01001970 goto malformed_exit;
Frédéric Lécailleda2b0842021-01-15 16:21:28 +01001971 }
Frédéric Lécailled27b0942019-01-23 17:31:37 +01001972
Emeric Brun530ba382020-06-02 11:17:42 +02001973 if (p->remote_table->table->type != peer_int_key_type[table_type]
Frédéric Lécailled27b0942019-01-23 17:31:37 +01001974 || p->remote_table->table->key_size != table_keylen) {
1975 p->remote_table = NULL;
Frédéric Lécailleda2b0842021-01-15 16:21:28 +01001976 TRACE_PROTO("ignored message", PEERS_EV_DEFMSG, NULL, p);
Frédéric Lécailled27b0942019-01-23 17:31:37 +01001977 goto ignore_msg;
1978 }
1979
1980 p->remote_table->remote_data = table_data;
1981 p->remote_table->remote_id = table_id;
1982 return 1;
1983
1984 ignore_msg:
1985 co_skip(si_oc(si), totl);
1986 return 0;
Willy Tarreau6f731f32019-01-29 11:11:23 +01001987
1988 malformed_exit:
1989 /* malformed message */
1990 appctx->st0 = PEER_SESS_ST_ERRPROTO;
1991 return 0;
Frédéric Lécailled27b0942019-01-23 17:31:37 +01001992}
1993
1994/*
Willy Tarreau1dfd4f12020-11-13 14:10:20 +01001995 * Receive a stick-table message or pre-parse any other message.
1996 * The message's header will be sent into <msg_head> which must be at least
1997 * <msg_head_sz> bytes long (at least 7 to store 32-bit variable lengths).
1998 * The first two bytes are always read, and the rest is only read if the
1999 * first bytes indicate a stick-table message. If the message is a stick-table
2000 * message, the varint is decoded and the equivalent number of bytes will be
2001 * copied into the trash at trash.area. <totl> is incremented by the number of
2002 * bytes read EVEN IN CASE OF INCOMPLETE MESSAGES.
Frédéric Lécaille95203f22019-01-23 19:38:11 +01002003 * Returns 1 if there was no error, if not, returns 0 if not enough data were available,
2004 * -1 if there was an error updating the appctx state st0 accordingly.
2005 */
2006static inline int peer_recv_msg(struct appctx *appctx, char *msg_head, size_t msg_head_sz,
2007 uint32_t *msg_len, int *totl)
2008{
2009 int reql;
2010 struct stream_interface *si = appctx->owner;
Willy Tarreau1dfd4f12020-11-13 14:10:20 +01002011 char *cur;
Frédéric Lécaille95203f22019-01-23 19:38:11 +01002012
2013 reql = co_getblk(si_oc(si), msg_head, 2 * sizeof(char), *totl);
2014 if (reql <= 0) /* closed or EOL not found */
2015 goto incomplete;
2016
2017 *totl += reql;
2018
Frédéric Lécaille36fb77e2019-06-04 08:28:19 +02002019 if (!(msg_head[1] & PEER_MSG_STKT_BIT_MASK))
Frédéric Lécaille95203f22019-01-23 19:38:11 +01002020 return 1;
2021
Willy Tarreau1dfd4f12020-11-13 14:10:20 +01002022 /* This is a stick-table message, let's go on */
2023
Frédéric Lécaille95203f22019-01-23 19:38:11 +01002024 /* Read and Decode message length */
Willy Tarreau1dfd4f12020-11-13 14:10:20 +01002025 msg_head += *totl;
2026 msg_head_sz -= *totl;
2027 reql = co_data(si_oc(si)) - *totl;
2028 if (reql > msg_head_sz)
2029 reql = msg_head_sz;
2030
2031 reql = co_getblk(si_oc(si), msg_head, reql, *totl);
Frédéric Lécaille95203f22019-01-23 19:38:11 +01002032 if (reql <= 0) /* closed */
2033 goto incomplete;
2034
Willy Tarreau1dfd4f12020-11-13 14:10:20 +01002035 cur = msg_head;
2036 *msg_len = intdecode(&cur, cur + reql);
2037 if (!cur) {
2038 /* the number is truncated, did we read enough ? */
2039 if (reql < msg_head_sz)
2040 goto incomplete;
Frédéric Lécaille95203f22019-01-23 19:38:11 +01002041
Willy Tarreau1dfd4f12020-11-13 14:10:20 +01002042 /* malformed message */
2043 TRACE_PROTO("malformed message: too large length encoding", PEERS_EV_UPDTMSG);
2044 appctx->st0 = PEER_SESS_ST_ERRPROTO;
2045 return -1;
Frédéric Lécaille95203f22019-01-23 19:38:11 +01002046 }
Willy Tarreau1dfd4f12020-11-13 14:10:20 +01002047 *totl += cur - msg_head;
Frédéric Lécaille95203f22019-01-23 19:38:11 +01002048
2049 /* Read message content */
2050 if (*msg_len) {
2051 if (*msg_len > trash.size) {
2052 /* Status code is not success, abort */
2053 appctx->st0 = PEER_SESS_ST_ERRSIZE;
2054 return -1;
2055 }
2056
2057 reql = co_getblk(si_oc(si), trash.area, *msg_len, *totl);
2058 if (reql <= 0) /* closed */
2059 goto incomplete;
2060 *totl += reql;
2061 }
2062
2063 return 1;
2064
2065 incomplete:
Willy Tarreau345ebcf2020-11-26 17:06:04 +01002066 if (reql < 0 || (si_oc(si)->flags & (CF_SHUTW|CF_SHUTW_NOW))) {
2067 /* there was an error or the message was truncated */
Frédéric Lécaille95203f22019-01-23 19:38:11 +01002068 appctx->st0 = PEER_SESS_ST_END;
2069 return -1;
2070 }
2071
2072 return 0;
2073}
Frédéric Lécaille444243c2019-01-24 15:40:11 +01002074
2075/*
2076 * Treat the awaited message with <msg_head> as header.*
2077 * Return 1 if succeeded, 0 if not.
2078 */
2079static inline int peer_treat_awaited_msg(struct appctx *appctx, struct peer *peer, unsigned char *msg_head,
2080 char **msg_cur, char *msg_end, int msg_len, int totl)
2081{
2082 struct stream_interface *si = appctx->owner;
2083 struct stream *s = si_strm(si);
2084 struct peers *peers = strm_fe(s)->parent;
2085
2086 if (msg_head[0] == PEER_MSG_CLASS_CONTROL) {
2087 if (msg_head[1] == PEER_MSG_CTRL_RESYNCREQ) {
2088 struct shared_table *st;
2089 /* Reset message: remote need resync */
2090
Frédéric Lécailleda2b0842021-01-15 16:21:28 +01002091 TRACE_PROTO("received control message", PEERS_EV_CTRLMSG,
2092 NULL, &msg_head[1], peers->local->id, peer->id);
Ilya Shipitsinc02a23f2020-05-06 00:53:22 +05002093 /* prepare tables for a global push */
Frédéric Lécaille444243c2019-01-24 15:40:11 +01002094 for (st = peer->tables; st; st = st->next) {
Emeric Brun437e48a2021-04-28 09:49:33 +02002095 st->teaching_origin = st->last_pushed = st->update;
Frédéric Lécaille444243c2019-01-24 15:40:11 +01002096 st->flags = 0;
2097 }
2098
2099 /* reset teaching flags to 0 */
2100 peer->flags &= PEER_TEACH_RESET;
2101
2102 /* flag to start to teach lesson */
2103 peer->flags |= PEER_F_TEACH_PROCESS;
Emeric Brunccdfbae2021-04-28 12:59:35 +02002104 peers->flags |= PEERS_F_RESYNC_REQUESTED;
Frédéric Lécaille444243c2019-01-24 15:40:11 +01002105 }
2106 else if (msg_head[1] == PEER_MSG_CTRL_RESYNCFINISHED) {
Frédéric Lécailleda2b0842021-01-15 16:21:28 +01002107 TRACE_PROTO("received control message", PEERS_EV_CTRLMSG,
2108 NULL, &msg_head[1], peers->local->id, peer->id);
Frédéric Lécaille444243c2019-01-24 15:40:11 +01002109 if (peer->flags & PEER_F_LEARN_ASSIGN) {
2110 peer->flags &= ~PEER_F_LEARN_ASSIGN;
2111 peers->flags &= ~(PEERS_F_RESYNC_ASSIGN|PEERS_F_RESYNC_PROCESS);
2112 peers->flags |= (PEERS_F_RESYNC_LOCAL|PEERS_F_RESYNC_REMOTE);
Emeric Brunccdfbae2021-04-28 12:59:35 +02002113 if (peer->local)
2114 peers->flags |= PEERS_F_RESYNC_LOCALFINISHED;
2115 else
2116 peers->flags |= PEERS_F_RESYNC_REMOTEFINISHED;
Frédéric Lécaille444243c2019-01-24 15:40:11 +01002117 }
2118 peer->confirm++;
2119 }
2120 else if (msg_head[1] == PEER_MSG_CTRL_RESYNCPARTIAL) {
Frédéric Lécailleda2b0842021-01-15 16:21:28 +01002121 TRACE_PROTO("received control message", PEERS_EV_CTRLMSG,
2122 NULL, &msg_head[1], peers->local->id, peer->id);
Frédéric Lécaille444243c2019-01-24 15:40:11 +01002123 if (peer->flags & PEER_F_LEARN_ASSIGN) {
2124 peer->flags &= ~PEER_F_LEARN_ASSIGN;
2125 peers->flags &= ~(PEERS_F_RESYNC_ASSIGN|PEERS_F_RESYNC_PROCESS);
2126
Emeric Brunccdfbae2021-04-28 12:59:35 +02002127 if (peer->local)
2128 peers->flags |= PEERS_F_RESYNC_LOCALPARTIAL;
2129 else
2130 peers->flags |= PEERS_F_RESYNC_REMOTEPARTIAL;
Frédéric Lécaille444243c2019-01-24 15:40:11 +01002131 peer->flags |= PEER_F_LEARN_NOTUP2DATE;
Frédéric Lécaille54bff832019-03-26 10:25:20 +01002132 peers->resync_timeout = tick_add(now_ms, MS_TO_TICKS(PEER_RESYNC_TIMEOUT));
Frédéric Lécaille444243c2019-01-24 15:40:11 +01002133 task_wakeup(peers->sync_task, TASK_WOKEN_MSG);
2134 }
2135 peer->confirm++;
2136 }
2137 else if (msg_head[1] == PEER_MSG_CTRL_RESYNCCONFIRM) {
2138 struct shared_table *st;
2139
Frédéric Lécailleda2b0842021-01-15 16:21:28 +01002140 TRACE_PROTO("received control message", PEERS_EV_CTRLMSG,
2141 NULL, &msg_head[1], peers->local->id, peer->id);
Frédéric Lécaille444243c2019-01-24 15:40:11 +01002142 /* If stopping state */
2143 if (stopping) {
2144 /* Close session, push resync no more needed */
2145 peer->flags |= PEER_F_TEACH_COMPLETE;
2146 appctx->st0 = PEER_SESS_ST_END;
2147 return 0;
2148 }
2149 for (st = peer->tables; st; st = st->next) {
2150 st->update = st->last_pushed = st->teaching_origin;
2151 st->flags = 0;
2152 }
2153
2154 /* reset teaching flags to 0 */
2155 peer->flags &= PEER_TEACH_RESET;
2156 }
Frédéric Lécaille645635d2019-02-11 17:49:39 +01002157 else if (msg_head[1] == PEER_MSG_CTRL_HEARTBEAT) {
Frédéric Lécailleda2b0842021-01-15 16:21:28 +01002158 TRACE_PROTO("received control message", PEERS_EV_CTRLMSG,
2159 NULL, &msg_head[1], peers->local->id, peer->id);
Frédéric Lécaille54bff832019-03-26 10:25:20 +01002160 peer->reconnect = tick_add(now_ms, MS_TO_TICKS(PEER_RECONNECT_TIMEOUT));
Frédéric Lécaille33cab3c2019-11-06 11:51:26 +01002161 peer->rx_hbt++;
Frédéric Lécaille645635d2019-02-11 17:49:39 +01002162 }
Frédéric Lécaille444243c2019-01-24 15:40:11 +01002163 }
2164 else if (msg_head[0] == PEER_MSG_CLASS_STICKTABLE) {
2165 if (msg_head[1] == PEER_MSG_STKT_DEFINE) {
2166 if (!peer_treat_definemsg(appctx, peer, msg_cur, msg_end, totl))
2167 return 0;
2168 }
2169 else if (msg_head[1] == PEER_MSG_STKT_SWITCH) {
2170 if (!peer_treat_switchmsg(appctx, peer, msg_cur, msg_end))
2171 return 0;
2172 }
2173 else if (msg_head[1] == PEER_MSG_STKT_UPDATE ||
2174 msg_head[1] == PEER_MSG_STKT_INCUPDATE ||
2175 msg_head[1] == PEER_MSG_STKT_UPDATE_TIMED ||
2176 msg_head[1] == PEER_MSG_STKT_INCUPDATE_TIMED) {
2177 int update, expire;
2178
2179 update = msg_head[1] == PEER_MSG_STKT_UPDATE || msg_head[1] == PEER_MSG_STKT_UPDATE_TIMED;
2180 expire = msg_head[1] == PEER_MSG_STKT_UPDATE_TIMED || msg_head[1] == PEER_MSG_STKT_INCUPDATE_TIMED;
2181 if (!peer_treat_updatemsg(appctx, peer, update, expire,
2182 msg_cur, msg_end, msg_len, totl))
2183 return 0;
2184
2185 }
2186 else if (msg_head[1] == PEER_MSG_STKT_ACK) {
2187 if (!peer_treat_ackmsg(appctx, peer, msg_cur, msg_end))
2188 return 0;
2189 }
2190 }
2191 else if (msg_head[0] == PEER_MSG_CLASS_RESERVED) {
2192 appctx->st0 = PEER_SESS_ST_ERRPROTO;
2193 return 0;
2194 }
2195
2196 return 1;
2197}
Frédéric Lécaille25e1d5e2019-01-24 17:33:48 +01002198
2199
2200/*
2201 * Send any message to <peer> peer.
2202 * Returns 1 if succeeded, or -1 or 0 if failed.
Ilya Shipitsinc02a23f2020-05-06 00:53:22 +05002203 * -1 means an internal error occurred, 0 is for a peer protocol error leading
Frédéric Lécaille25e1d5e2019-01-24 17:33:48 +01002204 * to a peer state change (from the peer I/O handler point of view).
2205 */
Frédéric Lécailleda2b0842021-01-15 16:21:28 +01002206static inline int peer_send_msgs(struct appctx *appctx,
2207 struct peer *peer, struct peers *peers)
Frédéric Lécaille25e1d5e2019-01-24 17:33:48 +01002208{
2209 int repl;
Frédéric Lécaille25e1d5e2019-01-24 17:33:48 +01002210
2211 /* Need to request a resync */
2212 if ((peer->flags & PEER_F_LEARN_ASSIGN) &&
2213 (peers->flags & PEERS_F_RESYNC_ASSIGN) &&
2214 !(peers->flags & PEERS_F_RESYNC_PROCESS)) {
2215
Frédéric Lécailleda2b0842021-01-15 16:21:28 +01002216 repl = peer_send_resync_reqmsg(appctx, peer, peers);
Frédéric Lécaille25e1d5e2019-01-24 17:33:48 +01002217 if (repl <= 0)
2218 return repl;
2219
2220 peers->flags |= PEERS_F_RESYNC_PROCESS;
2221 }
2222
2223 /* Nothing to read, now we start to write */
2224 if (peer->tables) {
2225 struct shared_table *st;
2226 struct shared_table *last_local_table;
2227
2228 last_local_table = peer->last_local_table;
2229 if (!last_local_table)
2230 last_local_table = peer->tables;
2231 st = last_local_table->next;
2232
2233 while (1) {
2234 if (!st)
2235 st = peer->tables;
2236
2237 /* It remains some updates to ack */
2238 if (st->last_get != st->last_acked) {
2239 repl = peer_send_ackmsg(st, appctx);
2240 if (repl <= 0)
2241 return repl;
2242
2243 st->last_acked = st->last_get;
2244 }
2245
2246 if (!(peer->flags & PEER_F_TEACH_PROCESS)) {
2247 HA_SPIN_LOCK(STK_TABLE_LOCK, &st->table->lock);
2248 if (!(peer->flags & PEER_F_LEARN_ASSIGN) &&
Emeric Brun8e7a13e2021-04-28 11:48:15 +02002249 (st->last_pushed != st->table->localupdate)) {
Frédéric Lécaille25e1d5e2019-01-24 17:33:48 +01002250
2251 repl = peer_send_teach_process_msgs(appctx, peer, st);
2252 if (repl <= 0) {
2253 HA_SPIN_UNLOCK(STK_TABLE_LOCK, &st->table->lock);
2254 return repl;
2255 }
2256 }
2257 HA_SPIN_UNLOCK(STK_TABLE_LOCK, &st->table->lock);
2258 }
Emeric Brun1675ada2021-04-22 18:13:13 +02002259 else if (!(peer->flags & PEER_F_TEACH_FINISHED)) {
Frédéric Lécaille25e1d5e2019-01-24 17:33:48 +01002260 if (!(st->flags & SHTABLE_F_TEACH_STAGE1)) {
2261 repl = peer_send_teach_stage1_msgs(appctx, peer, st);
2262 if (repl <= 0)
2263 return repl;
2264 }
2265
2266 if (!(st->flags & SHTABLE_F_TEACH_STAGE2)) {
2267 repl = peer_send_teach_stage2_msgs(appctx, peer, st);
2268 if (repl <= 0)
2269 return repl;
2270 }
2271 }
2272
2273 if (st == last_local_table)
2274 break;
2275 st = st->next;
2276 }
2277 }
2278
2279 if ((peer->flags & PEER_F_TEACH_PROCESS) && !(peer->flags & PEER_F_TEACH_FINISHED)) {
Frédéric Lécailleda2b0842021-01-15 16:21:28 +01002280 repl = peer_send_resync_finishedmsg(appctx, peer, peers);
Frédéric Lécaille25e1d5e2019-01-24 17:33:48 +01002281 if (repl <= 0)
2282 return repl;
2283
2284 /* flag finished message sent */
2285 peer->flags |= PEER_F_TEACH_FINISHED;
2286 }
2287
2288 /* Confirm finished or partial messages */
2289 while (peer->confirm) {
Frédéric Lécailleda2b0842021-01-15 16:21:28 +01002290 repl = peer_send_resync_confirmsg(appctx, peer, peers);
Frédéric Lécaille25e1d5e2019-01-24 17:33:48 +01002291 if (repl <= 0)
2292 return repl;
2293
2294 peer->confirm--;
2295 }
2296
2297 return 1;
2298}
2299
Frédéric Lécaille95203f22019-01-23 19:38:11 +01002300/*
Frédéric Lécaille3f0fb9d2019-01-25 08:30:29 +01002301 * Read and parse a first line of a "hello" peer protocol message.
2302 * Returns 0 if could not read a line, -1 if there was a read error or
2303 * the line is malformed, 1 if succeeded.
2304 */
2305static inline int peer_getline_version(struct appctx *appctx,
2306 unsigned int *maj_ver, unsigned int *min_ver)
2307{
2308 int reql;
2309
2310 reql = peer_getline(appctx);
2311 if (!reql)
2312 return 0;
2313
2314 if (reql < 0)
2315 return -1;
2316
2317 /* test protocol */
2318 if (strncmp(PEER_SESSION_PROTO_NAME " ", trash.area, proto_len + 1) != 0) {
2319 appctx->st0 = PEER_SESS_ST_EXIT;
2320 appctx->st1 = PEER_SESS_SC_ERRPROTO;
2321 return -1;
2322 }
2323 if (peer_get_version(trash.area + proto_len + 1, maj_ver, min_ver) == -1 ||
2324 *maj_ver != PEER_MAJOR_VER || *min_ver > PEER_MINOR_VER) {
2325 appctx->st0 = PEER_SESS_ST_EXIT;
2326 appctx->st1 = PEER_SESS_SC_ERRVERSION;
2327 return -1;
2328 }
2329
2330 return 1;
2331}
2332
2333/*
2334 * Read and parse a second line of a "hello" peer protocol message.
2335 * Returns 0 if could not read a line, -1 if there was a read error or
2336 * the line is malformed, 1 if succeeded.
2337 */
2338static inline int peer_getline_host(struct appctx *appctx)
2339{
2340 int reql;
2341
2342 reql = peer_getline(appctx);
2343 if (!reql)
2344 return 0;
2345
2346 if (reql < 0)
2347 return -1;
2348
2349 /* test hostname match */
2350 if (strcmp(localpeer, trash.area) != 0) {
2351 appctx->st0 = PEER_SESS_ST_EXIT;
2352 appctx->st1 = PEER_SESS_SC_ERRHOST;
2353 return -1;
2354 }
2355
2356 return 1;
2357}
2358
2359/*
2360 * Read and parse a last line of a "hello" peer protocol message.
2361 * Returns 0 if could not read a character, -1 if there was a read error or
2362 * the line is malformed, 1 if succeeded.
2363 * Set <curpeer> accordingly (the remote peer sending the "hello" message).
2364 */
2365static inline int peer_getline_last(struct appctx *appctx, struct peer **curpeer)
2366{
2367 char *p;
2368 int reql;
2369 struct peer *peer;
2370 struct stream_interface *si = appctx->owner;
2371 struct stream *s = si_strm(si);
2372 struct peers *peers = strm_fe(s)->parent;
2373
2374 reql = peer_getline(appctx);
2375 if (!reql)
2376 return 0;
2377
2378 if (reql < 0)
2379 return -1;
2380
2381 /* parse line "<peer name> <pid> <relative_pid>" */
2382 p = strchr(trash.area, ' ');
2383 if (!p) {
2384 appctx->st0 = PEER_SESS_ST_EXIT;
2385 appctx->st1 = PEER_SESS_SC_ERRPROTO;
2386 return -1;
2387 }
2388 *p = 0;
2389
2390 /* lookup known peer */
2391 for (peer = peers->remote; peer; peer = peer->next) {
2392 if (strcmp(peer->id, trash.area) == 0)
2393 break;
2394 }
2395
2396 /* if unknown peer */
2397 if (!peer) {
2398 appctx->st0 = PEER_SESS_ST_EXIT;
2399 appctx->st1 = PEER_SESS_SC_ERRPEER;
2400 return -1;
2401 }
2402 *curpeer = peer;
2403
2404 return 1;
2405}
2406
2407/*
Frédéric Lécaille4b2fd9b2019-01-25 08:58:41 +01002408 * Init <peer> peer after having accepted it at peer protocol level.
2409 */
2410static inline void init_accepted_peer(struct peer *peer, struct peers *peers)
2411{
2412 struct shared_table *st;
2413
Frédéric Lécaillebaeb9192020-10-14 11:50:26 +02002414 peer->heartbeat = tick_add(now_ms, MS_TO_TICKS(PEER_HEARTBEAT_TIMEOUT));
Frédéric Lécaille4b2fd9b2019-01-25 08:58:41 +01002415 /* Register status code */
2416 peer->statuscode = PEER_SESS_SC_SUCCESSCODE;
Frédéric Lécaille3fc0fe02020-10-08 09:46:24 +02002417 peer->last_hdshk = now_ms;
Frédéric Lécaille4b2fd9b2019-01-25 08:58:41 +01002418
2419 /* Awake main task */
2420 task_wakeup(peers->sync_task, TASK_WOKEN_MSG);
2421
2422 /* Init confirm counter */
2423 peer->confirm = 0;
2424
2425 /* Init cursors */
2426 for (st = peer->tables; st ; st = st->next) {
2427 st->last_get = st->last_acked = 0;
Emeric Brund9729da2021-02-23 16:50:53 +01002428 HA_SPIN_LOCK(STK_TABLE_LOCK, &st->table->lock);
2429 /* if st->update appears to be in future it means
2430 * that the last acked value is very old and we
2431 * remain unconnected a too long time to use this
2432 * acknowlegement as a reset.
2433 * We should update the protocol to be able to
2434 * signal the remote peer that it needs a full resync.
2435 * Here a partial fix consist to set st->update at
2436 * the max past value
2437 */
2438 if ((int)(st->table->localupdate - st->update) < 0)
2439 st->update = st->table->localupdate + (2147483648U);
Frédéric Lécaille4b2fd9b2019-01-25 08:58:41 +01002440 st->teaching_origin = st->last_pushed = st->update;
Emeric Brun1a6b43e2021-04-20 14:43:46 +02002441 st->flags = 0;
Emeric Bruncc9cce92021-02-23 17:08:08 +01002442 if ((int)(st->last_pushed - st->table->commitupdate) > 0)
2443 st->table->commitupdate = st->last_pushed;
Emeric Brund9729da2021-02-23 16:50:53 +01002444 HA_SPIN_UNLOCK(STK_TABLE_LOCK, &st->table->lock);
Frédéric Lécaille4b2fd9b2019-01-25 08:58:41 +01002445 }
2446
2447 /* reset teaching and learning flags to 0 */
2448 peer->flags &= PEER_TEACH_RESET;
2449 peer->flags &= PEER_LEARN_RESET;
2450
2451 /* if current peer is local */
2452 if (peer->local) {
Ilya Shipitsin46a030c2020-07-05 16:36:08 +05002453 /* if current host need resyncfrom local and no process assigned */
Frédéric Lécaille4b2fd9b2019-01-25 08:58:41 +01002454 if ((peers->flags & PEERS_RESYNC_STATEMASK) == PEERS_RESYNC_FROMLOCAL &&
2455 !(peers->flags & PEERS_F_RESYNC_ASSIGN)) {
2456 /* assign local peer for a lesson, consider lesson already requested */
2457 peer->flags |= PEER_F_LEARN_ASSIGN;
2458 peers->flags |= (PEERS_F_RESYNC_ASSIGN|PEERS_F_RESYNC_PROCESS);
Emeric Brunccdfbae2021-04-28 12:59:35 +02002459 peers->flags |= PEERS_F_RESYNC_LOCALASSIGN;
Frédéric Lécaille4b2fd9b2019-01-25 08:58:41 +01002460 }
2461
2462 }
2463 else if ((peers->flags & PEERS_RESYNC_STATEMASK) == PEERS_RESYNC_FROMREMOTE &&
2464 !(peers->flags & PEERS_F_RESYNC_ASSIGN)) {
2465 /* assign peer for a lesson */
2466 peer->flags |= PEER_F_LEARN_ASSIGN;
2467 peers->flags |= PEERS_F_RESYNC_ASSIGN;
Emeric Brunccdfbae2021-04-28 12:59:35 +02002468 peers->flags |= PEERS_F_RESYNC_REMOTEASSIGN;
Frédéric Lécaille4b2fd9b2019-01-25 08:58:41 +01002469 }
2470}
2471
2472/*
2473 * Init <peer> peer after having connected it at peer protocol level.
2474 */
2475static inline void init_connected_peer(struct peer *peer, struct peers *peers)
2476{
2477 struct shared_table *st;
2478
Frédéric Lécaillebaeb9192020-10-14 11:50:26 +02002479 peer->heartbeat = tick_add(now_ms, MS_TO_TICKS(PEER_HEARTBEAT_TIMEOUT));
Frédéric Lécaille4b2fd9b2019-01-25 08:58:41 +01002480 /* Init cursors */
2481 for (st = peer->tables; st ; st = st->next) {
2482 st->last_get = st->last_acked = 0;
Emeric Brund9729da2021-02-23 16:50:53 +01002483 HA_SPIN_LOCK(STK_TABLE_LOCK, &st->table->lock);
2484 /* if st->update appears to be in future it means
2485 * that the last acked value is very old and we
2486 * remain unconnected a too long time to use this
2487 * acknowlegement as a reset.
2488 * We should update the protocol to be able to
2489 * signal the remote peer that it needs a full resync.
2490 * Here a partial fix consist to set st->update at
2491 * the max past value.
2492 */
2493 if ((int)(st->table->localupdate - st->update) < 0)
2494 st->update = st->table->localupdate + (2147483648U);
Frédéric Lécaille4b2fd9b2019-01-25 08:58:41 +01002495 st->teaching_origin = st->last_pushed = st->update;
Emeric Brun1a6b43e2021-04-20 14:43:46 +02002496 st->flags = 0;
Emeric Bruncc9cce92021-02-23 17:08:08 +01002497 if ((int)(st->last_pushed - st->table->commitupdate) > 0)
2498 st->table->commitupdate = st->last_pushed;
Emeric Brund9729da2021-02-23 16:50:53 +01002499 HA_SPIN_UNLOCK(STK_TABLE_LOCK, &st->table->lock);
Frédéric Lécaille4b2fd9b2019-01-25 08:58:41 +01002500 }
2501
2502 /* Init confirm counter */
2503 peer->confirm = 0;
2504
2505 /* reset teaching and learning flags to 0 */
2506 peer->flags &= PEER_TEACH_RESET;
2507 peer->flags &= PEER_LEARN_RESET;
2508
2509 /* If current peer is local */
2510 if (peer->local) {
2511 /* flag to start to teach lesson */
2512 peer->flags |= PEER_F_TEACH_PROCESS;
2513 }
2514 else if ((peers->flags & PEERS_RESYNC_STATEMASK) == PEERS_RESYNC_FROMREMOTE &&
2515 !(peers->flags & PEERS_F_RESYNC_ASSIGN)) {
2516 /* If peer is remote and resync from remote is needed,
2517 and no peer currently assigned */
2518
2519 /* assign peer for a lesson */
2520 peer->flags |= PEER_F_LEARN_ASSIGN;
2521 peers->flags |= PEERS_F_RESYNC_ASSIGN;
Emeric Brunccdfbae2021-04-28 12:59:35 +02002522 peers->flags |= PEERS_F_RESYNC_REMOTEASSIGN;
Frédéric Lécaille4b2fd9b2019-01-25 08:58:41 +01002523 }
2524}
2525
2526/*
Ilya Shipitsin46a030c2020-07-05 16:36:08 +05002527 * IO Handler to handle message exchange with a peer
Emeric Brun2b920a12010-09-23 18:30:22 +02002528 */
Willy Tarreau00a37f02015-04-13 12:05:19 +02002529static void peer_io_handler(struct appctx *appctx)
Emeric Brun2b920a12010-09-23 18:30:22 +02002530{
Willy Tarreau00a37f02015-04-13 12:05:19 +02002531 struct stream_interface *si = appctx->owner;
Willy Tarreau87b09662015-04-03 00:22:06 +02002532 struct stream *s = si_strm(si);
Vincent Bernat3c2f2f22016-04-03 13:48:42 +02002533 struct peers *curpeers = strm_fe(s)->parent;
Emeric Brun80527f52017-06-19 17:46:37 +02002534 struct peer *curpeer = NULL;
Emeric Brun2b920a12010-09-23 18:30:22 +02002535 int reql = 0;
2536 int repl = 0;
Frédéric Lécaille523cc9e2016-10-12 17:30:30 +02002537 unsigned int maj_ver, min_ver;
Willy Tarreau2d372c22018-11-05 17:12:27 +01002538 int prev_state;
Emeric Brun2b920a12010-09-23 18:30:22 +02002539
Joseph Herlant82b2f542018-11-15 12:19:14 -08002540 /* Check if the input buffer is available. */
Frédéric Lécaille7d0ceee2019-01-24 14:24:05 +01002541 if (si_ic(si)->buf.size == 0) {
2542 si_rx_room_blk(si);
2543 goto out;
2544 }
Christopher Fauleta73e59b2016-12-09 17:30:18 +01002545
Emeric Brun2b920a12010-09-23 18:30:22 +02002546 while (1) {
Willy Tarreau2d372c22018-11-05 17:12:27 +01002547 prev_state = appctx->st0;
Emeric Brun2b920a12010-09-23 18:30:22 +02002548switchstate:
Frédéric Lécaille523cc9e2016-10-12 17:30:30 +02002549 maj_ver = min_ver = (unsigned int)-1;
Willy Tarreau7b4b4992013-12-01 09:15:12 +01002550 switch(appctx->st0) {
Willy Tarreaue4d927a2013-12-01 12:47:35 +01002551 case PEER_SESS_ST_ACCEPT:
Willy Tarreau2d372c22018-11-05 17:12:27 +01002552 prev_state = appctx->st0;
Willy Tarreau7b4b4992013-12-01 09:15:12 +01002553 appctx->ctx.peers.ptr = NULL;
Willy Tarreaue4d927a2013-12-01 12:47:35 +01002554 appctx->st0 = PEER_SESS_ST_GETVERSION;
Emeric Brun2b920a12010-09-23 18:30:22 +02002555 /* fall through */
Willy Tarreaue4d927a2013-12-01 12:47:35 +01002556 case PEER_SESS_ST_GETVERSION:
Willy Tarreau2d372c22018-11-05 17:12:27 +01002557 prev_state = appctx->st0;
Frédéric Lécaille3f0fb9d2019-01-25 08:30:29 +01002558 reql = peer_getline_version(appctx, &maj_ver, &min_ver);
2559 if (reql <= 0) {
2560 if (!reql)
2561 goto out;
Emeric Brun2b920a12010-09-23 18:30:22 +02002562 goto switchstate;
2563 }
2564
Willy Tarreaue4d927a2013-12-01 12:47:35 +01002565 appctx->st0 = PEER_SESS_ST_GETHOST;
Emeric Brun2b920a12010-09-23 18:30:22 +02002566 /* fall through */
Willy Tarreaue4d927a2013-12-01 12:47:35 +01002567 case PEER_SESS_ST_GETHOST:
Willy Tarreau2d372c22018-11-05 17:12:27 +01002568 prev_state = appctx->st0;
Frédéric Lécaille3f0fb9d2019-01-25 08:30:29 +01002569 reql = peer_getline_host(appctx);
2570 if (reql <= 0) {
2571 if (!reql)
2572 goto out;
Emeric Brun2b920a12010-09-23 18:30:22 +02002573 goto switchstate;
2574 }
2575
Willy Tarreaue4d927a2013-12-01 12:47:35 +01002576 appctx->st0 = PEER_SESS_ST_GETPEER;
Emeric Brun2b920a12010-09-23 18:30:22 +02002577 /* fall through */
Willy Tarreaue4d927a2013-12-01 12:47:35 +01002578 case PEER_SESS_ST_GETPEER: {
Willy Tarreau2d372c22018-11-05 17:12:27 +01002579 prev_state = appctx->st0;
Frédéric Lécaille3f0fb9d2019-01-25 08:30:29 +01002580 reql = peer_getline_last(appctx, &curpeer);
2581 if (reql <= 0) {
2582 if (!reql)
2583 goto out;
Emeric Brun2b920a12010-09-23 18:30:22 +02002584 goto switchstate;
2585 }
Emeric Brun2b920a12010-09-23 18:30:22 +02002586
Christopher Faulet2a944ee2017-11-07 10:42:54 +01002587 HA_SPIN_LOCK(PEER_LOCK, &curpeer->lock);
Willy Tarreau9df94c22016-10-31 18:42:52 +01002588 if (curpeer->appctx && curpeer->appctx != appctx) {
Emeric Brunb3971ab2015-05-12 18:49:09 +02002589 if (curpeer->local) {
2590 /* Local connection, reply a retry */
2591 appctx->st0 = PEER_SESS_ST_EXIT;
2592 appctx->st1 = PEER_SESS_SC_TRYAGAIN;
2593 goto switchstate;
Emeric Brun2b920a12010-09-23 18:30:22 +02002594 }
Emeric Brun80527f52017-06-19 17:46:37 +02002595
2596 /* we're killing a connection, we must apply a random delay before
2597 * retrying otherwise the other end will do the same and we can loop
2598 * for a while.
2599 */
Willy Tarreau52bf8392020-03-08 00:42:37 +01002600 curpeer->reconnect = tick_add(now_ms, MS_TO_TICKS(50 + ha_random() % 2000));
Emeric Brun9ef2ad72019-04-02 17:22:01 +02002601 peer_session_forceshutdown(curpeer);
Frédéric Lécaillebaeb9192020-10-14 11:50:26 +02002602 curpeer->heartbeat = TICK_ETERNITY;
Frédéric Lécaille3fc0fe02020-10-08 09:46:24 +02002603 curpeer->coll++;
Emeric Brun2b920a12010-09-23 18:30:22 +02002604 }
Frédéric Lécaille523cc9e2016-10-12 17:30:30 +02002605 if (maj_ver != (unsigned int)-1 && min_ver != (unsigned int)-1) {
2606 if (min_ver == PEER_DWNGRD_MINOR_VER) {
2607 curpeer->flags |= PEER_F_DWNGRD;
2608 }
2609 else {
2610 curpeer->flags &= ~PEER_F_DWNGRD;
2611 }
2612 }
Emeric Brunb3971ab2015-05-12 18:49:09 +02002613 curpeer->appctx = appctx;
Frédéric Lécaillebaeb9192020-10-14 11:50:26 +02002614 curpeer->flags |= PEER_F_ALIVE;
Emeric Brunb3971ab2015-05-12 18:49:09 +02002615 appctx->ctx.peers.ptr = curpeer;
Willy Tarreaue4d927a2013-12-01 12:47:35 +01002616 appctx->st0 = PEER_SESS_ST_SENDSUCCESS;
Willy Tarreau4781b152021-04-06 13:53:36 +02002617 _HA_ATOMIC_INC(&active_peers);
Emeric Brun2b920a12010-09-23 18:30:22 +02002618 }
Tim Duesterhus588b3142020-05-29 14:35:51 +02002619 /* fall through */
Willy Tarreaue4d927a2013-12-01 12:47:35 +01002620 case PEER_SESS_ST_SENDSUCCESS: {
Willy Tarreau2d372c22018-11-05 17:12:27 +01002621 prev_state = appctx->st0;
Emeric Brun80527f52017-06-19 17:46:37 +02002622 if (!curpeer) {
2623 curpeer = appctx->ctx.peers.ptr;
Christopher Faulet2a944ee2017-11-07 10:42:54 +01002624 HA_SPIN_LOCK(PEER_LOCK, &curpeer->lock);
Emeric Brun80527f52017-06-19 17:46:37 +02002625 if (curpeer->appctx != appctx) {
2626 appctx->st0 = PEER_SESS_ST_END;
2627 goto switchstate;
2628 }
2629 }
Frédéric Lécaille7d0ceee2019-01-24 14:24:05 +01002630
2631 repl = peer_send_status_successmsg(appctx);
Emeric Brun2b920a12010-09-23 18:30:22 +02002632 if (repl <= 0) {
2633 if (repl == -1)
Frédéric Lécaille7d0ceee2019-01-24 14:24:05 +01002634 goto out;
Emeric Brun2b920a12010-09-23 18:30:22 +02002635 goto switchstate;
2636 }
2637
Frédéric Lécaille4b2fd9b2019-01-25 08:58:41 +01002638 init_accepted_peer(curpeer, curpeers);
Emeric Brunb3971ab2015-05-12 18:49:09 +02002639
Emeric Brun2b920a12010-09-23 18:30:22 +02002640 /* switch to waiting message state */
Willy Tarreau4781b152021-04-06 13:53:36 +02002641 _HA_ATOMIC_INC(&connected_peers);
Willy Tarreaue4d927a2013-12-01 12:47:35 +01002642 appctx->st0 = PEER_SESS_ST_WAITMSG;
Emeric Brun2b920a12010-09-23 18:30:22 +02002643 goto switchstate;
2644 }
Willy Tarreaue4d927a2013-12-01 12:47:35 +01002645 case PEER_SESS_ST_CONNECT: {
Willy Tarreau2d372c22018-11-05 17:12:27 +01002646 prev_state = appctx->st0;
Emeric Brun80527f52017-06-19 17:46:37 +02002647 if (!curpeer) {
2648 curpeer = appctx->ctx.peers.ptr;
Christopher Faulet2a944ee2017-11-07 10:42:54 +01002649 HA_SPIN_LOCK(PEER_LOCK, &curpeer->lock);
Emeric Brun80527f52017-06-19 17:46:37 +02002650 if (curpeer->appctx != appctx) {
2651 appctx->st0 = PEER_SESS_ST_END;
2652 goto switchstate;
2653 }
2654 }
Emeric Brun2b920a12010-09-23 18:30:22 +02002655
Frédéric Lécaille7d0ceee2019-01-24 14:24:05 +01002656 repl = peer_send_hellomsg(appctx, curpeer);
Emeric Brun2b920a12010-09-23 18:30:22 +02002657 if (repl <= 0) {
2658 if (repl == -1)
Frédéric Lécaille7d0ceee2019-01-24 14:24:05 +01002659 goto out;
Emeric Brun2b920a12010-09-23 18:30:22 +02002660 goto switchstate;
2661 }
2662
2663 /* switch to the waiting statuscode state */
Willy Tarreaue4d927a2013-12-01 12:47:35 +01002664 appctx->st0 = PEER_SESS_ST_GETSTATUS;
Emeric Brun2b920a12010-09-23 18:30:22 +02002665 }
Tim Duesterhus588b3142020-05-29 14:35:51 +02002666 /* fall through */
Willy Tarreaue4d927a2013-12-01 12:47:35 +01002667 case PEER_SESS_ST_GETSTATUS: {
Willy Tarreau2d372c22018-11-05 17:12:27 +01002668 prev_state = appctx->st0;
Emeric Brun80527f52017-06-19 17:46:37 +02002669 if (!curpeer) {
2670 curpeer = appctx->ctx.peers.ptr;
Christopher Faulet2a944ee2017-11-07 10:42:54 +01002671 HA_SPIN_LOCK(PEER_LOCK, &curpeer->lock);
Emeric Brun80527f52017-06-19 17:46:37 +02002672 if (curpeer->appctx != appctx) {
2673 appctx->st0 = PEER_SESS_ST_END;
2674 goto switchstate;
2675 }
2676 }
2677
Christopher Faulet3c053242022-07-27 10:49:31 +02002678 if (si_ic(si)->flags & CF_WROTE_DATA)
Emeric Brunb3971ab2015-05-12 18:49:09 +02002679 curpeer->statuscode = PEER_SESS_SC_CONNECTEDCODE;
Emeric Brun2b920a12010-09-23 18:30:22 +02002680
Frédéric Lécaillece025572019-01-21 13:38:06 +01002681 reql = peer_getline(appctx);
2682 if (!reql)
2683 goto out;
Emeric Brun2b920a12010-09-23 18:30:22 +02002684
Frédéric Lécaillece025572019-01-21 13:38:06 +01002685 if (reql < 0)
2686 goto switchstate;
Emeric Brun2b920a12010-09-23 18:30:22 +02002687
2688 /* Register status code */
Willy Tarreau843b7cb2018-07-13 10:54:26 +02002689 curpeer->statuscode = atoi(trash.area);
Frédéric Lécaille3fc0fe02020-10-08 09:46:24 +02002690 curpeer->last_hdshk = now_ms;
Emeric Brun2b920a12010-09-23 18:30:22 +02002691
2692 /* Awake main task */
Frédéric Lécailleed2b4a62017-07-13 09:07:09 +02002693 task_wakeup(curpeers->sync_task, TASK_WOKEN_MSG);
Emeric Brun2b920a12010-09-23 18:30:22 +02002694
2695 /* If status code is success */
Emeric Brunb3971ab2015-05-12 18:49:09 +02002696 if (curpeer->statuscode == PEER_SESS_SC_SUCCESSCODE) {
Frédéric Lécaille4b2fd9b2019-01-25 08:58:41 +01002697 init_connected_peer(curpeer, curpeers);
Emeric Brun2b920a12010-09-23 18:30:22 +02002698 }
2699 else {
Frédéric Lécaille523cc9e2016-10-12 17:30:30 +02002700 if (curpeer->statuscode == PEER_SESS_SC_ERRVERSION)
2701 curpeer->flags |= PEER_F_DWNGRD;
Emeric Brun2b920a12010-09-23 18:30:22 +02002702 /* Status code is not success, abort */
Willy Tarreaue4d927a2013-12-01 12:47:35 +01002703 appctx->st0 = PEER_SESS_ST_END;
Emeric Brun2b920a12010-09-23 18:30:22 +02002704 goto switchstate;
2705 }
Willy Tarreau4781b152021-04-06 13:53:36 +02002706 _HA_ATOMIC_INC(&connected_peers);
Willy Tarreaue4d927a2013-12-01 12:47:35 +01002707 appctx->st0 = PEER_SESS_ST_WAITMSG;
Emeric Brun2b920a12010-09-23 18:30:22 +02002708 }
Tim Duesterhus588b3142020-05-29 14:35:51 +02002709 /* fall through */
Willy Tarreaue4d927a2013-12-01 12:47:35 +01002710 case PEER_SESS_ST_WAITMSG: {
Emeric Brunb3971ab2015-05-12 18:49:09 +02002711 uint32_t msg_len = 0;
Willy Tarreau843b7cb2018-07-13 10:54:26 +02002712 char *msg_cur = trash.area;
2713 char *msg_end = trash.area;
Willy Tarreau1dfd4f12020-11-13 14:10:20 +01002714 unsigned char msg_head[7]; // 2 + 5 for varint32
Emeric Brun2b920a12010-09-23 18:30:22 +02002715 int totl = 0;
2716
Willy Tarreau2d372c22018-11-05 17:12:27 +01002717 prev_state = appctx->st0;
Emeric Brun80527f52017-06-19 17:46:37 +02002718 if (!curpeer) {
2719 curpeer = appctx->ctx.peers.ptr;
Christopher Faulet2a944ee2017-11-07 10:42:54 +01002720 HA_SPIN_LOCK(PEER_LOCK, &curpeer->lock);
Emeric Brun80527f52017-06-19 17:46:37 +02002721 if (curpeer->appctx != appctx) {
2722 appctx->st0 = PEER_SESS_ST_END;
2723 goto switchstate;
2724 }
2725 }
2726
Frédéric Lécaille95203f22019-01-23 19:38:11 +01002727 reql = peer_recv_msg(appctx, (char *)msg_head, sizeof msg_head, &msg_len, &totl);
2728 if (reql <= 0) {
2729 if (reql == -1)
2730 goto switchstate;
Frédéric Lécaillebe825e52019-01-24 18:28:44 +01002731 goto send_msgs;
Emeric Brunb3971ab2015-05-12 18:49:09 +02002732 }
Willy Tarreau86a446e2013-11-25 23:02:37 +01002733
Frédéric Lécaille95203f22019-01-23 19:38:11 +01002734 msg_end += msg_len;
Frédéric Lécaille444243c2019-01-24 15:40:11 +01002735 if (!peer_treat_awaited_msg(appctx, curpeer, msg_head, &msg_cur, msg_end, msg_len, totl))
Emeric Brun2b920a12010-09-23 18:30:22 +02002736 goto switchstate;
Frédéric Lécaillebe825e52019-01-24 18:28:44 +01002737
Frédéric Lécaille045e0d42019-03-21 11:12:32 +01002738 curpeer->flags |= PEER_F_ALIVE;
2739
Emeric Brun2b920a12010-09-23 18:30:22 +02002740 /* skip consumed message */
Willy Tarreau06d80a92017-10-19 14:32:15 +02002741 co_skip(si_oc(si), totl);
Emeric Brun2b920a12010-09-23 18:30:22 +02002742 /* loop on that state to peek next message */
Willy Tarreau72d6c162013-04-11 16:14:13 +02002743 goto switchstate;
2744
Frédéric Lécaillebe825e52019-01-24 18:28:44 +01002745send_msgs:
Frédéric Lécaille645635d2019-02-11 17:49:39 +01002746 if (curpeer->flags & PEER_F_HEARTBEAT) {
2747 curpeer->flags &= ~PEER_F_HEARTBEAT;
Frédéric Lécailleda2b0842021-01-15 16:21:28 +01002748 repl = peer_send_heartbeatmsg(appctx, curpeer, curpeers);
Frédéric Lécaille645635d2019-02-11 17:49:39 +01002749 if (repl <= 0) {
2750 if (repl == -1)
2751 goto out;
2752 goto switchstate;
2753 }
Frédéric Lécaille33cab3c2019-11-06 11:51:26 +01002754 curpeer->tx_hbt++;
Frédéric Lécaille645635d2019-02-11 17:49:39 +01002755 }
Frédéric Lécaillebe825e52019-01-24 18:28:44 +01002756 /* we get here when a peer_recv_msg() returns 0 in reql */
Frédéric Lécailleda2b0842021-01-15 16:21:28 +01002757 repl = peer_send_msgs(appctx, curpeer, curpeers);
Frédéric Lécaille25e1d5e2019-01-24 17:33:48 +01002758 if (repl <= 0) {
2759 if (repl == -1)
2760 goto out;
2761 goto switchstate;
Emeric Brun597b26e2016-08-12 11:23:31 +02002762 }
2763
Emeric Brun2b920a12010-09-23 18:30:22 +02002764 /* noting more to do */
2765 goto out;
2766 }
Willy Tarreaue4d927a2013-12-01 12:47:35 +01002767 case PEER_SESS_ST_EXIT:
Willy Tarreau2d372c22018-11-05 17:12:27 +01002768 if (prev_state == PEER_SESS_ST_WAITMSG)
Willy Tarreau4781b152021-04-06 13:53:36 +02002769 _HA_ATOMIC_DEC(&connected_peers);
Willy Tarreau2d372c22018-11-05 17:12:27 +01002770 prev_state = appctx->st0;
Frédéric Lécaille7d0ceee2019-01-24 14:24:05 +01002771 if (peer_send_status_errormsg(appctx) == -1)
2772 goto out;
Willy Tarreaue4d927a2013-12-01 12:47:35 +01002773 appctx->st0 = PEER_SESS_ST_END;
Emeric Brunb3971ab2015-05-12 18:49:09 +02002774 goto switchstate;
2775 case PEER_SESS_ST_ERRSIZE: {
Willy Tarreau2d372c22018-11-05 17:12:27 +01002776 if (prev_state == PEER_SESS_ST_WAITMSG)
Willy Tarreau4781b152021-04-06 13:53:36 +02002777 _HA_ATOMIC_DEC(&connected_peers);
Willy Tarreau2d372c22018-11-05 17:12:27 +01002778 prev_state = appctx->st0;
Frédéric Lécaille7d0ceee2019-01-24 14:24:05 +01002779 if (peer_send_error_size_limitmsg(appctx) == -1)
2780 goto out;
Emeric Brunb3971ab2015-05-12 18:49:09 +02002781 appctx->st0 = PEER_SESS_ST_END;
2782 goto switchstate;
2783 }
2784 case PEER_SESS_ST_ERRPROTO: {
Frédéric Lécailleda2b0842021-01-15 16:21:28 +01002785 TRACE_PROTO("protocol error", PEERS_EV_PROTOERR,
2786 NULL, curpeer, &prev_state);
Frédéric Lécailleec1c10b2019-11-07 15:22:33 +01002787 if (curpeer)
2788 curpeer->proto_err++;
Willy Tarreau2d372c22018-11-05 17:12:27 +01002789 if (prev_state == PEER_SESS_ST_WAITMSG)
Willy Tarreau4781b152021-04-06 13:53:36 +02002790 _HA_ATOMIC_DEC(&connected_peers);
Willy Tarreau2d372c22018-11-05 17:12:27 +01002791 prev_state = appctx->st0;
Frédéric Lécailleda2b0842021-01-15 16:21:28 +01002792 if (peer_send_error_protomsg(appctx) == -1) {
2793 TRACE_PROTO("could not send error message", PEERS_EV_PROTOERR);
Frédéric Lécaille7d0ceee2019-01-24 14:24:05 +01002794 goto out;
Frédéric Lécailleda2b0842021-01-15 16:21:28 +01002795 }
Emeric Brunb3971ab2015-05-12 18:49:09 +02002796 appctx->st0 = PEER_SESS_ST_END;
Willy Tarreau2d372c22018-11-05 17:12:27 +01002797 prev_state = appctx->st0;
Emeric Brunb3971ab2015-05-12 18:49:09 +02002798 }
Tim Duesterhus588b3142020-05-29 14:35:51 +02002799 /* fall through */
Willy Tarreaue4d927a2013-12-01 12:47:35 +01002800 case PEER_SESS_ST_END: {
Willy Tarreau2d372c22018-11-05 17:12:27 +01002801 if (prev_state == PEER_SESS_ST_WAITMSG)
Willy Tarreau4781b152021-04-06 13:53:36 +02002802 _HA_ATOMIC_DEC(&connected_peers);
Willy Tarreau2d372c22018-11-05 17:12:27 +01002803 prev_state = appctx->st0;
Emeric Brun80527f52017-06-19 17:46:37 +02002804 if (curpeer) {
Christopher Faulet2a944ee2017-11-07 10:42:54 +01002805 HA_SPIN_UNLOCK(PEER_LOCK, &curpeer->lock);
Emeric Brun80527f52017-06-19 17:46:37 +02002806 curpeer = NULL;
2807 }
Willy Tarreau73b013b2012-05-21 16:31:45 +02002808 si_shutw(si);
2809 si_shutr(si);
Willy Tarreau2bb4a962014-11-28 11:11:05 +01002810 si_ic(si)->flags |= CF_READ_NULL;
Willy Tarreau828824a2015-04-19 17:20:03 +02002811 goto out;
Emeric Brun2b920a12010-09-23 18:30:22 +02002812 }
2813 }
2814 }
2815out:
Willy Tarreau2bb4a962014-11-28 11:11:05 +01002816 si_oc(si)->flags |= CF_READ_DONTWAIT;
Emeric Brun80527f52017-06-19 17:46:37 +02002817
2818 if (curpeer)
Christopher Faulet2a944ee2017-11-07 10:42:54 +01002819 HA_SPIN_UNLOCK(PEER_LOCK, &curpeer->lock);
Emeric Brun2b920a12010-09-23 18:30:22 +02002820 return;
2821}
2822
Willy Tarreau30576452015-04-13 13:50:30 +02002823static struct applet peer_applet = {
Willy Tarreau3fdb3662012-11-12 00:42:33 +01002824 .obj_type = OBJ_TYPE_APPLET,
Willy Tarreaub24281b2011-02-13 13:16:36 +01002825 .name = "<PEER>", /* used for logging */
2826 .fct = peer_io_handler,
Aman Gupta9a13e842012-04-02 18:57:53 -07002827 .release = peer_session_release,
Willy Tarreaub24281b2011-02-13 13:16:36 +01002828};
Emeric Brun2b920a12010-09-23 18:30:22 +02002829
Emeric Brun9ef2ad72019-04-02 17:22:01 +02002830
Emeric Brun2b920a12010-09-23 18:30:22 +02002831/*
2832 * Use this function to force a close of a peer session
2833 */
Emeric Brun9ef2ad72019-04-02 17:22:01 +02002834static void peer_session_forceshutdown(struct peer *peer)
Emeric Brun2b920a12010-09-23 18:30:22 +02002835{
Emeric Brun9ef2ad72019-04-02 17:22:01 +02002836 struct appctx *appctx = peer->appctx;
2837
Frédéric Lécaille5df11902017-06-13 16:39:57 +02002838 /* Note that the peer sessions which have just been created
2839 * (->st0 == PEER_SESS_ST_CONNECT) must not
2840 * be shutdown, if not, the TCP session will never be closed
2841 * and stay in CLOSE_WAIT state after having been closed by
2842 * the remote side.
2843 */
2844 if (!appctx || appctx->st0 == PEER_SESS_ST_CONNECT)
Willy Tarreau7b4b4992013-12-01 09:15:12 +01002845 return;
2846
Willy Tarreau81bc3b02016-10-31 17:37:39 +01002847 if (appctx->applet != &peer_applet)
2848 return;
2849
Emeric Brun9ef2ad72019-04-02 17:22:01 +02002850 __peer_session_deinit(peer);
2851
Willy Tarreaue4d927a2013-12-01 12:47:35 +01002852 appctx->st0 = PEER_SESS_ST_END;
Willy Tarreau78c0c502016-10-31 17:32:20 +01002853 appctx_wakeup(appctx);
Emeric Brun2b920a12010-09-23 18:30:22 +02002854}
2855
Willy Tarreau91d96282015-03-13 15:47:26 +01002856/* Pre-configures a peers frontend to accept incoming connections */
2857void peers_setup_frontend(struct proxy *fe)
2858{
2859 fe->last_change = now.tv_sec;
Frédéric Lécaillec06b5d42018-04-26 10:06:41 +02002860 fe->cap = PR_CAP_FE | PR_CAP_BE;
Willy Tarreaua389c9e2020-10-07 17:49:42 +02002861 fe->mode = PR_MODE_PEERS;
Willy Tarreau91d96282015-03-13 15:47:26 +01002862 fe->maxconn = 0;
2863 fe->conn_retries = CONN_RETRIES;
Christopher Faulet2d370282022-08-29 11:32:26 +02002864 fe->timeout.connect = MS_TO_TICKS(1000);
Willy Tarreau91d96282015-03-13 15:47:26 +01002865 fe->timeout.client = MS_TO_TICKS(5000);
Christopher Faulet2d370282022-08-29 11:32:26 +02002866 fe->timeout.server = MS_TO_TICKS(5000);
Willy Tarreaud1d48d42015-03-13 16:15:46 +01002867 fe->accept = frontend_accept;
Willy Tarreauf87ab942015-03-13 15:55:16 +01002868 fe->default_target = &peer_applet.obj_type;
Willy Tarreau91d96282015-03-13 15:47:26 +01002869 fe->options2 |= PR_O2_INDEPSTR | PR_O2_SMARTCON | PR_O2_SMARTACC;
Willy Tarreau0fca4832015-05-01 19:12:05 +02002870 fe->bind_proc = 0; /* will be filled by users */
Willy Tarreau91d96282015-03-13 15:47:26 +01002871}
2872
Emeric Brun2b920a12010-09-23 18:30:22 +02002873/*
Willy Tarreaubd55e312010-11-11 10:55:09 +01002874 * Create a new peer session in assigned state (connect will start automatically)
Emeric Brun2b920a12010-09-23 18:30:22 +02002875 */
Willy Tarreau9df94c22016-10-31 18:42:52 +01002876static struct appctx *peer_session_create(struct peers *peers, struct peer *peer)
Emeric Brun2b920a12010-09-23 18:30:22 +02002877{
Willy Tarreau04b92862017-09-15 11:01:04 +02002878 struct proxy *p = peers->peers_fe; /* attached frontend */
Willy Tarreau7b4b4992013-12-01 09:15:12 +01002879 struct appctx *appctx;
Willy Tarreau15b5e142015-04-04 14:38:25 +02002880 struct session *sess;
Willy Tarreau87b09662015-04-03 00:22:06 +02002881 struct stream *s;
Emeric Brun2b920a12010-09-23 18:30:22 +02002882
Frédéric Lécaille2b0ba542021-01-18 15:14:39 +01002883 peer->new_conn++;
Christopher Fauletd73a5cc2022-07-26 19:14:36 +02002884 peer->reconnect = tick_add(now_ms, (stopping ? MS_TO_TICKS(PEER_LOCAL_RECONNECT_TIMEOUT) : MS_TO_TICKS(PEER_RECONNECT_TIMEOUT)));
Frédéric Lécaillebaeb9192020-10-14 11:50:26 +02002885 peer->heartbeat = TICK_ETERNITY;
Emeric Brunb3971ab2015-05-12 18:49:09 +02002886 peer->statuscode = PEER_SESS_SC_CONNECTCODE;
Frédéric Lécaille3fc0fe02020-10-08 09:46:24 +02002887 peer->last_hdshk = now_ms;
Willy Tarreaud990baf2015-04-05 00:32:03 +02002888 s = NULL;
2889
Emeric Brun1138fd02017-06-19 12:38:55 +02002890 appctx = appctx_new(&peer_applet, tid_bit);
Willy Tarreaud990baf2015-04-05 00:32:03 +02002891 if (!appctx)
2892 goto out_close;
2893
2894 appctx->st0 = PEER_SESS_ST_CONNECT;
Emeric Brunb3971ab2015-05-12 18:49:09 +02002895 appctx->ctx.peers.ptr = (void *)peer;
Willy Tarreaud990baf2015-04-05 00:32:03 +02002896
Willy Tarreau04b92862017-09-15 11:01:04 +02002897 sess = session_new(p, NULL, &appctx->obj_type);
Willy Tarreau15b5e142015-04-04 14:38:25 +02002898 if (!sess) {
Christopher Faulet767a84b2017-11-24 16:50:31 +01002899 ha_alert("out of memory in peer_session_create().\n");
Willy Tarreaud990baf2015-04-05 00:32:03 +02002900 goto out_free_appctx;
Emeric Brun2b920a12010-09-23 18:30:22 +02002901 }
2902
Christopher Faulet26256f82020-09-14 11:40:13 +02002903 if ((s = stream_new(sess, &appctx->obj_type, &BUF_NULL)) == NULL) {
Christopher Faulet767a84b2017-11-24 16:50:31 +01002904 ha_alert("Failed to initialize stream in peer_session_create().\n");
Willy Tarreau87787ac2017-08-28 16:22:54 +02002905 goto out_free_sess;
Willy Tarreau8baf9062015-04-05 00:46:36 +02002906 }
2907
Willy Tarreau6e2979c2015-04-27 13:21:15 +02002908 /* applet is waiting for data */
Willy Tarreau0cd3bd62018-11-06 18:46:37 +01002909 si_cant_get(&s->si[0]);
Willy Tarreau6e2979c2015-04-27 13:21:15 +02002910 appctx_wakeup(appctx);
2911
Willy Tarreau3ed35ef2013-10-24 11:51:38 +02002912 /* initiate an outgoing connection */
Willy Tarreau1c8d32b2019-07-18 15:47:45 +02002913 s->target = peer_session_target(peer, s);
Willy Tarreau9b7587a2020-10-15 07:32:10 +02002914 if (!sockaddr_alloc(&s->target_addr, &peer->addr, sizeof(peer->addr)))
Willy Tarreau1c8d32b2019-07-18 15:47:45 +02002915 goto out_free_strm;
Willy Tarreau02efeda2019-07-18 17:21:24 +02002916 s->flags = SF_ASSIGNED|SF_ADDR_SET;
Willy Tarreaudbd02672017-12-06 17:39:53 +01002917 s->si[1].flags |= SI_FL_NOLINGER;
Willy Tarreau32e3c6a2013-10-11 19:34:20 +02002918
Emeric Brun2b920a12010-09-23 18:30:22 +02002919 s->do_log = NULL;
Emeric Brun2b920a12010-09-23 18:30:22 +02002920 s->uniq_id = 0;
Emeric Brun2b920a12010-09-23 18:30:22 +02002921
Willy Tarreau22ec1ea2014-11-27 20:45:39 +01002922 s->res.flags |= CF_READ_DONTWAIT;
Willy Tarreau696a2912014-11-24 11:36:57 +01002923
Emeric Brunb3971ab2015-05-12 18:49:09 +02002924 peer->appctx = appctx;
Willy Tarreau87787ac2017-08-28 16:22:54 +02002925 task_wakeup(s->task, TASK_WOKEN_INIT);
Willy Tarreau4781b152021-04-06 13:53:36 +02002926 _HA_ATOMIC_INC(&active_peers);
Willy Tarreau9df94c22016-10-31 18:42:52 +01002927 return appctx;
Emeric Brun2b920a12010-09-23 18:30:22 +02002928
2929 /* Error unrolling */
Willy Tarreau15b5e142015-04-04 14:38:25 +02002930 out_free_strm:
Willy Tarreau2b718102021-04-21 07:32:39 +02002931 LIST_DELETE(&s->list);
Willy Tarreaubafbe012017-11-24 17:34:44 +01002932 pool_free(pool_head_stream, s);
Willy Tarreau15b5e142015-04-04 14:38:25 +02002933 out_free_sess:
Willy Tarreau11c36242015-04-04 15:54:03 +02002934 session_free(sess);
Willy Tarreaud990baf2015-04-05 00:32:03 +02002935 out_free_appctx:
2936 appctx_free(appctx);
Emeric Brun2b920a12010-09-23 18:30:22 +02002937 out_close:
Willy Tarreaub21d08e2016-10-31 17:46:57 +01002938 return NULL;
Emeric Brun2b920a12010-09-23 18:30:22 +02002939}
2940
2941/*
Frédéric Lécaille645635d2019-02-11 17:49:39 +01002942 * Task processing function to manage re-connect, peer session
Willy Tarreauf6c88422021-01-29 12:38:42 +01002943 * tasks wakeup on local update and heartbeat. Let's keep it exported so that it
2944 * resolves in stack traces and "show tasks".
Emeric Brun2b920a12010-09-23 18:30:22 +02002945 */
Willy Tarreau144f84a2021-03-02 16:09:26 +01002946struct task *process_peer_sync(struct task * task, void *context, unsigned int state)
Emeric Brun2b920a12010-09-23 18:30:22 +02002947{
Olivier Houchard9f6af332018-05-25 14:04:04 +02002948 struct peers *peers = context;
Emeric Brunb3971ab2015-05-12 18:49:09 +02002949 struct peer *ps;
2950 struct shared_table *st;
Emeric Brun2b920a12010-09-23 18:30:22 +02002951
2952 task->expire = TICK_ETERNITY;
2953
Emeric Brunb3971ab2015-05-12 18:49:09 +02002954 if (!peers->peers_fe) {
Willy Tarreau46dc1ca2015-05-01 18:32:13 +02002955 /* this one was never started, kill it */
Emeric Brunb3971ab2015-05-12 18:49:09 +02002956 signal_unregister_handler(peers->sighandler);
Olivier Houchard3f795f72019-04-17 22:51:06 +02002957 task_destroy(peers->sync_task);
Willy Tarreau37bb7be2015-09-21 15:24:58 +02002958 peers->sync_task = NULL;
Willy Tarreau46dc1ca2015-05-01 18:32:13 +02002959 return NULL;
2960 }
2961
Emeric Brun80527f52017-06-19 17:46:37 +02002962 /* Acquire lock for all peers of the section */
2963 for (ps = peers->remote; ps; ps = ps->next)
Christopher Faulet2a944ee2017-11-07 10:42:54 +01002964 HA_SPIN_LOCK(PEER_LOCK, &ps->lock);
Emeric Brun80527f52017-06-19 17:46:37 +02002965
Emeric Brun2b920a12010-09-23 18:30:22 +02002966 if (!stopping) {
2967 /* Normal case (not soft stop)*/
Emeric Brunb3971ab2015-05-12 18:49:09 +02002968
Emeric Brun2c4ab412021-04-21 16:06:35 +02002969 /* resync timeout set to TICK_ETERNITY means we just start
2970 * a new process and timer was not initialized.
2971 * We must arm this timer to switch to a request to a remote
2972 * node if incoming connection from old local process never
2973 * comes.
2974 */
2975 if (peers->resync_timeout == TICK_ETERNITY)
2976 peers->resync_timeout = tick_add(now_ms, MS_TO_TICKS(PEER_RESYNC_TIMEOUT));
2977
Emeric Brunb3971ab2015-05-12 18:49:09 +02002978 if (((peers->flags & PEERS_RESYNC_STATEMASK) == PEERS_RESYNC_FROMLOCAL) &&
2979 (!nb_oldpids || tick_is_expired(peers->resync_timeout, now_ms)) &&
2980 !(peers->flags & PEERS_F_RESYNC_ASSIGN)) {
Emeric Brun2b920a12010-09-23 18:30:22 +02002981 /* Resync from local peer needed
2982 no peer was assigned for the lesson
2983 and no old local peer found
2984 or resync timeout expire */
2985
2986 /* flag no more resync from local, to try resync from remotes */
Emeric Brunb3971ab2015-05-12 18:49:09 +02002987 peers->flags |= PEERS_F_RESYNC_LOCAL;
Emeric Brunccdfbae2021-04-28 12:59:35 +02002988 peers->flags |= PEERS_F_RESYNC_LOCALTIMEOUT;
Emeric Brun2b920a12010-09-23 18:30:22 +02002989
2990 /* reschedule a resync */
Frédéric Lécaille54bff832019-03-26 10:25:20 +01002991 peers->resync_timeout = tick_add(now_ms, MS_TO_TICKS(PEER_RESYNC_TIMEOUT));
Emeric Brun2b920a12010-09-23 18:30:22 +02002992 }
2993
2994 /* For each session */
Emeric Brunb3971ab2015-05-12 18:49:09 +02002995 for (ps = peers->remote; ps; ps = ps->next) {
Emeric Brun2b920a12010-09-23 18:30:22 +02002996 /* For each remote peers */
Emeric Brunb3971ab2015-05-12 18:49:09 +02002997 if (!ps->local) {
Willy Tarreau9df94c22016-10-31 18:42:52 +01002998 if (!ps->appctx) {
2999 /* no active peer connection */
Emeric Brun2b920a12010-09-23 18:30:22 +02003000 if (ps->statuscode == 0 ||
Willy Tarreaue4d927a2013-12-01 12:47:35 +01003001 ((ps->statuscode == PEER_SESS_SC_CONNECTCODE ||
Willy Tarreaub4e34da2015-05-20 10:39:04 +02003002 ps->statuscode == PEER_SESS_SC_SUCCESSCODE ||
Willy Tarreaue4d927a2013-12-01 12:47:35 +01003003 ps->statuscode == PEER_SESS_SC_CONNECTEDCODE) &&
Emeric Brun2b920a12010-09-23 18:30:22 +02003004 tick_is_expired(ps->reconnect, now_ms))) {
3005 /* connection never tried
Willy Tarreau9df94c22016-10-31 18:42:52 +01003006 * or previous peer connection established with success
3007 * or previous peer connection failed while connecting
Emeric Brun2b920a12010-09-23 18:30:22 +02003008 * and reconnection timer is expired */
3009
3010 /* retry a connect */
Willy Tarreau9df94c22016-10-31 18:42:52 +01003011 ps->appctx = peer_session_create(peers, ps);
Emeric Brun2b920a12010-09-23 18:30:22 +02003012 }
Willy Tarreaub4e34da2015-05-20 10:39:04 +02003013 else if (!tick_is_expired(ps->reconnect, now_ms)) {
Emeric Brun2b920a12010-09-23 18:30:22 +02003014 /* If previous session failed during connection
3015 * but reconnection timer is not expired */
3016
3017 /* reschedule task for reconnect */
3018 task->expire = tick_first(task->expire, ps->reconnect);
3019 }
3020 /* else do nothing */
Willy Tarreau9df94c22016-10-31 18:42:52 +01003021 } /* !ps->appctx */
Willy Tarreaue4d927a2013-12-01 12:47:35 +01003022 else if (ps->statuscode == PEER_SESS_SC_SUCCESSCODE) {
Willy Tarreau9df94c22016-10-31 18:42:52 +01003023 /* current peer connection is active and established */
Emeric Brunb3971ab2015-05-12 18:49:09 +02003024 if (((peers->flags & PEERS_RESYNC_STATEMASK) == PEERS_RESYNC_FROMREMOTE) &&
3025 !(peers->flags & PEERS_F_RESYNC_ASSIGN) &&
Emeric Brun2b920a12010-09-23 18:30:22 +02003026 !(ps->flags & PEER_F_LEARN_NOTUP2DATE)) {
3027 /* Resync from a remote is needed
3028 * and no peer was assigned for lesson
3029 * and current peer may be up2date */
3030
3031 /* assign peer for the lesson */
3032 ps->flags |= PEER_F_LEARN_ASSIGN;
Emeric Brunb3971ab2015-05-12 18:49:09 +02003033 peers->flags |= PEERS_F_RESYNC_ASSIGN;
Emeric Brunccdfbae2021-04-28 12:59:35 +02003034 peers->flags |= PEERS_F_RESYNC_REMOTEASSIGN;
Emeric Brun2b920a12010-09-23 18:30:22 +02003035
Willy Tarreau9df94c22016-10-31 18:42:52 +01003036 /* wake up peer handler to handle a request of resync */
Willy Tarreaue5843b32015-04-27 18:40:14 +02003037 appctx_wakeup(ps->appctx);
Emeric Brun2b920a12010-09-23 18:30:22 +02003038 }
Emeric Brunb3971ab2015-05-12 18:49:09 +02003039 else {
Frédéric Lécaille645635d2019-02-11 17:49:39 +01003040 int update_to_push = 0;
3041
Emeric Brunb3971ab2015-05-12 18:49:09 +02003042 /* Awake session if there is data to push */
3043 for (st = ps->tables; st ; st = st->next) {
Emeric Brun8e7a13e2021-04-28 11:48:15 +02003044 if (st->last_pushed != st->table->localupdate) {
Willy Tarreau9df94c22016-10-31 18:42:52 +01003045 /* wake up the peer handler to push local updates */
Frédéric Lécaille645635d2019-02-11 17:49:39 +01003046 update_to_push = 1;
Frédéric Lécaille045e0d42019-03-21 11:12:32 +01003047 /* There is no need to send a heartbeat message
3048 * when some updates must be pushed. The remote
3049 * peer will consider <ps> peer as alive when it will
3050 * receive these updates.
3051 */
Frédéric Lécaille645635d2019-02-11 17:49:39 +01003052 ps->flags &= ~PEER_F_HEARTBEAT;
Frédéric Lécaille045e0d42019-03-21 11:12:32 +01003053 /* Re-schedule another one later. */
Frédéric Lécaille645635d2019-02-11 17:49:39 +01003054 ps->heartbeat = tick_add(now_ms, MS_TO_TICKS(PEER_HEARTBEAT_TIMEOUT));
Frédéric Lécaille045e0d42019-03-21 11:12:32 +01003055 /* We are going to send updates, let's ensure we will
3056 * come back to send heartbeat messages or to reconnect.
3057 */
3058 task->expire = tick_first(ps->reconnect, ps->heartbeat);
Emeric Brunb3971ab2015-05-12 18:49:09 +02003059 appctx_wakeup(ps->appctx);
3060 break;
3061 }
3062 }
Frédéric Lécaille045e0d42019-03-21 11:12:32 +01003063 /* When there are updates to send we do not reconnect
3064 * and do not send heartbeat message either.
3065 */
3066 if (!update_to_push) {
3067 if (tick_is_expired(ps->reconnect, now_ms)) {
3068 if (ps->flags & PEER_F_ALIVE) {
3069 /* This peer was alive during a 'reconnect' period.
3070 * Flag it as not alive again for the next period.
3071 */
3072 ps->flags &= ~PEER_F_ALIVE;
Frédéric Lécaille54bff832019-03-26 10:25:20 +01003073 ps->reconnect = tick_add(now_ms, MS_TO_TICKS(PEER_RECONNECT_TIMEOUT));
Frédéric Lécaille045e0d42019-03-21 11:12:32 +01003074 }
3075 else {
Willy Tarreau52bf8392020-03-08 00:42:37 +01003076 ps->reconnect = tick_add(now_ms, MS_TO_TICKS(50 + ha_random() % 2000));
Frédéric Lécaillebaeb9192020-10-14 11:50:26 +02003077 ps->heartbeat = TICK_ETERNITY;
Emeric Brun9ef2ad72019-04-02 17:22:01 +02003078 peer_session_forceshutdown(ps);
Frédéric Lécailleec1c10b2019-11-07 15:22:33 +01003079 ps->no_hbt++;
Frédéric Lécaille045e0d42019-03-21 11:12:32 +01003080 }
3081 }
3082 else if (tick_is_expired(ps->heartbeat, now_ms)) {
3083 ps->heartbeat = tick_add(now_ms, MS_TO_TICKS(PEER_HEARTBEAT_TIMEOUT));
3084 ps->flags |= PEER_F_HEARTBEAT;
3085 appctx_wakeup(ps->appctx);
3086 }
Frédéric Lécailleb7405c12019-03-27 14:32:39 +01003087 task->expire = tick_first(ps->reconnect, ps->heartbeat);
Frédéric Lécaille645635d2019-02-11 17:49:39 +01003088 }
Emeric Brun2b920a12010-09-23 18:30:22 +02003089 }
3090 /* else do nothing */
3091 } /* SUCCESSCODE */
3092 } /* !ps->peer->local */
3093 } /* for */
3094
3095 /* Resync from remotes expired: consider resync is finished */
Emeric Brunb3971ab2015-05-12 18:49:09 +02003096 if (((peers->flags & PEERS_RESYNC_STATEMASK) == PEERS_RESYNC_FROMREMOTE) &&
3097 !(peers->flags & PEERS_F_RESYNC_ASSIGN) &&
3098 tick_is_expired(peers->resync_timeout, now_ms)) {
Emeric Brun2b920a12010-09-23 18:30:22 +02003099 /* Resync from remote peer needed
3100 * no peer was assigned for the lesson
3101 * and resync timeout expire */
3102
3103 /* flag no more resync from remote, consider resync is finished */
Emeric Brunb3971ab2015-05-12 18:49:09 +02003104 peers->flags |= PEERS_F_RESYNC_REMOTE;
Emeric Brunccdfbae2021-04-28 12:59:35 +02003105 peers->flags |= PEERS_F_RESYNC_REMOTETIMEOUT;
Emeric Brun2b920a12010-09-23 18:30:22 +02003106 }
3107
Emeric Brunb3971ab2015-05-12 18:49:09 +02003108 if ((peers->flags & PEERS_RESYNC_STATEMASK) != PEERS_RESYNC_FINISHED) {
Emeric Brun2b920a12010-09-23 18:30:22 +02003109 /* Resync not finished*/
Frédéric Lécaille5d6e5f82017-05-29 13:47:16 +02003110 /* reschedule task to resync timeout if not expired, to ended resync if needed */
3111 if (!tick_is_expired(peers->resync_timeout, now_ms))
3112 task->expire = tick_first(task->expire, peers->resync_timeout);
Emeric Brun2b920a12010-09-23 18:30:22 +02003113 }
3114 } /* !stopping */
3115 else {
3116 /* soft stop case */
Willy Tarreau086735a2018-11-05 15:09:47 +01003117 if (state & TASK_WOKEN_SIGNAL) {
Joseph Herlant82b2f542018-11-15 12:19:14 -08003118 /* We've just received the signal */
Emeric Brunb3971ab2015-05-12 18:49:09 +02003119 if (!(peers->flags & PEERS_F_DONOTSTOP)) {
Emeric Brun2b920a12010-09-23 18:30:22 +02003120 /* add DO NOT STOP flag if not present */
Willy Tarreau4781b152021-04-06 13:53:36 +02003121 _HA_ATOMIC_INC(&jobs);
Emeric Brunb3971ab2015-05-12 18:49:09 +02003122 peers->flags |= PEERS_F_DONOTSTOP;
Emeric Brun2b920a12010-09-23 18:30:22 +02003123
Emeric Bruncbfe5eb2021-04-22 18:20:37 +02003124 /* disconnect all connected peers to process a local sync
3125 * this must be done only the first time we are switching
3126 * in stopping state
Emeric Brun80527f52017-06-19 17:46:37 +02003127 */
Emeric Bruncbfe5eb2021-04-22 18:20:37 +02003128 for (ps = peers->remote; ps; ps = ps->next) {
3129 /* we're killing a connection, we must apply a random delay before
3130 * retrying otherwise the other end will do the same and we can loop
3131 * for a while.
3132 */
3133 ps->reconnect = tick_add(now_ms, MS_TO_TICKS(50 + ha_random() % 2000));
3134 if (ps->appctx) {
3135 peer_session_forceshutdown(ps);
3136 }
Emeric Brun2b920a12010-09-23 18:30:22 +02003137 }
Christopher Faulet1f8342f2022-07-26 19:19:18 +02003138
3139 /* Set resync timeout for the local peer and request a immediate reconnect */
3140 peers->resync_timeout = tick_add(now_ms, MS_TO_TICKS(PEER_RESYNC_TIMEOUT));
3141 peers->local->reconnect = now_ms;
Emeric Brun2b920a12010-09-23 18:30:22 +02003142 }
3143 }
Emeric Brun2b920a12010-09-23 18:30:22 +02003144
Emeric Brunb3971ab2015-05-12 18:49:09 +02003145 ps = peers->local;
Emeric Brun2b920a12010-09-23 18:30:22 +02003146 if (ps->flags & PEER_F_TEACH_COMPLETE) {
Emeric Brunb3971ab2015-05-12 18:49:09 +02003147 if (peers->flags & PEERS_F_DONOTSTOP) {
Emeric Brun2b920a12010-09-23 18:30:22 +02003148 /* resync of new process was complete, current process can die now */
Willy Tarreau4781b152021-04-06 13:53:36 +02003149 _HA_ATOMIC_DEC(&jobs);
Emeric Brunb3971ab2015-05-12 18:49:09 +02003150 peers->flags &= ~PEERS_F_DONOTSTOP;
3151 for (st = ps->tables; st ; st = st->next)
Emeric Brun2cc201f2021-04-23 12:21:26 +02003152 HA_ATOMIC_DEC(&st->table->refcnt);
Emeric Brun2b920a12010-09-23 18:30:22 +02003153 }
3154 }
Willy Tarreau9df94c22016-10-31 18:42:52 +01003155 else if (!ps->appctx) {
Christopher Fauletda21ebc2022-08-26 18:40:46 +02003156 /* Re-arm resync timeout if necessary */
3157 if (!tick_isset(peers->resync_timeout))
3158 peers->resync_timeout = tick_add(now_ms, MS_TO_TICKS(PEER_RESYNC_TIMEOUT));
3159
Willy Tarreau9df94c22016-10-31 18:42:52 +01003160 /* If there's no active peer connection */
Christopher Faulet87da1db2022-08-26 18:46:16 +02003161 if ((peers->flags & PEERS_RESYNC_STATEMASK) == PEERS_RESYNC_FINISHED &&
3162 !tick_is_expired(peers->resync_timeout, now_ms) &&
Christopher Faulet1f8342f2022-07-26 19:19:18 +02003163 (ps->statuscode == 0 ||
3164 ps->statuscode == PEER_SESS_SC_SUCCESSCODE ||
3165 ps->statuscode == PEER_SESS_SC_CONNECTEDCODE ||
3166 ps->statuscode == PEER_SESS_SC_TRYAGAIN)) {
Christopher Faulet87da1db2022-08-26 18:46:16 +02003167 /* The resync is finished for the local peer and
3168 * the resync timeout is not expired and
Christopher Faulet1f8342f2022-07-26 19:19:18 +02003169 * connection never tried
3170 * or previous peer connection was successfully established
3171 * or previous tcp connect succeeded but init state incomplete
3172 * or during previous connect, peer replies a try again statuscode */
Emeric Brun2b920a12010-09-23 18:30:22 +02003173
Christopher Faulet1f8342f2022-07-26 19:19:18 +02003174 if (!tick_is_expired(ps->reconnect, now_ms)) {
3175 /* reconnection timer is not expired. reschedule task for reconnect */
3176 task->expire = tick_first(task->expire, ps->reconnect);
3177 }
3178 else {
3179 /* connect to the local peer if we must push a local sync */
3180 if (peers->flags & PEERS_F_DONOTSTOP) {
3181 peer_session_create(peers, ps);
3182 }
Emeric Bruncbfe5eb2021-04-22 18:20:37 +02003183 }
Emeric Brun2b920a12010-09-23 18:30:22 +02003184 }
3185 else {
3186 /* Other error cases */
Emeric Brunb3971ab2015-05-12 18:49:09 +02003187 if (peers->flags & PEERS_F_DONOTSTOP) {
Emeric Brun2b920a12010-09-23 18:30:22 +02003188 /* unable to resync new process, current process can die now */
Willy Tarreau4781b152021-04-06 13:53:36 +02003189 _HA_ATOMIC_DEC(&jobs);
Emeric Brunb3971ab2015-05-12 18:49:09 +02003190 peers->flags &= ~PEERS_F_DONOTSTOP;
3191 for (st = ps->tables; st ; st = st->next)
Emeric Brun2cc201f2021-04-23 12:21:26 +02003192 HA_ATOMIC_DEC(&st->table->refcnt);
Emeric Brun2b920a12010-09-23 18:30:22 +02003193 }
3194 }
3195 }
Emeric Brunb3971ab2015-05-12 18:49:09 +02003196 else if (ps->statuscode == PEER_SESS_SC_SUCCESSCODE ) {
Christopher Fauletda21ebc2022-08-26 18:40:46 +02003197 /* Reset resync timeout during a resync */
3198 peers->resync_timeout = TICK_ETERNITY;
3199
Willy Tarreau9df94c22016-10-31 18:42:52 +01003200 /* current peer connection is active and established
3201 * wake up all peer handlers to push remaining local updates */
Emeric Brunb3971ab2015-05-12 18:49:09 +02003202 for (st = ps->tables; st ; st = st->next) {
Emeric Brun8e7a13e2021-04-28 11:48:15 +02003203 if (st->last_pushed != st->table->localupdate) {
Emeric Brunb3971ab2015-05-12 18:49:09 +02003204 appctx_wakeup(ps->appctx);
3205 break;
3206 }
3207 }
Emeric Brun2b920a12010-09-23 18:30:22 +02003208 }
3209 } /* stopping */
Emeric Brun80527f52017-06-19 17:46:37 +02003210
3211 /* Release lock for all peers of the section */
3212 for (ps = peers->remote; ps; ps = ps->next)
Christopher Faulet2a944ee2017-11-07 10:42:54 +01003213 HA_SPIN_UNLOCK(PEER_LOCK, &ps->lock);
Emeric Brun80527f52017-06-19 17:46:37 +02003214
Emeric Brun2b920a12010-09-23 18:30:22 +02003215 /* Wakeup for re-connect */
3216 return task;
3217}
3218
Emeric Brunb3971ab2015-05-12 18:49:09 +02003219
Emeric Brun2b920a12010-09-23 18:30:22 +02003220/*
Willy Tarreaud9443442018-10-15 11:18:03 +02003221 * returns 0 in case of error.
Emeric Brun2b920a12010-09-23 18:30:22 +02003222 */
Willy Tarreaud9443442018-10-15 11:18:03 +02003223int peers_init_sync(struct peers *peers)
Emeric Brun2b920a12010-09-23 18:30:22 +02003224{
Emeric Brun2b920a12010-09-23 18:30:22 +02003225 struct peer * curpeer;
Emeric Brun2b920a12010-09-23 18:30:22 +02003226
Emeric Brun2b920a12010-09-23 18:30:22 +02003227 for (curpeer = peers->remote; curpeer; curpeer = curpeer->next) {
Emeric Brun2b920a12010-09-23 18:30:22 +02003228 peers->peers_fe->maxconn += 3;
3229 }
3230
Emeric Brunc60def82017-09-27 14:59:38 +02003231 peers->sync_task = task_new(MAX_THREADS_MASK);
Willy Tarreaud9443442018-10-15 11:18:03 +02003232 if (!peers->sync_task)
3233 return 0;
3234
Emeric Brunb3971ab2015-05-12 18:49:09 +02003235 peers->sync_task->process = process_peer_sync;
Emeric Brunb3971ab2015-05-12 18:49:09 +02003236 peers->sync_task->context = (void *)peers;
3237 peers->sighandler = signal_register_task(0, peers->sync_task, 0);
3238 task_wakeup(peers->sync_task, TASK_WOKEN_INIT);
Willy Tarreaud9443442018-10-15 11:18:03 +02003239 return 1;
Emeric Brunb3971ab2015-05-12 18:49:09 +02003240}
3241
Frédéric Lécaille74167b22019-05-28 19:02:42 +02003242/*
3243 * Allocate a cache a dictionary entries used upon transmission.
3244 */
Frédéric Lécaille6c391982019-06-06 11:34:03 +02003245static struct dcache_tx *new_dcache_tx(size_t max_entries)
Frédéric Lécaille74167b22019-05-28 19:02:42 +02003246{
3247 struct dcache_tx *d;
Frédéric Lécaille6c391982019-06-06 11:34:03 +02003248 struct ebpt_node *entries;
Frédéric Lécaille74167b22019-05-28 19:02:42 +02003249
3250 d = malloc(sizeof *d);
Frédéric Lécaille6c391982019-06-06 11:34:03 +02003251 entries = calloc(max_entries, sizeof *entries);
3252 if (!d || !entries)
3253 goto err;
Frédéric Lécaille74167b22019-05-28 19:02:42 +02003254
3255 d->lru_key = 0;
Frédéric Lécailleb65717f2019-06-07 14:25:25 +02003256 d->prev_lookup = NULL;
Frédéric Lécaille6c391982019-06-06 11:34:03 +02003257 d->cached_entries = EB_ROOT_UNIQUE;
3258 d->entries = entries;
Frédéric Lécaille74167b22019-05-28 19:02:42 +02003259
3260 return d;
Frédéric Lécaille6c391982019-06-06 11:34:03 +02003261
3262 err:
3263 free(d);
3264 free(entries);
3265 return NULL;
Frédéric Lécaille74167b22019-05-28 19:02:42 +02003266}
3267
3268/*
3269 * Allocate a cache of dictionary entries with <name> as name and <max_entries>
3270 * as maximum of entries.
Ilya Shipitsinc02a23f2020-05-06 00:53:22 +05003271 * Return the dictionary cache if succeeded, NULL if not.
Frédéric Lécaille74167b22019-05-28 19:02:42 +02003272 * Must be deallocated calling free_dcache().
3273 */
Frédéric Lécaille6c391982019-06-06 11:34:03 +02003274static struct dcache *new_dcache(size_t max_entries)
Frédéric Lécaille74167b22019-05-28 19:02:42 +02003275{
3276 struct dcache_tx *dc_tx;
3277 struct dcache *dc;
3278 struct dcache_rx *dc_rx;
3279
3280 dc = calloc(1, sizeof *dc);
3281 dc_tx = new_dcache_tx(max_entries);
3282 dc_rx = calloc(max_entries, sizeof *dc_rx);
3283 if (!dc || !dc_tx || !dc_rx)
3284 goto err;
3285
3286 dc->tx = dc_tx;
3287 dc->rx = dc_rx;
3288 dc->max_entries = max_entries;
3289
3290 return dc;
3291
3292 err:
3293 free(dc);
3294 free(dc_tx);
3295 free(dc_rx);
3296 return NULL;
3297}
3298
3299/*
Frédéric Lécaille74167b22019-05-28 19:02:42 +02003300 * Look for the dictionary entry with the value of <i> in <d> cache of dictionary
3301 * entries used upon transmission.
3302 * Return the entry if found, NULL if not.
3303 */
Frédéric Lécaille6c391982019-06-06 11:34:03 +02003304static struct ebpt_node *dcache_tx_lookup_value(struct dcache_tx *d,
3305 struct dcache_tx_entry *i)
Frédéric Lécaille74167b22019-05-28 19:02:42 +02003306{
Frédéric Lécaille6c391982019-06-06 11:34:03 +02003307 return ebpt_lookup(&d->cached_entries, i->entry.key);
Frédéric Lécaille74167b22019-05-28 19:02:42 +02003308}
3309
3310/*
Frédéric Lécaille74167b22019-05-28 19:02:42 +02003311 * Flush <dc> cache.
3312 * Always succeeds.
3313 */
3314static inline void flush_dcache(struct peer *peer)
3315{
3316 int i;
Frédéric Lécaille8d78fa72019-05-20 18:22:52 +02003317 struct dcache *dc = peer->dcache;
Frédéric Lécaille74167b22019-05-28 19:02:42 +02003318
Frédéric Lécailleea875e62020-11-12 21:01:54 +01003319 for (i = 0; i < dc->max_entries; i++) {
Frédéric Lécaille6c391982019-06-06 11:34:03 +02003320 ebpt_delete(&dc->tx->entries[i]);
Frédéric Lécailleea875e62020-11-12 21:01:54 +01003321 dc->tx->entries[i].key = NULL;
Thayne McCombs92149f92020-11-20 01:28:26 -07003322 dict_entry_unref(&server_key_dict, dc->rx[i].de);
3323 dc->rx[i].de = NULL;
Frédéric Lécailleea875e62020-11-12 21:01:54 +01003324 }
3325 dc->tx->prev_lookup = NULL;
3326 dc->tx->lru_key = 0;
Frédéric Lécaille74167b22019-05-28 19:02:42 +02003327
Frédéric Lécaille6c391982019-06-06 11:34:03 +02003328 memset(dc->rx, 0, dc->max_entries * sizeof *dc->rx);
Frédéric Lécaille74167b22019-05-28 19:02:42 +02003329}
3330
3331/*
3332 * Insert a dictionary entry in <dc> cache part used upon transmission (->tx)
3333 * with information provided by <i> dictionary cache entry (especially the value
3334 * to be inserted if not already). Return <i> if already present in the cache
Frédéric Lécaille6c391982019-06-06 11:34:03 +02003335 * or something different of <i> if not.
Frédéric Lécaille74167b22019-05-28 19:02:42 +02003336 */
Frédéric Lécaille6c391982019-06-06 11:34:03 +02003337static struct ebpt_node *dcache_tx_insert(struct dcache *dc, struct dcache_tx_entry *i)
Frédéric Lécaille74167b22019-05-28 19:02:42 +02003338{
3339 struct dcache_tx *dc_tx;
Frédéric Lécaille6c391982019-06-06 11:34:03 +02003340 struct ebpt_node *o;
Frédéric Lécaille74167b22019-05-28 19:02:42 +02003341
3342 dc_tx = dc->tx;
Frédéric Lécailleb65717f2019-06-07 14:25:25 +02003343
3344 if (dc_tx->prev_lookup && dc_tx->prev_lookup->key == i->entry.key) {
3345 o = dc_tx->prev_lookup;
3346 } else {
3347 o = dcache_tx_lookup_value(dc_tx, i);
3348 if (o) {
3349 /* Save it */
3350 dc_tx->prev_lookup = o;
3351 }
3352 }
3353
Frédéric Lécaille74167b22019-05-28 19:02:42 +02003354 if (o) {
Frédéric Lécaille6c391982019-06-06 11:34:03 +02003355 /* Copy the ID. */
3356 i->id = o - dc->tx->entries;
3357 return &i->entry;
Frédéric Lécaille74167b22019-05-28 19:02:42 +02003358 }
3359
Frédéric Lécaille6c391982019-06-06 11:34:03 +02003360 /* The new entry to put in cache */
Frédéric Lécailleb65717f2019-06-07 14:25:25 +02003361 dc_tx->prev_lookup = o = &dc_tx->entries[dc_tx->lru_key];
Frédéric Lécaille74167b22019-05-28 19:02:42 +02003362
Frédéric Lécaille6c391982019-06-06 11:34:03 +02003363 ebpt_delete(o);
3364 o->key = i->entry.key;
3365 ebpt_insert(&dc_tx->cached_entries, o);
3366 i->id = dc_tx->lru_key;
Frédéric Lécaille74167b22019-05-28 19:02:42 +02003367
Frédéric Lécaille6c391982019-06-06 11:34:03 +02003368 /* Update the index for the next entry to put in cache */
3369 dc_tx->lru_key = (dc_tx->lru_key + 1) & (dc->max_entries - 1);
Emeric Brunb3971ab2015-05-12 18:49:09 +02003370
Frédéric Lécaille74167b22019-05-28 19:02:42 +02003371 return o;
3372}
Emeric Brunb3971ab2015-05-12 18:49:09 +02003373
3374/*
Frédéric Lécaille8d78fa72019-05-20 18:22:52 +02003375 * Allocate a dictionary cache for each peer of <peers> section.
3376 * Return 1 if succeeded, 0 if not.
3377 */
3378int peers_alloc_dcache(struct peers *peers)
3379{
3380 struct peer *p;
3381
3382 for (p = peers->remote; p; p = p->next) {
3383 p->dcache = new_dcache(PEER_STKT_CACHE_MAX_ENTRIES);
3384 if (!p->dcache)
3385 return 0;
3386 }
3387
3388 return 1;
3389}
3390
3391/*
Emeric Brunb3971ab2015-05-12 18:49:09 +02003392 * Function used to register a table for sync on a group of peers
Remi Tricot-Le Bretonbe5b1bb2021-05-12 17:39:04 +02003393 * Returns 0 in case of success.
Emeric Brunb3971ab2015-05-12 18:49:09 +02003394 */
Remi Tricot-Le Bretonbe5b1bb2021-05-12 17:39:04 +02003395int peers_register_table(struct peers *peers, struct stktable *table)
Emeric Brunb3971ab2015-05-12 18:49:09 +02003396{
3397 struct shared_table *st;
3398 struct peer * curpeer;
3399 int id = 0;
Remi Tricot-Le Bretonbe5b1bb2021-05-12 17:39:04 +02003400 int retval = 0;
Emeric Brunb3971ab2015-05-12 18:49:09 +02003401
3402 for (curpeer = peers->remote; curpeer; curpeer = curpeer->next) {
Vincent Bernat02779b62016-04-03 13:48:43 +02003403 st = calloc(1,sizeof(*st));
Remi Tricot-Le Bretonbe5b1bb2021-05-12 17:39:04 +02003404 if (!st) {
3405 retval = 1;
3406 break;
3407 }
Emeric Brunb3971ab2015-05-12 18:49:09 +02003408 st->table = table;
3409 st->next = curpeer->tables;
3410 if (curpeer->tables)
3411 id = curpeer->tables->local_id;
3412 st->local_id = id + 1;
3413
Emeric Brun2cc201f2021-04-23 12:21:26 +02003414 /* If peer is local we inc table
3415 * refcnt to protect against flush
3416 * until this process pushed all
3417 * table content to the new one
3418 */
3419 if (curpeer->local)
3420 HA_ATOMIC_INC(&st->table->refcnt);
Emeric Brunb3971ab2015-05-12 18:49:09 +02003421 curpeer->tables = st;
3422 }
3423
3424 table->sync_task = peers->sync_task;
Remi Tricot-Le Bretonbe5b1bb2021-05-12 17:39:04 +02003425
3426 return retval;
Emeric Brun2b920a12010-09-23 18:30:22 +02003427}
3428
Frédéric Lécaille95679dc2019-04-15 10:25:27 +02003429/*
3430 * Parse the "show peers" command arguments.
3431 * Returns 0 if succeeded, 1 if not with the ->msg of the appctx set as
3432 * error message.
3433 */
3434static int cli_parse_show_peers(char **args, char *payload, struct appctx *appctx, void *private)
3435{
3436 appctx->ctx.cfgpeers.target = NULL;
3437
Willy Tarreau49962b52021-02-12 16:56:22 +01003438 if (strcmp(args[2], "dict") == 0) {
3439 /* show the dictionaries (large dump) */
3440 appctx->ctx.cfgpeers.flags |= PEERS_SHOW_F_DICT;
3441 args++;
3442 } else if (strcmp(args[2], "-") == 0)
3443 args++; // allows to show a section called "dict"
3444
Frédéric Lécaille95679dc2019-04-15 10:25:27 +02003445 if (*args[2]) {
3446 struct peers *p;
3447
3448 for (p = cfg_peers; p; p = p->next) {
Tim Duesterhuse5ff1412021-01-02 22:31:53 +01003449 if (strcmp(p->id, args[2]) == 0) {
Frédéric Lécaille95679dc2019-04-15 10:25:27 +02003450 appctx->ctx.cfgpeers.target = p;
3451 break;
3452 }
3453 }
3454
Willy Tarreau9d008692019-08-09 11:21:01 +02003455 if (!p)
3456 return cli_err(appctx, "No such peers\n");
Frédéric Lécaille95679dc2019-04-15 10:25:27 +02003457 }
3458
3459 return 0;
3460}
3461
3462/*
3463 * This function dumps the peer state information of <peers> "peers" section.
3464 * Returns 0 if the output buffer is full and needs to be called again, non-zero if not.
3465 * Dedicated to be called by cli_io_handler_show_peers() cli I/O handler.
3466 */
3467static int peers_dump_head(struct buffer *msg, struct stream_interface *si, struct peers *peers)
3468{
3469 struct tm tm;
3470
3471 get_localtime(peers->last_change, &tm);
Willy Tarreau1ad64ac2020-09-24 08:48:08 +02003472 chunk_appendf(msg, "%p: [%02d/%s/%04d:%02d:%02d:%02d] id=%s disabled=%d flags=0x%x resync_timeout=%s task_calls=%u\n",
Frédéric Lécaille95679dc2019-04-15 10:25:27 +02003473 peers,
3474 tm.tm_mday, monthname[tm.tm_mon], tm.tm_year+1900,
3475 tm.tm_hour, tm.tm_min, tm.tm_sec,
Willy Tarreau1ad64ac2020-09-24 08:48:08 +02003476 peers->id, peers->disabled, peers->flags,
Frédéric Lécaille95679dc2019-04-15 10:25:27 +02003477 peers->resync_timeout ?
3478 tick_is_expired(peers->resync_timeout, now_ms) ? "<PAST>" :
3479 human_time(TICKS_TO_MS(peers->resync_timeout - now_ms),
Emeric Brun0bbec0f2019-04-18 11:39:43 +02003480 TICKS_TO_MS(1000)) : "<NEVER>",
3481 peers->sync_task ? peers->sync_task->calls : 0);
Frédéric Lécaille95679dc2019-04-15 10:25:27 +02003482
3483 if (ci_putchk(si_ic(si), msg) == -1) {
3484 si_rx_room_blk(si);
3485 return 0;
3486 }
3487
3488 return 1;
3489}
3490
3491/*
3492 * This function dumps <peer> state information.
3493 * Returns 0 if the output buffer is full and needs to be called again, non-zero
3494 * if not. Dedicated to be called by cli_io_handler_show_peers() cli I/O handler.
3495 */
Willy Tarreau49962b52021-02-12 16:56:22 +01003496static int peers_dump_peer(struct buffer *msg, struct stream_interface *si, struct peer *peer, int flags)
Frédéric Lécaille95679dc2019-04-15 10:25:27 +02003497{
3498 struct connection *conn;
3499 char pn[INET6_ADDRSTRLEN];
3500 struct stream_interface *peer_si;
3501 struct stream *peer_s;
3502 struct appctx *appctx;
3503 struct shared_table *st;
3504
3505 addr_to_str(&peer->addr, pn, sizeof pn);
Frédéric Lécaille3fc0fe02020-10-08 09:46:24 +02003506 chunk_appendf(msg, " %p: id=%s(%s,%s) addr=%s:%d last_status=%s",
Frédéric Lécaille95679dc2019-04-15 10:25:27 +02003507 peer, peer->id,
3508 peer->local ? "local" : "remote",
Frédéric Lécaillee7e2b212020-10-05 12:33:07 +02003509 peer->appctx ? "active" : "inactive",
Frédéric Lécaille95679dc2019-04-15 10:25:27 +02003510 pn, get_host_port(&peer->addr),
Frédéric Lécaille3fc0fe02020-10-08 09:46:24 +02003511 statuscode_str(peer->statuscode));
3512
3513 chunk_appendf(msg, " last_hdshk=%s\n",
3514 peer->last_hdshk ? human_time(TICKS_TO_MS(now_ms - peer->last_hdshk),
3515 TICKS_TO_MS(1000)) : "<NEVER>");
3516
3517 chunk_appendf(msg, " reconnect=%s",
Frédéric Lécaille95679dc2019-04-15 10:25:27 +02003518 peer->reconnect ?
3519 tick_is_expired(peer->reconnect, now_ms) ? "<PAST>" :
3520 human_time(TICKS_TO_MS(peer->reconnect - now_ms),
Frédéric Lécaille3fc0fe02020-10-08 09:46:24 +02003521 TICKS_TO_MS(1000)) : "<NEVER>");
3522
3523 chunk_appendf(msg, " heartbeat=%s",
3524 peer->heartbeat ?
3525 tick_is_expired(peer->heartbeat, now_ms) ? "<PAST>" :
3526 human_time(TICKS_TO_MS(peer->heartbeat - now_ms),
3527 TICKS_TO_MS(1000)) : "<NEVER>");
3528
3529 chunk_appendf(msg, " confirm=%u tx_hbt=%u rx_hbt=%u no_hbt=%u new_conn=%u proto_err=%u coll=%u\n",
Frédéric Lécailleec1c10b2019-11-07 15:22:33 +01003530 peer->confirm, peer->tx_hbt, peer->rx_hbt,
Frédéric Lécaille3fc0fe02020-10-08 09:46:24 +02003531 peer->no_hbt, peer->new_conn, peer->proto_err, peer->coll);
Frédéric Lécaille95679dc2019-04-15 10:25:27 +02003532
3533 chunk_appendf(&trash, " flags=0x%x", peer->flags);
3534
3535 appctx = peer->appctx;
3536 if (!appctx)
Frédéric Lécaille470502b2019-11-06 10:41:03 +01003537 goto table_info;
Frédéric Lécaille95679dc2019-04-15 10:25:27 +02003538
Emeric Brun0bbec0f2019-04-18 11:39:43 +02003539 chunk_appendf(&trash, " appctx:%p st0=%d st1=%d task_calls=%u", appctx, appctx->st0, appctx->st1,
3540 appctx->t ? appctx->t->calls : 0);
Frédéric Lécaille95679dc2019-04-15 10:25:27 +02003541
3542 peer_si = peer->appctx->owner;
3543 if (!peer_si)
Frédéric Lécaille470502b2019-11-06 10:41:03 +01003544 goto table_info;
Frédéric Lécaille95679dc2019-04-15 10:25:27 +02003545
3546 peer_s = si_strm(peer_si);
3547 if (!peer_s)
Frédéric Lécaille470502b2019-11-06 10:41:03 +01003548 goto table_info;
Frédéric Lécaille95679dc2019-04-15 10:25:27 +02003549
3550 chunk_appendf(&trash, " state=%s", si_state_str(si_opposite(peer_si)->state));
3551
3552 conn = objt_conn(strm_orig(peer_s));
3553 if (conn)
3554 chunk_appendf(&trash, "\n xprt=%s", conn_get_xprt_name(conn));
3555
Willy Tarreau3ca14902019-07-17 14:53:15 +02003556 switch (conn && conn_get_src(conn) ? addr_to_str(conn->src, pn, sizeof(pn)) : AF_UNSPEC) {
Frédéric Lécaille95679dc2019-04-15 10:25:27 +02003557 case AF_INET:
3558 case AF_INET6:
Willy Tarreau3ca14902019-07-17 14:53:15 +02003559 chunk_appendf(&trash, " src=%s:%d", pn, get_host_port(conn->src));
Frédéric Lécaille95679dc2019-04-15 10:25:27 +02003560 break;
3561 case AF_UNIX:
3562 chunk_appendf(&trash, " src=unix:%d", strm_li(peer_s)->luid);
3563 break;
3564 }
3565
Willy Tarreau3ca14902019-07-17 14:53:15 +02003566 switch (conn && conn_get_dst(conn) ? addr_to_str(conn->dst, pn, sizeof(pn)) : AF_UNSPEC) {
Frédéric Lécaille95679dc2019-04-15 10:25:27 +02003567 case AF_INET:
3568 case AF_INET6:
Willy Tarreau3ca14902019-07-17 14:53:15 +02003569 chunk_appendf(&trash, " addr=%s:%d", pn, get_host_port(conn->dst));
Frédéric Lécaille95679dc2019-04-15 10:25:27 +02003570 break;
3571 case AF_UNIX:
3572 chunk_appendf(&trash, " addr=unix:%d", strm_li(peer_s)->luid);
3573 break;
3574 }
3575
Frédéric Lécaille470502b2019-11-06 10:41:03 +01003576 table_info:
Frédéric Lécaille95679dc2019-04-15 10:25:27 +02003577 if (peer->remote_table)
3578 chunk_appendf(&trash, "\n remote_table:%p id=%s local_id=%d remote_id=%d",
3579 peer->remote_table,
3580 peer->remote_table->table->id,
3581 peer->remote_table->local_id,
3582 peer->remote_table->remote_id);
3583
3584 if (peer->last_local_table)
3585 chunk_appendf(&trash, "\n last_local_table:%p id=%s local_id=%d remote_id=%d",
3586 peer->last_local_table,
3587 peer->last_local_table->table->id,
3588 peer->last_local_table->local_id,
3589 peer->last_local_table->remote_id);
3590
3591 if (peer->tables) {
3592 chunk_appendf(&trash, "\n shared tables:");
3593 for (st = peer->tables; st; st = st->next) {
Frédéric Lécaille62b0b0b2019-05-29 16:20:41 +02003594 int i, count;
Frédéric Lécaille95679dc2019-04-15 10:25:27 +02003595 struct stktable *t;
Frédéric Lécaille62b0b0b2019-05-29 16:20:41 +02003596 struct dcache *dcache;
3597
Frédéric Lécaille95679dc2019-04-15 10:25:27 +02003598 t = st->table;
Frédéric Lécaille62b0b0b2019-05-29 16:20:41 +02003599 dcache = peer->dcache;
3600
Frédéric Lécaille95679dc2019-04-15 10:25:27 +02003601 chunk_appendf(&trash, "\n %p local_id=%d remote_id=%d "
3602 "flags=0x%x remote_data=0x%llx",
3603 st, st->local_id, st->remote_id,
3604 st->flags, (unsigned long long)st->remote_data);
3605 chunk_appendf(&trash, "\n last_acked=%u last_pushed=%u last_get=%u"
3606 " teaching_origin=%u update=%u",
3607 st->last_acked, st->last_pushed, st->last_get,
3608 st->teaching_origin, st->update);
3609 chunk_appendf(&trash, "\n table:%p id=%s update=%u localupdate=%u"
Emeric Brun2cc201f2021-04-23 12:21:26 +02003610 " commitupdate=%u refcnt=%u",
3611 t, t->id, t->update, t->localupdate, t->commitupdate, t->refcnt);
Willy Tarreau49962b52021-02-12 16:56:22 +01003612 if (flags & PEERS_SHOW_F_DICT) {
3613 chunk_appendf(&trash, "\n TX dictionary cache:");
3614 count = 0;
3615 for (i = 0; i < dcache->max_entries; i++) {
3616 struct ebpt_node *node;
3617 struct dict_entry *de;
Frédéric Lécaille62b0b0b2019-05-29 16:20:41 +02003618
Willy Tarreau49962b52021-02-12 16:56:22 +01003619 node = &dcache->tx->entries[i];
3620 if (!node->key)
3621 break;
Frédéric Lécaille6c391982019-06-06 11:34:03 +02003622
Willy Tarreau49962b52021-02-12 16:56:22 +01003623 if (!count++)
3624 chunk_appendf(&trash, "\n ");
3625 de = node->key;
3626 chunk_appendf(&trash, " %3u -> %s", i, (char *)de->value.key);
3627 count &= 0x3;
3628 }
3629 chunk_appendf(&trash, "\n RX dictionary cache:");
3630 count = 0;
3631 for (i = 0; i < dcache->max_entries; i++) {
3632 if (!count++)
3633 chunk_appendf(&trash, "\n ");
3634 chunk_appendf(&trash, " %3u -> %s", i,
3635 dcache->rx[i].de ?
3636 (char *)dcache->rx[i].de->value.key : "-");
3637 count &= 0x3;
3638 }
3639 } else {
3640 chunk_appendf(&trash, "\n Dictionary cache not dumped (use \"show peers dict\")");
Frédéric Lécaille62b0b0b2019-05-29 16:20:41 +02003641 }
Frédéric Lécaille95679dc2019-04-15 10:25:27 +02003642 }
3643 }
3644
3645 end:
3646 chunk_appendf(&trash, "\n");
3647 if (ci_putchk(si_ic(si), msg) == -1) {
3648 si_rx_room_blk(si);
3649 return 0;
3650 }
3651
3652 return 1;
3653}
3654
3655/*
3656 * This function dumps all the peers of "peers" section.
3657 * Returns 0 if the output buffer is full and needs to be called
3658 * again, non-zero if not. It proceeds in an isolated thread, so
3659 * there is no thread safety issue here.
3660 */
3661static int cli_io_handler_show_peers(struct appctx *appctx)
3662{
3663 int show_all;
3664 int ret = 0, first_peers = 1;
3665 struct stream_interface *si = appctx->owner;
3666
3667 thread_isolate();
3668
3669 show_all = !appctx->ctx.cfgpeers.target;
3670
3671 chunk_reset(&trash);
3672
3673 while (appctx->st2 != STAT_ST_FIN) {
3674 switch (appctx->st2) {
3675 case STAT_ST_INIT:
3676 if (show_all)
3677 appctx->ctx.cfgpeers.peers = cfg_peers;
3678 else
3679 appctx->ctx.cfgpeers.peers = appctx->ctx.cfgpeers.target;
3680
3681 appctx->st2 = STAT_ST_LIST;
3682 /* fall through */
3683
3684 case STAT_ST_LIST:
3685 if (!appctx->ctx.cfgpeers.peers) {
3686 /* No more peers list. */
3687 appctx->st2 = STAT_ST_END;
3688 }
3689 else {
3690 if (!first_peers)
3691 chunk_appendf(&trash, "\n");
3692 else
3693 first_peers = 0;
3694 if (!peers_dump_head(&trash, si, appctx->ctx.cfgpeers.peers))
3695 goto out;
3696
3697 appctx->ctx.cfgpeers.peer = appctx->ctx.cfgpeers.peers->remote;
3698 appctx->ctx.cfgpeers.peers = appctx->ctx.cfgpeers.peers->next;
3699 appctx->st2 = STAT_ST_INFO;
3700 }
3701 break;
3702
3703 case STAT_ST_INFO:
3704 if (!appctx->ctx.cfgpeers.peer) {
3705 /* End of peer list */
3706 if (show_all)
3707 appctx->st2 = STAT_ST_LIST;
3708 else
3709 appctx->st2 = STAT_ST_END;
3710 }
3711 else {
Willy Tarreau49962b52021-02-12 16:56:22 +01003712 if (!peers_dump_peer(&trash, si, appctx->ctx.cfgpeers.peer, appctx->ctx.cfgpeers.flags))
Frédéric Lécaille95679dc2019-04-15 10:25:27 +02003713 goto out;
3714
3715 appctx->ctx.cfgpeers.peer = appctx->ctx.cfgpeers.peer->next;
3716 }
3717 break;
3718
3719 case STAT_ST_END:
3720 appctx->st2 = STAT_ST_FIN;
3721 break;
3722 }
3723 }
3724 ret = 1;
3725 out:
3726 thread_release();
3727 return ret;
3728}
3729
3730/*
3731 * CLI keywords.
3732 */
3733static struct cli_kw_list cli_kws = {{ }, {
Willy Tarreaub205bfd2021-05-07 11:38:37 +02003734 { { "show", "peers", NULL }, "show peers [dict|-] [section] : dump some information about all the peers or this peers section", cli_parse_show_peers, cli_io_handler_show_peers, },
Frédéric Lécaille95679dc2019-04-15 10:25:27 +02003735 {},
3736}};
3737
3738/* Register cli keywords */
3739INITCALL1(STG_REGISTER, cli_register_kw, &cli_kws);
3740