- Sort Score
- Result 10 results
- Languages All
Results 31 - 40 of 818 for gwrite (0.55 sec)
-
doc/go_mem.html
<p> Note that if there are no read-write or write-write data races on memory location <i>x</i>, then any read <i>r</i> on <i>x</i> has only one possible <i>W</i>(<i>r</i>): the single <i>w</i> that immediately precedes it in the happens before order. </p> <p> More generally, it can be shown that any Go program that is data-race-free, meaning it has no program executions with read-write or write-write data races,
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Mar 04 15:54:42 UTC 2024 - 26.6K bytes - Viewed (0) -
internal/ioutil/ioutil.go
// executes at least one write operation if it is closed. // // This can be useful within the context of HTTP. At least // one write operation must happen to send the HTTP headers // to the peer. type WriteOnCloser struct { io.Writer hasWritten bool } func (w *WriteOnCloser) Write(p []byte) (int, error) { w.hasWritten = true return w.Writer.Write(p) }
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Wed May 22 23:07:14 UTC 2024 - 10.2K bytes - Viewed (0) -
staging/src/k8s.io/apimachinery/pkg/util/httpstream/wsstream/conn.go
conn *Conn num byte r io.Reader w io.WriteCloser read, write bool } // newWebsocketChannel creates a pipe for writing to a websocket. Do not write to this pipe // prior to the connection being opened. It may be no, half, or full duplex depending on // read and write. func newWebsocketChannel(conn *Conn, num byte, read, write bool) *websocketChannel { r, w := io.Pipe()
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Mar 04 19:10:30 UTC 2024 - 14.5K bytes - Viewed (0) -
src/crypto/ed25519/ed25519.go
} R := (&edwards25519.Point{}).ScalarBaseMult(r) kh := sha512.New() if domPrefix != domPrefixPure { kh.Write([]byte(domPrefix)) kh.Write([]byte{byte(len(context))}) kh.Write([]byte(context)) } kh.Write(R.Bytes()) kh.Write(publicKey) kh.Write(message) hramDigest := make([]byte, 0, sha512.Size) hramDigest = kh.Sum(hramDigest)
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 23 00:11:18 UTC 2024 - 11.7K bytes - Viewed (0) -
src/text/tabwriter/tabwriter_test.go
var b buffer b.init(1000) var w Writer w.Init(&b, minwidth, tabwidth, padding, padchar, flags) // write all at once title := testname + " (written all at once)" b.clear() write(t, title, &w, src) verify(t, title, &w, &b, src, expected) // write byte-by-byte title = testname + " (written byte-by-byte)" b.clear() for i := 0; i < len(src); i++ { write(t, title, &w, src[i:i+1]) }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu Feb 29 16:46:34 UTC 2024 - 13.8K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/util/proxy/streamtunnel_test.go
assert.Equal(t, expectedHeader, trw.Header(), "") // Validate Write() for delegate response writer. expectedWrite := []byte("this is a test write string") assert.False(t, trw.written, "written field is before Write()") _, err := trw.Write(expectedWrite) assert.NoError(t, err, "No error expected after Write() on tunneling response writer")
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Mar 07 02:21:50 UTC 2024 - 22.7K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/dict/synonym/SynonymFile.java
throw new DictionaryException("Failed to write: " + oldItem + " -> " + item, e); } } public void write(final String line) { try { writer.write(line); writer.write(Constants.LINE_SEPARATOR); } catch (final IOException e) { throw new DictionaryException("Failed to write: " + line, e); } }
Registered: Wed Jun 12 13:08:18 UTC 2024 - Last Modified: Thu Feb 22 01:37:57 UTC 2024 - 12.5K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/util/proxy/streamtunnel.go
// Once Write or WriteHeader is called, Hijack returns an error. // Once Hijack is called, Write, WriteHeader, and Hijack return errors. type tunnelingResponseWriter struct { // w is used to delegate Header(), WriteHeader(), and Write() calls w http.ResponseWriter // conn is returned from Hijack() conn net.Conn // mu guards writes mu sync.Mutex
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Mar 04 19:10:30 UTC 2024 - 14.7K bytes - Viewed (0) -
tensorflow/cc/saved_model/metrics.cc
// across "api_label" is not expected to equal the ".../write/count" cell value // because programs can invoke more than one API to save a single SM and // because the API may error out before successfully writing a SM. auto* saved_model_write_api = monitoring::Counter<1>::New( "/tensorflow/core/saved_model/write/api", "The API used to write the SavedModel.", "api_label");
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Thu Jan 18 23:43:59 UTC 2024 - 13.4K bytes - Viewed (0) -
platforms/core-configuration/configuration-cache/src/main/kotlin/org/gradle/internal/cc/impl/fingerprint/ConfigurationCacheFingerprintWriter.kt
host: Host, private val writer: ScopedFingerprintWriter<ConfigurationCacheFingerprint> ) : Sink(host) { override fun write(value: ConfigurationCacheFingerprint, trace: PropertyTrace?) { writer.write(value, trace) } fun initScripts(initScripts: List<File>) { capturedFiles.addAll(initScripts) write(
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Sat Jun 08 11:29:30 UTC 2024 - 32.8K bytes - Viewed (0)