Searched refs:connection (Results 226 - 250 of 652) sorted by relevance

1234567891011>>

/forgerock/opendj2-jel-hg/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/opendj2-hg/src/server/org/opends/server/core/networkgroups/
H A DResourceLimitsPolicyFactory.java104 // The maximum number of concurrent operations per connection.
114 // The maximum number of operations per connection.
155 void addConnection(ClientConnection connection) argument
164 String ip = connection.getClientAddress();
227 boolean isAllowed(ClientConnection connection, argument
254 // Add the connection in the map
255 String ip = connection.getClientAddress();
278 // Check the max number of operations per connection
280 && connection.getNumberOfOperations() > maxOpsPerConnection)
288 // Check the max number of concurrent operations per connection
346 removeConnection(ClientConnection connection) argument
[all...]
/forgerock/openam-v13/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-v13/openam-core/src/main/java/org/forgerock/openam/sm/datalayer/impl/tasks/
H A DPartialQueryTask.java51 * @param connection Connection to use.
57 public void performTask(Object connection, TokenStorageAdapter adapter) throws DataLayerException { argument
60 handler.processResults(adapter.partialQuery(connection, tokenFilter));
H A DQueryTask.java56 * @param connection Connection to use.
62 public void performTask(Object connection, TokenStorageAdapter adapter) throws DataLayerException { argument
64 handler.processResults(adapter.query(connection, tokenFilter));
H A DReadTask.java50 * @param connection Non null connection.
51 * @param adapter Non null for connection-coupled operations.
55 public void performTask(Object connection, TokenStorageAdapter adapter) throws DataLayerException { argument
56 Token token = adapter.read(connection, tokenId);
/forgerock/openidm-v4/openidm-zip/src/main/resources/samples/scriptedcrest2dj/tools/
H A DScriptOnResourceScript.groovy38 def connection = connection as Connection
48 def response = connection.action(new RootContext(), request)
72 def result = connection.action(new RootContext(), request)
/forgerock/openidm-v4/openidm-zip/src/main/resources/samples/scriptedrest2dj/tools/
H A DCreateScript.groovy41 def httpClient = connection as HttpClient
42 def connection = customizedConnection as RESTClient
70 connection.put(
84 connection.put(
H A DUpdateScript.groovy43 def httpClient = connection as HttpClient
44 def connection = customizedConnection as RESTClient
68 return connection.request(PUT, JSON) { req ->
82 return connection.request(PUT, JSON) { req ->
H A DSyncScript.groovy37 def httpClient = connection as HttpClient
38 def connection = customizedConnection as RESTClient
47 return connection.request(GET) { req ->
74 return connection.request(GET) { req ->
107 connection.request(GET) { getReq ->
152 return connection.request(GET) { req ->
185 connection.request(GET) { getReq ->
/forgerock/openidm-v4/openidm-core/src/test/java/org/forgerock/openidm/managed/
H A DRelationshipValidatorTest.java73 Connection connection = mock(Connection.class);
74 when(connectionFactory.getConnection()).thenReturn(connection);
89 when(connection.read(any(Context.class), any(ReadRequest.class))).thenReturn(foundRelationshipResponse);
114 when(connection.read(any(Context.class), any(ReadRequest.class))).thenThrow(new NotFoundException());
126 Connection connection = mock(Connection.class);
127 when(connectionFactory.getConnection()).thenReturn(connection);
140 when(connection.read(any(Context.class), any(ReadRequest.class))).thenReturn(foundRelationshipResponse);
148 when(connection.read(any(Context.class), any(ReadRequest.class))).thenThrow(new NotFoundException());
/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-rest/src/test/java/org/forgerock/openam/rest/
H A DElevatedConnectionFactoryWrapperTest.java57 private Connection connection; field in class:ElevatedConnectionFactoryWrapperTest
88 given(internalConnectionFactory.getConnection()).willReturn(connection);
101 try (Connection connection = connectionFactory.getConnection()) {
102 connection.read(context, readRequest);
106 verify(connection).read(contextCaptor.capture(), eq(readRequest));
/forgerock/openam/openam-audit/openam-audit-configuration/src/main/java/org/forgerock/openam/audit/events/handlers/
H A DSplunkAuditEventHandlerFactory.java110 final ConnectionConfiguration connection = new ConnectionConfiguration();
112 connection.setHost(getMapAttr(attributes, "host"));
113 connection.setPort(getIntMapAttr(attributes, "port", 8088, DEBUG));
114 connection.setUseSSL(getBooleanMapAttr(attributes, "sslEnabled", false));
116 return connection;
/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-v13/openam-core/src/main/java/com/iplanet/dpro/session/service/cluster/
H A DClusterStateService.java499 HttpURLConnection connection = null;
503 connection = (HttpURLConnection) info.url.openConnection();
504 connection.setConnectTimeout(timeout);
505 connection.setReadTimeout(timeout);
507 if (connection instanceof HttpsURLConnection) {
508 ((HttpsURLConnection) connection).setHostnameVerifier(new HostnameVerifier() {
516 is = connection.getInputStream();
517 responseCode = connection.getResponseCode();
520 if (connection != null) {
521 readStream(connection
[all...]
/forgerock/openam/openam-core/src/main/java/com/iplanet/dpro/session/service/cluster/
H A DClusterStateService.java494 HttpURLConnection connection = null;
498 connection = (HttpURLConnection) info.url.openConnection();
499 connection.setConnectTimeout(timeout);
500 connection.setReadTimeout(timeout);
502 if (connection instanceof HttpsURLConnection) {
503 ((HttpsURLConnection) connection).setHostnameVerifier(new HostnameVerifier() {
511 is = connection.getInputStream();
512 responseCode = connection.getResponseCode();
515 if (connection != null) {
516 readStream(connection
[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/openidm-v4/openidm-authnfilter/src/test/java/org/forgerock/openidm/auth/
H A DIDMAuditApiTest.java48 final Connection connection = mock(Connection.class);
52 when(connectionFactory.getConnection()).thenReturn(connection);
53 when(connection.create(any(Context.class), createRequestArgumentCaptor.capture()))
/forgerock/opendj-b2.6/tests/unit-tests-testng/src/server/org/opends/server/replication/
H A DReSyncTest.java153 addOp = new AddOperationBasis(connection,
180 connection.processDelete(DN.decode("dc=fooUniqueName1," + EXAMPLE_DN));
210 connection.processDelete(DN.decode("dc=fooUniqueName1," + EXAMPLE_DN));
228 connection.processDelete(DN.decode("dc=fooUniqueName2," + EXAMPLE_DN));
/forgerock/opendj2/tests/unit-tests-testng/src/server/org/opends/server/replication/
H A DReSyncTest.java138 AddOperation addOp = connection.processAdd(entry);
158 connection.processDelete(entryDN);
187 connection.processDelete(entryDN);
205 connection.processDelete(entryDN);
/forgerock/opendj2.6.2/tests/unit-tests-testng/src/server/org/opends/server/replication/
H A DReSyncTest.java153 addOp = new AddOperationBasis(connection,
180 connection.processDelete(DN.decode("dc=fooUniqueName1," + EXAMPLE_DN));
210 connection.processDelete(DN.decode("dc=fooUniqueName1," + EXAMPLE_DN));
228 connection.processDelete(DN.decode("dc=fooUniqueName2," + EXAMPLE_DN));
/forgerock/opendj2-hg/tests/unit-tests-testng/src/server/org/opends/server/replication/
H A DReSyncTest.java138 AddOperation addOp = connection.processAdd(entry);
158 connection.processDelete(entryDN);
187 connection.processDelete(entryDN);
205 connection.processDelete(entryDN);
/forgerock/opendj2-jel-hg/tests/unit-tests-testng/src/server/org/opends/server/replication/
H A DReSyncTest.java153 addOp = new AddOperationBasis(connection,
180 connection.processDelete(DN.decode("dc=fooUniqueName1," + EXAMPLE_DN));
210 connection.processDelete(DN.decode("dc=fooUniqueName1," + EXAMPLE_DN));
228 connection.processDelete(DN.decode("dc=fooUniqueName2," + EXAMPLE_DN));
/forgerock/openam-v13/openam-audit/openam-audit-core/src/main/java/org/forgerock/openam/audit/
H A DAuditEventPublisherImpl.java85 Connection connection = newInternalConnection(auditService);
88 connection.create(new RootContext(), request);
93 Connection connection = newInternalConnection(auditService);
97 connection.create(new RootContext(), request);

Completed in 817 milliseconds

1234567891011>>