void function ( InetSocketAddress arg0 , Channel arg1 ) { Preconditions . checkArgument ( NETTY_CHANNEL_POOL_MAP . containsKey ( arg0 ) ) ; NETTY_CHANNEL_POOL_MAP . get ( arg0 ) . release ( arg1 ) ; }
releases a netty channel to the channel pools . concode_field_sep ConcurrentHashMapV8<InetSocketAddress,BlockWorkerThriftClientPool> BLOCK_WORKER_THRIFT_CLIENT_HEARTBEAT_POOL concode_elem_sep BlockMasterClientPool mBlockMasterClientPool concode_elem_sep Boolean mHasLocalWorker concode_elem_sep ConcurrentHashMapV8<InetSocketAddress,BlockWorkerThriftClientPool> BLOCK_WORKER_THRIFT_CLIENT_POOL concode_elem_sep ConcurrentHashMapV8<InetSocketAddress,NettyChannelPool> NETTY_CHANNEL_POOL_MAP concode_elem_sep Map<InetSocketAddress,BlockStoreContext> CACHED_CONTEXTS concode_field_sep BlockWorkerClient acquireWorkerClient concode_elem_sep void releaseBlockWorkerThriftClient concode_elem_sep void initializeGauges concode_elem_sep boolean hasLocalWorker concode_elem_sep void releaseBlockWorkerThriftClientHeartbeat concode_elem_sep void releaseWorkerClient concode_elem_sep BlockStoreContext get concode_elem_sep BlockStoreContext get concode_elem_sep CloseableResource<BlockMasterClient> acquireMasterClientResource concode_elem_sep BlockWorkerClientService.Client acquireBlockWorkerThriftClient concode_elem_sep List<WorkerNetAddress> getWorkerAddresses concode_elem_sep Channel acquireNettyChannel concode_elem_sep BlockWorkerClientService.Client acquireBlockWorkerThriftClientHeartbeat