4 Copyright (C) Andrew Tridgell 2006
6 This program is free software; you can redistribute it and/or modify
7 it under the terms of the GNU General Public License as published by
8 the Free Software Foundation; either version 3 of the License, or
9 (at your option) any later version.
11 This program is distributed in the hope that it will be useful,
12 but WITHOUT ANY WARRANTY; without even the implied warranty of
13 MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
14 GNU General Public License for more details.
16 You should have received a copy of the GNU General Public License
17 along with this program; if not, see <http://www.gnu.org/licenses/>.
21 #include "system/network.h"
22 #include "system/filesys.h"
24 #include "lib/util/dlinklist.h"
25 #include "lib/util/debug.h"
27 #include "ctdb_private.h"
29 #include "common/common.h"
30 #include "common/logging.h"
36 called when a complete packet has come in
38 void ctdb_tcp_read_cb(uint8_t *data
, size_t cnt
, void *args
)
40 struct ctdb_node
*node
= talloc_get_type_abort(args
, struct ctdb_node
);
41 struct ctdb_tcp_node
*tnode
= talloc_get_type_abort(
42 node
->private_data
, struct ctdb_tcp_node
);
43 struct ctdb_req_header
*hdr
= (struct ctdb_req_header
*)data
;
46 /* incoming socket has died */
50 if (cnt
< sizeof(*hdr
)) {
51 DEBUG(DEBUG_ALERT
,(__location__
" Bad packet length %u\n", (unsigned)cnt
));
55 if (cnt
& (CTDB_TCP_ALIGNMENT
-1)) {
56 DEBUG(DEBUG_ALERT
,(__location__
" Length 0x%x not multiple of alignment\n",
61 if (hdr
->ctdb_magic
!= CTDB_MAGIC
) {
62 DEBUG(DEBUG_ALERT
,(__location__
" Non CTDB packet 0x%x rejected\n",
67 if (hdr
->ctdb_version
!= CTDB_PROTOCOL
) {
68 DEBUG(DEBUG_ALERT
, (__location__
" Bad CTDB version 0x%x rejected\n",
73 /* tell the ctdb layer above that we have a packet */
74 tnode
->ctdb
->upcalls
->recv_pkt(tnode
->ctdb
, data
, cnt
);
78 TALLOC_FREE(tnode
->in_queue
);
81 node
->ctdb
->upcalls
->node_dead(node
);
87 queue a packet for sending
89 int ctdb_tcp_queue_pkt(struct ctdb_node
*node
, uint8_t *data
, uint32_t length
)
91 struct ctdb_tcp_node
*tnode
= talloc_get_type(node
->private_data
,
92 struct ctdb_tcp_node
);
93 if (tnode
->out_queue
== NULL
) {
94 DBG_DEBUG("No outgoing connection, dropping packet\n");
98 return ctdb_queue_send(tnode
->out_queue
, data
, length
);