- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 45 for prob (4.56 sec)
-
cni/pkg/nodeagent/net.go
// this can happen if the pod was dynamically added to the mesh after it was created. // in that case, try finding the netns using procfs. if err := s.rescanPod(pod); err != nil { log.Errorf("error scanning proc: error was %s", err) return nil, err } // try again. we can still get here if the pod is in the process of being created. // in this case the CNI will be invoked soon and provide us with the netns.
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Tue Apr 30 22:24:38 GMT 2024 - 12.2K bytes - Viewed (1) -
cni/pkg/nodeagent/server.go
EnableIPv6: args.EnableIPv6, } log.Debug("creating ipsets in the node netns") set, err := createHostsideProbeIpset(cfg.EnableIPv6) if err != nil { return nil, fmt.Errorf("error initializing hostside probe ipset: %w", err) } podNsMap := newPodNetnsCache(openNetnsInRoot(pconstants.HostMountsPath)) ztunnelServer, err := newZtunnelServer(args.ServerSocket, podNsMap) if err != nil {
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Tue Apr 30 22:24:38 GMT 2024 - 7.2K bytes - Viewed (0) -
cni/pkg/repair/netns.go
"github.com/prometheus/procfs" "github.com/vishvananda/netlink" "golang.org/x/sys/unix" corev1 "k8s.io/api/core/v1" "istio.io/istio/pkg/log" ) func getPidNamespace(pid int) string { return "/host/proc/" + strconv.Itoa(pid) + "/ns/net" } func runInHost[T any](f func() (T, error)) (T, error) { var res T ns, err := netns.GetNS(getPidNamespace(1)) if err != nil {
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Wed Dec 20 22:14:13 GMT 2023 - 4.8K bytes - Viewed (0) -
internal/mountinfo/mountinfo.go
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Aug 19 01:35:22 GMT 2021 - 1.1K bytes - Viewed (0) -
cmd/server-rlimit.go
"github.com/minio/minio/internal/logger" "github.com/minio/pkg/v2/sys" ) func oldLinux() bool { currentKernel, err := kernel.CurrentVersion() if err != nil { // Could not probe the kernel version return false } if currentKernel == 0 { // We could not get any valid value return false return false } // legacy linux indicator for printing warnings
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:06:57 GMT 2024 - 2.8K bytes - Viewed (0) -
cmd/metrics-v3-handler.go
// hence not included in the collector path. pathComponents = pathComponents[:bucketIdx] } innerHandler := h.handle(pathComponents, isListingRequest, buckets) // Add tracing to the prom. handler tracedHandler := http.HandlerFunc(func(w http.ResponseWriter, r *http.Request) { tc, ok := r.Context().Value(mcontext.ContextTraceKey).(*mcontext.TraceCtxt) if ok { tc.FuncName = "handler.MetricsV3"
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu May 02 17:37:57 GMT 2024 - 7.5K bytes - Viewed (0) -
internal/dsync/dsync_test.go
} func BenchmarkMutexSpin(b *testing.B) { b.ResetTimer() b.ReportAllocs() // This benchmark models a situation where spinning in the mutex should be // profitable. To achieve this we create a goroutine per-proc. // These goroutines access considerable amount of local data so that // unnecessary rescheduling is penalized by cache misses. m := NewDRWMutex(ds, "") var acc0, acc1 uint64 b.RunParallel(func(pb *testing.PB) {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sat Dec 24 03:49:07 GMT 2022 - 11K bytes - Viewed (0) -
cmd/peer-rest-server.go
if p == k { v.Stop() delete(globalProfiler, k) } } } for _, profiler := range profiles { prof, err := startProfiler(profiler) if err != nil { s.writeErrorResponse(w, err) return } globalProfiler[profiler] = prof } } // DownloadProfilingDataHandler - returns profiled data.
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 51.8K bytes - Viewed (0) -
src/cmd/asm/internal/asm/asm.go
prog.AddRestDest(a[2]) default: prog.From = a[0] prog.Reg = p.getRegister(prog, op, &a[1]) prog.To = a[2] } case sys.I386: prog.From = a[0] prog.AddRestSource(a[1]) prog.To = a[2] case sys.PPC64: if arch.IsPPC64CMP(op) { // CMPW etc.; third argument is a CR register that goes into prog.Reg. prog.From = a[0]
Go - Registered: Tue Apr 30 11:13:12 GMT 2024 - Last Modified: Wed Feb 21 14:34:57 GMT 2024 - 25.3K bytes - Viewed (0) -
cmd/warm-backend.go
type remoteVersionID string // newWarmBackend instantiates the tier type specific WarmBackend, runs // checkWarmBackend on it. func newWarmBackend(ctx context.Context, tier madmin.TierConfig, probe bool) (d WarmBackend, err error) { switch tier.Type { case madmin.S3: d, err = newWarmBackendS3(*tier.S3, tier.Name) case madmin.Azure: d, err = newWarmBackendAzure(*tier.Azure, tier.Name) case madmin.GCS:
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sun Apr 21 11:43:18 GMT 2024 - 3.9K bytes - Viewed (0)