Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 134 for fwrite (3.65 sec)

  1. cmd/local-locker_gen.go

    		return
    	}
    	err = en.WriteBool(z.Writer)
    	if err != nil {
    		err = msgp.WrapError(err, "Writer")
    		return
    	}
    	// write "UID"
    	err = en.Append(0xa3, 0x55, 0x49, 0x44)
    	if err != nil {
    		return
    	}
    	err = en.WriteString(z.UID)
    	if err != nil {
    		err = msgp.WrapError(err, "UID")
    		return
    	}
    	// write "Timestamp"
    	err = en.Append(0xa9, 0x54, 0x69, 0x6d, 0x65, 0x73, 0x74, 0x61, 0x6d, 0x70)
    	if err != nil {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Mar 21 17:21:35 GMT 2024
    - 13.8K bytes
    - Viewed (0)
  2. internal/grid/connection.go

    		}
    		mid.respMu.Lock()
    		resp(mid.closed)
    		mid.respMu.Unlock()
    	}
    }
    
    // wsWriter writes websocket messages.
    type wsWriter struct {
    	tmp [ws.MaxHeaderSize]byte
    }
    
    // writeMessage writes a message to w without allocations.
    func (ww *wsWriter) writeMessage(w io.Writer, s ws.State, op ws.OpCode, p []byte) error {
    	const fin = true
    	var frame ws.Frame
    	if s.ClientSide() {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 42.6K bytes
    - Viewed (0)
  3. cmd/metacache_gen.go

    }
    
    // EncodeMsg implements msgp.Encodable
    func (z *metacache) EncodeMsg(en *msgp.Writer) (err error) {
    	// map header, size 13
    	// write "end"
    	err = en.Append(0x8d, 0xa3, 0x65, 0x6e, 0x64)
    	if err != nil {
    		return
    	}
    	err = en.WriteTime(z.ended)
    	if err != nil {
    		err = msgp.WrapError(err, "ended")
    		return
    	}
    	// write "st"
    	err = en.Append(0xa2, 0x73, 0x74)
    	if err != nil {
    		return
    	}
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Mon Nov 08 18:26:08 GMT 2021
    - 10K bytes
    - Viewed (0)
  4. cmd/background-newdisks-heal-ops_gen.go

    // EncodeMsg implements msgp.Encodable
    func (z *healingTracker) EncodeMsg(en *msgp.Writer) (err error) {
    	// map header, size 25
    	// write "ID"
    	err = en.Append(0xde, 0x0, 0x19, 0xa2, 0x49, 0x44)
    	if err != nil {
    		return
    	}
    	err = en.WriteString(z.ID)
    	if err != nil {
    		err = msgp.WrapError(err, "ID")
    		return
    	}
    	// write "PoolIndex"
    	err = en.Append(0xa9, 0x50, 0x6f, 0x6f, 0x6c, 0x49, 0x6e, 0x64, 0x65, 0x78)
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Wed Feb 28 17:05:40 GMT 2024
    - 21.5K bytes
    - Viewed (0)
  5. src/archive/tar/writer.go

    	"path"
    	"sort"
    	"strings"
    	"time"
    )
    
    // Writer provides sequential writing of a tar archive.
    // [Writer.WriteHeader] begins a new file with the provided [Header],
    // and then Writer can be treated as an io.Writer to supply that file's data.
    type Writer struct {
    	w    io.Writer
    	pad  int64      // Amount of padding to write after current file entry
    	curr fileWriter // Writer for current file entry
    Go
    - Registered: Tue Apr 30 11:13:12 GMT 2024
    - Last Modified: Fri Oct 13 18:36:46 GMT 2023
    - 19.6K bytes
    - Viewed (0)
  6. cmd/metrics-resource.go

    	totalInodes    MetricName = "total_inodes"
    	readsPerSec    MetricName = "reads_per_sec"
    	writesPerSec   MetricName = "writes_per_sec"
    	readsKBPerSec  MetricName = "reads_kb_per_sec"
    	writesKBPerSec MetricName = "writes_kb_per_sec"
    	readsAwait     MetricName = "reads_await"
    	writesAwait    MetricName = "writes_await"
    	percUtil       MetricName = "perc_util"
    	usedInodes     MetricName = "used_inodes"
    
    	// network stats
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Tue Apr 23 23:56:12 GMT 2024
    - 17.4K bytes
    - Viewed (0)
  7. src/bytes/example_test.go

    	buf := bytes.Buffer{}
    	buf.Write([]byte{'h', 'e', 'l', 'l', 'o', ' ', 'w', 'o', 'r', 'l', 'd'})
    	os.Stdout.Write(buf.Bytes())
    	// Output: hello world
    }
    
    func ExampleBuffer_AvailableBuffer() {
    	var buf bytes.Buffer
    	for i := 0; i < 4; i++ {
    		b := buf.AvailableBuffer()
    		b = strconv.AppendInt(b, int64(i), 10)
    		b = append(b, ' ')
    		buf.Write(b)
    	}
    	os.Stdout.Write(buf.Bytes())
    	// Output: 0 1 2 3
    }
    
    Go
    - Registered: Tue Apr 30 11:13:12 GMT 2024
    - Last Modified: Mon Mar 04 15:54:40 GMT 2024
    - 15K bytes
    - Viewed (1)
  8. src/archive/tar/format.go

    //
    // The table's lower portion shows specialized features of each format,
    // such as supported string encodings, support for sub-second timestamps,
    // or support for sparse files.
    //
    // The Writer currently provides no support for sparse files.
    type Format int
    
    // Constants to identify various tar formats.
    const (
    	// Deliberately hide the meaning of constants from public API.
    Go
    - Registered: Tue Apr 30 11:13:12 GMT 2024
    - Last Modified: Fri Oct 13 18:36:46 GMT 2023
    - 11.3K bytes
    - Viewed (0)
  9. src/archive/zip/struct.go

    	creatorFAT    = 0
    	creatorUnix   = 3
    	creatorNTFS   = 11
    	creatorVFAT   = 14
    	creatorMacOSX = 19
    
    	// Version numbers.
    	zipVersion20 = 20 // 2.0
    	zipVersion45 = 45 // 4.5 (reads and writes zip64 archives)
    
    	// Limits for non zip64 files.
    	uint16max = (1 << 16) - 1
    	uint32max = (1 << 32) - 1
    
    	// Extra header IDs.
    	//
    	// IDs 0..31 are reserved for official use by PKWARE.
    Go
    - Registered: Tue Apr 30 11:13:12 GMT 2024
    - Last Modified: Fri Oct 13 18:36:46 GMT 2023
    - 12.1K bytes
    - Viewed (0)
  10. cmd/erasure-metadata.go

    		}
    	}
    	return
    }
    
    // Returns per object readQuorum and writeQuorum
    // readQuorum is the min required disks to read data.
    // writeQuorum is the min required disks to write data.
    func objectQuorumFromMeta(ctx context.Context, partsMetaData []FileInfo, errs []error, defaultParityCount int) (objectReadQuorum, objectWriteQuorum int, err error) {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Sun Apr 28 17:53:50 GMT 2024
    - 19.2K bytes
    - Viewed (1)
Back to top