Mailing-List: contact user-help@ignite.apache.org; run by ezmlm
Precedence: bulk
Reply-To: user@ignite.apache.org
MIME-Version: 1.0
In-Reply-To: <CALPm_-CBe9esmcqJZnr=vrEbL9gwc+O12+myc+eGvEZ5on2kqQ@mail.gmail.com>
References: <CALPm_-CpHJE+Z=01g6FenAMUayX+HU3bDLn-tASkmftG=Kx6dA@mail.gmail.com>
 <CAOKDqC-oiFWEf=Sm59myu1i8ngFB0UfNvr53kb5UtR5Qy3Q63A@mail.gmail.com>
 <CALPm_-D3mB5QbZVY+i=Kk6XyMMSoQUO=8Tqu6X_psstApzrymw@mail.gmail.com>
 <CAOKDqC9sYJq=VVcQZq_gsv8akapnCcZd+k3hO4vdwDPW9GOLSw@mail.gmail.com>
 <CALPm_-BS3=OaU_OCWfvv5aNZ+x3sZ28MX_7Av=RuKVYmq0seGQ@mail.gmail.com>
 <CAOKDqC_Ne=nny-ux9O3msUknp=fDp_a2RGc73u5f3wq4nw6jkA@mail.gmail.com>
 <CADez4_U7RgOnfpDif6Bct3-R3p5RqqoydarU4JRYnidwMggGKQ@mail.gmail.com> <CALPm_-CBe9esmcqJZnr=vrEbL9gwc+O12+myc+eGvEZ5on2kqQ@mail.gmail.com>
From: Anil <anilklce@gmail.com>
Date: Wed, 9 Nov 2016 19:56:45 +0530
Message-ID: <CALPm_-CBt9_fbngXGBQ1qWYMMX8HcKgZD_sOf6g3K2ohC6rtZg@mail.gmail.com>
Subject: Re: DataStreamer is closed
To: user@ignite.apache.org
Content-Type: multipart/mixed; boundary=001a114fcaa855fe9a0540df0e92
archived-at: Wed, 09 Nov 2016 14:27:42 -0000

--001a114fcaa855fe9a0540df0e92
Content-Type: multipart/alternative; boundary=001a114fcaa855fe930540df0e90

--001a114fcaa855fe930540df0e90
Content-Type: text/plain; charset=UTF-8

HI,

Data streamer closed exception is very frequent. I did not see any explicit
errors/exception about data streamer close. the excption i see only when
message is getting added.

I have 4 node ignite cluster and each node have consumer to connection and
push the message received to streamer.

What if the node is down and re-joined when message is getting added cache.

Following is the exception from logs -

2016-11-09 05:55:55 ERROR pool-6-thread-1 KafkaCacheDataStreamer:146 -
Exception while adding to streamer
java.lang.IllegalStateException: Data streamer has been closed.
        at
org.apache.ignite.internal.processors.datastreamer.DataStreamerImpl.enterBusy(DataStreamerImpl.java:360)
        at
org.apache.ignite.internal.processors.datastreamer.DataStreamerImpl.addData(DataStreamerImpl.java:507)
        at
org.apache.ignite.internal.processors.datastreamer.DataStreamerImpl.addData(DataStreamerImpl.java:498)
        at
com.test.cs.cache.KafkaCacheDataStreamer.addMessage(KafkaCacheDataStreamer.java:140)
        at
com.test.cs.cache.KafkaCacheDataStreamer$1.run(KafkaCacheDataStreamer.java:197)
        at
java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
        at java.util.concurrent.FutureTask.run(FutureTask.java:266)
        at
java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142)
        at
java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617)
        at java.lang.Thread.run(Thread.java:745)
2016-11-09 05:55:55 ERROR pool-6-thread-1 KafkaCacheDataStreamer:200 -
Message is ignored due to an error
[msg=MessageAndMetadata(TestTopic,1,Message(magic = 0, attributes = 0, crc
= 2111790081, key = null, payload = java.nio.HeapByteBuffer[pos=0 lim=1155
cap=1155]),2034,kafka.serializer.StringDecoder@3f77f0b
,kafka.serializer.StringDecoder@67fd2da0)]
java.lang.IllegalStateException: Cache has been closed or destroyed:
PERSON_CACHE
        at
org.apache.ignite.internal.processors.cache.GridCacheGateway.enter(GridCacheGateway.java:160)
        at
