[
https://issues.apache.org/jira/browse/GEODE-3742?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16192189#comment-16192189
]
Barry Oglesby commented on GEODE-3742:
--------------------------------------
This test passes regularly for me, but the difference in messages logged
between a successful test and an unsuccessful test is interesting. The failed
test logs messages that it shouldn't and doesn't log other messages that it
should.
I'm not sure this is just a timing issue even though the test currently does:
{noformat}
// Step 5
// verifyDurableClientDisconnected();
Thread.sleep(5000);
{noformat}
Here are relevant log messages in the failed test:
The client Cache Client Updater thread disconnects:
{noformat}
[info 2017/10/02 23:54:49.072 UTC <Cache Client Updater Thread on
120006d0596c(172)<v496>:32770 port 22032> tid=0x4d3] GemFireCache[id =
1517909714; isClosing = true; isShutDownAll = false; created = Mon Oct 02
23:54:48 UTC 2017; server = false; copyOnRead = false; lockLease = 120;
lockTimeout = 60]: Now closing.
{noformat}
The server Message Dispatcher thread catches and logs an IOException:
{noformat}
[vm0] [warn 2017/10/02 23:54:49.078 UTC <Client Message Dispatcher for
172.17.0.2(1:loner):55502:bd7683df (testBug40165ClientReconnects_client)>
tid=0x2d3d]
CacheClientProxy[identity(172.17.0.2(1:loner):55502:bd7683df,connection=1,durableAttributes=DurableClientAttributes[id=testBug40165ClientReconnects_client;
timeout=60]); port=55506; primary=true; version=GEODE 1.3.0]: Proxy closing
due to unexpected reset on socket connection.
{noformat}
The server Message Dispatcher thread attempts to pause twice (the second set of
messages shouldn't happen):
{noformat}
[vm0] [info 2017/10/02 23:54:49.078 UTC <Client Message Dispatcher for
172.17.0.2(1:loner):55502:bd7683df (testBug40165ClientReconnects_client)>
tid=0x2d3d] available ids = 102 , isEmptyAckList =true, peekInitialized = true
[vm0] [info 2017/10/02 23:54:49.079 UTC <Client Message Dispatcher for
172.17.0.2(1:loner):55502:bd7683df (testBug40165ClientReconnects_client)>
tid=0x2d3d]
CacheClientProxy[identity(172.17.0.2(1:loner):55502:bd7683df,connection=1,durableAttributes=DurableClientAttributes[id=testBug40165ClientReconnects_client;
timeout=60]); port=55506; primary=true; version=GEODE 1.3.0] : Pausing
processing
[vm0] [info 2017/10/02 23:54:49.079 UTC <Client Message Dispatcher for
172.17.0.2(1:loner):55502:bd7683df (testBug40165ClientReconnects_client)>
tid=0x2d3d] available ids = 102 , isEmptyAckList =true, peekInitialized = true
[vm0] [info 2017/10/02 23:54:49.079 UTC <Client Message Dispatcher for
172.17.0.2(1:loner):55502:bd7683df (testBug40165ClientReconnects_client)>
tid=0x2d3d]
CacheClientProxy[identity(172.17.0.2(1:loner):55502:bd7683df,connection=1,durableAttributes=DurableClientAttributes[id=testBug40165ClientReconnects_client;
timeout=60]); port=55506; primary=true; version=GEODE 1.3.0] : Pausing
processing
{noformat}
The server logs an 'Unsuccessfully registered' message when the client attempts
to re-connect:
{noformat}
[vm0] [warn 2017/10/02 23:54:53.794 UTC <Handshaker 0.0.0.0/0.0.0.0:22032
Thread 0> tid=0x2d39] CacheClientNotifier: Unsuccessfully registered client
with identifier
identity(172.17.0.2(1:loner):55872:2b8b83df,connection=1,durableAttributes=DurableClientAttributes[id=testBug40165ClientReconnects_client;
timeout=60])
{noformat}
The client logs error messages when it can't reconnect:
{noformat}
[error 2017/10/02 23:54:53.794 UTC <Test worker> tid=0x16] Could not find any
server to create primary client queue on. Number of excluded servers is 1 and
exception is no exception.
[error 2017/10/02 23:54:53.795 UTC <Test worker> tid=0x16] Could not initialize
a primary queue on startup. No queue servers available.
{noformat}
> CI failure: DeltaPropagationDUnitTest.testBug40165ClientReconnects FAILED
> with no queus server is available
> -----------------------------------------------------------------------------------------------------------
>
> Key: GEODE-3742
> URL: https://issues.apache.org/jira/browse/GEODE-3742
> Project: Geode
> Issue Type: Bug
> Components: client queues
> Reporter: Hitesh Khamesra
>
> org.apache.geode.internal.cache.DeltaPropagationDUnitTest >
> testBug40165ClientReconnects FAILED
> org.apache.geode.cache.NoSubscriptionServersAvailableException:
> org.apache.geode.cache.NoSubscriptionServersAvailableException: Could not
> initialize a primary queue on startup. No queue servers available.
> at
> org.apache.geode.cache.client.internal.QueueManagerImpl.getAllConnections(QueueManagerImpl.java:190)
> at
> org.apache.geode.cache.client.internal.OpExecutorImpl.executeOnQueuesAndReturnPrimaryResult(OpExecutorImpl.java:540)
> at
> org.apache.geode.cache.client.internal.PoolImpl.executeOnQueuesAndReturnPrimaryResult(PoolImpl.java:842)
> at
> org.apache.geode.cache.client.internal.RegisterInterestOp.execute(RegisterInterestOp.java:58)
> at
> org.apache.geode.cache.client.internal.ServerRegionProxy.registerInterest(ServerRegionProxy.java:359)
> at
> org.apache.geode.internal.cache.LocalRegion.processSingleInterest(LocalRegion.java:3734)
> at
> org.apache.geode.internal.cache.LocalRegion.registerInterest(LocalRegion.java:3823)
> at
> org.apache.geode.internal.cache.LocalRegion.registerInterest(LocalRegion.java:3625)
> at
> org.apache.geode.internal.cache.LocalRegion.registerInterest(LocalRegion.java:3620)
> at
> org.apache.geode.internal.cache.LocalRegion.registerInterest(LocalRegion.java:3615)
> at
> org.apache.geode.internal.cache.DeltaPropagationDUnitTest.createDurableCacheClient(DeltaPropagationDUnitTest.java:1372)
> at
> org.apache.geode.internal.cache.DeltaPropagationDUnitTest.testBug40165ClientReconnects(DeltaPropagationDUnitTest.java:698)
> Caused by:
> org.apache.geode.cache.NoSubscriptionServersAvailableException: Could
> not initialize a primary queue on startup. No queue servers available.
> at
> org.apache.geode.cache.client.internal.QueueManagerImpl.initializeConnections(QueueManagerImpl.java:592)
> at
> org.apache.geode.cache.client.internal.QueueManagerImpl.start(QueueManagerImpl.java:303)
> at
> org.apache.geode.cache.client.internal.PoolImpl.start(PoolImpl.java:346)
> at
> org.apache.geode.cache.client.internal.PoolImpl.finishCreate(PoolImpl.java:172)
> at
> org.apache.geode.cache.client.internal.PoolImpl.create(PoolImpl.java:158)
> at
> org.apache.geode.internal.cache.PoolFactoryImpl.create(PoolFactoryImpl.java:338)
> at
> org.apache.geode.internal.cache.DeltaPropagationDUnitTest.createDurableCacheClient(DeltaPropagationDUnitTest.java:1362)
> ... 1 more
--
This message was sent by Atlassian JIRA
(v6.4.14#64029)
