Modifier and Type | Method and Description |
---|---|
void |
MultiMsgCollector.addMultipartMsg(T reply,
boolean reqMore,
EventIdentifier eventIdentifier)
Method adds a reply multipart message to the collection and if the message has marker
"I'M A LAST" method set whole Collection to Future object and remove from cache.
|
void |
MultiMsgCollector.endCollecting(EventIdentifier eventIdentifier)
Null response could be a valid end multipart collecting event for barrier response scenario.
|
Modifier and Type | Method and Description |
---|---|
com.google.common.util.concurrent.ListenableFuture<org.opendaylight.yangtools.yang.common.RpcResult<List<T>>> |
StatisticsGatherer.getStatisticsOfType(EventIdentifier eventIdentifier,
MultipartType type) |
Modifier and Type | Method and Description |
---|---|
void |
MultiMsgCollectorImpl.addMultipartMsg(T reply,
boolean reqMore,
EventIdentifier eventIdentifier) |
void |
MultiMsgCollectorImpl.endCollecting(EventIdentifier eventIdentifier) |
Modifier and Type | Method and Description |
---|---|
EventIdentifier |
AbstractService.getEventIdentifier() |
EventIdentifier |
AbstractRequestCallback.getEventIdentifier() |
Modifier and Type | Method and Description |
---|---|
void |
AbstractService.setEventIdentifier(EventIdentifier eventIdentifier) |
Constructor and Description |
---|
AbstractMultipartRequestCallback(RequestContext<List<T>> context,
Class<?> requestType,
DeviceContext deviceContext,
EventIdentifier eventIdentifier) |
AbstractMultipartRequestOnTheFlyCallback(RequestContext<List<T>> context,
Class<?> requestType,
DeviceContext deviceContext,
EventIdentifier eventIdentifier,
MultipartWriterProvider statisticsWriterProvider,
ConvertorExecutor convertorExecutor) |
Constructor and Description |
---|
MultiLayerFlowMultipartRequestOnTheFlyCallback(RequestContext<List<T>> context,
Class<?> requestType,
DeviceContext deviceContext,
EventIdentifier eventIdentifier,
MultipartWriterProvider statisticsWriterProvider,
ConvertorExecutor convertorExecutor) |
MultiLayerMultipartRequestCallback(RequestContext<List<T>> context,
Class<?> requestType,
DeviceContext deviceContext,
EventIdentifier eventIdentifier) |
Constructor and Description |
---|
SingleLayerFlowMultipartRequestOnTheFlyCallback(RequestContext<List<T>> context,
Class<?> requestType,
DeviceContext deviceContext,
EventIdentifier eventIdentifier,
MultipartWriterProvider statisticsWriterProvider) |
SingleLayerMultipartRequestCallback(RequestContext<List<T>> context,
Class<?> requestType,
DeviceContext deviceContext,
EventIdentifier eventIdentifier) |
Modifier and Type | Method and Description |
---|---|
static void |
EventsTimeCounter.markEnd(EventIdentifier eventIdentifier) |
static void |
EventsTimeCounter.markStart(EventIdentifier eventIdentifier) |
Modifier and Type | Method and Description |
---|---|
com.google.common.util.concurrent.ListenableFuture<org.opendaylight.yangtools.yang.common.RpcResult<List<T>>> |
StatisticsGatheringService.getStatisticsOfType(EventIdentifier eventIdentifier,
MultipartType type) |
com.google.common.util.concurrent.ListenableFuture<org.opendaylight.yangtools.yang.common.RpcResult<List<T>>> |
StatisticsGatheringOnTheFlyService.getStatisticsOfType(EventIdentifier eventIdentifier,
MultipartType type) |
Copyright © 2020 OpenDaylight. All rights reserved.