- Sort Score
- Result 10 results
- Languages All
Results 1 - 9 of 9 for independent (0.23 sec)
-
internal/grid/handlers.go
// If <= 0 capacity will be 1. OutCapacity int } // StreamHandlerFn must process a request with an optional initial payload. // It must keep consuming from 'in' until it returns. // 'in' and 'out' are independent. // The handler should never close out. // Buffers received from 'in' can be recycled with PutByteBuffer. // Buffers sent on out can not be referenced once sent.
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Apr 23 17:15:52 GMT 2024 - 27.1K bytes - Viewed (0) -
cmd/object-multipart-handlers.go
// First, we compute the ETag of the multipart object. // The ETag of a multi-part object is always: // ETag := MD5(ETag_p1, ETag_p2, ...)+"-N" (N being the number of parts) // // This is independent of encryption. An encrypted multipart // object also has an ETag that is the MD5 of its part ETags. // The fact the in case of encryption the ETag of a part is // not the MD5 of the part content does not change that.
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Mar 28 17:44:56 GMT 2024 - 39K bytes - Viewed (0) -
internal/s3select/sql/evaluate.go
switch e.getFunctionName() { case aggFnCount, aggFnAvg, aggFnMax, aggFnMin, aggFnSum: return e.getAggregate() default: return e.evalSQLFnNode(r, tableAlias) } } // evalNode on a literal value is independent of the node being an // aggregation or a row function - it always returns a value. func (e *LitValue) evalNode(_ Record) (res *Value, err error) { switch { case e.Int != nil:
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sat Dec 23 07:19:11 GMT 2023 - 12K bytes - Viewed (0) -
src/cmd/asm/internal/asm/endtoend_test.go
} pList.Firstpc, ok = parser.Parse() if !ok || failed { t.Errorf("asm: %s assembly failed", goarch) return } output := strings.Split(testOut.String(), "\n") // Reconstruct expected output by independently "parsing" the input. data, err := os.ReadFile(input) if err != nil { t.Error(err) return } lineno := 0 seq := 0 hexByLine := map[string]string{} lines := strings.SplitAfter(string(data), "\n")
Go - Registered: Tue Apr 30 11:13:12 GMT 2024 - Last Modified: Thu Dec 07 18:42:59 GMT 2023 - 11.6K bytes - Viewed (0) -
cmd/bucket-object-lock.go
// For objects with legal hold header set, the s3:PutObjectLegalHold permission is expected to be set // Both legal hold and retention can be applied independently on an object
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Apr 22 17:49:30 GMT 2024 - 13.2K bytes - Viewed (0) -
cmd/storage-rest_test.go
"reflect" "runtime" "testing" "time" "github.com/minio/minio/internal/grid" xnet "github.com/minio/pkg/v2/net" ) // Storage REST server, storageRESTReceiver and StorageRESTClient are // inter-dependent, below test functions are sufficient to test all of them. func testStorageAPIDiskInfo(t *testing.T, storage StorageAPI) { testCases := []struct { expectErr bool }{ {true}, }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Jan 30 20:43:25 GMT 2024 - 11.4K bytes - Viewed (0) -
src/archive/tar/common.go
case TypeFifo: mode |= fs.ModeNamedPipe } return mode } func (fi headerFileInfo) String() string { return fs.FormatFileInfo(fi) } // sysStat, if non-nil, populates h from system-dependent fields of fi. var sysStat func(fi fs.FileInfo, h *Header, doNameLookups bool) error const ( // Mode constants from the USTAR spec:
Go - Registered: Tue Apr 30 11:13:12 GMT 2024 - Last Modified: Fri Mar 15 16:01:50 GMT 2024 - 24.7K bytes - Viewed (2) -
internal/ioutil/ioutil.go
// the function finishes executing, Run returns context.DeadlineExceeded to the caller. // channel so that the work function can attempt to exit gracefully. // Multiple calls to Run will run independently of each other. func (d *DeadlineWorker) Run(work func() error) error { c := make(chan ioret[struct{}], 1) t := time.NewTimer(d.timeout) go func() { c <- ioret[struct{}]{val: struct{}{}, err: work()} }()
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri Apr 19 11:26:59 GMT 2024 - 10.3K bytes - Viewed (0) -
istioctl/pkg/tag/tag.go
} taggedNamespaces, err := GetNamespacesWithTag(ctx, kubeClient, tagName) if err != nil { return fmt.Errorf("failed to retrieve namespaces dependent on tag %q", tagName) } // warn user if deleting a tag that still has namespaces pointed to it if len(taggedNamespaces) > 0 && !skipConfirmation {
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Tue Apr 02 08:32:06 GMT 2024 - 16.3K bytes - Viewed (0)