void function ( final String arg0 , final Throwable arg1 , final String arg2 ) { LOG . error ( arg0 , arg1 ) ; if ( arg2 == null ) { return ; } Subprocedure loc0 = subprocs . get ( arg2 ) ; if ( loc0 != null ) { loc0 . cancel ( arg0 , arg1 ) ; } }
the connection to the rest of the procedure group member and coordinator has been broken/lost/failed . this should fail any interested subprocedure , but not attempt to notify other members since we can not reach them anymore . concode_field_sep long KEEP_ALIVE_MILLIS_DEFAULT concode_elem_sep Log LOG concode_elem_sep SubprocedureFactory builder concode_elem_sep ExecutorService pool concode_elem_sep ProcedureMemberRpcs rpcs concode_elem_sep ConcurrentMap<String,Subprocedure> subprocs concode_field_sep ProcedureMemberRpcs getRpcs concode_elem_sep void receivedReachedGlobalBarrier concode_elem_sep boolean submitSubprocedure concode_elem_sep Subprocedure createSubprocedure concode_elem_sep boolean closeAndWait concode_elem_sep void close concode_elem_sep void receiveAbortProcedure concode_elem_sep ThreadPoolExecutor defaultPool concode_elem_sep ThreadPoolExecutor defaultPool