- Sort Score
- Result 10 results
- Languages All
Results 21 - 30 of 60 for spent (0.05 sec)
-
cmd/handler-utils.go
cred, _, _ = getReqAccessKeyV4(r, region, serviceS3) if cred.AccessKey == "" { cred, _, _ = getReqAccessKeyV2(r) } return cred } // Extract request params to be sent with event notification. func extractReqParams(r *http.Request) map[string]string { if r == nil { return nil } region := globalSite.Region() cred := getReqAccessCred(r, region)
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Mon Jun 10 15:31:51 UTC 2024 - 15.5K bytes - Viewed (0) -
platforms/core-runtime/launcher/src/main/java/org/gradle/launcher/daemon/server/DaemonServices.java
new EstablishBuildEnvironment(processEnvironment), new LogToClient(loggingManager, daemonDiagnostics), // from this point down, logging is sent back to the client new LogAndCheckHealth(healthStats, healthCheck, runningStats), new ForwardClientInput(inputReader, eventDispatch), new RequestStopIfSingleUsedDaemon(),
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue Jun 11 09:51:15 UTC 2024 - 9.7K bytes - Viewed (0) -
cmd/object-api-options.go
} } if metadata == nil { metadata = make(map[string]string) } wantCRC, err := hash.GetContentChecksum(hdr) if err != nil { return opts, fmt.Errorf("invalid/unknown checksum sent: %v", err) } etag := strings.TrimSpace(hdr.Get(xhttp.MinIOSourceETag)) if crypto.S3KMS.IsRequested(hdr) { keyID, context, err := crypto.S3KMS.ParseHTTP(hdr) if err != nil { return ObjectOptions{}, err
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Thu Jun 13 06:56:12 UTC 2024 - 14.3K bytes - Viewed (0) -
pilot/pkg/xds/deltatest.go
// response returned the optimal result. Checks include correctness checks (e.g. if a config changed, // we must include it) and possible optimizations (e.g. we sent a config, but it was not changed). func (s *DiscoveryServer) compareDiff( con *Connection, w *model.WatchedResource, sotwRes model.Resources, deltaRes model.Resources, deleted model.DeletedResources,
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 13 01:56:28 UTC 2024 - 5.7K bytes - Viewed (0) -
cmd/object-api-datatypes.go
ActualSize int64 // Checksum values ChecksumCRC32 string ChecksumCRC32C string ChecksumSHA1 string ChecksumSHA256 string } // CompletePart - represents the part that was completed, this is sent by the client // during CompleteMultipartUpload request. type CompletePart struct { // Part number identifying the part. This is a positive integer between 1 and // 10,000 PartNumber int
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Mon Jun 10 15:31:51 UTC 2024 - 20.9K bytes - Viewed (0) -
staging/src/k8s.io/apimachinery/pkg/watch/watch.go
// producer. If an error occurs or Stop() is called, the producer must // close this channel and release any resources used by the watch. // Closing the result channel tells the consumer that no more events will be // sent. ResultChan() <-chan Event } // EventType defines the possible types of events. type EventType string const ( Added EventType = "ADDED" Modified EventType = "MODIFIED"
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 12 20:06:22 UTC 2024 - 8.1K bytes - Viewed (1) -
tensorflow/compiler/mlir/tf2xla/internal/passes/xla_broadcast.cc
// Insert an XlaAllReduce. Value CreateAllReduce(ReplicateOp replicate, OpBuilder& builder, Value block_arg) { // This group_assignment is a list of all replicas. This says that the // reduction sent to each replica is over all replicas. uint32_t num_replicas = replicate.getN(); llvm::SmallVector<int32_t, 4> group_assignment_val; for (int i = 0; i < num_replicas; ++i) group_assignment_val.push_back(i);
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Thu Jun 13 18:52:07 UTC 2024 - 13.9K bytes - Viewed (0) -
cmd/erasure-multipart.go
Err: fmt.Errorf("checksum type mismatch"), } } } var checksumCombined []byte // However, in case of encryption, the persisted part ETags don't match // what we have sent to the client during PutObjectPart. The reason is // that ETags are encrypted. Hence, the client will send a list of complete // part ETags of which non can match the ETag of any part. For example
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Thu Jun 13 06:56:12 UTC 2024 - 44.8K bytes - Viewed (0) -
src/time/tick_test.go
}() Sleep(sched) notDone(done) tim.Reset(sched / 2) Sleep(sched) waitDone(done) tim.Stop() close(stop) waitDone(done1) waitDone(done2) if isTicker { // extra send might have sent done again // (handled by buffering done above). select { default: case <-done: } // extra send after that might have filled C. select { default: case <-C: } }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Jun 11 17:10:37 UTC 2024 - 14.7K bytes - Viewed (0) -
pilot/pkg/simulation/traffic.go
func (sim *Simulation) Run(input Call) (result Result) { result = Result{t: sim.t} input = input.FillDefaults() if input.Alpn != "" && input.TLS == Plaintext { result.Error = fmt.Errorf("invalid call, ALPN can only be sent in TLS requests") return result } // First we will match a listener l := matchListener(sim.Listeners, input) if l == nil { result.Error = ErrNoListener return }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 13 01:56:28 UTC 2024 - 19.4K bytes - Viewed (0)