X-Git-Url: https://git.opendaylight.org/gerrit/gitweb?p=controller.git;a=blobdiff_plain;f=benchmark%2Fntfbenchmark%2Fsrc%2Fmain%2Fjava%2Fntfbenchmark%2Fimpl%2FNtfbenchmarkProvider.java;fp=benchmark%2Fntfbenchmark%2Fsrc%2Fmain%2Fjava%2Fntfbenchmark%2Fimpl%2FNtfbenchmarkProvider.java;h=50b0478628beb68ff332ba738b28f7b78c20c1eb;hp=39e8273bdb8833e119cfe25f5963208025b5dd97;hb=4588c8fc9faaf73b84fdcf63d9be82e14087dffe;hpb=3b1bb4b5cad75f64dc7d8de93e7754aa4218fbe2 diff --git a/benchmark/ntfbenchmark/src/main/java/ntfbenchmark/impl/NtfbenchmarkProvider.java b/benchmark/ntfbenchmark/src/main/java/ntfbenchmark/impl/NtfbenchmarkProvider.java index 39e8273bdb..50b0478628 100644 --- a/benchmark/ntfbenchmark/src/main/java/ntfbenchmark/impl/NtfbenchmarkProvider.java +++ b/benchmark/ntfbenchmark/src/main/java/ntfbenchmark/impl/NtfbenchmarkProvider.java @@ -28,6 +28,7 @@ import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.ntfbench import org.opendaylight.yangtools.concepts.ListenerRegistration; import org.opendaylight.yangtools.yang.common.RpcResult; import org.opendaylight.yangtools.yang.common.RpcResultBuilder; +import org.opendaylight.yangtools.yang.common.Uint32; import org.slf4j.Logger; import org.slf4j.LoggerFactory; @@ -120,13 +121,14 @@ public class NtfbenchmarkProvider implements AutoCloseable, NtfbenchmarkService final StartTestOutput output = new StartTestOutputBuilder() - .setProducerElapsedTime(producerElapsedTime / 1000000) - .setListenerElapsedTime(listenerElapsedTime / 1000000) - .setListenerOk(allListeners) - .setProducerOk(allProducersOk) - .setProducerError(allProducersError) - .setProducerRate((allProducersOk + allProducersError) * 1000000000 / producerElapsedTime) - .setListenerRate(allListeners * 1000000000 / listenerElapsedTime) + .setProducerElapsedTime(Uint32.valueOf(producerElapsedTime / 1000000)) + .setListenerElapsedTime(Uint32.valueOf(listenerElapsedTime / 1000000)) + .setListenerOk(Uint32.valueOf(allListeners)) + .setProducerOk(Uint32.valueOf(allProducersOk)) + .setProducerError(Uint32.valueOf(allProducersError)) + .setProducerRate(Uint32.valueOf((allProducersOk + allProducersError) * 1000000000 + / producerElapsedTime)) + .setListenerRate(Uint32.valueOf(allListeners * 1000000000 / listenerElapsedTime)) .build(); return RpcResultBuilder.success(output).buildFuture(); } finally {