*/
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;
};
/* start a new connect cycle to try to re-establish the
link */
- ctdb_queue_set_fd(tnode->queue, -1);
+ ctdb_queue_set_fd(tnode->out_queue, -1);
tnode->fd = -1;
event_add_timed(node->ctdb->ev, tnode, timeval_zero(),
ctdb_tcp_node_connect, node);
setsockopt(tnode->fd,IPPROTO_TCP,TCP_NODELAY,(char *)&one,sizeof(one));
setsockopt(tnode->fd,SOL_SOCKET,SO_KEEPALIVE,(char *)&one,sizeof(one));
- ctdb_queue_set_fd(tnode->queue, tnode->fd);
+ ctdb_queue_set_fd(tnode->out_queue, tnode->fd);
/* tell the ctdb layer we are connected */
node->ctdb->upcalls->node_connected(node);
tnode->fd = -1;
node->private_data = tnode;
- tnode->queue = ctdb_queue_setup(node->ctdb, ctcp, tnode->fd, CTDB_TCP_ALIGNMENT,
+ tnode->out_queue = ctdb_queue_setup(node->ctdb, ctcp, tnode->fd, CTDB_TCP_ALIGNMENT,
ctdb_tcp_tnode_cb, node);
return 0;
{
struct ctdb_tcp_node *tnode = talloc_get_type(node->private_data,
struct ctdb_tcp_node);
- return ctdb_queue_send(tnode->queue, data, length);
+ return ctdb_queue_send(tnode->out_queue, data, length);
}