update lib/replace from samba4
[vlendec/samba-autobuild/.git] / ctdb / tcp / tcp_io.c
1 /* 
2    ctdb over TCP
3
4    Copyright (C) Andrew Tridgell  2006
5
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.
10    
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.
15    
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/>.
18 */
19
20 #include "includes.h"
21 #include "lib/events/events.h"
22 #include "lib/util/dlinklist.h"
23 #include "lib/tdb/include/tdb.h"
24 #include "system/network.h"
25 #include "system/filesys.h"
26 #include "../include/ctdb_private.h"
27 #include "ctdb_tcp.h"
28
29
30 /*
31   called when a complete packet has come in
32  */
33 void ctdb_tcp_read_cb(uint8_t *data, size_t cnt, void *args)
34 {
35         struct ctdb_incoming *in = talloc_get_type(args, struct ctdb_incoming);
36         struct ctdb_req_header *hdr = (struct ctdb_req_header *)data;
37
38         if (data == NULL) {
39                 /* incoming socket has died */
40                 goto failed;
41         }
42
43         if (cnt < sizeof(*hdr)) {
44                 DEBUG(0,(__location__ " Bad packet length %u\n", (unsigned)cnt));
45                 goto failed;
46         }
47
48         if (cnt & (CTDB_TCP_ALIGNMENT-1)) {
49                 DEBUG(0,(__location__ " Length 0x%x not multiple of alignment\n", 
50                          (unsigned)cnt));
51                 goto failed;
52         }
53
54
55         if (cnt != hdr->length) {
56                 DEBUG(0,(__location__ " Bad header length %u expected %u\n", 
57                          (unsigned)hdr->length, (unsigned)cnt));
58                 goto failed;
59         }
60
61         if (hdr->ctdb_magic != CTDB_MAGIC) {
62                 DEBUG(0,(__location__ " Non CTDB packet 0x%x rejected\n", 
63                          hdr->ctdb_magic));
64                 goto failed;
65         }
66
67         if (hdr->ctdb_version != CTDB_VERSION) {
68                 DEBUG(0, (__location__ " Bad CTDB version 0x%x rejected\n", 
69                           hdr->ctdb_version));
70                 goto failed;
71         }
72
73         /* tell the ctdb layer above that we have a packet */
74         in->ctdb->upcalls->recv_pkt(in->ctdb, data, cnt);
75         return;
76
77 failed:
78         talloc_free(in);
79 }
80
81 /*
82   queue a packet for sending
83 */
84 int ctdb_tcp_queue_pkt(struct ctdb_node *node, uint8_t *data, uint32_t length)
85 {
86         struct ctdb_tcp_node *tnode = talloc_get_type(node->private_data,
87                                                       struct ctdb_tcp_node);
88         return ctdb_queue_send(tnode->out_queue, data, length);
89 }