- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 26 for setPolicy (0.42 sec)
-
okhttp/src/test/java/okhttp3/internal/connection/ConnectionPoolTest.kt
forceConnectionsToExpire(pool, expireSooner) assertThat(pool.connectionCount()).isEqualTo(1) } private fun setPolicy( pool: RealConnectionPool, address: Address, policy: ConnectionPool.AddressPolicy, ) { pool.setPolicy(address, policy) taskFaker.runTasks() } private fun evictAllConnections(pool: RealConnectionPool) { pool.evictAll()
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Wed Apr 24 04:40:49 GMT 2024 - 12.7K bytes - Viewed (0) -
guava-tests/test/com/google/common/util/concurrent/JSR166TestCase.java
Policy.setPolicy(savedPolicy); } } else { Policy savedPolicy = Policy.getPolicy(); AdjustablePolicy policy = new AdjustablePolicy(permissions); Policy.setPolicy(policy); try { r.run(); } finally { policy.addPermission(new SecurityPermission("setPolicy")); Policy.setPolicy(savedPolicy); } } }
Java - Registered: Fri Apr 12 12:43:09 GMT 2024 - Last Modified: Thu Feb 22 17:15:24 GMT 2024 - 37.7K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/ConnectionPool.kt
} /** * Sets a policy that applies to [address]. * Overwrites any existing policy for that address. */ @ExperimentalOkHttpApi fun setPolicy( address: Address, policy: AddressPolicy, ) { delegate.setPolicy(address, policy) } /** * A policy for how the pool should treat a specific address. */ class AddressPolicy( /**
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Wed Apr 03 20:39:41 GMT 2024 - 5.6K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/util/concurrent/JSR166TestCase.java
Policy.setPolicy(savedPolicy); } } else { Policy savedPolicy = Policy.getPolicy(); AdjustablePolicy policy = new AdjustablePolicy(permissions); Policy.setPolicy(policy); try { r.run(); } finally { policy.addPermission(new SecurityPermission("setPolicy")); Policy.setPolicy(savedPolicy); } } }
Java - Registered: Fri May 03 12:43:13 GMT 2024 - Last Modified: Thu Feb 22 17:15:24 GMT 2024 - 37.2K bytes - Viewed (0) -
cmd/admin-handlers-users_test.go
} v, ok := usersMap[accessKey] if !ok { c.Fatalf("user not listed: %s", accessKey) } c.Assert(v.Status, madmin.AccountEnabled) // 3. Associate policy and check that user can access err = s.adm.SetPolicy(ctx, "readwrite", accessKey, false) if err != nil { c.Fatalf("unable to set policy: %v", err) } client := s.getUserClient(c, accessKey, secretKey, "")
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Feb 12 16:36:16 GMT 2024 - 45.7K bytes - Viewed (0) -
cmd/sts-handlers_test.go
} // Attempting to set a non-existent policy should fail. userDN := "uid=dillon,ou=people,ou=swengg,dc=min,dc=io" err = s.adm.SetPolicy(ctx, policy+"x", userDN, false) if err == nil { c.Fatalf("should not be able to set non-existent policy") } err = s.adm.SetPolicy(ctx, policy, userDN, false) if err != nil { c.Fatalf("Unable to set policy: %v", err) } value, err := ldapID.Retrieve()
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 25 15:50:16 GMT 2024 - 85.7K bytes - Viewed (0) -
cmd/admin-handlers-users-race_test.go
accessKey, secretKey := mustGenerateCredentials(c) err = s.adm.SetUser(ctx, accessKey, secretKey, madmin.AccountEnabled) if err != nil { c.Fatalf("Unable to set user: %v", err) } err = s.adm.SetPolicy(ctx, policy, accessKey, false) if err != nil { c.Fatalf("Unable to set policy: %v", err) } accessKeys[i] = accessKey secretKeys[i] = secretKey } g := errgroup.Group{}
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Sep 04 19:57:37 GMT 2023 - 3.9K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/connection/RealConnectionPool.kt
} } return references.size } /** * Adds or replaces the policy for [address]. * This will trigger a background task to start creating connections as needed. */ fun setPolicy( address: Address, policy: ConnectionPool.AddressPolicy, ) { val state = AddressState(address, taskRunner.newQueue(), policy) val newConnectionsNeeded: Int while (true) {
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sat Apr 20 17:03:43 GMT 2024 - 16.2K bytes - Viewed (0) -
cmd/iam.go
} return sys.store.ListPolicyDocs(ctx, bucketName) } // SetPolicy - sets a new named policy. func (sys *IAMSys) SetPolicy(ctx context.Context, policyName string, p policy.Policy) (time.Time, error) { if !sys.Initialized() { return time.Time{}, errServerNotInitialized } updatedAt, err := sys.store.SetPolicy(ctx, policyName, p) if err != nil { return updatedAt, err }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 25 21:28:16 GMT 2024 - 71.1K bytes - Viewed (1) -
cmd/iam-store.go
cache := store.rlock() defer store.runlock() v, ok := cache.iamPolicyDocsMap[name] if !ok { return r, errNoSuchPolicy } return v, nil } // SetPolicy - creates a policy with name. func (store *IAMStoreSys) SetPolicy(ctx context.Context, name string, policy policy.Policy) (time.Time, error) { if policy.IsEmpty() || name == "" { return time.Time{}, errInvalidArgument }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sat Apr 27 10:04:10 GMT 2024 - 75.2K bytes - Viewed (2)