try {
if (semaphore != null && !semaphore.tryAcquire()) {
LOG.warn("Limit of concurrent rpc messages was reached (limit: {}). Rpc reply message is needed. "
- + "Discarding request of Netconf device with id {}", concurentRpcMsgs, id.getName());
+ + "Discarding request of Netconf device with id: {}", concurentRpcMsgs, id.getName());
return FluentFutures.immediateFailedFluentFuture(new NetconfDocumentedException(
"Limit of rpc messages was reached (Limit :" + concurentRpcMsgs
- + ") waiting for emptying the queue of Netconf device with id" + id.getName()));
+ + ") waiting for emptying the queue of Netconf device with id: " + id.getName()));
}
return sendRequestWithLock(message, rpc);
case SUBTREE_MODIFIED:
case WRITE:
if (!rootNode.getDataAfter().isDatastoreLockAllowed()) {
- LOG.warn("With blocking the lock/unlock operations, the user is coming to"
- + "operate in a manner which is not supported. It must not exist"
- + "any concurrent access to the data store - it may interfere with"
- + "data consistency.");
+ LOG.warn("With blocking the lock/unlock operations, the user is coming to "
+ + "operate in a manner which is not supported. Concurrent access to "
+ + "the data store may interfere with data consistency.");
}
netconfDeviceDataBroker.setLockAllowed(rootNode.getDataAfter().isDatastoreLockAllowed());
break;
description "The operation allows the client to lock the entire configuration datastore
system of a device.
WARNING - With blocking the lock/unlock operations, the user is coming to operate
- in a manner which is not supported. It must not exist any concurrent access to
- the data store - it may interfere with data consistency.";
+ in a manner which is not supported. Concurrent access to the data store may interfere
+ with data consistency.";
}
}
}