- Sort Score
- Result 10 results
- Languages All
Results 21 - 30 of 69 for einmal (0.57 sec)
-
cmd/peer-s3-client.go
// - Return an error when a pool cannot return N/2+1 valid bucket information // - For each pool, check if the bucket exists in N/2+1 nodes before including it in the final result func (sys *S3PeerSys) ListBuckets(ctx context.Context, opts BucketOptions) ([]BucketInfo, error) { g := errgroup.WithNErrs(len(sys.peerClients)) nodeBuckets := make([][]BucketInfo, len(sys.peerClients))
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) -
cmd/storage-rest-server.go
ui, err := s.getStorage().NSScanner(ctx, *params.Cache, updates, madmin.HealScanMode(params.ScanMode), nil) wg.Wait() if err != nil { return grid.NewRemoteErr(err) } // Send final response. resp := storageNSScannerRPC.NewResponse() resp.Final = &ui out <- resp return nil } // MakeVolHandler - make a volume. func (s *storageRESTServer) MakeVolHandler(w http.ResponseWriter, r *http.Request) {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sun Apr 28 17:53:50 GMT 2024 - 44.8K bytes - Viewed (0) -
src/cmd/asm/internal/asm/asm.go
return } next := 1 // Next operand is the optional flag, a literal integer. var flag = int64(0) if len(operands) == 3 { flag = p.evalInteger("GLOBL", operands[1]) next++ } // Final operand is an immediate constant. addr := p.address(operands[next]) if !p.validImmediate("GLOBL", &addr) { return } // log.Printf("GLOBL %s %d, $%d", name, flag, size)
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
// // A careful programmer will check the return value of close(), since it is quite possible that // errors on a previous write(2) operation are reported only on the final close() that releases // the open file descriptor. // // Failing to check the return value when closing a file may lead to silent loss of data. // This can especially be observed with NFS and with disk quota.
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) -
src/archive/tar/example_test.go
"bytes" "fmt" "io" "log" "os" ) func Example_minimal() { // Create and add some files to the archive. var buf bytes.Buffer tw := tar.NewWriter(&buf) var files = []struct { Name, Body string }{ {"readme.txt", "This archive contains some text files."}, {"gopher.txt", "Gopher names:\nGeorge\nGeoffrey\nGonzo"}, {"todo.txt", "Get animal handling license."}, } for _, file := range files {
Go - Registered: Tue Apr 30 11:13:12 GMT 2024 - Last Modified: Thu Nov 16 16:54:08 GMT 2017 - 1.4K bytes - Viewed (0) -
internal/lock/lock_nix.go
case syscall.O_WRONLY | syscall.O_CREAT: fallthrough case syscall.O_RDWR | syscall.O_CREAT: lockType |= syscall.LOCK_EX default: return nil, &os.PathError{ Op: "open", Path: path, Err: syscall.EINVAL, } } f, err := os.OpenFile(path, flag|syscall.O_SYNC, perm) if err != nil { return nil, err } if err = syscall.Flock(int(f.Fd()), lockType); err != nil { f.Close()
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Aug 19 01:35:22 GMT 2021 - 2.8K bytes - Viewed (0) -
operator/cmd/mesh/manifest-generate_test.go
assert.NoError(t, err) // Install a default revision should not cause any error minimal := "minimal" _, err = fakeControllerReconcile(minimal, tmpCharts, &helmreconciler.Options{Force: false, SkipPrune: true}) assert.NoError(t, err) } func TestManifestGenerateIstiodRemote(t *testing.T) { g := NewWithT(t)
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Thu Apr 18 18:16:49 GMT 2024 - 43.5K bytes - Viewed (0) -
cmd/storage-errors.go
} if isSysErrIO(err) { return errFaultyDisk } if isSysErrInvalidArg(err) { storageLogIf(context.Background(), err) // For some odd calls with O_DIRECT reads // filesystems can return EINVAL, handle // these as FileNotFound instead. return errFileNotFound } if isSysErrNoSpace(err) { return errDiskFull } return err
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 6.4K bytes - Viewed (0) -
operator/cmd/mesh/profile-list_test.go
rootCmd.SetErr(&out) err := rootCmd.Execute() if err != nil { t.Fatalf("failed to execute istioctl profile command: %v", err) } output := out.String() expectedProfiles := []string{"default", "demo", "empty", "minimal", "openshift", "preview", "remote"} for _, prof := range expectedProfiles { g.Expect(output).To(ContainSubstring(prof)) }
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Wed Apr 03 06:27:07 GMT 2024 - 1.5K bytes - Viewed (0) -
internal/bucket/encryption/bucket-sse-config.go
} // Apply applies the SSE bucket configuration on the given HTTP headers and // sets the specified SSE headers. // // Apply does not overwrite any existing SSE headers. Further, it will // set minimal SSE-KMS headers if autoEncrypt is true and the BucketSSEConfig // is nil. func (b *BucketSSEConfig) Apply(headers http.Header, opts ApplyOptions) { if crypto.Requested(headers) { return } if b == nil {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Oct 25 00:44:15 GMT 2022 - 4.9K bytes - Viewed (0)