Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 31 for Rendle (0.16 sec)

  1. cmd/signature-v4-utils.go

    	if confRegion == "" {
    		return true
    	}
    	if confRegion == "US" {
    		confRegion = globalMinioDefaultRegion
    	}
    	// Some older s3 clients set region as "US" instead of
    	// globalMinioDefaultRegion, handle it.
    	if reqRegion == "US" {
    		reqRegion = globalMinioDefaultRegion
    	}
    	return reqRegion == confRegion
    }
    
    // check if the access key is valid and recognized, additionally
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Wed Jan 31 18:56:45 GMT 2024
    - 9K bytes
    - Viewed (0)
  2. internal/grid/README.md

        resp, err := instance.Call(ctx, conn, grid.NewMSSWith(map[string]string{"myfield": "myvalue"}))
        if err == nil {
            fmt.Println("Got response with field", resp["result"])
        }
    ```
    
    The wrapper will handle all serialization and de-seralization of the request and response,
    and furthermore provides reuse of the structs used for the request and response.
    
    Plain Text
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Jan 18 07:03:17 GMT 2024
    - 9.4K bytes
    - Viewed (0)
  3. cmd/storage-errors.go

    	}
    	if isSysErrIO(err) {
    		return errFaultyDisk
    	}
    	if isSysErrInvalidArg(err) {
    		storageLogIf(context.Background(), err)
    		// For some odd calls with O_DIRECT reads
    		// filesystems can return EINVAL, handle
    		// these as FileNotFound instead.
    		return errFileNotFound
    	}
    	if isSysErrNoSpace(err) {
    		return errDiskFull
    	}
    	return err
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 6.4K bytes
    - Viewed (0)
  4. internal/http/server.go

    			w.WriteHeader(http.StatusServiceUnavailable)
    			w.Write([]byte(http.ErrServerClosed.Error()))
    			return
    		}
    
    		atomic.AddInt32(&srv.requestCount, 1)
    		defer atomic.AddInt32(&srv.requestCount, -1)
    
    		// Handle request using passed handler.
    		handler.ServeHTTP(w, r)
    	})
    
    	srv.listenerMutex.Lock()
    	srv.Handler = wrappedHandler
    	srv.listener = listener
    	srv.listenerMutex.Unlock()
    
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri Feb 09 21:25:16 GMT 2024
    - 7.7K bytes
    - Viewed (0)
  5. internal/lock/lock_windows.go

    func lockedOpenFile(path string, flag int, perm os.FileMode, lockType uint32) (*LockedFile, error) {
    	f, err := Open(path, flag, perm)
    	if err != nil {
    		return nil, err
    	}
    
    	if err = lockFile(syscall.Handle(f.Fd()), lockType); err != nil {
    		f.Close()
    		return nil, err
    	}
    
    	st, err := os.Stat(path)
    	if err != nil {
    		f.Close()
    		return nil, err
    	}
    
    	if st.IsDir() {
    		f.Close()
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Wed Oct 18 18:08:15 GMT 2023
    - 7.9K bytes
    - Viewed (0)
  6. internal/config/policy/opa/config.go

    	opaRespBytes, err := io.ReadAll(resp.Body)
    	if err != nil {
    		return false, err
    	}
    
    	// Handle large OPA responses when OPA URL is of
    	// form http://localhost:8181/v1/data/httpapi/authz
    	type opaResultAllow struct {
    		Result struct {
    			Allow bool `json:"allow"`
    		} `json:"result"`
    	}
    
    	// Handle simpler OPA responses when OPA URL is of
    	// form http://localhost:8181/v1/data/httpapi/authz/allow
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Sep 14 21:50:16 GMT 2023
    - 5.2K bytes
    - Viewed (1)
  7. internal/crypto/sse-kms.go

    	"github.com/minio/minio/internal/kms"
    	"github.com/minio/minio/internal/logger"
    )
    
    type ssekms struct{}
    
    var (
    	// S3KMS represents AWS SSE-KMS. It provides functionality to
    	// handle SSE-KMS requests.
    	S3KMS = ssekms{}
    
    	_ Type = S3KMS
    )
    
    // String returns the SSE domain as string. For SSE-KMS the
    // domain is "SSE-KMS".
    func (ssekms) String() string { return "SSE-KMS" }
    
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Jan 18 07:03:17 GMT 2024
    - 8.4K bytes
    - Viewed (0)
  8. cmd/os_unix.go

    	case syscall.DT_REG:
    		typ = 0
    	case syscall.DT_DIR:
    		typ = os.ModeDir
    	case syscall.DT_LNK:
    		typ = os.ModeSymlink
    	default:
    		// Skip all other file types. Revisit if/when this code needs
    		// to handle such files, MinIO is only interested in
    		// files and directories.
    		typ = unexpectedFileMode
    	}
    
    	nameBuf := (*[unsafe.Sizeof(dirent.Name)]byte)(unsafe.Pointer(&dirent.Name[0]))
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Jan 18 07:03:17 GMT 2024
    - 9.3K bytes
    - Viewed (0)
  9. internal/grid/manager.go

    		return nil, fmt.Errorf("grid: local host not found")
    	}
    
    	return m, nil
    }
    
    // AddToMux will add the grid manager to the given mux.
    func (m *Manager) AddToMux(router *mux.Router) {
    	router.Handle(RoutePath, m.Handler())
    }
    
    // Handler returns a handler that can be used to serve grid requests.
    // This should be connected on RoutePath to the main server.
    func (m *Manager) Handler() http.HandlerFunc {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 9.5K bytes
    - Viewed (0)
  10. cmd/os-reliable.go

    			return errFileAccessDenied
    		case isSysErrPathNotFound(err):
    			// This is a special case should be handled only for
    			// windows, because windows API does not return "not a
    			// directory" error message. Handle this specifically
    			// here.
    			return errFileAccessDenied
    		}
    	}
    	return err
    }
    
    // Reliably retries os.RemoveAll if for some reason os.RemoveAll returns
    // syscall.ENOTEMPTY (children has files).
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Mon Apr 22 17:49:30 GMT 2024
    - 5.8K bytes
    - Viewed (0)
Back to top