BowlerKernel
Public Member Functions | Private Attributes | List of all members
com.neuronrobotics.sdk.network.BowlerUDPServer Class Reference
Inheritance diagram for com.neuronrobotics.sdk.network.BowlerUDPServer:
Inheritance graph
[legend]
Collaboration diagram for com.neuronrobotics.sdk.network.BowlerUDPServer:
Collaboration graph
[legend]

Public Member Functions

 BowlerUDPServer ()
 
 BowlerUDPServer (int port)
 
void disconnect ()
 
boolean connect ()
 
boolean reconnect () throws IOException
 
boolean waitingForConnection ()
 
DataInputStream getDataIns () throws NullPointerException
 
DataOutputStream getDataOuts () throws NullPointerException
 
void write (byte[] data) throws IOException
 
BowlerDatagram loadPacketFromPhy (ByteList bytesToPacketBuffer) throws NullPointerException, IOException
 
- Public Member Functions inherited from com.neuronrobotics.sdk.common.BowlerAbstractConnection
void setThreadedUpstreamPackets (boolean up)
 
BowlerDatagram sendSynchronusly (BowlerDatagram sendable)
 
synchronized BowlerDatagram sendSynchronusly (BowlerDatagram sendable, boolean switchParser)
 
void sendAsync (BowlerDatagram sendable) throws IOException
 
void setSynchronusPacketTimeoutTime (int sleepTime)
 
int getSleepTime ()
 
long msSinceLastSend ()
 
synchronized void setConnected (boolean c)
 
boolean isConnected ()
 
void clearLastSyncronousResponse ()
 
BowlerDatagram getLastSyncronousResponse ()
 
void onDataReceived (BowlerDatagram data)
 
void addDatagramListener (IBowlerDatagramListener listener)
 
void removeDatagramListener (IBowlerDatagramListener listener)
 
void setDataIns (DataInputStream dataIns)
 
void setDataOuts (DataOutputStream dataOuts)
 
void setChunkSize (int chunkSize)
 
int getChunkSize ()
 
void setAsyncQueue (QueueManager asyncQueue)
 
void setSyncQueue (QueueManager syncQueue)
 
QueueManager getAsyncQueue ()
 
QueueManager getSyncQueue ()
 
void addConnectionEventListener (IConnectionEventListener l)
 
void removeConnectionEventListener (IConnectionEventListener l)
 
void setSynchronousDatagramListener (ISynchronousDatagramListener l)
 
void removeSynchronousDatagramListener (ISynchronousDatagramListener l)
 
RpcEncapsulation locateRpc (String namespace, BowlerMethod method, String rpcString)
 
Object[] parseResponse (String namespace, BowlerMethod method, String rpcString, BowlerDatagram dg)
 
Object[] send (MACAddress addr, String namespace, BowlerMethod method, String rpcString, Object[] arguments, int retry) throws DeviceConnectionException
 
boolean isInitializedNamespaces ()
 
ArrayList< String > getNamespaces (MACAddress addr)
 
boolean hasNamespace (String string, MACAddress addr)
 
ArrayList< RpcEncapsulationgetRpcList (String namespace, MACAddress addr)
 
BowlerDatagram send (BowlerAbstractCommand command, MACAddress addr, int retry) throws NoConnectionAvailableException, InvalidResponseException
 
BowlerDatagram send (BowlerAbstractCommand command, MACAddress addr, int retry, boolean switchParser) throws NoConnectionAvailableException, InvalidResponseException
 
BowlerDatagram send (BowlerAbstractCommand command, MACAddress addr) throws NoConnectionAvailableException, InvalidResponseException
 
BowlerDatagram send (BowlerAbstractCommand command, MACAddress addr, boolean switchParser) throws NoConnectionAvailableException, InvalidResponseException
 
boolean ping (MACAddress mac)
 
boolean ping (MACAddress mac, boolean switchParser)
 
void startHeartBeat ()
 
void startHeartBeat (long msHeartBeatTime)
 
void stopHeartBeat ()
 
double getPercentagePrint ()
 
void setPercentagePrint (double percentagePrint)
 
long getLastWrite ()
 
void setLastWrite (long lastWrite)
 
boolean isUseThreadedStack ()
 
void setUseThreadedStack (boolean useThreadedStack)
 
boolean isBeater ()
 
void setBeater (boolean beater)
 

Private Attributes

int sleepTime = 1000
 
InetAddress IPAddressSet =null
 
ByteList internalReceiveBuffer = new ByteList()
 
DatagramSocket udpSock = null
 
int port = 1865
 
int destinationPort =port
 

Additional Inherited Members

- Static Public Member Functions inherited from com.neuronrobotics.sdk.common.BowlerAbstractConnection
static BowlerAbstractCommand getCommand (String namespace, BowlerMethod method, String rpcString, Object[] arguments, RpcEncapsulation rpc)
 
- Protected Member Functions inherited from com.neuronrobotics.sdk.common.BowlerAbstractConnection
BowlerDatagram fireSyncOnReceive (BowlerDatagram datagram)
 
void fireAsyncOnResponse (BowlerDatagram datagram)
 
void waitForConnectioToBeReady ()
 

Detailed Description

The Class BowlerUDPServer.

Definition at line 37 of file BowlerUDPServer.java.

Constructor & Destructor Documentation

◆ BowlerUDPServer() [1/2]

