Search Options

Results per page
Sort
Preferred Languages
Advance

Results 31 - 40 of 102 for Continuation (0.38 sec)

  1. 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)
  2. internal/s3select/message.go

    //
    // Header specification:
    // Continuation messages contain two headers, as follows:
    // https://docs.aws.amazon.com/AmazonS3/latest/API/images/s3select-frame-diagram-cont.png
    //
    // Payload specification:
    // Continuation messages have no payload.
    var continuationMessage = []byte{
    	0, 0, 0, 57, // total byte-length.
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Tue Aug 30 15:26:43 UTC 2022
    - 15.2K bytes
    - Viewed (0)
  3. src/runtime/debugcall.go

    	// Undo the lockOSThread we did earlier.
    	unlockOSThread()
    
    	gp.asyncSafePoint = false
    }
    
    type debugCallWrapArgs struct {
    	dispatch uintptr
    	callingG *g
    }
    
    // debugCallWrap1 is the continuation of debugCallWrap on the callee
    // goroutine.
    func debugCallWrap1() {
    	gp := getg()
    	args := (*debugCallWrapArgs)(gp.param)
    	dispatch, callingG := args.dispatch, args.callingG
    	gp.param = nil
    
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Fri Apr 05 20:50:21 UTC 2024
    - 7.1K bytes
    - Viewed (0)
  4. src/cmd/vendor/golang.org/x/text/cases/tables10.0.0.go

    		c1 := s[1]
    		if c1 < 0x80 || 0xC0 <= c1 {
    			return 0, 1 // Illegal UTF-8: not a continuation byte.
    		}
    		return t.lookupValue(uint32(i), c1), 2
    	case c0 < 0xF0: // 3-byte UTF-8
    		if len(s) < 3 {
    			return 0, 0
    		}
    		i := caseIndex[c0]
    		c1 := s[1]
    		if c1 < 0x80 || 0xC0 <= c1 {
    			return 0, 1 // Illegal UTF-8: not a continuation byte.
    		}
    		o := uint32(i)<<6 + uint32(c1)
    		i = caseIndex[o]
    		c2 := s[2]
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Wed Jan 24 13:01:26 UTC 2024
    - 93.9K 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/cases/tables9.0.0.go

    		c1 := s[1]
    		if c1 < 0x80 || 0xC0 <= c1 {
    			return 0, 1 // Illegal UTF-8: not a continuation byte.
    		}
    		return t.lookupValue(uint32(i), c1), 2
    	case c0 < 0xF0: // 3-byte UTF-8
    		if len(s) < 3 {
    			return 0, 0
    		}
    		i := caseIndex[c0]
    		c1 := s[1]
    		if c1 < 0x80 || 0xC0 <= c1 {
    			return 0, 1 // Illegal UTF-8: not a continuation byte.
    		}
    		o := uint32(i)<<6 + uint32(c1)
    		i = caseIndex[o]
    		c2 := s[2]
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Wed Jan 24 13:01:26 UTC 2024
    - 92.4K bytes
    - Viewed (0)
  7. cmd/object-api-listobjects_test.go

    	t, _ := t1.(*testing.T)
    	testBuckets := []string{
    		// This bucket is used for testing ListObject operations.
    		"test-bucket-list-object-continuation-1",
    		"test-bucket-list-object-continuation-2",
    	}
    	for _, bucket := range testBuckets {
    		err := obj.MakeBucket(context.Background(), bucket, MakeBucketOptions{})
    		if err != nil {
    			t.Fatalf("%s : %s", instanceType, err.Error())
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Wed May 01 11:07:40 UTC 2024
    - 73.1K bytes
    - Viewed (0)
  8. src/vendor/golang.org/x/text/unicode/bidi/tables10.0.0.go

    		c1 := s[1]
    		if c1 < 0x80 || 0xC0 <= c1 {
    			return 0, 1 // Illegal UTF-8: not a continuation byte.
    		}
    		return t.lookupValue(uint32(i), c1), 2
    	case c0 < 0xF0: // 3-byte UTF-8
    		if len(s) < 3 {
    			return 0, 0
    		}
    		i := bidiIndex[c0]
    		c1 := s[1]
    		if c1 < 0x80 || 0xC0 <= c1 {
    			return 0, 1 // Illegal UTF-8: not a continuation byte.
    		}
    		o := uint32(i)<<6 + uint32(c1)
    		i = bidiIndex[o]
    		c2 := s[2]
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Thu Oct 19 23:33:33 UTC 2023
    - 110.9K bytes
    - Viewed (0)
  9. src/cmd/internal/test2json/test2json.go

    				l.line(l.b[i:e])
    			}
    			i = e
    		}
    
    		// Whatever's left in l.b is a line fragment.
    		if i == 0 && len(l.b) == cap(l.b) {
    			// The whole buffer is a fragment.
    			// Emit it as the beginning (or continuation) of a partial line.
    			t := trimUTF8(l.b)
    			l.part(l.b[:t])
    			l.b = l.b[:copy(l.b, l.b[t:])]
    			l.mid = true
    		}
    
    		// There's room for more input.
    		// Slide it down in hope of completing the line.
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Wed Nov 09 17:33:07 UTC 2022
    - 14.5K bytes
    - Viewed (0)
  10. doc/next/9-todo.md

    CL 570681 ("os: make FindProcess use pidfd on Linux") mentions accepted proposal go.dev/issue/51246 (described as fully implemented in Go 1.22) and NeedsInvestigation continuation issue go.dev/issue/62654.
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Tue Jun 11 17:18:52 UTC 2024
    - 6K bytes
    - Viewed (0)
Back to top