Search Options

Results per page
Sort
Preferred Languages
Advance

Results 61 - 70 of 163 for EOF (0.01 sec)

  1. internal/s3select/csv/args.go

    	args.CommentCharacter = defaultCommentCharacter
    	args.AllowQuotedRecordDelimiter = false
    
    	for {
    		// Read tokens from the XML document in a stream.
    		t, err := d.Token()
    		if err != nil {
    			if err == io.EOF {
    				break
    			}
    			return err
    		}
    
    		if se, ok := t.(xml.StartElement); ok {
    			tagName := se.Name.Local
    			switch tagName {
    			case "AllowQuotedRecordDelimiter":
    				var b bool
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Tue Aug 20 18:31:45 UTC 2024
    - 5.7K bytes
    - Viewed (0)
  2. docs/multi-user/admin/README.md

    Create new canned policy file `adminManageUser.json`. This policy enables admin user to
    manage other users.
    
    ```json
    cat > adminManageUser.json << EOF
    {
      "Version": "2012-10-17",
      "Statement": [
        {
          "Action": [
            "admin:CreateUser",
            "admin:DeleteUser",
            "admin:ConfigUpdate"
          ],
          "Effect": "Allow",
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Tue Aug 12 18:20:36 UTC 2025
    - 4.7K bytes
    - Viewed (0)
  3. 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)
    Registered: Tue Dec 30 11:13:12 UTC 2025
    - Last Modified: Fri Sep 22 16:22:42 UTC 2023
    - 14.3K bytes
    - Viewed (0)
  4. src/cmd/asm/internal/lex/input.go

    			name := in.Stack.Text()
    			macro := in.macros[name]
    			if macro != nil {
    				nesting++
    				in.invokeMacro(macro)
    				continue
    			}
    			fallthrough
    		default:
    			if tok == scanner.EOF && len(in.ifdefStack) > 0 {
    				// We're skipping text but have run out of input with no #endif.
    				in.Error("unclosed #ifdef or #ifndef")
    			}
    			in.beginningOfLine = tok == '\n'
    			if in.enabled() {
    Registered: Tue Dec 30 11:13:12 UTC 2025
    - Last Modified: Wed Nov 12 03:59:40 UTC 2025
    - 12.4K bytes
    - Viewed (0)
  5. internal/grid/msg.go

    	// message will be sent after the serialized message as little endian.
    	FlagCRCxxh3 Flags = 1 << iota
    
    	// FlagEOF the stream (either direction) is at EOF.
    	FlagEOF
    
    	// FlagStateless indicates the message is stateless.
    	// This will retain clients across reconnections or
    	// if sequence numbers are unexpected.
    	FlagStateless
    
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Thu Jul 25 21:07:21 UTC 2024
    - 7.6K bytes
    - Viewed (0)
  6. 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 {
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Wed Sep 13 15:14:36 UTC 2023
    - 4K bytes
    - Viewed (0)
  7. 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 {
    Registered: Tue Dec 30 11:13:12 UTC 2025
    - Last Modified: Tue Aug 29 07:48:38 UTC 2023
    - 5.8K bytes
    - Viewed (0)
  8. fess-crawler/src/test/java/org/codelibs/fess/crawler/util/TemporaryFileInputStreamTest.java

                assertEquals('d', stream.read());
                assertEquals('a', stream.read());
                assertEquals('t', stream.read());
                assertEquals('a', stream.read());
                assertEquals(-1, stream.read()); // EOF
            }
    
            // File should be deleted after close
            // Note: FileUtil.deleteInBackground() is async, so we can't reliably test this
        }
    
        public void test_available() throws Exception {
    Registered: Sat Dec 20 11:21:39 UTC 2025
    - Last Modified: Sat Nov 22 13:28:22 UTC 2025
    - 7.2K bytes
    - Viewed (0)
  9. src/archive/tar/example_test.go

    		}
    	}
    	if err := tw.Close(); err != nil {
    		log.Fatal(err)
    	}
    
    	// Open and iterate through the files in the archive.
    	tr := tar.NewReader(&buf)
    	for {
    		hdr, err := tr.Next()
    		if err == io.EOF {
    			break // End of archive
    		}
    		if err != nil {
    			log.Fatal(err)
    		}
    		fmt.Printf("Contents of %s:\n", hdr.Name)
    		if _, err := io.Copy(os.Stdout, tr); err != nil {
    			log.Fatal(err)
    		}
    		fmt.Println()
    Registered: Tue Dec 30 11:13:12 UTC 2025
    - Last Modified: Thu Nov 16 16:54:08 UTC 2017
    - 1.4K bytes
    - Viewed (0)
  10. src/main/java/jcifs/dcerpc/DcerpcPipeHandle.java

            }
    
            while (have < fraglen) {
                final int r = this.handle.recv(inB, have, fraglen - have);
                if (r == 0) {
                    throw new IOException("Unexpected EOF");
                }
                have += r;
            }
    
            return have;
        }
    
        @Override
        protected void doSendFragment(final byte[] buf, final int off, final int length) throws IOException {
    Registered: Sat Dec 20 13:44:44 UTC 2025
    - Last Modified: Sat Aug 16 01:32:48 UTC 2025
    - 5.6K bytes
    - Viewed (0)
Back to top