public void reportError ( NodeT faulted , Throwable throwable ) { faulted . setPreparer ( true ) ; String dependency = faulted . key ( ) ; for ( String dependentKey : nodeTable . get ( dependency ) . dependentKeys ( ) ) { DAGNode < DataT , NodeT > dependent = nodeTable . get ( dependentKey ) ; dependent . lock ( ) . lock ( ) ; try { dependent . onFaultedResolution ( dependency , throwable ) ; if ( dependent . hasAllResolved ( ) ) { queue . add ( dependent . key ( ) ) ; } } finally { dependent . lock ( ) . unlock ( ) ; } } }
Reports that a node is faulted .