<snapshot>
<required-capabilities>
<capability>urn:opendaylight:params:xml:ns:yang:dsbenchmark:impl?module=dsbenchmark-impl&revision=2014-12-10</capability>
+ <capability>urn:opendaylight:params:xml:ns:yang:controller:config:distributed-datastore-provider?module=distributed-datastore-provider&revision=2014-06-12</capability>
+ <capability>urn:opendaylight:params:xml:ns:yang:controller:md:sal:core:spi:config-dom-store?module=opendaylight-config-dom-datastore&revision=2014-06-17</capability>
+ <capability>urn:opendaylight:params:xml:ns:yang:controller:md:sal:core:spi:operational-dom-store?module=opendaylight-operational-dom-datastore&revision=2014-06-17</capability>
+ <capability>urn:opendaylight:params:xml:ns:yang:controller:md:sal:dom?module=opendaylight-md-sal-dom&revision=2013-10-28</capability>
<capability>urn:opendaylight:params:xml:ns:yang:controller:md:sal:binding?module=opendaylight-md-sal-binding&revision=2013-10-28</capability>
</required-capabilities>
<configuration>
@Override
public void onSessionInitiated(ProviderContext session) {
this.dataBroker = session.getSALService(DataBroker.class);
- this.dstReg = session.addRpcImplementation( DsbenchmarkService.class, this );
+ this.dstReg = session.addRpcImplementation(DsbenchmarkService.class, this);
listenerProvider.setDataBroker(dataBroker);
- setTestOperData(this.execStatus.get(), testsCompleted);
+
+ try {
+ setTestOperData(this.execStatus.get(), testsCompleted);
+ } catch (Exception e) {
+ LOG.warn("Working around Bugs 8829 and 6793 by ignoring exception from setTestOperData: {}", e);
+ }
LOG.debug("DsbenchmarkProvider Session Initiated");
}
public Future<RpcResult<Void>> cleanupStore() {
cleanupTestStore();
LOG.debug("Data Store cleaned up");
- return Futures.immediateFuture( RpcResultBuilder.<Void>success().build());
+ return Futures.immediateFuture(RpcResultBuilder.<Void>success().build());
}
@Override
LOG.info("Starting the data store benchmark test, input: {}", input);
// Check if there is a test in progress
- if ( execStatus.compareAndSet(ExecStatus.Idle, ExecStatus.Executing) == false ) {
+ if (execStatus.compareAndSet(ExecStatus.Idle, ExecStatus.Executing) == false) {
LOG.info("Test in progress");
return RpcResultBuilder.success(new StartTestOutputBuilder()
.setStatus(StartTestOutput.Status.TESTINPROGRESS)
this.testsCompleted++;
- } catch (Exception e) {
- LOG.error( "Test error: {}", e.toString());
- execStatus.set( ExecStatus.Idle );
+ } catch (final Exception e) {
+ LOG.error("Test error: {}", e.toString());
+ execStatus.set(ExecStatus.Idle);
return RpcResultBuilder.success(new StartTestOutputBuilder()
.setStatus(StartTestOutput.Status.FAILED)
.build()).buildFuture();
}
LOG.info("Test finished");
- setTestOperData( ExecStatus.Idle, testsCompleted);
+ setTestOperData(ExecStatus.Idle, testsCompleted);
execStatus.set(ExecStatus.Idle);
// Get the number of data change events and cleanup the data change listeners
return RpcResultBuilder.success(output).buildFuture();
}
- private void setTestOperData( ExecStatus sts, long tstCompl ) {
+ private void setTestOperData(final ExecStatus sts, final long tstCompl) {
TestStatus status = new TestStatusBuilder()
.setExecStatus(sts)
.setTestsCompleted(tstCompl)