Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 31 - 40 of 112 for EOF (0.02 seconds)

The search processing time has exceeded the limit. The displayed results may be partial.

  1. src/bufio/net_test.go

    	"strings"
    	"sync"
    	"testing"
    )
    
    // TestCopyUnixpacket tests that we can use bufio when copying
    // across a unixpacket socket. This used to fail due to an unnecessary
    // empty Write call that was interpreted as an EOF.
    func TestCopyUnixpacket(t *testing.T) {
    	tmpDir := t.TempDir()
    	socket := filepath.Join(tmpDir, "unixsock")
    
    	// Start a unixpacket server.
    	addr := &net.UnixAddr{
    		Name: socket,
    		Net:  "unixpacket",
    	}
    Created: Tue Dec 30 11:13:12 GMT 2025
    - Last Modified: Fri Feb 07 19:37:07 GMT 2025
    - 1.9K bytes
    - Click Count (0)
  2. cmd/dummy-data-generator_test.go

    				i, b1, b2)
    		}
    		// Check if stream has ended
    		if (e1 == io.ErrUnexpectedEOF && e2 == io.ErrUnexpectedEOF) || (e1 == io.EOF && e2 == io.EOF) {
    			break
    		}
    		if e1 != nil || e2 != nil {
    			return false, fmt.Sprintf("Got unexpected error values: %v == %v", e1, e2)
    		}
    	}
    	return true, ""
    }
    
    func TestCmpReaders(t *testing.T) {
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 4.8K bytes
    - Click Count (0)
  3. internal/grid/muxserver.go

    	m.recvMu.Lock()
    	defer m.recvMu.Unlock()
    	if cap(m.inbound) == 0 {
    		m.disconnect("did not expect inbound message", true)
    		return
    	}
    	// Note, on EOF no value can be sent.
    	if msg.Flags&FlagEOF != 0 {
    		if len(msg.Payload) > 0 {
    			gridLogIf(m.ctx, fmt.Errorf("muxServer: EOF message with payload"))
    		}
    		if m.inbound != nil {
    			xioutil.SafeClose(m.inbound)
    			m.inbound = nil
    		}
    		return
    	}
    
    	select {
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Tue May 27 15:19:03 GMT 2025
    - 9.7K bytes
    - Click Count (0)
  4. .github/workflows/check-commits.yml

          - name: Read output file
            id: read_output
            if: ${{ always() }}
            run: |
              cat output.txt
              OUTPUT=$(cat output.txt)
              echo "OUTPUT<<EOF" >> $GITHUB_ENV
              echo "$OUTPUT" >> $GITHUB_ENV
              echo "EOF" >> $GITHUB_ENV
          - name: Comment on PR if check failed
            if: ${{ failure() }}
            uses: actions/github-script@v8
            with:
    Created: Wed Dec 31 11:36:14 GMT 2025
    - Last Modified: Thu Nov 20 22:15:20 GMT 2025
    - 3K bytes
    - Click Count (0)
  5. internal/ioutil/ioutil.go

    			remaining := totalSize - written
    			if remaining < int64(len(buf)) {
    				buf = buf[:remaining]
    			}
    		}
    
    		nr, err := io.ReadFull(r, buf)
    		eof := errors.Is(err, io.EOF) || errors.Is(err, io.ErrUnexpectedEOF)
    		if err != nil && !eof {
    			return written, err
    		}
    
    		buf = buf[:nr]
    		var (
    			n  int
    			un int
    			nw int64
    		)
    
    		remain := len(buf) % DirectioAlignSize
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Tue Feb 18 16:25:55 GMT 2025
    - 11.1K bytes
    - Click Count (0)
  6. ci/official/envs/rbe

      cat <<EOF
    ERROR: RBE was enabled via the 'rbe' env in the 'TFCI' variable.
           TFCI: $TFCI
           TFCI_BAZEL_TARGET_SELECTING_CONFIG_PREFIX is "$TFCI_BAZEL_TARGET_SELECTING_CONFIG_PREFIX".
           But in .bazelrc, there is no "rbe_$TFCI_BAZEL_TARGET_SELECTING_CONFIG_PREFIX".
           That setting must exist for this script to function correctly.
    EOF
      exit 1
    fi
    Created: Tue Dec 30 12:39:10 GMT 2025
    - Last Modified: Fri Aug 09 16:05:18 GMT 2024
    - 2.7K bytes
    - Click Count (0)
  7. buildscripts/multipart-quorum-test.sh

    	done
    	cat <<EOF >parts.json
    {
        "Parts": [
            {
                "PartNumber": 1,
                "ETag": "5f363e0e58a95f06cbe9bbc662c5dfb6"
            },
            {
                "PartNumber": 2,
                "ETag": "5f363e0e58a95f06cbe9bbc662c5dfb6"
            }
        ]
    }
    EOF
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Sep 06 10:51:23 GMT 2024
    - 2.9K bytes
    - Click Count (0)
  8. src/bufio/scan_test.go

    	}
    	err := s.Err()
    	if err != testError {
    		t.Fatalf("expected %q got %v", testError, err)
    	}
    }
    
    // Test that an EOF is overridden by a user-generated scan error.
    func TestErrAtEOF(t *testing.T) {
    	s := NewScanner(strings.NewReader("1 2 33"))
    	// This splitter will fail on last entry, after s.err==EOF.
    	split := func(data []byte, atEOF bool) (advance int, token []byte, err error) {
    		advance, token, err = ScanWords(data, atEOF)
    Created: Tue Dec 30 11:13:12 GMT 2025
    - Last Modified: Fri Sep 22 16:22:42 GMT 2023
    - 14.3K bytes
    - Click Count (0)
  9. internal/s3select/json/reader.go

    func (r *Reader) Read(dst sql.Record) (sql.Record, error) {
    	v, ok := <-r.valueCh
    	if !ok {
    		if err := r.decoder.Err(); err != nil {
    			return nil, errJSONParsingError(err)
    		}
    		return nil, io.EOF
    	}
    
    	var kvs jstream.KVS
    	if v.ValueType == jstream.Object {
    		// This is a JSON object type (that preserves key
    		// order)
    		kvs, _ = v.Value.(jstream.KVS)
    	} else {
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Tue Feb 18 16:25:55 GMT 2025
    - 3.2K bytes
    - Click Count (0)
  10. cmd/os_other.go

    			return nil
    		}
    		return osErrToFileErr(err)
    	}
    	defer d.Close()
    
    	maxEntries := 1000
    	for {
    		// Read up to max number of entries.
    		fis, err := d.Readdir(maxEntries)
    		if err != nil {
    			if err == io.EOF {
    				break
    			}
    			err = osErrToFileErr(err)
    			if err == errFileNotFound {
    				return nil
    			}
    			return err
    		}
    		for _, fi := range fis {
    			if fi.Mode()&os.ModeSymlink == os.ModeSymlink {
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Wed Sep 13 15:14:36 GMT 2023
    - 4K bytes
    - Click Count (0)
Back to Top