GlobalChannelTrafficShapingHandler.
This TrafficCounter is the Global one, and its special property is to directly handle
other channel's TrafficCounters. In particular, there are no scheduler for those
channel's TrafficCounters because it is managed by this one.
| Modifier and Type | Class and Description |
|---|---|
| private static class | GlobalChannelTrafficCounter.
Class to implement monitoring at fix delay. |
| Access | Constructor and Description |
|---|---|
| public | GlobalChannelTrafficCounter(GlobalChannelTrafficShapingHandler
the associated trafficShapingHandler, EventExecutorGroup GlobalChannelTrafficShapingHandler.the underlying executor service for scheduling checks (both Global and per Channel). executor, String the name given to this monitor. name, long the checkInterval in millisecond between two computations. checkInterval)
|
| Modifier and Type | Method and Description |
|---|---|
| public void | resetCumulativeTime()
Overrides io. |
| public synchronized void | |
| public synchronized void |
| GlobalChannelTrafficCounter | back to summary |
|---|---|
public GlobalChannelTrafficCounter(GlobalChannelTrafficShapingHandler trafficShapingHandler, EventExecutorGroup executor, String name, long checkInterval)
| |
| resetCumulativeTime | back to summary |
|---|---|
| public void resetCumulativeTime() Overrides io. Doc from io. Reset both read and written cumulative bytes counters and the associated absolute time from System.currentTimeMillis().
| |
| start | back to summary |
|---|---|
| public synchronized void start() Overrides io. Start the monitoring process.
| |
| stop | back to summary |
|---|---|
| public synchronized void stop() Overrides io. Stop the monitoring process.
| |
| Modifier and Type | Field and Description |
|---|---|
| private final TrafficCounter | counter
The associated TrafficCounter |
| private final GlobalChannelTrafficShapingHandler | trafficShapingHandler1
The associated TrafficShapingHandler |
| Access | Constructor and Description |
|---|---|
| pack-priv | MixedTrafficMonitoringTask(GlobalChannelTrafficShapingHandler
The parent handler to which this task needs to callback to for accounting. trafficShapingHandler, TrafficCounter The parent TrafficCounter that we need to reset the statistics for. counter)
|
| Modifier and Type | Method and Description |
|---|---|
| public void |
| counter | back to summary |
|---|---|
| private final TrafficCounter counter The associated TrafficCounter | |
| trafficShapingHandler1 | back to summary |
|---|---|
| private final GlobalChannelTrafficShapingHandler trafficShapingHandler1 The associated TrafficShapingHandler | |
| MixedTrafficMonitoringTask | back to summary |
|---|---|
pack-priv MixedTrafficMonitoringTask(GlobalChannelTrafficShapingHandler trafficShapingHandler, TrafficCounter counter)
| |
| run | back to summary |
|---|---|
| public void run() Implements java. Doc from java. Runs this operation.
| |