diff options
author | Anton Tananaev <anton.tananaev@gmail.com> | 2015-06-30 09:51:23 +1200 |
---|---|---|
committer | Anton Tananaev <anton.tananaev@gmail.com> | 2015-06-30 09:51:23 +1200 |
commit | 727e7bfad908abd899d1114c5405f9bf69b47ebc (patch) | |
tree | 5c66197f72f4cbb42a1b5cecd5a71fed4b2ed757 /src/org/traccar/database/DataCache.java | |
parent | 54c54703d66e8991472c1f7476ba4acb424b27d9 (diff) | |
download | traccar-server-727e7bfad908abd899d1114c5405f9bf69b47ebc.tar.gz traccar-server-727e7bfad908abd899d1114c5405f9bf69b47ebc.tar.bz2 traccar-server-727e7bfad908abd899d1114c5405f9bf69b47ebc.zip |
Active devices in connection manager
Diffstat (limited to 'src/org/traccar/database/DataCache.java')
-rw-r--r-- | src/org/traccar/database/DataCache.java | 98 |
1 files changed, 0 insertions, 98 deletions
diff --git a/src/org/traccar/database/DataCache.java b/src/org/traccar/database/DataCache.java deleted file mode 100644 index fc29f0e2e..000000000 --- a/src/org/traccar/database/DataCache.java +++ /dev/null @@ -1,98 +0,0 @@ -/* - * Copyright 2015 Anton Tananaev (anton.tananaev@gmail.com) - * - * Licensed under the Apache License, Version 2.0 (the "License"); - * you may not use this file except in compliance with the License. - * You may obtain a copy of the License at - * - * http://www.apache.org/licenses/LICENSE-2.0 - * - * Unless required by applicable law or agreed to in writing, software - * distributed under the License is distributed on an "AS IS" BASIS, - * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. - * See the License for the specific language governing permissions and - * limitations under the License. - */ -package org.traccar.database; - -import java.sql.SQLException; -import java.util.Collection; -import java.util.HashMap; -import java.util.HashSet; -import java.util.LinkedList; -import java.util.List; -import java.util.Map; -import java.util.Set; -import org.traccar.helper.Log; -import org.traccar.model.Position; - -public class DataCache { - - private final Map<Long, Position> positions = new HashMap<Long, Position>(); - private final Map<Long, Set<DataCacheListener>> listeners = new HashMap<Long, Set<DataCacheListener>>(); - - public void init(DataManager dataManager) { - try { - Collection<Position> positions = dataManager.getLatestPositions(); - for (Position position : positions) { - this.positions.put(position.getDeviceId(), position); - } - } catch (SQLException error) { - Log.warning(error); - } - } - - public synchronized void update(Position position) { - long deviceId = position.getDeviceId(); - positions.put(deviceId, position); - if (listeners.containsKey(deviceId)) { - for (DataCacheListener listener : listeners.get(deviceId)) { - listener.onUpdate(position); - } - } - } - - public synchronized Collection<Position> getInitialState(Collection<Long> devices) { - - List<Position> result = new LinkedList<Position>(); - - for (long device : devices) { - if (positions.containsKey(device)) { - result.add(positions.get(device)); - } - } - - return result; - } - - public static interface DataCacheListener { - public void onUpdate(Position position); - } - - public void addListener(Collection<Long> devices, DataCacheListener listener) { - for (long deviceId : devices) { - addListener(deviceId, listener); - } - } - - public synchronized void addListener(long deviceId, DataCacheListener listener) { - if (!listeners.containsKey(deviceId)) { - listeners.put(deviceId, new HashSet<DataCacheListener>()); - } - listeners.get(deviceId).add(listener); - } - - public void removeListener(Collection<Long> devices, DataCacheListener listener) { - for (long deviceId : devices) { - removeListener(deviceId, listener); - } - } - - public synchronized void removeListener(long deviceId, DataCacheListener listener) { - if (!listeners.containsKey(deviceId)) { - listeners.put(deviceId, new HashSet<DataCacheListener>()); - } - listeners.get(deviceId).remove(listener); - } - -} |