Searched refs:Connection (Results 1 - 25 of 255) sorted by relevance

1234567891011

/forgerock/openam-v13/openam-core/src/main/java/com/sun/identity/sm/ldap/
H A DCTSDataLayer.java25 import org.forgerock.opendj.ldap.Connection;
63 * Obtain a Connection from the Shared Pool
67 public Connection getConnection() {
72 * Release an obtained Connection back to the pool.
76 public void releaseConnection(Connection ldapConnection) {
81 * Release an obtained Connection back to the pool, with a
87 public void releaseConnection(Connection ldapConnection, int ldapErrorCode ) {
92 * Release an obtained Connection back to the pool, with a
99 public void releaseConnection(Connection ldapConnection, Exception lastLDAPException ) {
/forgerock/openam/openam-core/src/main/java/com/sun/identity/sm/ldap/
H A DCTSDataLayer.java25 import org.forgerock.opendj.ldap.Connection;
63 * Obtain a Connection from the Shared Pool
67 public Connection getConnection() {
72 * Release an obtained Connection back to the pool.
76 public void releaseConnection(Connection ldapConnection) {
81 * Release an obtained Connection back to the pool, with a
87 public void releaseConnection(Connection ldapConnection, int ldapErrorCode ) {
92 * Release an obtained Connection back to the pool, with a
99 public void releaseConnection(Connection ldapConnection, Exception lastLDAPException ) {
/forgerock/openidm-v4/openidm-router/src/main/java/org/forgerock/openidm/router/
H A DIDMConnectionFactory.java19 import org.forgerock.json.resource.Connection;
25 * An ConnectionFactory extension that also permits obtaining an "external" Connection
37 Connection getExternalConnection() throws ResourceException;
46 Promise<Connection, ResourceException> getExternalConnectionAsync();
/forgerock/openidm-v4/openidm-repo-jdbc/src/main/java/org/forgerock/openidm/repo/jdbc/
H A DSQLExceptionHandler.java26 import java.sql.Connection;
52 boolean isRetryable(SQLException ex, Connection connection);
H A DTableHandler.java27 import java.sql.Connection;
63 String localId, Connection connection)
85 Map<String, Object> obj, Connection connection)
113 String rev, Map<String, Object> obj, Connection connection)
133 String rev, Connection connection)
157 public List<Map<String, Object>> query(String type, Map<String, Object> params, Connection connection)
177 public Integer command(String type, Map<String, Object> params, Connection connection)
216 public boolean isRetryable(SQLException ex, Connection connection);
/forgerock/openidm-v4/openidm-repo-jdbc/src/main/java/org/forgerock/openidm/repo/jdbc/impl/
H A DDB2SQLExceptionHandler.java26 import java.sql.Connection;
39 public boolean isRetryable(SQLException ex, Connection connection) {
H A DDefaultSQLExceptionHandler.java26 import java.sql.Connection;
51 public boolean isRetryable(SQLException ex, Connection connection) {
/forgerock/openidm-v4/openidm-router/src/test/java/org/forgerock/openidm/router/
H A DIDMConnectionFactoryWrapper.java18 import org.forgerock.json.resource.Connection;
34 public Connection getExternalConnection() throws ResourceException {
39 public Promise<Connection, ResourceException> getExternalConnectionAsync() {
49 public Connection getConnection() throws ResourceException {
54 public Promise<Connection, ResourceException> getConnectionAsync() {
/forgerock/opendj-b2.6/src/server/org/opends/server/protocols/http/
H A DHTTPStatsProbe.java30 import org.glassfish.grizzly.Connection;
36 * {@link #onDataReceivedEvent(Connection, Buffer)} and
37 * {@link #onDataSentEvent(Connection, Buffer)} because they are the only ones
64 public void onDataSentEvent(Connection connection, Buffer buffer)
71 public void onDataReceivedEvent(Connection connection, Buffer buffer)
/forgerock/opendj2/src/server/org/opends/server/protocols/http/
H A DHTTPStatsProbe.java29 import org.glassfish.grizzly.Connection;
35 * {@link #onDataReceivedEvent(Connection, Buffer)} and
36 * {@link #onDataSentEvent(Connection, Buffer)} because they are the only ones
63 public void onDataSentEvent(Connection connection, Buffer buffer)
70 public void onDataReceivedEvent(Connection connection, Buffer buffer)
/forgerock/opendj2.6.2/src/server/org/opends/server/protocols/http/
H A DHTTPStatsProbe.java30 import org.glassfish.grizzly.Connection;
36 * {@link #onDataReceivedEvent(Connection, Buffer)} and
37 * {@link #onDataSentEvent(Connection, Buffer)} because they are the only ones
64 public void onDataSentEvent(Connection connection, Buffer buffer)
71 public void onDataReceivedEvent(Connection connection, Buffer buffer)
/forgerock/opendj2-jel-hg/src/server/org/opends/server/protocols/http/
H A DHTTPStatsProbe.java30 import org.glassfish.grizzly.Connection;
36 * {@link #onDataReceivedEvent(Connection, Buffer)} and
37 * {@link #onDataSentEvent(Connection, Buffer)} because they are the only ones
64 public void onDataSentEvent(Connection connection, Buffer buffer)
71 public void onDataReceivedEvent(Connection connection, Buffer buffer)
/forgerock/opendj2-hg/src/server/org/opends/server/protocols/http/
H A DHTTPStatsProbe.java29 import org.glassfish.grizzly.Connection;
35 * {@link #onDataReceivedEvent(Connection, Buffer)} and
36 * {@link #onDataSentEvent(Connection, Buffer)} because they are the only ones
63 public void onDataSentEvent(Connection connection, Buffer buffer)
70 public void onDataReceivedEvent(Connection connection, Buffer buffer)
/forgerock/opendj-v3/opendj-server-legacy/src/main/java/org/opends/server/protocols/http/
H A DHTTPStatsProbe.java29 import org.glassfish.grizzly.Connection;
35 * {@link #onDataReceivedEvent(Connection, Buffer)} and
36 * {@link #onDataSentEvent(Connection, Buffer)} because they are the only ones
63 public void onDataSentEvent(Connection connection, Buffer buffer)
70 public void onDataReceivedEvent(Connection connection, Buffer buffer)
/forgerock/openidm-v4/openidm-zip/src/main/resources/samples/audit-sample/tools/
H A DTestScript.groovy27 import java.sql.Connection;
34 def sql = new Sql(connection as Connection);
/forgerock/openam-v13/openam-core/src/main/java/org/forgerock/openam/sm/datalayer/impl/ldap/
H A DLdapQueryFactory.java24 import org.forgerock.opendj.ldap.Connection;
33 public class LdapQueryFactory implements QueryFactory<Connection, Filter> {
43 public QueryBuilder<Connection, Filter> createInstance() {
/forgerock/openam/openam-core/src/main/java/org/forgerock/openam/sm/datalayer/impl/ldap/
H A DLdapQueryFactory.java24 import org.forgerock.opendj.ldap.Connection;
33 public class LdapQueryFactory implements QueryFactory<Connection, Filter> {
43 public QueryBuilder<Connection, Filter> createInstance() {
/forgerock/openam-v13/openam-core/src/test/java/org/forgerock/openam/sm/datalayer/impl/tasks/
H A DUpdateTaskTest.java31 import org.forgerock.opendj.ldap.Connection;
37 private Connection mockConnection;
46 mockConnection = mock(Connection.class);
50 given(mockAdapter.read(any(Connection.class), anyString())).willReturn(mockToken);
56 verify(mockAdapter).update(any(Connection.class), any(Token.class), eq(mockToken));
61 given(mockAdapter.read(any(Connection.class), anyString())).willReturn(null);
63 verify(mockAdapter).create(any(Connection.class), eq(mockToken));
68 doThrow(DataLayerException.class).when(mockAdapter).read(any(Connection.class), anyString());
H A DCreateTaskTest.java28 import org.forgerock.opendj.ldap.Connection;
35 private Connection mockConnection;
44 mockConnection = mock(Connection.class);
53 verify(mockAdapter).create(any(Connection.class), eq(mockToken));
59 .when(mockAdapter).create(any(Connection.class), any(Token.class));
H A DDeleteTaskTest.java25 import org.forgerock.opendj.ldap.Connection;
31 private Connection mockConnection;
40 mockConnection = mock(Connection.class);
49 verify(mockAdapter).delete(any(Connection.class), eq(tokenId));
55 .when(mockAdapter).delete(any(Connection.class), anyString());
/forgerock/openam/openam-core/src/main/java/org/forgerock/openam/sm/datalayer/providers/
H A DLdapConnectionFactoryProvider.java40 import org.forgerock.opendj.ldap.Connection;
64 public class LdapConnectionFactoryProvider implements ConnectionFactoryProvider<Connection> {
96 public ConnectionFactory<Connection> createFactory() throws InvalidConfigurationException {
138 public static ConnectionFactory<Connection> wrapExistingConnectionFactory(
143 private static class LdapConnectionFactory implements ConnectionFactory<Connection> {
145 private static final Function<Connection, Connection, DataLayerException> IDENTITY_FUNCTION =
146 new Function<Connection, Connection, DataLayerException>() {
148 public Connection appl
[all...]
/forgerock/openam-v13/openam-core/src/main/java/org/forgerock/openam/sm/datalayer/providers/
H A DLdapConnectionFactoryProvider.java40 import org.forgerock.opendj.ldap.Connection;
63 public class LdapConnectionFactoryProvider implements ConnectionFactoryProvider<Connection> {
95 public ConnectionFactory<Connection> createFactory() throws InvalidConfigurationException {
126 private static class LdapConnectionFactory implements ConnectionFactory<Connection> {
128 private static final Function<Connection, Connection, DataLayerException> IDENTITY_FUNCTION =
129 new Function<Connection, Connection, DataLayerException>() {
131 public Connection apply(Connection valu
[all...]
/forgerock/openidm-v4/openidm-zip/src/main/resources/samples/sample3/tools/
H A DTestScript.groovy34 import java.sql.Connection
61 def connection = new Sql(connection as Connection)
/forgerock/openidm-v4/openidm-zip/src/main/resources/samples/scriptedcrest2dj/tools/
H A DTestScript.groovy25 import org.forgerock.json.resource.Connection
32 def connection = connection as Connection
/forgerock/openam-v13/openam-rest/src/main/java/org/forgerock/openam/rest/
H A DElevatedConnectionFactoryWrapper.java25 import org.forgerock.json.resource.Connection;
56 public Connection getConnection() throws ResourceException {
57 Connection connection = connectionFactory.getConnection();
63 public Promise<Connection, ResourceException> getConnectionAsync() {
76 private static final class ElevatedConnection extends AbstractConnectionWrapper<Connection> {
81 ElevatedConnection(Connection connection, SSOToken adminToken) {

Completed in 209 milliseconds

1234567891011