Return-Path: Delivered-To: apmail-incubator-cassandra-dev-archive@minotaur.apache.org Received: (qmail 10748 invoked from network); 5 Nov 2009 02:31:47 -0000 Received: from hermes.apache.org (HELO mail.apache.org) (140.211.11.3) by minotaur.apache.org with SMTP; 5 Nov 2009 02:31:47 -0000 Received: (qmail 48333 invoked by uid 500); 5 Nov 2009 02:31:47 -0000 Delivered-To: apmail-incubator-cassandra-dev-archive@incubator.apache.org Received: (qmail 48285 invoked by uid 500); 5 Nov 2009 02:31:47 -0000 Mailing-List: contact cassandra-dev-help@incubator.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Reply-To: cassandra-dev@incubator.apache.org Delivered-To: mailing list cassandra-dev@incubator.apache.org Received: (qmail 48268 invoked by uid 99); 5 Nov 2009 02:31:47 -0000 Received: from nike.apache.org (HELO nike.apache.org) (192.87.106.230) by apache.org (qpsmtpd/0.29) with ESMTP; Thu, 05 Nov 2009 02:31:47 +0000 X-ASF-Spam-Status: No, hits=0.4 required=10.0 tests=SPF_PASS,SUBJECT_FUZZY_TION X-Spam-Check-By: apache.org Received-SPF: pass (nike.apache.org: domain of jbellis@gmail.com designates 209.85.219.209 as permitted sender) Received: from [209.85.219.209] (HELO mail-ew0-f209.google.com) (209.85.219.209) by apache.org (qpsmtpd/0.29) with ESMTP; Thu, 05 Nov 2009 02:31:39 +0000 Received: by ewy5 with SMTP id 5so2338256ewy.12 for ; Wed, 04 Nov 2009 18:31:19 -0800 (PST) DKIM-Signature: v=1; a=rsa-sha256; c=relaxed/relaxed; d=gmail.com; s=gamma; h=domainkey-signature:mime-version:received:in-reply-to:references :from:date:message-id:subject:to:content-type :content-transfer-encoding; bh=4mZlslvLfC5L6o74/M+EIJmi02hasm2MvEaVEYpl9Lg=; b=ipRPH06Uw/akTh/idxUi1o9SIF7pCwLHE82/qlVOfptkuyof5Gy8v2RgX3Tgk/zP7B 1qVpCJHHf+Tsu9vbVMWZ/hRGls8COPRefYsEw0GStHHG+l9/o4ogPp0vNcAX0QDGDcLL e3Igy7e0inkR9crBDJ63IKD+wI9n98nGIPpTM= DomainKey-Signature: a=rsa-sha1; c=nofws; d=gmail.com; s=gamma; h=mime-version:in-reply-to:references:from:date:message-id:subject:to :content-type:content-transfer-encoding; b=IAHVixMinMStKSENNg1AJ6J3IQy9vaAgnctytaXlBjjnZD2amH4B1xy3OzWg0NfmEl EdZskbNqj5bWMukAMUsMbHRvbMa4X1XDsI+OILRMhA7BgWxfTJAQFQiEcRU4SCQaG56H ZtJndYj6d927vvPVW7zVpm6AqzjOnX9e+JhKI= MIME-Version: 1.0 Received: by 10.216.87.3 with SMTP id x3mr616414wee.132.1257388279146; Wed, 04 Nov 2009 18:31:19 -0800 (PST) In-Reply-To: References: From: Jonathan Ellis Date: Wed, 4 Nov 2009 20:30:59 -0600 Message-ID: Subject: Re: gossip & partitioning To: cassandra-dev@incubator.apache.org Content-Type: text/plain; charset=ISO-8859-1 Content-Transfer-Encoding: quoted-printable X-Virus-Checked: Checked by ClamAV on apache.org Yes, I was missing something. EndPointState is maintained in its entirety for each node in Gossiper, but onChange is called on EPS containing only a single "delta" key. On Wed, Nov 4, 2009 at 3:25 PM, Jonathan Ellis wrote: > There's some code in StorageService.onChange that looks like this: > > =A0 =A0 =A0 =A0// if there is no token data in the endpointstate > =A0 =A0 =A0 =A0 =A0 =A0/* > =A0 =A0 =A0 =A0 =A0 =A0 * If we are here and if this node is UP and alrea= dy has an entry > =A0 =A0 =A0 =A0 =A0 =A0 * in the token map. It means that the node was be= hind a > network partition. > =A0 =A0 =A0 =A0 =A0 =A0*/ > =A0 =A0 =A0 =A0 =A0 =A0if ( epState.isAlive() && tokenMetadata_.isKnownEn= dPoint(endpoint) ) > =A0 =A0 =A0 =A0 =A0 =A0{ > =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0logger_.debug("EndPoint " + ep + " just re= covered from > a partition. Sending hinted data."); > =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0// send hinted handoffs > =A0 =A0 =A0 =A0 =A0 =A0} > > I don't see how you could actually have null token data. =A0Since token > (NODE_ID) is the first thing a node gossips, and is required for an > entry to be added to tokenMetadata, I don't see how that could > disappear from EndPointState. =A0My understanding is that Gossiper never > actually discards data from EndPointState, only updates it with > more-current information (see applyApplicationStateLocally). > > Am I missing something, or can this part of onChange be safely removed? > > -Jonathan >