Loading kinetic-client/src/main/java/com/seagate/kinetic/client/io/IoHandler.java +3 −0 Original line number Diff line number Diff line Loading @@ -26,6 +26,7 @@ import kinetic.client.KineticException; import com.seagate.kinetic.client.internal.ClientProxy; import com.seagate.kinetic.client.io.provider.spi.ClientTransportProvider; import com.seagate.kinetic.common.lib.KineticMessage; import com.seagate.kinetic.proto.Kinetic; /** * Loading Loading @@ -115,6 +116,8 @@ public class IoHandler { // init transport this.transport.init(messageHandler); logger.info("connected to device., protocol version: " + Kinetic.Local.getDefaultInstance().getProtocolVersion()); } catch (KineticException ke) { close(); throw ke; Loading Loading
kinetic-client/src/main/java/com/seagate/kinetic/client/io/IoHandler.java +3 −0 Original line number Diff line number Diff line Loading @@ -26,6 +26,7 @@ import kinetic.client.KineticException; import com.seagate.kinetic.client.internal.ClientProxy; import com.seagate.kinetic.client.io.provider.spi.ClientTransportProvider; import com.seagate.kinetic.common.lib.KineticMessage; import com.seagate.kinetic.proto.Kinetic; /** * Loading Loading @@ -115,6 +116,8 @@ public class IoHandler { // init transport this.transport.init(messageHandler); logger.info("connected to device., protocol version: " + Kinetic.Local.getDefaultInstance().getProtocolVersion()); } catch (KineticException ke) { close(); throw ke; Loading