/forgerock/opendj2-jel-hg/src/server/org/opends/server/tools/ |
H A D | LDAPCompare.java | 120 * @param connection The connection to execute the request on. 132 public int readAndExecute(LDAPConnection connection, String attributeType, argument 141 executeCompare(connection, attributeType, attributeVal, line, 153 * @param connection The connection to execute the request on. 165 public int readAndExecute(LDAPConnection connection, String attributeType, argument 177 executeCompare(connection, attributeType, attributeVal, line, 215 * @param connection The connection t 227 executeCompare(LDAPConnection connection, String attributeType, byte[] attributeVal, String line, LDAPCompareOptions compareOptions) argument [all...] |
H A D | LDAPSearch.java | 117 * @param connection The connection to use for the search. 133 public int executeSearch(LDAPConnection connection, String baseDN, argument 162 connection.getLDAPWriter().writeMessage(message); 171 connection.getLDAPReader().readMessage(); 670 LDAPConnection connection = null; 1634 // Set the connection options. 1766 // We don't actually need to open a connection or perform the search, 1775 connection = new LDAPConnection(hostNameValue, portNumber, 1778 connection [all...] |
/forgerock/opendj2-hg/src/server/org/opends/server/core/networkgroups/ |
H A D | NetworkGroupPlugin.java | 67 * the appropriate network group for each client connection. 132 * @param connection The client connection on which the operation is done 139 ClientConnection connection, 144 if (!connection.getNetworkGroup().checkResourceLimitsPolicy( 145 connection, operation, fullCheck, messages)) { 149 if (!connection.getNetworkGroup().checkRequestFilteringPolicy( 161 * @param connection The client connection on which the operation is 165 ClientConnection connection, 138 checkNetworkGroup( ClientConnection connection, PreParseOperation operation, boolean fullCheck, ArrayList<Message> messages) argument 164 setAndCheckNetworkGroup( ClientConnection connection, PreParseOperation operation, ArrayList<Message> messages) argument [all...] |
/forgerock/opendj2-hg/src/server/org/opends/server/extensions/ |
H A D | SASLByteChannel.java | 274 * A client connection associated with the instance. 311 * processing a confidentiality/integrity SASL connection. 313 * @param connection 314 * The client connection to read/write the bytes. 320 private SASLByteChannel(final ClientConnection connection, final String name, argument 326 channel = connection.getChannel();
|
/forgerock/opendj2-hg/src/server/org/opends/server/replication/protocol/ |
H A D | DeleteMsg.java | 106 public DeleteOperation createOperation(InternalClientConnection connection, argument 109 DeleteOperation del = new DeleteOperationBasis(connection,
|
/forgerock/opendj2-hg/src/server/org/opends/server/tools/ |
H A D | LDAPCompare.java | 119 * @param connection The connection to execute the request on. 131 public int readAndExecute(LDAPConnection connection, String attributeType, argument 140 executeCompare(connection, attributeType, attributeVal, line, 152 * @param connection The connection to execute the request on. 164 public int readAndExecute(LDAPConnection connection, String attributeType, argument 176 executeCompare(connection, attributeType, attributeVal, line, 214 * @param connection The connection t 226 executeCompare(LDAPConnection connection, String attributeType, byte[] attributeVal, String line, LDAPCompareOptions compareOptions) argument [all...] |
H A D | LDAPSearch.java | 115 * @param connection The connection to use for the search. 131 public int executeSearch(LDAPConnection connection, String baseDN, argument 160 connection.getLDAPWriter().writeMessage(message); 169 connection.getLDAPReader().readMessage(); 651 LDAPConnection connection = null; 1614 // Set the connection options. 1746 // We don't actually need to open a connection or perform the search, 1755 connection = new LDAPConnection(hostNameValue, portNumber, 1758 connection [all...] |
/forgerock/openam-v13/openam-core/src/main/java/com/sun/identity/setup/ |
H A D | AMSetupUtils.java | 192 HttpURLConnection connection = null; 194 connection = openConnection(serverUrl + "/getServerInfo.jsp"); 195 writeToConnection(connection, "IDToken1=" + URLEncoder.encode(userId, "UTF-8") 198 return BootstrapData.queryStringToMap(readFromConnection(connection).replace("\n", "")); 211 if (connection != null) { 213 status = connection.getResponseCode(); 224 if (connection != null) { 225 connection.disconnect(); 232 HttpURLConnection connection = (HttpURLConnection) url.openConnection(); 234 HttpsURLConnection sslConnection = (HttpsURLConnection) connection; 244 writeToConnection(URLConnection connection, String data) argument 256 readFromConnection(URLConnection connection) argument [all...] |
/forgerock/openam-v13/openam-core/src/main/java/org/forgerock/openam/sm/datalayer/impl/ |
H A D | SeriesTaskExecutor.java | 214 public <T> void execute(T connection, TokenStorageAdapter<T> adapter) throws DataLayerException { argument 217 delegate.execute(connection, adapter);
|
/forgerock/opendj-v3/opendj-server-legacy/src/main/java/org/opends/server/extensions/ |
H A D | SASLByteChannel.java | 259 * A client connection associated with the instance. 296 * processing a confidentiality/integrity SASL connection. 298 * @param connection 299 * The client connection to read/write the bytes. 305 private SASLByteChannel(final ClientConnection connection, final String name, argument 311 channel = connection.getChannel();
|
/forgerock/openam-v13/openam-oauth2/src/main/java/org/forgerock/openam/oauth2/resources/labels/ |
H A D | UmaLabelsStore.java | 93 try (Connection connection = getConnection()) { 94 return createLabel(realm, username, label, id, connection); 99 try (Connection connection = getConnection()) { 101 connection.add(LDAPRequests.newAddRequest(realmDn) 110 connection.add(LDAPRequests.newAddRequest(userDn) 116 return createLabel(realm, username, label, id, connection); 129 Connection connection) throws LdapException, InternalServerErrorException { 138 Result result = connection.add(addRequest); 154 try (Connection connection = getConnection()) { 155 SearchResultEntry entry = connection 128 createLabel(String realm, String username, ResourceSetLabel label, String id, Connection connection) argument [all...] |
/forgerock/opendj-v3/opendj-server-legacy/src/main/java/org/opends/server/protocols/http/ |
H A D | CollectClientConnectionsFilter.java | 83 /** The connection handler that created this servlet filter. */ 98 * the connection handler that accepted this connection 131 final Connection connection = new SdkConnectionAdapter(clientConnection); 141 .thenAsync(doBindAfterSearch(context, request, next, userName, password, clientConnection, connection), 147 return doFilter(context, request, next, connection); 160 private boolean canProcessRequest(final HTTPClientConnection connection) throws UnknownHostException argument 162 final InetAddress clientAddr = connection.getRemoteAddress(); 164 // Check to see if the core server rejected the connection (e.g. already too many connections established). 165 if (connection 204 doBindAfterSearch( final Context context, final Request request, final Handler next, final String userName, final String password, final HTTPClientConnection clientConnection, final Connection connection) argument 228 doChain( final Context context, final Request request, final Handler next, final String userName, final HTTPClientConnection clientConnection, final Connection connection) argument 251 doFilter( final Context context, final Request request, final Handler next, final Connection connection) argument [all...] |
/forgerock/opendj-v3/opendj-server-legacy/src/main/java/org/opends/server/replication/protocol/ |
H A D | DeleteMsg.java | 106 public DeleteOperation createOperation(InternalClientConnection connection, argument 109 DeleteOperation del = new DeleteOperationBasis(connection,
|
/forgerock/opendj-v3/opendj-server-legacy/src/main/java/org/opends/server/tools/ |
H A D | LDAPSearch.java | 114 * @param connection The connection to use for the search. 130 public int executeSearch(LDAPConnection connection, String baseDN, argument 159 connection.getLDAPWriter().writeMessage(message); 168 connection.getLDAPReader().readMessage(); 631 LDAPConnection connection = null; 1504 // Set the connection options. 1620 // We don't actually need to open a connection or perform the search, 1629 connection = new LDAPConnection(hostNameValue, portNumber, 1632 connection [all...] |
/forgerock/opendj-v3/opendj-config/src/main/java/org/forgerock/opendj/config/client/ldap/ |
H A D | LDAPManagementContext.java | 75 * An LDAP management connection context. 178 * Create a new LDAP management context using the provided LDAP connection. 180 * @param connection 181 * The LDAP connection. 186 public static ManagementContext newManagementContext(Connection connection, LDAPProfile profile) { argument 187 Reject.ifNull(connection, profile); 188 LDAPDriver driver = new LDAPDriver(connection, profile);
|
/forgerock/openidm-v4/openidm-repo-jdbc/src/test/java/org/forgerock/openidm/repo/jdbc/internal/ |
H A D | DBUnitUtils.java | 48 private IDatabaseConnection connection; field in class:DBUnitUtils 55 if (connection == null) { 57 connection = new DatabaseConnection(DriverManager.getConnection("jdbc:hsqldb:mem:openidmtestdb")); 61 // connection = new DatabaseDataSourceConnection(ctx, "java:openejb/Resource/openidmDS"); 72 // ctx.bind("jdbc/openidm", connection); 74 return connection; 78 if (connection != null) { 79 connection.close(); 80 connection = null; 122 Connection connection [all...] |
/forgerock/openidm-v4/openidm-security/src/test/java/org/forgerock/openidm/security/impl/ |
H A D | KeystoreResourceProviderTest.java | 65 private final Connection connection = Resources.newInternalConnection(router); field in class:KeystoreResourceProviderTest 135 connection.close(); 148 final ActionResponse result = connection.action(new RootContext(), actionRequest); 166 final ActionResponse result = connection.action(new RootContext(), actionRequest); 186 connection.action(new RootContext(), actionRequest); 199 connection.action(new RootContext(), actionRequest); 200 connection.action(new RootContext(), actionRequest);
|
/forgerock/openam/openam-oauth2/src/main/java/org/forgerock/openam/oauth2/resources/labels/ |
H A D | UmaLabelsStore.java | 93 try (Connection connection = getConnection()) { 94 return createLabel(realm, username, label, id, connection); 99 try (Connection connection = getConnection()) { 101 connection.add(LDAPRequests.newAddRequest(realmDn) 110 connection.add(LDAPRequests.newAddRequest(userDn) 116 return createLabel(realm, username, label, id, connection); 129 Connection connection) throws LdapException, InternalServerErrorException { 138 Result result = connection.add(addRequest); 154 try (Connection connection = getConnection()) { 155 SearchResultEntry entry = connection 128 createLabel(String realm, String username, ResourceSetLabel label, String id, Connection connection) argument [all...] |
/forgerock/openam/openam-core/src/main/java/com/sun/identity/setup/ |
H A D | AMSetupUtils.java | 192 HttpURLConnection connection = null; 194 connection = openConnection(serverUrl + "/getServerInfo.jsp"); 195 writeToConnection(connection, "IDToken1=" + URLEncoder.encode(userId, "UTF-8") 198 return BootstrapData.queryStringToMap(readFromConnection(connection).replace("\n", "")); 211 if (connection != null) { 213 status = connection.getResponseCode(); 224 if (connection != null) { 225 connection.disconnect(); 232 HttpURLConnection connection = (HttpURLConnection) url.openConnection(); 234 HttpsURLConnection sslConnection = (HttpsURLConnection) connection; 244 writeToConnection(URLConnection connection, String data) argument 256 readFromConnection(URLConnection connection) argument [all...] |
/forgerock/openam/openam-core/src/main/java/org/forgerock/openam/cts/impl/ |
H A D | LdapAdapter.java | 87 private Connection connection; field in class:LdapAdapter 95 * @param connectionFactoryProvider Produces connection factories for connections to the datastore. 123 Result result = connection.add(request); 131 * Performs a read against the LDAP connection and converts the result into a Token. 145 SearchResultEntry resultEntry = connection.searchSingleEntry(request); 199 Result result = connection.modify(request); 228 Result result = connection.delete(request); 258 .execute(connection).next(); 273 .executeAttributeQuery(connection).next(); 309 if (!connectionFactory.isValid(connection)) { [all...] |
/forgerock/openam/openam-core/src/main/java/org/forgerock/openam/sm/datalayer/api/query/ |
H A D | QueryBuilder.java | 46 * @param <C> The type of connection that will be used. 173 * @param connection The connection used to perform the request. 178 public Iterator<Collection<PartialToken>> executeAttributeQuery(C connection) { argument 179 return executeRawResults(connection, PartialToken.class); 185 * @param connection The connection to query. 190 public abstract <T> Iterator<Collection<T>> executeRawResults(C connection, Class<T> returnType); argument 195 * @param connection The connection use 200 execute(C connection) argument [all...] |
/forgerock/openam/openam-core/src/main/java/org/forgerock/openam/sm/datalayer/impl/ldap/ |
H A D | LdapQueryBuilder.java | 96 * @param connection The connection used to perform the request. 99 public <T> Iterator<Collection<T>> executeRawResults(Connection connection, Class<T> returnType) { argument 107 return new EntryIterator<>(connection, entryConverter); 128 private Collection<Entry> getEntries(Connection connection) throws CoreTokenException { argument 145 final Result result = handler.performSearch(connection, searchRequest, entries); 270 private Connection connection; field in class:LdapQueryBuilder.EntryIterator 272 EntryIterator(Connection connection, EntryConverter<T> converter) { argument 274 this.connection = connection; [all...] |
/forgerock/opendj-b2.6/src/server/org/opends/server/core/networkgroups/ |
H A D | ResourceLimitsPolicyFactory.java | 105 // The maximum number of concurrent operations per connection. 115 // The maximum number of operations per connection. 156 void addConnection(ClientConnection connection) argument 165 String ip = connection.getClientAddress(); 228 boolean isAllowed(ClientConnection connection, argument 255 // Add the connection in the map 256 String ip = connection.getClientAddress(); 279 // Check the max number of operations per connection 281 && connection.getNumberOfOperations() > maxOpsPerConnection) 289 // Check the max number of concurrent operations per connection 347 removeConnection(ClientConnection connection) argument [all...] |
/forgerock/opendj-b2.6/src/server/org/opends/server/protocols/http/ |
H A D | CollectClientConnectionsFilter.java | 93 private Connection connection; field in class:CollectClientConnectionsFilter.HTTPRequestContext 147 ctx.connection.bindAsync(bindRequest, null, 204 /** The connection handler that created this servlet filter. */ 216 * the connection handler that accepted this connection 292 ctx.connection = new SdkConnectionAdapter(clientConnection); 302 ctx.connection.searchSingleEntryAsync(buildSearchRequest(ctx.userName), 327 * WARNING: This action triggers 3-4 others: Set the connection for use with 333 Rest2LDAPContextFactory.ATTRIBUTE_AUTHN_CONNECTION, ctx.connection); 402 // connection ( [all...] |
/forgerock/opendj-b2.6/src/server/org/opends/server/protocols/jmx/ |
H A D | JmxConnectionHandler.java | 62 * This class defines a connection handler that will be used for 63 * communicating with administrative clients over JMX. The connection 76 * Key that may be placed into a JMX connection environment map to 78 * for a connection. 87 // The list of active client connection. 96 // The unique name for this connection handler. 102 // The set of listeners for this connection handler. 106 * Creates a new instance of this JMX connection handler. It must be 127 // Determine whether or not the RMI connection needs restarting. 241 * established through this connection handle 492 registerClientConnection(ClientConnection connection) argument [all...] |