Package org.epics.pvaccess.impl.remote
Interface Transport
-
- All Superinterfaces:
AutoCloseable,Channel,Closeable,org.epics.pvdata.pv.DeserializableControl
- All Known Implementing Classes:
BlockingClientTCPTransport,BlockingServerTCPTransport,BlockingTCPTransport,BlockingUDPTransport,NonBlockingClientTCPTransport,NonBlockingServerTCPTransport,NonBlockingTCPTransport
public interface Transport extends org.epics.pvdata.pv.DeserializableControl, Channel
Interface defining transport (connection).- Version:
- $Id$
- Author:
- Matej Sekoranja
-
-
Method Summary
All Methods Instance Methods Abstract Methods Modifier and Type Method Description booleanacquire(TransportClient client)Acquires transport.voidaliveNotification()Alive notification.voidauthNZInitialize(Object data)Used to initialize authNZ (select security plug-in).voidauthNZMessage(org.epics.pvdata.pv.PVField data)Pass data to the active security plug-in session.voidchangedTransport()Notification that transport has changed (server restarted).voidenqueueSendRequest(TransportSender sender)Enqueue send request.ContextgetContext()Get context transport is living in.shortgetPriority()Transport priority.intgetReceiveBufferSize()Get receive buffer size.InetSocketAddressgetRemoteAddress()Get remote address.bytegetRevision()Transport protocol revision.SecurityPlugin.SecuritySessiongetSecuritySession()intgetSocketReceiveBufferSize()Get socket receive buffer size.StringgetType()Get protocol type (tcp, udp, ssl, etc.).voidrelease(TransportClient client)Releases transport.voidsetByteOrder(ByteOrder byteOrder)Set byte order.voidsetRemoteRevision(byte revision)Set remote transport protocol revision.voidsetRemoteTransportReceiveBufferSize(int receiveBufferSize)Set remote transport receive buffer size.voidsetRemoteTransportSocketReceiveBufferSize(int socketReceiveBufferSize)Set remote transport socket receive buffer size.voidverified(org.epics.pvdata.pv.Status status)Acknowledge that transport was verified.booleanverify(long timeoutMs)Waits (if needed) until transport is verified, i.e.
-
-
-
Method Detail
-
acquire
boolean acquire(TransportClient client)
Acquires transport.- Parameters:
client- client (channel) acquiring the transport- Returns:
trueif transport was granted,falseotherwise.
-
release
void release(TransportClient client)
Releases transport.- Parameters:
client- client (channel) releasing the transport
-
getType
String getType()
Get protocol type (tcp, udp, ssl, etc.).- Returns:
- protocol type.
-
getRemoteAddress
InetSocketAddress getRemoteAddress()
Get remote address.- Returns:
- remote address.
-
getContext
Context getContext()
Get context transport is living in.- Returns:
- context transport is living in.
-
getRevision
byte getRevision()
Transport protocol revision.- Returns:
- protocol revision.
-
getReceiveBufferSize
int getReceiveBufferSize()
Get receive buffer size.- Returns:
- receive buffer size.
-
getSocketReceiveBufferSize
int getSocketReceiveBufferSize()
Get socket receive buffer size.- Returns:
- socket receive buffer size.
-
getPriority
short getPriority()
Transport priority.- Returns:
- protocol priority.
-
setRemoteRevision
void setRemoteRevision(byte revision)
Set remote transport protocol revision.- Parameters:
revision- protocol revision.
-
setRemoteTransportReceiveBufferSize
void setRemoteTransportReceiveBufferSize(int receiveBufferSize)
Set remote transport receive buffer size.- Parameters:
receiveBufferSize- receive buffer size.
-
setRemoteTransportSocketReceiveBufferSize
void setRemoteTransportSocketReceiveBufferSize(int socketReceiveBufferSize)
Set remote transport socket receive buffer size.- Parameters:
socketReceiveBufferSize- remote socket receive buffer size.
-
setByteOrder
void setByteOrder(ByteOrder byteOrder)
Set byte order.- Parameters:
byteOrder- byte order to set.
-
changedTransport
void changedTransport()
Notification that transport has changed (server restarted).
-
enqueueSendRequest
void enqueueSendRequest(TransportSender sender)
Enqueue send request.- Parameters:
sender- sender to enqueue.
-
verify
boolean verify(long timeoutMs)
Waits (if needed) until transport is verified, i.e. verified() method is being called.- Parameters:
timeoutMs- timeout to wait for verification, infinite if 0.- Returns:
- completion status.
-
verified
void verified(org.epics.pvdata.pv.Status status)
Acknowledge that transport was verified.- Parameters:
status- verification status.
-
aliveNotification
void aliveNotification()
Alive notification. This method needs to be called (by newly received data or beacon) at least once in this period, if not echo will be issued and if there is not response to it, transport will be considered as unresponsive.
-
authNZMessage
void authNZMessage(org.epics.pvdata.pv.PVField data)
Pass data to the active security plug-in session.- Parameters:
data- the data (any data), can benull.
-
authNZInitialize
void authNZInitialize(Object data)
Used to initialize authNZ (select security plug-in).- Parameters:
data- any data.
-
getSecuritySession
SecurityPlugin.SecuritySession getSecuritySession()
-
-