← Back to branch summary

~ubuntu-branches/ubuntu/vivid/ctdb/vivid-proposed

« back to all changes in this revision

Viewing changes to tcp/tcp_io.c

  • Committer: Bazaar Package Importer
  • Author(s): Mathieu Parent
  • Date: 2008-04-26 15:21:27 UTC
  • Revision ID: james.westby@ubuntu.com-20080426152127-58mv5ojv5q362ise
Tags: upstream-1.0.34+git200804242206
Import upstream version 1.0.34+git200804242206

Show diffs side-by-side

added added

removed removed

Lines of Context:
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(DEBUG_ALERT,(__location__ " Bad packet length %u\n", (unsigned)cnt));
 
45
                goto failed;
 
46
        }
 
47
 
 
48
        if (cnt & (CTDB_TCP_ALIGNMENT-1)) {
 
49
                DEBUG(DEBUG_ALERT,(__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(DEBUG_ALERT,(__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(DEBUG_ALERT,(__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(DEBUG_ALERT, (__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
}