- Sort Score
- Result 10 results
- Languages All
Results 41 - 50 of 70 for probing (1.29 sec)
-
src/internal/trace/testtrace/validation.go
// generate a Log. The category and message are entirely user-created, // so we can't make any assumptions as to what they are. We also // can't validate the task, because proving the task's existence is very // much best-effort. _ = ev.Log() } return e.Errors() } func (v *Validator) hasRange(r trace.ResourceID, name string) bool { ranges, ok := v.ranges[r]
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri May 17 18:48:18 UTC 2024 - 10.9K bytes - Viewed (0) -
src/runtime/debug/garbage.go
func FreeOSMemory() { freeOSMemory() } // SetMaxStack sets the maximum amount of memory that // can be used by a single goroutine stack. // If any goroutine exceeds this limit while growing its stack, // the program crashes. // SetMaxStack returns the previous setting. // The initial setting is 1 GB on 64-bit systems, 250 MB on 32-bit systems. // There may be a system-imposed maximum stack limit regardless
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 23 01:00:11 UTC 2024 - 9.9K bytes - Viewed (0) -
pkg/controlplane/apiserver/config.go
return config, genericInitializers, nil } // CreateProxyTransport creates the dialer infrastructure to connect to the nodes. func CreateProxyTransport() *http.Transport { var proxyDialerFn utilnet.DialFunc // Proxying to pods and services is IP-based... don't expect to be able to verify the hostname proxyTLSClientConfig := &tls.Config{InsecureSkipVerify: true} proxyTransport := utilnet.SetTransportDefaults(&http.Transport{
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jun 07 17:57:37 UTC 2024 - 14.9K bytes - Viewed (0) -
src/cmd/vendor/golang.org/x/telemetry/start.go
} cmd.Dir = telemetry.Default.LocalDir() // The child process must write to a log file, not // the stderr file it inherited from the parent, as // the child may outlive the parent but should not prolong // the life of any pipes created (by the grandparent) // to gather the output of the parent. // // By default, we discard the child process's stderr, // but in line with the uploader, log to a file in debug
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Jun 04 14:52:56 UTC 2024 - 10.8K bytes - Viewed (0) -
pkg/scheduler/schedule_one.go
UnschedulablePlugins: sets.New(status.Plugin()), }, } return framework.NewStatus(status.Code()).WithError(fitErr) } return status } // Run "prebind" plugins. if status := fwk.RunPreBindPlugins(ctx, state, assumedPod, scheduleResult.SuggestedHost); !status.IsSuccess() { if status.IsRejected() { fitErr := &framework.FitError{ NumAllNodes: 1,
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Jun 06 13:28:08 UTC 2024 - 43.4K bytes - Viewed (0) -
src/index/suffixarray/suffixarray_test.go
cleanup := setBits(bits) defer cleanup() b.StopTimer() x := New(data) size := testSaveRestore(nil, nil, x) // verify correctness buf := bytes.NewBuffer(make([]byte, size)) // avoid growing b.SetBytes(int64(size)) b.StartTimer() b.ReportAllocs() for i := 0; i < b.N; i++ { buf.Reset() if err := x.Write(buf); err != nil { b.Fatal(err) } var y Index
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 23 01:00:11 UTC 2024 - 14.1K bytes - Viewed (0) -
pkg/scheduler/schedule_one_test.go
eventBroadcaster := events.NewBroadcaster(&events.EventSinkImpl{Interface: client.EventsV1()}) errS := errors.New("scheduler") errB := errors.New("binder") preBindErr := errors.New("on PreBind") table := []struct { name string injectBindError error sendPod *v1.Pod registerPluginFuncs []tf.RegisterPluginFunc expectErrorPod *v1.Pod
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 04 06:20:55 UTC 2024 - 128.1K bytes - Viewed (0) -
src/go/token/position.go
defer s.mutex.Unlock() if i := searchFiles(s.files, file.base); i >= 0 && s.files[i] == file { last := &s.files[len(s.files)-1] s.files = append(s.files[:i], s.files[i+1:]...) *last = nil // don't prolong lifetime when popping last element } } // Iterate calls f for the files in the file set in the order they were added // until f returns false. func (s *FileSet) Iterate(f func(*File) bool) {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 23 01:00:11 UTC 2024 - 19.7K bytes - Viewed (0) -
internal/grid/handlers.go
} h.ignoreNilConn = true return h } // WithSharedResponse indicates it is unsafe to reuse the response // when it has been returned on a handler. // This will disable automatic response recycling/pooling. // Typically this is used when the response sharing part of its data structure. func (h *SingleHandler[Req, Resp]) WithSharedResponse() *SingleHandler[Req, Resp] { h.sharedResp = true return h }
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Mon Jun 10 15:51:27 UTC 2024 - 27.1K bytes - Viewed (0) -
pkg/istio-agent/xds_proxy.go
type adsStream interface { Send(*discovery.DiscoveryResponse) error Recv() (*discovery.DiscoveryRequest, error) Context() context.Context } // StreamAggregatedResources is an implementation of XDS API used for proxying between Istiod and Envoy. // Every time envoy makes a fresh connection to the agent, we reestablish a new connection to the upstream xds
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu May 16 22:12:28 UTC 2024 - 27.9K bytes - Viewed (0)