Search Options

Results per page
Sort
Preferred Languages
Advance

Results 11 - 20 of 23 for handle1_ (0.26 sec)

  1. pkg/proxy/nftables/proxier_test.go

    		makeTestEndpointSlice("ns4", "ep4", 1, complexSubset8),
    		nil,
    	}
    
    	testCases := []struct {
    		// previousEndpoints and currentEndpoints are used to call appropriate
    		// handlers OnEndpoints* (based on whether corresponding values are nil
    		// or non-nil) and must be of equal length.
    		name                           string
    		previousEndpoints              []*discovery.EndpointSlice
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat Apr 27 01:31:57 UTC 2024
    - 173.5K bytes
    - Viewed (0)
  2. src/cmd/internal/obj/x86/asm6.go

    			// See issue 57952.
    			ctxt.Diag("mask register must be specified for .Z instructions: %v", p)
    		} else if k.Reg == REG_K0 {
    			// The mask register must not be K0. That restriction is already
    			// handled by the Yknot0 restriction in the opcode tables, so we
    			// won't ever reach here. But put something sensible here just in case.
    			ctxt.Diag("mask register must not be K0 for .Z instructions: %v", p)
    		}
    		evexZ = 1
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Wed May 15 15:44:14 UTC 2024
    - 146.9K bytes
    - Viewed (0)
  3. pkg/proxy/ipvs/proxier_test.go

    		makeTestEndpointSlice("ns4", "ep4", 1, complexSubset8),
    		nil,
    	}
    
    	testCases := []struct {
    		// previousEndpoints and currentEndpoints are used to call appropriate
    		// handlers OnEndpoints* (based on whether corresponding values are nil
    		// or non-nil) and must be of equal length.
    		name                           string
    		previousEndpoints              []*discovery.EndpointSlice
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat Apr 27 01:31:57 UTC 2024
    - 186.8K bytes
    - Viewed (0)
  4. pkg/kubelet/kubelet_test.go

    		kubelet.recorder,
    	)
    	kubelet.setNodeStatusFuncs = kubelet.defaultNodeStatusFuncs()
    
    	// enable active deadline handler
    	activeDeadlineHandler, err := newActiveDeadlineHandler(kubelet.statusManager, kubelet.recorder, kubelet.clock)
    	require.NoError(t, err, "Can't initialize active deadline handler")
    
    	kubelet.AddPodSyncLoopHandler(activeDeadlineHandler)
    	kubelet.AddPodSyncHandler(activeDeadlineHandler)
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Jun 14 16:09:17 UTC 2024
    - 106.9K bytes
    - Viewed (0)
  5. src/net/http/transport_test.go

    				}
    			}
    
    			mu.Lock()
    			got := logbuf.String()
    			mu.Unlock()
    			want := fmt.Sprintf(`Dial
    Write("%s")
    Handler
    intentional write failure
    Retried.
    Dial
    Write("%s")
    Handler
    Write("%s")
    Handler
    `, tc.reqString, tc.reqString, tc.reqString)
    			if got != want {
    				t.Errorf("Log of events differs. Got:\n%s\nWant:\n%s", got, want)
    			}
    		})
    	}
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Thu Jun 06 21:59:21 UTC 2024
    - 192.6K bytes
    - Viewed (0)
  6. pkg/printers/internalversion/printers.go

    	row := metav1.TableRow{
    		Object: runtime.RawExtension{Object: obj},
    	}
    
    	name := obj.Name
    	handler := obj.Handler
    	row.Cells = append(row.Cells, name, handler, translateTimestampSince(obj.CreationTimestamp))
    
    	return []metav1.TableRow{row}, nil
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jun 11 14:04:15 UTC 2024
    - 128.3K bytes
    - Viewed (0)
  7. src/runtime/proc.go

    	gp.sched.g = guintptr(unsafe.Pointer(gp))
    	gp.sched.pc = getcallerpc()
    	gp.sched.sp = getcallersp()
    
    	asminit()
    	minit()
    
    	// Install signal handlers; after minit so that minit can
    	// prepare the thread to be able to handle the signals.
    	if gp.m == &m0 {
    		mstartm0()
    	}
    
    	if fn := gp.m.mstartfn; fn != nil {
    		fn()
    	}
    
    	if gp.m != &m0 {
    		acquirep(gp.m.nextp.ptr())
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Wed May 29 17:58:53 UTC 2024
    - 207.5K bytes
    - Viewed (0)
  8. api/openapi-spec/v3/apis__apiregistration.k8s.io__v1_openapi.json

                "description": "Service is a reference to the service for this API server.  It must communicate on port 443. If the Service is nil, that means the handling for the API groupversion is handled locally on this server. The call will simply delegate to the normal handler chain to be fulfilled."
              },
              "version": {
                "description": "Version is the API version this server hosts.  For example, \"v1\"",
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Mar 08 04:18:56 UTC 2024
    - 135.1K bytes
    - Viewed (0)
  9. src/cmd/go/internal/work/exec.go

    		}
    		a.pending = len(a.Deps)
    		if a.pending == 0 {
    			b.ready.push(a)
    			b.readySema <- true
    		}
    	}
    
    	// Handle runs a single action and takes care of triggering
    	// any actions that are runnable as a result.
    	handle := func(ctx context.Context, a *Action) {
    		if a.json != nil {
    			a.json.TimeStart = time.Now()
    		}
    		var err error
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Mon Jun 10 14:46:37 UTC 2024
    - 105.6K bytes
    - Viewed (0)
  10. src/cmd/go/alldocs.go

    // in no time at all, so a successful package test result will be cached and
    // reused regardless of -timeout setting.
    //
    // In addition to the build flags, the flags handled by 'go test' itself are:
    //
    //	-args
    //	    Pass the remainder of the command line (everything after -args)
    //	    to the test binary, uninterpreted and unchanged.
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Tue Jun 11 16:54:28 UTC 2024
    - 142.4K bytes
    - Viewed (0)
Back to top