package Ġcom . ag m to py . k ocket mq . rem oting . netty Ċ Ċ import Ġcom . ag m to py . k ocket mq . rem oting . constant . Net ty System Config Ċ Ċ /** Ċ Ġ* ĠNet ty Server ĠConfig Ċ Ġ*/ Ċ class ĠNet ty Server Config : ĠClone able Ġ{ ĊĠĠĠ Ġprivate Ġvar Ġlisten Port Ġ= Ġ 8 8 8 8 ĊĠĠĠ Ġprivate Ġvar Ġserver Worker Threads Ġ= Ġ 8 ĊĠĠĠ Ġprivate Ġvar Ġserver Callback Executor Threads Ġ= Ġ 0 ĊĠĠĠ Ġprivate Ġvar Ġserver Selector Threads Ġ= Ġ 3 ĊĠĠĠ Ġvar Ġserver O new ay Semaphore Value Ġ= Ġ 2 5 6 ĊĠĠĠ Ġvar Ġserver Async Semaphore Value Ġ= Ġ 6 4 ĊĠĠĠ Ġprivate Ġvar Ġserver Channel Max Idle Time Seconds Ġ= Ġ 1 2 0 ĊĊĠĠĠ Ġprivate Ġvar Ġserver Socket S nd Buf Size : ĠInt Ġ= ĠNet ty System Config . socket S nd buf Size ĊĠĠĠ Ġprivate Ġvar Ġserver Socket R cv Buf Size : ĠInt Ġ= ĠNet ty System Config . socket R cv buf Size ĊĠĠĠ Ġprivate Ġvar Ġserver P ooled Byte Buf Allocator Enable Ġ= Ġtrue ĊĊĠĠĠ Ġ/** ĊĠĠĠĠ Ġ* Ġmake Ġmake Ġinstall ĊĠĠĠĠ Ġ* ĊĠĠĠĠ Ġ* ĊĠĠĠĠ Ġ* Ġ../ g libc - 2 . 1 0 . 1 / configure Ġ\ Ġ-- prefix =/ usr Ġ\ Ġ-- with - headers =/ usr / include Ġ\ ĊĠĠĠĠ Ġ* Ġ-- host = x 8 6 _ 6 4 - linux - gnu Ġ\ Ġ-- build = x 8 6 _ 6 4 - pc - linux - gnu Ġ\ Ġ-- without - gd ĊĠĠĠĠ Ġ*/ ĊĠĠĠ Ġprivate Ġvar Ġuse E poll Native Selector Ġ= Ġfalse ĊĊĠĠĠ Ġfun Ġget Listen Port (): ĠInt Ġ{ ĊĠĠĠĠĠĠĠ Ġreturn Ġlisten Port ĊĠĠĠ Ġ} ĊĊĠĠĠ Ġfun Ġset Listen Port ( listen Port : ĠInt ) Ġ{ ĊĠĠĠĠĠĠĠ Ġthis . listen Port Ġ= Ġlisten Port ĊĠĠĠ Ġ} ĊĊĠĠĠ Ġfun Ġget Server Worker Threads (): ĠInt Ġ{ ĊĠĠĠĠĠĠĠ Ġreturn Ġserver Worker Threads ĊĠĠĠ Ġ} ĊĊĠĠĠ Ġfun Ġset Server Worker Threads ( server Worker Threads : ĠInt ) Ġ{ ĊĠĠĠĠĠĠĠ Ġthis . server Worker Threads Ġ= Ġserver Worker Threads ĊĠĠĠ Ġ} ĊĊĠĠĠ Ġfun Ġget Server Selector Threads (): ĠInt Ġ{ ĊĠĠĠĠĠĠĠ Ġreturn Ġserver Selector Threads ĊĠĠĠ Ġ} ĊĊĠĠĠ Ġfun Ġset Server Selector Threads ( server Selector Threads : ĠInt ) Ġ{ ĊĠĠĠĠĠĠĠ Ġthis . server Selector Threads Ġ= Ġserver Selector Threads ĊĠĠĠ Ġ} ĊĊĠĠ Ġfun Ġget Server Callback Executor Threads (): ĠInt Ġ{ ĊĠĠĠĠĠĠĠ Ġreturn Ġserver Callback Executor Threads ĊĠĠĠ Ġ} ĊĊĠĠĠ Ġfun Ġset Server Callback Executor Threads ( server Callback Executor Threads : ĠInt ) Ġ{ ĊĠĠĠĠĠĠĠ Ġthis . server Callback Executor Threads Ġ= Ġserver Callback Executor Threads ĊĠĠĠ Ġ} ĊĊĠĠĠ Ġfun Ġget Server Channel Max Idle Time Seconds (): ĠInt Ġ{ ĊĠĠĠĠĠĠĠ Ġreturn Ġserver Channel Max Idle Time Seconds ĊĠĠĠ Ġ} ĊĊĠĠĠ Ġfun Ġset Server Channel Max Idle Time Seconds ( server Channel Max Idle Time Seconds : ĠInt ) Ġ{ ĊĠĠĠĠĠĠĠ Ġthis . server Channel Max Idle Time Seconds Ġ= Ġserver Channel Max Idle Time Seconds ĊĠĠĠ Ġ} ĊĊĠĠĠ Ġfun Ġget Server Socket S nd Buf Size (): ĠInt Ġ{ ĊĠĠĠĠĠĠĠ Ġreturn Ġserver Socket S nd Buf Size ĊĠĠĠ Ġ} ĊĊĠĠĠ Ġfun Ġset Server Socket S nd Buf Size ( server Socket S nd Buf Size : ĠInt ) Ġ{ ĊĠĠĠĠĠĠĠ Ġthis . server Socket S nd Buf Size Ġ= Ġserver Socket S nd Buf Size ĊĠĠĠ Ġ} ĊĊĠĠĠ Ġfun Ġget Server Socket R cv Buf Size (): ĠInt Ġ{ ĊĠĠĠĠĠĠĠ Ġreturn Ġserver Socket R cv Buf Size ĊĠĠĠ Ġ} ĊĊĠĠĠ Ġfun Ġset Server Socket R cv Buf Size ( server Socket R cv Buf Size : ĠInt ) Ġ{ ĊĠĠĠĠĠĠĠ Ġthis . server Socket R cv Buf Size Ġ= Ġserver Socket R cv Buf Size ĊĠĠĠ Ġ} ĊĊĠĠĠ Ġfun Ġis Server P ooled Byte Buf Allocator Enable (): ĠBoolean Ġ{ ĊĠĠĠĠĠĠĠ Ġreturn Ġserver P ooled Byte Buf Allocator Enable ĊĠĠĠ Ġ} ĊĊĠĠĠ Ġfun Ġset Server P ooled Byte Buf Allocator Enable ( server P ooled Byte Buf Allocator Enable : ĠBoolean ) Ġ{ ĊĠĠĠĠĠĠĠ Ġthis . server P ooled Byte Buf Allocator Enable Ġ= Ġserver P ooled Byte Buf Allocator Enable ĊĠĠĠ Ġ} ĊĊĠĠĠ Ġfun Ġis Use E poll Native Selector (): ĠBoolean Ġ{ ĊĠĠĠĠĠĠĠ Ġreturn Ġuse E poll Native Selector ĊĠĠĠ Ġ} ĊĊĠĠĠ Ġfun Ġset Use E poll Native Selector ( use E poll Native Selector : ĠBoolean ) Ġ{ ĊĠĠĠĠĠĠĠ Ġthis . use E poll Native Selector Ġ= Ġuse E poll Native Selector ĊĠĠĠ Ġ} ĊĊĠĠĠ Ġ@ Throws ( Clone NotSupportedException :: class ) ĊĠĠĠ Ġoverride Ġfun Ġclone (): ĠAny Ġ{ ĊĠĠĠĠĠĠĠ Ġreturn Ġsuper . clone () Ġas ĠNet ty Server Config ĊĠĠĠ Ġ} Ċ }