BlockStoreContext function ( InetSocketAddress arg0 ) { BlockStoreContext loc0 = CACHED_CONTEXTS . get ( arg0 ) ; if ( loc0 == null ) { loc0 = new BlockStoreContext ( arg0 ) ; CACHED_CONTEXTS . put ( arg0 , loc0 ) ; } return loc0 ; }
gets a context with the specified master address from the cache if it 's created before . otherwise creates a new one and puts it in the cache . 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 CloseableResource<BlockMasterClient> acquireMasterClientResource concode_elem_sep void releaseNettyChannel concode_elem_sep BlockWorkerClientService.Client acquireBlockWorkerThriftClient concode_elem_sep List<WorkerNetAddress> getWorkerAddresses concode_elem_sep Channel acquireNettyChannel concode_elem_sep BlockWorkerClientService.Client acquireBlockWorkerThriftClientHeartbeat