Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 91 - 100 of 187 for buf2 (0.01 seconds)

  1. cmd/signature-v4.go

    		headers = append(headers, k)
    		vals[k] = vv
    	}
    	sort.Strings(headers)
    
    	var buf bytes.Buffer
    	for _, k := range headers {
    		buf.WriteString(k)
    		buf.WriteByte(':')
    		for idx, v := range vals[k] {
    			if idx > 0 {
    				buf.WriteByte(',')
    			}
    			buf.WriteString(signV4TrimAll(v))
    		}
    		buf.WriteByte('\n')
    	}
    	return buf.String()
    }
    
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Dec 13 22:19:12 GMT 2024
    - 12.4K bytes
    - Click Count (0)
  2. cmd/xl-storage-format-utils.go

    	var fi FileInfo
    	var err error
    	var inData xlMetaInlineData
    	if buf, data, e := isIndexedMetaV2(xlMetaBuf); e != nil {
    		return FileInfo{}, e
    	} else if buf != nil {
    		inData = data
    		fi, err = buf.ToFileInfo(volume, path, versionID, true)
    		if len(buf) != 0 && errors.Is(err, errFileNotFound) {
    			// This special case is needed to handle len(xlMeta.versions) == 0
    			return FileInfo{
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Thu Aug 08 15:29:58 GMT 2024
    - 5.5K bytes
    - Click Count (0)
  3. src/archive/zip/writer.go

    	// The approach here is to write 8 byte sizes if needed without
    	// adding a zip64 extra in the local header (too late anyway).
    	var buf []byte
    	if w.isZip64() {
    		buf = make([]byte, dataDescriptor64Len)
    	} else {
    		buf = make([]byte, dataDescriptorLen)
    	}
    	b := writeBuf(buf)
    	b.uint32(dataDescriptorSignature) // de-facto standard, required by OS X
    	b.uint32(w.CRC32)
    	if w.isZip64() {
    		b.uint64(w.CompressedSize64)
    Created: Tue Dec 30 11:13:12 GMT 2025
    - Last Modified: Tue Jan 28 04:20:09 GMT 2025
    - 19.4K bytes
    - Click Count (0)
  4. cmd/config-common.go

    		}
    
    		return nil, ObjectInfo{}, err
    	}
    	defer r.Close()
    
    	buf, err := io.ReadAll(r)
    	if err != nil {
    		return nil, ObjectInfo{}, err
    	}
    	if len(buf) == 0 {
    		return nil, ObjectInfo{}, errConfigNotFound
    	}
    	return buf, r.ObjInfo, nil
    }
    
    func readConfig(ctx context.Context, store objectIO, configFile string) ([]byte, error) {
    	buf, _, err := readConfigWithMetadata(ctx, store, configFile, ObjectOptions{})
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Mon Sep 18 17:00:54 GMT 2023
    - 3.1K bytes
    - Click Count (0)
  5. internal/http/request-recorder.go

    // RequestRecorder - records the
    // of a given io.Reader
    type RequestRecorder struct {
    	// Data source to record
    	io.Reader
    	// Response body should be logged
    	LogBody bool
    
    	// internal recording buffer
    	buf bytes.Buffer
    	// total bytes read including header size
    	bytesRead int
    }
    
    // Close is a no operation closer
    func (r *RequestRecorder) Close() error {
    	// no-op
    	return nil
    }
    
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Wed Apr 12 21:37:19 GMT 2023
    - 1.8K bytes
    - Click Count (0)
  6. schema/serializer.go

    }
    
    // Value implements serializer interface
    func (GobSerializer) Value(ctx context.Context, field *Field, dst reflect.Value, fieldValue interface{}) (interface{}, error) {
    	buf := new(bytes.Buffer)
    	err := gob.NewEncoder(buf).Encode(fieldValue)
    	return buf.Bytes(), err
    Created: Sun Dec 28 09:35:17 GMT 2025
    - Last Modified: Sun Oct 26 12:29:44 GMT 2025
    - 5.1K bytes
    - Click Count (0)
  7. schema/naming.go

    			if lastCase && (nextCase || nextNumber) {
    				buf.WriteRune(v + 32)
    			} else {
    				if i > 0 && value[i-1] != '_' && value[i+1] != '_' {
    					buf.WriteByte('_')
    				}
    				buf.WriteRune(v + 32)
    			}
    		} else {
    			buf.WriteRune(v)
    		}
    
    		lastCase = curCase
    		curCase = nextCase
    	}
    
    	if curCase {
    		if !lastCase && len(value) > 1 {
    			buf.WriteByte('_')
    		}
    Created: Sun Dec 28 09:35:17 GMT 2025
    - Last Modified: Wed Jun 12 03:46:59 GMT 2024
    - 5.3K bytes
    - Click Count (0)
  8. cmd/perf-tests.go

    }
    
    // Reader to read random data.
    type netperfReader struct {
    	n   uint64
    	eof chan struct{}
    	buf []byte
    }
    
    func (m *netperfReader) Read(b []byte) (int, error) {
    	select {
    	case <-m.eof:
    		return 0, io.EOF
    	default:
    	}
    	n := copy(b, m.buf)
    	atomic.AddUint64(&m.n, uint64(n))
    	return n, nil
    }
    
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 11.8K bytes
    - Click Count (0)
  9. cmd/bucket-replication-metrics.go

    // SMA struct for calculating simple moving average
    type SMA struct {
    	buf       []float64
    	window    int     // len of buf
    	idx       int     // current index in buf
    	CAvg      float64 // cumulative average
    	prevSMA   float64
    	filledBuf bool
    }
    
    func newSMA(ln int) *SMA {
    	if ln <= 0 {
    		ln = defaultWindowSize
    	}
    	return &SMA{
    		buf:    make([]float64, ln),
    		window: ln,
    		idx:    0,
    	}
    }
    
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Thu Aug 15 12:04:40 GMT 2024
    - 14.2K bytes
    - Click Count (0)
  10. cmd/utils.go

    			runtime.GC()
    			var buf bytes.Buffer
    			err := pprof.Lookup("heap").WriteTo(&buf, 0)
    			return buf.Bytes(), err
    		}
    	case madmin.ProfilerBlock:
    		runtime.SetBlockProfileRate(100)
    		prof.stopFn = func() ([]byte, error) {
    			var buf bytes.Buffer
    			err := pprof.Lookup("block").WriteTo(&buf, 0)
    			runtime.SetBlockProfileRate(0)
    			return buf.Bytes(), err
    		}
    	case madmin.ProfilerMutex:
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 33K bytes
    - Click Count (0)
Back to Top