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.ScheduledExecutorService;
  20 import java.util.concurrent.ScheduledFuture;
  21 import java.util.concurrent.TimeUnit;
  22
  23 import org.eclipse.jdt.annotation.NonNullByDefault;
  24 import org.openhab.binding.smaenergymeter.internal.SMAEnergyMeterBindingConstants;
  25 import org.openhab.binding.smaenergymeter.internal.packet.PacketListener.ReceivingTask;
  26 import org.openhab.core.common.ThreadPoolManager;
  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 = ThreadPoolManager
  44             .getScheduledPool("OH-binding-" + SMAEnergyMeterBindingConstants.BINDING_ID + "-listener");
  45     private final Map<String, PacketListener> listeners = new ConcurrentHashMap<>();
  46
  47     @Override
  48     public PacketListener getListener(String group, int port) throws IOException {
  49         String identifier = group + ":" + port;
  50         PacketListener listener = listeners.get(identifier);
  51         if (listener == null) {
  52             listener = new PacketListener(this, group, port);
  53             listeners.put(identifier, listener);
  54         }
  55         return listener;
  56     }
  57
  58     @Deactivate
  59     protected void shutdown() throws IOException {
  60         for (Entry<String, PacketListener> entry : listeners.entrySet()) {
  61             try {
  62                 entry.getValue().close();
  63             } catch (IOException e) {
  64                 logger.warn("Multicast socket {} failed to terminate", entry.getKey(), e);
  65             }
  66         }
  67         scheduler.shutdownNow();
  68     }
  69
  70     public ScheduledFuture<?> addTask(ReceivingTask runnable) {
  71         return scheduler.scheduleWithFixedDelay(runnable, 0, 1000, TimeUnit.MILLISECONDS);
  72     }
  73
  74     public void execute(ReceivingTask receivingTask) {
  75         scheduler.execute(receivingTask);
  76     }
  77
  78     public void close(String group, int port) {
  79         String listenerId = group + ":" + port;
  80         PacketListener listener = listeners.remove(listenerId);
  81         if (listener != null) {
  82             try {
  83                 listener.close();
  84             } catch (IOException e) {
  85                 logger.warn("Multicast socket {} failed to terminate", listenerId, e);
  86             }
  87         }
  88     }
  89 }