60.nfs
[sahlberg/ctdb.git] / tcp / ctdb_tcp.h
index c8df8bb63f245a1baa9493cbc0a3b55b7c8fd636..9a17bd6b5961a2fb6a7dbdc9a313df0473d6f98d 100644 (file)
@@ -5,7 +5,7 @@
 
    This program is free software; you can redistribute it and/or modify
    it under the terms of the GNU General Public License as published by
-   the Free Software Foundation; either version 2 of the License, or
+   the Free Software Foundation; either version 3 of the License, or
    (at your option) any later version.
    
    This program is distributed in the hope that it will be useful,
    GNU General Public License for more details.
    
    You should have received a copy of the GNU General Public License
-   along with this program; if not, write to the Free Software
-   Foundation, Inc., 675 Mass Ave, Cambridge, MA 02139, USA.
+   along with this program; if not, see <http://www.gnu.org/licenses/>.
 */
 
 
 /* ctdb_tcp main state */
 struct ctdb_tcp {
+       struct ctdb_context *ctdb;
        int listen_fd;
 };
 
@@ -38,7 +38,7 @@ struct ctdb_incoming {
 */
 struct ctdb_tcp_node {
        int fd;
-       struct ctdb_queue *queue;
+       struct ctdb_queue *out_queue;
        struct fd_event *connect_fde;
        struct timed_event *connect_te;
 };
@@ -51,5 +51,6 @@ void ctdb_tcp_node_connect(struct event_context *ev, struct timed_event *te,
                           struct timeval t, void *private_data);
 void ctdb_tcp_read_cb(uint8_t *data, size_t cnt, void *args);
 void ctdb_tcp_tnode_cb(uint8_t *data, size_t cnt, void *private_data);
+void ctdb_tcp_stop_connection(struct ctdb_node *node);
 
 #define CTDB_TCP_ALIGNMENT 8