Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 201 - 210 of 900 for context_b (0.07 seconds)

  1. cmd/lock-rest-client_test.go

    	}
    
    	// Attempt all calls.
    	_, err = lkClient.RLock(t.Context(), dsync.LockArgs{})
    	if err == nil {
    		t.Fatal("Expected for Rlock to fail")
    	}
    
    	_, err = lkClient.Lock(t.Context(), dsync.LockArgs{})
    	if err == nil {
    		t.Fatal("Expected for Lock to fail")
    	}
    
    	_, err = lkClient.RUnlock(t.Context(), dsync.LockArgs{})
    	if err == nil {
    		t.Fatal("Expected for RUnlock to fail")
    	}
    
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Wed Apr 09 14:28:39 GMT 2025
    - 2K bytes
    - Click Count (0)
  2. compat/maven-model-builder/src/main/java/org/apache/maven/model/profile/activation/OperatingSystemProfileActivator.java

            String actualOsName = context.getSystemProperties()
                    .getOrDefault("os.name", Os.OS_NAME)
                    .toLowerCase(Locale.ENGLISH);
            String actualOsArch = context.getSystemProperties()
                    .getOrDefault("os.arch", Os.OS_ARCH)
                    .toLowerCase(Locale.ENGLISH);
            String actualOsVersion = context.getSystemProperties()
    Created: Sun Dec 28 03:35:09 GMT 2025
    - Last Modified: Tue Feb 25 08:27:34 GMT 2025
    - 5.3K bytes
    - Click Count (0)
  3. cmd/warm-backend-s3.go

    	})
    	return remoteVersionID(res.VersionID), s3.ToObjectError(err, object)
    }
    
    func (s3 *warmBackendS3) Put(ctx context.Context, object string, r io.Reader, length int64) (remoteVersionID, error) {
    	return s3.PutWithMeta(ctx, object, r, length, map[string]string{})
    }
    
    func (s3 *warmBackendS3) Get(ctx context.Context, object string, rv remoteVersionID, opts WarmBackendGetOpts) (io.ReadCloser, error) {
    	gopts := minio.GetObjectOptions{}
    
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Jun 08 16:13:30 GMT 2025
    - 5.8K bytes
    - Click Count (0)
  4. cmd/signature-v2_test.go

    			break
    		}
    	}
    }
    
    // Tests presigned v2 signature.
    func TestDoesPresignedV2SignatureMatch(t *testing.T) {
    	ctx, cancel := context.WithCancel(t.Context())
    	defer cancel()
    
    	obj, fsDir, err := prepareFS(ctx)
    	if err != nil {
    		t.Fatal(err)
    	}
    	defer os.RemoveAll(fsDir)
    	if err = newTestConfig(globalMinioDefaultRegion, obj); err != nil {
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 8K bytes
    - Click Count (0)
  5. cmd/peer-rest-server.go

    	go func() {
    		err := globalTierConfigMgr.Reload(context.Background(), newObjectLayerFn())
    		if err != nil {
    			peersLogIf(context.Background(), fmt.Errorf("Failed to reload remote tier config %s", err))
    		}
    	}()
    
    	return np, nerr
    }
    
    // ConsoleLogHandler sends console logs of this node back to peer rest client
    func (s *peerRESTServer) ConsoleLogHandler(ctx context.Context, params *grid.MSS, out chan<- *grid.Bytes) *grid.RemoteErr {
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 53.6K bytes
    - Click Count (0)
  6. api/go1.21.txt

    pkg cmp, func Less[$0 Ordered]($0, $0) bool #59488
    pkg cmp, type Ordered interface {} #59488
    pkg context, func AfterFunc(Context, func()) func() bool #57928
    pkg context, func WithDeadlineCause(Context, time.Time, error) (Context, CancelFunc) #56661
    pkg context, func WithoutCancel(Context) Context #40221
    pkg context, func WithTimeoutCause(Context, time.Duration, error) (Context, CancelFunc) #56661
    pkg crypto/elliptic, func GenerateKey //deprecated #52221
    Created: Tue Dec 30 11:13:12 GMT 2025
    - Last Modified: Mon Aug 07 09:39:17 GMT 2023
    - 25.6K bytes
    - Click Count (0)
  7. cmd/consolelogger.go

    // the console logging pub sub system
    func NewConsoleLogger(ctx context.Context, w io.Writer) *HTTPConsoleLoggerSys {
    	return &HTTPConsoleLoggerSys{
    		pubsub:  pubsub.New[log.Info, madmin.LogMask](8),
    		console: console.New(w),
    		logBuf:  ring.New(defaultLogBufferCount),
    	}
    }
    
    // IsOnline always true in case of console logger
    func (sys *HTTPConsoleLoggerSys) IsOnline(_ context.Context) bool {
    	return true
    }
    
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 5.4K bytes
    - Click Count (0)
  8. internal/config/lambda/parse.go

    	"github.com/minio/pkg/v3/env"
    	xnet "github.com/minio/pkg/v3/net"
    )
    
    const (
    	logSubsys = "notify"
    )
    
    func logOnceIf(ctx context.Context, err error, id string, errKind ...any) {
    	logger.LogOnceIf(ctx, logSubsys, err, id, errKind...)
    }
    
    // ErrTargetsOffline - Indicates single/multiple target failures.
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 6K bytes
    - Click Count (0)
  9. scripts/playwright/separate_openapi_schemas/image01.py

    def run(playwright: Playwright) -> None:
        browser = playwright.chromium.launch(headless=False)
        # Update the viewport manually
        context = browser.new_context(viewport={"width": 960, "height": 1080})
        page = context.new_page()
        page.goto("http://localhost:8000/docs")
        page.get_by_text("POST/items/Create Item").click()
        page.get_by_role("tab", name="Schema").first.click()
    Created: Sun Dec 28 07:19:09 GMT 2025
    - Last Modified: Fri Sep 13 09:14:46 GMT 2024
    - 974 bytes
    - Click Count (0)
  10. compat/maven-model-builder/src/test/java/org/apache/maven/model/profile/activation/AbstractProfileActivatorTest.java

            DefaultProfileActivationContext context = new DefaultProfileActivationContext();
            return context.setUserProperties(userProperties).setSystemProperties(systemProperties);
        }
    
        protected void assertActivation(boolean active, Profile profile, ProfileActivationContext context) {
            SimpleProblemCollector problems = new SimpleProblemCollector();
    
    Created: Sun Dec 28 03:35:09 GMT 2025
    - Last Modified: Fri Mar 21 04:56:21 GMT 2025
    - 2.4K bytes
    - Click Count (0)
Back to Top