FAQ Search Today's Posts Mark Forums Read
» Video Reviews

» Linux Archive

Linux-archive is a website aiming to archive linux email lists and to make them easily accessible for linux users/developers.


» Sponsor

» Partners

» Sponsor

Go Back   Linux Archive > Redhat > Cluster Development

 
 
LinkBack Thread Tools
 
Old 11-20-2007, 10:02 AM
 
Default [Cluster-devel] cluster/cman-kernel/src cnxman.c membership.c

CVSROOT: /cvs/cluster
Module name: cluster
Branch: RHEL4
Changes by: pcaulfield@sourceware.org 2007-11-20 11:02:46

Modified files:
cman-kernel/src: cnxman.c membership.c

Log message:
A fix to the last patch. The last_ackneeded_seq_recv variable needed to
be cleared when the node went down, otherwise we end up comparing
received sequence numbers against old ones and end up throwing all
new messages away!
bz#387081 shows this happening. The "inconsistent" message is slightly
misleading in this context

Patches:
http://sourceware.org/cgi-bin/cvsweb.cgi/cluster/cman-kernel/src/cnxman.c.diff?cvsroot=cluster&only_with_tag=RHEL4& r1=1.42.2.30&r2=1.42.2.31
http://sourceware.org/cgi-bin/cvsweb.cgi/cluster/cman-kernel/src/membership.c.diff?cvsroot=cluster&only_with_tag=RH EL4&r1=1.44.2.28&r2=1.44.2.29

--- cluster/cman-kernel/src/Attic/cnxman.c 2007/11/01 10:44:25 1.42.2.30
+++ cluster/cman-kernel/src/Attic/cnxman.c 2007/11/20 11:02:45 1.42.2.31
@@ -867,10 +867,10 @@
/* Have we received this message before ? If so just ignore it, it's a
* resend for someone else's benefit */
if (!(flags & MSG_NOACK) &&
- rem_node && rem_node->last_seq_recv &&
+ rem_node && rem_node->last_ackneeded_seq_recv &&
(short)((short)le16_to_cpu(header->seq) - (short)rem_node->last_ackneeded_seq_recv) <= 0) {
- P_COMMS("Discarding message - seq = %d, last_seen = %d
",
- header->seq, rem_node->last_seq_recv);
+ P_COMMS("Discarding message - seq = %d, last_seen = %d, last_acked_seen = %d
",
+ header->seq, rem_node->last_seq_recv, rem_node->last_ackneeded_seq_recv);
/* Still need to ACK it though, in case it was the ACK that got
* lost */
cl_sendack(csock, header->seq, addrlen, addr, header->tgtport, 0);
--- cluster/cman-kernel/src/Attic/membership.c 2007/09/19 15:01:07 1.44.2.28
+++ cluster/cman-kernel/src/Attic/membership.c 2007/11/20 11:02:46 1.44.2.29
@@ -1398,6 +1398,7 @@
cluster_members--;
node->state = NODESTATE_DEAD;
node->last_seq_recv = 0;
+ node->last_ackneeded_seq_recv = 0;
up(&cluster_members_lock);

send_nodedown(node->node_id, node->leave_reason);
@@ -1683,6 +1684,7 @@
newnode->us = 0;
newnode->leave_reason = 0;
newnode->last_seq_recv = 0;
+ newnode->last_ackneeded_seq_recv = 0;
newnode->last_seq_acked = 0;
newnode->last_seq_sent = 0;
newnode->incarnation++;
@@ -1717,6 +1719,7 @@
newnode->us = 0;
newnode->leave_reason = 0;
newnode->last_seq_recv = 0;
+ newnode->last_ackneeded_seq_recv = 0;
newnode->last_seq_acked = 0;
newnode->last_seq_sent = 0;
newnode->incarnation = 0;
 

Thread Tools




All times are GMT. The time now is 03:54 AM.

VBulletin, Copyright ©2000 - 2014, Jelsoft Enterprises Ltd.
Content Relevant URLs by vBSEO ©2007, Crawlability, Inc.
Copyright 2007 - 2008, www.linux-archive.org