- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 17 for Ask (0.16 sec)
-
cmd/metacache-set.go
askDisks = getListQuorum("strict", er.setDriveCount) } } var fallbackDisks []StorageAPI // Special case: ask all disks if the drive count is 4 if er.setDriveCount == 4 || askDisks > len(disks) { askDisks = len(disks) // use all available drives } // However many we ask, versions must exist on ~50% listingQuorum := (askDisks + 1) / 2 if askDisks > 0 && len(disks) > askDisks {
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Fri Apr 26 19:52:52 GMT 2024 - 30.4K bytes - Viewed (0) -
src/cmd/cgo/internal/swig/swig_test.go
} out, err := cmd.CombinedOutput() if string(out) != "OK\n" { t.Errorf("%s", string(out)) } if err != nil { t.Errorf("%s", err) } } func mustHaveCxx(t *testing.T) { // Ask the go tool for the CXX it's configured to use. cxx, err := exec.Command("go", "env", "CXX").CombinedOutput() if err != nil { t.Fatalf("go env CXX failed: %s", err) } args, err := quoted.Split(string(cxx))
Go - Registered: Tue Apr 23 11:13:09 GMT 2024 - Last Modified: Fri May 12 12:00:07 GMT 2023 - 3.7K bytes - Viewed (0) -
istioctl/pkg/validate/validate.go
if err := checkFields(un); err != nil { return nil, err } // IstioOperator isn't part of pkg/config/schema/collections, // usual conversion not available. Convert unstructured to string // and ask operator code to check. un.SetCreationTimestamp(metav1.Time{}) // UnmarshalIstioOperator chokes on these by := util.ToYAML(un) iop, err := operatoristio.UnmarshalIstioOperator(by, false) if err != nil {
Go - Registered: Wed May 01 22:53:12 GMT 2024 - Last Modified: Mon Jan 22 17:58:52 GMT 2024 - 15K bytes - Viewed (0) -
internal/bucket/encryption/bucket-sse-config.go
return nil, errors.New("MasterKeyID contains unsupported characters") } } } if config.XMLNS == "" { config.XMLNS = xmlNS } return &config, nil } // ApplyOptions ask for specific features to be enabled, // when bucketSSEConfig is empty. type ApplyOptions struct { AutoEncrypt bool } // Apply applies the SSE bucket configuration on the given HTTP headers and
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Tue Oct 25 00:44:15 GMT 2022 - 4.9K bytes - Viewed (0) -
internal/http/check_port_test.go
) // Tests for port availability logic written for server startup sequence. func TestCheckPortAvailability(t *testing.T) { if runtime.GOOS != "linux" { t.Skip() } l, err := net.Listen("tcp", "localhost:0") // ask kernel for a free port. if err != nil { t.Fatal(err) } defer l.Close() port := l.Addr().(*net.TCPAddr).Port testCases := []struct { host string port int expectedErr error
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Wed May 03 21:12:25 GMT 2023 - 1.9K bytes - Viewed (0) -
src/bytes/buffer_test.go
for i := 0; i <= 5; i++ { for j := i; j <= 5; j++ { for k := 0; k <= 6; k++ { // 0 <= i <= j <= 5; 0 <= k <= 6 // Check that if we start with a buffer // of length j at offset i and ask for // Next(k), we get the right bytes. buf := NewBuffer(b[0:j]) n, _ := buf.Read(tmp[0:i]) if n != i { t.Fatalf("Read %d returned %d", i, n) } bb := buf.Next(k) want := k
Go - Registered: Tue Apr 30 11:13:12 GMT 2024 - Last Modified: Fri Apr 26 13:31:36 GMT 2024 - 18.6K bytes - Viewed (0) -
istioctl/pkg/describe/describe.go
svcHost := extendFQDN(fmt.Sprintf("%s.%s", svc.ObjectMeta.Name, svc.ObjectMeta.Namespace)) filter := istio_envoy_configdump.ClusterFilter{ FQDN: host.Name(svcHost), Port: int(port), // Although we want inbound traffic, ask for outbound traffic, as the DR is // not associated with the inbound traffic. Direction: model.TrafficDirectionOutbound, } dump, err := cd.GetClusterConfigDump() if err != nil { return "", err }
Go - Registered: Wed May 01 22:53:12 GMT 2024 - Last Modified: Sat Apr 13 05:23:38 GMT 2024 - 50.4K bytes - Viewed (0) -
cmd/metacache-server-pool.go
} // We have 2 cases: // 1) Cold listing, just list. // 2) Returning, but with no id. Start async listing. // 3) Returning, with ID, stream from list. // // If we don't have a list id we must ask the server if it has a cache or create a new. if o.ID != "" && !o.Transient { // Create or ping with handout... rpc := globalNotificationSys.restClientFromHash(pathJoin(o.Bucket, o.Prefix)) var c *metacache
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 12.8K bytes - Viewed (0) -
cmd/endpoint.go
if runtime.GOOS == globalWindowsOSName { if filepath.VolumeName(u.Path[1:]) != "" { u.Path = u.Path[1:] } } } else { // Only check if the arg is an ip address and ask for scheme since its absent. // localhost, example.com, any FQDN cannot be disambiguated from a regular file path such as // /mnt/export1. So we go ahead and start the minio server in FS modes in these cases.
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Sun Apr 21 11:43:18 GMT 2024 - 34.1K bytes - Viewed (0) -
cni/pkg/nodeagent/net.go
// 2. Adding the pod's IPs to the hostnetns ipsets for node probe checks // 3. Creating iptables rules inside the pod's netns // 4. Notifying ztunnel via GRPC to create a proxy for the pod // // You may ask why we pass the pod IPs separately from the pod manifest itself (which contains the pod IPs as a field) // - this is because during add specifically, if CNI plugins have not finished executing,
Go - Registered: Wed May 01 22:53:12 GMT 2024 - Last Modified: Tue Apr 30 22:24:38 GMT 2024 - 12.2K bytes - Viewed (1)