Searched refs:operationsInProgress (Results 1 - 12 of 12) sorted by relevance

/forgerock/opendj-b2.6/src/server/org/opends/server/protocols/http/
H A DHTTPClientConnection.java107 * and removed from the {@link HTTPClientConnection#operationsInProgress} Map.
163 private final Map<Integer, OperationWithFutureResult> operationsInProgress = field in class:HTTPClientConnection
403 this.operationsInProgress.get(operation.getMessageID());
476 this.operationsInProgress.get(operation.getMessageID());
496 this.operationsInProgress.get(operation.getMessageID());
624 operationsInProgress.values();
637 OperationWithFutureResult op = operationsInProgress.get(messageID);
670 operationsInProgress.put(operation.getMessageID(),
680 operationsInProgress.remove(messageID);
702 OperationWithFutureResult op = operationsInProgress
[all...]
/forgerock/opendj2/src/server/org/opends/server/protocols/http/
H A DHTTPClientConnection.java106 * and removed from the {@link HTTPClientConnection#operationsInProgress} Map.
162 private final Map<Integer, OperationWithFutureResult> operationsInProgress = field in class:HTTPClientConnection
402 this.operationsInProgress.get(operation.getMessageID());
475 this.operationsInProgress.get(operation.getMessageID());
495 this.operationsInProgress.get(operation.getMessageID());
623 operationsInProgress.values();
636 OperationWithFutureResult op = operationsInProgress.get(messageID);
669 operationsInProgress.put(operation.getMessageID(),
679 operationsInProgress.remove(messageID);
701 OperationWithFutureResult op = operationsInProgress
[all...]
/forgerock/opendj2.6.2/src/server/org/opends/server/protocols/http/
H A DHTTPClientConnection.java107 * and removed from the {@link HTTPClientConnection#operationsInProgress} Map.
163 private final Map<Integer, OperationWithFutureResult> operationsInProgress = field in class:HTTPClientConnection
403 this.operationsInProgress.get(operation.getMessageID());
476 this.operationsInProgress.get(operation.getMessageID());
496 this.operationsInProgress.get(operation.getMessageID());
624 operationsInProgress.values();
637 OperationWithFutureResult op = operationsInProgress.get(messageID);
670 operationsInProgress.put(operation.getMessageID(),
680 operationsInProgress.remove(messageID);
702 OperationWithFutureResult op = operationsInProgress
[all...]
/forgerock/opendj2-jel-hg/src/server/org/opends/server/protocols/http/
H A DHTTPClientConnection.java107 * and removed from the {@link HTTPClientConnection#operationsInProgress} Map.
163 private final Map<Integer, OperationWithFutureResult> operationsInProgress = field in class:HTTPClientConnection
403 this.operationsInProgress.get(operation.getMessageID());
476 this.operationsInProgress.get(operation.getMessageID());
496 this.operationsInProgress.get(operation.getMessageID());
624 operationsInProgress.values();
637 OperationWithFutureResult op = operationsInProgress.get(messageID);
670 operationsInProgress.put(operation.getMessageID(),
680 operationsInProgress.remove(messageID);
702 OperationWithFutureResult op = operationsInProgress
[all...]
/forgerock/opendj2-hg/src/server/org/opends/server/protocols/http/
H A DHTTPClientConnection.java106 * and removed from the {@link HTTPClientConnection#operationsInProgress} Map.
162 private final Map<Integer, OperationWithFutureResult> operationsInProgress = field in class:HTTPClientConnection
402 this.operationsInProgress.get(operation.getMessageID());
475 this.operationsInProgress.get(operation.getMessageID());
495 this.operationsInProgress.get(operation.getMessageID());
623 operationsInProgress.values();
636 OperationWithFutureResult op = operationsInProgress.get(messageID);
669 operationsInProgress.put(operation.getMessageID(),
679 operationsInProgress.remove(messageID);
701 OperationWithFutureResult op = operationsInProgress
[all...]
/forgerock/opendj-v3/opendj-server-legacy/src/main/java/org/opends/server/protocols/http/
H A DHTTPClientConnection.java109 * and removed from the {@link HTTPClientConnection#operationsInProgress} Map.
174 private final Map<Integer, OperationWithPromise> operationsInProgress = new ConcurrentHashMap<>(); field in class:HTTPClientConnection
415 OperationWithPromise op = this.operationsInProgress.get(operation.getMessageID());
486 (SearchOperationWithPromise) this.operationsInProgress.get(operation.getMessageID());
503 (SearchOperationWithPromise) this.operationsInProgress.get(operation.getMessageID());
617 Collection<OperationWithPromise> values = operationsInProgress.values();
629 OperationWithPromise op = operationsInProgress.get(messageID);
674 operationsInProgress.put(opPromise.operation.getMessageID(), opPromise);
681 final OperationWithPromise previousValue = operationsInProgress.remove(messageID);
700 OperationWithPromise op = operationsInProgress
[all...]
/forgerock/opendj-b2.6/src/server/org/opends/server/protocols/ldap/
H A DLDAPClientConnection.java388 private final ConcurrentHashMap<Integer, Operation> operationsInProgress; field in class:LDAPClientConnection
484 operationsInProgress = new ConcurrentHashMap<Integer, Operation>();
1197 return operationsInProgress.values();
1213 return operationsInProgress.get(messageID);
1253 Operation op = operationsInProgress.putIfAbsent(messageID, operation);
1279 operationsInProgress.remove(messageID);
1316 Operation operation = operationsInProgress.remove(messageID);
1352 Operation op = operationsInProgress.get(messageID);
1397 for (Operation o : operationsInProgress.values())
1418 if (!(operationsInProgress
[all...]
/forgerock/opendj2/src/server/org/opends/server/protocols/ldap/
H A DLDAPClientConnection.java387 private final ConcurrentHashMap<Integer, Operation> operationsInProgress; field in class:LDAPClientConnection
484 operationsInProgress = new ConcurrentHashMap<Integer, Operation>();
1203 return operationsInProgress.values();
1219 return operationsInProgress.get(messageID);
1259 Operation op = operationsInProgress.putIfAbsent(messageID, operation);
1285 operationsInProgress.remove(messageID);
1322 Operation operation = operationsInProgress.remove(messageID);
1358 Operation op = operationsInProgress.get(messageID);
1403 for (Operation o : operationsInProgress.values())
1424 if (!(operationsInProgress
[all...]
/forgerock/opendj2.6.2/src/server/org/opends/server/protocols/ldap/
H A DLDAPClientConnection.java388 private final ConcurrentHashMap<Integer, Operation> operationsInProgress; field in class:LDAPClientConnection
484 operationsInProgress = new ConcurrentHashMap<Integer, Operation>();
1197 return operationsInProgress.values();
1213 return operationsInProgress.get(messageID);
1253 Operation op = operationsInProgress.putIfAbsent(messageID, operation);
1279 operationsInProgress.remove(messageID);
1316 Operation operation = operationsInProgress.remove(messageID);
1352 Operation op = operationsInProgress.get(messageID);
1397 for (Operation o : operationsInProgress.values())
1418 if (!(operationsInProgress
[all...]
/forgerock/opendj2-jel-hg/src/server/org/opends/server/protocols/ldap/
H A DLDAPClientConnection.java388 private final ConcurrentHashMap<Integer, Operation> operationsInProgress; field in class:LDAPClientConnection
484 operationsInProgress = new ConcurrentHashMap<Integer, Operation>();
1197 return operationsInProgress.values();
1213 return operationsInProgress.get(messageID);
1253 Operation op = operationsInProgress.putIfAbsent(messageID, operation);
1279 operationsInProgress.remove(messageID);
1316 Operation operation = operationsInProgress.remove(messageID);
1352 Operation op = operationsInProgress.get(messageID);
1397 for (Operation o : operationsInProgress.values())
1418 if (!(operationsInProgress
[all...]
/forgerock/opendj2-hg/src/server/org/opends/server/protocols/ldap/
H A DLDAPClientConnection.java387 private final ConcurrentHashMap<Integer, Operation> operationsInProgress; field in class:LDAPClientConnection
484 operationsInProgress = new ConcurrentHashMap<Integer, Operation>();
1203 return operationsInProgress.values();
1219 return operationsInProgress.get(messageID);
1259 Operation op = operationsInProgress.putIfAbsent(messageID, operation);
1285 operationsInProgress.remove(messageID);
1322 Operation operation = operationsInProgress.remove(messageID);
1358 Operation op = operationsInProgress.get(messageID);
1403 for (Operation o : operationsInProgress.values())
1424 if (!(operationsInProgress
[all...]
/forgerock/opendj-v3/opendj-server-legacy/src/main/java/org/opends/server/protocols/ldap/
H A DLDAPClientConnection.java383 private final ConcurrentHashMap<Integer, Operation> operationsInProgress; field in class:LDAPClientConnection
475 operationsInProgress = new ConcurrentHashMap<>();
1178 return operationsInProgress.values();
1194 return operationsInProgress.get(messageID);
1234 Operation op = operationsInProgress.putIfAbsent(messageID, operation);
1257 operationsInProgress.remove(messageID);
1291 Operation operation = operationsInProgress.remove(messageID);
1325 Operation op = operationsInProgress.get(messageID);
1366 for (Operation o : operationsInProgress.values())
1384 if (!operationsInProgress
[all...]

Completed in 46 milliseconds