Search Options

Results per page
Sort
Preferred Languages
Advance

Results 161 - 170 of 276 for buf1 (0.03 sec)

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

    // drain returns a single string representing the processed input tokens.
    func drain(input *Input) string {
    	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
    }
    Registered: Tue Nov 05 11:13:11 UTC 2024
    - Last Modified: Tue Aug 29 07:48:38 UTC 2023
    - 5.8K bytes
    - Viewed (0)
  2. 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
    }
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Apr 12 21:37:19 UTC 2023
    - 1.8K bytes
    - Viewed (0)
  3. src/cmd/asm/internal/asm/endtoend_test.go

    		// Comma to separate argument gets a space; comma within does not.
    		var buf []byte
    		nest := 0
    		for i := 0; i < len(printed); i++ {
    			c := printed[i]
    			switch c {
    			case '{', '[':
    				nest++
    			case '}', ']':
    				nest--
    			case ',':
    				buf = append(buf, ',')
    				if nest == 0 {
    					buf = append(buf, ' ')
    				}
    				for i+1 < len(printed) && (printed[i+1] == ' ' || printed[i+1] == '\t') {
    Registered: Tue Nov 05 11:13:11 UTC 2024
    - Last Modified: Thu Dec 07 18:42:59 UTC 2023
    - 11.6K bytes
    - Viewed (0)
  4. src/main/java/org/codelibs/fess/app/web/admin/wizard/AdminWizardAction.java

            // normalize
            final StringBuilder buf = new StringBuilder(1000);
            for (int i = 0; i < configPath.length(); i++) {
                final char c = configPath.charAt(i);
                if (c == '\\') {
                    buf.append('/');
                } else if (c == ' ') {
                    buf.append("%20");
                } else if (CharUtil.isUrlChar(c)) {
                    buf.append(c);
                } else {
    Registered: Thu Oct 31 13:40:30 UTC 2024
    - Last Modified: Thu Feb 22 01:53:18 UTC 2024
    - 12.7K bytes
    - Viewed (0)
  5. internal/event/target/elasticsearch.go

    	doc := map[string]interface{}{
    		"Records": []event.Event{eventData},
    	}
    	var buf bytes.Buffer
    	enc := json.NewEncoder(&buf)
    	err := enc.Encode(doc)
    	if err != nil {
    		return err
    	}
    	res, err := c.Index(
    		index,
    		&buf,
    		c.Index.WithDocumentID(key),
    		c.Index.WithContext(ctx),
    	)
    	if err != nil {
    		return err
    	}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 06 23:06:30 UTC 2024
    - 15K bytes
    - Viewed (0)
  6. cmd/storage-rest-client.go

    }
    
    // AppendFile - append to a file.
    func (client *storageRESTClient) AppendFile(ctx context.Context, volume string, path string, buf []byte) error {
    	values := make(url.Values)
    	values.Set(storageRESTVolume, volume)
    	values.Set(storageRESTFilePath, path)
    	reader := bytes.NewReader(buf)
    	respBody, err := client.call(ctx, storageRESTMethodAppendFile, values, reader, -1)
    	defer xhttp.DrainBody(respBody)
    	return err
    }
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sun Oct 13 13:07:21 UTC 2024
    - 30.2K bytes
    - Viewed (0)
  7. src/bufio/export_test.go

    )
    
    var IsSpace = isSpace
    
    const DefaultBufSize = defaultBufSize
    
    func (s *Scanner) MaxTokenSize(n int) {
    	if n < utf8.UTFMax || n > 1e9 {
    		panic("bad max token size")
    	}
    	if n < len(s.buf) {
    		s.buf = make([]byte, n)
    	}
    	s.maxTokenSize = n
    }
    
    // ErrOrEOF is like Err, but returns EOF. Used to test a corner case.
    func (s *Scanner) ErrOrEOF() error {
    	return s.err
    Registered: Tue Nov 05 11:13:11 UTC 2024
    - Last Modified: Thu Nov 02 17:17:44 UTC 2017
    - 597 bytes
    - Viewed (0)
  8. internal/bucket/lifecycle/rule.go

    	if !r.Filter.Tag.IsEmpty() {
    		return r.Filter.Tag.String()
    	}
    	if len(r.Filter.And.Tags) != 0 {
    		var buf bytes.Buffer
    		for _, t := range r.Filter.And.Tags {
    			if buf.Len() > 0 {
    				buf.WriteString("&")
    			}
    			buf.WriteString(t.String())
    		}
    		return buf.String()
    	}
    	return ""
    }
    
    // Validate - validates the rule element
    func (r Rule) Validate() error {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed May 01 01:11:10 UTC 2024
    - 5.5K bytes
    - Viewed (0)
  9. docs/sts/web-identity.go

    		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 Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri May 19 09:13:33 UTC 2023
    - 7.8K bytes
    - Viewed (0)
  10. src/main/java/org/codelibs/fess/indexer/IndexUpdater.java

                final StringBuilder buf = new StringBuilder(100);
                buf.append("Processing ");
                if (totalHits > 0) {
                    buf.append(arList.size()).append('/').append(totalHits).append(" docs (Doc:{access ");
                } else {
                    buf.append("no docs in indexing queue (Doc:{access ");
                }
                buf.append(systemHelper.getCurrentTimeAsLong() - execTime).append("ms");
    Registered: Thu Oct 31 13:40:30 UTC 2024
    - Last Modified: Fri Oct 11 21:20:39 UTC 2024
    - 24.2K bytes
    - Viewed (0)
Back to top