Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 251 - 260 of 870 for context_b (0.06 seconds)

  1. cmd/lock-rest-server.go

    }
    
    // RefreshHandler - refresh the current lock
    func (l *lockRESTServer) RefreshHandler(args *dsync.LockArgs) (*dsync.LockResp, *grid.RemoteErr) {
    	// Add a timeout similar to what we expect upstream.
    	ctx, cancel := context.WithTimeout(context.Background(), dsync.DefaultTimeouts.RefreshCall)
    	defer cancel()
    
    	resp := lockRPCRefresh.NewResponse()
    	refreshed, err := l.ll.Refresh(ctx, *args)
    	if err != nil {
    		return l.makeResp(resp, err)
    	}
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Jan 31 19:54:34 GMT 2025
    - 6.3K bytes
    - Click Count (0)
  2. cmd/admin-handlers-idp-config.go

    	"github.com/minio/minio/internal/config/identity/openid"
    	"github.com/minio/mux"
    	"github.com/minio/pkg/v3/ldap"
    	"github.com/minio/pkg/v3/policy"
    )
    
    func addOrUpdateIDPHandler(ctx context.Context, w http.ResponseWriter, r *http.Request, isUpdate bool) {
    	objectAPI, cred := validateAdminReq(ctx, w, r, policy.ConfigUpdateAdminAction)
    	if objectAPI == nil {
    		return
    	}
    
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Tue Feb 18 16:25:55 GMT 2025
    - 12.7K bytes
    - Click Count (0)
  3. internal/http/dial_others.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 configures a custom dialer for internode communications
    func NewInternodeDialContext(dialTimeout time.Duration, _ TCPOptions) DialContext {
    	return func(ctx context.Context, network, addr string) (net.Conn, error) {
    		dialer := &net.Dialer{
    			Timeout: dialTimeout,
    		}
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Wed Apr 24 04:08:47 GMT 2024
    - 1.6K bytes
    - Click Count (0)
  4. cmd/metacache-server-pool.go

    			c = &resp
    		} else {
    			rctx, cancel := context.WithTimeout(ctx, 5*time.Second)
    			c, err = rpc.GetMetacacheListing(rctx, *o)
    			cancel()
    		}
    		if err != nil {
    			if errors.Is(err, context.Canceled) {
    				// Context is canceled, return at once.
    				// request canceled, no entries to return
    				return entries, io.EOF
    			}
    			if !IsErr(err, context.DeadlineExceeded, grid.ErrDisconnected) {
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 12.9K bytes
    - Click Count (0)
  5. cmd/auth-handler.go

    	_, _, s3Err = checkRequestAuthTypeCredential(ctx, r, action)
    	return s3Err
    }
    
    func authenticateRequest(ctx context.Context, r *http.Request, action policy.Action) (s3Err APIErrorCode) {
    	if logger.GetReqInfo(ctx) == nil {
    		bugLogIf(ctx, errors.New("unexpected context.Context does not have a logger.ReqInfo"), logger.ErrorKind)
    		return ErrAccessDenied
    	}
    
    	var cred auth.Credentials
    	var owner bool
    	switch getRequestAuthType(r) {
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 25.4K bytes
    - Click Count (0)
  6. internal/lsync/lrwmutex.go

    func (lm *LRWMutex) lockLoop(ctx context.Context, id, source string, timeout time.Duration, isWriteLock bool) (locked bool) {
    	r := rand.New(rand.NewSource(time.Now().UnixNano()))
    
    	retryCtx, cancel := context.WithTimeout(ctx, timeout)
    	defer cancel()
    
    	for {
    		select {
    		case <-retryCtx.Done():
    			// Caller context canceled or we timedout,
    			// return false anyways for both situations.
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Jan 02 17:15:06 GMT 2022
    - 4.8K bytes
    - Click Count (0)
  7. cmd/generic-handlers.go

    			}
    		}
    		sr, err := globalDNSConfig.Get(bucket)
    		if err != nil {
    			defer logger.AuditLog(r.Context(), w, r, mustGetClaimsFromToken(r))
    			if err == dns.ErrNoEntriesFound {
    				writeErrorResponse(r.Context(), w, errorCodes.ToAPIErr(ErrNoSuchBucket), r.URL)
    			} else {
    				writeErrorResponse(r.Context(), w, toAPIError(r.Context(), err), r.URL)
    			}
    			return
    		}
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 20.7K bytes
    - Click Count (1)
  8. cmd/object-api-getobjectinfo_test.go

    	// This bucket is used for testing getObjectInfo operations.
    	err := obj.MakeBucket(context.Background(), "test-getobjectinfo", MakeBucketOptions{})
    	if err != nil {
    		t.Fatalf("%s : %s", instanceType, err.Error())
    	}
    	opts := ObjectOptions{}
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Dec 23 15:46:00 GMT 2022
    - 5.6K bytes
    - Click Count (0)
  9. schema/utils.go

    	if strings.Contains(t, value) {
    		return tag
    	}
    	return reflect.StructTag(fmt.Sprintf(`gorm:"%s;%s"`, value, t))
    }
    
    // GetRelationsValues get relations's values from a reflect value
    func GetRelationsValues(ctx context.Context, reflectValue reflect.Value, rels []*Relationship) (reflectResults reflect.Value) {
    	for _, rel := range rels {
    		reflectResults = reflect.MakeSlice(reflect.SliceOf(reflect.PointerTo(rel.FieldSchema.ModelType)), 0, 1)
    
    Created: Sun Dec 28 09:35:17 GMT 2025
    - Last Modified: Thu Oct 30 11:15:36 GMT 2025
    - 5.9K bytes
    - Click Count (0)
  10. cmd/server-main.go

    	}
    }
    
    func initConfigSubsystem(ctx context.Context, newObject ObjectLayer) error {
    	// %w is used by all error returns here to make sure
    	// we wrap the underlying error, make sure when you
    	// are modifying this code that you do so, if and when
    	// you want to add extra context to your error. This
    	// ensures top level retry works accordingly.
    
    	// Initialize config system.
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Tue May 27 15:18:36 GMT 2025
    - 35.9K bytes
    - Click Count (4)
Back to Top