Searched defs:connection (Results 101 - 125 of 361) sorted by relevance

1234567891011>>

/forgerock/opendj-v3/opendj-server-legacy/src/main/java/org/opends/server/admin/client/ldap/
H A DLDAPManagementContext.java40 * An LDAP management connection context.
46 * connection.
48 * @param connection
49 * The LDAP connection.
52 public static ManagementContext createFromContext(LDAPConnection connection) { argument
53 Reject.ifNull(connection);
54 return new LDAPManagementContext(connection, LDAPProfile.getInstance());
63 private LDAPManagementContext(LDAPConnection connection, argument
65 this.driver = new LDAPDriver(this, connection, profile);
/forgerock/opendj-v3/opendj-server-legacy/src/main/java/org/opends/server/protocols/http/
H A DHTTPStatsProbe.java34 * written to the HTTP connection. We are using
63 public void onDataSentEvent(Connection connection, Buffer buffer) argument
70 public void onDataReceivedEvent(Connection connection, Buffer buffer) argument
/forgerock/opendj-v3/opendj-dsml-servlet/src/main/java/org/opends/dsml/protocol/
H A DDSMLExtendedOperation.java52 private LDAPConnection connection; field in class:DSMLExtendedOperation
56 * Create an instance with the specified LDAP connection.
58 * @param connection The LDAP connection to send the request on.
62 public DSMLExtendedOperation(LDAPConnection connection, argument
65 this.connection = connection;
120 connection.getLDAPWriter().writeMessage(msg);
123 LDAPMessage responseMessage = connection.getLDAPReader().readMessage();
/forgerock/openidm-v4/openidm-repo-jdbc/src/main/java/org/forgerock/openidm/datasource/jdbc/impl/
H A DBoneCPDatabaseShutdownHook.java34 public boolean onConnectionException(ConnectionHandle connection, String state, Throwable t) { argument
37 return super.onConnectionException(connection, state, t);
43 logger.warn("Failure to acquire connection at {}. Retry attempts remaining : {}",
/forgerock/openidm-v4/openidm-repo-jdbc/src/main/java/org/forgerock/openidm/repo/jdbc/
H A DSQLExceptionHandler.java49 * @param connection where the failure occured, used for additional context
52 boolean isRetryable(SQLException ex, Connection connection); argument
/forgerock/openidm-v4/openidm-repo-jdbc/src/main/java/org/forgerock/openidm/repo/jdbc/impl/
H A DCleanupHelper.java44 * @param connection the connection to try to close if not null.
47 public static void loggedClose(Connection connection) { argument
48 if (connection != null) {
50 connection.close();
52 logger.warn("Failure during connection close ", ex);
H A DDefaultSQLExceptionHandler.java51 public boolean isRetryable(SQLException ex, Connection connection) { argument
/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-rest/src/test/java/org/forgerock/openam/rest/
H A DElevatedConnectionFactoryWrapperTest.java57 private Connection connection; field in class:ElevatedConnectionFactoryWrapperTest
88 given(internalConnectionFactory.getConnection()).willReturn(connection);
101 try (Connection connection = connectionFactory.getConnection()) {
102 connection.read(context, readRequest);
106 verify(connection).read(contextCaptor.capture(), eq(readRequest));
/forgerock/openam/openam-core/src/main/java/org/forgerock/openam/cts/exceptions/
H A DQueryFailedException.java32 * @param connection Connection used to make the query.
37 public QueryFailedException(Connection connection, DN dn, Filter filter, Throwable cause) { argument
44 connection,
/forgerock/openam/openam-core/src/main/java/org/forgerock/openam/sm/datalayer/api/
H A DConnectionFactory.java30 * Creates a connection asynchronously. The returned promise can be used to obtain and act on the eventually
32 * @return A promise that will be resolved with a connection.
37 * Create a connection synchronously.
38 * @return The created connection.
48 * Checks if a (possibly null) connection is valid for use.
50 boolean isValid(T connection); argument
/forgerock/openam/openam-core/src/main/java/org/forgerock/openam/sm/datalayer/impl/ldap/
H A DLdapSearchHandler.java48 * Perform a search using the provided connection.
52 * @param connection Required for perform the search.
60 public Result performSearch(Connection connection, SearchRequest request, Collection<Entry> entries) throws QueryFailedException { argument
62 return connection.search(request, entries);
70 throw new QueryFailedException(connection, ldapConfig.getTokenStoreRootSuffix(), request.getFilter(), e);
/forgerock/opendj-b2.6/src/server/org/opends/server/core/networkgroups/
H A DResourceLimitsPolicy.java57 * Adds a connection to the network group.
59 * @param connection
60 * The client connection.
62 abstract void addConnection(ClientConnection connection); argument
110 * @param connection
120 * @return a boolean indicating whether the connection is allowed
122 abstract boolean isAllowed(ClientConnection connection, argument
129 * Removes a connection from the network group.
131 * @param connection
132 * The client connection t
134 removeConnection(ClientConnection connection) argument
[all...]
/forgerock/opendj-b2.6/src/server/org/opends/server/tools/
H A DLDAPModify.java132 * @param connection The connection to use for this modify request.
142 public void readAndExecute(LDAPConnection connection, String fileNameValue, argument
339 connection.getLDAPWriter().writeMessage(message);
340 responseMessage = connection.getLDAPReader().readMessage();
626 LDAPConnection connection = null;
1157 // Set the connection options.
1235 connection = new LDAPConnection(hostNameValue, portNumber,
1238 connection.connectToHost(bindDNValue, bindPasswordValue, nextMessageID,
1242 ldapModify.readAndExecute(connection, fileNameValu
[all...]
/forgerock/opendj2/src/server/org/opends/server/core/networkgroups/
H A DResourceLimitsPolicy.java56 * Adds a connection to the network group.
58 * @param connection
59 * The client connection.
61 abstract void addConnection(ClientConnection connection); argument
109 * @param connection
119 * @return a boolean indicating whether the connection is allowed
121 abstract boolean isAllowed(ClientConnection connection, argument
128 * Removes a connection from the network group.
130 * @param connection
131 * The client connection t
133 removeConnection(ClientConnection connection) argument
[all...]
/forgerock/opendj2/src/server/org/opends/server/tools/
H A DLDAPModify.java131 * @param connection The connection to use for this modify request.
141 public void readAndExecute(LDAPConnection connection, String fileNameValue, argument
338 connection.getLDAPWriter().writeMessage(message);
339 responseMessage = connection.getLDAPReader().readMessage();
607 LDAPConnection connection = null;
1138 // Set the connection options.
1216 connection = new LDAPConnection(hostNameValue, portNumber,
1219 connection.connectToHost(bindDNValue, bindPasswordValue, nextMessageID,
1223 ldapModify.readAndExecute(connection, fileNameValu
[all...]
/forgerock/opendj2.6.2/src/server/org/opends/server/core/networkgroups/
H A DResourceLimitsPolicy.java57 * Adds a connection to the network group.
59 * @param connection
60 * The client connection.
62 abstract void addConnection(ClientConnection connection); argument
110 * @param connection
120 * @return a boolean indicating whether the connection is allowed
122 abstract boolean isAllowed(ClientConnection connection, argument
129 * Removes a connection from the network group.
131 * @param connection
132 * The client connection t
134 removeConnection(ClientConnection connection) argument
[all...]
/forgerock/opendj2.6.2/src/server/org/opends/server/tools/
H A DLDAPModify.java132 * @param connection The connection to use for this modify request.
142 public void readAndExecute(LDAPConnection connection, String fileNameValue, argument
339 connection.getLDAPWriter().writeMessage(message);
340 responseMessage = connection.getLDAPReader().readMessage();
626 LDAPConnection connection = null;
1157 // Set the connection options.
1235 connection = new LDAPConnection(hostNameValue, portNumber,
1238 connection.connectToHost(bindDNValue, bindPasswordValue, nextMessageID,
1242 ldapModify.readAndExecute(connection, fileNameValu
[all...]
/forgerock/opendj2-jel-hg/src/server/org/opends/server/core/networkgroups/
H A DResourceLimitsPolicy.java57 * Adds a connection to the network group.
59 * @param connection
60 * The client connection.
62 abstract void addConnection(ClientConnection connection); argument
110 * @param connection
120 * @return a boolean indicating whether the connection is allowed
122 abstract boolean isAllowed(ClientConnection connection, argument
129 * Removes a connection from the network group.
131 * @param connection
132 * The client connection t
134 removeConnection(ClientConnection connection) argument
[all...]
/forgerock/opendj2-jel-hg/src/server/org/opends/server/tools/
H A DLDAPModify.java132 * @param connection The connection to use for this modify request.
142 public void readAndExecute(LDAPConnection connection, String fileNameValue, argument
339 connection.getLDAPWriter().writeMessage(message);
340 responseMessage = connection.getLDAPReader().readMessage();
626 LDAPConnection connection = null;
1157 // Set the connection options.
1235 connection = new LDAPConnection(hostNameValue, portNumber,
1238 connection.connectToHost(bindDNValue, bindPasswordValue, nextMessageID,
1242 ldapModify.readAndExecute(connection, fileNameValu
[all...]
/forgerock/opendj2-hg/src/server/org/opends/server/core/networkgroups/
H A DResourceLimitsPolicy.java56 * Adds a connection to the network group.
58 * @param connection
59 * The client connection.
61 abstract void addConnection(ClientConnection connection); argument
109 * @param connection
119 * @return a boolean indicating whether the connection is allowed
121 abstract boolean isAllowed(ClientConnection connection, argument
128 * Removes a connection from the network group.
130 * @param connection
131 * The client connection t
133 removeConnection(ClientConnection connection) argument
[all...]
/forgerock/opendj2-hg/src/server/org/opends/server/tools/
H A DLDAPModify.java131 * @param connection The connection to use for this modify request.
141 public void readAndExecute(LDAPConnection connection, String fileNameValue, argument
338 connection.getLDAPWriter().writeMessage(message);
339 responseMessage = connection.getLDAPReader().readMessage();
607 LDAPConnection connection = null;
1138 // Set the connection options.
1216 connection = new LDAPConnection(hostNameValue, portNumber,
1219 connection.connectToHost(bindDNValue, bindPasswordValue, nextMessageID,
1223 ldapModify.readAndExecute(connection, fileNameValu
[all...]
/forgerock/openam-v13/openam-core/src/main/java/org/forgerock/openam/cts/impl/query/reaper/
H A DReaperConnection.java33 * of the connection that will be used for the paged query against the LDAP server.
38 * and close the established connection.
43 private C connection; field in class:ReaperConnection
47 * @param factory Required for establishing a connection to the persistence layer.
57 * If this first call, then establishes a connection to the persistence layer and
59 * the connection will be closed automatically.
91 * If this is the first call, then initialise the connection.
93 * @throws org.forgerock.openam.sm.datalayer.api.LdapOperationFailedException If there was an error getting the connection.
96 if (connection == null) {
98 connection
[all...]
/forgerock/openam-v13/openam-core/src/main/java/org/forgerock/openam/cts/monitoring/impl/connections/
H A DMonitoredCTSConnectionFactory.java28 * of connection attempts requested through this factory. The tracked values are
49 * The connection factory registers as a config listener in case these settings change.
52 * @param monitorStore The data structure in which to count connection success/failures
61 * Provides a connection to the applicable token store, whether embedded or external.
65 * @return a connection to the token store.
66 * @throws DataLayerException unable to provide a connection.
92 public boolean isValid(C connection) { argument
93 return connectionFactory.isValid(connection);
/forgerock/openam-v13/openam-core/src/main/java/org/forgerock/openam/sm/datalayer/api/
H A DTokenStorageAdapter.java26 * Adapts the token to some activity against the connection type, T.
27 * @param <T> The type of connection that token activity will be recorded using.
34 * @param connection The non null connection to perform this call against.
38 void create(T connection, Token token) throws DataLayerException; argument
41 * Performs a read against the database connection and converts the result into a Token.
43 * @param connection The non null connection to perform this call against.
47 Token read(T connection, String tokenId) throws DataLayerException; argument
52 * @param connection Th
58 update(T connection, Token previous, Token updated) argument
67 delete(T connection, String tokenId) argument
76 query(T connection, TokenFilter query) argument
85 partialQuery(T connection, TokenFilter query) argument
[all...]

Completed in 126 milliseconds

1234567891011>>