Searched defs:connection (Results 201 - 225 of 361) sorted by relevance

1234567891011>>

/forgerock/opendj2-jel-hg/src/server/org/opends/server/tools/
H A DLDAPCompare.java120 * @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 DLDAPSearch.java117 * @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 DNetworkGroupPlugin.java67 * 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 DSASLByteChannel.java274 * 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 DDeleteMsg.java106 public DeleteOperation createOperation(InternalClientConnection connection, argument
109 DeleteOperation del = new DeleteOperationBasis(connection,
/forgerock/opendj2-hg/src/server/org/opends/server/tools/
H A DLDAPCompare.java119 * @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 DLDAPSearch.java115 * @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 DAMSetupUtils.java192 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 DSeriesTaskExecutor.java214 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 DSASLByteChannel.java259 * 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 DUmaLabelsStore.java93 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 DCollectClientConnectionsFilter.java83 /** 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 DDeleteMsg.java106 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 DLDAPSearch.java114 * @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 DLDAPManagementContext.java75 * 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 DDBUnitUtils.java48 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 DKeystoreResourceProviderTest.java65 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 DUmaLabelsStore.java93 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 DAMSetupUtils.java192 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 DLdapAdapter.java87 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 DQueryBuilder.java46 * @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 DLdapQueryBuilder.java96 * @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 DResourceLimitsPolicyFactory.java105 // 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 DCollectClientConnectionsFilter.java93 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 DJmxConnectionHandler.java62 * 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...]

Completed in 110 milliseconds

1234567891011>>