Searched refs:pSearch (Results 1 - 9 of 9) sorted by relevance
/forgerock/openam/openam-core/src/test/java/org/forgerock/openam/sm/datalayer/impl/ldap/ |
H A D | CTSDJLDAPv3PersistentSearchTest.java | 33 CTSDJLDAPv3PersistentSearch pSearch; field in class:CTSDJLDAPv3PersistentSearchTest 41 pSearch = new CTSDJLDAPv3PersistentSearch(3000, DN.rootDN(), Filter.alwaysFalse(), 50 pSearch.addContinuousQueryListener(mockListener); 51 pSearch.addContinuousQueryListener(mockListener2); 54 pSearch.clearCaches(); 66 pSearch.addContinuousQueryListener(mockListener); 67 pSearch.addContinuousQueryListener(mockListener2); 70 pSearch.stopQuery(); 73 assertThat(pSearch.hasListeners()).isFalse(); 74 assertThat(pSearch [all...] |
/forgerock/openam-v13/openam-core/src/main/java/com/iplanet/services/ldap/event/ |
H A D | EventService.java | 179 EventServicePersistentSearch pSearch = new EventServicePersistentSearch(RETRY_INTERVAL, 184 pSearch.addListener(listener, new BigInteger(130, new Random()).toString()); 186 pSearch.startSearch(); 187 persistentSearches.put(listenerClass, new ListenerSearch(listener, pSearch)); 205 for (ListenerSearch pSearch : persistentSearches.values()) { 206 pSearch.search.removeListener(pSearch.listener); 207 pSearch.search.stopSearch();
|
/forgerock/openam/openam-core/src/main/java/com/iplanet/services/ldap/event/ |
H A D | EventService.java | 192 EventServicePersistentSearch pSearch = new EventServicePersistentSearch(RETRY_INTERVAL, 197 pSearch.addListener(listener, new BigInteger(130, new Random()).toString()); 199 pSearch.startQuery(); 200 persistentSearches.put(listenerClass, new ListenerSearch(listener, pSearch)); 221 for (ListenerSearch pSearch : persistentSearches.values()) { 222 pSearch.search.removeListener(pSearch.listener); 223 pSearch.search.stopSearch();
|
/forgerock/openam/openam-core/src/main/java/org/forgerock/openam/sm/datalayer/impl/ldap/ |
H A D | LdapQueryBuilder.java | 115 ContinuousQuery pSearch = builder 122 pSearch.addContinuousQueryListener(listener); 123 pSearch.startQuery(); 125 return pSearch;
|
/forgerock/opendj2/src/server/org/opends/server/backends/ |
H A D | ChangelogBackend.java | 446 for (PersistentSearch pSearch : cookieBasedPersistentSearches) 448 final SearchOperation searchOp = pSearch.getSearchOperation(); 493 for (PersistentSearch pSearch : changeNumberBasedPersistentSearches) 495 final SearchOperation searchOp = pSearch.getSearchOperation(); 1040 for (PersistentSearch pSearch : getPersistentSearches()) 1042 if (op == pSearch.getSearchOperation()) 1052 public void registerPersistentSearch(PersistentSearch pSearch) throws DirectoryException argument 1054 validatePersistentSearch(pSearch); 1055 initializeEntrySender(pSearch); 1057 if (isCookieBased(pSearch 1068 validatePersistentSearch(final PersistentSearch pSearch) argument 1084 initializeEntrySender(PersistentSearch pSearch) argument [all...] |
/forgerock/opendj2-hg/src/server/org/opends/server/backends/ |
H A D | ChangelogBackend.java | 446 for (PersistentSearch pSearch : cookieBasedPersistentSearches) 448 final SearchOperation searchOp = pSearch.getSearchOperation(); 493 for (PersistentSearch pSearch : changeNumberBasedPersistentSearches) 495 final SearchOperation searchOp = pSearch.getSearchOperation(); 1040 for (PersistentSearch pSearch : getPersistentSearches()) 1042 if (op == pSearch.getSearchOperation()) 1052 public void registerPersistentSearch(PersistentSearch pSearch) throws DirectoryException argument 1054 validatePersistentSearch(pSearch); 1055 initializeEntrySender(pSearch); 1057 if (isCookieBased(pSearch 1068 validatePersistentSearch(final PersistentSearch pSearch) argument 1084 initializeEntrySender(PersistentSearch pSearch) argument [all...] |
/forgerock/opendj-v3/opendj-server-legacy/src/main/java/org/opends/server/backends/ |
H A D | ChangelogBackend.java | 407 for (PersistentSearch pSearch : cookieBasedPersistentSearches) 409 final SearchOperation searchOp = pSearch.getSearchOperation(); 455 for (PersistentSearch pSearch : changeNumberBasedPersistentSearches) 457 final SearchOperation searchOp = pSearch.getSearchOperation(); 872 for (PersistentSearch pSearch : getPersistentSearches()) 874 if (op == pSearch.getSearchOperation()) 883 public void registerPersistentSearch(PersistentSearch pSearch) throws DirectoryException argument 885 initializePersistentSearch(pSearch); 887 if (isCookieBased(pSearch.getSearchOperation())) 889 cookieBasedPersistentSearches.add(pSearch); 898 initializePersistentSearch(PersistentSearch pSearch) argument [all...] |
/forgerock/openam-v13/openam-datastore/src/main/java/org/forgerock/openam/idrepo/ldap/ |
H A D | DJLDAPv3Repo.java | 2079 DJLDAPv3PersistentSearch pSearch = pSearchMap.get(pSearchId); 2082 if (pSearch == null) { 2083 pSearch = new DJLDAPv3PersistentSearch(configMap, createConnectionFactory(username, password, 1)); 2085 pSearch.addMovedOrRenamedListener(this); 2087 pSearch.addListener(idRepoListener, getSupportedTypes()); 2088 pSearch.startSearch(); 2089 pSearchMap.put(pSearchId, pSearch); 2091 pSearch.addListener(idRepoListener, getSupportedTypes()); 2093 pSearch.addMovedOrRenamedListener(this); 2111 DJLDAPv3PersistentSearch pSearch [all...] |
/forgerock/openam/openam-datastore/src/main/java/org/forgerock/openam/idrepo/ldap/ |
H A D | DJLDAPv3Repo.java | 2093 DJLDAPv3PersistentSearch pSearch = pSearchMap.get(pSearchId); 2094 if (pSearch == null) { 2097 pSearch = new DJLDAPv3PersistentSearch(configMap, createConnectionFactory(username, password, 1)); 2099 pSearch.addMovedOrRenamedListener(this); 2101 pSearch.addListener(idRepoListener, getSupportedTypes()); 2103 pSearch.startQuery(); 2107 pSearchMap.put(pSearchId, pSearch); 2109 pSearch.addListener(idRepoListener, getSupportedTypes()); 2111 pSearch.addMovedOrRenamedListener(this); 2135 DJLDAPv3PersistentSearch pSearch [all...] |
Completed in 51 milliseconds