| 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 |
AbstractRequestCallback.getEventIdentifier() |
EventIdentifier |
AbstractService.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 © 2019 OpenDaylight. All rights reserved.