Search Options

Results per page
Sort
Preferred Languages
Advance

Results 21 - 30 of 52 for outbound (0.12 sec)

  1. docs/contribute/debug_logging.md

    $ adb shell setprop log.tag.okhttp.Http2 DEBUG
    $ adb shell setprop log.tag.okhttp.TaskRunner DEBUG
    $ adb logcat '*:E' 'okhttp.Http2:D' 'okhttp.TaskRunner:D'
    ```
    
    ### HTTP/2 Frame Logging
    
    This logs inbound (`<<`) and outbound (`>>`) frames for HTTP/2 connections.
    
    ```
    [2020-01-01 00:00:00] >> CONNECTION 505249202a20485454502f322e300d0a0d0a534d0d0a0d0a
    [2020-01-01 00:00:00] >> 0x00000000     6 SETTINGS
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Sun Feb 06 16:35:36 UTC 2022
    - 2.7K bytes
    - Viewed (0)
  2. okhttp/src/main/kotlin/okhttp3/internal/ws/WebSocketWriter.kt

      val sink: BufferedSink,
      val random: Random,
      private val perMessageDeflate: Boolean,
      private val noContextTakeover: Boolean,
      private val minimumDeflateSize: Long,
    ) : Closeable {
      /** This holds outbound data for compression and masking. */
      private val messageBuffer = Buffer()
    
      /** The [Buffer] of [sink]. Write to this and then flush/emit [sink]. */
      private val sinkBuffer: Buffer = sink.buffer
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 5.9K bytes
    - Viewed (0)
  3. architecture/ambient/ztunnel-cni-lifecycle.md

    This will send some identifying information about the Pod to Ztunnel, and, importantly, the Pod's network namespace file descriptor.
    
    Ztunnel will use this to enter the Pod network namespace and start various listeners (inbound, outbound, etc).
    
    > [!NOTE]
    > While Ztunnel runs as a single shared binary on the node, each individual pod gets its own unique set of listeners within its own network namespace.
    
    ## Pod Startup
    
    ### Pod Startup Requirements
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Wed Jul 17 23:10:17 UTC 2024
    - 9.4K bytes
    - Viewed (0)
  4. okhttp/src/main/kotlin/okhttp3/internal/http2/Http2.kt

       *
       * The format is:
       *
       * ```
       * direction streamID length type flags
       * ```
       *
       * Where direction is `<<` for inbound and `>>` for outbound.
       *
       * For example, the following would indicate a HEAD request sent from the client.
       * ```
       * `<< 0x0000000f    12 HEADERS       END_HEADERS|END_STREAM
       * ```
       */
      fun frameLog(
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 5.7K bytes
    - Viewed (0)
  5. cni/pkg/iptables/iptables.go

    		)
    	}
    
    	// CLI: -A ISTIO_OUTPUT -m connmark --mark 0x111/0xfff -j CONNMARK --restore-mark --nfmask 0xffffffff --ctmask 0xffffffff
    	//
    	// DESC: Propagate/restore connmark (if we had one) for outbound
    	iptablesBuilder.AppendRule(
    		iptableslog.UndefinedCommand, ChainInpodOutput, iptablesconstants.MANGLE,
    		"-m", "connmark",
    		"--mark", inpodTproxyMark,
    		"-j", "CONNMARK",
    		"--restore-mark",
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Tue Oct 15 15:39:28 UTC 2024
    - 23.3K bytes
    - Viewed (0)
  6. istioctl/pkg/describe/describe.go

    		clusterName = cs.WeightedClusters.Clusters[0].GetName()
    	}
    
    	// If this is an ingress gateway, the Domains will be something like *:80, so check routes
    	// which will look like "outbound|9080||productpage.default.svc.cluster.local"
    	res := fmt.Sprintf(`outbound\|%d\|[^\|]*\|(?P<service>[^\.]+)\.(?P<namespace>[^\.]+)\.svc\.cluster\.local$`, port)
    	re = regexp.MustCompile(res)
    
    	ss := re.FindStringSubmatch(clusterName)
    	if ss != nil {
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Thu Oct 24 17:36:49 UTC 2024
    - 50.6K bytes
    - Viewed (0)
  7. istioctl/pkg/proxyconfig/proxyconfig.go

      istioctl proxy-config endpoint <pod-name[.namespace]> --address 172.17.0.2 -o json
    
      # Retrieve full endpoint with a cluster name (outbound|9411||zipkin.istio-system.svc.cluster.local).
      istioctl proxy-config endpoint <pod-name[.namespace]> --cluster "outbound|9411||zipkin.istio-system.svc.cluster.local" -o json
      # Retrieve full endpoint with the status (healthy).
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Thu Oct 24 15:53:49 UTC 2024
    - 50.6K bytes
    - Viewed (0)
  8. docs/changelogs/changelog_4x.md

        point were invalid certificates accepted.
     *  New: `OkHttpClient.Builder.minWebSocketMessageToCompress()` configures a threshold for
        compressing outbound web socket messages. Configure this with 0L to always compress outbound
        messages and `Long.MAX_VALUE` to never compress outbound messages. The default is 1024L which
        compresses messages of size 1 KiB and larger. (Inbound messages are compressed or not based on
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Wed Apr 17 13:25:31 UTC 2024
    - 25.2K bytes
    - Viewed (0)
  9. okhttp/src/test/java/okhttp3/internal/http2/MockHttp2Peer.kt

        if (this.client == client) return
        this.client = client
        writer = Http2Writer(bytesOut, client)
      }
    
      fun acceptFrame() {
        frameCount++
      }
    
      /** 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 {
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Thu Apr 11 22:09:35 UTC 2024
    - 8.7K bytes
    - Viewed (0)
  10. internal/grid/muxserver.go

    		handlerIn = make(chan []byte, 1)
    		go func(inbound chan []byte) {
    			wg.Wait()
    			defer xioutil.SafeClose(handlerIn)
    			m.handleInbound(c, inbound, handlerIn)
    		}(m.inbound)
    	}
    	// Fill outbound block.
    	// Each token represents a message that can be sent to the client without blocking.
    	// The client will refill the tokens as they confirm delivery of the messages.
    	for i := 0; i < outboundCap; i++ {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Jun 07 15:51:52 UTC 2024
    - 9.7K bytes
    - Viewed (0)
Back to top