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 DCTSDJLDAPv3PersistentSearchTest.java33 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 DEventService.java179 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 DEventService.java192 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 DLdapQueryBuilder.java115 ContinuousQuery pSearch = builder
122 pSearch.addContinuousQueryListener(listener);
123 pSearch.startQuery();
125 return pSearch;
/forgerock/opendj2/src/server/org/opends/server/backends/
H A DChangelogBackend.java446 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 DChangelogBackend.java446 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 DChangelogBackend.java407 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 DDJLDAPv3Repo.java2079 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 DDJLDAPv3Repo.java2093 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