Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 99 for Kramer (0.13 sec)

  1. docs/contribute/concurrency.md

    Blocking APIs may be inefficient because you hold a thread idle while waiting on the network. Threads are expensive because they have both a memory overhead and a context-switching overhead.
    
    #### Framed protocols
    
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Sun Feb 06 16:35:36 UTC 2022
    - 7K bytes
    - Viewed (0)
  2. okhttp/src/jvmTest/kotlin/okhttp3/internal/http2/Http2Test.kt

        writeMedium(frame, (headerBlock.size / 2).toInt() + paddingLength + 1)
        frame.writeByte(Http2.TYPE_HEADERS)
        frame.writeByte(FLAG_PADDED)
        frame.writeInt(expectedStreamId and 0x7fffffff)
        frame.writeByte(paddingLength)
        frame.write(headerBlock, headerBlock.size / 2)
        frame.write(padding)
    
        // Write the continuation frame, specifying no more frames are expected.
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Wed Mar 19 19:25:20 UTC 2025
    - 28.1K bytes
    - Viewed (0)
  3. okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/http2/Http2Reader.kt

    import okio.ByteString
    import okio.Source
    import okio.Timeout
    
    /**
     * Reads HTTP/2 transport frames.
     *
     * This implementation assumes we do not send an increased [frame][Settings.getMaxFrameSize] to the
     * peer. Hence, we expect all frames to have a max length of [Http2.INITIAL_MAX_FRAME_SIZE].
     */
    class Http2Reader(
      /** Creates a frame reader with max header table size of 4096. */
      private val source: BufferedSource,
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Fri Dec 27 13:39:56 UTC 2024
    - 19.8K bytes
    - Viewed (0)
  4. okhttp/src/jvmTest/kotlin/okhttp3/internal/http2/MockHttp2Peer.kt

      }
    
      /** Maximum length of an outbound data frame.  */
      fun maxOutboundDataLength(): Int = writer.maxDataLength()
    
      /** Count of frames sent or received.  */
      fun frameCount(): Int = frameCount
    
      fun sendFrame(): Http2Writer {
        outFrames.add(OutFrame(frameCount++, bytesOut.size, false))
        return writer
      }
    
      /**
       * Shortens the last frame from its original length to `length`. This will cause the peer to
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Wed Mar 19 19:25:20 UTC 2025
    - 8.7K bytes
    - Viewed (0)
  5. utils/utils.go

    	len := runtime.Callers(3, pcs[:])
    	frames := runtime.CallersFrames(pcs[:len])
    	for i := 0; i < len; i++ {
    		// second return value is "more", not "ok"
    		frame, _ := frames.Next()
    		if (!strings.HasPrefix(frame.File, gormSourceDir) ||
    			strings.HasSuffix(frame.File, "_test.go")) && !strings.HasSuffix(frame.File, ".gen.go") {
    			return string(strconv.AppendInt(append([]byte(frame.File), ':'), int64(frame.Line), 10))
    		}
    	}
    
    	return ""
    Registered: Sun Sep 07 09:35:13 UTC 2025
    - Last Modified: Thu Aug 22 11:03:42 UTC 2024
    - 4.1K bytes
    - Viewed (0)
  6. okhttp/src/jvmTest/kotlin/okhttp3/internal/ws/RealWebSocketTest.kt

        // Note: we don't process server frames so our client 'close' doesn't receive a server 'close'.
        assertThat(client.canceled).isFalse()
    
        taskFaker.advanceUntil(ns(4_999))
        assertThat(client.canceled).isFalse()
    
        taskFaker.advanceUntil(ns(5_000))
        assertThat(client.canceled).isTrue()
    
        client.processNextFrame() // This won't get a frame, but it will get a closed pipe.
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Thu Jul 31 04:18:40 UTC 2025
    - 18.7K bytes
    - Viewed (0)
  7. okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/ws/RealWebSocket.kt

      /** Outgoing messages and close frames in the order they should be written. */
      private val messageAndCloseQueue = ArrayDeque<Any>()
    
      /** The total size in bytes of enqueued but not yet transmitted messages. */
      private var queueSize = 0L
    
      /** True if we've enqueued a close frame. No further message frames will be enqueued. */
      private var enqueuedClose = false
    
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Thu Jul 31 04:18:40 UTC 2025
    - 21.6K bytes
    - Viewed (0)
  8. api/go1.7.txt

    pkg runtime, func CallersFrames([]uintptr) *Frames
    pkg runtime, func KeepAlive(interface{})
    pkg runtime, func SetCgoTraceback(int, unsafe.Pointer, unsafe.Pointer, unsafe.Pointer)
    pkg runtime, method (*Frames) Next() (Frame, bool)
    pkg runtime, type Frame struct
    pkg runtime, type Frame struct, Entry uintptr
    pkg runtime, type Frame struct, File string
    pkg runtime, type Frame struct, Func *Func
    Registered: Tue Sep 09 11:13:09 UTC 2025
    - Last Modified: Tue Jun 28 15:08:11 UTC 2016
    - 13.6K bytes
    - Viewed (0)
  9. okhttp/src/jvmTest/kotlin/okhttp3/internal/http2/Http2ConnectionTest.kt

        while (buffer.size != 1024L) source.read(buffer, 1024)
        stream1.close(ErrorCode.CANCEL, null)
        val frame1 = peer.takeFrame()
        assertThat(frame1.type).isEqualTo(Http2.TYPE_HEADERS)
        val frame2 = peer.takeFrame()
        assertThat(frame2.type).isEqualTo(Http2.TYPE_RST_STREAM)
        val frame3 = peer.takeFrame()
        assertThat(frame3.type).isEqualTo(Http2.TYPE_RST_STREAM)
        assertThat(connection.readBytes.acknowledged).isEqualTo(0L)
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Thu Jul 31 04:18:40 UTC 2025
    - 75.5K bytes
    - Viewed (0)
  10. okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/http2/Http2Writer.kt

      /**
       * HTTP/2 only. Send a push promise header block.
       *
       * A push promise contains all the headers that pertain to a server-initiated request, and a
       * `promisedStreamId` to which response frames will be delivered. Push promise frames are sent as
       * a part of the response to `streamId`. The `promisedStreamId` has a priority of one greater than
       * `streamId`.
       *
       * @param streamId client-initiated stream ID.  Must be an odd number.
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Wed May 28 23:28:25 UTC 2025
    - 11K bytes
    - Viewed (0)
Back to top