|
|
@ -126,13 +126,12 @@ public class UdpKernel extends AbstractKernel |
|
|
|
if( reliable ) |
|
|
|
if( reliable ) |
|
|
|
throw new UnsupportedOperationException( "Reliable send not supported by this kernel." ); |
|
|
|
throw new UnsupportedOperationException( "Reliable send not supported by this kernel." ); |
|
|
|
|
|
|
|
|
|
|
|
if( copy ) |
|
|
|
if( copy ) { |
|
|
|
{ |
|
|
|
|
|
|
|
// Copy the data just once
|
|
|
|
// Copy the data just once
|
|
|
|
byte[] temp = new byte[data.remaining()]; |
|
|
|
byte[] temp = new byte[data.remaining()]; |
|
|
|
System.arraycopy(data.array(), data.position(), temp, 0, data.remaining()); |
|
|
|
System.arraycopy(data.array(), data.position(), temp, 0, data.remaining()); |
|
|
|
data = ByteBuffer.wrap(temp); |
|
|
|
data = ByteBuffer.wrap(temp); |
|
|
|
} |
|
|
|
} |
|
|
|
|
|
|
|
|
|
|
|
// Hand it to all of the endpoints that match our routing
|
|
|
|
// Hand it to all of the endpoints that match our routing
|
|
|
|
for( UdpEndpoint p : socketEndpoints.values() ) { |
|
|
|
for( UdpEndpoint p : socketEndpoints.values() ) { |
|
|
|