You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@geode.apache.org by "ASF subversion and git services (JIRA)" <ji...@apache.org> on 2016/12/15 18:35:58 UTC
[jira] [Commented] (GEODE-2209) Only 16 GatewaySenders are
supported
[ https://issues.apache.org/jira/browse/GEODE-2209?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15752124#comment-15752124 ]
ASF subversion and git services commented on GEODE-2209:
--------------------------------------------------------
Commit b0fbf72f043bd73a94a6d4df36a44bfef91efce8 in geode's branch refs/heads/develop from [~barry.oglesby]
[ https://git-wip-us.apache.org/repos/asf?p=geode.git;h=b0fbf72 ]
GEODE-2209: Added support for up to 128 GatewaySenders
> Only 16 GatewaySenders are supported
> ------------------------------------
>
> Key: GEODE-2209
> URL: https://issues.apache.org/jira/browse/GEODE-2209
> Project: Geode
> Issue Type: Improvement
> Components: wan
> Reporter: Barry Oglesby
> Assignee: Barry Oglesby
>
> If java assertions are enabled, attempting to use a 17th {{GatewaySender}}, throws this {{AssertionError}}:
> {noformat}
> [severe 2016/12/13 15:58:08.456 PST gateway-ln-1 <ServerConnection on port 60712 Thread 0> tid=0x440] Server connection from [identity(192.168.2.10(client:39966:loner):61377:e4369ffa:client,connection=2; port=61377] : Unexpected Error on server
> java.lang.AssertionError
> at org.apache.geode.internal.cache.ha.ThreadIdentifier$Bits.shift(ThreadIdentifier.java:126)
> at org.apache.geode.internal.cache.ha.ThreadIdentifier$WanType.generateWanId(ThreadIdentifier.java:74)
> at org.apache.geode.internal.cache.ha.ThreadIdentifier.createFakeThreadIDForParallelGSPrimaryBucket(ThreadIdentifier.java:284)
> at org.apache.geode.internal.cache.wan.serial.SerialGatewaySenderImpl.setModifiedEventId(SerialGatewaySenderImpl.java:248)
> at org.apache.geode.internal.cache.wan.AbstractGatewaySender.distribute(AbstractGatewaySender.java:849)
> at org.apache.geode.internal.cache.LocalRegion.notifyGatewaySender(LocalRegion.java:6367)
> at org.apache.geode.internal.cache.LocalRegion.basicPutPart2(LocalRegion.java:5909)
> at org.apache.geode.internal.cache.AbstractRegionMap.basicPut(AbstractRegionMap.java:2800)
> at org.apache.geode.internal.cache.LocalRegion.virtualPut(LocalRegion.java:5750)
> at org.apache.geode.internal.cache.DistributedRegion.virtualPut(DistributedRegion.java:337)
> at org.apache.geode.internal.cache.LocalRegionDataView.putEntry(LocalRegionDataView.java:151)
> at org.apache.geode.internal.cache.LocalRegion.basicUpdate(LocalRegion.java:5730)
> at org.apache.geode.internal.cache.LocalRegion.basicBridgePut(LocalRegion.java:5374)
> at org.apache.geode.internal.cache.tier.sockets.command.Put65.cmdExecute(Put65.java:381)
> at org.apache.geode.internal.cache.tier.sockets.BaseCommand.execute(BaseCommand.java:141)
> at org.apache.geode.internal.cache.tier.sockets.ServerConnection.doNormalMsg(ServerConnection.java:777)
> at org.apache.geode.internal.cache.tier.sockets.ServerConnection.doOneMessage(ServerConnection.java:908)
> at org.apache.geode.internal.cache.tier.sockets.ServerConnection.run(ServerConnection.java:1165)
> at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142)
> at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617)
> at org.apache.geode.internal.cache.tier.sockets.AcceptorImpl$1$1.run(AcceptorImpl.java:519)
> at java.lang.Thread.run(Thread.java:745)
> {noformat}
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)