- Sort Score
- Result 10 results
- Languages All
Results 91 - 100 of 975 for writeMsg (0.16 sec)
-
pkg/channels/unbounded_test.go
wg.Wait() if !reflect.DeepEqual(reads, wantReads) { t.Errorf("reads: %#v, wantReads: %#v", reads, wantReads) } } // TestMultipleWriters starts multiple writers and one reader goroutine and // makes sure that the reader gets all the data written by all writers. func TestMultipleWriters(t *testing.T) { ub := NewUnbounded[int]() reads := []int{} var wg sync.WaitGroup wg.Add(1) go func() { defer wg.Done()
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Aug 31 19:53:39 UTC 2022 - 2.3K bytes - Viewed (0) -
pkg/kubelet/util/ioutils/ioutils.go
// applied to the writer interface. // LimitWriter returns a Writer that writes to w // but stops with EOF after n bytes. // The underlying implementation is a *LimitedWriter. func LimitWriter(w io.Writer, n int64) io.Writer { return &LimitedWriter{w, n} } // A LimitedWriter writes to W but limits the amount of // data returned to just N bytes. Each call to Write
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Jan 16 12:00:49 UTC 2023 - 1.5K bytes - Viewed (0) -
src/cmd/internal/test2json/test2json.go
) // NewConverter returns a "test to json" converter. // Writes on the returned writer are written as JSON to w, // with minimal delay. // // The writes to w are whole JSON events ending in \n, // so that it is safe to run multiple tests writing to multiple converters // writing to a single underlying output stream w. // As long as the underlying output w can handle concurrent writes // from multiple goroutines, the result will be a JSON stream
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed Nov 09 17:33:07 UTC 2022 - 14.5K bytes - Viewed (0) -
docs/contribute/concurrency.md
Framing rules make it impractical to implement http/2 correctly on a single blocking thread. The flow-control features introduce feedback between reads and writes, requiring writes to acknowledge reads and reads to throttle writes. In OkHttp we expose a blocking API over a framed protocol. This document explains the code and policy that makes that work. ### Threads #### Application's calling thread
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Sun Feb 06 16:35:36 UTC 2022 - 7K bytes - Viewed (0) -
cmd/kubeadm/app/phases/certs/certlist.go
return err } csr, key, err := pkiutil.NewCSRAndKey(cfg) if err != nil { return err } err = pkiutil.WriteKey(certDir, name, key) if err != nil { return err } return pkiutil.WriteCSR(certDir, name, csr) } // CreateDefaultKeysAndCSRFiles is used in ExternalCA mode to create key files // and adjacent CSR files.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed May 01 16:01:49 UTC 2024 - 15.8K bytes - Viewed (0) -
internal/s3select/simdj/reader_amd64_test.go
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Mon Sep 19 18:05:16 UTC 2022 - 3.9K bytes - Viewed (0) -
tensorflow/compiler/mlir/tensorflow/transforms/tpu_resource_read_for_write.cc
}; // Helper struct holding a resource value and its associated type. struct ResourceValueAndSubtype { Value resource; Type subtype; }; // Finds resource handle and type for result if result writes to a resource. ResourceValueAndSubtype GetResourceWriteResult( tf_device::ClusterFuncOp cluster_func, Value result) { ResourceValueAndSubtype resource; if (!result.hasOneUse()) return resource;
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Thu May 02 16:54:40 UTC 2024 - 5.4K bytes - Viewed (0) -
src/cmd/link/internal/ld/outbuf.go
} out.off += int64(n) } // WriteStringN writes the first n bytes of s. // If n is larger than len(s) then it is padded with zero bytes. func (out *OutBuf) WriteStringN(s string, n int) { out.WriteStringPad(s, n, zeros[:]) } // WriteStringPad writes the first n bytes of s. // If n is larger than len(s) then it is padded with the bytes in pad (repeated as needed).
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue May 17 19:51:29 UTC 2022 - 8.1K bytes - Viewed (0) -
android/guava/src/com/google/common/io/CharSink.java
Writer writer = openStream(); return (writer instanceof BufferedWriter) ? (BufferedWriter) writer : new BufferedWriter(writer); } /** * Writes the given character sequence to this sink. * * @throws IOException if an I/O error while writing to this sink */ public void write(CharSequence charSequence) throws IOException { checkNotNull(charSequence);
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Tue Feb 28 20:13:02 UTC 2023 - 6.1K bytes - Viewed (0) -
src/cmd/go/internal/work/cover.go
return werr } // WriteCoverMetaFilesFile writes out a summary file ("meta-files // file") as part of the action function for the "writeCoverMeta" // pseudo action employed during "go test -coverpkg" runs where there // are multiple tests and multiple packages covered. It builds up a // table mapping package import path to meta-data file fragment and // writes it out to a file where it can be read by the various test
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu Oct 19 19:09:38 UTC 2023 - 5.2K bytes - Viewed (0)