import org.opendaylight.ovsdb.lib.operations.OperationResult;
public class FutureTransformUtils {
- private static final ObjectMapper objectMapper = new ObjectMapper();
+ private static final ObjectMapper OBJECT_MAPPER = new ObjectMapper();
public static final ListenableFuture<List<OperationResult>> transformTransactResponse(
ListenableFuture<List<JsonNode>> transactResponseFuture, final List<Operation> operations) {
- objectMapper.configure(DeserializationFeature.FAIL_ON_UNKNOWN_PROPERTIES, false);
+ OBJECT_MAPPER.configure(DeserializationFeature.FAIL_ON_UNKNOWN_PROPERTIES, false);
return Futures.transform(transactResponseFuture, new Function<List<JsonNode>, List<OperationResult>>() {
@Override
public List<OperationResult> apply(List<JsonNode> jsonNodes) {
break;
default:
- or = objectMapper.convertValue(jsonNode, OperationResult.class);
+ or = OBJECT_MAPPER.convertValue(jsonNode, OperationResult.class);
break;
}
} else {
- or = objectMapper.convertValue(jsonNode, OperationResult.class);
+ or = OBJECT_MAPPER.convertValue(jsonNode, OperationResult.class);
}
} else {
or = new OperationResult();
private Channel channel;
private boolean isConnectionPublished;
- private static final ThreadFactory threadFactorySSL =
- new ThreadFactoryBuilder().setNameFormat("OVSDBPassiveConnSSL-%d").build();
- private static final ThreadFactory threadFactoryNonSSL =
- new ThreadFactoryBuilder().setNameFormat("OVSDBPassiveConnNonSSL-%d").build();
+ private static final ThreadFactory THREAD_FACTORY_SSL =
+ new ThreadFactoryBuilder().setNameFormat("OVSDB-PassiveConnection-SSL-%d").build();
+ private static final ThreadFactory THREAD_FACTORY_NON_SSL =
+ new ThreadFactoryBuilder().setNameFormat("OVSDB-PassiveConnection-Non-SSL-%d").build();
public OvsdbClientImpl(OvsdbRPC rpc, Channel channel, ConnectionType type,
SocketConnectionType socketConnType) {
if (type == ConnectionType.PASSIVE) {
switch (socketConnType) {
case SSL:
- return threadFactorySSL;
+ return THREAD_FACTORY_SSL;
case NON_SSL:
- return threadFactoryNonSSL;
+ return THREAD_FACTORY_NON_SSL;
default:
return Executors.defaultThreadFactory();
}
private static final int IDLE_READER_TIMEOUT = 30;
private static final int READ_TIMEOUT = 180;
- private static final StalePassiveConnectionService stalePassiveConnectionService =
+ private static final StalePassiveConnectionService STALE_PASSIVE_CONNECTION_SERVICE =
new StalePassiveConnectionService(executorService);
private static int retryPeriod = 100; // retry after 100 milliseconds
if (clientsFromSameNode.size() == 0) {
notifyListenerForPassiveConnection(client);
} else {
- stalePassiveConnectionService.handleNewPassiveConnection(client, clientsFromSameNode);
+ STALE_PASSIVE_CONNECTION_SERVICE.handleNewPassiveConnection(client, clientsFromSameNode);
}
}
listener.disconnected(client);
}
}
- stalePassiveConnectionService.clientDisconnected(client);
+ STALE_PASSIVE_CONNECTION_SERVICE.clientDisconnected(client);
}
@Override
private static final Logger LOG = LoggerFactory.getLogger(JsonRpcEndpoint.class);
private static final int REAPER_INTERVAL = 300;
private static final int REAPER_THREADS = 3;
- private static final ThreadFactory futureReaperThreadFactory = new ThreadFactoryBuilder()
+ private static final ThreadFactory FUTURE_REAPER_THREAD_FACTORY = new ThreadFactoryBuilder()
.setNameFormat("OVSDB-Lib-Future-Reaper-%d").build();
- private static final ScheduledExecutorService futureReaperService
- = Executors.newScheduledThreadPool(REAPER_THREADS, futureReaperThreadFactory);
+ private static final ScheduledExecutorService FUTURE_REAPER_SERVICE
+ = Executors.newScheduledThreadPool(REAPER_THREADS, FUTURE_REAPER_THREAD_FACTORY);
public class CallContext {
Method method;
SettableFuture<Object> sf = SettableFuture.create();
methodContext.put(request.getId(), new CallContext(request, method, sf));
- futureReaperService.schedule(new Runnable() {
+ FUTURE_REAPER_SERVICE.schedule(new Runnable() {
@Override
public void run() {
if (sf.isDone() || sf.isCancelled()) {