public Future < Void > processClientResponse ( final Callable < ClientResponseImpl > response ) { return m_es . submit ( new Callable < Void > ( ) { @ Override public Void call ( ) throws Exception { try { ClientResponseImpl resp = response . call ( ) ; long handle = resp . getClientHandle ( ) ; m_procedureCallbacks . remove ( handle ) . clientCallback ( resp ) ; } catch ( Exception e ) { SNAP_LOG . warn ( "Error when SnapshotDaemon invoked callback for a procedure invocation" , e ) ; /* * Don't think it is productive to propagate any exceptions here, Ideally * they should be handled by the procedure callbacks */ } return null ; } } ) ; }
Process responses to sysproc invocations generated by this daemon via processPeriodicWork