summary |
shortlog |
log |
commit | commitdiff |
review |
tree
raw |
patch |
inline | side by side (from parent 1:
a0c03dc)
They create spam during CSIT,
making real errors less noticable in log.
Change-Id: Icf00389526919751e88189ffef1be70e16e806e8
Signed-off-by: Vratko Polak <vrpolak@cisco.com>
18 files changed:
this.writesPerTx = writesPerTx;
this.oper = oper;
this.dataStore = dataStore;
this.writesPerTx = writesPerTx;
this.oper = oper;
this.dataStore = dataStore;
- LOG.info("DatastoreAbstractWriter created: {}", this);
+ LOG.debug("DatastoreAbstractWriter created: {}", this);
}
public abstract void createList();
}
public abstract void createList();
listenerProvider.setDataBroker(dataBroker);
setTestOperData(this.execStatus.get(), testsCompleted);
listenerProvider.setDataBroker(dataBroker);
setTestOperData(this.execStatus.get(), testsCompleted);
- LOG.info("DsbenchmarkProvider Session Initiated");
+ LOG.debug("DsbenchmarkProvider Session Initiated");
}
@Override
public void close() throws Exception {
dstReg.close();
}
@Override
public void close() throws Exception {
dstReg.close();
- LOG.info("DsbenchmarkProvider Closed");
+ LOG.debug("DsbenchmarkProvider Closed");
}
@Override
public Future<RpcResult<Void>> cleanupStore() {
cleanupTestStore();
}
@Override
public Future<RpcResult<Void>> cleanupStore() {
cleanupTestStore();
- LOG.info("Data Store cleaned up");
+ LOG.debug("Data Store cleaned up");
return Futures.immediateFuture( RpcResultBuilder.<Void>success().build());
}
return Futures.immediateFuture( RpcResultBuilder.<Void>success().build());
}
throw new IllegalStateException(e);
}
throw new IllegalStateException(e);
}
- LOG.info("DataStore test oper status populated: {}", status);
+ LOG.debug("DataStore test oper status populated: {}", status);
}
private void cleanupTestStore() {
}
private void cleanupTestStore() {
tx.put(LogicalDatastoreType.CONFIGURATION, TEST_EXEC_IID, data);
try {
tx.submit().checkedGet();
tx.put(LogicalDatastoreType.CONFIGURATION, TEST_EXEC_IID, data);
try {
tx.submit().checkedGet();
- LOG.info("DataStore config test data cleaned up");
+ LOG.debug("DataStore config test data cleaned up");
} catch (TransactionCommitFailedException e) {
LOG.info("Failed to cleanup DataStore configtest data");
throw new IllegalStateException(e);
} catch (TransactionCommitFailedException e) {
LOG.info("Failed to cleanup DataStore configtest data");
throw new IllegalStateException(e);
tx.put(LogicalDatastoreType.OPERATIONAL, TEST_EXEC_IID, data);
try {
tx.submit().checkedGet();
tx.put(LogicalDatastoreType.OPERATIONAL, TEST_EXEC_IID, data);
try {
tx.submit().checkedGet();
- LOG.info("DataStore operational test data cleaned up");
+ LOG.debug("DataStore operational test data cleaned up");
} catch (TransactionCommitFailedException e) {
LOG.info("Failed to cleanup DataStore operational test data");
throw new IllegalStateException(e);
} catch (TransactionCommitFailedException e) {
LOG.info("Failed to cleanup DataStore operational test data");
throw new IllegalStateException(e);
public void setDataBroker(DataBroker dataBroker) {
this.dataBroker = dataBroker;
public void setDataBroker(DataBroker dataBroker) {
this.dataBroker = dataBroker;
- LOG.info("DsbenchmarkListenerProvider created");
+ LOG.debug("DsbenchmarkListenerProvider created");
}
public void createAndRegisterListeners(int numListeners) {
}
public void createAndRegisterListeners(int numListeners) {
new DataTreeIdentifier<>(LogicalDatastoreType.OPERATIONAL, TEST_EXEC_IID), listener));
}
new DataTreeIdentifier<>(LogicalDatastoreType.OPERATIONAL, TEST_EXEC_IID), listener));
}
- LOG.info("DsbenchmarkListenerProvider created {} listeneres", numListeners);
+ LOG.debug("DsbenchmarkListenerProvider created {} listeneres", numListeners);
}
public long getDataChangeCount() {
}
public long getDataChangeCount() {
for (ListenerRegistration<DsbenchmarkListener> listenerRegistration : listeners) {
dataChanges += listenerRegistration.getInstance().getNumDataChanges();
}
for (ListenerRegistration<DsbenchmarkListener> listenerRegistration : listeners) {
dataChanges += listenerRegistration.getInstance().getNumDataChanges();
}
- LOG.info("DsbenchmarkListenerProvider , total data changes {}", dataChanges);
+ LOG.debug("DsbenchmarkListenerProvider , total data changes {}", dataChanges);
listenerRegistration.close();
}
listeners.clear();
listenerRegistration.close();
}
listeners.clear();
- LOG.info("DsbenchmarkListenerProvider destroyed listeneres, total events {}", totalEvents);
+ LOG.debug("DsbenchmarkListenerProvider destroyed listeneres, total events {}", totalEvents);
final long writesPerTx, final DataStore dataStore) {
super(StartTestInput.Operation.DELETE, outerListElem, innerListElem, writesPerTx, dataStore);
this.dataBroker = dataBroker;
final long writesPerTx, final DataStore dataStore) {
super(StartTestInput.Operation.DELETE, outerListElem, innerListElem, writesPerTx, dataStore);
this.dataBroker = dataBroker;
- LOG.info("Created SimpletxBaDelete");
+ LOG.debug("Created SimpletxBaDelete");
}
@Override
public void createList() {
}
@Override
public void createList() {
- LOG.info("DatastoreDelete: creating data in the data store");
+ LOG.debug("DatastoreDelete: creating data in the data store");
// Dump the whole list into the data store in a single transaction
// with <outerListElem> PUTs on the transaction
SimpletxBaWrite dd = new SimpletxBaWrite(dataBroker,
// Dump the whole list into the data store in a single transaction
// with <outerListElem> PUTs on the transaction
SimpletxBaWrite dd = new SimpletxBaWrite(dataBroker,
final long writesPerTx, final DataStore dataStore) {
super(StartTestInput.Operation.DELETE, outerListElem, innerListElem, writesPerTx, dataStore);
this.dataBroker = dataBroker;
final long writesPerTx, final DataStore dataStore) {
super(StartTestInput.Operation.DELETE, outerListElem, innerListElem, writesPerTx, dataStore);
this.dataBroker = dataBroker;
- LOG.info("Created SimpletxBaRead");
+ LOG.debug("Created SimpletxBaRead");
}
@Override
public void createList() {
}
@Override
public void createList() {
- LOG.info("DatastoreRead: creating data in the data store");
+ LOG.debug("DatastoreRead: creating data in the data store");
// Dump the whole list into the data store in a single transaction
// with <outerListElem> PUTs on the transaction
SimpletxBaWrite dd = new SimpletxBaWrite(dataBroker,
// Dump the whole list into the data store in a single transaction
// with <outerListElem> PUTs on the transaction
SimpletxBaWrite dd = new SimpletxBaWrite(dataBroker,
final int outerListElem, final int innerListElem, final long writesPerTx, final DataStore dataStore) {
super(oper, outerListElem, innerListElem, writesPerTx, dataStore);
this.dataBroker = dataBroker;
final int outerListElem, final int innerListElem, final long writesPerTx, final DataStore dataStore) {
super(oper, outerListElem, innerListElem, writesPerTx, dataStore);
this.dataBroker = dataBroker;
- LOG.info("Created SimpletxBaWrite");
+ LOG.debug("Created SimpletxBaWrite");
final int innerListElem, final long writesPerTx, final DataStore dataStore) {
super(StartTestInput.Operation.DELETE, outerListElem, innerListElem, writesPerTx, dataStore);
this.domDataBroker = domDataBroker;
final int innerListElem, final long writesPerTx, final DataStore dataStore) {
super(StartTestInput.Operation.DELETE, outerListElem, innerListElem, writesPerTx, dataStore);
this.domDataBroker = domDataBroker;
- LOG.info("Created simpleTxDomDelete");
+ LOG.debug("Created simpleTxDomDelete");
}
@Override
public void createList() {
}
@Override
public void createList() {
- LOG.info("SimpletxDomDelete: creating data in the data store");
+ LOG.debug("SimpletxDomDelete: creating data in the data store");
// Dump the whole list into the data store in a single transaction
// with <outerListElem> PUTs on the transaction
SimpletxDomWrite dd = new SimpletxDomWrite(domDataBroker,
// Dump the whole list into the data store in a single transaction
// with <outerListElem> PUTs on the transaction
SimpletxDomWrite dd = new SimpletxDomWrite(domDataBroker,
final int innerListElem, final long writesPerTx, final DataStore dataStore) {
super(StartTestInput.Operation.DELETE, outerListElem, innerListElem, writesPerTx, dataStore);
this.domDataBroker = domDataBroker;
final int innerListElem, final long writesPerTx, final DataStore dataStore) {
super(StartTestInput.Operation.DELETE, outerListElem, innerListElem, writesPerTx, dataStore);
this.domDataBroker = domDataBroker;
- LOG.info("Created simpleTxDomRead");
+ LOG.debug("Created simpleTxDomRead");
}
@Override
public void createList() {
}
@Override
public void createList() {
- LOG.info("SimpletxDomRead: creating data in the data store");
+ LOG.debug("SimpletxDomRead: creating data in the data store");
// Dump the whole list into the data store in a single transaction
// with <outerListElem> PUTs on the transaction
SimpletxDomWrite dd = new SimpletxDomWrite(domDataBroker,
// Dump the whole list into the data store in a single transaction
// with <outerListElem> PUTs on the transaction
SimpletxDomWrite dd = new SimpletxDomWrite(domDataBroker,
final int outerListElem, final int innerListElem, final long putsPerTx, final DataStore dataStore ) {
super(oper, outerListElem, innerListElem, putsPerTx, dataStore);
this.domDataBroker = domDataBroker;
final int outerListElem, final int innerListElem, final long putsPerTx, final DataStore dataStore ) {
super(oper, outerListElem, innerListElem, putsPerTx, dataStore);
this.domDataBroker = domDataBroker;
- LOG.info("Created SimpletxDomWrite");
+ LOG.debug("Created SimpletxDomWrite");
final long writesPerTx, final DataStore dataStore) {
super(StartTestInput.Operation.DELETE, outerListElem, innerListElem, writesPerTx, dataStore);
this.bindingDataBroker = bindingDataBroker;
final long writesPerTx, final DataStore dataStore) {
super(StartTestInput.Operation.DELETE, outerListElem, innerListElem, writesPerTx, dataStore);
this.bindingDataBroker = bindingDataBroker;
- LOG.info("Created TxchainBaDelete");
+ LOG.debug("Created TxchainBaDelete");
}
@Override
public void createList() {
}
@Override
public void createList() {
- LOG.info("TxchainBaDelete: creating data in the data store");
+ LOG.debug("TxchainBaDelete: creating data in the data store");
// Dump the whole list into the data store in a single transaction
// with <outerListElem> PUTs on the transaction
// Dump the whole list into the data store in a single transaction
// with <outerListElem> PUTs on the transaction
} catch (IllegalStateException e) {
LOG.error("Transaction close failed,", e);
}
} catch (IllegalStateException e) {
LOG.error("Transaction close failed,", e);
}
- LOG.info("Transactions: submitted {}, completed {}", txSubmitted, (txOk + txError));
+ LOG.debug("Transactions: submitted {}, completed {}", txSubmitted, (txOk + txError));
@Override
public void onTransactionChainSuccessful(final TransactionChain<?, ?> chain) {
@Override
public void onTransactionChainSuccessful(final TransactionChain<?, ?> chain) {
- LOG.info("TxchainBaDelete closed successfully, chain {}", chain);
+ LOG.debug("TxchainBaDelete closed successfully, chain {}", chain);
final long writesPerTx, final DataStore dataStore) {
super(StartTestInput.Operation.DELETE, outerListElem, innerListElem, writesPerTx, dataStore);
this.bindingDataBroker = bindingDataBroker;
final long writesPerTx, final DataStore dataStore) {
super(StartTestInput.Operation.DELETE, outerListElem, innerListElem, writesPerTx, dataStore);
this.bindingDataBroker = bindingDataBroker;
- LOG.info("Created TxchainBaRead");
+ LOG.debug("Created TxchainBaRead");
}
@Override
public void createList() {
}
@Override
public void createList() {
- LOG.info("TxchainBaRead: reading data in the data store");
+ LOG.debug("TxchainBaRead: reading data in the data store");
// Dump the whole list into the data store in a single transaction
// with <outerListElem> PUTs on the transaction
// Dump the whole list into the data store in a single transaction
// with <outerListElem> PUTs on the transaction
@Override
public void onTransactionChainSuccessful(final TransactionChain<?, ?> chain) {
@Override
public void onTransactionChainSuccessful(final TransactionChain<?, ?> chain) {
- LOG.info("TxchainBaDelete closed successfully, chain {}", chain);
+ LOG.debug("TxchainBaDelete closed successfully, chain {}", chain);
final int outerListElem, final int innerListElem, final long writesPerTx, final DataStore dataStore) {
super(oper, outerListElem, innerListElem, writesPerTx, dataStore);
this.bindingDataBroker = bindingDataBroker;
final int outerListElem, final int innerListElem, final long writesPerTx, final DataStore dataStore) {
super(oper, outerListElem, innerListElem, writesPerTx, dataStore);
this.bindingDataBroker = bindingDataBroker;
- LOG.info("Created TxchainBaWrite");
+ LOG.debug("Created TxchainBaWrite");
} catch (IllegalStateException e) {
LOG.error("Transaction close failed,", e);
}
} catch (IllegalStateException e) {
LOG.error("Transaction close failed,", e);
}
- LOG.info("Transactions: submitted {}, completed {}", txSubmitted, (txOk + txError));
+ LOG.debug("Transactions: submitted {}, completed {}", txSubmitted, (txOk + txError));
@Override
public void onTransactionChainSuccessful(final TransactionChain<?, ?> chain) {
@Override
public void onTransactionChainSuccessful(final TransactionChain<?, ?> chain) {
- LOG.info("DatastoreBaAbstractWrite closed successfully, chain {}", chain);
+ LOG.debug("DatastoreBaAbstractWrite closed successfully, chain {}", chain);
}
}
\ No newline at end of file
}
}
\ No newline at end of file
final long writesPerTx, final DataStore dataStore) {
super(StartTestInput.Operation.DELETE, outerListElem, innerListElem, writesPerTx, dataStore);
this.domDataBroker = domDataBroker;
final long writesPerTx, final DataStore dataStore) {
super(StartTestInput.Operation.DELETE, outerListElem, innerListElem, writesPerTx, dataStore);
this.domDataBroker = domDataBroker;
- LOG.info("Created TxchainDomDelete");
+ LOG.debug("Created TxchainDomDelete");
}
@Override
public void createList() {
}
@Override
public void createList() {
- LOG.info("TxchainDomDelete: creating data in the data store");
+ LOG.debug("TxchainDomDelete: creating data in the data store");
// Dump the whole list into the data store in a single transaction
// with <outerListElem> PUTs on the transaction
// Dump the whole list into the data store in a single transaction
// with <outerListElem> PUTs on the transaction
} catch (IllegalStateException e) {
LOG.error("Transaction close failed,", e);
}
} catch (IllegalStateException e) {
LOG.error("Transaction close failed,", e);
}
- LOG.info("Transactions: submitted {}, completed {}", txSubmitted, (txOk + txError));
+ LOG.debug("Transactions: submitted {}, completed {}", txSubmitted, (txOk + txError));
@Override
public void onTransactionChainSuccessful(final TransactionChain<?, ?> chain) {
@Override
public void onTransactionChainSuccessful(final TransactionChain<?, ?> chain) {
- LOG.info("TxchainDomDelete closed successfully, chain {}", chain);
+ LOG.debug("TxchainDomDelete closed successfully, chain {}", chain);
final long writesPerTx, final DataStore dataStore) {
super(StartTestInput.Operation.DELETE, outerListElem, innerListElem, writesPerTx, dataStore);
this.domDataBroker = domDataBroker;
final long writesPerTx, final DataStore dataStore) {
super(StartTestInput.Operation.DELETE, outerListElem, innerListElem, writesPerTx, dataStore);
this.domDataBroker = domDataBroker;
- LOG.info("Created TxchainDomDelete");
+ LOG.debug("Created TxchainDomDelete");
}
@Override
public void createList() {
}
@Override
public void createList() {
- LOG.info("TxchainDomDelete: creating data in the data store");
+ LOG.debug("TxchainDomDelete: creating data in the data store");
// Dump the whole list into the data store in a single transaction
// with <outerListElem> PUTs on the transaction
// Dump the whole list into the data store in a single transaction
// with <outerListElem> PUTs on the transaction
@Override
public void onTransactionChainSuccessful(final TransactionChain<?, ?> chain) {
@Override
public void onTransactionChainSuccessful(final TransactionChain<?, ?> chain) {
- LOG.info("TxchainDomDelete closed successfully, chain {}", chain);
+ LOG.debug("TxchainDomDelete closed successfully, chain {}", chain);
final int innerListElem, final long writesPerTx, final DataStore dataStore) {
super(oper, outerListElem, innerListElem, writesPerTx, dataStore);
this.domDataBroker = domDataBroker;
final int innerListElem, final long writesPerTx, final DataStore dataStore) {
super(oper, outerListElem, innerListElem, writesPerTx, dataStore);
this.domDataBroker = domDataBroker;
- LOG.info("Created TxchainDomWrite");
+ LOG.debug("Created TxchainDomWrite");
LOG.error("Transaction close failed,", e);
}
LOG.error("Transaction close failed,", e);
}
- LOG.info("Transactions: submitted {}, completed {}", txSubmitted, (txOk + txError));
+ LOG.debug("Transactions: submitted {}, completed {}", txSubmitted, (txOk + txError));
@Override
public void onTransactionChainSuccessful(final TransactionChain<?, ?> chain) {
@Override
public void onTransactionChainSuccessful(final TransactionChain<?, ?> chain) {
- LOG.info("Chain {} closed successfully", chain);
+ LOG.debug("Chain {} closed successfully", chain);
public NtfbenchmarkProvider(NotificationService listenServiceDependency,
NotificationPublishService publishServiceDependency) {
public NtfbenchmarkProvider(NotificationService listenServiceDependency,
NotificationPublishService publishServiceDependency) {
- LOG.info("NtfbenchmarkProvider Constructor");
+ LOG.debug("NtfbenchmarkProvider Constructor");
listenService = listenServiceDependency;
publishService = publishServiceDependency;
}
@Override
public void onSessionInitiated(final ProviderContext session) {
listenService = listenServiceDependency;
publishService = publishServiceDependency;
}
@Override
public void onSessionInitiated(final ProviderContext session) {
- LOG.info("NtfbenchmarkProvider Session Initiated");
+ LOG.debug("NtfbenchmarkProvider Session Initiated");
session.addRpcImplementation(NtfbenchmarkService.class, this);
}
@Override
public void close() throws Exception {
session.addRpcImplementation(NtfbenchmarkService.class, this);
}
@Override
public void close() throws Exception {
- LOG.info("NtfbenchmarkProvider Closed");
+ LOG.debug("NtfbenchmarkProvider Closed");
private int numRpcs = 0;
public GlobalBindingRTCServer() {
private int numRpcs = 0;
public GlobalBindingRTCServer() {
- LOG.info("GlobalBindingRTCServer created.");
+ LOG.debug("GlobalBindingRTCServer created.");
@Override
public void onSessionInitiated(ProviderContext session) {
@Override
public void onSessionInitiated(ProviderContext session) {
- LOG.info("RpcbenchmarkProvider Session Initiated");
+ LOG.debug("RpcbenchmarkProvider Session Initiated");
consumerRegistry = session.getSALService(RpcConsumerRegistry.class);
providerRegistry = session.getSALService(RpcProviderRegistry.class);
consumerRegistry = session.getSALService(RpcConsumerRegistry.class);
providerRegistry = session.getSALService(RpcProviderRegistry.class);
@Override
public void close() throws Exception {
@Override
public void close() throws Exception {
- LOG.info("RpcbenchmarkProvider Closed");
+ LOG.debug("RpcbenchmarkProvider Closed");
}
@Override
public Future<RpcResult<StartTestOutput>> startTest(final StartTestInput input) {
}
@Override
public Future<RpcResult<StartTestOutput>> startTest(final StartTestInput input) {
- LOG.info("startTest {}", input);
+ LOG.debug("startTest {}", input);
final RTCClient client;
final List<RoutedRpcRegistration<?>> rpcRegs = new ArrayList<>();
final RTCClient client;
final List<RoutedRpcRegistration<?>> rpcRegs = new ArrayList<>();