- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 72 for original (0.24 sec)
-
cni/pkg/nodeagent/netns_linux.go
return err } defer func() { err := threadNS.Set() // switch back if err == nil { // Unlock the current thread only when we successfully switched back // to the original namespace; otherwise leave the thread locked which // will force the runtime to scrap the current thread, that is maybe // not as optimal but at least always safe to do. runtime.UnlockOSThread() } }()
Go - Registered: Wed Apr 24 22:53:08 GMT 2024 - Last Modified: Wed Jan 31 10:05:36 GMT 2024 - 2.7K bytes - Viewed (0) -
cni/pkg/nodeagent/pod_cache_test.go
ns2 := newFakeNsInode(inc(), 1) wl2 := WorkloadInfo{ Workload: podToWorkload(pod), Netns: ns2, } // when using same uid, the original netns should be returned netns2 := p.UpsertPodCacheWithNetns(string(pod.UID), wl2) if netns2 != ns { t.Fatalf("Expected the original Netns for the same uid, got %p and %p", netns2, ns) } if !ns2.closed.Load() { t.Fatalf("Expected the second Netns to be closed") } }
Go - Registered: Wed Apr 24 22:53:08 GMT 2024 - Last Modified: Fri Apr 12 21:47:31 GMT 2024 - 4.2K bytes - Viewed (0) -
buildscripts/heal-manual.go
"encoding/json" "fmt" "log" "os" "time" "github.com/minio/madmin-go/v3" ) func main() { // Note: YOUR-ACCESSKEYID, YOUR-SECRETACCESSKEY are // dummy values, please replace them with original values. // API requests are secure (HTTPS) if secure=true and insecure (HTTP) otherwise. // New returns an MinIO Admin client object. madmClnt, err := madmin.New(os.Args[1], os.Args[2], os.Args[3], false)
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Tue Feb 27 09:47:58 GMT 2024 - 2.3K bytes - Viewed (0) -
src/cmd/cgo/internal/cgotest/overlaydir.go
if err != nil { return err } perm = info.Mode() & os.ModePerm } // Always copy directories (don't symlink them). // If we add a file in the overlay, we don't want to add it in the original. if info.IsDir() { return os.MkdirAll(dstPath, perm|0200) } // If the OS supports symlinks, use them instead of copying bytes. if err := os.Symlink(srcPath, dstPath); err == nil { return nil }
Go - Registered: Tue Apr 30 11:13:12 GMT 2024 - Last Modified: Mon May 22 20:56:09 GMT 2023 - 1.7K bytes - Viewed (0) -
istioctl/pkg/writer/envoy/configdump/route.go
shouldDelete.Insert(h) } stripPartial := strings.TrimSuffix(h, ".svc") if unique.Contains(stripPartial) && stripPartial != h { shouldDelete.Insert(h) } } // Filter from original list to keep original order ret := make([]string, 0, len(domains)) for _, h := range domains { if !shouldDelete.Contains(h) { ret = append(ret, h) } } return ret }
Go - Registered: Wed Apr 24 22:53:08 GMT 2024 - Last Modified: Thu May 11 05:38:17 GMT 2023 - 7.2K bytes - Viewed (0) -
cmd/erasure-metadata-utils.go
distribution := fi.Erasure.Distribution var inconsistent int for i, meta := range metaArr { if disks[i] == nil { // Assuming offline drives as inconsistent, // to be safe and fallback to original // distribution order. inconsistent++ continue } if !meta.IsValid() { inconsistent++ continue } if meta.XLV1 != fi.XLV1 { inconsistent++ continue }
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Tue Apr 23 17:15:52 GMT 2024 - 11.3K bytes - Viewed (0) -
internal/config/dns/types.go
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Tue Jun 01 21:59:40 GMT 2021 - 2K bytes - Viewed (0) -
cmd/service.go
cmd.Stdout = os.Stdout cmd.Stderr = os.Stderr cmd.Stdin = os.Stdin cmd.Env = os.Environ() err := cmd.Run() if err == nil { os.Exit(0) } return err } // Use the original binary location. This works with symlinks such that if // the file it points to has been changed we will use the updated symlink. argv0, err := exec.LookPath(os.Args[0]) if err != nil { return err }
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Wed Feb 28 07:02:14 GMT 2024 - 3.8K bytes - Viewed (0) -
internal/config/crypto_test.go
} data, err = io.ReadAll(plaintext) if err != nil { t.Fatalf("Test %d: failed to decrypt stream: %v", i, err) } if !bytes.Equal(data, test.Data) { t.Fatalf("Test %d: decrypted data does not match original data", i) } } } func BenchmarkEncrypt(b *testing.B) { key, err := hex.DecodeString("ddedadb867afa3f73bd33c25499a723ed7f9f51172ee7b1b679e08dc795debcc") if err != nil {
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Mon Sep 19 18:05:16 GMT 2022 - 3.2K bytes - Viewed (0) -
internal/handlers/forwarder.go
} w.WriteHeader(http.StatusBadGateway) } func (f *Forwarder) getURLFromRequest(req *http.Request) *url.URL { // If the Request was created by Go via a real HTTP request, RequestURI will // contain the original query string. If the Request was created in code, RequestURI // will be empty, and we will use the URL object instead u := req.URL if req.RequestURI != "" { parsedURL, err := url.ParseRequestURI(req.RequestURI)
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Fri Apr 07 05:42:10 GMT 2023 - 5.6K bytes - Viewed (0)