|
|
@ -113,7 +113,6 @@ public class UdpConnector implements Connector |
|
|
|
public ByteBuffer read() |
|
|
|
public ByteBuffer read() |
|
|
|
{ |
|
|
|
{ |
|
|
|
checkClosed(); |
|
|
|
checkClosed(); |
|
|
|
|
|
|
|
|
|
|
|
try { |
|
|
|
try { |
|
|
|
DatagramPacket packet = new DatagramPacket( buffer, buffer.length ); |
|
|
|
DatagramPacket packet = new DatagramPacket( buffer, buffer.length ); |
|
|
|
sock.receive(packet); |
|
|
|
sock.receive(packet); |
|
|
@ -132,7 +131,6 @@ public class UdpConnector implements Connector |
|
|
|
public void write( ByteBuffer data ) |
|
|
|
public void write( ByteBuffer data ) |
|
|
|
{ |
|
|
|
{ |
|
|
|
checkClosed(); |
|
|
|
checkClosed(); |
|
|
|
|
|
|
|
|
|
|
|
try { |
|
|
|
try { |
|
|
|
DatagramPacket p = new DatagramPacket( data.array(), data.position(), data.remaining(), |
|
|
|
DatagramPacket p = new DatagramPacket( data.array(), data.position(), data.remaining(), |
|
|
|
remoteAddress ); |
|
|
|
remoteAddress ); |
|
|
|