Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 31 - 40 of 139 for EOF (0.06 seconds)

  2. github.com/minio/minio

    cmd/object_api_suite_test.go 

    }

// OneByteReadEOF - implements io.Reader which returns 1 byte along with io.EOF error.
type testOneByteReadEOF struct {
	eof  bool
	data []byte
}

func (r *testOneByteReadEOF) Read(p []byte) (n int, err error) {
	if r.eof {
		return 0, io.EOF
	}
	n = copy(p, r.data)
	r.eof = true
	return n, io.EOF
}

// Return pointer to testOneByteReadNoEOF{}
func newTestReaderNoEOF(data []byte) io.Reader {
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 34.5K bytes
    - Click Count (0)
  3. github.com/minio/minio

    cmd/metacache-set.go 

    				// We have enough and we have more.
				// Do not return io.EOF
				if resCh != nil {
					resErr = nil
					select {
					case resCh <- results:
					case <-ctx.Done():
					}
					resCh = nil
					returned = true
				}
				continue
			}
			results.o = append(results.o, entry)
		}
		if resCh != nil {
			resErr = io.EOF
			select {
			case <-ctx.Done():
				// Nobody wants it.
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 30.7K bytes
    - Click Count (0)
  4. github.com/minio/minio

    docs/iam/opa.md 

    ```sh
cat > example.rego <<EOF
package httpapi.authz

import input

default allow = false

# Allow the root user to perform any action.
allow {
 input.owner == true
}

# All other users may do anything other than call PutObject
allow {
 input.action != "s3:PutObject"
 input.owner == false
}
EOF
```

Then load the policy via OPA's REST API.

```
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Jul 17 15:43:14 GMT 2022
    - 2.3K bytes
    - Click Count (0)
  5. github.com/minio/minio

    internal/s3select/csv/reader_contrib_test.go 

    			wantErr:         io.EOF,
		},
		{
			// This works since LazyQuotes is true:
			file:            "invalid-badstartline.csv",
			recordDelimiter: "\n",
			fieldDelimiter:  ",",
			sendErr:         nil,
			header:          true,
			wantColumns:     []string{"header1", "header2", "header3"},
			wantFields:      "ok1,ok2,ok3\n" + `a,"b` + "\n" + `c""d,e` + "\n\"\n",
			wantErr:         io.EOF,
		},
		{
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 38.4K bytes
    - Click Count (0)
  6. github.com/gradle/gradle

    .github/workflows/update-jdks.yml 

            # https://github.com/gradle/gradle-private/issues/4518
        run: |
          cat << 'EOF' > .teamcity/jdks.yaml.tmp
          # To verify the change, run the build with:
          # @bot-gradle test ReadyForNightly
          # ```
          # stopGradleDaemons=true
          # ```
          EOF
          # Append everything from "version:" onwards
    Created: Wed Dec 31 11:36:14 GMT 2025
    - Last Modified: Tue Dec 09 22:14:16 GMT 2025
    - 2.1K bytes
    - Click Count (0)
  7. github.com/minio/minio

    internal/s3select/json/preader.go 

    		r.readerWg.Wait()
		r.close = nil
	}
	r.recordsRead = len(r.current)
	if r.err == nil {
		r.err = io.EOF
	}
	return r.readCloser.Close()
}

// nextSplit will attempt to skip a number of bytes and
// return the buffer until the next newline occurs.
// The last block will be sent along with an io.EOF.
func (r *PReader) nextSplit(skip int, dst []byte) ([]byte, error) {
	if cap(dst) < skip {
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Tue May 27 15:19:03 GMT 2025
    - 6.5K bytes
    - Click Count (0)
  8. github.com/golang/go

    src/bufio/scan.go 

    	return &Scanner{
		r:            r,
		split:        ScanLines,
		maxTokenSize: MaxScanTokenSize,
	}
}

// Err returns the first non-EOF error that was encountered by the [Scanner].
func (s *Scanner) Err() error {
	if s.err == io.EOF {
		return nil
	}
	return s.err
}

// Bytes returns the most recent token generated by a call to [Scanner.Scan].
    Created: Tue Dec 30 11:13:12 GMT 2025
    - Last Modified: Wed May 21 18:05:26 GMT 2025
    - 14.2K bytes
    - Click Count (0)
  9. github.com/minio/minio

    internal/etag/reader.go 

    // MD5 checksum of the read content as ETag.
//
// Optionally, a Reader can also verify that
// the computed ETag matches an expected value.
// Therefore, it compares both ETags once the
// underlying io.Reader returns io.EOF.
// If the computed ETag does not match the
// expected ETag then Read returns a VerifyError.
//
// Reader implements the Tagger interface.
type Reader struct {
	src io.Reader

	md5      hash.Hash
	checksum ETag
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Mar 30 00:56:02 GMT 2025
    - 4.8K bytes
    - Click Count (0)
  10. github.com/tensorflow/tensorflow

    ci/official/utilities/generate_index_html.sh 

    # Generates a handy index.html with a bunch of Kokoro links for GitHub
# presubmits.
# Usage: generate_index_html.sh /path/to/output/index.html

cat > "$1" <<EOF
<html>
<head>
<title>$(basename "$KOKORO_JOB_NAME")</title>
</head>
<body>
<h1>TensorFlow Job Logs and Links</h1>
<h2>Job Details</h2>
<ul>
<li>Job name: $KOKORO_JOB_NAME</li>
    Created: Tue Dec 30 12:39:10 GMT 2025
    - Last Modified: Fri Sep 29 20:26:13 GMT 2023
    - 2.3K bytes
    - Click Count (0)
  11. github.com/golang/go

    src/cmd/asm/internal/lex/stack.go 

    // it resumes reading the next one down.
type Stack struct {
	tr []TokenReader
}

// Push adds tr to the top (end) of the input stack. (Popping happens automatically.)
func (s *Stack) Push(tr TokenReader) {
	s.tr = append(s.tr, tr)
}

func (s *Stack) Next() ScanToken {
	tos := s.tr[len(s.tr)-1]
	tok := tos.Next()
	for tok == scanner.EOF && len(s.tr) > 1 {
		tos.Close()
    Created: Tue Dec 30 11:13:12 GMT 2025
    - Last Modified: Mon Jan 09 22:33:23 GMT 2017
    - 1.2K bytes
    - Click Count (0)
Back to Top