Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 16 for Continuation (0.21 sec)

  1. okhttp/src/main/kotlin/okhttp3/internal/http2/Http2Reader.kt

      private fun readHeaderBlock(
        length: Int,
        padding: Int,
        flags: Int,
        streamId: Int,
      ): List<Header> {
        continuation.left = length
        continuation.length = continuation.left
        continuation.padding = padding
        continuation.flags = flags
        continuation.streamId = streamId
    
        // TODO: Concat multi-value headers with 0x0, except COOKIE, which uses 0x3B, 0x20.
    Registered: Sun Jun 16 04:42:17 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 19.9K bytes
    - Viewed (0)
  2. okhttp/src/test/java/okhttp3/internal/ws/WebSocketReaderTest.kt

        }.also { expected ->
          assertThat(expected.message).isEqualTo("Unexpected rsv1 flag")
        }
      }
    
      @Test fun reservedFlag1IsUnsupportedForContinuationFrames() {
        data.write("c000".decodeHex()) // Empty continuation, flag 1 set.
        assertFailsWith<ProtocolException> {
          clientReaderWithCompression.processNextFrame()
        }.also { expected ->
          assertThat(expected.message).isEqualTo("Unexpected rsv1 flag")
        }
      }
    Registered: Sun Jun 16 04:42:17 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 14.4K bytes
    - Viewed (0)
  3. src/net/textproto/reader.go

    	return line, nil
    }
    
    // ReadContinuedLine reads a possibly continued line from r,
    // eliding the final trailing ASCII white space.
    // Lines after the first are considered continuations if they
    // begin with a space or tab character. In the returned data,
    // continuation lines are separated from the previous line
    // only by a single space: the newline and leading white space
    // are removed.
    //
    // For example, consider this input:
    //
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Wed May 15 19:57:43 UTC 2024
    - 22.1K bytes
    - Viewed (0)
  4. okhttp/src/test/java/okhttp3/internal/http2/Http2Test.kt

        frame.writeByte(Http2.TYPE_HEADERS)
        frame.writeByte(FLAG_NONE)
        frame.writeInt(expectedStreamId and 0x7fffffff)
        frame.write(headerBlock, Http2.INITIAL_MAX_FRAME_SIZE.toLong())
    
        // Write the continuation frame, specifying no more frames are expected.
        writeMedium(frame, headerBlock.size.toInt())
        frame.writeByte(Http2.TYPE_CONTINUATION)
        frame.writeByte(FLAG_END_HEADERS)
    Registered: Sun Jun 16 04:42:17 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 28.1K bytes
    - Viewed (0)
  5. okhttp/src/main/kotlin/okhttp3/internal/ws/WebSocketReader.kt

              maskCursor.close()
            }
          }
    
          if (isFinalFrame) break // We are exhausted and have no continuations.
    
          readUntilNonControlFrame()
          if (opcode != OPCODE_CONTINUATION) {
            throw ProtocolException("Expected continuation opcode. Got: ${opcode.toHexString()}")
          }
        }
      }
    
      @Throws(IOException::class)
      override fun close() {
    Registered: Sun Jun 16 04:42:17 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 9.8K bytes
    - Viewed (0)
  6. src/cmd/vendor/golang.org/x/text/unicode/norm/normalize.go

    			return false
    		}
    		bp, _ = rb.f.quickSpan(rb.src, bp, len(s), true)
    	}
    	return true
    }
    
    // patchTail fixes a case where a rune may be incorrectly normalized
    // if it is followed by illegal continuation bytes. It returns the
    // patched buffer and whether the decomposition is still in progress.
    func patchTail(rb *reorderBuffer) bool {
    	info, p := lastRuneStart(&rb.f, rb.out)
    	if p == -1 || info.size == 0 {
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Wed Jan 24 13:01:26 UTC 2024
    - 14.9K bytes
    - Viewed (0)
  7. JavadocStyleGuide.md

     * @param name the location of the image, relative to the url argument
     * @return the image at the specified URL
     * @see Image
     */
    ```
    
    When a block tag doesn't fit on a single line, continuation lines are indented four (or more) spaces from the position of the `@`:
    
    ```java
    /**
     * @param url an absolute URL giving the base location of the image, and 
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Thu Jun 06 15:43:07 UTC 2024
    - 11.5K bytes
    - Viewed (0)
  8. staging/src/k8s.io/apiserver/pkg/util/flowcontrol/request/width_test.go

    				Resource: "events",
    			},
    			countErr:             ObjectCountNotFoundErr,
    			maxSeats:             10,
    			initialSeatsExpected: 1,
    		},
    		{
    			name:       "request verb is list, continuation is set",
    			requestURI: "http://server/apis/foo.bar/v1/events?continue=token&limit=399",
    			requestInfo: &apirequest.RequestInfo{
    				Verb:     "list",
    				APIGroup: "foo.bar",
    				Resource: "events",
    			},
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Apr 24 18:25:29 UTC 2024
    - 17K bytes
    - Viewed (0)
  9. src/compress/bzip2/bzip2.go

    			if err != nil {
    				if err == io.EOF {
    					err = io.ErrUnexpectedEOF
    				}
    				br.err = err
    				return 0, err
    			}
    			if b != 'B' || z != 'Z' {
    				return 0, StructuralError("bad magic value in continuation file")
    			}
    			if err := bz2.setup(false); err != nil {
    				return 0, err
    			}
    		}
    	}
    }
    
    // readBlock reads a bzip2 block. The magic number should already have been consumed.
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Fri Apr 26 13:32:40 UTC 2024
    - 13K bytes
    - Viewed (0)
  10. staging/src/k8s.io/apiserver/pkg/storage/etcd3/store.go

    func (s *store) resolveGetListRev(continueKey string, continueRV int64, opts storage.ListOptions) (int64, error) {
    	var withRev int64
    	// Uses continueRV if this is a continuation request.
    	if len(continueKey) > 0 {
    		if len(opts.ResourceVersion) > 0 && opts.ResourceVersion != "0" {
    			return withRev, apierrors.NewBadRequest("specifying resource version is not allowed when using continue")
    		}
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri May 10 11:56:42 UTC 2024
    - 35.2K bytes
    - Viewed (0)
Back to top