/forgerock/opendj-b2.6/src/server/org/opends/server/core/ |
H A D | RootDseWorkflowTopology.java | 97 * @param searchOp the operation to execute 102 private void executeSearch(SearchOperation searchOp) argument 106 SearchScope originalScope = searchOp.getScope(); 113 getWorkflowImpl().execute(searchOp); 120 searchOp.getResultCode(), searchOp.getErrorMessage()); 125 searchOp.setScope(newScope); 126 DN originalBaseDN = searchOp.getBaseDN(); 142 searchOp.setBaseDN(ncDN); 143 namingContext.execute(searchOp); [all...] |
H A D | WorkflowTopologyNode.java | 114 * @param searchOp the search operation to execute 119 private void executeSearchOnSubordinates(SearchOperation searchOp) argument 123 SearchScope originalScope = searchOp.getScope(); 132 searchOp.setScope(newScope); 136 searchOp.getResultCode(), searchOp.getErrorMessage()); 137 DN originalBaseDN = searchOp.getBaseDN(); 163 searchOp.setBaseDN(subordinateDN); 164 subordinate.execute(searchOp); 167 searchOp [all...] |
/forgerock/opendj2/src/server/org/opends/server/core/ |
H A D | RootDseWorkflowTopology.java | 96 * @param searchOp the operation to execute 101 private void executeSearch(SearchOperation searchOp) argument 105 SearchScope originalScope = searchOp.getScope(); 112 getWorkflowImpl().execute(searchOp); 119 searchOp.getResultCode(), searchOp.getErrorMessage()); 124 searchOp.setScope(newScope); 125 DN originalBaseDN = searchOp.getBaseDN(); 141 searchOp.setBaseDN(ncDN); 142 namingContext.execute(searchOp); [all...] |
H A D | WorkflowTopologyNode.java | 113 * @param searchOp the search operation to execute 118 private void executeSearchOnSubordinates(SearchOperation searchOp) argument 122 SearchScope originalScope = searchOp.getScope(); 131 searchOp.setScope(newScope); 135 searchOp.getResultCode(), searchOp.getErrorMessage()); 136 DN originalBaseDN = searchOp.getBaseDN(); 162 searchOp.setBaseDN(subordinateDN); 163 subordinate.execute(searchOp); 166 searchOp [all...] |
/forgerock/opendj2.6.2/src/server/org/opends/server/core/ |
H A D | RootDseWorkflowTopology.java | 97 * @param searchOp the operation to execute 102 private void executeSearch(SearchOperation searchOp) argument 106 SearchScope originalScope = searchOp.getScope(); 113 getWorkflowImpl().execute(searchOp); 120 searchOp.getResultCode(), searchOp.getErrorMessage()); 125 searchOp.setScope(newScope); 126 DN originalBaseDN = searchOp.getBaseDN(); 142 searchOp.setBaseDN(ncDN); 143 namingContext.execute(searchOp); [all...] |
H A D | WorkflowTopologyNode.java | 114 * @param searchOp the search operation to execute 119 private void executeSearchOnSubordinates(SearchOperation searchOp) argument 123 SearchScope originalScope = searchOp.getScope(); 132 searchOp.setScope(newScope); 136 searchOp.getResultCode(), searchOp.getErrorMessage()); 137 DN originalBaseDN = searchOp.getBaseDN(); 163 searchOp.setBaseDN(subordinateDN); 164 subordinate.execute(searchOp); 167 searchOp [all...] |
/forgerock/opendj2-jel-hg/src/server/org/opends/server/core/ |
H A D | RootDseWorkflowTopology.java | 97 * @param searchOp the operation to execute 102 private void executeSearch(SearchOperation searchOp) argument 106 SearchScope originalScope = searchOp.getScope(); 113 getWorkflowImpl().execute(searchOp); 120 searchOp.getResultCode(), searchOp.getErrorMessage()); 125 searchOp.setScope(newScope); 126 DN originalBaseDN = searchOp.getBaseDN(); 142 searchOp.setBaseDN(ncDN); 143 namingContext.execute(searchOp); [all...] |
H A D | WorkflowTopologyNode.java | 114 * @param searchOp the search operation to execute 119 private void executeSearchOnSubordinates(SearchOperation searchOp) argument 123 SearchScope originalScope = searchOp.getScope(); 132 searchOp.setScope(newScope); 136 searchOp.getResultCode(), searchOp.getErrorMessage()); 137 DN originalBaseDN = searchOp.getBaseDN(); 163 searchOp.setBaseDN(subordinateDN); 164 subordinate.execute(searchOp); 167 searchOp [all...] |
/forgerock/opendj2-hg/src/server/org/opends/server/core/ |
H A D | RootDseWorkflowTopology.java | 96 * @param searchOp the operation to execute 101 private void executeSearch(SearchOperation searchOp) argument 105 SearchScope originalScope = searchOp.getScope(); 112 getWorkflowImpl().execute(searchOp); 119 searchOp.getResultCode(), searchOp.getErrorMessage()); 124 searchOp.setScope(newScope); 125 DN originalBaseDN = searchOp.getBaseDN(); 141 searchOp.setBaseDN(ncDN); 142 namingContext.execute(searchOp); [all...] |
H A D | WorkflowTopologyNode.java | 113 * @param searchOp the search operation to execute 118 private void executeSearchOnSubordinates(SearchOperation searchOp) argument 122 SearchScope originalScope = searchOp.getScope(); 131 searchOp.setScope(newScope); 135 searchOp.getResultCode(), searchOp.getErrorMessage()); 136 DN originalBaseDN = searchOp.getBaseDN(); 162 searchOp.setBaseDN(subordinateDN); 163 subordinate.execute(searchOp); 166 searchOp [all...] |
/forgerock/opendj-v3/opendj-server-legacy/src/main/java/org/opends/server/workflowelement/localbackend/ |
H A D | LocalBackendWorkflowElement.java | 941 * @param searchOp 948 private static void executeSearch(SearchOperation searchOp, LocalBackendWorkflowElement workflow) argument 952 SearchScope originalScope = searchOp.getScope(); 959 workflow.execute(searchOp); 966 new SearchResultCode(searchOp.getResultCode(), searchOp.getErrorMessage()); 971 searchOp.setScope(newScope); 972 DN originalBaseDN = searchOp.getBaseDN(); 984 searchOp.setBaseDN(ncDN); 985 execute(searchOp, ncD 1043 executeSearchOnSubordinates(SearchOperation searchOp, LocalBackendWorkflowElement workflow) argument [all...] |
/forgerock/opendj-b2.6/tests/unit-tests-testng/src/server/org/opends/server/protocols/ldap/ |
H A D | TestSearchProtocolOp.java | 110 SearchRequestProtocolOp searchOp = 114 assertTrue(protocolOp.getBaseDN().equals(searchOp.getBaseDN())); 115 assertTrue(protocolOp.getScope().equals(searchOp.getScope())); 117 equals(searchOp.getDereferencePolicy())); 118 assertTrue(protocolOp.getSizeLimit() == searchOp.getSizeLimit()); 119 assertTrue(protocolOp.getTimeLimit() == searchOp.getTimeLimit()); 121 searchOp.getFilter().toString())); 125 searchOp.getAttributes().toArray())); 173 SearchRequestProtocolOp searchOp = 177 assertTrue(baseDN.equals(searchOp [all...] |
/forgerock/opendj2/tests/unit-tests-testng/src/server/org/opends/server/protocols/ldap/ |
H A D | TestSearchProtocolOp.java | 109 SearchRequestProtocolOp searchOp = 113 assertTrue(protocolOp.getBaseDN().equals(searchOp.getBaseDN())); 114 assertTrue(protocolOp.getScope().equals(searchOp.getScope())); 116 equals(searchOp.getDereferencePolicy())); 117 assertTrue(protocolOp.getSizeLimit() == searchOp.getSizeLimit()); 118 assertTrue(protocolOp.getTimeLimit() == searchOp.getTimeLimit()); 120 searchOp.getFilter().toString())); 124 searchOp.getAttributes().toArray())); 172 SearchRequestProtocolOp searchOp = 176 assertTrue(baseDN.equals(searchOp [all...] |
/forgerock/opendj2.6.2/tests/unit-tests-testng/src/server/org/opends/server/protocols/ldap/ |
H A D | TestSearchProtocolOp.java | 110 SearchRequestProtocolOp searchOp = 114 assertTrue(protocolOp.getBaseDN().equals(searchOp.getBaseDN())); 115 assertTrue(protocolOp.getScope().equals(searchOp.getScope())); 117 equals(searchOp.getDereferencePolicy())); 118 assertTrue(protocolOp.getSizeLimit() == searchOp.getSizeLimit()); 119 assertTrue(protocolOp.getTimeLimit() == searchOp.getTimeLimit()); 121 searchOp.getFilter().toString())); 125 searchOp.getAttributes().toArray())); 173 SearchRequestProtocolOp searchOp = 177 assertTrue(baseDN.equals(searchOp [all...] |
/forgerock/opendj2-hg/tests/unit-tests-testng/src/server/org/opends/server/protocols/ldap/ |
H A D | TestSearchProtocolOp.java | 109 SearchRequestProtocolOp searchOp = 113 assertTrue(protocolOp.getBaseDN().equals(searchOp.getBaseDN())); 114 assertTrue(protocolOp.getScope().equals(searchOp.getScope())); 116 equals(searchOp.getDereferencePolicy())); 117 assertTrue(protocolOp.getSizeLimit() == searchOp.getSizeLimit()); 118 assertTrue(protocolOp.getTimeLimit() == searchOp.getTimeLimit()); 120 searchOp.getFilter().toString())); 124 searchOp.getAttributes().toArray())); 172 SearchRequestProtocolOp searchOp = 176 assertTrue(baseDN.equals(searchOp [all...] |
/forgerock/opendj2-jel-hg/tests/unit-tests-testng/src/server/org/opends/server/protocols/ldap/ |
H A D | TestSearchProtocolOp.java | 110 SearchRequestProtocolOp searchOp = 114 assertTrue(protocolOp.getBaseDN().equals(searchOp.getBaseDN())); 115 assertTrue(protocolOp.getScope().equals(searchOp.getScope())); 117 equals(searchOp.getDereferencePolicy())); 118 assertTrue(protocolOp.getSizeLimit() == searchOp.getSizeLimit()); 119 assertTrue(protocolOp.getTimeLimit() == searchOp.getTimeLimit()); 121 searchOp.getFilter().toString())); 125 searchOp.getAttributes().toArray())); 173 SearchRequestProtocolOp searchOp = 177 assertTrue(baseDN.equals(searchOp [all...] |
/forgerock/opendj-v3/opendj-server-legacy/src/test/java/org/opends/server/backends/ |
H A D | ChangelogBackendTestCase.java | 274 InternalSearchOperation searchOp = 277 final List<SearchResultEntry> searchEntries = searchOp.getSearchEntries(); 282 assertResultsContainCookieControl(searchOp, newArrayList(buildCookiesFromCsns(csns))); 294 InternalSearchOperation searchOp = null; 301 searchOp = searchChangelogUsingCookie("(targetdn=*" + test + "*,o=test)", cookies[0], SUCCESS, nbEntries, test); 303 List<SearchResultEntry> searchEntries = searchOp.getSearchEntries(); 310 searchOp = searchChangelogUsingCookie("(targetdn=*" + test + "*,o=test)", cookies[1], SUCCESS, nbEntries, test); 314 searchOp = searchChangelogUsingCookie("(targetdn=*" + test + "*,o=test)", cookies[2], SUCCESS, nbEntries, test); 316 searchEntries = searchOp.getSearchEntries(); 321 searchOp 1265 assertContainsNoControl(InternalSearchOperation searchOp) argument 1276 assertResultsContainCookieControl(InternalSearchOperation searchOp, List<String> cookies) argument [all...] |
/forgerock/opendj2/tests/unit-tests-testng/src/server/org/opends/server/backends/ |
H A D | ChangelogBackendTestCase.java | 261 InternalSearchOperation searchOp = 264 final List<SearchResultEntry> searchEntries = searchOp.getSearchEntries(); 270 assertResultsContainCookieControl(searchOp, cookies); 282 InternalSearchOperation searchOp = null; 289 searchOp = searchChangelogUsingCookie("(targetdn=*" + test + "*,o=test)", cookies[0], nbEntries, SUCCESS, test); 291 List<SearchResultEntry> searchEntries = searchOp.getSearchEntries(); 299 searchOp = searchChangelogUsingCookie("(targetdn=*" + test + "*,o=test)", cookies[1], nbEntries, SUCCESS, test); 303 searchOp = searchChangelogUsingCookie("(targetdn=*" + test + "*,o=test)", cookies[2], nbEntries, SUCCESS, test); 305 searchEntries = searchOp.getSearchEntries(); 311 searchOp 1247 assertContainsNoControl(InternalSearchOperation searchOp) argument 1257 assertResultsContainCookieControl(InternalSearchOperation searchOp, String[] cookies) argument [all...] |
/forgerock/opendj2-hg/tests/unit-tests-testng/src/server/org/opends/server/backends/ |
H A D | ChangelogBackendTestCase.java | 261 InternalSearchOperation searchOp = 264 final List<SearchResultEntry> searchEntries = searchOp.getSearchEntries(); 270 assertResultsContainCookieControl(searchOp, cookies); 282 InternalSearchOperation searchOp = null; 289 searchOp = searchChangelogUsingCookie("(targetdn=*" + test + "*,o=test)", cookies[0], nbEntries, SUCCESS, test); 291 List<SearchResultEntry> searchEntries = searchOp.getSearchEntries(); 299 searchOp = searchChangelogUsingCookie("(targetdn=*" + test + "*,o=test)", cookies[1], nbEntries, SUCCESS, test); 303 searchOp = searchChangelogUsingCookie("(targetdn=*" + test + "*,o=test)", cookies[2], nbEntries, SUCCESS, test); 305 searchEntries = searchOp.getSearchEntries(); 311 searchOp 1247 assertContainsNoControl(InternalSearchOperation searchOp) argument 1257 assertResultsContainCookieControl(InternalSearchOperation searchOp, String[] cookies) argument [all...] |
/forgerock/opendj-v3/opendj-server-legacy/src/main/java/org/opends/server/backends/ |
H A D | ChangelogBackend.java | 409 final SearchOperation searchOp = pSearch.getSearchOperation(); 410 final CookieEntrySender entrySender = searchOp.getAttachment(ENTRY_SENDER_ATTACHMENT); 457 final SearchOperation searchOp = pSearch.getSearchOperation(); 458 final ChangeNumberEntrySender entrySender = searchOp.getAttachment(ENTRY_SENDER_ATTACHMENT); 468 private boolean isCookieBased(final SearchOperation searchOp) argument 470 for (Control c : searchOp.getRequestControls()) 824 if (!sendBaseChangelogEntry(entrySender.searchOp)) 900 final SearchOperation searchOp = pSearch.getSearchOperation(); 907 checkChangelogReadPrivilege(searchOp); 909 final ChangeNumberRange range = optimizeSearch(searchOp 926 getCookie(boolean isChangesOnly, SearchOperation searchOp, Set<DN> excludedBaseDNs) argument 938 getNewestCookie(SearchOperation searchOp) argument 1302 checkChangelogReadPrivilege(SearchOperation searchOp) argument 1403 sendEntryIfMatches(SearchOperation searchOp, Entry entry, String cookie) argument 1415 matchBaseAndScopeAndFilter(SearchOperation searchOp, Entry entry) argument 1438 sendBaseChangelogEntry(SearchOperation searchOp) argument 1616 private final SearchOperation searchOp; field in class:ChangelogBackend.ChangeNumberEntrySender 1621 ChangeNumberEntrySender(SearchOperation searchOp, SearchPhase startPhase, ChangeNumberRange range) argument 1676 private final SearchOperation searchOp; field in class:ChangelogBackend.CookieEntrySender 1683 CookieEntrySender(SearchOperation searchOp, SearchPhase startPhase, MultiDomainServerState cookie, Set<DN> excludedBaseDNs) argument [all...] |
/forgerock/opendj-b2.6/tests/unit-tests-testng/src/server/org/opends/server/replication/ |
H A D | ExternalChangeLogTest.java | 813 InternalSearchOperation searchOp = connection.processSearch( 826 waitOpResult(searchOp, ResultCode.SUCCESS); 828 LinkedList<SearchResultEntry> entries = searchOp.getSearchEntries(); 855 searchOp = connection.processSearch( 868 waitOpResult(searchOp, ResultCode.SUCCESS); 870 entries = searchOp.getSearchEntries(); 990 InternalSearchOperation searchOp = 1003 waitOpResult(searchOp, ResultCode.SUCCESS); 1006 LinkedList<SearchResultEntry> entries = searchOp.getSearchEntries(); 1023 assertEquals(searchOp [all...] |
/forgerock/opendj2.6.2/tests/unit-tests-testng/src/server/org/opends/server/replication/ |
H A D | ExternalChangeLogTest.java | 813 InternalSearchOperation searchOp = connection.processSearch( 826 waitOpResult(searchOp, ResultCode.SUCCESS); 828 LinkedList<SearchResultEntry> entries = searchOp.getSearchEntries(); 855 searchOp = connection.processSearch( 868 waitOpResult(searchOp, ResultCode.SUCCESS); 870 entries = searchOp.getSearchEntries(); 990 InternalSearchOperation searchOp = 1003 waitOpResult(searchOp, ResultCode.SUCCESS); 1006 LinkedList<SearchResultEntry> entries = searchOp.getSearchEntries(); 1023 assertEquals(searchOp [all...] |
/forgerock/opendj2-jel-hg/tests/unit-tests-testng/src/server/org/opends/server/replication/ |
H A D | ExternalChangeLogTest.java | 813 InternalSearchOperation searchOp = connection.processSearch( 826 waitOpResult(searchOp, ResultCode.SUCCESS); 828 LinkedList<SearchResultEntry> entries = searchOp.getSearchEntries(); 855 searchOp = connection.processSearch( 868 waitOpResult(searchOp, ResultCode.SUCCESS); 870 entries = searchOp.getSearchEntries(); 990 InternalSearchOperation searchOp = 1003 waitOpResult(searchOp, ResultCode.SUCCESS); 1006 LinkedList<SearchResultEntry> entries = searchOp.getSearchEntries(); 1023 assertEquals(searchOp [all...] |
/forgerock/opendj-v3/opendj-server-legacy/src/test/java/org/opends/server/protocols/ldap/ |
H A D | TestSearchProtocolOp.java | 107 SearchRequestProtocolOp searchOp = 111 assertEquals(protocolOp.getBaseDN(), searchOp.getBaseDN()); 112 assertEquals(protocolOp.getScope(), searchOp.getScope()); 113 assertEquals(protocolOp.getDereferencePolicy(), searchOp.getDereferencePolicy()); 114 assertEquals(protocolOp.getSizeLimit(), searchOp.getSizeLimit()); 115 assertEquals(protocolOp.getTimeLimit(), searchOp.getTimeLimit()); 116 assertEquals(protocolOp.getFilter().toString(), searchOp.getFilter().toString()); 120 searchOp.getAttributes().toArray())); 168 SearchRequestProtocolOp searchOp = 172 assertEquals(baseDN, searchOp [all...] |
/forgerock/opendj2/src/server/org/opends/server/backends/ |
H A D | ChangelogBackend.java | 448 final SearchOperation searchOp = pSearch.getSearchOperation(); 449 final CookieEntrySender entrySender = searchOp.getAttachment(ENTRY_SENDER_ATTACHMENT); 495 final SearchOperation searchOp = pSearch.getSearchOperation(); 496 final ChangeNumberEntrySender entrySender = searchOp.getAttachment(ENTRY_SENDER_ATTACHMENT); 506 private boolean isCookieBased(final SearchOperation searchOp) argument 508 for (Control c : searchOp.getRequestControls()) 1088 final SearchOperation searchOp = pSearch.getSearchOperation(); 1089 if (isCookieBased(searchOp)) 1091 final CookieEntrySender entrySender = new CookieEntrySender(searchOp, startPhase); 1092 searchOp 1106 getNewestCookie(SearchOperation searchOp) argument 1449 checkChangelogReadPrivilege(SearchOperation searchOp) argument 1550 sendEntryIfMatches(SearchOperation searchOp, Entry entry, String cookie) argument 1562 matchBaseAndScopeAndFilter(SearchOperation searchOp, Entry entry) argument 1583 sendBaseChangelogEntry(SearchOperation searchOp) argument 1767 private final SearchOperation searchOp; field in class:ChangelogBackend.ChangeNumberEntrySender 1770 ChangeNumberEntrySender(SearchOperation searchOp, SearchPhase startPhase) argument 1809 private final SearchOperation searchOp; field in class:ChangelogBackend.CookieEntrySender 1815 CookieEntrySender(SearchOperation searchOp, SearchPhase startPhase) argument [all...] |