Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 7 of 7 for enBlocks (0.23 sec)

  1. cmd/erasure-utils.go

    	// Offset and out size cannot be negative.
    	if offset < 0 || length < 0 {
    		return 0, errUnexpected
    	}
    
    	// Do we have enough blocks?
    	if len(enBlocks) < dataBlocks {
    		return 0, reedsolomon.ErrTooFewShards
    	}
    
    	// Do we have enough data?
    	if int64(getDataBlockLen(enBlocks, dataBlocks)) < length {
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Wed Jan 31 02:11:45 UTC 2024
    - 3.1K bytes
    - Viewed (0)
  2. src/main/java/jcifs/internal/smb1/com/SmbComLockingAndX.java

            final int start = bufferIndex;
            for (int i = 0; i < this.unlocks.length; i++) {
                this.unlocks[i] = createLockRange();
                bufferIndex += this.unlocks[i].decode(buffer, bufferIndex, buffer.length);
            }
    
            for (int i = 0; i < this.locks.length; i++) {
                this.locks[i] = createLockRange();
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Sat Aug 16 01:32:48 UTC 2025
    - 5.2K bytes
    - Viewed (0)
  3. src/test/java/jcifs/internal/smb1/com/SmbComLockingAndXTest.java

            setField(unlock, "pid", 456);
            setField(unlock, "byteOffset", 300L);
            setField(unlock, "lengthInBytes", 400L);
            setField(cmd, "locks", new LockingAndXRange[] { lock });
            setField(cmd, "unlocks", new LockingAndXRange[] { unlock });
            setField(cmd, "largeFile", false);
    
            byte[] buffer = new byte[20];
            int len = cmd.writeParameterWordsWireFormat(buffer, 0);
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Thu Aug 14 05:31:44 UTC 2025
    - 7.1K bytes
    - Viewed (0)
  4. src/test/java/jcifs/internal/smb2/lock/Smb2LockRequestTest.java

            }
    
            @Test
            @DisplayName("Should calculate size correctly with no locks")
            void testSizeWithNoLocks() {
                Smb2Lock[] noLocks = new Smb2Lock[0];
                Smb2LockRequest req = new Smb2LockRequest(mockConfig, testFileId, noLocks);
    
                int expectedSize = Smb2Constants.SMB2_HEADER_LENGTH + 24; // header + structure
                expectedSize = ((expectedSize + 7) / 8) * 8; // 8-byte alignment
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Thu Aug 14 05:31:44 UTC 2025
    - 25.3K bytes
    - Viewed (0)
  5. cmd/admin-router.go

    		if globalIsDistErasure {
    			// Top locks
    			adminRouter.Methods(http.MethodGet).Path(adminVersion + "/top/locks").HandlerFunc(adminMiddleware(adminAPI.TopLocksHandler))
    			// Force unlocks paths
    			adminRouter.Methods(http.MethodPost).Path(adminVersion+"/force-unlock").
    				Queries("paths", "{paths:.*}").HandlerFunc(adminMiddleware(adminAPI.ForceUnlockHandler))
    		}
    
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Wed Apr 16 07:34:24 UTC 2025
    - 26.7K bytes
    - Viewed (0)
  6. cmd/object-api-utils.go

    			}
    		}
    	}
    
    	return compressedOffset, partSkip, firstPartIdx, decryptSkip, seqNum
    }
    
    // GetObjectReader is a type that wraps a reader with a lock to
    // provide a ReadCloser interface that unlocks on Close()
    type GetObjectReader struct {
    	io.Reader
    	ObjInfo    ObjectInfo
    	cleanUpFns []func()
    	once       sync.Once
    }
    
    // WithCleanupFuncs sets additional cleanup functions to be called when closing
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Wed Jun 25 15:08:54 UTC 2025
    - 37.3K bytes
    - Viewed (0)
  7. cmd/admin-handlers.go

    	return lockEntries
    }
    
    // PeerLocks holds server information result of one node
    type PeerLocks struct {
    	Addr  string
    	Locks map[string][]lockRequesterInfo
    }
    
    // ForceUnlockHandler force unlocks requested resource
    func (a adminAPIHandlers) ForceUnlockHandler(w http.ResponseWriter, r *http.Request) {
    	ctx := r.Context()
    
    	objectAPI, _ := validateAdminReq(ctx, w, r, policy.ForceUnlockAdminAction)
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 99.6K bytes
    - Viewed (0)
Back to top