- Sort Score
- Result 10 results
- Languages All
Results 1111 - 1120 of 1,713 for Take (0.02 sec)
-
guava/src/com/google/common/eventbus/Subscriber.java
bus.handleSubscriberException(e.getCause(), context(event)); } }); } /** * Invokes the subscriber method. This method can be overridden to make the invocation * synchronized. */ @VisibleForTesting void invokeSubscriberMethod(Object event) throws InvocationTargetException { try { method.invoke(target, checkNotNull(event));
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Wed Oct 06 00:47:57 UTC 2021 - 4.7K bytes - Viewed (0) -
cmd/background-heal-ops.go
} else { workers = numHealers } } if workers == 0 { workers = 4 } return &healRoutine{ tasks: make(chan healTask), workers: workers, } } // healDiskFormat - heals format.json, return value indicates if a // failure error occurred.
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 4.6K bytes - Viewed (0) -
cni/pkg/log/uds_test.go
) func TestUDSLog(t *testing.T) { // Start UDS log server udsSockDir := t.TempDir() udsSock := filepath.Join(udsSockDir, "cni.sock") logger := NewUDSLogger(istiolog.DebugLevel) stop := make(chan struct{}) defer close(stop) assert.NoError(t, logger.StartUDSLogServer(udsSock, stop)) // Configure log to tee to UDS server stdout := os.Stdout r, w, _ := os.Pipe() os.Stdout = w
Registered: Wed Nov 06 22:53:10 UTC 2024 - Last Modified: Wed Jun 12 16:26:28 UTC 2024 - 4.1K bytes - Viewed (0) -
schema/relationship.go
} if constraint.OnUpdate != "" { sql += " ON UPDATE " + constraint.OnUpdate } foreignKeys := make([]interface{}, 0, len(constraint.ForeignKeys)) for _, field := range constraint.ForeignKeys { foreignKeys = append(foreignKeys, clause.Column{Name: field.DBName}) } references := make([]interface{}, 0, len(constraint.References)) for _, field := range constraint.References {
Registered: Sun Nov 03 09:35:10 UTC 2024 - Last Modified: Wed Jun 12 03:46:59 UTC 2024 - 22.7K bytes - Viewed (0) -
compat/maven-embedder/src/main/java/org/apache/maven/cli/transfer/ConsoleMavenTransferListener.java
Iterator<TransferResourceAndSize> entries = transfers.values().iterator(); while (entries.hasNext()) { TransferResourceAndSize entry = entries.next(); // just in case, make sure 0 <= complete <= total long complete = Math.max(0, entry.transferredBytes); long total = Math.max(complete, entry.resource.getContentLength());
Registered: Sun Nov 03 03:35:11 UTC 2024 - Last Modified: Fri Oct 25 12:31:46 UTC 2024 - 5.4K bytes - Viewed (0) -
docs/en/docs/tutorial/dependencies/dependencies-in-path-operation-decorators.md
/// tip Some editors check for unused function parameters, and show them as errors. Using these `dependencies` in the *path operation decorator* you can make sure they are executed while avoiding editor/tooling errors. It might also help avoid confusion for new developers that see an unused parameter in your code and could think it's unnecessary. /// /// info
Registered: Sun Nov 03 07:19:11 UTC 2024 - Last Modified: Sun Oct 06 20:36:54 UTC 2024 - 4K bytes - Viewed (0) -
internal/config/subnet/config.go
cfg.Proxy = proxy if transport == nil { // when transport is nil, it means we are just validating the // inputs not performing any network calls. return cfg, nil } // Make sure to clone the transport before editing the ProxyURL if proxyURL != nil { ctransport := transport.(*http.Transport).Clone() ctransport.Proxy = http.ProxyURL((*url.URL)(proxyURL)) cfg.transport = ctransport
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 3.8K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/util/concurrent/AbstractFutureTest.java
waiter1.awaitWaiting(); WaiterThread waiter2 = new WaiterThread(future); waiter2.start(); waiter2.awaitWaiting(); // The waiter queue should be waiter2->waiter1 // This should wake up waiter1 and cause the waiter1 node to be removed. waiter1.interrupt(); waiter1.join(); waiter2.awaitWaiting(); // should still be blocked LockSupport.unpark(waiter2); // spurious wakeup
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Fri Oct 18 22:10:29 UTC 2024 - 47.1K bytes - Viewed (0) -
cmd/xl-storage_test.go
volume := "success-vol" // Setup test environment. if err = xlStorage.MakeVol(context.Background(), volume); err != nil { t.Fatalf("Unable to create volume, %s", err) } // Create directory to make errIsNotRegular if err = os.Mkdir(slashpath.Join(path, "success-vol", "object-as-dir"), 0o777); err != nil { t.Fatalf("Unable to create directory, %s", err) } testCases := []struct { volume string
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Wed Aug 14 17:11:51 UTC 2024 - 66.7K bytes - Viewed (0) -
buildscripts/minio-iam-ldap-upgrade-import-test.sh
#!/bin/bash # This script is used to test the migration of IAM content from old minio # instance to new minio instance. # # To run it locally, start the LDAP server in github.com/minio/minio-iam-testing # repo (e.g. make podman-run), and then run this script. # # This script assumes that LDAP server is at: # # `localhost:1389` # # if this is not the case, set the environment variable # `_MINIO_LDAP_TEST_SERVER`.
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Sat May 18 18:19:01 UTC 2024 - 3.4K bytes - Viewed (0)