Search Options

Results per page
Sort
Preferred Languages
Advance

Results 141 - 150 of 2,543 for context (1.76 sec)

  1. cmd/healthcheck-handler.go

    				apiErr := toAPIError(r.Context(), err)
    				writeResponse(w, apiErr.HTTPStatusCode, nil, mimeNone)
    			case http.MethodGet:
    				writeErrorResponse(r.Context(), w, toAPIError(r.Context(), err), r.URL)
    			}
    			return
    		}
    	}
    
    	if globalEtcdClient != nil {
    		// Borrowed from
    		// https://github.com/etcd-io/etcd/blob/main/etcdctl/ctlv3/command/ep_command.go#L118
    		ctx, cancel := context.WithTimeout(r.Context(), defaultContextTimeout)
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Wed Jun 26 07:44:34 UTC 2024
    - 6.9K bytes
    - Viewed (0)
  2. cmd/storage-interface.go

    	DeleteVersions(ctx context.Context, volume string, versions []FileInfoVersions, opts DeleteOptions) []error
    	DeleteBulk(ctx context.Context, volume string, paths ...string) error
    	WriteMetadata(ctx context.Context, origvolume, volume, path string, fi FileInfo) error
    	UpdateMetadata(ctx context.Context, volume, path string, fi FileInfo, opts UpdateMetadataOpts) error
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Fri Apr 25 05:41:04 UTC 2025
    - 5.3K bytes
    - Viewed (0)
  3. cmd/tier.go

    	if t, ok := config.Tiers[tierName]; ok {
    		return t.Type, true
    	}
    	return madmin.Unsupported, false
    }
    
    // Add adds tier to config if it passes all validations.
    func (config *TierConfigMgr) Add(ctx context.Context, tier madmin.TierConfig, ignoreInUse bool) error {
    	config.Lock()
    	defer config.Unlock()
    
    	// check if tier name is in all caps
    	tierName := tier.Name
    	if tierName != strings.ToUpper(tierName) {
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 15.6K bytes
    - Viewed (0)
  4. impl/maven-core/src/test/java/org/apache/maven/project/harness/PomTestWrapper.java

        }
    
        public void setValueOnModel(String expression, Object value) {
            context.setValue(expression, value);
        }
    
        public Iterator<?> getIteratorForXPathExpression(String expression) {
            return context.iterate(expression);
        }
    
        public boolean containsXPathExpression(String expression) {
            return context.getValue(expression) != null;
        }
    
        public Object getValue(String expression) {
    Registered: Sun Dec 28 03:35:09 UTC 2025
    - Last Modified: Sun Mar 30 23:08:36 UTC 2025
    - 2.8K bytes
    - Viewed (0)
  5. src/main/java/jcifs/internal/smb2/persistent/DurableHandleReconnect.java

        @Override
        public int size() {
            // Context header (16) + name length (4) + padding to 8-byte alignment + data (16)
            return 16 + 4 + 4 + STRUCTURE_SIZE;
        }
    
        @Override
        public int encode(byte[] dst, int dstIndex) {
            int start = dstIndex;
    
            // Write context header
            SMBUtil.writeInt4(0, dst, dstIndex); // Next (offset to next context, 0 for last)
            dstIndex += 4;
    
    Registered: Sat Dec 20 13:44:44 UTC 2025
    - Last Modified: Thu Aug 21 04:51:33 UTC 2025
    - 3K bytes
    - Viewed (0)
  6. internal/grid/muxserver.go

    	clientPingInterval time.Duration
    }
    
    func newMuxStateless(ctx context.Context, msg message, c *Connection, handler StatelessHandler) *muxServer {
    	var cancel context.CancelFunc
    	ctx = setCaller(ctx, c.remote)
    	if msg.DeadlineMS > 0 {
    		ctx, cancel = context.WithTimeout(ctx, time.Duration(msg.DeadlineMS)*time.Millisecond)
    	} else {
    		ctx, cancel = context.WithCancel(ctx)
    	}
    	m := muxServer{
    		ID:        msg.MuxID,
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Tue May 27 15:19:03 UTC 2025
    - 9.7K bytes
    - Viewed (0)
  7. src/test/java/jcifs/internal/smb2/nego/Smb2NegotiateRequestTest.java

            // Then
            NegotiateContextRequest[] contexts = request.getNegotiateContexts();
            assertNotNull(contexts);
            assertEquals(2, contexts.length);
    
            // Verify preauth context
            assertTrue(contexts[0] instanceof PreauthIntegrityNegotiateContext);
            assertEquals(PreauthIntegrityNegotiateContext.NEGO_CTX_PREAUTH_TYPE, contexts[0].getContextType());
    
            // Verify encryption context
    Registered: Sat Dec 20 13:44:44 UTC 2025
    - Last Modified: Thu Aug 14 05:31:44 UTC 2025
    - 20.7K bytes
    - Viewed (0)
  8. src/main/java/jcifs/smb1/util/MD4.java

        @Override
        public void engineReset() {
            // initial values of MD4 i.e. A, B, C, D
            // as per rfc-1320; they are low-order byte first
            context[0] = 0x67452301;
            context[1] = 0xEFCDAB89;
            context[2] = 0x98BADCFE;
            context[3] = 0x10325476;
            count = 0L;
            for (int i = 0; i < BLOCK_LENGTH; i++) {
                buffer[i] = 0;
            }
        }
    
        /**
    Registered: Sat Dec 20 13:44:44 UTC 2025
    - Last Modified: Sat Aug 16 01:32:48 UTC 2025
    - 9.6K bytes
    - Viewed (0)
  9. cmd/storage-rest_test.go

    			continue
    		}
    		err := storage.AppendFile(t.Context(), testCase.volumeName, testCase.objectName, testCase.data)
    		expectErr := (err != nil)
    
    		if expectErr != testCase.expectErr {
    			t.Fatalf("case %v: error: expected: %v, got: %v", i+1, testCase.expectErr, expectErr)
    		}
    
    		if !testCase.expectErr {
    			data, err := storage.ReadAll(t.Context(), testCase.volumeName, testCase.objectName)
    			if err != nil {
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Wed Apr 09 14:28:39 UTC 2025
    - 11.4K bytes
    - Viewed (0)
  10. impl/maven-cli/src/main/java/org/apache/maven/cling/invoker/mvn/MavenInvoker.java

        protected void lookup(MavenContext context) throws Exception {
            if (context.maven == null) {
                super.lookup(context);
                context.maven = context.lookup.lookup(Maven.class);
            }
        }
    
        @Override
        protected void postCommands(MavenContext context) throws Exception {
            super.postCommands(context);
    
            Logger logger = context.logger;
    Registered: Sun Dec 28 03:35:09 UTC 2025
    - Last Modified: Thu Sep 11 17:20:46 UTC 2025
    - 28.2K bytes
    - Viewed (0)
Back to top