- Sort Score
- Result 10 results
- Languages All
Results 41 - 50 of 1,078 for ONCE (0.04 sec)
-
tensorflow/c/eager/c_api_distributed_test.cc
} private: bool first_call_ = true; }; // After the graph pass is registered, it takes effect globally and can affect // other test cases. Define a static variable to switch it on and off. bool GraphErrorInjectionPass::enabled_ = false; // Test to ensure that a registered graph optimization pass is only executed
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Thu Feb 15 09:49:45 UTC 2024 - 23.5K bytes - Viewed (0) -
pilot/pkg/model/jwks_resolver_test.go
in: []string{"testIssuer", mockCertURL}, expectedJwtPubkey: test.JwtPubKey1, }, { in: []string{"testIssuer", mockCertURL}, // Send two same request, mock server is expected to hit only once because of the cache. expectedJwtPubkey: test.JwtPubKey1, }, } for _, c := range cases { pk, err := r.GetPublicKey(c.in[0], c.in[1], testRequestTimeout) if err != nil {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Feb 23 09:47:21 UTC 2024 - 19.2K bytes - Viewed (0) -
src/strings/replace.go
package strings import ( "io" "sync" ) // Replacer replaces a list of strings with replacements. // It is safe for concurrent use by multiple goroutines. type Replacer struct { once sync.Once // guards buildOnce method r replacer oldnew []string } // replacer is the interface that a replacement algorithm needs to implement. type replacer interface { Replace(s string) string
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Oct 13 17:10:31 UTC 2023 - 14.5K bytes - Viewed (0) -
guava/src/com/google/common/util/concurrent/AbstractService.java
* #notifyFailed(Throwable)} instead. * * <p>This method should return promptly; prefer to do work on a different thread where it is * convenient. It is invoked exactly once on service startup, even when {@link #startAsync} is * called multiple times. */ @ForOverride protected abstract void doStart(); /**
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Fri May 12 18:32:03 UTC 2023 - 20.7K bytes - Viewed (0) -
cni/pkg/nodeagent/informers_test.go
Spec: corev1.PodSpec{ NodeName: NodeName, }, Status: corev1.PodStatus{ PodIP: "11.1.1.12", }, } ns := &corev1.Namespace{ ObjectMeta: metav1.ObjectMeta{Name: "test"}, // TODO: once we if the add pod bug, re-enable this and remove the patch below // Labels: map[string]string{constants.DataplaneModeLabel: constants.DataplaneModeAmbient}, } client := kube.NewFakeClient(ns, pod)
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 06 05:10:23 UTC 2024 - 22.2K bytes - Viewed (0) -
hack/make-rules/test.sh
# support collecting coverage across multiple packages at once, so we must issue # separate 'go test' commands for each package and then combine at the end. # To speed things up considerably, we can at least use xargs -P to run multiple # 'go test' commands at once. # To properly parse the test results if generating a JUnit test report, we
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat Mar 02 22:40:10 UTC 2024 - 10.8K bytes - Viewed (0) -
internal/event/target/amqp.go
"encoding/json" "errors" "fmt" "net" "net/url" "os" "path/filepath" "sync" "github.com/minio/minio/internal/event" "github.com/minio/minio/internal/logger" "github.com/minio/minio/internal/once" "github.com/minio/minio/internal/store" xnet "github.com/minio/pkg/v3/net" "github.com/rabbitmq/amqp091-go" ) // AMQPArgs - AMQP target arguments. type AMQPArgs struct {
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 10K bytes - Viewed (0) -
src/syscall/syscall_linux_test.go
// is to race thread creation with v.fn(want) // being executed. Via the once boolean we // also encourage one in 5 waiters to return // locked after participating in only one // question response sequence. This allows the // test to race thread destruction too. once := routines%5 == 4 go waiter(question, response, once) // Keep a count of how many goroutines are // going to participate in the
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 23 01:00:11 UTC 2024 - 23K bytes - Viewed (0) -
pkg/kubelet/container/helpers.go
name = fmt.Sprintf("%s-%s-%s:%d:%d", family, p.Protocol, p.HostIP, p.ContainerPort, p.HostPort) } // Protect against a port name being used more than once in a container. if _, ok := names[name]; ok { klog.InfoS("Port name conflicted, it is defined more than once", "portName", name) continue } ports = append(ports, pm) names[name] = struct{}{} } return }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 04 06:25:43 UTC 2024 - 14.3K bytes - Viewed (0) -
android/guava/src/com/google/common/collect/ImmutableMap.java
* Returns a newly-created immutable map, using the last value for any key that was added more * than once. The iteration order of the returned map is the order in which entries were * inserted into the builder, unless {@link #orderEntriesByValue} was called, in which case * entries are sorted by value. If a key was added more than once, it appears in iteration order
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Sun Jun 02 13:36:19 UTC 2024 - 41.6K bytes - Viewed (0)