- Sort Score
- Result 10 results
- Languages All
Results 151 - 160 of 2,776 for deer (0.07 sec)
-
src/cmd/compile/internal/test/zerorange_test.go
testZeroRange136(t) } func testZeroRange8(t *testing.T) (r int64) { defer func() { glob = 4 }() globp = &r return } func testZeroRange16(t *testing.T) (r, s int64) { defer func() { glob = 4 }() globp = &r globp = &s return } func testZeroRange32(t *testing.T) (r, s, t2, u int64) { defer func() { glob = 4 }() globp = &r globp = &s globp = &t2 globp = &u
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Apr 01 18:18:07 UTC 2022 - 4.1K bytes - Viewed (0) -
staging/src/k8s.io/apimachinery/pkg/watch/watch.go
func (f *FakeWatcher) Stop() { f.Lock() defer f.Unlock() if !f.stopped { klog.V(4).Infof("Stopping fake watcher.") close(f.result) f.stopped = true } } func (f *FakeWatcher) IsStopped() bool { f.Lock() defer f.Unlock() return f.stopped } // Reset prepares the watcher to be reused. func (f *FakeWatcher) Reset() { f.Lock() defer f.Unlock() f.stopped = false
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 12 20:06:22 UTC 2024 - 8.1K bytes - Viewed (1) -
pkg/kubelet/status/state/state_mem.go
s.RLock() defer s.RUnlock() alloc, ok := s.podAllocation[podUID][containerName] return alloc.DeepCopy(), ok } func (s *stateMemory) GetPodResourceAllocation() PodResourceAllocation { s.RLock() defer s.RUnlock() return s.podAllocation.Clone() } func (s *stateMemory) GetPodResizeStatus(podUID string) (v1.PodResizeStatus, bool) { s.RLock() defer s.RUnlock()
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Feb 24 18:21:21 UTC 2023 - 4K bytes - Viewed (0) -
src/net/unixsock_test.go
} c1.SetReadDeadline(time.Now().Add(100 * time.Millisecond)) var peer Addr if genericRead { _, err = c1.(Conn).Read(nil) } else { _, peer, err = c1.ReadFrom(nil) } switch err { case nil: // ReadFrom succeeds if peer != nil { // peer is connected-mode t.Fatalf("unexpected peer address: %v", peer) } default: // Read may timeout, it depends on the platform
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Sep 18 17:20:52 UTC 2023 - 10.6K bytes - Viewed (0) -
src/net/http/httputil/persist.go
// Ensure pipeline order sc.pipe.StartResponse(id) defer sc.pipe.EndResponse(id) sc.mu.Lock() if sc.we != nil { defer sc.mu.Unlock() return sc.we } if sc.c == nil { // connection closed by user in the meantime defer sc.mu.Unlock() return ErrClosed } c := sc.c if sc.nread <= sc.nwritten { defer sc.mu.Unlock() return errors.New("persist server pipe count") }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed Jan 10 03:29:50 UTC 2024 - 11.1K bytes - Viewed (0) -
src/database/sql/sql_test.go
db := newTestDB(t, "people") defer closeDB(t, db) tx, err := db.Begin() if err != nil { t.Fatal(err) } defer tx.Rollback() r1, err := tx.Query("SELECT|people|name|") if err != nil { t.Fatal(err) } defer r1.Close() r2, err := tx.Query("SELECT|people|name|") if err != nil { t.Fatal(err) } defer r2.Close() }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 23 18:42:28 UTC 2024 - 111.6K bytes - Viewed (0) -
staging/src/k8s.io/apimachinery/pkg/util/runtime/runtime_test.go
"strings" "sync" "testing" "time" ) func TestHandleCrash(t *testing.T) { defer func() { if x := recover(); x == nil { t.Errorf("Expected a panic to recover from") } }() defer HandleCrash() panic("Test Panic") } func TestCustomHandleCrash(t *testing.T) { old := PanicHandlers defer func() { PanicHandlers = old }() var result interface{}
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Mar 26 16:28:45 UTC 2024 - 4.5K bytes - Viewed (0) -
src/net/file_test.go
c := newLocalPacketListener(t, tt.network) defer c.Close() network = c.LocalAddr().Network() address = c.LocalAddr().String() default: handler := func(ls *localServer, ln Listener) { c, err := ln.Accept() if err != nil { return } defer c.Close() var b [1]byte c.Read(b[:]) } ls := newLocalServer(t, tt.network) defer ls.teardown()
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Sep 18 17:20:52 UTC 2023 - 6.4K bytes - Viewed (0) -
pkg/registry/core/event/storage/storage_test.go
} func TestDelete(t *testing.T) { storage, server := newStorage(t) defer server.Terminate(t) defer storage.Store.DestroyFunc() test := genericregistrytest.New(t, storage.Store) test.TestDelete(validNewEvent(test.TestNamespace())) } func TestShortNames(t *testing.T) { storage, server := newStorage(t) defer server.Terminate(t) defer storage.Store.DestroyFunc() expected := []string{"ev"}
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jul 01 14:50:28 UTC 2020 - 3.4K bytes - Viewed (0) -
pkg/kube/multicluster/clusterstore.go
c.Lock() defer c.Unlock() if _, ok := c.remoteClusters[secretKey]; !ok { c.remoteClusters[secretKey] = make(map[cluster.ID]*Cluster) } c.remoteClusters[secretKey][clusterID] = value c.clusters.Insert(string(clusterID)) } func (c *ClusterStore) Delete(secretKey string, clusterID cluster.ID) { c.Lock() defer c.Unlock() delete(c.remoteClusters[secretKey], clusterID)
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Jun 07 15:01:12 UTC 2023 - 3.6K bytes - Viewed (0)