Searched defs:coordinatorId (Results 1 – 6 of 6) sorted by relevance
66 public synchronized UceRequestCoordinator removeRequestCoordinator(Long coordinatorId) { in removeRequestCoordinator()82 public synchronized UceRequestCoordinator getRequestCoordinator(Long coordinatorId) { in getRequestCoordinator()
570 Long coordinatorId = requestCoordinator.getCoordinatorId(); in sendSubscribeRetryRequest() local844 public void sendRequestMessage(Long coordinatorId, Long taskId, long delayTimeMs) { in sendRequestMessage()858 public void sendRequestUpdatedMessage(Long coordinatorId, Long taskId, in sendRequestUpdatedMessage()906 public void sendRequestFinishedMessage(Long coordinatorId, Long taskId) { in sendRequestFinishedMessage()920 public void sendRequestCoordinatorFinishedMessage(Long coordinatorId) { in sendRequestCoordinatorFinishedMessage()953 final Long coordinatorId = (Long) args.arg1; in handleMessage() local1029 private UceRequestCoordinator removeRequestCoordinator(Long coordinatorId) { in removeRequestCoordinator()1037 private UceRequestCoordinator getRequestCoordinator(Long coordinatorId) { in getRequestCoordinator()
45 public Request(long coordinatorId, long taskId) { in Request()103 public synchronized void addRequest(long coordinatorId, List<Long> taskIds) { in addRequest()
47 void setRequestCoordinatorId(long coordinatorId); in setRequestCoordinatorId()
105 public void setRequestCoordinatorId(long coordinatorId) { in setRequestCoordinatorId()
82 public void setRequestCoordinatorId(long coordinatorId) { in setRequestCoordinatorId()