Search Options

Results per page
Sort
Preferred Languages
Advance

Results 11 - 16 of 16 for headerBlock (0.16 sec)

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

          }
        }
    
        override fun headers(
          inFinished: Boolean,
          streamId: Int,
          associatedStreamId: Int,
          headerBlock: List<Header>,
        ) {
          if (pushedStream(streamId)) {
            pushHeadersLater(streamId, headerBlock, inFinished)
            return
          }
          val stream: Http2Stream?
          ******@****.***ck {
            stream = getStream(streamId)
    
    Registered: Sun Jun 16 04:42:17 UTC 2024
    - Last Modified: Sat Apr 20 17:03:43 UTC 2024
    - 32.6K bytes
    - Viewed (0)
  2. okhttp/src/test/java/okhttp3/internal/http2/Http2ConnectionTest.kt

        assertThat(synStream.associatedStreamId).isEqualTo(-1)
        assertThat(synStream.headerBlock).isEqualTo(headerEntries("b", "banana"))
        val requestData = peer.takeFrame()
        assertArrayEquals("c3po".toByteArray(), requestData.data)
        val nextFrame = peer.takeFrame()
        assertThat(nextFrame.headerBlock).isEqualTo(headerEntries("e", "elephant"))
      }
    
      @Test fun clientCreatesStreamAndServerRepliesWithFin() {
    Registered: Sun Jun 16 04:42:17 UTC 2024
    - Last Modified: Sat Apr 20 17:03:43 UTC 2024
    - 75.4K bytes
    - Viewed (0)
  3. src/net/http/h2_bundle.go

    	// only waste 9 bytes anyway.
    	const maxFrameSize = 16384
    
    	first := true
    	for len(headerBlock) > 0 {
    		frag := headerBlock
    		if len(frag) > maxFrameSize {
    			frag = frag[:maxFrameSize]
    		}
    		headerBlock = headerBlock[len(frag):]
    		if err := fn(ctx, frag, first, len(headerBlock) == 0); err != nil {
    			return err
    		}
    		first = false
    	}
    	return nil
    }
    
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Tue Jun 04 16:19:04 UTC 2024
    - 364.1K bytes
    - Viewed (0)
  4. tensorflow/compiler/jit/xla_activity_listener.cc

      (void)unused;
      return listener_list;
    }
    
    template <typename FnTy>
    Status ForEachListener(FnTy fn) {
      XlaActivityListenerList* listener_list = GetXlaActivityListenerList();
      absl::ReaderMutexLock reader_lock(&listener_list->mutex);
    
      for (const std::unique_ptr<XlaActivityListener>& listener :
           listener_list->listeners) {
        TF_RETURN_IF_ERROR(fn(listener.get()));
      }
    
      return absl::OkStatus();
    }
    
    Registered: Sun Jun 16 05:45:23 UTC 2024
    - Last Modified: Thu Feb 22 08:47:20 UTC 2024
    - 3.3K bytes
    - Viewed (0)
  5. tests/integration/security/fuzz/fuzzers/jwt_tool/jwtconf.ini

    commonHeaders = common-headers.txt
    commonPayloads = common-payloads.txt
    
    [argvals]
    # Set at runtime - changes here are ignored
    sigType =
    targetUrl =
    cookies =
    key =
    keyList =
    keyFile =
    headerLoc =
    payloadclaim =
    headerclaim =
    payloadvalue =
    headervalue =
    canaryvalue =
    header =
    exploitType =
    scanMode =
    reqMode =
    postData =
    resCode =
    resSize =
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Mon Jun 21 20:06:01 UTC 2021
    - 1.1K bytes
    - Viewed (0)
  6. testing/architecture-test/src/changes/archunit-store/internal-api-nullability.txt

    Class <org.gradle.cache.internal.btree.BTreePersistentIndexedCache$HeaderBlock> is not annotated (directly or via its package) with @org.gradle.api.NonNullApi in (BTreePersistentIndexedCache.java:0)
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Tue Jun 11 09:51:15 UTC 2024
    - 967.9K bytes
    - Viewed (0)
Back to top