question: allows to wait for all non master nodes to reply to the publish event up to a timeout concode_field_sep CountDownLatch latch concode_elem_sep Set<DiscoveryNode> pendingNodes concode_field_sep void onResponse concode_elem_sep void onFailure concode_elem_sep DiscoveryNode[] pendingNodes
target: boolean function ( TimeValue arg0 ) { boolean loc0 = latch . await ( arg0 . millis ( ) , TimeUnit . MILLISECONDS ) ; assert ! loc0 || pendingNodes . isEmpty ( ) : "srini_string" ; return loc0 ; }