git.basschouten.com Git - openhab-addons.git/blob

   1 /**
   2  * Copyright (c) 2010-2024 Contributors to the openHAB project
   3  *
   4  * See the NOTICE file(s) distributed with this work for additional
   5  * information.
   6  *
   7  * This program and the accompanying materials are made available under the
   8  * terms of the Eclipse Public License 2.0 which is available at
   9  * http://www.eclipse.org/legal/epl-2.0
  10  *
  11  * SPDX-License-Identifier: EPL-2.0
  12  */
  13 package org.openhab.binding.smaenergymeter.internal.packet;
  14
  15 import java.io.IOException;
  16 import java.util.Map;
  17 import java.util.Map.Entry;
  18 import java.util.concurrent.ConcurrentHashMap;
  19 import java.util.concurrent.Executors;
  20 import java.util.concurrent.ScheduledExecutorService;
  21 import java.util.concurrent.ScheduledFuture;
  22 import java.util.concurrent.TimeUnit;
  23
  24 import org.eclipse.jdt.annotation.NonNullByDefault;
  25 import org.openhab.binding.smaenergymeter.internal.SMAEnergyMeterBindingConstants;
  26 import org.openhab.binding.smaenergymeter.internal.packet.PacketListener.ReceivingTask;
  27 import org.osgi.service.component.annotations.Component;
  28 import org.osgi.service.component.annotations.Deactivate;
  29 import org.slf4j.Logger;
  30 import org.slf4j.LoggerFactory;
  31
  32 /**
  33  * Implementation of packet listener registry which manage multicast sockets.
  34  *
  35  * @author Łukasz Dywicki - Initial contribution
  36  */
  37
  38 @NonNullByDefault
  39 @Component
  40 public class DefaultPacketListenerRegistry implements PacketListenerRegistry {
  41
  42     private final Logger logger = LoggerFactory.getLogger(DefaultPacketListenerRegistry.class);
  43     private final ScheduledExecutorService scheduler = Executors.newScheduledThreadPool(1,
  44             (runnable) -> new Thread(runnable,
  45                     "OH-binding-" + SMAEnergyMeterBindingConstants.BINDING_ID + "-listener"));
  46     private final Map<String, PacketListener> listeners = new ConcurrentHashMap<>();
  47
  48     @Override
  49     public PacketListener getListener(String group, int port) throws IOException {
  50         String identifier = group + ":" + port;
  51         PacketListener listener = listeners.get(identifier);
  52         if (listener == null) {
  53             listener = new PacketListener(this, group, port);
  54             listeners.put(identifier, listener);
  55         }
  56         return listener;
  57     }
  58
  59     @Deactivate
  60     protected void shutdown() throws IOException {
  61         for (Entry<String, PacketListener> entry : listeners.entrySet()) {
  62             try {
  63                 entry.getValue().close();
  64             } catch (IOException e) {
  65                 logger.warn("Multicast socket {} failed to terminate", entry.getKey(), e);
  66             }
  67         }
  68         scheduler.shutdownNow();
  69     }
  70
  71     public ScheduledFuture<?> addTask(Runnable runnable, int intervalSec) {
  72         return scheduler.scheduleWithFixedDelay(runnable, 0, intervalSec, TimeUnit.SECONDS);
  73     }
  74
  75     public void execute(ReceivingTask receivingTask) {
  76         scheduler.execute(receivingTask);
  77     }
  78
  79     public void close(String group, int port) {
  80         String listenerId = group + ":" + port;
  81         PacketListener listener = listeners.remove(listenerId);
  82         if (listener != null) {
  83             try {
  84                 listener.close();
  85             } catch (IOException e) {
  86                 logger.warn("Multicast socket {} failed to terminate", listenerId, e);
  87             }
  88         }
  89     }
  90 }