/forgerock/openidm-v4/openidm-core/src/test/java/org/forgerock/openidm/sync/impl/ |
H A D | SynchronizationServiceTest.java | 43 final Connection connection = mock(Connection.class); 50 when(connectionFactory.getConnection()).thenReturn(connection); 51 when(connection.create(any(Context.class), argumentCaptor.capture())) 59 verify(connection).create(any(Context.class), any(CreateRequest.class));
|
/forgerock/openidm-v4/openidm-provisioner/src/test/java/org/forgerock/openidm/provisioner/impl/ |
H A D | SystemObjectSetServiceTest.java | 43 final Connection connection = mock(Connection.class); 51 when(connectionFactory.getConnection()).thenReturn(connection); 52 when(connection.create(any(Context.class), argumentCaptor.capture())) 59 verify(connection).create(any(Context.class), any(CreateRequest.class));
|
/forgerock/openam/openam-samples/sts-example-code/ |
H A D | RestSTSConsumer.java | 419 HttpURLConnection connection = (HttpURLConnection) restSTSInstanceTranslateUrl.openConnection(); 420 connection.setDoOutput(true); 421 connection.setRequestMethod("POST"); 422 connection.setRequestProperty(SharedSTSConstants.CONTENT_TYPE, SharedSTSConstants.APPLICATION_JSON); 426 connection.setRequestProperty(stsClientCertHeaderName, Base64.encode(userCertificate.getEncoded())); 431 OutputStreamWriter writer = new OutputStreamWriter(connection.getOutputStream()); 435 final int responseCode = connection.getResponseCode(); 437 return parseTokenTranslationResponse(getSuccessMessage(connection)); 439 throw new TokenCreationException(responseCode, getErrorMessage(connection)); 446 HttpURLConnection connection 481 getSuccessMessage(HttpURLConnection connection) argument 485 getErrorMessage(HttpURLConnection connection) argument [all...] |
/forgerock/opendj-b2.6/src/server/org/opends/server/core/networkgroups/ |
H A D | AuthMethodConnectionCriteria.java | 44 * A connection criteria which matches connections authenticated using a 57 * Creates a new authentication method connection criteria using the 74 public boolean matches(ClientConnection connection) argument 76 AuthenticationInfo authInfo = connection.getAuthenticationInfo(); 111 public boolean willMatchAfterBind(ClientConnection connection, argument
|
/forgerock/opendj2/src/server/org/opends/server/core/networkgroups/ |
H A D | AuthMethodConnectionCriteria.java | 43 * A connection criteria which matches connections authenticated using a 56 * Creates a new authentication method connection criteria using the 73 public boolean matches(ClientConnection connection) argument 75 AuthenticationInfo authInfo = connection.getAuthenticationInfo(); 110 public boolean willMatchAfterBind(ClientConnection connection, argument
|
/forgerock/opendj2.6.2/src/server/org/opends/server/core/networkgroups/ |
H A D | AuthMethodConnectionCriteria.java | 44 * A connection criteria which matches connections authenticated using a 57 * Creates a new authentication method connection criteria using the 74 public boolean matches(ClientConnection connection) argument 76 AuthenticationInfo authInfo = connection.getAuthenticationInfo(); 111 public boolean willMatchAfterBind(ClientConnection connection, argument
|
/forgerock/opendj2-jel-hg/src/server/org/opends/server/core/networkgroups/ |
H A D | AuthMethodConnectionCriteria.java | 44 * A connection criteria which matches connections authenticated using a 57 * Creates a new authentication method connection criteria using the 74 public boolean matches(ClientConnection connection) argument 76 AuthenticationInfo authInfo = connection.getAuthenticationInfo(); 111 public boolean willMatchAfterBind(ClientConnection connection, argument
|
/forgerock/opendj2-hg/src/server/org/opends/server/core/networkgroups/ |
H A D | AuthMethodConnectionCriteria.java | 43 * A connection criteria which matches connections authenticated using a 56 * Creates a new authentication method connection criteria using the 73 public boolean matches(ClientConnection connection) argument 75 AuthenticationInfo authInfo = connection.getAuthenticationInfo(); 110 public boolean willMatchAfterBind(ClientConnection connection, argument
|
/forgerock/openam-v13/openam-core/src/main/java/org/forgerock/openam/cts/impl/ |
H A D | LdapAdapter.java | 74 * @param connection The non null connection to perform this call against. 79 public void create(Connection connection, Token token) throws LdapOperationFailedException { argument 82 processResult(connection.add(LDAPRequests.newAddRequest(entry))); 89 * Performs a read against the LDAP connection and converts the result into a Token. 91 * @param connection The non null connection to perform this call against. 95 public Token read(Connection connection, String tokenId) throws DataLayerException { argument 98 SearchResultEntry resultEntry = connection.searchSingleEntry(LDAPRequests.newSingleEntrySearchRequest(dn)); 113 * @param connection Th 119 update(Connection connection, Token previous, Token updated) argument 150 delete(Connection connection, String tokenId) argument 165 query(Connection connection, TokenFilter query) argument 176 partialQuery(Connection connection, TokenFilter query) argument [all...] |
/forgerock/openam-v13/openam-core/src/main/java/org/forgerock/openam/sm/datalayer/impl/ldap/ |
H A D | LdapSearchHandler.java | 47 * Perform a search using the provided connection. 51 * @param connection Required for perform the search. 59 public Result performSearch(Connection connection, SearchRequest request, Collection<Entry> entries) throws QueryFailedException { argument 61 return connection.search(request, entries); 69 throw new QueryFailedException(connection, ldapConfig.getTokenStoreRootSuffix(), request.getFilter(), e);
|
/forgerock/openidm-v4/openidm-repo-jdbc/src/main/java/org/forgerock/openidm/repo/jdbc/impl/ |
H A D | JDBCRepoService.java | 257 Connection connection = null; 260 connection = getConnection(); 261 connection.setAutoCommit(true); // Ensure this does not get 268 result = handler.read(request.getResourcePath(), type, localId, connection); 283 CleanupHelper.loggedClose(connection); 313 Connection connection = null; 325 connection = getConnection(); 326 connection.setAutoCommit(false); 328 handler.create(fullId, type, localId, obj.asMap(), connection); 330 connection 804 rollback(Connection connection) argument [all...] |
H A D | GenericTableHandler.java | 159 //DatabaseMetaData metadata = connection.getMetaData(); 215 public ResourceResponse read(String fullId, String type, String localId, Connection connection) argument 223 readStatement = getPreparedStatement(connection, QueryDefinition.READQUERYSTR); 251 public void create(String fullId, String type, String localId, Map<String, Object> obj, Connection connection) argument 254 long typeId = getTypeId(type, connection); // Note this call can commit and start a new transaction in some cases 258 createStatement = queries.getPreparedStatement(connection, queryMap.get(QueryDefinition.CREATEQUERYSTR), true); 284 writeValueProperties(fullId, dbId, localId, jv, connection); 297 * @param connection the DB connection 300 void writeValueProperties(String fullId, long dbId, String localId, JsonValue value, Connection connection) throw argument 337 writeValueProperties(String fullId, long dbId, String localId, JsonValue value, Connection connection, PreparedStatement propCreateStatement, int batchingCount) argument 399 isRetryable(SQLException ex, Connection connection) argument 405 getTypeId(String type, Connection connection) argument 433 readTypeId(String type, Connection connection) argument 465 createTypeId(String type, Connection connection) argument 496 readForUpdate(String fullId, String type, String localId, Connection connection) argument 528 update(String fullId, String type, String localId, String rev, Map<String, Object> obj, Connection connection) argument 600 delete(String fullId, String type, String localId, String rev, Connection connection) argument 651 query(String type, Map<String, Object> params, Connection connection) argument 657 command(String type, Map<String, Object> params, Connection connection) argument 666 getPreparedStatement(Connection connection, QueryDefinition queryDefinition) argument [all...] |
/forgerock/openam-v13/openam-rest/src/test/java/org/forgerock/openam/rest/ |
H A D | ElevatedConnectionFactoryWrapperTest.java | 53 private Connection connection; field in class:ElevatedConnectionFactoryWrapperTest 80 given(internalConnectionFactory.getConnection()).willReturn(connection); 86 try (Connection connection = connectionFactory.getConnection()) { 87 connection.read(context, readRequest); 91 verify(connection).read(contextCaptor.capture(), eq(readRequest));
|
/forgerock/openam-v13/openam-core/src/main/java/org/forgerock/openam/sm/datalayer/api/query/ |
H A D | QueryBuilder.java | 38 * @param <C> The type of connection that will be used. 153 * @param connection The connection used to perform the request. 158 public Iterator<Collection<PartialToken>> executeAttributeQuery(C connection) { argument 159 return executeRawResults(connection, PartialToken.class); 165 * @param connection The connection to query. 170 public abstract <T> Iterator<Collection<T>> executeRawResults(C connection, Class<T> returnType); argument 175 * @param connection The connection use 180 execute(C connection) argument [all...] |
/forgerock/opendj-v3/opendj-server-legacy/src/main/java/org/opends/server/protocols/http/ |
H A D | CollectClientConnectionsFilter.java | 83 /** The connection handler that created this servlet filter. */ 98 * the connection handler that accepted this connection 131 final Connection connection = new SdkConnectionAdapter(clientConnection); 141 .thenAsync(doBindAfterSearch(context, request, next, userName, password, clientConnection, connection), 147 return doFilter(context, request, next, connection); 160 private boolean canProcessRequest(final HTTPClientConnection connection) throws UnknownHostException argument 162 final InetAddress clientAddr = connection.getRemoteAddress(); 164 // Check to see if the core server rejected the connection (e.g. already too many connections established). 165 if (connection 204 doBindAfterSearch( final Context context, final Request request, final Handler next, final String userName, final String password, final HTTPClientConnection clientConnection, final Connection connection) argument 228 doChain( final Context context, final Request request, final Handler next, final String userName, final HTTPClientConnection clientConnection, final Connection connection) argument 251 doFilter( final Context context, final Request request, final Handler next, final Connection connection) argument [all...] |
/forgerock/openidm-v4/openidm-util/src/test/java/org/forgerock/openidm/audit/util/ |
H A D | RouterActivityLoggerTest.java | 93 Connection connection = mock(Connection.class); 94 when(connectionFactory.getConnection()).thenReturn(connection); 95 when(connection.create(any(Context.class), any(CreateRequest.class))).thenReturn( 98 when(connection.action(any(Context.class), any(ActionRequest.class))).thenReturn(actionResponse); 106 verify(connection).create(any(Context.class), createRequestArgumentCaptor.capture()); 140 Connection connection = mock(Connection.class); 141 when(connectionFactory.getConnection()).thenReturn(connection); 142 when(connection.create(any(Context.class), any(CreateRequest.class))).thenReturn( 145 when(connection.action(any(Context.class), any(ActionRequest.class))).thenReturn(actionResponse); 153 verify(connection) [all...] |
/forgerock/openidm-v4/openidm-maintenance/src/test/java/org/forgerock/openidm/maintenance/impl/ |
H A D | MaintenanceServiceTest.java | 72 private Connection connection = null; field in class:MaintenanceServiceTest 105 connection = filterService.getConnection(); 111 assertThat(connection.action(new RootContext(), enableAction).getJsonContent() 113 connection.delete(new RootContext(), Requests.newDeleteRequest("managed/user/0")); 119 assertThat(connection.action(new RootContext(), enableAction).getJsonContent() 123 assertThat(!connection.action(new RootContext(), disableAction).getJsonContent() 125 connection.delete(new RootContext(), Requests.newDeleteRequest("managed/user/0"));
|
/forgerock/openam/openam-audit/openam-audit-configuration/src/main/java/org/forgerock/openam/audit/events/handlers/ |
H A D | ElasticsearchAuditEventHandlerFactory.java | 118 final ConnectionConfiguration connection = new ConnectionConfiguration(); 120 connection.setHost(getMapAttr(attributes, "host")); 121 connection.setPort(getIntMapAttr(attributes, "port", 9200, DEBUG)); 122 connection.setUseSSL(getBooleanMapAttr(attributes, "sslEnabled", false)); 123 connection.setUsername(getMapAttr(attributes, "username")); 124 connection.setPassword(getMapAttr(attributes, "password")); 126 return connection;
|
/forgerock/opendj-b2.6/tests/unit-tests-testng/src/server/org/opends/server/core/ |
H A D | SubentryPasswordPolicyTestCase.java | 67 InternalClientConnection connection = 76 connection.processAdd(suffixEntry.getDN(), 90 connection.processAdd(baseEntry.getDN(), 114 connection.processAdd(testEntry.getDN(), 220 InternalClientConnection connection = 224 connection.processAdd(e.getDN(), 269 InternalClientConnection connection = 273 connection.processAdd(policyEntry.getDN(), 366 InternalClientConnection connection = 370 connection [all...] |
/forgerock/opendj-b2.6/tests/staf-tests/shared/java/ldapjdk/ |
H A D | PSearchOperations.java | 51 private LDAPConnection connection; field in class:PSearchOperations 135 connection = new LDAPConnection(); 136 connection.connect(3, hostname, portnumber, "", ""); 137 connection.authenticate(3, bindDN, bindPW); 139 write("[Thread id: " + threadId + "] \n" + getDate() + connection); 186 LDAPSearchConstraints cons = connection.getSearchConstraints(); 190 res = connection.search(suffix, LDAPv3.SCOPE_SUB, "(objectclass=*)", null, false, cons); 266 while (result.hasMoreElements() && connection.isConnected()) { 278 connection.disconnect(); 304 if (!connection [all...] |
/forgerock/opendj2/tests/staf-tests/shared/java/ldapjdk/ |
H A D | PSearchOperations.java | 50 private LDAPConnection connection; field in class:PSearchOperations 134 connection = new LDAPConnection(); 135 connection.connect(3, hostname, portnumber, "", ""); 136 connection.authenticate(3, bindDN, bindPW); 138 write("[Thread id: " + threadId + "] \n" + getDate() + connection); 185 LDAPSearchConstraints cons = connection.getSearchConstraints(); 189 res = connection.search(suffix, LDAPv3.SCOPE_SUB, "(objectclass=*)", null, false, cons); 265 while (result.hasMoreElements() && connection.isConnected()) { 277 connection.disconnect(); 303 if (!connection [all...] |
/forgerock/opendj2.6.2/tests/staf-tests/shared/java/ldapjdk/ |
H A D | PSearchOperations.java | 51 private LDAPConnection connection; field in class:PSearchOperations 135 connection = new LDAPConnection(); 136 connection.connect(3, hostname, portnumber, "", ""); 137 connection.authenticate(3, bindDN, bindPW); 139 write("[Thread id: " + threadId + "] \n" + getDate() + connection); 186 LDAPSearchConstraints cons = connection.getSearchConstraints(); 190 res = connection.search(suffix, LDAPv3.SCOPE_SUB, "(objectclass=*)", null, false, cons); 266 while (result.hasMoreElements() && connection.isConnected()) { 278 connection.disconnect(); 304 if (!connection [all...] |
/forgerock/opendj2-jel-hg/tests/staf-tests/shared/java/ldapjdk/ |
H A D | PSearchOperations.java | 51 private LDAPConnection connection; field in class:PSearchOperations 135 connection = new LDAPConnection(); 136 connection.connect(3, hostname, portnumber, "", ""); 137 connection.authenticate(3, bindDN, bindPW); 139 write("[Thread id: " + threadId + "] \n" + getDate() + connection); 186 LDAPSearchConstraints cons = connection.getSearchConstraints(); 190 res = connection.search(suffix, LDAPv3.SCOPE_SUB, "(objectclass=*)", null, false, cons); 266 while (result.hasMoreElements() && connection.isConnected()) { 278 connection.disconnect(); 304 if (!connection [all...] |
/forgerock/opendj2-hg/tests/staf-tests/shared/java/ldapjdk/ |
H A D | PSearchOperations.java | 50 private LDAPConnection connection; field in class:PSearchOperations 134 connection = new LDAPConnection(); 135 connection.connect(3, hostname, portnumber, "", ""); 136 connection.authenticate(3, bindDN, bindPW); 138 write("[Thread id: " + threadId + "] \n" + getDate() + connection); 185 LDAPSearchConstraints cons = connection.getSearchConstraints(); 189 res = connection.search(suffix, LDAPv3.SCOPE_SUB, "(objectclass=*)", null, false, cons); 265 while (result.hasMoreElements() && connection.isConnected()) { 277 connection.disconnect(); 303 if (!connection [all...] |
/forgerock/opendj2-jel-hg/tests/unit-tests-testng/src/server/org/opends/server/core/ |
H A D | SubentryPasswordPolicyTestCase.java | 67 InternalClientConnection connection = 76 connection.processAdd(suffixEntry.getDN(), 90 connection.processAdd(baseEntry.getDN(), 114 connection.processAdd(testEntry.getDN(), 220 InternalClientConnection connection = 224 connection.processAdd(e.getDN(), 269 InternalClientConnection connection = 273 connection.processAdd(policyEntry.getDN(), 366 InternalClientConnection connection = 370 connection [all...] |