Return-Path: 
 <user-return-738-apmail-curator-user-archive=curator.apache.org@curator.apache.org>
X-Original-To: apmail-curator-user-archive@minotaur.apache.org
Delivered-To: apmail-curator-user-archive@minotaur.apache.org
Received: from mail.apache.org (hermes.apache.org [140.211.11.3])
	by minotaur.apache.org (Postfix) with SMTP id 150E2111D9
	for <apmail-curator-user-archive@minotaur.apache.org>;
 Fri, 19 Sep 2014 20:31:31 +0000 (UTC)
Received: (qmail 48376 invoked by uid 500); 19 Sep 2014 20:31:31 -0000
Delivered-To: apmail-curator-user-archive@curator.apache.org
Received: (qmail 48334 invoked by uid 500); 19 Sep 2014 20:31:30 -0000
Mailing-List: contact user-help@curator.apache.org; run by ezmlm
Precedence: bulk
List-Help: <mailto:user-help@curator.apache.org>
List-Unsubscribe: <mailto:user-unsubscribe@curator.apache.org>
List-Post: <mailto:user@curator.apache.org>
List-Id: <user.curator.apache.org>
Reply-To: user@curator.apache.org
Delivered-To: mailing list user@curator.apache.org
Received: (qmail 48324 invoked by uid 99); 19 Sep 2014 20:31:30 -0000
Received: from athena.apache.org (HELO athena.apache.org) (140.211.11.136)
    by apache.org (qpsmtpd/0.29) with ESMTP; Fri, 19 Sep 2014 20:31:30 +0000
X-ASF-Spam-Status: No, hits=2.2 required=5.0
	tests=HTML_MESSAGE,RCVD_IN_DNSWL_LOW,SPF_NEUTRAL
X-Spam-Check-By: apache.org
Received-SPF: neutral (athena.apache.org: local policy)
Received: from [209.85.192.180] (HELO mail-pd0-f180.google.com)
 (209.85.192.180)
    by apache.org (qpsmtpd/0.29) with ESMTP; Fri, 19 Sep 2014 20:31:26 +0000
Received: by mail-pd0-f180.google.com with SMTP id r10so599040pdi.11
        for <user@curator.apache.org>; Fri, 19 Sep 2014 13:31:05 -0700 (PDT)
X-Google-DKIM-Signature: v=1; a=rsa-sha256; c=relaxed/relaxed;
        d=1e100.net; s=20130820;
        h=x-gm-message-state:date:from:to:message-id:in-reply-to:references
         :subject:mime-version:content-type;
        bh=Cquc6KKPg0xBg8RHUG9wIon2IxZYLhoheLHtZDtw00Q=;
        b=Jk3p9EJAM4LXtyCF0q8CmeSJCr+0VhTqjPE9S3QT+4u9k3PNWk9ycUetiW+8aDAP5K
         Kyc4z+nnALEgc2byYN7YH/F7apGzq4rxFW5uGno/qFBaB9rfdTouzE7Vj2BdfaZEb+DH
         46DZ/uZYpkULdHQnhZae7gEF8Tk02O/mWU9OSQ7jTtHQHEpiT8yRnBDc2imkQYPtlyJE
         LbRfg8QE+eAYUQsZ7OSnd6lJvhy/0fnueJXHeifPv6v/SSbcI9UNgNfQe+dqq2QDC+jN
         MkLY2fChB9XnsSMhXswHICL5fAtdKWInvHZ+O+XZKwqnKpGDaDL7F5lrNP5M9n0PKfRx
         wF/Q==
X-Gm-Message-State: 
 ALoCoQkAGRxVdaOmmS29zscS/RqltYT9IO0TTgClj7k6EkoKU39sSpQpIlzRtjwtd0pc3lWGrO1/
X-Received: by 10.66.155.105 with SMTP id vv9mr4654632pab.61.1411158665062;
        Fri, 19 Sep 2014 13:31:05 -0700 (PDT)
Received: from Jordans-MacBook-Pro.local ([190.141.38.38])
        by mx.google.com with ESMTPSA id
 hs8sm2651966pbc.35.2014.09.19.13.31.03
        for <multiple recipients>
        (version=SSLv3 cipher=RC4-SHA bits=128/128);
        Fri, 19 Sep 2014 13:31:04 -0700 (PDT)
