- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 20 for tasks (0.16 sec)
-
cmd/notification.go
// the same overall task. // // A zero NotificationGroup is valid and does not cancel on error. type NotificationGroup struct { workers *workers.Workers errs []NotificationPeerErr retryCount int } // WithNPeers returns a new NotificationGroup with length of errs slice upto nerrs, // upon Wait() errors are returned collected from all tasks. func WithNPeers(nerrs int) *NotificationGroup {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri Apr 12 18:13:36 GMT 2024 - 44.5K bytes - Viewed (0) -
cmd/peer-s3-client.go
// buckets only and not the quourum lost ones like this, so // explicit call for bktName, count := range bucketsMap { if count < quorum { // Queue a bucket heal task globalMRFState.addPartialOp(partialOperation{ bucket: bktName, queued: time.Now(), }) } } } result := make([]BucketInfo, 0, len(resultMap))
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 14.8K bytes - Viewed (0) -
cni/pkg/iptables/iptables.go
iptablesconstants "istio.io/istio/tools/istio-iptables/pkg/constants" dep "istio.io/istio/tools/istio-iptables/pkg/dependencies" iptableslog "istio.io/istio/tools/istio-iptables/pkg/log" ) const ( // INPOD marks/masks InpodTProxyMark = 0x111 InpodTProxyMask = 0xfff InpodMark = 1337 // this needs to match the inpod config mark in ztunnel. InpodMask = 0xfff InpodRestoreMask = 0xffffffff
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Tue May 07 19:54:50 GMT 2024 - 19.7K bytes - Viewed (0) -
src/cmd/asm/internal/asm/asm.go
Offset: frameSize, // Argsize set below. }, } nameAddr.Sym.Func().Text = prog prog.To.Val = int32(argSize) p.append(prog, "", true) } // asmData assembles a DATA pseudo-op. // DATA masks<>+0x00(SB)/4, $0x00000000 func (p *Parser) asmData(operands [][]lex.Token) { if len(operands) != 2 { p.errorf("expect two operands for DATA") return } // Operand 0 has the general form foo<>+0x04(SB)/4.
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/xl-storage.go
b, err := os.ReadFile(healingFile) if err != nil { return nil } h := newHealingTracker() _, err = h.UnmarshalMsg(b) bugLogIf(GlobalContext, err) return h } // checkODirectDiskSupport asks the disk to write some data // with O_DIRECT support, return an error if any and return // errUnsupportedDisk if there is no O_DIRECT support func (s *xlStorage) checkODirectDiskSupport(fsType string) error {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sun Apr 28 17:53:50 GMT 2024 - 84.7K bytes - Viewed (0) -
istioctl/pkg/describe/describe.go
if hIP := ingress.pods[0].Status.HostIP; hIP != "" { return hIP } // The scope of this function is to get the IP from Kubernetes, we do not // ask Docker or minikube for an IP. // See https://istio.io/docs/tasks/traffic-management/ingress/ingress-control/#determining-the-ingress-ip-and-ports return "unknown" } func printIngressInfo( writer io.Writer, matchingServices []corev1.Service, podsLabels []klabels.Set,
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Sat Apr 13 05:23:38 GMT 2024 - 50.4K bytes - Viewed (0) -
cmd/veeam-sos-api.go
// Vendors might change the settings based on the configuration and scale out of the solution (more storage nodes => // higher task limit). // // <S3ConcurrentTaskLimit> // // - Defines how many S3 operations are executed parallel within one Repository Task Slot (and within one backup object // that gets offloaded). The same registry key setting overwrites the storage-defined setting.
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Jan 30 18:43:58 GMT 2024 - 8.2K bytes - Viewed (2) -
misc/ios/go_ios_exec.go
<!DOCTYPE plist PUBLIC "-//Apple//DTD PLIST 1.0//EN" "http://www.apple.com/DTDs/PropertyList-1.0.dtd"> <plist version="1.0"> <dict> <key>keychain-access-groups</key> <array><string>` + appID + `</string></array> <key>get-task-allow</key> <true/> <key>application-identifier</key> <string>` + appID + `</string> <key>com.apple.developer.team-identifier</key> <string>` + teamID + `</string> </dict> </plist> ` }
Go - Registered: Tue Apr 30 11:13:12 GMT 2024 - Last Modified: Mon Apr 11 16:34:30 GMT 2022 - 23.4K bytes - Viewed (0) -
cmd/callhome.go
"fmt" "math/rand" "net/url" "time" "github.com/minio/madmin-go/v3" ) var callhomeLeaderLockTimeout = newDynamicTimeout(30*time.Second, 10*time.Second) // initCallhome will start the callhome task in the background. func initCallhome(ctx context.Context, objAPI ObjectLayer) { if !globalCallhomeConfig.Enabled() { return } go func() { r := rand.New(rand.NewSource(time.Now().UnixNano()))
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 5.1K bytes - Viewed (1) -
src/cmd/asm/internal/asm/operand_test.go
{"$10", "$10"}, {"$1000", "$1000"}, {"$1000000", "$1000000"}, {"$1000000000", "$1000000000"}, {"$__tsan_func_enter(SB)", "$__tsan_func_enter(SB)"}, {"$main(SB)", "$main(SB)"}, {"$masks<>(SB)", "$masks<>(SB)"}, {"$setg_gcc<>(SB)", "$setg_gcc<>(SB)"}, {"$shifts<>(SB)", "$shifts<>(SB)"}, {"$~(1<<63)", "$9223372036854775807"}, {"$~0x3F", "$-64"}, {"$~15", "$-16"}, {"(((8)&0xf)*4)(SP)", "32(SP)"},
Go - Registered: Tue Apr 30 11:13:12 GMT 2024 - Last Modified: Tue Aug 29 18:31:05 GMT 2023 - 23.9K bytes - Viewed (0)