- added connect timeout

pull/4/head
Michael Zillgith 8 years ago
parent dc632f3007
commit f064d16553

@ -18,8 +18,8 @@ package org.openmuc.jositransport;
import java.io.IOException;
import java.net.InetAddress;
import java.net.InetSocketAddress;
import java.net.Socket;
import javax.net.SocketFactory;
/**
@ -152,8 +152,11 @@ public final class ClientTSap {
public TConnection connectTo(InetAddress address, int port, InetAddress localAddr, int localPort)
throws IOException {
Socket socket;
if (localAddr == null) {
socket = socketFactory.createSocket(address, port);
if (localAddr == null) {
socket = socketFactory.createSocket();
socket.connect(new InetSocketAddress(address, port), messageTimeout);
}
else {
socket = socketFactory.createSocket(address, port, localAddr, localPort);

@ -294,7 +294,7 @@ public final class TConnection {
}
os.flush();
socket.setSoTimeout(messageTimeout);
byte myByte;

@ -110,4 +110,8 @@ abstract public class BasicDataAttribute extends FcModelNode {
mirror = bda;
}
public String getValueString() {
return null;
}
}

@ -95,5 +95,11 @@ abstract public class BdaBitString extends BasicDataAttribute {
public String toString() {
return getReference().toString() + ": " + HexConverter.toHexString(value);
}
@Override
public String getValueString()
{
return HexConverter.toHexString(value);
}
}

@ -90,4 +90,9 @@ public final class BdaBoolean extends BasicDataAttribute {
return getReference().toString() + ": " + value;
}
@Override
public String getValueString()
{
return "" + value;
}
}

@ -95,4 +95,9 @@ public final class BdaDoubleBitPos extends BdaBitString {
}
}
@Override
public String getValueString()
{
return getDoubleBitPos().toString();
}
}

@ -132,4 +132,9 @@ public final class BdaEntryTime extends BasicDataAttribute {
return getReference().toString() + ": " + getTimestampValue();
}
@Override
public String getValueString()
{
return "" + getTimestampValue();
}
}

@ -115,4 +115,9 @@ public final class BdaFloat32 extends BasicDataAttribute {
return getReference().toString() + ": " + getFloat();
}
@Override
public String getValueString()
{
return getFloat().toString();
}
}

@ -121,5 +121,11 @@ public final class BdaFloat64 extends BasicDataAttribute {
public String toString() {
return getReference().toString() + ": " + getDouble();
}
@Override
public String getValueString()
{
return "" + value;
}
}

@ -90,4 +90,9 @@ public final class BdaInt128 extends BasicDataAttribute {
return getReference().toString() + ": " + value;
}
@Override
public String getValueString()
{
return "" + value;
}
}

@ -90,4 +90,8 @@ public final class BdaInt32 extends BasicDataAttribute {
return getReference().toString() + ": " + value;
}
@Override
public String getValueString() {
return "" + value;
}
}

@ -89,5 +89,11 @@ public final class BdaInt32U extends BasicDataAttribute {
public String toString() {
return getReference().toString() + ": " + value;
}
@Override
public String getValueString()
{
return "" + value;
}
}

@ -89,5 +89,11 @@ public final class BdaInt8 extends BasicDataAttribute {
public String toString() {
return getReference().toString() + ": " + value;
}
@Override
public String getValueString()
{
return "" + value;
}
}

@ -241,5 +241,11 @@ public final class BdaQuality extends BdaBitString {
value[1] = (byte) (value[0] & 0xf7);
}
}
@Override
public String getValueString()
{
return getValidity().toString();
}
}

@ -242,4 +242,8 @@ public final class BdaTimestamp extends BasicDataAttribute {
return getReference().toString() + ": " + getDate();
}
@Override
public String getValueString() {
return getDate().toString();
}
}

@ -120,5 +120,10 @@ public final class BdaVisibleString extends BasicDataAttribute {
}
return getReference().toString() + ": " + new String(value);
}
@Override
public String getValueString()
{
return new String(value);
}
}

@ -280,7 +280,7 @@ public final class ClientSap {
*/
public ClientAssociation associate(InetAddress address, int port, String authenticationParameter,
ClientEventListener reportListener) throws IOException {
System.out.println("Associate");
return associate(address, port, authenticationParameter, null, -1, reportListener);
}

@ -1012,6 +1012,22 @@ final class SclParser {
else if (bType.equals("Tcmd")) {
return new BdaTapCommand(new ObjectReference(ref), fc, sAddr, dchg, dupd);
}
else if (bType.equals("OptFlds")) {
return new BdaOptFlds(new ObjectReference(ref), fc);
}
else if (bType.equals("TrgOps")) {
return new BdaTriggerConditions(new ObjectReference(ref), fc);
}
else if (bType.equals("EntryID")) {
return new BdaOctetString(new ObjectReference(ref), fc, sAddr, 8, dchg, dupd);
}
else if (bType.equals("EntryTime")) {
return new BdaEntryTime(new ObjectReference(ref), fc, sAddr, dchg, dupd);
}
else if (bType.equals("PhyComAddr")) {
//TODO not correct!
return new BdaOctetString(new ObjectReference(ref), fc, sAddr, 6, dchg, dupd);
}
else if (bType.equals("Timestamp")) {
BdaTimestamp bda = new BdaTimestamp(new ObjectReference(ref), fc, sAddr, dchg, dupd);
if (val != null) {

Loading…
Cancel
Save