Searched defs:connection (Results 126 - 150 of 361) sorted by relevance

1234567891011>>

/forgerock/openam-v13/openam-rest/src/main/java/org/forgerock/openam/rest/
H A DElevatedConnectionFactoryWrapper.java38 * CREST connection factory wrapper that elevates in coming contexts
39 * with an admin user for the duration of the connection.
57 Connection connection = connectionFactory.getConnection();
59 return new ElevatedConnection(connection, ssoToken);
81 ElevatedConnection(Connection connection, SSOToken adminToken) { argument
82 super(connection);
/forgerock/openam-v13/openam-console/src/main/java/com/sun/identity/console/base/model/
H A DAMSystemConfig.java107 HttpURLConnection connection = null;
112 connection = HttpURLConnectionManager.getConnection(url);
113 int responseCode = connection.getResponseCode();
115 version = getContent(connection);
124 if (connection != null) {
125 connection.disconnect();
131 private static String getContent(HttpURLConnection connection) { argument
135 in_buf = connection.getInputStream();
/forgerock/openam-v13/openam-core/src/test/java/org/forgerock/openam/cts/impl/query/reaper/
H A DReaperConnectionTest.java37 private ReaperConnection connection; field in class:ReaperConnectionTest
44 connection = new ReaperConnection(mockFactory, mockImpl);
58 connection.nextPage();
65 connection.nextPage();
73 connection.nextPage();
82 connection.nextPage();
94 connection.nextPage();
96 connection.nextPage();
/forgerock/openam-v13/openam-entitlements/src/main/java/org/forgerock/openam/entitlement/indextree/
H A DIndexChangeMonitorImpl.java38 * This monitor implementation acquires a connection against the data source and uses a persistent search to listen for
51 private Connection connection; field in class:IndexChangeMonitorImpl
78 connection = factory.create();
80 searchStatus = connection.searchAsync(request, null, handler);
115 * Ensure the connection is safely closed.
119 // Ensure any connection is cleaned up before shutdown.
120 if (connection != null) {
121 connection.close();
122 connection = null;
/forgerock/opendj-v3/opendj-server-legacy/src/main/java/org/opends/server/tools/
H A DLDAPModify.java130 * @param connection The connection to use for this modify request.
140 public void readAndExecute(LDAPConnection connection, String fileNameValue, argument
308 connection.getLDAPWriter().writeMessage(message);
309 responseMessage = connection.getLDAPReader().readMessage();
559 LDAPConnection connection = null;
1043 // Set the connection options.
1110 connection = new LDAPConnection(hostNameValue, portNumber,
1113 connection.connectToHost(bindDNValue, bindPasswordValue, nextMessageID,
1117 ldapModify.readAndExecute(connection, fileNameValu
[all...]
/forgerock/openam/openam-rest/src/main/java/org/forgerock/openam/rest/
H A DElevatedConnectionFactoryWrapper.java41 * CREST connection factory wrapper that elevates in coming contexts
42 * with an admin user for the duration of the connection.
62 Connection connection = connectionFactory.getConnection();
64 return new ElevatedConnection(connection, ssoToken);
86 ElevatedConnection(Connection connection, SSOToken adminToken) { argument
87 super(connection);
/forgerock/openam/openam-console/src/main/java/com/sun/identity/console/base/model/
H A DAMSystemConfig.java107 HttpURLConnection connection = null;
112 connection = HttpURLConnectionManager.getConnection(url);
113 int responseCode = connection.getResponseCode();
115 version = getContent(connection);
124 if (connection != null) {
125 connection.disconnect();
131 private static String getContent(HttpURLConnection connection) { argument
135 in_buf = connection.getInputStream();
/forgerock/openam/openam-core/src/main/java/org/forgerock/openam/cts/impl/query/worker/queries/
H A DCTSWorkerBaseQuery.java44 private C connection; field in class:CTSWorkerBaseQuery
65 if (connection == null) {
66 connection = factory.create();
67 results = getQuery().executeRawResults(connection, PartialToken.class);
83 IOUtils.closeIfNotNull(connection);
84 connection = null;
/forgerock/openam/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/openam-entitlements/src/main/java/org/forgerock/openam/entitlement/indextree/
H A DIndexChangeMonitorImpl.java38 * This monitor implementation acquires a connection against the data source and uses a persistent search to listen for
51 private Connection connection; field in class:IndexChangeMonitorImpl
78 connection = factory.create();
80 searchStatus = connection.searchAsync(request, null, handler);
115 * Ensure the connection is safely closed.
119 // Ensure any connection is cleaned up before shutdown.
120 if (connection != null) {
121 connection.close();
122 connection = null;
/forgerock/opendj-b2.6/src/server/org/opends/server/replication/protocol/
H A DModifyMsg.java136 public Operation createOperation(InternalClientConnection connection, argument
144 ModifyOperationBasis mod = new ModifyOperationBasis(connection,
/forgerock/opendj-b2.6/src/server/org/opends/server/tools/
H A DLDAPDelete.java116 * @param connection The connection to use to execute the request.
125 public void readAndExecute(LDAPConnection connection, argument
132 executeDelete(connection, line, deleteOptions);
140 * @param connection The connection to use to execute the request.
149 public void readAndExecute(LDAPConnection connection, Reader reader, argument
158 executeDelete(connection, line, deleteOptions);
167 * @param connection The connection t
176 executeDelete(LDAPConnection connection, String line, LDAPDeleteOptions deleteOptions) argument
[all...]
/forgerock/opendj-b2.6/src/server/org/opends/server/tools/tasks/
H A DTaskClient.java87 protected LDAPConnection connection; field in class:TaskClient
99 this.connection = conn;
309 LDAPReader reader = connection.getLDAPReader();
310 LDAPWriter writer = connection.getLDAPWriter();
375 LDAPReader reader = connection.getLDAPReader();
427 LDAPReader reader = connection.getLDAPReader();
464 LDAPReader reader = connection.getLDAPReader();
465 LDAPWriter writer = connection.getLDAPWriter();
571 LDAPWriter writer = connection.getLDAPWriter();
/forgerock/opendj2/src/dsml/org/opends/dsml/protocol/
H A DDSMLSearchOperation.java66 private LDAPConnection connection; field in class:DSMLSearchOperation
71 * Create the instance with the specified connection.
73 * @param connection
74 * The LDAP connection to send the request on.
77 public DSMLSearchOperation(LDAPConnection connection) argument
79 this.connection = connection;
544 connection.getLDAPWriter().writeMessage(msg);
551 LDAPMessage responseMessage = connection.getLDAPReader().readMessage();
/forgerock/opendj-b2.6/src/dsml/org/opends/dsml/protocol/
H A DDSMLSearchOperation.java67 private LDAPConnection connection; field in class:DSMLSearchOperation
72 * Create the instance with the specified connection.
74 * @param connection
75 * The LDAP connection to send the request on.
78 public DSMLSearchOperation(LDAPConnection connection) argument
80 this.connection = connection;
545 connection.getLDAPWriter().writeMessage(msg);
552 LDAPMessage responseMessage = connection.getLDAPReader().readMessage();
/forgerock/opendj2/src/server/org/opends/server/replication/protocol/
H A DModifyMsg.java123 public ModifyOperation createOperation(InternalClientConnection connection, argument
133 ModifyOperation mod = new ModifyOperationBasis(connection,
/forgerock/opendj2/src/server/org/opends/server/tools/
H A DLDAPDelete.java115 * @param connection The connection to use to execute the request.
124 public void readAndExecute(LDAPConnection connection, argument
131 executeDelete(connection, line, deleteOptions);
139 * @param connection The connection to use to execute the request.
148 public void readAndExecute(LDAPConnection connection, Reader reader, argument
157 executeDelete(connection, line, deleteOptions);
166 * @param connection The connection t
175 executeDelete(LDAPConnection connection, String line, LDAPDeleteOptions deleteOptions) argument
[all...]
/forgerock/opendj2/src/server/org/opends/server/tools/tasks/
H A DTaskClient.java86 protected LDAPConnection connection; field in class:TaskClient
98 this.connection = conn;
308 LDAPReader reader = connection.getLDAPReader();
309 LDAPWriter writer = connection.getLDAPWriter();
374 LDAPReader reader = connection.getLDAPReader();
426 LDAPReader reader = connection.getLDAPReader();
463 LDAPReader reader = connection.getLDAPReader();
464 LDAPWriter writer = connection.getLDAPWriter();
570 LDAPWriter writer = connection.getLDAPWriter();
/forgerock/opendj2.6.2/src/server/org/opends/server/replication/protocol/
H A DModifyMsg.java136 public Operation createOperation(InternalClientConnection connection, argument
144 ModifyOperationBasis mod = new ModifyOperationBasis(connection,
/forgerock/opendj2.6.2/src/server/org/opends/server/tools/
H A DLDAPDelete.java116 * @param connection The connection to use to execute the request.
125 public void readAndExecute(LDAPConnection connection, argument
132 executeDelete(connection, line, deleteOptions);
140 * @param connection The connection to use to execute the request.
149 public void readAndExecute(LDAPConnection connection, Reader reader, argument
158 executeDelete(connection, line, deleteOptions);
167 * @param connection The connection t
176 executeDelete(LDAPConnection connection, String line, LDAPDeleteOptions deleteOptions) argument
[all...]
/forgerock/opendj2.6.2/src/server/org/opends/server/tools/tasks/
H A DTaskClient.java87 protected LDAPConnection connection; field in class:TaskClient
99 this.connection = conn;
309 LDAPReader reader = connection.getLDAPReader();
310 LDAPWriter writer = connection.getLDAPWriter();
375 LDAPReader reader = connection.getLDAPReader();
427 LDAPReader reader = connection.getLDAPReader();
464 LDAPReader reader = connection.getLDAPReader();
465 LDAPWriter writer = connection.getLDAPWriter();
571 LDAPWriter writer = connection.getLDAPWriter();
/forgerock/opendj2.6.2/src/dsml/org/opends/dsml/protocol/
H A DDSMLSearchOperation.java67 private LDAPConnection connection; field in class:DSMLSearchOperation
72 * Create the instance with the specified connection.
74 * @param connection
75 * The LDAP connection to send the request on.
78 public DSMLSearchOperation(LDAPConnection connection) argument
80 this.connection = connection;
545 connection.getLDAPWriter().writeMessage(msg);
552 LDAPMessage responseMessage = connection.getLDAPReader().readMessage();
/forgerock/opendj2-hg/src/dsml/org/opends/dsml/protocol/
H A DDSMLSearchOperation.java66 private LDAPConnection connection; field in class:DSMLSearchOperation
71 * Create the instance with the specified connection.
73 * @param connection
74 * The LDAP connection to send the request on.
77 public DSMLSearchOperation(LDAPConnection connection) argument
79 this.connection = connection;
544 connection.getLDAPWriter().writeMessage(msg);
551 LDAPMessage responseMessage = connection.getLDAPReader().readMessage();
/forgerock/opendj2-jel-hg/src/dsml/org/opends/dsml/protocol/
H A DDSMLSearchOperation.java67 private LDAPConnection connection; field in class:DSMLSearchOperation
72 * Create the instance with the specified connection.
74 * @param connection
75 * The LDAP connection to send the request on.
78 public DSMLSearchOperation(LDAPConnection connection) argument
80 this.connection = connection;
545 connection.getLDAPWriter().writeMessage(msg);
552 LDAPMessage responseMessage = connection.getLDAPReader().readMessage();
/forgerock/opendj2-jel-hg/src/server/org/opends/server/replication/protocol/
H A DModifyMsg.java136 public Operation createOperation(InternalClientConnection connection, argument
144 ModifyOperationBasis mod = new ModifyOperationBasis(connection,

Completed in 106 milliseconds

1234567891011>>