- Sort Score
- Result 10 results
- Languages All
Results 51 - 60 of 114 for closeFn (2.19 sec)
-
src/encoding/pem/pem.go
} } var breaker lineBreaker breaker.out = out b64 := base64.NewEncoder(base64.StdEncoding, &breaker) if _, err := b64.Write(b.Bytes); err != nil { return err } b64.Close() breaker.Close() if _, err := out.Write(pemEnd[1:]); err != nil { return err } _, err := out.Write([]byte(b.Type + "-----\n")) return err } // EncodeToMemory returns the PEM encoding of b. //
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 23 01:00:11 UTC 2024 - 7.6K bytes - Viewed (0) -
src/vendor/golang.org/x/net/nettest/nettest.go
ipv4Enabled = true } if ln, err := net.Listen("tcp4", "127.0.0.1:0"); err == nil { ln.Close() canListenTCP4OnLoopback = true } if _, err := RoutedInterface("ip6", net.FlagUp); err == nil { ipv6Enabled = true } if ln, err := net.Listen("tcp6", "[::1]:0"); err == nil { ln.Close() canListenTCP6OnLoopback = true } rawSocketSess = supportsRawSocket() switch runtime.GOOS { case "aix":
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Jun 04 16:19:04 UTC 2024 - 8.5K bytes - Viewed (0) -
internal/event/target/webhook.go
return store.ErrNotConnected } return err } // Delete the event from store. return target.store.Del(key.Name) } // Close - does nothing and available for interface compatibility. func (target *WebhookTarget) Close() error { target.cancel() return nil } func (target *WebhookTarget) init() error { return target.initOnce.Do(target.initWebhook) }
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 8.5K bytes - Viewed (0) -
api/maven-api-core/src/main/java/org/apache/maven/api/Type.java
*/ String BOM = "bom"; /** * Artifact type name for a JAR file that can be placed either on the class-path or on the module-path. * The path (classes or modules) is chosen by the plugin, possibly using heuristic rules. * This is the behavior of Maven 3. */ String JAR = "jar"; /** * Artifact type name for a fat-JAR file that can be only on the class-path.
Registered: Wed Jun 12 09:55:16 UTC 2024 - Last Modified: Mon May 13 09:53:45 UTC 2024 - 6.4K bytes - Viewed (0) -
platforms/core-runtime/base-services/src/main/java/org/gradle/internal/classloader/VisitableURLClassLoader.java
} errorHandler.exitClassLoadingScope(); return loadedClass; } @Override public void close() throws IOException { IoActions.closeQuietly(replacer); super.close(); } }
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue Jun 11 09:51:15 UTC 2024 - 6.5K bytes - Viewed (0) -
src/cmd/go/testdata/script/telemetry.txt
# counter has been written per script tests. # Run go before unsetting TEST_TELEMETRY_DIR to make the tests happy. # We want to unset it so the environment we're testing is as close # to a user's environment. go help telemetry env TEST_TELEMETRY_DIR= # Set userconfig dir, which is determined by os.UserConfigDir. # The telemetry dir is determined using that. mkdir $WORK/userconfig
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 16 20:16:39 UTC 2024 - 1.5K bytes - Viewed (0) -
src/cmd/trace/testdata/mktests.go
} // Create file. f, err := os.Create(fmt.Sprintf("./go1%d.test", version.Current)) if err != nil { log.Fatalf("creating output file: %v", err) } defer f.Close() // Write out the trace. r, err := raw.NewReader(&trace) if err != nil { log.Fatalf("reading trace: %v", err) } w, err := raw.NewTextWriter(f, version.Current) for { ev, err := r.ReadEvent()
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri May 17 18:48:18 UTC 2024 - 1.2K bytes - Viewed (0) -
pkg/util/tail/tail.go
// allocate up to max bytes. func ReadAtMost(path string, max int64) ([]byte, bool, error) { f, err := os.Open(path) if err != nil { return nil, false, err } defer f.Close() fi, err := f.Stat() if err != nil { return nil, false, err } size := fi.Size() if size == 0 { return nil, false, nil } if size < max { max = size }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu May 30 13:13:22 UTC 2024 - 1.3K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/io/IoTestCase.java
byte[] buf = new byte[4096]; for (int read = in.read(buf); read != -1; read = in.read(buf)) { out.write(buf, 0, read); } } finally { out.close(); } } finally { in.close(); } } @CanIgnoreReturnValue private boolean delete(File file) { if (file.isDirectory()) { File[] files = file.listFiles(); if (files != null) {
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Fri May 31 12:36:13 UTC 2024 - 5.6K bytes - Viewed (0) -
cni/pkg/log/uds.go
}() go func() { <-stop if err := l.loggingServer.Close(); err != nil { log.Errorf("CNI log server terminated with error: %v", err) } else { log.Debug("CNI log server terminated") } }() return nil } func (l *UDSLogger) handleLog(w http.ResponseWriter, req *http.Request) { if req.Body == nil { return } defer req.Body.Close() data, err := io.ReadAll(req.Body) if err != nil {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Jun 12 16:26:28 UTC 2024 - 4.7K bytes - Viewed (0)