Searched refs:connection (Results 151 - 175 of 652) sorted by relevance

1234567891011>>

/forgerock/openidm-v4/openidm-core/src/test/java/org/forgerock/openidm/sync/impl/
H A DSynchronizationServiceTest.java43 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 DSystemObjectSetServiceTest.java43 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 DRestSTSConsumer.java419 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 DAuthMethodConnectionCriteria.java44 * 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 DAuthMethodConnectionCriteria.java43 * 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 DAuthMethodConnectionCriteria.java44 * 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 DAuthMethodConnectionCriteria.java44 * 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 DAuthMethodConnectionCriteria.java43 * 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 DLdapAdapter.java74 * @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 DLdapSearchHandler.java47 * 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 DJDBCRepoService.java257 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 DGenericTableHandler.java159 //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 DElevatedConnectionFactoryWrapperTest.java53 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 DQueryBuilder.java38 * @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 DCollectClientConnectionsFilter.java83 /** 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 DRouterActivityLoggerTest.java93 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 DMaintenanceServiceTest.java72 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 DElasticsearchAuditEventHandlerFactory.java118 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 DSubentryPasswordPolicyTestCase.java67 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 DPSearchOperations.java51 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 DPSearchOperations.java50 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 DPSearchOperations.java51 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 DPSearchOperations.java51 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 DPSearchOperations.java50 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 DSubentryPasswordPolicyTestCase.java67 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...]

Completed in 79 milliseconds

1234567891011>>