Search Options

Results per page
Sort
Preferred Languages
Advance

Results 31 - 40 of 47 for writeType (0.16 sec)

  1. cmd/streaming-v4-unsigned.go

    	// Read value
    	for {
    		v, err := cr.reader.ReadByte()
    		if err != nil {
    			if err == io.EOF {
    				return io.ErrUnexpectedEOF
    			}
    		}
    		if v != '\r' {
    			valueBuffer.WriteByte(v)
    			continue
    		}
    		// Must end with \r\n\r\n
    		var tmp [3]byte
    		_, err = io.ReadFull(cr.reader, tmp[:])
    		if err != nil {
    			if err == io.EOF {
    				return io.ErrUnexpectedEOF
    			}
    		}
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Sat May 06 02:53:12 UTC 2023
    - 6.1K bytes
    - Viewed (0)
  2. docs/sts/web-identity.go

    	}
    	if len(c.Scopes) > 0 {
    		v.Set("scope", strings.Join(c.Scopes, " "))
    	}
    	v.Set("state", state)
    	v.Set("nonce", state)
    	if strings.Contains(c.Endpoint.AuthURL, "?") {
    		buf.WriteByte('&')
    	} else {
    		buf.WriteByte('?')
    	}
    	buf.WriteString(v.Encode())
    	return buf.String()
    }
    
    func main() {
    	flag.Parse()
    	if clientID == "" {
    		flag.PrintDefaults()
    		return
    	}
    
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Fri May 19 09:13:33 UTC 2023
    - 7.8K bytes
    - Viewed (0)
  3. src/cmd/asm/internal/lex/lex_test.go

    	var buf strings.Builder
    	for {
    		tok := input.Next()
    		if tok == scanner.EOF {
    			return buf.String()
    		}
    		if tok == '#' {
    			continue
    		}
    		if buf.Len() > 0 {
    			buf.WriteByte('.')
    		}
    		buf.WriteString(input.Text())
    	}
    }
    
    type badLexTest struct {
    	input string
    	error string
    }
    
    var badLexTests = []badLexTest{
    	{
    		"3 #define foo bar\n",
    Registered: Tue Oct 29 11:13:09 UTC 2024
    - Last Modified: Tue Aug 29 07:48:38 UTC 2023
    - 5.8K bytes
    - Viewed (0)
  4. cmd/metacache-stream.go

    		blockSize: blockSize,
    	}
    	w.creator = func() error {
    		s2w := s2.NewWriter(out, s2.WriterBlockSize(blockSize), s2.WriterConcurrency(2))
    		w.mw = msgp.NewWriter(s2w)
    		w.creator = nil
    		if err := w.mw.WriteByte(metacacheStreamVersion); err != nil {
    			return err
    		}
    
    		w.closer = func() (err error) {
    			defer func() {
    				cerr := s2w.Close()
    				if err == nil && cerr != nil {
    					err = cerr
    				}
    			}()
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Thu Apr 04 12:04:40 UTC 2024
    - 19.5K bytes
    - Viewed (0)
  5. src/bytes/buffer_test.go

    		n, err := buf.Write(testBytes[0:1])
    		if want := 1; err != nil || n != want {
    			t.Errorf("Write: got (%d, %v), want (%d, %v)", n, err, want, nil)
    		}
    		check(t, "TestBasicOperations (4)", &buf, "a")
    
    		buf.WriteByte(testString[1])
    		check(t, "TestBasicOperations (5)", &buf, "ab")
    
    		n, err = buf.Write(testBytes[2:26])
    		if want := 24; err != nil || n != want {
    			t.Errorf("Write: got (%d, %v), want (%d, %v)", n, err, want, nil)
    Registered: Tue Oct 29 11:13:09 UTC 2024
    - Last Modified: Tue Sep 03 20:55:15 UTC 2024
    - 18.6K bytes
    - Viewed (0)
  6. logger/sql.go

    		var newSQL strings.Builder
    
    		for _, v := range []byte(sql) {
    			if v == '?' {
    				if len(vars) > idx {
    					newSQL.WriteString(vars[idx])
    					idx++
    					continue
    				}
    			}
    			newSQL.WriteByte(v)
    		}
    
    		sql = newSQL.String()
    	} else {
    		sql = numericPlaceholder.ReplaceAllString(sql, "$$$1$$")
    
    		sql = numericPlaceholderRe.ReplaceAllStringFunc(sql, func(v string) string {
    Registered: Sun Oct 27 09:35:08 UTC 2024
    - Last Modified: Thu Mar 21 08:00:02 UTC 2024
    - 5K bytes
    - Viewed (0)
  7. internal/s3select/sql/value.go

    		return fmt.Sprintf("\"%s\":%s", x, v.GetTypeString())
    	case []byte:
    		return fmt.Sprintf("\"%s\":BYTES", string(x))
    	case []Value:
    		var s strings.Builder
    		s.WriteByte('[')
    		for i, v := range x {
    			s.WriteString(v.Repr())
    			if i < len(x)-1 {
    				s.WriteByte(',')
    			}
    		}
    		s.WriteString("]:ARRAY")
    		return s.String()
    	case Missing:
    		return ":MISSING"
    	default:
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Fri Feb 25 20:31:19 UTC 2022
    - 20.2K bytes
    - Viewed (0)
  8. src/bufio/bufio.go

    		}
    		nn += n
    		p = p[n:]
    	}
    	if b.err != nil {
    		return nn, b.err
    	}
    	n := copy(b.buf[b.n:], p)
    	b.n += n
    	nn += n
    	return nn, nil
    }
    
    // WriteByte writes a single byte.
    func (b *Writer) WriteByte(c byte) error {
    	if b.err != nil {
    		return b.err
    	}
    	if b.Available() <= 0 && b.Flush() != nil {
    		return b.err
    	}
    	b.buf[b.n] = c
    	b.n++
    	return nil
    }
    
    Registered: Tue Oct 29 11:13:09 UTC 2024
    - Last Modified: Thu Oct 12 14:39:08 UTC 2023
    - 21.8K bytes
    - Viewed (0)
  9. cmd/streaming-signature-v4.go

    	// Read value
    	for {
    		v, err := cr.reader.ReadByte()
    		if err != nil {
    			if err == io.EOF {
    				return io.ErrUnexpectedEOF
    			}
    		}
    		if v != '\r' {
    			valueBuffer.WriteByte(v)
    			continue
    		}
    		// End of buffer, do not add to value.
    		v, err = cr.reader.ReadByte()
    		if err != nil {
    			if err == io.EOF {
    				return io.ErrUnexpectedEOF
    			}
    		}
    		if v != '\n' {
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Thu May 16 23:13:47 UTC 2024
    - 18.2K bytes
    - Viewed (0)
  10. cmd/test-utils_test.go

    	var buf bytes.Buffer
    	for _, k := range headers {
    		buf.WriteString(k)
    		buf.WriteByte(':')
    		switch {
    		case k == "host":
    			buf.WriteString(req.URL.Host)
    			fallthrough
    		default:
    			for idx, v := range headerMap[k] {
    				if idx > 0 {
    					buf.WriteByte(',')
    				}
    				buf.WriteString(v)
    			}
    			buf.WriteByte('\n')
    		}
    	}
    	canonicalHeaders := buf.String()
    
    	// Get signed headers.
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Tue Oct 01 22:13:18 UTC 2024
    - 77K bytes
    - Viewed (0)
Back to top