- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 1,606 for cgoUse (0.13 sec)
-
src/cmd/compile/internal/types2/issues_test.go
var _ syscall.Errno func _Cgo_ptr(ptr unsafe.Pointer) unsafe.Pointer { return ptr } //go:linkname _Cgo_always_false runtime.cgoAlwaysFalse var _Cgo_always_false bool //go:linkname _Cgo_use runtime.cgoUse func _Cgo_use(interface{}) type _Ctype_int int32 type _Ctype_struct_layout struct { field _Ctype_int } type _Ctype_void [0]byte //go:linkname _cgo_runtime_cgocall runtime.cgocall
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 30 19:19:55 UTC 2024 - 28.1K bytes - Viewed (0) -
src/go/types/issues_test.go
var _ syscall.Errno func _Cgo_ptr(ptr unsafe.Pointer) unsafe.Pointer { return ptr } //go:linkname _Cgo_always_false runtime.cgoAlwaysFalse var _Cgo_always_false bool //go:linkname _Cgo_use runtime.cgoUse func _Cgo_use(interface{}) type _Ctype_int int32 type _Ctype_struct_layout struct { field _Ctype_int } type _Ctype_void [0]byte //go:linkname _cgo_runtime_cgocall runtime.cgocall
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 30 19:19:55 UTC 2024 - 28.1K bytes - Viewed (0) -
pkg/kubelet/cm/topologymanager/policy.go
// // For case (3c), we know that *both* the current bestHint and the // candidate hint are less than bestNonPreferredAffinityCount, so we // want to choose one that brings us back up as close to // bestNonPreferredAffinityCount as possible. There are three cases to // consider here: // // 3ca. candidate.NUMANodeAffinity.Count() > current.NUMANodeAffinity.Count()
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Nov 03 09:45:25 UTC 2022 - 12.7K bytes - Viewed (0) -
src/io/io_test.go
wt.writeToCalled = true return wt.Buffer.WriteTo(w) } // It's preferable to choose WriterTo over ReaderFrom, since a WriterTo can issue one large write, // while the ReaderFrom must read until EOF, potentially allocating when running out of buffer. // Make sure that we choose WriterTo when both are implemented. func TestCopyPriority(t *testing.T) { rb := new(writeToChecker) wb := new(bytes.Buffer)
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Oct 09 22:04:41 UTC 2023 - 18.9K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/storage/cacher/cache_watcher.go
c.stopped = true // stop without draining the input channel was requested. if !c.drainInputBuffer { close(c.done) } close(c.input) } // Even if the watcher was already stopped, if it previously was // using draining mode and it's not using it now we need to // close the done channel now. Otherwise we could leak the // processing goroutine if it will be trying to put more objects
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Aug 24 12:22:41 UTC 2023 - 18.7K bytes - Viewed (0) -
pkg/test/echo/server/endpoint/http.go
if err != nil { epLog.Errorf("readiness failed for endpoint %s: %v", url, err) } else { epLog.Infof("ready for HTTP endpoint %s", url) } } func (s *httpInstance) Close() error { if s.server != nil { return s.server.Close() } return nil } type httpHandler struct { Config } // Imagine a pie of different flavors. // The flavors are the HTTP response codes.
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue May 23 16:20:31 UTC 2023 - 12.8K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/internal/ws/RealWebSocketTest.kt
server.listener.assertExhausted() server.source.close() client.source.close() taskFaker.runTasks() server.webSocket!!.tearDown() client.webSocket!!.tearDown() taskFaker.close() } @Test fun close() { client.webSocket!!.close(1000, "Hello!") // This will trigger a close response. assertThat(server.processNextFrame()).isFalse()
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Thu Apr 11 01:59:58 UTC 2024 - 18.5K bytes - Viewed (0) -
platforms/core-execution/persistent-cache/src/test/groovy/org/gradle/cache/internal/LockOnDemandCrossProcessCacheAccessTest.groovy
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue Apr 16 15:49:51 UTC 2024 - 21.8K bytes - Viewed (0) -
src/net/sendfile_test.go
} } func TestSendfile(t *testing.T) { ln := newLocalListener(t, "tcp") defer ln.Close() errc := make(chan error, 1) go func(ln Listener) { // Wait for a connection. conn, err := ln.Accept() if err != nil { errc <- err close(errc) return } go func() { defer close(errc) defer conn.Close() f, err := os.Open(newton) if err != nil { errc <- err return
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Apr 26 18:12:56 UTC 2024 - 12.1K bytes - Viewed (0) -
src/net/unixsock_test.go
f.Close() checkExists(t, "after File close") l1.Close() checkExists(t, "after FileListener close") l.Close() checkNotExists(t, "after Listener close") }) // Only first call to l.Close should remove. t.Run("SecondClose", func(t *testing.T) { l := listen(t) checkExists(t, "after Listen") l.Close() checkNotExists(t, "after Listener close")
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Sep 18 17:20:52 UTC 2023 - 10.6K bytes - Viewed (0)