- Sort Score
- Result 10 results
- Languages All
Results 41 - 50 of 101 for Write (0.09 sec)
-
android/guava/src/com/google/common/util/concurrent/AbstractFuture.java
*/ Waiter(boolean unused) {} Waiter() { // avoid volatile write, write is made visible by subsequent CAS on waiters field ATOMIC_HELPER.putThread(this, Thread.currentThread()); } // non-volatile write to the next field. Should be made visible by subsequent CAS on waiters // field. void setNext(@CheckForNull Waiter next) {
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Fri Jun 07 22:25:23 UTC 2024 - 63.1K bytes - Viewed (1) -
guava/src/com/google/common/util/concurrent/AbstractFuture.java
*/ Waiter(boolean unused) {} Waiter() { // avoid volatile write, write is made visible by subsequent CAS on waiters field ATOMIC_HELPER.putThread(this, Thread.currentThread()); } // non-volatile write to the next field. Should be made visible by subsequent CAS on waiters // field. void setNext(@CheckForNull Waiter next) {
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Fri Jun 07 22:25:23 UTC 2024 - 62.8K bytes - Viewed (1) -
src/cmd/compile/internal/ppc64/ssa.go
ld = ppc64.ALWAR st = ppc64.ASTWCCC } r0 := v.Args[0].Reg() r1 := v.Args[1].Reg() // LWSYNC - Assuming shared data not write-through-required nor // caching-inhibited. See Appendix B.2.2.2 in the ISA 2.07b. plwsync := s.Prog(ppc64.ALWSYNC) plwsync.To.Type = obj.TYPE_NONE // LBAR or LWAR p := s.Prog(ld)
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed May 22 19:59:38 UTC 2024 - 55.4K bytes - Viewed (0) -
cmd/erasure-object.go
} if freeVersionID != "" { metaArr[index].SetTierFreeVersionID(freeVersionID) } if freeVersionMarker { metaArr[index].SetTierFreeVersion() } } } // Write unique `xl.meta` for each disk. if _, err = writeUniqueFileInfo(ctx, onlineDisks, "", srcBucket, srcObject, metaArr, writeQuorum); err != nil { return oi, toObjectErr(err, srcBucket, srcObject) }
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Mon Jun 10 15:51:27 UTC 2024 - 78.6K bytes - Viewed (0) -
src/cmd/dist/test.go
testNames map[string]bool timeoutScale int worklist []*work } // work tracks command execution for a test. type work struct { dt *distTest // unique test name, etc. cmd *exec.Cmd // must write stdout/stderr to out flush func() // if non-nil, called after cmd.Run start chan bool // a true means to start, a false means to skip out bytes.Buffer // combined stdout/stderr from cmd
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon May 20 16:01:35 UTC 2024 - 50K bytes - Viewed (0) -
src/crypto/tls/common.go
func (c *Config) initLegacySessionTicketKeyRLocked() { // Don't write if SessionTicketKey is already defined as our deprecated string, // or if it is defined by the user but sessionTicketKeys is already set. if c.SessionTicketKey != [32]byte{} && (bytes.HasPrefix(c.SessionTicketKey[:], deprecatedSessionTicketKey) || len(c.sessionTicketKeys) > 0) { return } // We need to write some data, so get an exclusive lock and re-check any conditions.
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 23 03:10:12 UTC 2024 - 59.1K bytes - Viewed (0) -
src/cmd/cgo/gcc.go
if *debugGcc { fmt.Fprintf(os.Stderr, "$ %s <<EOF\n", strings.Join(args, " ")) os.Stderr.Write(stdin) fmt.Fprint(os.Stderr, "EOF\n") } stdout, stderr, ok := run(stdin, args) if *debugGcc { os.Stderr.Write(stdout) os.Stderr.Write(stderr) } if !ok { os.Stderr.Write(stderr) os.Exit(2) } return string(stdout), string(stderr) }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon May 20 15:50:06 UTC 2024 - 97K bytes - Viewed (0) -
docs/metrics/prometheus/grafana/minio-dashboard.json
"fullMetaSearch": false, "hide": false, "includeNullMetadata": true, "instant": false, "legendFormat": "Pool {{pool}} / Set {{set}} - Write Quorum", "range": true, "refId": "C", "useBackend": false }, { "datasource": { "type": "prometheus",
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Mon Apr 15 10:03:01 UTC 2024 - 93K bytes - Viewed (0) -
src/net/http/fs_test.go
} res.Body.Close() } type gzipResponseWriter struct { ResponseWriter w *gzip.Writer } func (grw gzipResponseWriter) Write(b []byte) (int, error) { return grw.w.Write(b) } func (grw gzipResponseWriter) Flush() { grw.w.Flush() if fw, ok := grw.ResponseWriter.(http.Flusher); ok { fw.Flush() } } // Issue 63769
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed May 15 23:39:44 UTC 2024 - 49.9K bytes - Viewed (0) -
src/crypto/tls/handshake_messages.go
if msgWithOrig, ok := msg.(handshakeMessageWithOriginalBytes); ok { if orig := msgWithOrig.originalBytes(); orig != nil { h.Write(msgWithOrig.originalBytes()) return nil } } data, err := msg.marshal() if err != nil { return err } h.Write(data) return nil
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 23 03:10:12 UTC 2024 - 51.8K bytes - Viewed (0)