public void onMemberLeft ( MemberImpl leftMember ) { for ( WaitSet waitSet : waitSetMap . values ( ) ) { waitSet . invalidateAll ( leftMember . getUuid ( ) ) ; } }
invalidated waiting ops will removed from queue eventually by notifiers .