Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 6 of 6 for getSubject (0.12 sec)

  1. src/main/java/jcifs/smb/SmbSessionImpl.java

                log.debug("Initial session preauth hash " + Hexdump.toHexString(this.preauthIntegrityHash));
            }
    
            while ( true ) {
                Subject s = this.credentials.getSubject();
                if ( ctx == null ) {
                    ctx = createContext(trans, tdomain, negoResp, !anonymous, s);
                }
                token = createToken(ctx, token, s);
    
                if ( token != null ) {
    Registered: Sun Nov 03 00:10:13 UTC 2024
    - Last Modified: Sun Nov 14 17:41:04 UTC 2021
    - 49K bytes
    - Viewed (0)
  2. cmd/sts-handlers_test.go

       {
        "Sid": "ObjectActionsRW",
        "Effect": "Allow",
        "Action": [
         "s3:PutObject",
         "s3:PutObjectTagging",
         "s3:AbortMultipartUpload",
         "s3:DeleteObject",
         "s3:GetObject",
         "s3:GetObjectTagging",
         "s3:GetObjectVersion",
         "s3:ListMultipartUploadParts"
        ],
        "Resource": [
         "arn:aws:s3:::%s/*"
        ]
       },
       {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Oct 10 23:40:37 UTC 2024
    - 97.1K bytes
    - Viewed (0)
  3. cmd/batch-handlers.go

    	}
    	gopts := miniogo.GetObjectOptions{
    		VersionID: srcObjInfo.VersionID,
    	}
    	if err := gopts.SetMatchETag(srcObjInfo.ETag); err != nil {
    		return err
    	}
    	rd, objInfo, _, err := core.GetObject(ctx, srcBucket, srcObject, gopts)
    	if err != nil {
    		return ErrorRespToObjectError(err, srcBucket, srcObject, srcObjInfo.VersionID)
    	}
    	defer rd.Close()
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Oct 18 15:32:09 UTC 2024
    - 62.2K bytes
    - Viewed (0)
  4. cmd/test-utils_test.go

    		case "HeadObject":
    			// Register HeadObject handler.
    			bucket.Methods("Head").Path("/{object:.+}").HandlerFunc(api.HeadObjectHandler)
    		case "GetObject":
    			// Register GetObject handler.
    			bucket.Methods(http.MethodGet).Path("/{object:.+}").HandlerFunc(api.GetObjectHandler)
    		case "PutObject":
    			// Register PutObject handler.
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Oct 01 22:13:18 UTC 2024
    - 77K bytes
    - Viewed (0)
  5. cmd/erasure-object.go

    func (er erasureObjects) GetObjectNInfo(ctx context.Context, bucket, object string, rs *HTTPRangeSpec, h http.Header, opts ObjectOptions) (gr *GetObjectReader, err error) {
    	if !opts.NoAuditLog {
    		auditObjectErasureSet(ctx, "GetObject", object, &er)
    	}
    
    	var unlockOnDefer bool
    	nsUnlocker := func() {}
    	defer func() {
    		if unlockOnDefer {
    			nsUnlocker()
    		}
    	}()
    
    	// Acquire lock
    	if !opts.NoLock {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Oct 31 22:10:24 UTC 2024
    - 78.8K bytes
    - Viewed (0)
  6. cmd/erasure-server-pool.go

    // is present in-case there were duplicate writes to both pools, this function also returns the
    // additional index where the latest object exists, that is used to start the GetObject stream.
    func (z *erasureServerPools) getLatestObjectInfoWithIdx(ctx context.Context, bucket, object string, opts ObjectOptions) (ObjectInfo, int, error) {
    	object = encodeDirObject(object)
    	results := make([]struct {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sun Sep 29 22:40:36 UTC 2024
    - 89.8K bytes
    - Viewed (0)
Back to top