responseMap = rpcManager.invokeRemotely(Collections.singleton(groupManager.getPrimaryOwner(groupName)),command,rpcManager.getDefaultRpcOptions(true)) | future = rpcManager.invokeRemotelyAsync(Collections.singleton(groupManager.getPrimaryOwner(groupName)),command,rpcManager.getDefaultRpcOptions(true)) | rpcManager.invokeRemotely(Collections.singleton(groupManager.getPrimaryOwner(groupName)),command,rpcManager.getDefaultRpcOptions(true)) | rpcManager.invokeRemotelyAsync(Collections.singleton(groupManager.getPrimaryOwner(groupName)),command,rpcManager.getDefaultRpcOptions(true)) | infinispan | 5d3d55e238dfae5af6fdcee68029aea7ce771273 | org.infinispan.interceptors.distribution.BaseDistributionInterceptor | | | v0 | rpcManager |
---|
v1 | rpcManager.getDefaultRpcOptions(true) |
---|
v2 | Collections.singleton(groupManager.getPrimaryOwner(groupName)) |
---|
v3 | command |
---|
| | v0 | rpcManager |
---|
v1 | rpcManager.getDefaultRpcOptions(true) |
---|
v2 | Collections.singleton(groupManager.getPrimaryOwner(groupName)) |
---|
v3 | command |
---|
| AssignedTo | True |
Map<Address,Response> responseMap=rpcManager.invokeRemotely(Collections.singleton(groupManager.getPrimaryOwner(groupName)),command,rpcManager.getDefaultRpcOptions(true)); | CompletableFuture<Map<Address,Response>> future=rpcManager.invokeRemotelyAsync(Collections.singleton(groupManager.getPrimaryOwner(groupName)),command,rpcManager.getDefaultRpcOptions(true)); | rpcManager.invokeRemotely(Collections.singleton(groupManager.getPrimaryOwner(groupName)),command,rpcManager.getDefaultRpcOptions(true)) | rpcManager.invokeRemotelyAsync(Collections.singleton(groupManager.getPrimaryOwner(groupName)),command,rpcManager.getDefaultRpcOptions(true)) | infinispan | 5d3d55e238dfae5af6fdcee68029aea7ce771273 | org.infinispan.interceptors.distribution.BaseDistributionInterceptor | | | v0 | rpcManager |
---|
v1 | rpcManager.getDefaultRpcOptions(true) |
---|
v2 | Collections.singleton(groupManager.getPrimaryOwner(groupName)) |
---|
v3 | command |
---|
| | v0 | rpcManager |
---|
v1 | rpcManager.getDefaultRpcOptions(true) |
---|
v2 | Collections.singleton(groupManager.getPrimaryOwner(groupName)) |
---|
v3 | command |
---|
| AssignedTo | True |
responseMap = rpcManager.invokeRemotely(recipients,prepareCommand,builder.build()) | remoteInvocation = rpcManager.invokeRemotelyAsync(recipients,prepareCommand,builder.build()) | rpcManager.invokeRemotely(recipients,prepareCommand,builder.build()) | rpcManager.invokeRemotelyAsync(recipients,prepareCommand,builder.build()) | infinispan | ad0b1cc84778074769adf9312042fad74169bf2d | org.infinispan.interceptors.impl.BaseRpcInterceptor | | _1 | responseMap |
---|
_2 | remoteInvocation |
---|
| v0 | rpcManager |
---|
v1 | builder.build() |
---|
v2 | recipients |
---|
v3 | prepareCommand |
---|
| | v0 | rpcManager |
---|
v1 | builder.build() |
---|
v2 | recipients |
---|
v3 | prepareCommand |
---|
| AssignedTo | True |
Map<Address,Response> responseMap=rpcManager.invokeRemotely(recipients,prepareCommand,builder.build()); | CompletableFuture<Map<Address,Response>> remoteInvocation=rpcManager.invokeRemotelyAsync(recipients,prepareCommand,builder.build()); | rpcManager.invokeRemotely(recipients,prepareCommand,builder.build()) | rpcManager.invokeRemotelyAsync(recipients,prepareCommand,builder.build()) | infinispan | ad0b1cc84778074769adf9312042fad74169bf2d | org.infinispan.interceptors.impl.BaseRpcInterceptor | | _1 | responseMap |
---|
_2 | remoteInvocation |
---|
| v0 | rpcManager |
---|
v1 | builder.build() |
---|
v2 | recipients |
---|
v3 | prepareCommand |
---|
| | v0 | rpcManager |
---|
v1 | builder.build() |
---|
v2 | recipients |
---|
v3 | prepareCommand |
---|
| AssignedTo | True |
return rpcManager.invokeRemotely(recipients,prepareCommand,builder.build()); | return rpcManager.invokeRemotelyAsync(recipients,prepareCommand,builder.build()); | rpcManager.invokeRemotely(recipients,prepareCommand,builder.build()) | rpcManager.invokeRemotelyAsync(recipients,prepareCommand,builder.build()) | infinispan | ad0b1cc84778074769adf9312042fad74169bf2d | org.infinispan.interceptors.impl.BaseRpcInterceptor | | _1 | internalTotalOrderPrepare |
---|
_2 | internalTotalOrderPrepare |
---|
| v0 | rpcManager |
---|
v1 | builder.build() |
---|
v2 | recipients |
---|
v3 | prepareCommand |
---|
| | v0 | rpcManager |
---|
v1 | builder.build() |
---|
v2 | recipients |
---|
v3 | prepareCommand |
---|
| Returns | True |
resps = rpcManager.invokeRemotely(recipients,command,createPrepareRpcOptions()) | remoteInvocation = rpcManager.invokeRemotelyAsync(recipients,command,createPrepareRpcOptions()) | rpcManager.invokeRemotely(recipients,command,createPrepareRpcOptions()) | rpcManager.invokeRemotelyAsync(recipients,command,createPrepareRpcOptions()) | infinispan | ad0b1cc84778074769adf9312042fad74169bf2d | org.infinispan.interceptors.distribution.VersionedDistributionInterceptor | | _1 | resps |
---|
_2 | remoteInvocation |
---|
| v0 | rpcManager |
---|
v1 | createPrepareRpcOptions() |
---|
v2 | recipients |
---|
v3 | command |
---|
| | v0 | rpcManager |
---|
v1 | createPrepareRpcOptions() |
---|
v2 | recipients |
---|
v3 | command |
---|
| AssignedTo | True |
Map<Address,Response> resps=rpcManager.invokeRemotely(recipients,command,createPrepareRpcOptions()); | CompletableFuture<Map<Address,Response>> remoteInvocation=rpcManager.invokeRemotelyAsync(recipients,command,createPrepareRpcOptions()); | rpcManager.invokeRemotely(recipients,command,createPrepareRpcOptions()) | rpcManager.invokeRemotelyAsync(recipients,command,createPrepareRpcOptions()) | infinispan | ad0b1cc84778074769adf9312042fad74169bf2d | org.infinispan.interceptors.distribution.VersionedDistributionInterceptor | | _1 | resps |
---|
_2 | remoteInvocation |
---|
| v0 | rpcManager |
---|
v1 | createPrepareRpcOptions() |
---|
v2 | recipients |
---|
v3 | command |
---|
| | v0 | rpcManager |
---|
v1 | createPrepareRpcOptions() |
---|
v2 | recipients |
---|
v3 | command |
---|
| AssignedTo | True |
responseMap = rpcManager.invokeRemotely(recipients,command,createPrepareRpcOptions()) | remoteInvocation = rpcManager.invokeRemotelyAsync(recipients,command,createPrepareRpcOptions()) | rpcManager.invokeRemotely(recipients,command,createPrepareRpcOptions()) | rpcManager.invokeRemotelyAsync(recipients,command,createPrepareRpcOptions()) | infinispan | ad0b1cc84778074769adf9312042fad74169bf2d | org.infinispan.interceptors.distribution.TxDistributionInterceptor | | _1 | responseMap |
---|
_2 | remoteInvocation |
---|
| v0 | rpcManager |
---|
v1 | createPrepareRpcOptions() |
---|
v2 | recipients |
---|
v3 | command |
---|
| | v0 | rpcManager |
---|
v1 | createPrepareRpcOptions() |
---|
v2 | recipients |
---|
v3 | command |
---|
| AssignedTo | True |
Map<Address,Response> responseMap=rpcManager.invokeRemotely(recipients,command,createPrepareRpcOptions()); | CompletableFuture<Map<Address,Response>> remoteInvocation=rpcManager.invokeRemotelyAsync(recipients,command,createPrepareRpcOptions()); | rpcManager.invokeRemotely(recipients,command,createPrepareRpcOptions()) | rpcManager.invokeRemotelyAsync(recipients,command,createPrepareRpcOptions()) | infinispan | ad0b1cc84778074769adf9312042fad74169bf2d | org.infinispan.interceptors.distribution.TxDistributionInterceptor | | _1 | responseMap |
---|
_2 | remoteInvocation |
---|
| v0 | rpcManager |
---|
v1 | createPrepareRpcOptions() |
---|
v2 | recipients |
---|
v3 | command |
---|
| | v0 | rpcManager |
---|
v1 | createPrepareRpcOptions() |
---|
v2 | recipients |
---|
v3 | command |
---|
| AssignedTo | True |
responseMap = rpcManager.invokeRemotely(recipients,command,createRollbackRpcOptions()) | remoteInvocation = rpcManager.invokeRemotelyAsync(recipients,command,createRollbackRpcOptions()) | rpcManager.invokeRemotely(recipients,command,createRollbackRpcOptions()) | rpcManager.invokeRemotelyAsync(recipients,command,createRollbackRpcOptions()) | infinispan | ad0b1cc84778074769adf9312042fad74169bf2d | org.infinispan.interceptors.distribution.TxDistributionInterceptor | | _1 | responseMap |
---|
_2 | remoteInvocation |
---|
| v0 | rpcManager |
---|
v1 | createRollbackRpcOptions() |
---|
v2 | recipients |
---|
v3 | command |
---|
| | v0 | rpcManager |
---|
v1 | createRollbackRpcOptions() |
---|
v2 | recipients |
---|
v3 | command |
---|
| AssignedTo | True |
Map<Address,Response> responseMap=rpcManager.invokeRemotely(recipients,command,createRollbackRpcOptions()); | CompletableFuture<Map<Address,Response>> remoteInvocation=rpcManager.invokeRemotelyAsync(recipients,command,createRollbackRpcOptions()); | rpcManager.invokeRemotely(recipients,command,createRollbackRpcOptions()) | rpcManager.invokeRemotelyAsync(recipients,command,createRollbackRpcOptions()) | infinispan | ad0b1cc84778074769adf9312042fad74169bf2d | org.infinispan.interceptors.distribution.TxDistributionInterceptor | | _1 | responseMap |
---|
_2 | remoteInvocation |
---|
| v0 | rpcManager |
---|
v1 | createRollbackRpcOptions() |
---|
v2 | recipients |
---|
v3 | command |
---|
| | v0 | rpcManager |
---|
v1 | createRollbackRpcOptions() |
---|
v2 | recipients |
---|
v3 | command |
---|
| AssignedTo | True |
responseMap = rpcManager.invokeRemotely(recipients,command,createCommitRpcOptions()) | remoteInvocation = rpcManager.invokeRemotelyAsync(recipients,command,createCommitRpcOptions()) | rpcManager.invokeRemotely(recipients,command,createCommitRpcOptions()) | rpcManager.invokeRemotelyAsync(recipients,command,createCommitRpcOptions()) | infinispan | ad0b1cc84778074769adf9312042fad74169bf2d | org.infinispan.interceptors.distribution.TxDistributionInterceptor | | _1 | responseMap |
---|
_2 | remoteInvocation |
---|
| v0 | rpcManager |
---|
v1 | createCommitRpcOptions() |
---|
v2 | recipients |
---|
v3 | command |
---|
| | v0 | rpcManager |
---|
v1 | createCommitRpcOptions() |
---|
v2 | recipients |
---|
v3 | command |
---|
| AssignedTo | True |
Map<Address,Response> responseMap=rpcManager.invokeRemotely(recipients,command,createCommitRpcOptions()); | CompletableFuture<Map<Address,Response>> remoteInvocation=rpcManager.invokeRemotelyAsync(recipients,command,createCommitRpcOptions()); | rpcManager.invokeRemotely(recipients,command,createCommitRpcOptions()) | rpcManager.invokeRemotelyAsync(recipients,command,createCommitRpcOptions()) | infinispan | ad0b1cc84778074769adf9312042fad74169bf2d | org.infinispan.interceptors.distribution.TxDistributionInterceptor | | _1 | responseMap |
---|
_2 | remoteInvocation |
---|
| v0 | rpcManager |
---|
v1 | createCommitRpcOptions() |
---|
v2 | recipients |
---|
v3 | command |
---|
| | v0 | rpcManager |
---|
v1 | createCommitRpcOptions() |
---|
v2 | recipients |
---|
v3 | command |
---|
| AssignedTo | True |
responseMap = rpcManager.invokeRemotely(affectedNodes,command,rpcOptions) | remoteInvocation = rpcManager.invokeRemotelyAsync(affectedNodes,command,rpcOptions) | rpcManager.invokeRemotely(affectedNodes,command,rpcOptions) | rpcManager.invokeRemotelyAsync(affectedNodes,command,rpcOptions) | infinispan | ad0b1cc84778074769adf9312042fad74169bf2d | org.infinispan.interceptors.distribution.TxDistributionInterceptor | | _1 | responseMap |
---|
_2 | remoteInvocation |
---|
| v0 | rpcManager |
---|
v1 | rpcOptions |
---|
v2 | affectedNodes |
---|
v3 | command |
---|
| | v0 | rpcManager |
---|
v1 | rpcOptions |
---|
v2 | affectedNodes |
---|
v3 | command |
---|
| AssignedTo | True |
Map<Address,Response> responseMap=rpcManager.invokeRemotely(affectedNodes,command,rpcOptions); | CompletableFuture<Map<Address,Response>> remoteInvocation=rpcManager.invokeRemotelyAsync(affectedNodes,command,rpcOptions); | rpcManager.invokeRemotely(affectedNodes,command,rpcOptions) | rpcManager.invokeRemotelyAsync(affectedNodes,command,rpcOptions) | infinispan | ad0b1cc84778074769adf9312042fad74169bf2d | org.infinispan.interceptors.distribution.TxDistributionInterceptor | | _1 | responseMap |
---|
_2 | remoteInvocation |
---|
| v0 | rpcManager |
---|
v1 | rpcOptions |
---|
v2 | affectedNodes |
---|
v3 | command |
---|
| | v0 | rpcManager |
---|
v1 | rpcOptions |
---|
v2 | affectedNodes |
---|
v3 | command |
---|
| AssignedTo | True |
addressResponseMap=rpcManager.invokeRemotely(Collections.singletonList(primaryOwner),command,rpcManager.getDefaultRpcOptions(isSyncForwarding)); | remoteInvocation=rpcManager.invokeRemotelyAsync(Collections.singletonList(primaryOwner),command,rpcManager.getDefaultRpcOptions(isSyncForwarding)); | rpcManager.invokeRemotely(Collections.singletonList(primaryOwner),command,rpcManager.getDefaultRpcOptions(isSyncForwarding)) | rpcManager.invokeRemotelyAsync(Collections.singletonList(primaryOwner),command,rpcManager.getDefaultRpcOptions(isSyncForwarding)) | infinispan | ad0b1cc84778074769adf9312042fad74169bf2d | org.infinispan.interceptors.distribution.BaseDistributionInterceptor | | _1 | addressResponseMap |
---|
_2 | remoteInvocation |
---|
| v0 | rpcManager |
---|
v1 | rpcManager.getDefaultRpcOptions(isSyncForwarding) |
---|
v2 | Collections.singletonList(primaryOwner) |
---|
v3 | command |
---|
| | v0 | rpcManager |
---|
v1 | rpcManager.getDefaultRpcOptions(isSyncForwarding) |
---|
v2 | Collections.singletonList(primaryOwner) |
---|
v3 | command |
---|
| AssignedTo | True |