package Ġru . cap jack . csi . core . server . internal Ċ Ċ import Ġru . cap jack . csi . core . internal . Internal Connection Processor Ċ import Ġru . cap jack . csi . core . internal . Internal Channel Ċ import Ġru . cap jack . csi . core . internal . Internal Connection Impl Ċ import Ġru . cap jack . tool . io . ByteBuffer Ċ import Ġru . cap jack . tool . lang . to HexString Ċ import Ġru . cap jack . tool . lang . wait If Ċ import Ġru . cap jack . tool . utils . assistant . Temporal Assistant Ċ import Ġru . cap jack . tool . utils . pool . Object Pool Ċ Ċ internal Ġclass ĠServer Connection Impl < I Ġ: ĠAny >( Ċ ĉ id : ĠLong , Ċ ĉ override Ġval Ġidentity : ĠI , Ċ ĉ channel : ĠInternal Channel , Ċ ĉ processor : ĠInternal Connection Processor , Ċ ĉ assistant : ĠTemp oral Assistant , Ċ ĉ byte Buffers : ĠObject Pool < ByteBuffer >, Ċ ĉ private Ġval Ġre le aser : ĠServer Connection Re le aser < I > Ċ ) Ġ: ĠInternal Connection Impl ( Ċ ĉ id , Ċ ĉ channel , Ċ ĉ processor , Ċ ĉ assistant , Ċ ĉ byte Buffers , Ċ ĉ "$ identity -${ id . to HexString () }" Ċ ), ĠServer Connection < I > Ġ{ ĊĉĊ ĉ override Ġfun Ġtry Recovery ( channel : ĠInternal Channel , Ġlast Sent MessageId : ĠInt ): ĠBoolean Ġ{ Ċĉ ĉ return Ġ! wait If ( 1 0 0 0 , Ġ 1 0 ) Ġ{ Ċĉĉ ĉ ! super . try Recovery ( channel , Ġlast Sent MessageId ) Ċĉ ĉ } Ċ ĉ } ĊĉĊ ĉ override Ġfun Ġsync Process Close () Ġ{ Ċĉ ĉ re le aser . release Server Connection ( this ) Ċ ĉ } Ċ }