/forgerock/openam-v13/openam-rest/src/main/java/org/forgerock/openam/rest/ |
H A D | ElevatedConnectionFactoryWrapper.java | 38 * 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 D | AMSystemConfig.java | 107 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 D | ReaperConnectionTest.java | 37 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 D | IndexChangeMonitorImpl.java | 38 * 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 D | LDAPModify.java | 130 * @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 D | ElevatedConnectionFactoryWrapper.java | 41 * 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 D | AMSystemConfig.java | 107 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 D | CTSWorkerBaseQuery.java | 44 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 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/openam-entitlements/src/main/java/org/forgerock/openam/entitlement/indextree/ |
H A D | IndexChangeMonitorImpl.java | 38 * 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 D | ModifyMsg.java | 136 public Operation createOperation(InternalClientConnection connection, argument 144 ModifyOperationBasis mod = new ModifyOperationBasis(connection,
|
/forgerock/opendj-b2.6/src/server/org/opends/server/tools/ |
H A D | LDAPDelete.java | 116 * @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 D | TaskClient.java | 87 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 D | DSMLSearchOperation.java | 66 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 D | DSMLSearchOperation.java | 67 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 D | ModifyMsg.java | 123 public ModifyOperation createOperation(InternalClientConnection connection, argument 133 ModifyOperation mod = new ModifyOperationBasis(connection,
|
/forgerock/opendj2/src/server/org/opends/server/tools/ |
H A D | LDAPDelete.java | 115 * @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 D | TaskClient.java | 86 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 D | ModifyMsg.java | 136 public Operation createOperation(InternalClientConnection connection, argument 144 ModifyOperationBasis mod = new ModifyOperationBasis(connection,
|
/forgerock/opendj2.6.2/src/server/org/opends/server/tools/ |
H A D | LDAPDelete.java | 116 * @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 D | TaskClient.java | 87 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 D | DSMLSearchOperation.java | 67 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 D | DSMLSearchOperation.java | 66 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 D | DSMLSearchOperation.java | 67 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 D | ModifyMsg.java | 136 public Operation createOperation(InternalClientConnection connection, argument 144 ModifyOperationBasis mod = new ModifyOperationBasis(connection,
|