Date: Fri, 19 Sep 2014 15:31:02 -0500
From: Jordan Zimmerman <jordan@jordanzimmerman.com>
To: Purshotam Shah <purushah@yahoo-inc.com>,
 "=?utf-8?Q?user=40curator.apache.org?=" <user@curator.apache.org>
Message-ID: <etPan.541c9286.4427069a.116@Jordans-MacBook-Pro.local>
In-Reply-To: <D041A897.4749E%purushah@yahoo-inc.com>
References: <CFCF6FFB.36848%purushah@yahoo-inc.com>
 <CFCF719E.36854%purushah@yahoo-inc.com>
 <etPan.53aa282b.7644a45c.11c@Jordans-MacBook-Pro.local>
 <CFD0A46A.369E7%purushah@yahoo-inc.com>
 <D041A897.4749E%purushah@yahoo-inc.com>
Subject: Re: DistributedAtomicLong fails in multithread env.
X-Mailer: Airmail (247)
MIME-Version: 1.0
Content-Type: multipart/alternative; boundary="541c9286_b37e80a_116"
X-Virus-Checked: Checked by ClamAV on apache.org

--541c9286_b37e80a_116
Content-Type: text/plain; charset="utf-8"
Content-Transfer-Encoding: quoted-printable
Content-Disposition: inline

Are you using a=C2=A0PromotedToLock=3F Combined with a reasonable retry i=
t should make failures almost never happen. You can also just set the num=
ber of retries to a huge number.

-Jordan


On September 19, 2014 at 12:38:52 PM, Purshotam Shah (purushah=40yahoo-in=
c.com) wrote:

Hi=C2=A0Jordan,

