diff options
author | Mark Spruiell <mes@zeroc.com> | 2014-05-29 11:06:44 -0700 |
---|---|---|
committer | Mark Spruiell <mes@zeroc.com> | 2014-05-29 11:06:44 -0700 |
commit | 3cfd324cdcc65d2acbc7536f1652d44f66a0e896 (patch) | |
tree | 44613394c5b9c6c6eb0ec8b41e110002a58d60ea /java/src/IceInternal/Transceiver.java | |
parent | Fixed Python throughput demo config (diff) | |
download | ice-3cfd324cdcc65d2acbc7536f1652d44f66a0e896.tar.bz2 ice-3cfd324cdcc65d2acbc7536f1652d44f66a0e896.tar.xz ice-3cfd324cdcc65d2acbc7536f1652d44f66a0e896.zip |
porting C++ transport changes to Java
Diffstat (limited to 'java/src/IceInternal/Transceiver.java')
-rw-r--r-- | java/src/IceInternal/Transceiver.java | 31 |
1 files changed, 5 insertions, 26 deletions
diff --git a/java/src/IceInternal/Transceiver.java b/java/src/IceInternal/Transceiver.java index 329ff3e1386..ad372615208 100644 --- a/java/src/IceInternal/Transceiver.java +++ b/java/src/IceInternal/Transceiver.java @@ -13,35 +13,14 @@ public interface Transceiver { java.nio.channels.SelectableChannel fd(); - // - // Initialize the transceiver. - // - // Returns the status if the initialize operation. - // - int initialize(Buffer readBuffer, Buffer writeBuffer); - + int initialize(Buffer readBuffer, Buffer writeBuffer, Ice.BooleanHolder moreData); + int closing(boolean initiator, Ice.LocalException ex); void close(); - // - // Write data. - // - // Returns true if all the data was written, false otherwise. - // - boolean write(Buffer buf); - - // - // Read data. - // - // Returns true if all the requested data was read, false otherwise. - // - // NOTE: In Java, read() returns a boolean in moreData to indicate - // whether the transceiver has read more data than requested. - // If moreData is true, read should be called again without - // calling select on the FD. - // - boolean read(Buffer buf, Ice.BooleanHolder moreData); + int write(Buffer buf); + int read(Buffer buf, Ice.BooleanHolder moreData); - String type(); + String protocol(); String toString(); Ice.ConnectionInfo getInfo(); void checkSendSize(Buffer buf, int messageSizeMax); |