- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 20 for fh (0.15 sec)
-
pkg/proxy/util/nfacct/nfacct_linux_test.go
func (fh *fakeHandler) newRequest(cmd int, flags uint16) request { var response [][]byte if fh.responses != nil && len(fh.responses) > 0 { response = fh.responses[0] // remove the response from the list of predefined responses and add it to request object for mocking. fh.responses = fh.responses[1:] } var err error if fh.errs != nil && len(fh.errs) > 0 { err = fh.errs[0]
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat Apr 27 06:47:50 UTC 2024 - 18.8K bytes - Viewed (0) -
src/net/http/clone.go
// See go.dev/issue/67401. // //go:linkname cloneMultipartFileHeader func cloneMultipartFileHeader(fh *multipart.FileHeader) *multipart.FileHeader { if fh == nil { return nil } fh2 := new(multipart.FileHeader) *fh2 = *fh fh2.Header = textproto.MIMEHeader(Header(fh.Header).Clone()) return fh2 } // cloneOrMakeHeader invokes Header.Clone but if the
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 23 01:17:26 UTC 2024 - 3K bytes - Viewed (0) -
pkg/scheduler/framework/preemption/preemption.go
} logger.V(2).Info("Preemptor Pod preempted victim Pod", "preemptor", klog.KObj(pod), "victim", klog.KObj(victim), "node", c.Name()) } fh.EventRecorder().Eventf(victim, pod, v1.EventTypeNormal, "Preempted", "Preempting", "Preempted by pod %v on node %v", pod.UID, c.Name()) } fh.Parallelizer().Until(ctx, len(c.Victims().Pods), preemptPod, ev.PluginName) if err := errCh.ReceiveError(); err != nil { return framework.AsStatus(err)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri May 31 15:52:16 UTC 2024 - 25.1K bytes - Viewed (0) -
src/net/http/h2_bundle.go
if fr.AllowIllegalReads { return nil } fh := f.Header() if fr.lastHeaderStream != 0 { if fh.Type != http2FrameContinuation { return fr.connError(http2ErrCodeProtocol, fmt.Sprintf("got %s for stream %d; expected CONTINUATION following %s for stream %d", fh.Type, fh.StreamID, last.Header().Type, fr.lastHeaderStream)) } if fh.StreamID != fr.lastHeaderStream {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Jun 04 16:19:04 UTC 2024 - 364.1K bytes - Viewed (0) -
src/cmd/vendor/github.com/google/pprof/internal/elfexec/elfexec.go
// address to get symbol table address. For an executable, the base // is 0. Otherwise, it's a shared library, and the base is the // address where the mapping starts. The kernel needs special handling. func GetBase(fh *elf.FileHeader, loadSegment *elf.ProgHeader, stextOffset *uint64, start, limit, offset uint64) (uint64, error) { if start == 0 && offset == 0 && (limit == ^uint64(0) || limit == 0) {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri May 31 19:48:28 UTC 2024 - 13.9K bytes - Viewed (0) -
pkg/scheduler/framework/plugins/dynamicresources/dynamicresources.go
func New(ctx context.Context, plArgs runtime.Object, fh framework.Handle, fts feature.Features) (framework.Plugin, error) { if !fts.EnableDynamicResourceAllocation { // Disabled, won't do anything. return &dynamicResources{}, nil } logger := klog.FromContext(ctx) pl := &dynamicResources{ enabled: true, fh: fh, clientset: fh.ClientSet(),
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu May 30 15:22:37 UTC 2024 - 75.9K bytes - Viewed (0) -
src/net/http/request_test.go
} } } func testMissingFile(t *testing.T, req *Request) { f, fh, err := req.FormFile("missing") if f != nil { t.Errorf("FormFile file = %v, want nil", f) } if fh != nil { t.Errorf("FormFile file header = %v, want nil", fh) } if err != ErrMissingFile { t.Errorf("FormFile err = %q, want ErrMissingFile", err) } }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 16 18:42:34 UTC 2024 - 44K bytes - Viewed (0) -
pkg/scheduler/framework/runtime/framework_test.go
r := make(Registry) r.Register(preFilterPluginName, func(_ context.Context, _ runtime.Object, fh framework.Handle) (framework.Plugin, error) { return preFilter1, nil }) r.Register(preFilterWithExtensionsPluginName, func(_ context.Context, _ runtime.Object, fh framework.Handle) (framework.Plugin, error) { return preFilter2, nil })
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri May 17 09:07:27 UTC 2024 - 103K bytes - Viewed (0) -
pkg/kube/kclient/client.go
defer n.handlerMu.Unlock() for _, c := range n.registeredHandlers { _ = n.informer.RemoveEventHandler(c.registration) } } func (n *informerClient[T]) AddEventHandler(h cache.ResourceEventHandler) { fh := cache.FilteringResourceEventHandler{ FilterFunc: func(obj interface{}) bool { if n.filter == nil { return true } return n.filter(obj) }, Handler: h, } n.handlerMu.Lock()
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri May 17 07:14:28 UTC 2024 - 13K bytes - Viewed (0) -
pkg/scheduler/framework/plugins/defaultpreemption/default_preemption_test.go
t.Fatal(err) } pl := &DefaultPreemption{ fh: fwk, podLister: informerFactory.Core().V1().Pods().Lister(), pdbLister: getPDBLister(informerFactory), args: *getDefaultDefaultPreemptionArgs(), } pe := preemption.Evaluator{ PluginName: names.DefaultPreemption, Handler: pl.fh, PodLister: pl.podLister, PdbLister: pl.pdbLister,
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri May 31 15:52:16 UTC 2024 - 82.8K bytes - Viewed (0)