Search Options

Results per page
Sort
Preferred Languages
Advance

Results 101 - 110 of 965 for call (0.03 sec)

  1. cmd/post-policy_test.go

    	req.Header.Set("Content-Type", contentTypeHdr)
    	req.Header.Set("User-Agent", "Mozilla")
    
    	// Since `apiRouter` satisfies `http.Handler` it has a ServeHTTP to execute the logic of the handler.
    	// Call the ServeHTTP to execute the handler.
    	apiRouter.ServeHTTP(rec, req)
    
    	ctx, cancel := context.WithCancel(GlobalContext)
    	defer cancel()
    
    	// Now check if we actually wrote to backend (regardless of the response
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Wed May 22 23:07:14 UTC 2024
    - 30.2K bytes
    - Viewed (0)
  2. src/cmd/asm/internal/arch/s390x.go

    		"CMPBNE",
    		"CMPUBEQ",
    		"CMPUBGE",
    		"CMPUBGT",
    		"CMPUBLE",
    		"CMPUBLT",
    		"CMPUBNE",
    		"CRJ",
    		"CGRJ",
    		"CLRJ",
    		"CLGRJ",
    		"CIJ",
    		"CGIJ",
    		"CLIJ",
    		"CLGIJ",
    		"CALL",
    		"JMP":
    		return true
    	}
    	return false
    }
    
    func s390xRegisterNumber(name string, n int16) (int16, bool) {
    	switch name {
    	case "AR":
    		if 0 <= n && n <= 15 {
    			return s390x.REG_AR0 + n, true
    		}
    Registered: Tue Oct 29 11:13:09 UTC 2024
    - Last Modified: Thu Oct 17 14:55:25 UTC 2019
    - 1.2K bytes
    - Viewed (0)
  3. fastapi/concurrency.py

        # has its own internal pool (e.g. a database connection pool)
        # to avoid this we let __exit__ run without a capacity limit
        # since we're creating a new limiter for each call, any non-zero limit
        # works (1 is arbitrary)
        exit_limiter = CapacityLimiter(1)
        try:
            yield await run_in_threadpool(cm.__enter__)
        except Exception as e:
            ok = bool(
    Registered: Sun Oct 27 07:19:11 UTC 2024
    - Last Modified: Mon Dec 25 17:57:35 UTC 2023
    - 1.4K bytes
    - Viewed (0)
  4. cmd/os-rename_nolinux.go

    //
    // You should have received a copy of the GNU Affero General Public License
    // along with this program.  If not, see <http://www.gnu.org/licenses/>.
    
    package cmd
    
    import (
    	"os"
    )
    
    // RenameSys is low level call in case of non-Linux this just uses os.Rename()
    func RenameSys(src, dst string) (err error) {
    	return os.Rename(src, dst)
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Thu Feb 15 01:09:38 UTC 2024
    - 985 bytes
    - Viewed (0)
  5. cmd/bucket-policy-handlers.go

    		return
    	}
    
    	updatedAt, err := globalBucketMetadataSys.Update(ctx, bucket, bucketPolicyConfig, configData)
    	if err != nil {
    		writeErrorResponse(ctx, w, toAPIError(ctx, err), r.URL)
    		return
    	}
    
    	// Call site replication hook.
    	replLogIf(ctx, globalSiteReplicationSys.BucketMetaHook(ctx, madmin.SRBucketMeta{
    		Type:      madmin.SRBucketMetaTypePolicy,
    		Bucket:    bucket,
    		Policy:    bucketPolicyBytes,
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 6.1K bytes
    - Viewed (0)
  6. cmd/ftp-server-driver.go

    	if bucket == "" {
    		return errors.New("deleting all buckets not allowed")
    	}
    
    	clnt, err := driver.getMinIOClient(ctx)
    	if err != nil {
    		return err
    	}
    
    	cctx, cancel := context.WithCancel(context.Background())
    	defer cancel()
    
    	if prefix == "" {
    		// if all objects are not deleted yet this call may fail.
    		return clnt.RemoveBucket(cctx, bucket)
    	}
    
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Wed Aug 14 17:11:51 UTC 2024
    - 14K bytes
    - Viewed (0)
  7. cmd/sts-handlers.go

    	ctx := newContext(r, w, "AssumeRole")
    
    	claims := stsClaims{}
    	defer logger.AuditLog(ctx, w, r, claims)
    
    	// Check auth here (otherwise r.Form will have unexpected values from
    	// the call to `parseForm` below), but return failure only after we are
    	// able to validate that it is a valid STS request, so that we are able
    	// to send an appropriate audit log.
    	user, apiErrCode := checkAssumeRoleAuth(ctx, r)
    
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Thu Aug 15 01:29:20 UTC 2024
    - 33.9K bytes
    - Viewed (0)
  8. cmd/bucket-encryption-handlers.go

    	updatedAt, err := globalBucketMetadataSys.Update(ctx, bucket, bucketSSEConfig, configData)
    	if err != nil {
    		writeErrorResponse(ctx, w, toAPIError(ctx, err), r.URL)
    		return
    	}
    
    	// Call site replication hook.
    	//
    	// We encode the xml bytes as base64 to ensure there are no encoding
    	// errors.
    	cfgStr := base64.StdEncoding.EncodeToString(configData)
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 6.4K bytes
    - Viewed (0)
  9. internal/disk/stat_windows.go

    	// _Out_opt_ PULARGE_INTEGER lpFreeBytesAvailable,
    	// _Out_opt_ PULARGE_INTEGER lpTotalNumberOfBytes,
    	// _Out_opt_ PULARGE_INTEGER lpTotalNumberOfFreeBytes
    	// );
    	_, _, _ = GetDiskFreeSpaceEx.Call(uintptr(unsafe.Pointer(syscall.StringToUTF16Ptr(path))),
    		uintptr(unsafe.Pointer(&lpFreeBytesAvailable)),
    		uintptr(unsafe.Pointer(&lpTotalNumberOfBytes)),
    		uintptr(unsafe.Pointer(&lpTotalNumberOfFreeBytes)))
    
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Mon Feb 26 19:34:50 UTC 2024
    - 4.1K bytes
    - Viewed (0)
  10. fastapi/param_functions.py

        dependency: Annotated[
            Optional[Callable[..., Any]],
            Doc(
                """
                A "dependable" callable (like a function).
    
                Don't call it directly, FastAPI will call it for you, just pass the object
                directly.
                """
            ),
        ] = None,
        *,
        use_cache: Annotated[
            bool,
            Doc(
                """
    Registered: Sun Oct 27 07:19:11 UTC 2024
    - Last Modified: Wed Oct 23 18:30:18 UTC 2024
    - 62.5K bytes
    - Viewed (0)
Back to top