- Sort Score
- Result 10 results
- Languages All
Results 151 - 160 of 2,106 for writes (0.19 sec)
-
src/cmd/compile/internal/types2/typestring.go
qf Qualifier ctxt *Context // if non-nil, we are type hashing tparams *TypeParamList // local type parameters paramNames bool // if set, write function parameter names, otherwise, write types only tpSubscripts bool // if set, write type parameter indices as subscripts pkgInfo bool // package-annotate first unexported-type field to avoid confusing type description }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 23 03:01:18 UTC 2024 - 12.2K bytes - Viewed (0) -
cmd/erasure-utils.go
// from subsequent blocks. offset = 0 // We have written all the blocks, write the last remaining block. if write < int64(len(block)) { n, err := dst.Write(block[:write]) if err != nil { return 0, err } totalWritten += int64(n) break } // Copy the block. n, err := dst.Write(block) if err != nil { return 0, err } // Decrement output size.
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Wed Jan 31 02:11:45 UTC 2024 - 3.1K bytes - Viewed (0) -
src/runtime/netpoll_wasip1.go
// accepts one or more subscriptions to FD read or write events. // // Major differences to poll(2): // - the events are not written to the input entries (like pollfd.revents), and // instead are appended to a separate events buffer. poll_oneoff writes zero // or more events to the buffer (at most one per input subscription) and // returns the number of events written. Although the index of the
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed Mar 27 18:23:49 UTC 2024 - 6.1K bytes - Viewed (0) -
staging/src/k8s.io/apimachinery/pkg/runtime/serializer/streaming/streaming.go
} type encoder struct { writer io.Writer encoder runtime.Encoder buf *bytes.Buffer } // NewEncoder returns a new streaming encoder. func NewEncoder(w io.Writer, e runtime.Encoder) Encoder { return &encoder{ writer: w, encoder: e, buf: &bytes.Buffer{}, } } // Encode writes the provided object to the nested writer. func (e *encoder) Encode(obj runtime.Object) error {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Aug 25 14:51:36 UTC 2023 - 3.7K bytes - Viewed (0) -
internal/deadlineconn/deadlineconn.go
func (c *DeadlineConn) Read(b []byte) (n int, err error) { c.setReadDeadline() n, err = c.Conn.Read(b) return n, err } // Write - writes data to the connection. func (c *DeadlineConn) Write(b []byte) (n int, err error) { c.setWriteDeadline() n, err = c.Conn.Write(b) return n, err } // WithReadDeadline sets a new read side net.Conn deadline.
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Wed May 22 23:07:14 UTC 2024 - 2.3K bytes - Viewed (0) -
src/cmd/vendor/golang.org/x/text/unicode/norm/readwriter.go
func (w *normWriter) Close() error { if len(w.buf) > 0 { _, err := w.w.Write(w.buf) if err != nil { return err } } return nil } // Writer returns a new writer that implements Write(b) // by writing f(b) to w. The returned writer may use an // internal buffer to maintain state across Write calls. // Calling its Close method writes any buffered data to w.
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed Jan 24 13:01:26 UTC 2024 - 2.9K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/TimeoutFuture.java
* * 1. visibility of the writes to these fields to Fire.run: * * The initial write to delegateRef is made definitely visible via the semantics of * addListener/SES.schedule. The later racy write in cancel() is not guaranteed to be observed, * however that is fine since the correctness is based on the atomic state in our base class. The
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Thu Feb 01 21:46:34 UTC 2024 - 7.7K bytes - Viewed (0) -
platforms/software/dependency-management/src/integTest/groovy/org/gradle/integtests/resolve/locking/MixedDependencyLockingIntegrationTest.groovy
then: outputContains('org:foo:1.0') outputContains('dependency was locked to version \'1.0\'') } def 'writes lock file entries for inherited dependencies'() { mavenRepo.module('org', 'foo', '1.0').publish() mavenRepo.module('org', 'foo', '1.1').publish() buildFile << """ repositories { maven {
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue Oct 10 21:10:11 UTC 2023 - 4.2K bytes - Viewed (0) -
internal/store/queuestore.go
buf.Reset() if err != nil { return err } // Increment the item count. store.entries[key] = time.Now().UnixNano() return nil } // write - writes an item to the directory. func (store *QueueStore[I]) write(key string, item I) error { // Marshalls the item. eventData, err := json.Marshal(item) if err != nil { return err }
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Mon Mar 25 16:44:20 UTC 2024 - 7.1K bytes - Viewed (0) -
cmd/speedtest.go
} if totalGet < throughputHighestGet { // Following check is for situations // when Writes() scale higher than Reads() // - practically speaking this never happens // and should never happen - however it has // been seen recently due to hardware issues // causes Reads() to go slower than Writes(). // // Send such results anyways as this shall // expose a problem underneath.
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Mon May 06 09:45:10 UTC 2024 - 9.2K bytes - Viewed (0)