- Sort Score
- Result 10 results
- Languages All
Results 41 - 50 of 414 for closeFn (0.37 sec)
-
src/archive/tar/writer.go
if err != nil && err != ErrWriteTooLong { tw.err = err } return n, err } // Close closes the tar archive by flushing the padding, and writing the footer. // If the current file (from a prior call to [Writer.WriteHeader]) is not fully written, // then this returns an error. func (tw *Writer) Close() error { if tw.err == ErrWriteAfterClose { return nil } if tw.err != nil { return tw.err }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 23 01:00:11 UTC 2024 - 19.6K bytes - Viewed (0) -
android/guava/src/com/google/common/io/Files.java
} @Override public byte[] read() throws IOException { Closer closer = Closer.create(); try { FileInputStream in = closer.register(openStream()); return ByteStreams.toByteArray(in, in.getChannel().size()); } catch (Throwable e) { throw closer.rethrow(e); } finally { closer.close(); } } @Override public String toString() {
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Thu Feb 15 16:12:13 UTC 2024 - 33.1K bytes - Viewed (0) -
src/cmd/gofmt/gofmt.go
// backupFile writes data to a new file named filename<number> with permissions perm, // with <number> randomly chosen such that the file name is unique. backupFile returns // the chosen file name. func backupFile(filename string, data []byte, perm fs.FileMode) (string, error) { fdSem <- true defer func() { <-fdSem }() nextRandom := func() string { return strconv.Itoa(rand.Int()) } dir, base := filepath.Split(filename)
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue May 14 19:41:17 UTC 2024 - 15.1K bytes - Viewed (0) -
internal/event/target/nats.go
} // Close - closes underneath connections to NATS server. func (target *NATSTarget) Close() (err error) { close(target.quitCh) if target.stanConn != nil { // closing the streaming connection does not close the provided NATS connection. if target.stanConn.NatsConn() != nil { target.stanConn.NatsConn().Close() } return target.stanConn.Close() } if target.natsConn != nil {
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 12.8K bytes - Viewed (0) -
src/cmd/vendor/rsc.io/markdown/inline.go
process emphasis walk forward in list to find a closer. walk back to find first potential matching opener. if found: strong for length >= 2 insert node drop delimiters between opener and closer remove 1 or 2 from open/close count, removing if now empty if closing has some left, go around again on this node if not:
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Jun 04 16:19:04 UTC 2024 - 21.9K bytes - Viewed (0) -
pilot/pkg/xds/delta.go
} func (s *DiscoveryServer) receiveDelta(con *Connection, identities []string) { defer func() { close(con.deltaReqChan) close(con.ErrorCh()) // Close the initialized channel, if its not already closed, to prevent blocking the stream select { case <-con.InitializedCh(): default: close(con.InitializedCh()) } }() firstRequest := true for { req, err := con.deltaStream.Recv()
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Jun 14 04:34:37 UTC 2024 - 25.6K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/server/options/encryptionconfig/controller/controller_test.go
err: nil, }, }, EncryptionFileContentHash: "anything different", }, nil }, }, { name: "when config is not updated transformers are closed correctly", wantECFileHash: "k8s:enc:unstable:1:6bc9f4aa2e5587afbb96074e1809550cbc4de3cc3a35717dac8ff2800a147fd3", wantLoadCalls: 1, wantHashCalls: 1, wantTransformerClosed: true,
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 16.2K bytes - Viewed (0) -
internal/event/target/kafka.go
Key: sarama.StringEncoder(key), Value: sarama.ByteEncoder(data), }, nil } // Close - closes underneath kafka connection. func (target *KafkaTarget) Close() error { close(target.quitCh) if target.producer != nil { target.producer.Close() return target.client.Close() } return nil } func (target *KafkaTarget) init() error {
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Sat Jun 01 15:02:59 UTC 2024 - 13.1K bytes - Viewed (0) -
platforms/software/dependency-management/src/main/java/org/gradle/api/internal/artifacts/ivyservice/resolveengine/graph/builder/ComponentState.java
*/ Selectable(true), /** * A selected component has been chosen, at some point, as the version to use. * This is not for a lifetime: a component can later be evicted through conflict resolution, * or another compatible component can be chosen instead if more constraints arise. */ Selected(true), /**
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Jun 07 02:21:08 UTC 2024 - 17K 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)