import com.google.common.util.concurrent.FutureCallback;
import com.google.common.util.concurrent.Futures;
import com.google.common.util.concurrent.ListenableFuture;
+import com.google.common.util.concurrent.MoreExecutors;
/**
* Endpoint registry provides a scalable store for accessing and updating
*/
public class EndpointRpcRegistry implements EndpointService, EpRendererAugmentationRegistry, AutoCloseable {
- private static final Logger LOG = LoggerFactory.getLogger(EndpointRpcRegistry.class);
-
- private final DataBroker dataProvider;
-
final static ConcurrentMap<String, EpRendererAugmentation> registeredRenderers =
new ConcurrentHashMap<String, EpRendererAugmentation>();
+ private static final Logger LOG = LoggerFactory.getLogger(EndpointRpcRegistry.class);
+ private final DataBroker dataProvider;
+ private Function<Void, RpcResult<Void>> futureTrans = input -> RpcResultBuilder.<Void>success().build();
/**
* This method registers a renderer for endpoint RPC API. This method
public void onSuccess(Void result) {
}
- });
+ }, MoreExecutors.directExecutor());
}
// TODO Be alagalah - age out endpoint data and remove
}
}
ListenableFuture<Void> r = t.submit();
- return Futures.transform(r, futureTrans);
+ return Futures.transform(r, futureTrans, MoreExecutors.directExecutor());
}
@Override
t.put(LogicalDatastoreType.OPERATIONAL, iid_l3prefix, epL3Prefix);
ListenableFuture<Void> r = t.submit();
- return Futures.transform(r, futureTrans);
+ return Futures.transform(r, futureTrans, MoreExecutors.directExecutor());
}
@Override
}
ListenableFuture<Void> r = t.submit();
- return Futures.transform(r, futureTrans);
+ return Futures.transform(r, futureTrans, MoreExecutors.directExecutor());
}
@Override
}
ListenableFuture<Void> r = t.submit();
- return Futures.transform(r, futureTrans);
+ return Futures.transform(r, futureTrans, MoreExecutors.directExecutor());
}
@Override
}
ListenableFuture<Void> r = t.submit();
- return Futures.transform(r, futureTrans);
+ return Futures.transform(r, futureTrans, MoreExecutors.directExecutor());
}
-
- Function<Void, RpcResult<Void>> futureTrans = new Function<Void, RpcResult<Void>>() {
-
- @Override
- public RpcResult<Void> apply(Void input) {
- return RpcResultBuilder.<Void>success().build();
- }
- };
}