package art.servers.rtzserver.controller.RTZ32;
|
|
import art.library.interop.serialization.Serialization;
|
import art.library.model.devices.colors.controller.RTZ32.RTZ32_Controller;
|
import art.library.utils.synchro.Mutex;
|
import art.servers.Shared;
|
import art.servers.rtzserver.controller.Controller_RTZ32;
|
import java.net.InetSocketAddress;
|
import java.net.Socket;
|
import java.net.SocketException;
|
import java.net.SocketTimeoutException;
|
|
|
|
|
public class RTZ32_Talker
|
{
|
public static final byte STX = 0x02;
|
public static final byte ETX = 0x03;
|
public static final byte DC1 = 0x11;
|
public static final byte DC3 = 0x13;
|
public static final byte ACK = 0x06;
|
public static final byte NACK = 0x15;
|
public static final byte DET = 0x20;
|
public static final byte HTR = 0x33;
|
public static final byte SYNC = 0x40;
|
public static final byte SYNCD = 0x50;
|
public static final byte SCYCLE = 0x60;
|
|
protected String name = null;
|
protected RTZ32_Talker_Listener listener = null;
|
protected Thread threadReadData = null;
|
protected Thread threadReadControl = null;
|
protected RTZ32_Talker_Reader_Data readerData = null;
|
protected RTZ32_Talker_Reader_Control readerControl = null;
|
protected Socket socketData = null;
|
protected Socket socketControl = null;
|
public RTZ32_Talker_Writer writer = null;
|
public RTZ32_Controller rtz32 = null;
|
|
|
|
protected Mutex mutex_PET_DETECTORES = null;
|
protected Mutex mutex_PET_PLAN_DESFASE = null;
|
protected Mutex mutex_PET_ESTADO = null;
|
protected Mutex mutex_PET_ALARMAS = null;
|
protected Mutex mutex_PET_FH = null;
|
protected Mutex mutex_PET_CONTADORES = null;
|
protected Mutex mutex_PET_GRUPO = null;
|
protected Mutex mutex_PET_TABLA = null;
|
protected Mutex mutex_PET_VERSION = null;
|
protected Mutex mutex_PET_CAMBIO_FASE = null;
|
protected Mutex mutex_PET_TIEMPO_REAL = null;
|
|
protected Mutex mutex_ORD_TABLA = null;
|
protected Mutex mutex_ORD_GRABACION = null;
|
|
private Controller_RTZ32 controllerRTZ32 = null;
|
|
|
public RTZ32_Talker(String name, RTZ32_Controller rtz32, Controller_RTZ32 controllerRTZ32)
|
{
|
this.name = name;
|
this.rtz32 = Serialization.clone(rtz32);
|
this.rtz32.realtime = rtz32.realtime;
|
this.controllerRTZ32 = controllerRTZ32;
|
this.connect();
|
|
threadReadData = new Thread(new Runnable()
|
{
|
public void run()
|
{
|
if (rtz32.getDeviceInformation().connection.address == null)
|
{
|
try{threadReadData.sleep(15000);} catch (Exception e){};
|
}
|
else
|
{
|
readData();
|
}
|
}
|
});
|
|
|
threadReadControl = new Thread(new Runnable()
|
{
|
public void run()
|
{
|
if (rtz32.getDeviceInformation().connection.address == null)
|
{
|
try{threadReadControl.sleep(15000);} catch (Exception e){};
|
}
|
else
|
{
|
readControl();
|
}
|
}
|
});
|
|
threadReadData.setName("Reader data, " + name);
|
threadReadData.start();
|
threadReadData.setName("Reader control, " + name);
|
threadReadControl.start();
|
}
|
|
|
|
public void setListener(RTZ32_Talker_Listener listener)
|
{
|
this.listener = listener;
|
}
|
|
|
|
|
|
private void readData()
|
{
|
while (threadReadData.isInterrupted() == false)
|
{
|
try
|
{
|
if ((rtz32.getDeviceInformation().connection.address != null) && (isCentralized() == true))
|
{
|
connect();
|
readerData.read(rtz32, controllerRTZ32);
|
}
|
else
|
{
|
disconnect(1);
|
}
|
}
|
catch (SocketTimeoutException exception)
|
{
|
// Timeout
|
// Nothing to do
|
}
|
catch (SocketException exception)
|
{
|
// Timeout
|
// Nothing to do
|
Shared.println(name, exception.getMessage());
|
|
try
|
{
|
threadReadData.sleep(5000);
|
}
|
catch (Exception e)
|
{
|
}
|
|
disconnect(2);
|
connect();
|
}
|
catch (Exception exception)
|
{
|
// Shared.println(name, exception.getMessage());
|
//
|
// try
|
// {
|
// threadReadData.sleep(5000);
|
// }
|
// catch (Exception e)
|
// {
|
// }
|
//
|
// disconnect();
|
// connect();
|
|
rtz32.setAlarm("alarm_controller_offline", true);
|
}
|
}
|
}
|
|
|
|
private void readControl()
|
{
|
while (threadReadControl.isInterrupted() == false)
|
{
|
try
|
{
|
if ((rtz32.getDeviceInformation().connection.address != null) && (isCentralized() == true))
|
{
|
connect();
|
readerControl.read();
|
}
|
else
|
{
|
disconnect(3);
|
}
|
}
|
catch (SocketTimeoutException exception)
|
{
|
// Timeout
|
// Nothing to do
|
}
|
catch (SocketException exception)
|
{
|
Shared.println(name, exception.getMessage());
|
|
try
|
{
|
threadReadControl.sleep(5000);
|
}
|
catch (Exception e)
|
{
|
}
|
|
disconnect(4);
|
connect();
|
}
|
catch (Exception exception)
|
{
|
// Shared.println(name, exception.getMessage());
|
//
|
// try
|
// {
|
// threadReadControl.sleep(5000);
|
// }
|
// catch (Exception e)
|
// {
|
// }
|
//
|
// disconnect();
|
// connect();
|
|
rtz32.setAlarm("alarm_controller_offline", true);
|
}
|
}
|
}
|
|
//<editor-fold desc="Connection">
|
|
|
|
private Mutex mutexConnection = new Mutex();
|
|
|
|
private boolean isCentralized()
|
{
|
try
|
{
|
return (rtz32.getDeviceStatus().rtz32.isCentralized());
|
}
|
catch (Exception exception)
|
{
|
}
|
|
return true;
|
}
|
|
|
public boolean isConnected()
|
{
|
boolean connected = ((socketData != null) && (socketData.isConnected() == true) && (socketControl != null) && (socketControl.isConnected() == true));
|
|
if ((rtz32.getDeviceInformation().number <= 9003) && (connected == false))
|
{
|
Shared.println(name, Shared.getMessage("Not connected") + " : " + rtz32.getDeviceInformation().connection.address + ":" + rtz32.getDeviceInformation().connection.dataPort);
|
}
|
|
return connected;
|
}
|
|
|
public void connect()
|
{
|
if (rtz32.getDeviceInformation().connection.address == null) return;
|
|
mutexConnection.lockWrite();
|
{
|
try
|
{
|
if ((isConnected() == false) && (isCentralized() == true))
|
{
|
disconnect(5);
|
|
if (rtz32.getDeviceInformation().number <= 9003)
|
{
|
Shared.println(name, Shared.getMessage("Connecting") + " : " + rtz32.getDeviceInformation().connection.address + ":" + rtz32.getDeviceInformation().connection.dataPort);
|
}
|
|
socketData = new Socket();
|
socketData.connect(new InetSocketAddress(rtz32.getDeviceInformation().connection.address, rtz32.getDeviceInformation().connection.dataPort), rtz32.getDeviceInformation().connection.connectionTimeout);
|
socketData.setSoTimeout(rtz32.getDeviceInformation().connection.connectionTimeout);
|
|
socketControl = new Socket();
|
socketControl.connect(new InetSocketAddress(rtz32.getDeviceInformation().connection.address, rtz32.getDeviceInformation().connection.controlPort), rtz32.getDeviceInformation().connection.connectionTimeout);
|
socketControl.setSoTimeout(rtz32.getDeviceInformation().connection.connectionTimeout);
|
|
writer = new RTZ32_Talker_Writer(this, socketData, socketControl);
|
readerData = new RTZ32_Talker_Reader_Data(this, socketData, socketControl);
|
readerControl = new RTZ32_Talker_Reader_Control(this, socketControl);
|
|
Shared.println(name, Shared.getMessage("Connected"));
|
|
rtz32.setAlarm("alarm_offline", false);
|
rtz32.setAlarm("alarm_controller_offline", false);
|
if (listener != null) listener.connected();
|
|
if (rtz32.getDeviceInformation().number <= 9003)
|
{
|
Shared.println(name, Shared.getMessage("Connected") + " : " + rtz32.getDeviceInformation().connection.address + ":" + rtz32.getDeviceInformation().connection.dataPort);
|
}
|
}
|
}
|
catch (Exception exception)
|
{
|
if (rtz32.getDeviceInformation().number <= 9003)
|
{
|
Shared.printstack(name, exception);
|
}
|
|
disconnect(6);
|
}
|
}
|
mutexConnection.releaseWrite();
|
}
|
|
|
|
|
public void disconnect(int n)
|
{
|
if (rtz32.getDeviceInformation().number <= 9003)
|
{
|
Shared.println(name, Shared.getMessage("Disconnecting") + " (" + n + ") : " + rtz32.getDeviceInformation().connection.address + ":" + rtz32.getDeviceInformation().connection.dataPort);
|
}
|
try
|
{
|
socketData.close();
|
}
|
catch (Exception exception)
|
{
|
}
|
|
try
|
{
|
socketControl.close();
|
}
|
catch (Exception exception)
|
{
|
}
|
|
socketData = null;
|
socketControl = null;
|
readerData = null;
|
writer = null;
|
rtz32.setAlarm("alarm_offline", true);
|
if (listener != null) listener.disconnected();
|
}
|
|
|
|
|
|
//</editor-fold>
|
|
|
|
|
}
|