com.neuronrobotics.sdk.network.BowlerUDPServer.BowlerUDPServer ( )

◆ BowlerUDPServer() [2/2]

com.neuronrobotics.sdk.network.BowlerUDPServer.BowlerUDPServer ( int  port)

Member Function Documentation

◆ connect()

boolean com.neuronrobotics.sdk.network.BowlerUDPServer.connect ( )

◆ disconnect()

void com.neuronrobotics.sdk.network.BowlerUDPServer.disconnect ( )

Disconnect and deactive the current connection.

Reimplemented from com.neuronrobotics.sdk.common.BowlerAbstractConnection.

Definition at line 81 of file BowlerUDPServer.java.

References com.neuronrobotics.sdk.common.BowlerAbstractConnection.setConnected(), and com.neuronrobotics.sdk.network.BowlerUDPServer.udpSock.

Referenced by com.neuronrobotics.sdk.network.BowlerUDPServer.reconnect().

Here is the call graph for this function:

◆ getDataIns()

DataInputStream com.neuronrobotics.sdk.network.BowlerUDPServer.getDataIns ( ) throws NullPointerException

Gets the data ins.

Returns
the data ins
Exceptions
NullPointerExceptionthe null pointer exception

Reimplemented from com.neuronrobotics.sdk.common.BowlerAbstractConnection.

Definition at line 139 of file BowlerUDPServer.java.

◆ getDataOuts()

DataOutputStream com.neuronrobotics.sdk.network.BowlerUDPServer.getDataOuts ( ) throws NullPointerException

Gets the data outs.

Returns
the data outs
Exceptions
NullPointerExceptionthe null pointer exception

Reimplemented from com.neuronrobotics.sdk.common.BowlerAbstractConnection.

Definition at line 151 of file BowlerUDPServer.java.

◆ loadPacketFromPhy()

BowlerDatagram com.neuronrobotics.sdk.network.BowlerUDPServer.loadPacketFromPhy ( ByteList  bytesToPacketBuffer) throws NullPointerException, IOException

Load packet from phy.

Parameters
bytesToPacketBufferthe bytes to packet buffer
Returns
the bowler datagram
Exceptions
NullPointerExceptionthe null pointer exception
IOExceptionSignals that an I/O exception has occurred.

Reimplemented from com.neuronrobotics.sdk.common.BowlerAbstractConnection.

Definition at line 177 of file BowlerUDPServer.java.

References com.neuronrobotics.sdk.common.ByteList.add(), com.neuronrobotics.sdk.network.BowlerUDPServer.destinationPort, com.neuronrobotics.sdk.common.Log.info(), com.neuronrobotics.sdk.network.BowlerUDPServer.internalReceiveBuffer, com.neuronrobotics.sdk.network.BowlerUDPServer.IPAddressSet, com.neuronrobotics.sdk.common.ByteList.pop(), com.neuronrobotics.sdk.common.ByteList.size(), and com.neuronrobotics.sdk.network.BowlerUDPServer.udpSock.

Here is the call graph for this function:

◆ reconnect()

boolean com.neuronrobotics.sdk.network.BowlerUDPServer.reconnect ( ) throws IOException

Reconnect.

Returns
true, if successful
Exceptions
IOExceptionSignals that an I/O exception has occurred.

Definition at line 116 of file BowlerUDPServer.java.

References com.neuronrobotics.sdk.network.BowlerUDPServer.connect(), and com.neuronrobotics.sdk.network.BowlerUDPServer.disconnect().

Referenced by com.neuronrobotics.sdk.common.device.server.BowlerAbstractServer.removeServer().

Here is the call graph for this function:

◆ waitingForConnection()

boolean com.neuronrobotics.sdk.network.BowlerUDPServer.waitingForConnection ( )

Attempt to re-establish a connection. Return if the attempt was successful.

Returns
true, if successful Attempt to re-establish a connection. Return if the attempt was successful.
true, if successful

Reimplemented from com.neuronrobotics.sdk.common.BowlerAbstractConnection.

Definition at line 126 of file BowlerUDPServer.java.

◆ write()

void com.neuronrobotics.sdk.network.BowlerUDPServer.write ( byte[]  data) throws IOException

Member Data Documentation

◆ destinationPort

int com.neuronrobotics.sdk.network.BowlerUDPServer.destinationPort =port
private

◆ internalReceiveBuffer

ByteList com.neuronrobotics.sdk.network.BowlerUDPServer.internalReceiveBuffer = new ByteList()
private

The internal receive buffer.

Definition at line 46 of file BowlerUDPServer.java.

Referenced by com.neuronrobotics.sdk.network.BowlerUDPServer.loadPacketFromPhy().

◆ IPAddressSet

InetAddress com.neuronrobotics.sdk.network.BowlerUDPServer.IPAddressSet =null
private

◆ port

int com.neuronrobotics.sdk.network.BowlerUDPServer.port = 1865
private

◆ sleepTime

int com.neuronrobotics.sdk.network.BowlerUDPServer.sleepTime = 1000
private

The sleep time.

Definition at line 40 of file BowlerUDPServer.java.

Referenced by com.neuronrobotics.sdk.network.BowlerUDPServer.BowlerUDPServer().

◆ udpSock

DatagramSocket com.neuronrobotics.sdk.network.BowlerUDPServer.udpSock = null
private

The documentation for this class was generated from the following file: