- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 166 for source (0.22 sec)
-
cmd/namespace-lock_test.go
for i := 0; i < 10000; i++ { nsLk := newNSLock(false) // lk1; ref=1 if !nsLk.lock(ctx, "volume", "path", "source", "opsID", false, time.Second) { t.Fatal("failed to acquire lock") } // lk2 lk2ch := make(chan struct{}) go func() { defer close(lk2ch) nsLk.lock(ctx, "volume", "path", "source", "opsID", false, 1*time.Millisecond) }() time.Sleep(1 * time.Millisecond) // wait for goroutine to advance; ref=2
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri Apr 23 18:58:53 GMT 2021 - 3.1K bytes - Viewed (0) -
internal/crypto/sse_test.go
}{ { // 0 - Valid HTTP headers and valid metadata entries for bucket/object Headers: http.Header{ "X-Amz-Copy-Source-Server-Side-Encryption-Customer-Algorithm": []string{"AES256"}, "X-Amz-Copy-Source-Server-Side-Encryption-Customer-Key": []string{"MzJieXRlc2xvbmdzZWNyZXRrZXltdXN0cHJvdmlkZWQ="}, "X-Amz-Copy-Source-Server-Side-Encryption-Customer-Key-Md5": []string{"7PpPLAK26ONlVUGOWlusfg=="}, }, Bucket: "bucket",
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Jun 01 21:59:40 GMT 2021 - 8.4K bytes - Viewed (0) -
docs/debugging/s3-verify/main.go
if sourceEndpoint == "" { log.Fatalln("source Endpoint is not provided") } if sourceAccessKey == "" { log.Fatalln("source Access key is not provided") } if sourceSecretKey == "" { log.Fatalln("source Secret key is not provided") } if sourceBucket == "" && sourcePrefix != "" { log.Fatalln("--source-prefix is specified without --source-bucket.") } if targetEndpoint == "" {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed Jun 22 15:12:47 GMT 2022 - 8.4K bytes - Viewed (0) -
internal/lsync/lrwmutex.go
lm.lockLoop(context.Background(), lm.id, lm.source, 1<<63-1, isWriteLock) } // GetRLock tries to get a read lock on lm before the timeout occurs. func (lm *LRWMutex) GetRLock(ctx context.Context, id string, source string, timeout time.Duration) (locked bool) { const isWriteLock = false return lm.lockLoop(ctx, id, source, timeout, isWriteLock) } func (lm *LRWMutex) lock(id, source string, isWriteLock bool) (locked bool) { lm.mu.Lock()
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sun Jan 02 17:15:06 GMT 2022 - 4.8K bytes - Viewed (0) -
src/bufio/example_test.go
// Copyright 2013 The Go Authors. All rights reserved. // Use of this source code is governed by a BSD-style // license that can be found in the LICENSE file. package bufio_test import ( "bufio" "bytes" "fmt" "os" "strconv" "strings" ) func ExampleWriter() { w := bufio.NewWriter(os.Stdout) fmt.Fprint(w, "Hello, ") fmt.Fprint(w, "world!") w.Flush() // Don't forget to flush! // Output: Hello, world! }
Go - Registered: Tue Apr 30 11:13:12 GMT 2024 - Last Modified: Mon Oct 23 09:06:30 GMT 2023 - 4.9K bytes - Viewed (0) -
cmd/crossdomain-xml-handler.go
// When clients request content hosted on a particular source domain and that content make requests // directed towards a domain other than its own, the remote domain needs to host a cross-domain // policy file that grants access to the source domain, allowing the client to continue the transaction. func setCrossDomainPolicyMiddleware(h http.Handler) http.Handler {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Mar 18 06:42:40 GMT 2024 - 2.2K bytes - Viewed (0) -
src/cmd/cgo/godefs.go
// Copyright 2011 The Go Authors. All rights reserved. // Use of this source code is governed by a BSD-style // license that can be found in the LICENSE file. package main import ( "fmt" "go/ast" "go/printer" "go/token" "os" "path/filepath" "strings" ) // godefs returns the output for -godefs mode. func (p *Package) godefs(f *File, args []string) string { var buf strings.Builder
Go - Registered: Tue Apr 30 11:13:12 GMT 2024 - Last Modified: Thu Sep 08 14:33:35 GMT 2022 - 4.5K bytes - Viewed (0) -
src/cmd/asm/internal/lex/lex.go
Text() string // File reports the source file name of the token. File() string // Base reports the position base of the token. Base() *src.PosBase // SetBase sets the position base. SetBase(*src.PosBase) // Line reports the source line number of the token. Line() int // Col reports the source column number of the token. Col() int // Close does any teardown required. Close()
Go - Registered: Tue Apr 30 11:13:12 GMT 2024 - Last Modified: Tue Aug 29 18:31:05 GMT 2023 - 4.1K bytes - Viewed (0) -
internal/dsync/lock-args.go
// Resources contains single or multiple entries to be locked/unlocked. Resources []string // Source contains the line number, function and file name of the code // on the client node that requested the lock. Source string // Owner represents unique ID for this instance, an owner who originally requested // the locked resource, useful primarily in figuring out stale locks. Owner string
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Jan 18 04:34:26 GMT 2024 - 1.7K bytes - Viewed (0) -
cmd/bucket-lifecycle-audit.go
lcEventSrc_s3CopyObject lcEventSrc_s3CompleteMultipartUpload ) //revive:enable:var-naming type lcAuditEvent struct { lifecycle.Event source lcEventSrc } func (lae lcAuditEvent) Tags() map[string]interface{} { event := lae.Event src := lae.source const ( ilmSrc = "ilm-src" ilmAction = "ilm-action" ilmDue = "ilm-due"
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri Dec 01 15:56:24 GMT 2023 - 2.6K bytes - Viewed (0)