- Sort Score
- Result 10 results
- Languages All
Results 201 - 210 of 391 for ctx_ (0.02 sec)
-
cmd/peer-s3-server.go
g.Go(func() error { if localDrives[index] == nil { return errDiskNotFound } return localDrives[index].DeleteVol(ctx, bucket, opts.Force) }, index) } return reduceWriteQuorumErrs(ctx, g.Wait(), bucketOpIgnoredErrs, (len(localDrives)/2)+1) } func makeBucketLocal(ctx context.Context, bucket string, opts MakeBucketOptions) error { globalLocalDrivesMu.RLock() localDrives := cloneDrives(globalLocalDrivesMap)
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Thu Aug 22 21:57:20 UTC 2024 - 8.1K bytes - Viewed (0) -
internal/grid/grid_test.go
errFatal(manager.RegisterStreamingHandler(handlerTest, StreamHandler{ Handle: func(ctx context.Context, payload []byte, request <-chan []byte, resp chan<- []byte) *RemoteErr { started := time.Now() dl, _ := ctx.Deadline() if testing.Verbose() { fmt.Println(GetCaller(ctx).Name, "Server deadline:", time.Until(dl)) } <-ctx.Done() serverCanceled <- time.Since(started) if testing.Verbose() {
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Mon Jul 29 18:10:04 UTC 2024 - 36.4K bytes - Viewed (0) -
cmd/benchmark-utils_test.go
func benchmarkPutObjectPart(b *testing.B, instanceType string, objSize int) { // create a temp Erasure/FS backend. ctx, cancel := context.WithCancel(context.Background()) defer cancel() objLayer, disks, err := prepareTestBackend(ctx, instanceType) if err != nil { b.Fatalf("Failed obtaining Temp Backend: <ERROR> %s", err) }
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Fri Dec 23 15:46:00 UTC 2022 - 8.2K bytes - Viewed (0) -
internal/config/identity/plugin/config.go
// service. func (o *AuthNPlugin) checkConnectivity(ctx context.Context) bool { ctx, cancel := context.WithTimeout(ctx, healthCheckTimeout) defer cancel() u := url.URL(*o.args.URL) req, err := http.NewRequestWithContext(ctx, http.MethodHead, u.String(), nil) if err != nil { authNLogIf(ctx, err) return false } if o.args.AuthToken != "" {
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 13.3K bytes - Viewed (0) -
cmd/warm-backend-minio.go
return minPartSize, nil } return partSize, nil } func (m *warmBackendMinIO) PutWithMeta(ctx context.Context, object string, r io.Reader, length int64, meta map[string]string) (remoteVersionID, error) { partSize, err := optimalPartSize(length) if err != nil { return remoteVersionID(""), err } res, err := m.client.PutObject(ctx, m.Bucket, m.getDest(object), r, length, minio.PutObjectOptions{ StorageClass: m.StorageClass,
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Thu Oct 31 22:10:24 UTC 2024 - 4K bytes - Viewed (0) -
src/main/java/jcifs/internal/smb1/com/SmbComTreeConnectAndX.java
private int passwordLength; private CIFSContext ctx; private ServerData server; /** * * @param ctx * @param server * @param path * @param service * @param andx */ public SmbComTreeConnectAndX ( CIFSContext ctx, ServerData server, String path, String service, ServerMessageBlock andx ) { super(ctx.getConfig(), SMB_COM_TREE_CONNECT_ANDX, andx);
Registered: Sun Nov 03 00:10:13 UTC 2024 - Last Modified: Sun Jul 01 13:12:10 UTC 2018 - 6.6K bytes - Viewed (0) -
cmd/auth-handler.go
// passes versionID additionally. func checkRequestAuthTypeWithVID(ctx context.Context, r *http.Request, action policy.Action, bucketName, objectName, versionID string) (s3Err APIErrorCode) { logger.GetReqInfo(ctx).BucketName = bucketName logger.GetReqInfo(ctx).ObjectName = objectName logger.GetReqInfo(ctx).VersionID = versionID _, _, s3Err = checkRequestAuthTypeCredential(ctx, r, action) return s3Err }
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Tue Sep 17 16:45:46 UTC 2024 - 26.1K bytes - Viewed (0) -
cmd/prepare-storage.go
reqInfo := (&logger.ReqInfo{}).AppendTags("endpoint", endpoint.String()) ctx := logger.SetReqInfo(GlobalContext, reqInfo) mutex.Lock() defer mutex.Unlock() m, ok := printOnce[endpoint] if !ok { m = make(map[string]int) printOnce[endpoint] = m if once { m[err.Error()]++ peersLogAlwaysIf(ctx, err) return } } // Once is set and we are here means error was already
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Fri Jul 12 20:51:54 UTC 2024 - 11.1K bytes - Viewed (0) -
internal/event/target/webhook.go
return store.ErrNotConnected } return nil } // NewWebhookTarget - creates new Webhook target. func NewWebhookTarget(ctx context.Context, id string, args WebhookArgs, loggerOnce logger.LogOnce, transport *http.Transport) (*WebhookTarget, error) { ctx, cancel := context.WithCancel(ctx) var queueStore store.Store[event.Event] if args.QueueDir != "" { queueDir := filepath.Join(args.QueueDir, storePrefix+"-webhook-"+id)
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Fri Sep 06 23:06:30 UTC 2024 - 8.8K bytes - Viewed (0) -
internal/http/dial_linux.go
} // DialContext is a function to make custom Dial for internode communications type DialContext func(ctx context.Context, network, address string) (net.Conn, error) // NewInternodeDialContext setups a custom dialer for internode communication func NewInternodeDialContext(dialTimeout time.Duration, opts TCPOptions) DialContext { return func(ctx context.Context, network, addr string) (net.Conn, error) { dialer := &net.Dialer{
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Tue Jul 23 10:53:03 UTC 2024 - 5K bytes - Viewed (0)