/forgerock/opendj2-jel-hg/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/opendj2-hg/src/server/org/opends/server/core/networkgroups/ |
H A D | ResourceLimitsPolicyFactory.java | 104 // 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 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-v13/openam-core/src/main/java/org/forgerock/openam/sm/datalayer/impl/tasks/ |
H A D | PartialQueryTask.java | 51 * @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 D | QueryTask.java | 56 * @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 D | ReadTask.java | 50 * @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 D | ScriptOnResourceScript.groovy | 38 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 D | CreateScript.groovy | 41 def httpClient = connection as HttpClient 42 def connection = customizedConnection as RESTClient 70 connection.put( 84 connection.put(
|
H A D | UpdateScript.groovy | 43 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 D | SyncScript.groovy | 37 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 D | RelationshipValidatorTest.java | 73 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 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-rest/src/test/java/org/forgerock/openam/rest/ |
H A D | ElevatedConnectionFactoryWrapperTest.java | 57 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 D | SplunkAuditEventHandlerFactory.java | 110 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 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-v13/openam-core/src/main/java/com/iplanet/dpro/session/service/cluster/ |
H A D | ClusterStateService.java | 499 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 D | ClusterStateService.java | 494 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 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/openidm-v4/openidm-authnfilter/src/test/java/org/forgerock/openidm/auth/ |
H A D | IDMAuditApiTest.java | 48 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 D | ReSyncTest.java | 153 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 D | ReSyncTest.java | 138 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 D | ReSyncTest.java | 153 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 D | ReSyncTest.java | 138 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 D | ReSyncTest.java | 153 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 D | AuditEventPublisherImpl.java | 85 Connection connection = newInternalConnection(auditService); 88 connection.create(new RootContext(), request); 93 Connection connection = newInternalConnection(auditService); 97 connection.create(new RootContext(), request);
|