Code Review
/
controller.git
/ blobdiff
commit
grep
author
committer
pickaxe
?
search:
re
summary
|
shortlog
|
log
|
commit
|
commitdiff
|
review
|
tree
raw
|
inline
| side by side
Do not use RpcService in rpcbenchmark
[controller.git]
/
benchmark
/
rpcbenchmark
/
src
/
main
/
java
/
rpcbenchmark
/
impl
/
GlobalBindingRTCServer.java
diff --git
a/benchmark/rpcbenchmark/src/main/java/rpcbenchmark/impl/GlobalBindingRTCServer.java
b/benchmark/rpcbenchmark/src/main/java/rpcbenchmark/impl/GlobalBindingRTCServer.java
index 67fde76865771b5d5135d0d2bf800092afeaa54f..bac7a659a2ab72ba2a7745496393b29a44280ca5 100644
(file)
--- a/
benchmark/rpcbenchmark/src/main/java/rpcbenchmark/impl/GlobalBindingRTCServer.java
+++ b/
benchmark/rpcbenchmark/src/main/java/rpcbenchmark/impl/GlobalBindingRTCServer.java
@@
-7,9
+7,12
@@
*/
package rpcbenchmark.impl;
*/
package rpcbenchmark.impl;
+import com.google.common.collect.ImmutableClassToInstanceMap;
import org.opendaylight.mdsal.binding.api.RpcProviderService;
import org.opendaylight.mdsal.binding.api.RpcProviderService;
-import org.opendaylight.yang.gen.v1.rpcbench.payload.rev150702.RpcbenchPayloadService;
+import org.opendaylight.yang.gen.v1.rpcbench.payload.rev150702.GlobalRpcBench;
+import org.opendaylight.yang.gen.v1.rpcbench.payload.rev150702.RoutedRpcBench;
import org.opendaylight.yangtools.concepts.Registration;
import org.opendaylight.yangtools.concepts.Registration;
+import org.opendaylight.yangtools.yang.binding.Rpc;
import org.osgi.service.component.annotations.Reference;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.osgi.service.component.annotations.Reference;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
@@
-20,7
+23,10
@@
final class GlobalBindingRTCServer extends AbstractRpcbenchPayloadService implem
private final Registration reg;
GlobalBindingRTCServer(@Reference final RpcProviderService rpcProvider) {
private final Registration reg;
GlobalBindingRTCServer(@Reference final RpcProviderService rpcProvider) {
- reg = rpcProvider.registerRpcImplementation(RpcbenchPayloadService.class, this);
+ reg = rpcProvider.registerRpcImplementations(ImmutableClassToInstanceMap.<Rpc<?, ?>>builder()
+ .put(GlobalRpcBench.class, this::globalRpcBench)
+ .put(RoutedRpcBench.class, this::routedRpcBench)
+ .build());
LOG.debug("GlobalBindingRTCServer started");
}
LOG.debug("GlobalBindingRTCServer started");
}