- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 267 for cgoUse (0.41 sec)
-
pkg/scheduler/framework/interface.go
PercentageOfNodesToScore() *int32 // SetPodNominator sets the PodNominator SetPodNominator(nominator PodNominator) // Close calls Close method of each plugin. Close() error } // Handle provides data and some tools that plugins can use. It is // passed to the plugin factories at the time of plugin initialization. Plugins
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri May 31 15:52:16 UTC 2024 - 35.4K bytes - Viewed (0) -
platforms/core-configuration/configuration-cache/src/integTest/groovy/org/gradle/internal/cc/impl/inputs/undeclared/UndeclaredFileAccess.groovy
String getKotlinExpression() { "FileInputStream(File(\"$filePath\")).close()" } @Override String getJavaExpression() { """ ((Supplier<Object>) () -> { try { new FileInputStream(new File("$filePath")).close(); } catch (IOException e) {
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Sat Jun 08 11:29:25 UTC 2024 - 9.6K bytes - Viewed (0) -
src/net/http/serve_test.go
} t.Cleanup(func() { bresp.Body.Close() }) // Try to cause a race. Canceling the client request will cause the client // transport to close req2.Body. Returning from the server handler will // cause the server to close req.Body. Since they are the same underlying // ReadCloser, that will result in concurrent calls to Close (and possibly a // Read concurrent with a Close). if mode == http2Mode {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Jun 07 17:57:01 UTC 2024 - 202K bytes - Viewed (0) -
src/net/http/transport_test.go
tests := []struct { disableKeepAlives bool close bool }{ {disableKeepAlives: false, close: false}, {disableKeepAlives: false, close: true}, {disableKeepAlives: true, close: false}, {disableKeepAlives: true, close: true}, } for _, tc := range tests { t.Run(fmt.Sprintf("DisableKeepAlive=%v,RequestClose=%v", tc.disableKeepAlives, tc.close), func(t *testing.T) {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu Jun 06 21:59:21 UTC 2024 - 192.6K bytes - Viewed (0) -
platforms/core-configuration/configuration-cache/src/main/kotlin/org/gradle/internal/cc/impl/problems/ConfigurationCacheReport.kt
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Sat Jun 08 11:29:30 UTC 2024 - 11.4K bytes - Viewed (0) -
cmd/object-api-utils.go
cleanUpFns: cFns, } return r, nil } } return fn, off, length, nil } // Close - calls the cleanup actions in reverse order func (g *GetObjectReader) Close() error { if g == nil { return nil } // sync.Once is used here to ensure that Close() is // idempotent. g.once.Do(func() { for i := len(g.cleanUpFns) - 1; i >= 0; i-- { g.cleanUpFns[i]() } })
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Tue Jun 11 03:13:30 UTC 2024 - 36.3K bytes - Viewed (0) -
platforms/core-runtime/base-services/src/main/java/org/gradle/internal/classloader/TransformReplacer.java
if (closed) { // This replacer was closed while setting up a loader. // The transformLoader might be inserted into the loaders map after close(), so let's close it for sure to // avoid leaks. IoActions.closeQuietly(transformLoader); // Throw the exception so the caller doesn't see the obviously closed loader.
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue Jun 11 09:51:15 UTC 2024 - 12.7K bytes - Viewed (0) -
staging/src/k8s.io/apimachinery/pkg/watch/watch.go
// errors and needs to stop the watch prematurely, it should instead send // an error event and close the result channel. Stop() // ResultChan returns a channel which will receive events from the event // producer. If an error occurs or Stop() is called, the producer must // close this channel and release any resources used by the watch. // Closing the result channel tells the consumer that no more events will be
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 12 20:06:22 UTC 2024 - 8.1K bytes - Viewed (1) -
src/net/http/server.go
// onceCloseListener wraps a net.Listener, protecting it from // multiple Close calls. type onceCloseListener struct { net.Listener once sync.Once closeErr error } func (oc *onceCloseListener) Close() error { oc.once.Do(oc.close) return oc.closeErr } func (oc *onceCloseListener) close() { oc.closeErr = oc.Listener.Close() } // globalOptionsHandler responds to "OPTIONS *" requests.
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Jun 07 17:57:01 UTC 2024 - 123.4K bytes - Viewed (0) -
src/crypto/tls/handshake_server_test.go
Client(c, testConfig).sendAlert(alertUnknownCA) c.Close() }() err := Server(s, testConfig).Handshake() s.Close() var opErr *net.OpError if !errors.As(err, &opErr) || opErr.Err != error(alertUnknownCA) { t.Errorf("Got error: %s; expected: %s", err, error(alertUnknownCA)) } } func TestClose(t *testing.T) { c, s := localPipe(t) go c.Close() err := Server(s, testConfig).Handshake()
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Jun 03 14:56:25 UTC 2024 - 64.7K bytes - Viewed (0)