package org.opendaylight.genius.idmanager;
import com.google.common.net.InetAddresses;
+import java.net.InetAddress;
+import java.util.LinkedList;
+import java.util.List;
+import java.util.concurrent.ExecutionException;
+import java.util.concurrent.Future;
import org.opendaylight.yang.gen.v1.urn.opendaylight.genius.idmanager.rev160406.DelayedIdEntry;
import org.opendaylight.yang.gen.v1.urn.opendaylight.genius.idmanager.rev160406.IdPools;
import org.opendaylight.yang.gen.v1.urn.opendaylight.genius.idmanager.rev160406.id.pools.IdPool;
import org.opendaylight.yang.gen.v1.urn.opendaylight.genius.idmanager.rev160406.id.pools.IdPoolBuilder;
import org.opendaylight.yang.gen.v1.urn.opendaylight.genius.idmanager.rev160406.id.pools.IdPoolKey;
-import org.opendaylight.yang.gen.v1.urn.opendaylight.genius.idmanager.rev160406.id.pools.id.pool.*;
+import org.opendaylight.yang.gen.v1.urn.opendaylight.genius.idmanager.rev160406.id.pools.id.pool.AvailableIdsHolder;
+import org.opendaylight.yang.gen.v1.urn.opendaylight.genius.idmanager.rev160406.id.pools.id.pool.AvailableIdsHolderBuilder;
+import org.opendaylight.yang.gen.v1.urn.opendaylight.genius.idmanager.rev160406.id.pools.id.pool.ChildPools;
+import org.opendaylight.yang.gen.v1.urn.opendaylight.genius.idmanager.rev160406.id.pools.id.pool.ChildPoolsBuilder;
+import org.opendaylight.yang.gen.v1.urn.opendaylight.genius.idmanager.rev160406.id.pools.id.pool.ChildPoolsKey;
+import org.opendaylight.yang.gen.v1.urn.opendaylight.genius.idmanager.rev160406.id.pools.id.pool.IdEntries;
+import org.opendaylight.yang.gen.v1.urn.opendaylight.genius.idmanager.rev160406.id.pools.id.pool.IdEntriesBuilder;
+import org.opendaylight.yang.gen.v1.urn.opendaylight.genius.idmanager.rev160406.id.pools.id.pool.IdEntriesKey;
+import org.opendaylight.yang.gen.v1.urn.opendaylight.genius.idmanager.rev160406.id.pools.id.pool.ReleasedIdsHolder;
+import org.opendaylight.yang.gen.v1.urn.opendaylight.genius.idmanager.rev160406.id.pools.id.pool.ReleasedIdsHolderBuilder;
import org.opendaylight.yang.gen.v1.urn.opendaylight.genius.idmanager.rev160406.released.ids.DelayedIdEntries;
import org.opendaylight.yang.gen.v1.urn.opendaylight.genius.idmanager.rev160406.released.ids.DelayedIdEntriesBuilder;
-import org.opendaylight.yang.gen.v1.urn.opendaylight.genius.lockmanager.rev160413.*;
+import org.opendaylight.yang.gen.v1.urn.opendaylight.genius.lockmanager.rev160413.LockInput;
+import org.opendaylight.yang.gen.v1.urn.opendaylight.genius.lockmanager.rev160413.LockInputBuilder;
+import org.opendaylight.yang.gen.v1.urn.opendaylight.genius.lockmanager.rev160413.LockManagerService;
+import org.opendaylight.yang.gen.v1.urn.opendaylight.genius.lockmanager.rev160413.UnlockInput;
+import org.opendaylight.yang.gen.v1.urn.opendaylight.genius.lockmanager.rev160413.UnlockInputBuilder;
import org.opendaylight.yangtools.yang.binding.InstanceIdentifier;
import org.opendaylight.yangtools.yang.common.RpcResult;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
-import java.net.InetAddress;
-import java.util.LinkedList;
-import java.util.List;
-import java.util.concurrent.ExecutionException;
-import java.util.concurrent.Future;
-
class IdUtils {
private static final Logger LOGGER = LoggerFactory.getLogger(IdUtils.class);
}
protected static IdPool createLocalIdPool(String localPoolName, IdPool parentIdPool) {
+ IdPoolBuilder idPoolBuilder = new IdPoolBuilder();
ReleasedIdsHolder releasedIdsHolder = createReleasedIdsHolder(DEFAULT_AVAILABLE_ID_COUNT, DEFAULT_DELAY_TIME);
- return new IdPoolBuilder().setKey(new IdPoolKey(localPoolName))
+ return idPoolBuilder.setKey(new IdPoolKey(localPoolName))
.setPoolName(localPoolName)
.setParentPoolName(parentIdPool.getPoolName())
.setBlockSize(parentIdPool.getBlockSize())
Future<RpcResult<Void>> result = lockManager.lock(input);
try {
if ((result != null) && (result.get().isSuccessful())) {
- LOGGER.debug("Acquired lock {}", poolName);
+ if (LOGGER.isDebugEnabled()) {
+ LOGGER.debug("Acquired lock {}", poolName);
+ }
} else {
throw new RuntimeException(String.format("Unable to getLock for pool %s", poolName));
}
Future<RpcResult<Void>> result = lockManager.unlock(input);
try {
if ((result != null) && (result.get().isSuccessful())) {
- LOGGER.debug("Unlocked {}", poolName);
+ if (LOGGER.isDebugEnabled()) {
+ LOGGER.debug("Unlocked {}", poolName);
+ }
} else {
- LOGGER.debug("Unable to unlock pool {}", poolName);
+ if (LOGGER.isDebugEnabled()) {
+ LOGGER.debug("Unable to unlock pool {}", poolName);
+ }
}
} catch (InterruptedException | ExecutionException e) {
LOGGER.error("Unable to unlock for pool {}", poolName);
throw new RuntimeException(String.format("Unable to unlock pool %s", poolName), e.getCause());
}
}
-}
\ No newline at end of file
+}