Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 371 - 380 of 762 for chunks (0.42 seconds)

  1. src/main/java/jcifs/internal/witness/WitnessRpcMessage.java

         *
         * @param returnCode the return code to set
         */
        public void setReturnCode(int returnCode) {
            this.returnCode = returnCode;
        }
    
        /**
         * Checks if the RPC operation was successful.
         *
         * @return true if successful (return code is ERROR_SUCCESS)
         */
        public boolean isSuccess() {
            return returnCode == ERROR_SUCCESS;
        }
    
    Created: Sun Apr 05 00:10:12 GMT 2026
    - Last Modified: Sun Aug 24 00:12:28 GMT 2025
    - 5.5K bytes
    - Click Count (0)
  2. internal/hash/reader.go

    }
    
    // SetExpectedMax set expected max data expected from reader
    func (r *Reader) SetExpectedMax(expectedMax int64) {
    	r.expectedMax = expectedMax
    }
    
    // AddChecksum will add checksum checks as specified in
    // https://docs.aws.amazon.com/AmazonS3/latest/userguide/checking-object-integrity.html
    // Returns ErrInvalidChecksum if a problem with the checksum is found.
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Wed Jun 25 15:08:54 GMT 2025
    - 11.8K bytes
    - Click Count (0)
  3. docs/pt/docs/advanced/stream-data.md

    ### Arquivos e async { #files-and-async }
    
    Na maioria dos casos, objetos semelhantes a arquivo não são compatíveis com async e await por padrão.
    
    Por exemplo, eles não têm `await file.read()`, nem `async for chunk in file`.
    
    E, em muitos casos, lê-los seria uma operação bloqueante (que poderia bloquear o loop de eventos), pois são lidos do disco ou da rede.
    
    /// info | Informação
    
    Created: Sun Apr 05 07:19:11 GMT 2026
    - Last Modified: Thu Mar 19 18:20:13 GMT 2026
    - 5.7K bytes
    - Click Count (0)
  4. cmd/auth-handler.go

    	}
    
    	logger.GetReqInfo(ctx).Cred = cred
    	logger.GetReqInfo(ctx).Owner = owner
    	logger.GetReqInfo(ctx).Region = globalSite.Region()
    
    	return cred, owner, ErrNone
    }
    
    // checkAdminRequestAuth checks for authentication and authorization for the incoming
    // request. It only accepts V2 and V4 requests. Presigned, JWT and anonymous requests
    // are automatically rejected.
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 25.4K bytes
    - Click Count (0)
  5. .github/PULL_REQUEST_TEMPLATE.md

    <!--  Thanks for sending a pull request!  Here are some tips for you:
    
    1. If this is your first time, please read our contributor guidelines: https://git.k8s.io/community/contributors/guide/first-contribution.md#your-first-contribution and developer guide https://git.k8s.io/community/contributors/devel/development.md#development-guide
    Created: Fri Apr 03 09:05:14 GMT 2026
    - Last Modified: Tue Jan 20 23:14:09 GMT 2026
    - 3.1K bytes
    - Click Count (0)
  6. src/test/java/jcifs/smb1/smb1/Trans2QueryFSInformationTest.java

            assertEquals(SmbComTransaction.TRANS2_QUERY_FS_INFORMATION, cmd.subCommand, "subCommand should be QUERY_FS_INFORMATION");
            // the fields are set in the constructor – check that the counts match
            assertEquals(2, cmd.totalParameterCount, "totalParameterCount should be 2");
            assertEquals(0, cmd.totalDataCount, "totalDataCount should be 0");
    Created: Sun Apr 05 00:10:12 GMT 2026
    - Last Modified: Thu Aug 14 05:31:44 GMT 2025
    - 4.5K bytes
    - Click Count (0)
  7. internal/bucket/lifecycle/rule_test.go

    // along with this program.  If not, see <http://www.gnu.org/licenses/>.
    
    package lifecycle
    
    import (
    	"encoding/xml"
    	"fmt"
    	"testing"
    )
    
    // TestInvalidRules checks if Rule xml with invalid elements returns
    // appropriate errors on validation
    func TestInvalidRules(t *testing.T) {
    	invalidTestCases := []struct {
    		inputXML    string
    		expectedErr error
    	}{
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Wed May 01 01:11:10 GMT 2024
    - 4.9K bytes
    - Click Count (0)
  8. docs/ko/docs/advanced/stream-data.md

    이 예시처럼 메모리 상의 가짜 파일(`io.BytesIO`)이라면 크게 중요하지 않지만, 실제 파일의 경우 작업이 끝난 뒤 파일을 닫는 것이 매우 중요합니다.
    
    ### 파일과 비동기 { #files-and-async }
    
    대부분의 경우 파일 유사 객체는 기본적으로 async/await와 호환되지 않습니다.
    
    예를 들어 `await file.read()`나 `async for chunk in file`과 같은 패턴을 지원하지 않습니다.
    
    또한 디스크나 네트워크에서 읽기 때문에, 많은 경우 읽기 작업은 이벤트 루프를 막을 수 있는 블로킹 연산입니다.
    
    /// info | 정보
    
    위의 예시는 예외적인 경우입니다. `io.BytesIO` 객체는 이미 메모리에 있으므로 읽기가 아무 것도 차단하지 않습니다.
    
    Created: Sun Apr 05 07:19:11 GMT 2026
    - Last Modified: Thu Mar 19 18:56:39 GMT 2026
    - 6.2K bytes
    - Click Count (0)
  9. cmd/test-utils_test.go

    	"Content-Type":  true,
    	"Content-Md5":   true,
    	"User-Agent":    true,
    }
    
    // calculateSignedChunkLength - calculates the length of chunk metadata
    func calculateSignedChunkLength(chunkDataSize int64) int64 {
    	return int64(len(fmt.Sprintf("%x", chunkDataSize))) +
    		17 + // ";chunk-signature="
    		64 + // e.g. "f2ca1bb6c7e907d06dafe4687e579fce76b37e4e93b7605022da52e6ccc26fd2"
    		2 + // CRLF
    		chunkDataSize +
    		2 // CRLF
    }
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 77K bytes
    - Click Count (0)
  10. cmd/bucket-policy.go

    // Get returns stored bucket policy
    func (sys *PolicySys) Get(bucket string) (*policy.BucketPolicy, error) {
    	policy, _, err := globalBucketMetadataSys.GetPolicyConfig(bucket)
    	return policy, err
    }
    
    // IsAllowed - checks given policy args is allowed to continue the Rest API.
    func (sys *PolicySys) IsAllowed(args policy.BucketPolicyArgs) bool {
    	p, err := sys.Get(args.BucketName)
    	if err == nil {
    		return p.IsAllowed(args)
    	}
    
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 7.9K bytes
    - Click Count (0)
Back to Top