Search Options

Results per page
Sort
Preferred Languages
Advance

Results 31 - 40 of 6,372 for callB (0.09 sec)

  1. docs/features/events.md

      }
    
      @Override public void callStart(Call call) {
        printEvent("callStart");
      }
    
      @Override public void callEnd(Call call) {
        printEvent("callEnd");
      }
    
      @Override public void dnsStart(Call call, String domainName) {
        printEvent("dnsStart");
      }
    
      @Override public void dnsEnd(Call call, String domainName, List<InetAddress> inetAddressList) {
        printEvent("dnsEnd");
    Registered: Sun Jun 16 04:42:17 UTC 2024
    - Last Modified: Sun Feb 06 02:19:09 UTC 2022
    - 7.7K bytes
    - Viewed (0)
  2. pilot/pkg/networking/core/serviceentry_simulation_test.go

    	cases := []simulationTest{
    		{
    			name:   "service entries with reused hosts should have auto allocated the same IP address",
    			config: serviceEntriesWithDuplicatedHosts,
    			calls: []simulation.Expect{
    				{
    					Name: "HTTP call",
    					Call: simulation.Call{
    						Address:    "240.240.91.120",
    						Port:       80,
    						HostHeader: "istio.io",
    						Protocol:   simulation.HTTP,
    					},
    					Result: simulation.Result{
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Tue Apr 02 21:06:06 UTC 2024
    - 4.9K bytes
    - Viewed (0)
  3. pilot/pkg/networking/core/gateway_simulation_test.go

            port:
              number: 80
    `,
    			calls: []simulation.Expect{
    				{
    					Name: "a",
    					Call: simulation.Call{
    						Port:       80,
    						HostHeader: "a.example.com",
    						Protocol:   simulation.HTTP,
    					},
    					Result: simulation.Result{ClusterMatched: "outbound|80||a.default"},
    				},
    				{
    					Name: "b",
    					Call: simulation.Call{
    						Port:       80,
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Wed Apr 10 18:27:40 UTC 2024
    - 46.5K bytes
    - Viewed (0)
  4. pilot/pkg/networking/core/sidecar_simulation_test.go

    	} {
    		calls = append(calls, simulation.Expect{
    			Name: fmt.Sprintf("%s-%d", call.call.Protocol, call.call.Port),
    			Call: call.call,
    			Result: simulation.Result{
    				ClusterMatched: fmt.Sprintf("outbound|%d||%s.default.svc.cluster.local", call.call.Port, call.expected),
    			},
    		})
    	}
    	service := `apiVersion: v1
    kind: Service
    metadata:
      name: alias
      namespace: default
    spec:
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu Jun 13 01:56:28 UTC 2024
    - 84.7K bytes
    - Viewed (0)
  5. src/sync/oncefunc_test.go

    func TestOnceFunc(t *testing.T) {
    	calls := 0
    	f := sync.OnceFunc(func() { calls++ })
    	allocs := testing.AllocsPerRun(10, f)
    	if calls != 1 {
    		t.Errorf("want calls==1, got %d", calls)
    	}
    	if allocs != 0 {
    		t.Errorf("want 0 allocations per call, got %v", allocs)
    	}
    }
    
    func TestOnceValue(t *testing.T) {
    	calls := 0
    	f := sync.OnceValue(func() int {
    		calls++
    		return calls
    	})
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Tue Nov 21 17:31:33 UTC 2023
    - 6.9K bytes
    - Viewed (0)
  6. src/net/rpc/client.go

    		} else {
    			err = io.ErrUnexpectedEOF
    		}
    	}
    	for _, call := range client.pending {
    		call.Error = err
    		call.done()
    	}
    	client.mutex.Unlock()
    	client.reqMutex.Unlock()
    	if debugLog && err != io.EOF && !closing {
    		log.Println("rpc: client protocol error:", err)
    	}
    }
    
    func (call *Call) done() {
    	select {
    	case call.Done <- call:
    		// ok
    	default:
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Wed Jan 10 03:29:50 UTC 2024
    - 9K bytes
    - Viewed (0)
  7. src/log/slog/logger.go

    // Before [SetDefault] is called, slog top-level logging functions call the default [log.Logger].
    // In that mode, SetLogLoggerLevel sets the minimum level for those calls.
    // By default, the minimum level is Info, so calls to [Debug]
    // (as well as top-level logging calls at lower levels)
    // will not be passed to the log.Logger. After calling
    //
    //	slog.SetLogLoggerLevel(slog.LevelDebug)
    //
    // calls to [Debug] will be passed to the log.Logger.
    //
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Mon Jan 08 18:26:18 UTC 2024
    - 10.2K bytes
    - Viewed (0)
  8. src/sync/once.go

    // arguments to a function to be invoked by Do:
    //
    //	config.once.Do(func() { config.init(filename) })
    //
    // Because no call to Do returns until the one call to f returns, if f causes
    // Do to be called, it will deadlock.
    //
    // If f panics, Do considers it to have returned; future calls of Do return
    // without calling f.
    func (o *Once) Do(f func()) {
    	// Note: Here is an incorrect implementation of Do:
    	//
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Fri Jun 07 21:14:51 UTC 2024
    - 2.5K bytes
    - Viewed (0)
  9. okhttp/src/main/kotlin/okhttp3/internal/http/RealInterceptorChain.kt

        return copy(writeTimeoutMillis = checkDuration("writeTimeout", timeout.toLong(), unit))
      }
    
      override fun call(): Call = call
    
      override fun request(): Request = request
    
      @Throws(IOException::class)
      override fun proceed(request: Request): Response {
        check(index < interceptors.size)
    
        calls++
    
        if (exchange != null) {
          check(exchange.finder.routePlanner.sameHostAndPort(request.url)) {
    Registered: Sun Jun 16 04:42:17 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 4.2K bytes
    - Viewed (0)
  10. okhttp/src/test/java/okhttp3/RecordingExecutor.kt

      }
    
      fun finishJob(url: String) {
        val i = calls.iterator()
        while (i.hasNext()) {
          val call = i.next()
          if (call.request.url.toString() == url) {
            i.remove()
            dispatcherTest.dispatcher.finishedAccessor(call)
            return
          }
        }
        throw AssertionError("No such job: $url")
      }
    
      override fun shutdown() {
        shutdown = true
      }
    
      override fun shutdownNow(): List<Runnable> {
    Registered: Sun Jun 16 04:42:17 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 2.1K bytes
    - Viewed (0)
Back to top