Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 35 for plano (0.14 sec)

  1. okhttp/src/test/java/okhttp3/internal/connection/FastFallbackExchangeFinderTest.kt

        plan0.tcpConnectDelayNanos = 280.ms
    
        val plan1 = routePlanner.addPlan()
        plan1.tcpConnectDelayNanos = 10.ms // Connect at time = 260 ms.
        plan1.tlsConnectDelayNanos = 10.ms // Connect at time = 270 ms.
        plan1.tlsConnectThrowable = IOException("boom!")
    
        val plan2 = plan1.createConnectTlsNextPlan()
        plan2.tcpConnectDelayNanos = 270.ms // Connect at time = 540 ms.
    
        val plan3 = plan0.createRetry()
    Plain Text
    - Registered: Fri May 03 11:42:14 GMT 2024
    - Last Modified: Wed Apr 24 04:40:49 GMT 2024
    - 20.9K bytes
    - Viewed (0)
  2. okhttp/src/test/java/okhttp3/FakeRoutePlanner.kt

        if (nextPlanIndex >= plans.size && autoGeneratePlans) addPlan()
    
        require(nextPlanIndex < plans.size) {
          "not enough plans! call addPlan() or set autoGeneratePlans=true in the test to set this up"
        }
        val result = plans[nextPlanIndex++]
        events += "take plan ${result.id}"
    
        if (result.yieldBeforePlanReturns) {
          taskFaker.yield()
        }
    
    Plain Text
    - Registered: Fri May 03 11:42:14 GMT 2024
    - Last Modified: Wed Apr 24 04:40:49 GMT 2024
    - 6.2K bytes
    - Viewed (0)
  3. okhttp/src/main/kotlin/okhttp3/internal/connection/RealRoutePlanner.kt

      private var routeSelector: RouteSelector? = null
      private var nextRouteToTry: Route? = null
    
      override val deferredPlans = ArrayDeque<Plan>()
    
      override fun isCanceled(): Boolean = connectionUser.isCanceled()
    
      @Throws(IOException::class)
      override fun plan(): Plan {
        val reuseCallConnection = planReuseCallConnection()
        if (reuseCallConnection != null) return reuseCallConnection
    
    Plain Text
    - Registered: Fri May 03 11:42:14 GMT 2024
    - Last Modified: Sat Apr 20 17:03:43 GMT 2024
    - 12K bytes
    - Viewed (0)
  4. istioctl/pkg/writer/ztunnel/configdump/testdata/workloadsummary.txt

    kube-system        coredns-5dd5756b68-mgjn9                             10.244.0.2  ambient-control-plane None                                TCP
    kube-system        coredns-5dd5756b68-nzlpw                             10.244.0.3  ambient-control-plane None                                TCP
    local-path-storage local-path-provisioner-6f8956fb48-vvnpn              10.244.0.4  ambient-control-plane None                                TCP
    Plain Text
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Tue Apr 23 21:30:30 GMT 2024
    - 4K bytes
    - Viewed (0)
  5. okhttp/src/main/kotlin/okhttp3/internal/connection/ConnectPlan.kt

      private val user: ConnectionUser,
      private val routePlanner: RealRoutePlanner,
      // Specifics to this plan.
      override val route: Route,
      internal val routes: List<Route>?,
      private val attempt: Int,
      private val tunnelRequest: Request?,
      internal val connectionSpecIndex: Int,
      internal val isTlsFallback: Boolean,
    ) : RoutePlanner.Plan, ExchangeCodec.Carrier {
      /** True if this connect was canceled; typically because it lost a race. */
    Plain Text
    - Registered: Fri May 03 11:42:14 GMT 2024
    - Last Modified: Sat Apr 20 17:03:43 GMT 2024
    - 18.6K bytes
    - Viewed (0)
  6. istioctl/pkg/writer/compare/comparator.go

    // limitations under the License.
    
    package compare
    
    import (
    	"encoding/json"
    	"fmt"
    	"io"
    	"strings"
    
    	admin "github.com/envoyproxy/go-control-plane/envoy/admin/v3"
    	discovery "github.com/envoyproxy/go-control-plane/envoy/service/discovery/v3"
    	legacyproto "github.com/golang/protobuf/proto" // nolint: staticcheck
    	exprpb "google.golang.org/genproto/googleapis/api/expr/v1alpha1"
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Sun Apr 21 17:42:54 GMT 2024
    - 3.7K bytes
    - Viewed (1)
  7. manifests/charts/istiod-remote/values.yaml

        #
        # certSigners:
        #   - clusterissuers.cert-manager.io/istio-ca
        certSigners: []
        # enable pod disruption budget for the control plane, which is used to
        # ensure Istio control plane components are gradually upgraded or recovered.
        defaultPodDisruptionBudget:
          enabled: true
          # The values aren't mutable due to a current PodDisruptionBudget limitation
    Others
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Mon Apr 22 22:00:40 GMT 2024
    - 20.2K bytes
    - Viewed (0)
  8. doc/godebug.md

    restores the installation and use of preinstalled `.a` files.
    
    There is no plan to remove any of these settings.
    
    ### Go 1.19
    
    Go 1.19 made it an error for path lookups to resolve to binaries in the current directory,
    controlled by the [`execerrdot` setting](/pkg/os/exec#hdr-Executables_in_the_current_directory).
    There is no plan to remove this setting.
    
    ### Go 1.18
    
    Plain Text
    - Registered: Tue May 07 11:14:38 GMT 2024
    - Last Modified: Tue Apr 16 17:29:58 GMT 2024
    - 13.5K bytes
    - Viewed (0)
  9. istioctl/pkg/writer/envoy/configdump/endpoint.go

    package configdump
    
    import (
    	"encoding/json"
    	"fmt"
    	"sort"
    	"strconv"
    	"strings"
    	"text/tabwriter"
    
    	core "github.com/envoyproxy/go-control-plane/envoy/config/core/v3"
    	endpoint "github.com/envoyproxy/go-control-plane/envoy/config/endpoint/v3"
    	"google.golang.org/protobuf/types/known/anypb"
    	"sigs.k8s.io/yaml"
    
    	"istio.io/istio/istioctl/pkg/util/proto"
    	"istio.io/istio/pilot/pkg/networking/util"
    )
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Sun Apr 21 17:42:54 GMT 2024
    - 5.6K bytes
    - Viewed (0)
  10. operator/cmd/mesh/install.go

    		var icpTag string
    		// create normalized tags for multiple control plane revisions
    		for _, icp := range *icps {
    			if icp.Revision != revision {
    				continue
    			}
    			tagVer, err := GetTagVersion(icp.Info.GitTag)
    			if err != nil {
    				return err
    			}
    			icpTags = append(icpTags, tagVer)
    		}
    		// sort different versions of control plane revisions
    		sort.Strings(icpTags)
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Thu May 02 14:30:43 GMT 2024
    - 15.5K bytes
    - Viewed (1)
Back to top