/forgerock/opendj-v3/opendj-server-legacy/src/main/java/org/opends/server/admin/client/ldap/ |
H A D | LDAPManagementContext.java | 40 * 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 D | HTTPStatsProbe.java | 34 * 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 D | DSMLExtendedOperation.java | 52 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 D | BoneCPDatabaseShutdownHook.java | 34 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 D | SQLExceptionHandler.java | 49 * @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 D | CleanupHelper.java | 44 * @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 D | DefaultSQLExceptionHandler.java | 51 public boolean isRetryable(SQLException ex, Connection connection) { argument
|
/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-rest/src/test/java/org/forgerock/openam/rest/ |
H A D | ElevatedConnectionFactoryWrapperTest.java | 57 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 D | QueryFailedException.java | 32 * @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 D | ConnectionFactory.java | 30 * 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 D | LdapSearchHandler.java | 48 * 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 D | ResourceLimitsPolicy.java | 57 * 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 D | LDAPModify.java | 132 * @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 D | ResourceLimitsPolicy.java | 56 * 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 D | LDAPModify.java | 131 * @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 D | ResourceLimitsPolicy.java | 57 * 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 D | LDAPModify.java | 132 * @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 D | ResourceLimitsPolicy.java | 57 * 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 D | LDAPModify.java | 132 * @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 D | ResourceLimitsPolicy.java | 56 * 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 D | LDAPModify.java | 131 * @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 D | ReaperConnection.java | 33 * 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 D | MonitoredCTSConnectionFactory.java | 28 * 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 D | TokenStorageAdapter.java | 26 * 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...] |