Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 111 - 120 of 139 for EOF (0.01 seconds)

  1. cmd/handler-utils.go

    		internalLogOnceIf(GlobalContext, err, "location-constraint-xml-parsing")
    		// Treat all other failures as XML parsing errors.
    		return "", ErrMalformedXML
    	} // else for both err as nil or io.EOF
    	location = locationConstraint.Location
    	if location == "" {
    		location = globalSite.Region()
    	}
    	if !isValidLocation(location) {
    		return location, ErrInvalidRegion
    	}
    
    	return location, ErrNone
    }
    
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 16.4K bytes
    - Click Count (1)
  2. mockwebserver-deprecated/src/test/java/okhttp3/mockwebserver/MockWebServerTest.kt

          // treats an incomplete response body as a ProtocolException.
        } catch (ioe: IOException) {
          // Change in https://bugs.openjdk.org/browse/JDK-8335135
          assertThat(ioe.message).isEqualTo("Premature EOF")
        }
      }
    
      private fun headersToList(response: MockResponse): List<String> {
        val headers = response.headers
        val size = headers.size
        val headerList: MutableList<String> = ArrayList(size)
    Created: Fri Dec 26 11:42:13 GMT 2025
    - Last Modified: Thu Jul 03 13:16:34 GMT 2025
    - 22.3K bytes
    - Click Count (0)
  3. internal/grid/connection.go

    
    // Stateless connects to the remote handler and return all packets sent back.
    // If the remote is restarted will return ErrRemoteRestart.
    // If nil will be returned remote call sent EOF or ErrDone is returned by the callback.
    // If ErrDone is returned on cb nil will be returned.
    func (c *Connection) Stateless(ctx context.Context, h HandlerID, req []byte, cb func([]byte) error) error {
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 46.9K bytes
    - Click Count (0)
  4. internal/bucket/object/lock/lock.go

    			start.Name.Local))
    	}
    	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 {
    			switch se.Name.Local {
    			case "Status":
    				var st LegalHoldStatus
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 17.9K bytes
    - Click Count (0)
  5. android/guava/src/com/google/common/io/CharSource.java

       * #lengthIfKnown}, returning true if it's known to be zero and false if it's known to be
       * non-zero. If the length is not known, it falls back to opening a stream and checking for EOF.
       *
       * <p>Note that, in cases where {@code lengthIfKnown} returns zero, it is <i>possible</i> that
       * chars are actually available for reading. This means that a source may return {@code true} from
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Mon Sep 08 18:35:13 GMT 2025
    - 25.7K bytes
    - Click Count (0)
  6. guava/src/com/google/common/io/CharSource.java

       * #lengthIfKnown}, returning true if it's known to be zero and false if it's known to be
       * non-zero. If the length is not known, it falls back to opening a stream and checking for EOF.
       *
       * <p>Note that, in cases where {@code lengthIfKnown} returns zero, it is <i>possible</i> that
       * chars are actually available for reading. This means that a source may return {@code true} from
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Mon Sep 08 18:35:13 GMT 2025
    - 25.3K bytes
    - Click Count (0)
  7. mockwebserver/src/test/java/mockwebserver3/MockWebServerTest.kt

          // treats an incomplete response body as a ProtocolException.
        } catch (ioe: IOException) {
          // Change in https://bugs.openjdk.org/browse/JDK-8335135
          assertThat(ioe.message).isEqualTo("Premature EOF")
        }
      }
    
      private fun headersToList(response: MockResponse.Builder): List<String> {
        val headers = response.build().headers
        return headers.map { (key, value) -> "$key: $value" }.toList()
      }
    
    Created: Fri Dec 26 11:42:13 GMT 2025
    - Last Modified: Sun Aug 03 22:38:00 GMT 2025
    - 28K bytes
    - Click Count (0)
  8. cmd/erasure-object.go

    	// Fetch buffer for I/O, returns from the pool if not allocates a new one and returns.
    	var buffer []byte
    	switch size := data.Size(); {
    	case size == 0:
    		buffer = make([]byte, 1) // Allocate at least a byte to reach EOF
    	case size >= fi.Erasure.BlockSize:
    		buffer = globalBytePoolCap.Load().Get()
    		defer globalBytePoolCap.Load().Put(buffer)
    	case size < fi.Erasure.BlockSize:
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Oct 24 04:05:31 GMT 2025
    - 80.4K bytes
    - Click Count (0)
  9. src/cmd/asm/internal/asm/operand_test.go

    	{"$bar<ABI0>(SB)", "$bar<ABI0>(SB)"},
    	{"$foo<ABIInternal>(SB)", "$foo<ABIInternal>(SB)"},
    }
    
    var amd64BadOperandTests = []badOperandTest{
    	{"[", "register list: expected ']', found EOF"},
    	{"[4", "register list: bad low register in `[4`"},
    	{"[]", "register list: bad low register in `[]`"},
    	{"[f-x]", "register list: bad low register in `[f`"},
    	{"[r10-r13]", "register list: bad low register in `[r10`"},
    Created: Tue Dec 30 11:13:12 GMT 2025
    - Last Modified: Tue Aug 29 18:31:05 GMT 2023
    - 23.9K bytes
    - Click Count (0)
  10. src/archive/tar/tar_test.go

    type testFile struct {
    	ops fileOps
    	pos int64
    }
    
    func (f *testFile) Read(b []byte) (int, error) {
    	if len(b) == 0 {
    		return 0, nil
    	}
    	if len(f.ops) == 0 {
    		return 0, io.EOF
    	}
    	s, ok := f.ops[0].(string)
    	if !ok {
    		return 0, errors.New("unexpected Read operation")
    	}
    
    	n := copy(b, s)
    	if len(s) > n {
    		f.ops[0] = s[n:]
    	} else {
    		f.ops = f.ops[1:]
    	}
    Created: Tue Dec 30 11:13:12 GMT 2025
    - Last Modified: Thu Jul 25 00:25:45 GMT 2024
    - 23.9K bytes
    - Click Count (0)
Back to Top