org.apache.ignite.internal.processors.cache.IgniteCacheProxy.onEnter(IgniteCacheProxy.java:2103)
        at
org.apache.ignite.internal.processors.cache.IgniteCacheProxy.size(IgniteCacheProxy.java:826)
        at
com.test.cs.cache.KafkaCacheDataStreamer.addMessage(KafkaCacheDataStreamer.java:149)
        at
com.test.cs.cache.KafkaCacheDataStreamer$1.run(KafkaCacheDataStreamer.java:197)
        at
java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
        at java.util.concurrent.FutureTask.run(FutureTask.java:266)
        at
java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142)
        at
java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617)
        at java.lang.Thread.run(Thread.java:745)

I have attached the KafkaCacheDataStreamer class and let me know if you
need any additional details. thanks.

--001a114fcaa855fe930540df0e90
Content-Type: text/html; charset=UTF-8
Content-Transfer-Encoding: quoted-printable

<div dir=3D"ltr"><div class=3D"gmail_extra">HI,</div><div class=3D"gmail_ex=
tra"><br></div><div class=3D"gmail_extra">Data streamer closed exception is=
 very frequent. I did not see any explicit errors/exception about data stre=
amer close. the excption i see only when message is getting added.</div><di=
v class=3D"gmail_extra"><br></div><div class=3D"gmail_extra">I have 4 node =
ignite cluster and each node have consumer to connection and push the messa=
ge received to streamer.</div><div class=3D"gmail_extra"><br></div><div cla=
ss=3D"gmail_extra">What if the node is down and re-joined when message is g=
etting added cache.=C2=A0</div><div class=3D"gmail_extra"><br></div><div cl=
ass=3D"gmail_extra">Following is the exception from logs -</div><div class=
=3D"gmail_extra"><br></div><div class=3D"gmail_extra"><div class=3D"gmail_e=
xtra">2016-11-09 05:55:55 ERROR pool-6-thread-1 KafkaCacheDataStreamer:146 =
- Exception while adding to streamer</div><div class=3D"gmail_extra">java.l=
ang.IllegalStateException: Data streamer has been closed.</div><div class=
=3D"gmail_extra">=C2=A0 =C2=A0 =C2=A0 =C2=A0 at org.apache.ignite.internal.=
processors.datastreamer.DataStreamerImpl.enterBusy(DataStreamerImpl.java:36=
0)</div><div class=3D"gmail_extra">=C2=A0 =C2=A0 =C2=A0 =C2=A0 at org.apach=
e.ignite.internal.processors.datastreamer.DataStreamerImpl.addData(DataStre=
amerImpl.java:507)</div><div class=3D"gmail_extra">=C2=A0 =C2=A0 =C2=A0 =C2=
=A0 at org.apache.ignite.internal.processors.datastreamer.DataStreamerImpl.=
addData(DataStreamerImpl.java:498)</div><div class=3D"gmail_extra">=C2=A0 =
=C2=A0 =C2=A0 =C2=A0 at com.test.cs.cache.KafkaCacheDataStreamer.addMessage=
(KafkaCacheDataStreamer.java:140)</div><div class=3D"gmail_extra">=C2=A0 =
=C2=A0 =C2=A0 =C2=A0 at com.test.cs.cache.KafkaCacheDataStreamer$1.run(Kafk=
aCacheDataStreamer.java:197)</div><div class=3D"gmail_extra">=C2=A0 =C2=A0 =
=C2=A0 =C2=A0 at java.util.concurrent.Executors$RunnableAdapter.call(Execut=
ors.java:511)</div><div class=3D"gmail_extra">=C2=A0 =C2=A0 =C2=A0 =C2=A0 a=
t java.util.concurrent.FutureTask.run(FutureTask.java:266)</div><div class=
=3D"gmail_extra">=C2=A0 =C2=A0 =C2=A0 =C2=A0 at java.util.concurrent.Thread=
PoolExecutor.runWorker(ThreadPoolExecutor.java:1142)</div><div class=3D"gma=
il_extra">=C2=A0 =C2=A0 =C2=A0 =C2=A0 at java.util.concurrent.ThreadPoolExe=
cutor$Worker.run(ThreadPoolExecutor.java:617)</div><div class=3D"gmail_extr=
a">=C2=A0 =C2=A0 =C2=A0 =C2=A0 at java.lang.Thread.run(Thread.java:745)</di=
v><div class=3D"gmail_extra">2016-11-09 05:55:55 ERROR pool-6-thread-1 Kafk=
aCacheDataStreamer:200 - Message is ignored due to an error [msg=3DMessageA=
ndMetadata(TestTopic,1,Message(magic =3D 0, attributes =3D 0, crc =3D 21117=
90081, key =3D null, payload =3D java.nio.HeapByteBuffer[pos=3D0 lim=3D1155=
 cap=3D1155]),2034,kafka.serializer.StringDecoder@3f77f0b,kafka.serializer.=
StringDecoder@67fd2da0)]</div><div class=3D"gmail_extra">java.lang.IllegalS=
tateException: Cache has been closed or destroyed: PERSON_CACHE</div><div c=
lass=3D"gmail_extra">=C2=A0 =C2=A0 =C2=A0 =C2=A0 at org.apache.ignite.inter=
nal.processors.cache.GridCacheGateway.enter(GridCacheGateway.java:160)</div=
><div class=3D"gmail_extra">=C2=A0 =C2=A0 =C2=A0 =C2=A0 at org.apache.ignit=
e.internal.processors.cache.IgniteCacheProxy.onEnter(IgniteCacheProxy.java:=
2103)</div><div class=3D"gmail_extra">=C2=A0 =C2=A0 =C2=A0 =C2=A0 at org.ap=
ache.ignite.internal.processors.cache.IgniteCacheProxy.size(IgniteCacheProx=
y.java:826)</div><div class=3D"gmail_extra">=C2=A0 =C2=A0 =C2=A0 =C2=A0 at =
com.test.cs.cache.KafkaCacheDataStreamer.addMessage(KafkaCacheDataStreamer.=
java:149)</div><div class=3D"gmail_extra">=C2=A0 =C2=A0 =C2=A0 =C2=A0 at co=
m.test.cs.cache.KafkaCacheDataStreamer$1.run(KafkaCacheDataStreamer.java:19=
7)</div><div class=3D"gmail_extra">=C2=A0 =C2=A0 =C2=A0 =C2=A0 at java.util=
.concurrent.Executors$RunnableAdapter.call(Executors.java:511)</div><div cl=
ass=3D"gmail_extra">=C2=A0 =C2=A0 =C2=A0 =C2=A0 at java.util.concurrent.Fut=
ureTask.run(FutureTask.java:266)</div><div class=3D"gmail_extra">=C2=A0 =C2=
=A0 =C2=A0 =C2=A0 at java.util.concurrent.ThreadPoolExecutor.runWorker(Thre=
adPoolExecutor.java:1142)</div><div class=3D"gmail_extra">=C2=A0 =C2=A0 =C2=
=A0 =C2=A0 at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPool=
Executor.java:617)</div><div class=3D"gmail_extra">=C2=A0 =C2=A0 =C2=A0 =C2=
=A0 at java.lang.Thread.run(Thread.java:745)</div><div><br></div><div>I hav=
e attached the KafkaCacheDataStreamer class and let me know if you need any=
 additional details. thanks.</div></div><div class=3D"gmail_extra"><br></di=
