Search Options

Results per page
Sort
Preferred Languages
Advance

Results 171 - 180 of 199 for reader_r (0.09 sec)

  1. src/cmd/asm/internal/lex/input.go

    	"fmt"
    	"os"
    	"path/filepath"
    	"slices"
    	"strconv"
    	"strings"
    	"text/scanner"
    
    	"cmd/asm/internal/flags"
    	"cmd/internal/objabi"
    	"cmd/internal/src"
    )
    
    // Input is the main input: a stack of readers and some macro definitions.
    // It also handles #include processing (by pushing onto the input stack)
    // and parses and instantiates macro definitions.
    type Input struct {
    	Stack
    	includes        []string
    Registered: Tue Oct 29 11:13:09 UTC 2024
    - Last Modified: Fri Sep 06 13:17:27 UTC 2024
    - 12.5K bytes
    - Viewed (0)
  2. api/go1.9.txt

    pkg encoding/base32, const NoPadding int32
    pkg encoding/base32, const StdPadding = 61
    pkg encoding/base32, const StdPadding int32
    pkg encoding/base32, method (Encoding) WithPadding(int32) *Encoding
    pkg encoding/csv, type Reader struct, ReuseRecord bool
    pkg encoding/json, func Valid([]uint8) bool
    pkg go/ast, type TypeSpec struct, Assign token.Pos
    pkg go/types, func SizesFor(string, string) Sizes
    pkg go/types, method (*TypeName) IsAlias() bool
    Registered: Tue Oct 29 11:13:09 UTC 2024
    - Last Modified: Mon Oct 04 20:20:20 UTC 2021
    - 10.7K bytes
    - Viewed (0)
  3. cmd/object-api-utils.go

    	}
    	p.Reader = encReader
    	p.sealMD5Fn = sealETagFn(*objEncKey)
    	return p, nil
    }
    
    // NewPutObjReader returns a new PutObjReader. It uses given hash.Reader's
    // MD5Current method to construct md5sum when requested downstream.
    func NewPutObjReader(rawReader *hash.Reader) *PutObjReader {
    	return &PutObjReader{Reader: rawReader, rawReader: rawReader}
    }
    
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Thu Aug 08 15:29:58 UTC 2024
    - 37.1K bytes
    - Viewed (0)
  4. cmd/admin-handlers-site-replication.go

    	if err := json.NewEncoder(w).Encode(idpSettings); err != nil {
    		writeErrorResponseJSON(ctx, w, toAdminAPIErr(ctx, err), r.URL)
    		return
    	}
    }
    
    func parseJSONBody(ctx context.Context, body io.Reader, v interface{}, encryptionKey string) error {
    	data, err := io.ReadAll(body)
    	if err != nil {
    		return SRError{
    			Cause: err,
    			Code:  ErrSiteReplicationInvalidRequest,
    		}
    	}
    	if encryptionKey != "" {
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 19.4K bytes
    - Viewed (0)
  5. cmd/xl-storage_test.go

    	w := newStreamingBitrotWriter(storage, "", volName, fileName, size, algo, shardSize)
    	reader := bytes.NewReader(data)
    	for {
    		// Using io.Copy instead of this loop will not work for us as io.Copy
    		// will use bytes.Reader.WriteTo() which will not do shardSize'ed writes
    		// causing error.
    		n, err := reader.Read(shard)
    		w.Write(shard[:n])
    		if err == nil {
    			continue
    		}
    		if err == io.EOF {
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Wed Aug 14 17:11:51 UTC 2024
    - 66.7K bytes
    - Viewed (0)
  6. src/bytes/example_test.go

    	b.Write([]byte("Hello "))
    	fmt.Fprintf(&b, "world!")
    	b.WriteTo(os.Stdout)
    	// Output: Hello world!
    }
    
    func ExampleBuffer_reader() {
    	// A Buffer can turn a string or a []byte into an io.Reader.
    	buf := bytes.NewBufferString("R29waGVycyBydWxlIQ==")
    	dec := base64.NewDecoder(base64.StdEncoding, buf)
    	io.Copy(os.Stdout, dec)
    	// Output: Gophers rule!
    }
    
    func ExampleBuffer_Bytes() {
    	buf := bytes.Buffer{}
    Registered: Tue Oct 29 11:13:09 UTC 2024
    - Last Modified: Wed Aug 07 17:22:36 UTC 2024
    - 14.9K bytes
    - Viewed (0)
  7. istioctl/pkg/tag/tag.go

    	sa := local.NewSourceAnalyzer(analysis.Combine("webhook", &webhook.Analyzer{}), "", resource.Namespace(istioNamespace), nil)
    	if err := sa.AddReaderKubeSource([]local.ReaderSource{{Name: "", Reader: strings.NewReader(wh)}}); err != nil {
    		return err
    	}
    	k, err := kube.NewClient(kube.NewClientConfigForRestConfig(config), "")
    	if err != nil {
    		return err
    	}
    Registered: Wed Oct 30 22:53:10 UTC 2024
    - Last Modified: Mon Jul 22 15:40:30 UTC 2024
    - 16.5K bytes
    - Viewed (0)
  8. cmd/handler-utils.go

    	xnet "github.com/minio/pkg/v3/net"
    )
    
    const (
    	copyDirective    = "COPY"
    	replaceDirective = "REPLACE"
    	accessDirective  = "ACCESS"
    )
    
    // Parses location constraint from the incoming reader.
    func parseLocationConstraint(r *http.Request) (location string, s3Error APIErrorCode) {
    	// If the request has no body with content-length set to 0,
    	// we do not have to validate location constraint. Bucket will
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Mon Jun 10 15:31:51 UTC 2024
    - 15.5K bytes
    - Viewed (0)
  9. api/go1.3.txt

    pkg archive/tar, const TypeGNUSparse = 83
    pkg archive/tar, const TypeGNUSparse ideal-char
    pkg archive/tar, type Header struct, Xattrs map[string]string
    pkg compress/gzip, method (*Reader) Reset(io.Reader) error
    pkg crypto/tls, const CurveP256 = 23
    pkg crypto/tls, const CurveP256 CurveID
    pkg crypto/tls, const CurveP384 = 24
    pkg crypto/tls, const CurveP384 CurveID
    pkg crypto/tls, const CurveP521 = 25
    pkg crypto/tls, const CurveP521 CurveID
    Registered: Tue Oct 29 11:13:09 UTC 2024
    - Last Modified: Mon Jun 02 02:45:00 UTC 2014
    - 117K bytes
    - Viewed (0)
  10. internal/dsync/drwmutex.go

    type DRWMutex struct {
    	Names                []string
    	writeLocks           []string // Array of nodes that granted a write lock
    	readLocks            []string // Array of array of nodes that granted reader locks
    	rng                  *rand.Rand
    	m                    sync.Mutex // Mutex to prevent multiple simultaneous locks from this node
    	clnt                 *Dsync
    	cancelRefresh        context.CancelFunc
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Mon Sep 09 15:49:49 UTC 2024
    - 20.4K bytes
    - Viewed (0)
Back to top