getEngine().closeOutbound();
} catch (Throwable e) {
log.warn("Error closing connection ",e);
close();
}
<BUG>}
public boolean writeToSocketChannel(Pipe<NetPayloadSchema> source) {

ByteBuffer[] writeHolder = PipeReader.wrappedUnstructuredLayoutBuffer(source, NetPayloadSchema.MSG_PLAIN_210_FIELD_PAYLOAD_204);
try {
do {
getSocketChannel().write(writeHolder);
} while (writeHolder[1].hasRemaining()); //TODO: this  is a bad spin loop to be refactored up and out.
} catch (IOException e) {</BUG>
log.debug("unable to write to socket {}",this,e);

getEngine().closeOutbound();
} catch (Throwable e) {
log.warn("Error closing connection ",e);