Same issue with Curator 2.5.0.
I read one of your mail thread (can't find it now) where you said that Di=
stributedAtomicLong is not guarantee to succeed in multithread env, we ha=
ve to keep on trying until it succeed.

Is that true=3F This is becoming bottleneck in our stress testing. When t=
ry to call DistributedAtomicLong =C2=A0concurrently from multiple thread =
(30 thread), we see few failures (with retry policy =22ExponentialBackoff=
Retry(1000, 3))=22.

What is the best way to guarantee that DistributedAtomicLong will always =
succeed=3F


Thanks,
Puru

=46rom: Purshotam Shah <purushah=40yahoo-inc.com>
Date: Wednesday, June 25, 2014 at 4:12 PM
To: Jordan Zimmerman <jordan=40jordanzimmerman.com>, =22user=40curator.ap=
ache.org=22 <user=40curator.apache.org>
Subject: Re: DistributedAtomicLong fails in multithread env.

Thanks.=C2=A0
Looks like it=E2=80=99s working fine with=C2=A0Curator 2.5.0.
Will do some more testing. Will respond if it fails with 2.5.0.

Thanks,
Puru.



=46rom: Jordan Zimmerman <jordan=40jordanzimmerman.com>
Date: Tuesday, June 24, 2014 at 6:38 PM
To: Purshotam Shah <purushah=40yahoo-inc.com>, =22user=40curator.apache.o=
rg=22 <user=40curator.apache.org>
Subject: Re: DistributedAtomicLong fails in multithread env.

This sounds like=C2=A0https://issues.apache.org/jira/browse/CURATOR-108=C2=
=A0- Curator 2.5.0 added a new method, initialize(), to work around this =
issue. Please try that and let me know.

-Jordan


=46rom:=C2=A0Purshotam Shah purushah=40yahoo-inc.com
Reply:=C2=A0user=40curator.apache.orguser=40curator.apache.org
Date:=C2=A0June 24, 2014 at 8:20:18 PM
To:=C2=A0user=40curator.apache.orguser=40curator.apache.org
Subject:=C2=A0 DistributedAtomicLong fails in multithread env.

We are using DistributedAtomicLong to use job sequenceID in ZK.

We noticed that getZKId in multithread env fails. value.preValue() and va=
lue.postValue() value =3D 0 and succeeded =3D false.

If we synchronized the function it works fine, but I don't think it's a r=
ight approach.

Other approach is to retry multiple time, but how many times. We need to =
make sure that getZKId return sequence.

What is the best approach=3F


=C2=A0 =C2=A0 DistributedAtomicLong atomicIdGenerator;
=C2=A0 =C2=A0 PromotedToLock.Builder lockBuilder =3D PromotedToLock.build=
er()
=C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 .lo=
ckPath(getPromotedLock()).retryPolicy(ZKUtils.getRetryPloicy())
=C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 .ti=
meout(Service.lockTimeout, TimeUnit.MILLISECONDS);
=C2=A0 =C2=A0 =C2=A0atomicIdGenerator =3D new DistributedAtomicLong(zk.ge=
tClient(), ZK=5FSEQUENCE=5FPATH, ZKUtils.getRetryPloicy(),
=C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 loc=
kBuilder.build());

=C2=A0 =C2=A0 private =C2=A0long getZKId( ) =7B
=C2=A0 =C2=A0 =C2=A0 =C2=A0 if (atomicIdGenerator =3D=3D null) =7B
=C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 throw new RuntimeException(=22S=
equence generator can't be null. Path : =22 + ZK=5FSEQUENCE=5FPATH);
=C2=A0 =C2=A0 =C2=A0 =C2=A0 =7D
=C2=A0 =C2=A0 =C2=A0 =C2=A0 AtomicValue<Long> value =3D null;
=C2=A0 =C2=A0 =C2=A0 =C2=A0 try =7B
=C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 value =3D atomicIdGenerator.inc=
rement();
=C2=A0 =C2=A0 =C2=A0 =C2=A0 =7D
=C2=A0 =C2=A0 =C2=A0 =C2=A0 catch (Exception e) =7B
=C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 throw new RuntimeException(=22E=
xception incrementing UID for session =22, e);
=C2=A0 =C2=A0 =C2=A0 =C2=A0 =7D
=C2=A0 =C2=A0 =C2=A0 =C2=A0 finally =7B
=C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 if (value =21=3D null && value.=
succeeded()) =7B
=C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 return value.preV=
alue();
=C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =7D
=C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 else =7B
=C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 throw new Runtime=
Exception(=22Exception incrementing UID for session =22);
=C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =7D
=C2=A0 =C2=A0 =C2=A0 =C2=A0 =7D

=C2=A0 =C2=A0 =7D
--541c9286_b37e80a_116
Content-Type: text/html; charset="utf-8"
Content-Transfer-Encoding: quoted-printable
Content-Disposition: inline

<html><head><style>body=7Bfont-family:Helvetica,Arial;font-size:13px=7D</=
style></head><body style=3D=22word-wrap: break-word; -webkit-nbsp-mode: s=
pace; -webkit-line-break: after-white-space;=22><div id=3D=22bloop=5Fcust=
omfont=22 style=3D=22font-family:Helvetica,Arial;font-size:13px; color: r=
gba(0,0,0,1.0); margin: 0px; line-height: auto;=22>Are you using a&nbsp;P=
romotedToLock=3F Combined with a reasonable retry it should make failures=
 almost never happen. You can also just set the number of retries to a hu=
ge number.</div><div id=3D=22bloop=5Fcustomfont=22 style=3D=22font-family=
:Helvetica,Arial;font-size:13px; color: rgba(0,0,0,1.0); margin: 0px; lin=
e-height: auto;=22><br></div><div id=3D=22bloop=5Fcustomfont=22 style=3D=22=
font-family:Helvetica,Arial;font-size:13px; color: rgba(0,0,0,1.0); margi=
n: 0px; line-height: auto;=22>-Jordan</div> <div id=3D=22bloop=5Fsign=5F1=
411158597786930944=22 class=3D=22bloop=5Fsign=22><div style=3D=22font-fam=
ily:helvetica,arial;font-size:13px=22><br></div></div> <br><p style=3D=22=
color:=23000;=22>On September 19, 2014 at 12:38:52 PM, Purshotam Shah (<a=
 href=3D=22mailto:purushah=40yahoo-inc.com=22>purushah=40yahoo-inc.com</a=
>) wrote:</p> <blockquote type=3D=22cite=22 class=3D=22clean=5Fbq=22><spa=
n><div style=3D=22word-wrap: break-word; -webkit-nbsp-mode: space; -webki=
t-line-break: after-white-space; color: rgb(0, 0, 0); font-size: 14px; fo=
nt-family: Calibri, sans-serif;=22><div></div><div>




<title></title>



<div>
<div>Hi&nbsp;<span style=3D=22font-family: Helvetica, Arial; font-size: 1=
3px;=22>Jordan,</span></div>
<div><br></div>
<div>Same issue with Curator 2.5.0.</div>
<div>I read one of your mail thread (can't find it now) where you
said that DistributedAtomicLong is not guarantee to succeed in
multithread env, we have to keep on trying until it succeed.</div>
<div><span style=3D=22font-family: Helvetica, Arial; font-size: 13px;=22>=
<br></span></div>
<div><span style=3D=22font-family: Helvetica, Arial; font-size: 13px;=22>=
Is that true=3F
This is becoming bottleneck in our stress testing. When try to call
DistributedAtomicLong &nbsp;concurrently from multiple thread (30
thread), we see few failures (with retry policy
=22ExponentialBackoffRetry(1000, 3))=22.</span></div>
<div><span style=3D=22font-family: Helvetica, Arial; font-size: 13px;=22>=
<br></span></div>
<div><span style=3D=22font-family: Helvetica, Arial; font-size: 13px;=22>=
What is the best
way to guarantee that DistributedAtomicLong will always
succeed=3F</span></div>
</div>
<div><span style=3D=22font-family: Helvetica, Arial; font-size: 13px;=22>=
<br></span></div>
<div><span style=3D=22font-family: Helvetica, Arial; font-size: 13px;=22>=
<br></span></div>
<div><span style=3D=22font-family: Helvetica, Arial; font-size: 13px;=22>=
Thanks,</span></div>
<div><span style=3D=22font-family: Helvetica, Arial; font-size: 13px;=22>=
Puru</span></div>
<div><br></div>
<span id=3D=22OLK=5FSRC=5FBODY=5FSECTION=22></span>
<div style=3D=22font-family:Calibri; font-size:11pt; text-align:left; col=
or:black; BORDER-BOTTOM: medium none; BORDER-LE=46T: medium none; PADDING=
-BOTTOM: 0in; PADDING-LE=46T: 0in; PADDING-RIGHT: 0in; BORDER-TOP: =23b5c=
4df 1pt solid; BORDER-RIGHT: medium none; PADDING-TOP: 3pt=22>
<span id=3D=22OLK=5FSRC=5FBODY=5FSECTION=22><span style=3D=22font-weight:=
bold=22>=46rom:</span> Purshotam Shah &lt;<a href=3D=22mailto:purushah=40=
yahoo-inc.com=22>purushah=40yahoo-inc.com</a>&gt;<br>

<span style=3D=22font-weight:bold=22>Date:</span> Wednesday, June 25,
2014 at 4:12 PM<br>
<span style=3D=22font-weight:bold=22>To:</span> Jordan Zimmerman
&lt;<a href=3D=22mailto:jordan=40jordanzimmerman.com=22>jordan=40jordanzi=
mmerman.com</a>&gt;,
=22<a href=3D=22mailto:user=40curator.apache.org=22>user=40curator.apache=
.org</a>=22
&lt;<a href=3D=22mailto:user=40curator.apache.org=22>user=40curator.apach=
e.org</a>&gt;<br>

<span style=3D=22font-weight:bold=22>Subject:</span> Re:
DistributedAtomicLong fails in multithread env.<br></span></div>
<div><br></div>
<div>
<div style=3D=22word-wrap: break-word; -webkit-nbsp-mode: space; -webkit-=
line-break: after-white-space;=22>
<div style=3D=22color: rgb(0, 0, 0); font-family: Calibri, sans-serif; fo=
nt-size: 14px;=22>
Thanks.&nbsp;</div>
<div style=3D=22color: rgb(0, 0, 0); font-family: Calibri, sans-serif; fo=
nt-size: 14px;=22>
Looks like it=E2=80=99s working fine with&nbsp;<span style=3D=22font-fami=
ly: Helvetica, Arial; font-size: 13px;=22>Curator
2.5.0.</span></div>
<div>Will do some more testing. Will respond if it fails with
2.5.0.</div>
<div><br></div>
<div>Thanks,</div>
<div>Puru.</div>
<div style=3D=22color: rgb(0, 0, 0); font-family: Calibri, sans-serif; fo=
nt-size: 14px;=22>
<span style=3D=22font-family: Helvetica, Arial; font-size: 13px;=22><br><=
/span></div>
<div style=3D=22color: rgb(0, 0, 0); font-family: Calibri, sans-serif; fo=
nt-size: 14px;=22>
<br></div>
<div style=3D=22color: rgb(0, 0, 0); font-family: Calibri, sans-serif; fo=
nt-size: 14px;=22>
<br></div>
<span id=3D=22OLK=5FSRC=5FBODY=5FSECTION=22 style=3D=22color: rgb(0, 0, 0=
); font-family: Calibri, sans-serif; font-size: 14px;=22></span>
<div style=3D=22font-family:Calibri; font-size:11pt; text-align:left; col=
or:black; BORDER-BOTTOM: medium none; BORDER-LE=46T: medium none; PADDING=
-BOTTOM: 0in; PADDING-LE=46T: 0in; PADDING-RIGHT: 0in; BORDER-TOP: =23b5c=
4df 1pt solid; BORDER-RIGHT: medium none; PADDING-TOP: 3pt=22>
<span id=3D=22OLK=5FSRC=5FBODY=5FSECTION=22 style=3D=22color: rgb(0, 0, 0=
); font-family: Calibri, sans-serif; font-size: 14px;=22>
<span style=3D=22font-weight:bold=22>=46rom:</span> Jordan Zimmerman
&lt;<a href=3D=22mailto:jordan=40jordanzimmerman.com=22>jordan=40jordanzi=
mmerman.com</a>&gt;<br>

<span style=3D=22font-weight:bold=22>Date:</span> Tuesday, June 24, 2014
at 6:38 PM<br>
<span style=3D=22font-weight:bold=22>To:</span> Purshotam Shah
&lt;<a href=3D=22mailto:purushah=40yahoo-inc.com=22>purushah=40yahoo-inc.=
com</a>&gt;,
=22<a href=3D=22mailto:user=40curator.apache.org=22>user=40curator.apache=
.org</a>=22
&lt;<a href=3D=22mailto:user=40curator.apache.org=22>user=40curator.apach=
e.org</a>&gt;<br>

<span style=3D=22font-weight:bold=22>Subject:</span> Re:
DistributedAtomicLong fails in multithread env.<br></span></div>
<div><br></div>
<div>
<div style=3D=22word-wrap: break-word; -webkit-nbsp-mode: space; -webkit-=
line-break: after-white-space;=22>
<div id=3D=22bloop=5Fcustomfont=22 style=3D=22font-family:Helvetica,Arial=
;font-size:13px; color: rgba(0,0,0,1.0); margin: 0px; line-height: auto;=22=
>
This sounds like&nbsp;<a href=3D=22https://issues.apache.org/jira/browse/=
CURATOR-108=22>https://issues.apache.org/jira/browse/CURATOR-108</a>&nbsp=
;-
Curator 2.5.0 added a new method, initialize(), to work around this
issue. Please try that and let me know.</div>
<div id=3D=22bloop=5Fcustomfont=22 style=3D=22font-family:Helvetica,Arial=
;font-size:13px; color: rgba(0,0,0,1.0); margin: 0px; line-height: auto;=22=
>
<br></div>
<div id=3D=22bloop=5Fcustomfont=22 style=3D=22font-family:Helvetica,Arial=
;font-size:13px; color: rgba(0,0,0,1.0); margin: 0px; line-height: auto;=22=
>
-Jordan</div>
<div id=3D=22bloop=5Fsign=5F1403660048721691136=22 class=3D=22bloop=5Fsig=
n=22>
<div style=3D=22font-family:helvetica,arial;font-size:13px=22>
<br></div>
</div>
<div style=3D=22color:black=22><br>
=46rom:&nbsp;<span style=3D=22color:black=22>Purshotam Shah</span> <a hre=
f=3D=22mailto:purushah=40yahoo-inc.com=22>purushah=40yahoo-inc.com</a><br=
>
Reply:&nbsp;<span style=3D=22color:black=22><a href=3D=22mailto:user=40cu=
rator.apache.org=22>user=40curator.apache.org</a></span><a href=3D=22mail=
to:user=40curator.apache.org=22>user=40curator.apache.org</a><br>

Date:&nbsp;<span style=3D=22color:black=22>June 24, 2014 at 8:20:18
PM</span><br>
To:&nbsp;<span style=3D=22color:black=22><a href=3D=22mailto:user=40curat=
or.apache.org=22>user=40curator.apache.org</a></span><a href=3D=22mailto:=
user=40curator.apache.org=22>user=40curator.apache.org</a><br>

Subject:&nbsp; <span style=3D=22color:black=22>DistributedAtomicLong
fails in multithread env.<br></span></div>
<br>
<blockquote type=3D=22cite=22 class=3D=22clean=5Fbq=22>
<div style=3D=22word-wrap: break-word; -webkit-nbsp-mode: space; -webkit-=
line-break: after-white-space; color: rgb(0, 0, 0); font-size: 14px; font=
-family: Calibri, sans-serif;=22>
<div>
<div><span>We are using DistributedAtomicLong to use job sequenceID
in ZK.</span></div>
<span><span id=3D=22OLK=5FSRC=5FBODY=5FSECTION=22></span></span>
<div style=3D=22word-wrap: break-word; -webkit-nbsp-mode: space; -webkit-=
line-break: after-white-space; color: rgb(0, 0, 0); font-size: 14px; font=
-family: Calibri, sans-serif;=22>
<span id=3D=22OLK=5FSRC=5FBODY=5FSECTION=22></span>
<div><span id=3D=22OLK=5FSRC=5FBODY=5FSECTION=22><br></span></div>
<div><span id=3D=22OLK=5FSRC=5FBODY=5FSECTION=22>We noticed that getZKId =
in
multithread env fails. value.preValue() and value.postValue() value
=3D 0 and succeeded =3D false.</span></div>
<div><span id=3D=22OLK=5FSRC=5FBODY=5FSECTION=22><br></span></div>
<div><span id=3D=22OLK=5FSRC=5FBODY=5FSECTION=22>If we synchronized the
function it works fine, but I don't think it's a right
approach.</span></div>
<div><span id=3D=22OLK=5FSRC=5FBODY=5FSECTION=22><br></span></div>
<div><span id=3D=22OLK=5FSRC=5FBODY=5FSECTION=22>Other approach is to ret=
ry
multiple time, but how many times. We need to make sure that
getZKId return sequence.</span></div>
<div><span id=3D=22OLK=5FSRC=5FBODY=5FSECTION=22><br></span></div>
<div><span id=3D=22OLK=5FSRC=5FBODY=5FSECTION=22>What is the best
approach=3F</span></div>
<div><span id=3D=22OLK=5FSRC=5FBODY=5FSECTION=22><br></span></div>
<div><span id=3D=22OLK=5FSRC=5FBODY=5FSECTION=22><br></span></div>
<div><span id=3D=22OLK=5FSRC=5FBODY=5FSECTION=22>&nbsp; &nbsp;
DistributedAtomicLong atomicIdGenerator;</span></div>
<div><span id=3D=22OLK=5FSRC=5FBODY=5FSECTION=22>&nbsp; &nbsp;
PromotedToLock.Builder lockBuilder =3D
PromotedToLock.builder()</span></div>
<div><span id=3D=22OLK=5FSRC=5FBODY=5FSECTION=22>&nbsp; &nbsp; &nbsp; &nb=
sp;
&nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp;
.lockPath(getPromotedLock()).retryPolicy(ZKUtils.getRetryPloicy())</span>=
</div>
<div><span id=3D=22OLK=5FSRC=5FBODY=5FSECTION=22>&nbsp; &nbsp; &nbsp; &nb=
sp;
&nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp;
.timeout(Service.lockTimeout, TimeUnit.MILLISECONDS);</span></div>
<div><span id=3D=22OLK=5FSRC=5FBODY=5FSECTION=22>&nbsp; &nbsp;
&nbsp;atomicIdGenerator =3D new DistributedAtomicLong(zk.getClient(),
ZK=5FSEQUENCE=5FPATH, ZKUtils.getRetryPloicy(),</span></div>
<div><span id=3D=22OLK=5FSRC=5FBODY=5FSECTION=22>&nbsp; &nbsp; &nbsp; &nb=
sp;
&nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp;
lockBuilder.build());</span></div>
<div><span id=3D=22OLK=5FSRC=5FBODY=5FSECTION=22><br></span></div>
<div><span id=3D=22OLK=5FSRC=5FBODY=5FSECTION=22>&nbsp; &nbsp; private
&nbsp;long getZKId( ) =7B</span></div>
<div><span id=3D=22OLK=5FSRC=5FBODY=5FSECTION=22>&nbsp; &nbsp; &nbsp; &nb=
sp; if
(atomicIdGenerator =3D=3D null) =7B</span></div>
<div><span id=3D=22OLK=5FSRC=5FBODY=5FSECTION=22>&nbsp; &nbsp; &nbsp; &nb=
sp;
&nbsp; &nbsp; throw new RuntimeException(=22Sequence generator can't
be null. Path : =22 + ZK=5FSEQUENCE=5FPATH);</span></div>
<div><span id=3D=22OLK=5FSRC=5FBODY=5FSECTION=22>&nbsp; &nbsp; &nbsp; &nb=
sp;
=7D</span></div>
<div><span id=3D=22OLK=5FSRC=5FBODY=5FSECTION=22>&nbsp; &nbsp; &nbsp; &nb=
sp;
AtomicValue&lt;Long&gt; value =3D null;</span></div>
<div><span id=3D=22OLK=5FSRC=5FBODY=5FSECTION=22>&nbsp; &nbsp; &nbsp; &nb=
sp;
try =7B</span></div>
<div><span id=3D=22OLK=5FSRC=5FBODY=5FSECTION=22>&nbsp; &nbsp; &nbsp; &nb=
sp;
&nbsp; &nbsp; value =3D atomicIdGenerator.increment();</span></div>
<div><span id=3D=22OLK=5FSRC=5FBODY=5FSECTION=22>&nbsp; &nbsp; &nbsp; &nb=
sp;
=7D</span></div>
<div><span id=3D=22OLK=5FSRC=5FBODY=5FSECTION=22>&nbsp; &nbsp; &nbsp; &nb=
sp;
catch (Exception e) =7B</span></div>
<div><span id=3D=22OLK=5FSRC=5FBODY=5FSECTION=22>&nbsp; &nbsp; &nbsp; &nb=
sp;
&nbsp; &nbsp; throw new RuntimeException(=22Exception incrementing
UID for session =22, e);</span></div>
<div><span id=3D=22OLK=5FSRC=5FBODY=5FSECTION=22>&nbsp; &nbsp; &nbsp; &nb=
sp;
=7D</span></div>
<div><span id=3D=22OLK=5FSRC=5FBODY=5FSECTION=22>&nbsp; &nbsp; &nbsp; &nb=
sp;
finally =7B</span></div>
<div><span id=3D=22OLK=5FSRC=5FBODY=5FSECTION=22>&nbsp; &nbsp; &nbsp; &nb=
sp;
&nbsp; &nbsp; if (value =21=3D null &amp;&amp; value.succeeded())
=7B</span></div>
<div><span id=3D=22OLK=5FSRC=5FBODY=5FSECTION=22>&nbsp; &nbsp; &nbsp; &nb=
sp;
&nbsp; &nbsp; &nbsp; &nbsp; return value.preValue();</span></div>
<div><span id=3D=22OLK=5FSRC=5FBODY=5FSECTION=22>&nbsp; &nbsp; &nbsp; &nb=
sp;
&nbsp; &nbsp; =7D</span></div>
<div><span id=3D=22OLK=5FSRC=5FBODY=5FSECTION=22>&nbsp; &nbsp; &nbsp; &nb=
sp;
&nbsp; &nbsp; else =7B</span></div>
<div><span id=3D=22OLK=5FSRC=5FBODY=5FSECTION=22>&nbsp; &nbsp; &nbsp; &nb=
sp;
&nbsp; &nbsp; &nbsp; &nbsp; throw new RuntimeException(=22Exception
incrementing UID for session =22);</span></div>
<div><span id=3D=22OLK=5FSRC=5FBODY=5FSECTION=22>&nbsp; &nbsp; &nbsp; &nb=
sp;
&nbsp; &nbsp; =7D</span></div>
<div><span id=3D=22OLK=5FSRC=5FBODY=5FSECTION=22>&nbsp; &nbsp; &nbsp; &nb=
sp;
=7D</span></div>
<div><span id=3D=22OLK=5FSRC=5FBODY=5FSECTION=22><br></span></div>
<div><span id=3D=22OLK=5FSRC=5FBODY=5FSECTION=22>&nbsp; &nbsp; =7D</span>=
</div>
</div>
</div>
</div>
</blockquote>
</div>
</div>
</div>
</div>


</div></div></span></blockquote></body></html>
--541c9286_b37e80a_116--