mhop/ha-bridge
1
0
Fork 0
mirror of https://github.com/bwssytems/ha-bridge.git synced 2025-12-21 01:05:43 +00:00
Code Issues Packages Projects Releases Wiki Activity

Fixed spelling mistake in UDP Sender.

Browse Source
This commit is contained in:
melloware
2016-12-17 14:04:06 -05:00
parent d0a63747c7
commit 11eefa9efd
1 changed files with 72 additions and 72 deletions
Download Patch File Download Diff File Expand all files Collapse all files

144
src/main/java/com/bwssystems/util/UDPDatagramSender.java
View File

@@ -1,72 +1,72 @@
package com.bwssystems.util; package com.bwssystems.util;
import java.io.IOException; import java.io.IOException;
import java.net.DatagramPacket; import java.net.DatagramPacket;
import java.net.DatagramSocket; import java.net.DatagramSocket;
import java.net.InetAddress; import java.net.InetAddress;
import java.net.SocketException; import java.net.SocketException;
import org.slf4j.Logger; import org.slf4j.Logger;
import org.slf4j.LoggerFactory; import org.slf4j.LoggerFactory;
public class UDPDatagramSender { public class UDPDatagramSender {
private Logger log = LoggerFactory.getLogger(UDPDatagramSender.class); private Logger log = LoggerFactory.getLogger(UDPDatagramSender.class);
private DatagramSocket responseSocket = null; private DatagramSocket responseSocket = null;
private int udpResponsePort; private int udpResponsePort;
public UDPDatagramSender() { public UDPDatagramSender() {
super(); super();
udpResponsePort = 0; udpResponsePort = 0;
} }
public static UDPDatagramSender createUDPDatagramSender(int udpResponsePort) { public static UDPDatagramSender createUDPDatagramSender(int udpResponsePort) {
UDPDatagramSender aDatagramSender = new UDPDatagramSender(); UDPDatagramSender aDatagramSender = new UDPDatagramSender();
if(aDatagramSender.initializeSocket(udpResponsePort)) if(aDatagramSender.initializeSocket(udpResponsePort))
return aDatagramSender; return aDatagramSender;
else else
return null; return null;
} }
private boolean initializeSocket(int port) { private boolean initializeSocket(int port) {
log.info("Initializing UDP response Seocket..."); log.info("Initializing UDP response Socket...");
udpResponsePort = port; udpResponsePort = port;
boolean portLoopControl = true; boolean portLoopControl = true;
int retryCount = 0; int retryCount = 0;
while(portLoopControl) { while(portLoopControl) {
try { try {
responseSocket = new DatagramSocket(udpResponsePort); responseSocket = new DatagramSocket(udpResponsePort);
portLoopControl = false; portLoopControl = false;
} catch(SocketException e) { } catch(SocketException e) {
if(retryCount == 0) if(retryCount == 0)
log.warn("UDP Response Port is in use, starting loop to find open port for 20 tries - configured port is: " + udpResponsePort); log.warn("UDP Response Port is in use, starting loop to find open port for 20 tries - configured port is: " + udpResponsePort);
if(retryCount >= 20) { if(retryCount >= 20) {
portLoopControl = false; portLoopControl = false;
log.error("UDP Response Port issue, could not find open port - last port tried: " + udpResponsePort + " with message: " + e.getMessage()); log.error("UDP Response Port issue, could not find open port - last port tried: " + udpResponsePort + " with message: " + e.getMessage());
return false; return false;
} }
} }
if(portLoopControl) { if(portLoopControl) {
retryCount++; retryCount++;
udpResponsePort++; udpResponsePort++;
} }
} }
log.info("UDP response Seocket initialized to: " + udpResponsePort); log.info("UDP response Seocket initialized to: " + udpResponsePort);
return true; return true;
} }
public int getUdpResponsePort() { public int getUdpResponsePort() {
return udpResponsePort; return udpResponsePort;
} }
public void closeResponseSocket() { public void closeResponseSocket() {
responseSocket.close(); responseSocket.close();
} }
public void sendUDPResponse(String udpResponse, InetAddress requester, int sourcePort) throws IOException { public void sendUDPResponse(String udpResponse, InetAddress requester, int sourcePort) throws IOException {
log.debug("Sending response string: <<<" + udpResponse + ">>>"); log.debug("Sending response string: <<<" + udpResponse + ">>>");
if(responseSocket == null) if(responseSocket == null)
throw new IOException("Socket not initialized"); throw new IOException("Socket not initialized");
DatagramPacket response = new DatagramPacket(udpResponse.getBytes(), udpResponse.length(), requester, sourcePort); DatagramPacket response = new DatagramPacket(udpResponse.getBytes(), udpResponse.length(), requester, sourcePort);
responseSocket.send(response); responseSocket.send(response);
} }
} }