v></div>

--001a114fcaa855fe930540df0e90--

--001a114fcaa855fe9a0540df0e92
Content-Type: application/octet-stream; name="KafkaCacheDataStreamer.java"
Content-Disposition: attachment; filename="KafkaCacheDataStreamer.java"
Content-Transfer-Encoding: base64
X-Attachment-Id: f_ivb0n6ba0

cGFja2FnZSBuZXQuanVuaXBlci5jcy5jYWNoZTsNCg0KaW1wb3J0IGphdmEudXRpbC5IYXNoTWFw
Ow0KaW1wb3J0IGphdmEudXRpbC5MaXN0Ow0KaW1wb3J0IGphdmEudXRpbC5NYXA7DQppbXBvcnQg
amF2YS51dGlsLk9iamVjdHM7DQppbXBvcnQgamF2YS51dGlsLmNvbmN1cnJlbnQuRXhlY3V0b3JT
ZXJ2aWNlOw0KaW1wb3J0IGphdmEudXRpbC5jb25jdXJyZW50LkV4ZWN1dG9yczsNCmltcG9ydCBq
YXZhLnV0aWwuY29uY3VycmVudC5UaW1lVW5pdDsNCg0KaW1wb3J0IG9yZy5hcGFjaGUuaWduaXRl
Lklnbml0ZUNhY2hlOw0KaW1wb3J0IG9yZy5hcGFjaGUuaWduaXRlLklnbml0ZUV4Y2VwdGlvbjsN
CmltcG9ydCBvcmcuYXBhY2hlLmlnbml0ZS5sYW5nLklnbml0ZUZ1dHVyZTsNCmltcG9ydCBvcmcu
YXBhY2hlLmlnbml0ZS5zdHJlYW0uU3RyZWFtQWRhcHRlcjsNCmltcG9ydCBvcmcuc2xmNGouTG9n
Z2VyOw0KaW1wb3J0IG9yZy5zbGY0ai5Mb2dnZXJGYWN0b3J5Ow0KDQppbXBvcnQga2Fma2EuY29u
c3VtZXIuQ29uc3VtZXJDb25maWc7DQppbXBvcnQga2Fma2EuY29uc3VtZXIuQ29uc3VtZXJJdGVy
YXRvcjsNCmltcG9ydCBrYWZrYS5jb25zdW1lci5LYWZrYVN0cmVhbTsNCmltcG9ydCBrYWZrYS5q
YXZhYXBpLmNvbnN1bWVyLkNvbnN1bWVyQ29ubmVjdG9yOw0KaW1wb3J0IGthZmthLm1lc3NhZ2Uu
TWVzc2FnZUFuZE1ldGFkYXRhOw0KaW1wb3J0IGthZmthLnNlcmlhbGl6ZXIuRGVjb2RlcjsNCmlt
cG9ydCBjb20udGVzdC5jcy5lbnRpdHkuUGVyc29uOw0KDQpwdWJsaWMgY2xhc3MgS2Fma2FDYWNo
ZURhdGFTdHJlYW1lcjxULCBLLCBWPiBleHRlbmRzIFN0cmVhbUFkYXB0ZXI8VCwgSywgVj4gew0K
ICAgIA0KCXByaXZhdGUgc3RhdGljIExvZ2dlciBsb2cgPSBMb2dnZXJGYWN0b3J5LmdldExvZ2dl
cihLYWZrYUNhY2hlRGF0YVN0cmVhbWVyLmNsYXNzKTsNCgkNCgkvKiogUmV0cnkgdGltZW91dC4g
Ki8NCiAgICBwcml2YXRlIHN0YXRpYyBmaW5hbCBsb25nIERGTFRfUkVUUllfVElNRU9VVCA9IDEw
MDAwOw0KDQogICAgLyoqIEV4ZWN1dG9yIHVzZWQgdG8gc3VibWl0IGthZmthIHN0cmVhbXMuICov
DQogICAgcHJpdmF0ZSBFeGVjdXRvclNlcnZpY2UgZXhlY3V0b3I7DQoNCiAgICAvKiogVG9waWMu
ICovDQogICAgcHJpdmF0ZSBTdHJpbmcgdG9waWM7DQoNCiAgICAvKiogTnVtYmVyIG9mIHRocmVh
ZHMgdG8gcHJvY2VzcyBrYWZrYSBzdHJlYW1zLiAqLw0KICAgIHByaXZhdGUgaW50IHRocmVhZHM7
DQoNCiAgICAvKiogS2Fma2EgY29uc3VtZXIgY29uZmlnLiAqLw0KICAgIHByaXZhdGUgQ29uc3Vt
ZXJDb25maWcgY29uc3VtZXJDZmc7DQoNCiAgICAvKiogS2V5IGRlY29kZXIuICovDQogICAgcHJp
dmF0ZSBEZWNvZGVyPFQ+IGtleURlY29kZXI7DQoNCiAgICAvKiogVmFsdWUgZGVjb2Rlci4gKi8N
CiAgICBwcml2YXRlIERlY29kZXI8VD4gdmFsRGVjb2RlcjsNCg0KICAgIC8qKiBLYWZrYSBjb25z
dW1lciBjb25uZWN0b3IuICovDQogICAgcHJpdmF0ZSBDb25zdW1lckNvbm5lY3RvciBjb25zdW1l
cjsNCg0KICAgIC8qKiBSZXRyeSB0aW1lb3V0LiAqLw0KICAgIHByaXZhdGUgbG9uZyByZXRyeVRp
bWVvdXQgPSBERkxUX1JFVFJZX1RJTUVPVVQ7DQoNCiAgICAvKiogU3RvcHBlZC4gKi8NCiAgICBw
cml2YXRlIHZvbGF0aWxlIGJvb2xlYW4gc3RvcHBlZDsNCg0KICAgIHByaXZhdGUgSWduaXRlQ2Fj
aGU8U3RyaW5nLCBQZXJzb24+IGNhY2hlID0gQ2FjaGVNYW5hZ2VyLmdldFBlcnNvbkNhY2hlKCk7
DQogICAgDQogICAgLyoqDQogICAgICogU2V0cyB0aGUgdG9waWMgbmFtZS4NCiAgICAgKg0KICAg
ICAqIEBwYXJhbSB0b3BpYyBUb3BpYyBuYW1lLg0KICAgICAqLw0KICAgIHB1YmxpYyB2b2lkIHNl
dFRvcGljKFN0cmluZyB0b3BpYykgew0KICAgICAgICB0aGlzLnRvcGljID0gdG9waWM7DQogICAg
fQ0KDQogICAgLyoqDQogICAgICogU2V0cyB0aGUgdGhyZWFkcy4NCiAgICAgKg0KICAgICAqIEBw
YXJhbSB0aHJlYWRzIE51bWJlciBvZiB0aHJlYWRzLg0KICAgICAqLw0KICAgIHB1YmxpYyB2b2lk
IHNldFRocmVhZHMoaW50IHRocmVhZHMpIHsNCiAgICAgICAgdGhpcy50aHJlYWRzID0gdGhyZWFk
czsNCiAgICB9DQoNCiAgICAvKioNCiAgICAgKiBTZXRzIHRoZSBjb25zdW1lciBjb25maWcuDQog
ICAgICoNCiAgICAgKiBAcGFyYW0gY29uc3VtZXJDZmcgQ29uc3VtZXIgY29uZmlndXJhdGlvbi4N
CiAgICAgKi8NCiAgICBwdWJsaWMgdm9pZCBzZXRDb25zdW1lckNvbmZpZyhDb25zdW1lckNvbmZp
ZyBjb25zdW1lckNmZykgew0KICAgICAgICB0aGlzLmNvbnN1bWVyQ2ZnID0gY29uc3VtZXJDZmc7
DQogICAgfQ0KDQogICAgLyoqDQogICAgICogU2V0cyB0aGUga2V5IGRlY29kZXIuDQogICAgICoN
CiAgICAgKiBAcGFyYW0ga2V5RGVjb2RlciBLZXkgZGVjb2Rlci4NCiAgICAgKi8NCiAgICBwdWJs
aWMgdm9pZCBzZXRLZXlEZWNvZGVyKERlY29kZXI8VD4ga2V5RGVjb2Rlcikgew0KICAgICAgICB0
aGlzLmtleURlY29kZXIgPSBrZXlEZWNvZGVyOw0KICAgIH0NCg0KICAgIC8qKg0KICAgICAqIFNl
dHMgdGhlIHZhbHVlIGRlY29kZXIuDQogICAgICoNCiAgICAgKiBAcGFyYW0gdmFsRGVjb2RlciBW
YWx1ZSBkZWNvZGVyLg0KICAgICAqLw0KICAgIHB1YmxpYyB2b2lkIHNldFZhbHVlRGVjb2RlcihE
ZWNvZGVyPFQ+IHZhbERlY29kZXIpIHsNCiAgICAgICAgdGhpcy52YWxEZWNvZGVyID0gdmFsRGVj
b2RlcjsNCiAgICB9DQoNCiAgICAvKioNCiAgICAgKiBTZXRzIHRoZSByZXRyeSB0aW1lb3V0Lg0K
ICAgICAqDQogICAgICogQHBhcmFtIHJldHJ5VGltZW91dCBSZXRyeSB0aW1lb3V0Lg0KICAgICAq
Lw0KICAgIHB1YmxpYyB2b2lkIHNldFJldHJ5VGltZW91dChsb25nIHJldHJ5VGltZW91dCkgew0K
ICAgIAlpZiAocmV0cnlUaW1lb3V0IDw9IDApew0KICAgIAkJdGhyb3cgbmV3IElsbGVnYWxBcmd1
bWVudEV4Y2VwdGlvbigicmV0cnlUaW1lb3V0IG1pc3QgYmUgZ3JlYXRlciB0aGFuIDAiKTsNCiAg
ICAJCQ0KICAgIAl9DQogICAgICAgIHRoaXMucmV0cnlUaW1lb3V0ID0gcmV0cnlUaW1lb3V0Ow0K
ICAgIH0NCg0KICAgIA0KICAgIA0KICAgIEBPdmVycmlkZQ0KICAgIHByb3RlY3RlZCB2b2lkIGFk
ZE1lc3NhZ2UoVCBtc2cpIHsNCiAgICAJdHJ5IHsNCiAgICAJCWlmIChnZXRNdWx0aXBsZVR1cGxl
RXh0cmFjdG9yKCkgPT0gbnVsbCl7DQogICAgICAgICAgICAgICAgTWFwLkVudHJ5PEssIFY+IGUg
PSBnZXRTaW5nbGVUdXBsZUV4dHJhY3RvcigpLmV4dHJhY3QobXNnKTsNCg0KICAgICAgICAgICAg
ICAgIGlmIChlICE9IG51bGwpDQogICAgICAgICAgICAgICAgICAgIGdldFN0cmVhbWVyKCkuYWRk
RGF0YShlKTsNCg0KICAgICAgICAgICAgfSBlbHNlIHsNCiAgICAgICAgICAgICAgICBNYXA8Sywg
Vj4gbSA9IGdldE11bHRpcGxlVHVwbGVFeHRyYWN0b3IoKS5leHRyYWN0KG1zZyk7DQogICAgICAg
ICAgICAgICAgaWYgKG0gIT0gbnVsbCAmJiAhbS5pc0VtcHR5KCkpew0KICAgICAgICAgICAgICAg
IAkvKmZvciAoTWFwLkVudHJ5PEssIFY+IGVudHJ5IDogbS5lbnRyeVNldCgpKXsNCiAgICAgICAg
ICAgICAgICAJCWdldFN0cmVhbWVyKCkuYWRkRGF0YShlbnRyeS5nZXRLZXkoKSwgZW50cnkuZ2V0
VmFsdWUoKSk7DQovLyAgICAgICAgICAgICAgICAJCWNhY2hlLnB1dCgoU3RyaW5nKWVudHJ5Lmdl
dEtleSgpLCAoUGVyc29uKSBlbnRyeS5nZXRWYWx1ZSgpKTsNCiAgICAgICAgICAgICAgICAJfSov
DQogICAgICAgICAgICAgICAgCQ0KICAgICAgICAgICAgICAgIAlnZXRTdHJlYW1lcigpLmFkZERh
dGEobSk7DQoNCiAgICAgICAgICAgICAgICB9DQogICAgICAgICAgICB9DQoJDQogICAgCX1jYXRj
aChFeGNlcHRpb24gZXgpew0KICAgIAkJbG9nLmVycm9yKCJFeGNlcHRpb24gd2hpbGUgYWRkaW5n
IHRvIHN0cmVhbWVyICIsIGV4KTsNCiAgICAJfQ0KICAgIH0NCiAgICAvKioNCiAgICAgKiBTdGFy
dHMgc3RyZWFtZXIuDQogICAgICoNCiAgICAgKiBAdGhyb3dzIElnbml0ZUV4Y2VwdGlvbiBJZiBm
YWlsZWQuDQogICAgICovDQogICAgcHVibGljIHZvaWQgc3RhcnQoKSB7DQogICAgICAgIE9iamVj
dHMucmVxdWlyZU5vbk51bGwoZ2V0U3RyZWFtZXIoKSwgInN0cmVhbWVyIik7DQogICAgICAgIE9i
amVjdHMucmVxdWlyZU5vbk51bGwoZ2V0SWduaXRlKCksICJpZ25pdGUiKTsNCiAgICAgICAgT2Jq
ZWN0cy5yZXF1aXJlTm9uTnVsbCh0b3BpYywgInRvcGljIik7DQogICAgICAgIE9iamVjdHMucmVx
dWlyZU5vbk51bGwoa2V5RGVjb2RlciwgImtleSBkZWNvZGVyIik7DQogICAgICAgIE9iamVjdHMu
cmVxdWlyZU5vbk51bGwodmFsRGVjb2RlciwgInZhbHVlIGRlY29kZXIiKTsNCiAgICAgICAgDQog
ICAgICAgIE9iamVjdHMucmVxdWlyZU5vbk51bGwoY29uc3VtZXJDZmcsICJrYWZrYSBjb25zdW1l
ciBjb25maWciKTsNCiAgICAgICAgaWYodGhyZWFkcyA8PSAwKXsNCiAgICAgICAgCXRocm93IG5l
dyBJbGxlZ2FsQXJndW1lbnRFeGNlcHRpb24oIlRocmVhZHMgY2Fubm90IGJlIHplcm8iKTsNCiAg
ICAgICAgfQ0KDQogICAgICAgIA0KICAgICAgICANCiAgICAgICAgY29uc3VtZXIgPSBrYWZrYS5j
b25zdW1lci5Db25zdW1lci5jcmVhdGVKYXZhQ29uc3VtZXJDb25uZWN0b3IoY29uc3VtZXJDZmcp
Ow0KDQogICAgICAgIE1hcDxTdHJpbmcsIEludGVnZXI+IHRvcGljQ250TWFwID0gbmV3IEhhc2hN
YXA8PigpOw0KDQogICAgICAgIHRvcGljQ250TWFwLnB1dCh0b3BpYywgdGhyZWFkcyk7DQoNCiAg
ICAgICAgTWFwPFN0cmluZywgTGlzdDxLYWZrYVN0cmVhbTxULCBUPj4+IGNvbnN1bWVyTWFwID0N
CiAgICAgICAgICAgIGNvbnN1bWVyLmNyZWF0ZU1lc3NhZ2VTdHJlYW1zKHRvcGljQ250TWFwLCBr
ZXlEZWNvZGVyLCB2YWxEZWNvZGVyKTsNCg0KICAgICAgICBMaXN0PEthZmthU3RyZWFtPFQsIFQ+
PiBzdHJlYW1zID0gY29uc3VtZXJNYXAuZ2V0KHRvcGljKTsNCiAgICAgICAgDQogICAgICAgIGxv
Zy5pbmZvKCJLYWZrYSBpcyBjb25uZWN0ZWQgc3VjY2Vzc2Z1bGx5Iik7ICAgICAgICANCiAgICAg
ICAgLy8gTm93IGxhdW5jaCBhbGwgdGhlIGNvbnN1bWVyIHRocmVhZHMuDQogICAgICAgIGV4ZWN1
dG9yID0gRXhlY3V0b3JzLm5ld0ZpeGVkVGhyZWFkUG9vbCh0aHJlYWRzKTsNCg0KICAgICAgICBz
dG9wcGVkID0gZmFsc2U7DQoNCiAgICAgICAgLy8gTm93IGNyZWF0ZSBhbiBvYmplY3QgdG8gY29u
c3VtZSB0aGUgbWVzc2FnZXMuDQogICAgICAgIGZvciAoZmluYWwgS2Fma2FTdHJlYW08VCwgVD4g
c3RyZWFtIDogc3RyZWFtcykgew0KICAgICAgICAgICAgZXhlY3V0b3Iuc3VibWl0KG5ldyBSdW5u
YWJsZSgpIHsNCiAgICAgICAgICAgICAgICBAT3ZlcnJpZGUgcHVibGljIHZvaWQgcnVuKCkgew0K
ICAgICAgICAgICAgICAgICAgICB3aGlsZSAoIXN0b3BwZWQpIHsNCiAgICAgICAgICAgICAgICAg
ICAgICAgIHRyeSB7DQogICAgICAgICAgICAgICAgICAgICAgICAgICAgZm9yIChDb25zdW1lckl0
ZXJhdG9yPFQsIFQ+IGl0ID0gc3RyZWFtLml0ZXJhdG9yKCk7IGl0Lmhhc05leHQoKSAmJiAhc3Rv
cHBlZDsgKSB7DQogICAgICAgICAgICAgICAgICAgICAgICAgICAgICAgIE1lc3NhZ2VBbmRNZXRh
ZGF0YTxULCBUPiBtc2cgPSBpdC5uZXh0KCk7DQogICAgICAgICAgICAgICAgICAgICAgICAgICAg
ICAgIGxvZy5pbmZvKCJNZXNzYWdlIHJlY2lldmVkIHt9ICIsIG1zZy5tZXNzYWdlKCkpOyANCiAg
ICAgICAgICAgICAgICAgICAgICAgICAgICAgICAgdHJ5IHsNCiAgICAgICAgICAgICAgICAgICAg
ICAgICAgICAgICAgCWFkZE1lc3NhZ2UobXNnLm1lc3NhZ2UoKSk7DQogICAgICAgICAgICAgICAg
ICAgICAgICAgICAgICAgIH0NCiAgICAgICAgICAgICAgICAgICAgICAgICAgICAgICAgY2F0Y2gg
KEV4Y2VwdGlvbiBlKSB7DQogICAgICAgICAgICAgICAgICAgICAgICAgICAgICAgICAgICBsb2cu
ZXJyb3IoIk1lc3NhZ2UgaXMgaWdub3JlZCBkdWUgdG8gYW4gZXJyb3IgW21zZz0iICsgbXNnICsg
J10nLCBlKTsNCiAgICAgICAgICAgICAgICAgICAgICAgICAgICAgICAgfQ0KICAgICAgICAgICAg
ICAgICAgICAgICAgICAgIH0NCiAgICAgICAgICAgICAgICAgICAgICAgIH0NCiAgICAgICAgICAg
ICAgICAgICAgICAgIGNhdGNoIChFeGNlcHRpb24gZSkgew0KICAgICAgICAgICAgICAgICAgICAg
ICAgICAgIGxvZy5lcnJvcigiTWVzc2FnZSBjYW4ndCBiZSBjb25zdW1lZCBmcm9tIHN0cmVhbS4g
UmV0cnkgYWZ0ZXIgIiArIHJldHJ5VGltZW91dCArICIgbXMuIiwgZSk7DQoNCiAgICAgICAgICAg
ICAgICAgICAgICAgICAgICB0cnkgew0KICAgICAgICAgICAgICAgICAgICAgICAgICAgICAgICBU
aHJlYWQuc2xlZXAocmV0cnlUaW1lb3V0KTsNCiAgICAgICAgICAgICAgICAgICAgICAgICAgICB9
DQogICAgICAgICAgICAgICAgICAgICAgICAgICAgY2F0Y2ggKEludGVycnVwdGVkRXhjZXB0aW9u
IGllKSB7DQogICAgICAgICAgICAgICAgICAgICAgICAgICAgICAgIC8vIE5vLW9wLg0KICAgICAg
ICAgICAgICAgICAgICAgICAgICAgIH0NCiAgICAgICAgICAgICAgICAgICAgICAgIH0NCiAgICAg
ICAgICAgICAgICAgICAgfQ0KICAgICAgICAgICAgICAgIH0NCiAgICAgICAgICAgIH0pOw0KICAg
ICAgICB9DQogICAgfQ0KDQogICAgLyoqDQogICAgICogU3RvcHMgc3RyZWFtZXIuDQogICAgICov
DQogICAgcHVibGljIHZvaWQgc3RvcCgpIHsNCiAgICAgICAgc3RvcHBlZCA9IHRydWU7DQoNCiAg
ICAgICAgaWYgKGNvbnN1bWVyICE9IG51bGwpDQogICAgICAgICAgICBjb25zdW1lci5zaHV0ZG93
bigpOw0KDQogICAgICAgIGlmIChleGVjdXRvciAhPSBudWxsKSB7DQogICAgICAgICAgICBleGVj
dXRvci5zaHV0ZG93bigpOw0KDQogICAgICAgICAgICB0cnkgew0KICAgICAgICAgICAgICAgIGlm
ICghZXhlY3V0b3IuYXdhaXRUZXJtaW5hdGlvbig1MDAwLCBUaW1lVW5pdC5NSUxMSVNFQ09ORFMp
KQ0KICAgICAgICAgICAgICAgICAgICBpZiAobG9nLmlzRGVidWdFbmFibGVkKCkpDQogICAgICAg
ICAgICAgICAgICAgICAgICBsb2cuZGVidWcoIlRpbWVkIG91dCB3YWl0aW5nIGZvciBjb25zdW1l
ciB0aHJlYWRzIHRvIHNodXQgZG93biwgZXhpdGluZyB1bmNsZWFubHkuIik7DQogICAgICAgICAg
ICB9DQogICAgICAgICAgICBjYXRjaCAoSW50ZXJydXB0ZWRFeGNlcHRpb24gZSkgew0KICAgICAg
ICAgICAgICAgIGlmIChsb2cuaXNEZWJ1Z0VuYWJsZWQoKSkNCiAgICAgICAgICAgICAgICAgICAg
bG9nLmRlYnVnKCJJbnRlcnJ1cHRlZCBkdXJpbmcgc2h1dGRvd24sIGV4aXRpbmcgdW5jbGVhbmx5
LiIpOw0KICAgICAgICAgICAgfQ0KICAgICAgICB9DQogICAgfQ0KDQp9DQo=
--001a114fcaa855fe9a0540df0e92--