| | |
|---|
| | | public synchronized CollectorHistoryPage collectorHistory(int collectorId, long offset, int limit) |
|---|
| | | { |
|---|
| | | CollectorState collector = requireCollector(collectorId); |
|---|
| | | return DevelopmentCollectorSimulation.history(collector, |
|---|
| | | stateStore.loadCollectorHistory(collector.deviceCode()), offset, limit); |
|---|
| | | return DevelopmentCollectorSimulation.history(collector, stateStore, offset, limit); |
|---|
| | | } |
|---|
| | | |
|---|
| | | /** 返回控制页需要的运行状态快照。 */ |
|---|
| | |
|---|
| | | || !isIpv4(collector.ip()) || !ips.add(collector.ip()) |
|---|
| | | || collector.channelCount() < 1 || collector.channelCount() > MAX_CHANNEL_COUNT) |
|---|
| | | throw new IllegalStateException("Invalid BTS simulator collector state in Redis"); |
|---|
| | | DevelopmentCollectorSimulation.validate(collector, |
|---|
| | | stateStore.loadCollectorHistory(collector.deviceCode())); |
|---|
| | | DevelopmentCollectorSimulation.validate(collector, stateStore); |
|---|
| | | maximumCollectorId = Math.max(maximumCollectorId, collector.collectorId()); |
|---|
| | | } |
|---|
| | | java.util.Set<String> tombstoneIds = new java.util.HashSet<>(); |
|---|
