added comments, code cleanup
This commit is contained in:
parent
cf875832d9
commit
d8455e1faf
@ -228,6 +228,7 @@ internal constructor(val type: Class<*>,
|
|||||||
*/
|
*/
|
||||||
internal val crypto: CryptoManagement
|
internal val crypto: CryptoManagement
|
||||||
|
|
||||||
|
// this barrier only prevents multiple shutdowns (in the event this close() is called multiple timees)
|
||||||
private val shutdown = atomic(false)
|
private val shutdown = atomic(false)
|
||||||
|
|
||||||
@Volatile
|
@Volatile
|
||||||
@ -275,8 +276,6 @@ internal constructor(val type: Class<*>,
|
|||||||
serialization.finishInit(type, kryo)
|
serialization.finishInit(type, kryo)
|
||||||
|
|
||||||
|
|
||||||
handshakeSendIdleStrategy = config.sendIdleStrategy.cloneToNormal()
|
|
||||||
|
|
||||||
// the initial kryo created for serialization is reused as the read kryo
|
// the initial kryo created for serialization is reused as the read kryo
|
||||||
if (type == Server::class.java) {
|
if (type == Server::class.java) {
|
||||||
readKryo = serialization.initKryo(kryo)
|
readKryo = serialization.initKryo(kryo)
|
||||||
|
Loading…
Reference in New Issue
Block a user