- Sort Score
- Num 10 results
- Language All
Results 111 - 120 of 139 for EOF (0.01 seconds)
-
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) -
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) -
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) -
internal/bucket/object/lock/lock.go
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) -
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) -
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) -
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) -
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) -
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) -
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)