- Sort Score
- Result 10 results
- Languages All
Results 21 - 30 of 36 for Mitake (0.19 sec)
-
internal/grid/muxclient.go
// Route directly to output. m.respWait = out } // RequestStream will send a single payload request and stream back results. // 'requests' can be nil, in which case only req is sent as input. // It will however take less resources. func (m *muxClient) RequestStream(h HandlerID, payload []byte, requests chan []byte, responses chan Response) (*Stream, error) { if m.init { return nil, errors.New("mux client already used") }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 14.2K bytes - Viewed (0) -
cmd/erasure-server-pool-decom.go
z.poolMetaMutex.Unlock() } wk.Take() go func(setIdx int) { defer wk.Give() // We will perpetually retry listing if it fails, since we cannot // possibly give up in this matter for { if contextCanceled(ctx) { break } err := set.listObjectsToDecommission(ctx, bi, func(entry metaCacheEntry) { wk.Take() go decommissionEntry(entry) },
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed May 01 15:18:21 GMT 2024 - 41.5K bytes - Viewed (1) -
cmd/iam-store.go
if !groups.Contains(group) { continue } groups.Remove(group) c.iamUserGroupMemberships[member] = groups } } // policyDBGet - lower-level helper; does not take locks. // // If a group is passed, it returns policies associated with the group. // // If a user is passed, it returns policies of the user along with any groups // that the server knows the user is a member of. //
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sat Apr 27 10:04:10 GMT 2024 - 75.2K bytes - Viewed (2) -
cmd/erasure-encode.go
}...) { return 0, err } } eof := err == io.EOF || err == io.ErrUnexpectedEOF if n == 0 && total != 0 { // Reached EOF, nothing more to be done. break } // We take care of the situation where if n == 0 and total == 0 by creating empty data and parity files. blocks, err = e.EncodeData(ctx, buf[:n]) if err != nil { return 0, err }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed Jan 31 02:11:45 GMT 2024 - 3K bytes - Viewed (0) -
cmd/batch-handlers.go
skipReplicate = obj.IsDeleteMarker && s3Type } if skipReplicate { continue } wk.Take() go func() { defer wk.Give() stopFn := globalBatchJobsMetrics.trace(batchJobMetricReplication, job.ID, attempts) success := true if err := r.ReplicateFromSource(ctx, api, core, oi, retry); err != nil {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sun May 05 16:56:21 GMT 2024 - 55.2K bytes - Viewed (0) -
cmd/metacache-set.go
// listPathRaw will list a path on the provided drives. // See listPathRawOptions on how results are delivered. // Directories are always returned. // Cache will be bypassed. // Context cancellation will be respected but may take a while to effectuate. func listPathRaw(ctx context.Context, opts listPathRawOptions) (err error) { disks := opts.disks if len(disks) == 0 { return fmt.Errorf("listPathRaw: 0 drives provided") }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed May 01 17:59:08 GMT 2024 - 30.4K bytes - Viewed (0) -
cmd/notification.go
// collected in errs slice and returned by Wait(). func (g *NotificationGroup) Go(ctx context.Context, f func() error, index int, addr xnet.Host) { r := rand.New(rand.NewSource(time.Now().UnixNano())) g.workers.Take() go func() { defer g.workers.Give() g.errs[index] = NotificationPeerErr{ Host: addr, } for i := 0; i < g.retryCount; i++ { g.errs[index].Err = nil if err := f(); err != nil {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri Apr 12 18:13:36 GMT 2024 - 44.5K bytes - Viewed (0) -
cmd/admin-handlers.go
hr := healResp{respBytes, apiErr, errMsg} respCh <- hr }() } // Due to the force-starting functionality, the Launch // call above can take a long time - to keep the // connection alive, we start sending whitespace keepConnLive(w, r, respCh) } // getAggregatedBackgroundHealState returns the heal state of disks.
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Apr 29 17:39:04 GMT 2024 - 97.8K bytes - Viewed (2) -
cmd/healthcheck-handler.go
} if !result.Healthy { // As a maintenance call we are purposefully asked to be taken // down, this is for orchestrators to know if we can safely // take this server down, return appropriate error. if opts.Maintenance { writeResponse(w, http.StatusPreconditionFailed, nil, mimeNone) } else { writeResponse(w, http.StatusServiceUnavailable, nil, mimeNone) }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed Apr 03 21:13:20 GMT 2024 - 6.5K bytes - Viewed (0) -
internal/etag/etag.go
// is encrypted, compressed or uploaded using // the S3 multipart API then its ETag is not // necessarily the MD5 of the object content. // // For a more detailed description of S3 ETags // take a look at the package documentation. type ETag []byte // String returns the string representation of the ETag. // // The returned string is a hex representation of the
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sun Mar 10 21:09:36 GMT 2024 - 13.3K bytes - Viewed (0)