Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 16 for Bainter (0.18 sec)

  1. cmd/os-dirent_namelen_linux.go

    	"fmt"
    	"syscall"
    	"unsafe"
    )
    
    func direntNamlen(dirent *syscall.Dirent) (uint64, error) {
    	const fixedHdr = uint16(unsafe.Offsetof(syscall.Dirent{}.Name))
    	nameBuf := (*[unsafe.Sizeof(dirent.Name)]byte)(unsafe.Pointer(&dirent.Name[0]))
    	const nameBufLen = uint16(len(nameBuf))
    	limit := dirent.Reclen - fixedHdr
    	if limit > nameBufLen {
    		limit = nameBufLen
    	}
    	// Avoid bugs in long file names
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Aug 19 01:35:22 GMT 2021
    - 1.5K bytes
    - Viewed (0)
  2. cmd/api-utils.go

    // only works correctly when the type is present in the cmd package.
    func getHandlerName(f http.HandlerFunc, cmdType string) string {
    	name := runtime.FuncForPC(reflect.ValueOf(f).Pointer()).Name()
    
    	packageName := fmt.Sprintf("github.com/minio/minio/cmd.%s.", cmdType)
    	name = strings.TrimPrefix(name, packageName)
    	name = strings.TrimSuffix(name, "Handler-fm")
    	name = strings.TrimSuffix(name, "-fm")
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Mon Mar 04 18:05:56 GMT 2024
    - 2.8K bytes
    - Viewed (0)
  3. internal/config/identity/openid/provider/keycloak.go

    		return User{}, ErrAccessTokenExpired
    	}
    	return User{}, fmt.Errorf("Unable to lookup %s - keycloak user lookup returned %v", userid, resp.Status)
    }
    
    // Option is a function type that accepts a pointer Target
    type Option func(*KeycloakProvider)
    
    // WithTransport provide custom transport
    func WithTransport(transport http.RoundTripper) Option {
    	return func(p *KeycloakProvider) {
    		p.client = http.Client{
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri Apr 29 01:27:09 GMT 2022
    - 4.6K bytes
    - Viewed (0)
  4. cmd/grid.go

    	"github.com/minio/minio/internal/grid"
    	xhttp "github.com/minio/minio/internal/http"
    	"github.com/minio/minio/internal/rest"
    )
    
    // globalGrid is the global grid manager.
    var globalGrid atomic.Pointer[grid.Manager]
    
    // globalGridStart is a channel that will block startup of grid connections until closed.
    var globalGridStart = make(chan struct{})
    
    func initGlobalGrid(ctx context.Context, eps EndpointServerPools) error {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Tue Mar 26 15:00:38 GMT 2024
    - 2K bytes
    - Viewed (0)
  5. cmd/os_unix.go

    func parseDirEnt(buf []byte) (consumed int, name []byte, typ os.FileMode, err error) {
    	// golang.org/issue/15653
    	dirent := (*syscall.Dirent)(unsafe.Pointer(&buf[0]))
    	if v := unsafe.Offsetof(dirent.Reclen) + unsafe.Sizeof(dirent.Reclen); uintptr(len(buf)) < v {
    		return consumed, nil, typ, fmt.Errorf("buf size of %d smaller than dirent header size %d", len(buf), v)
    	}
    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)
  6. internal/disk/type_windows.go

    	// );
    
    	_, _, _ = GetVolumeInformation.Call(uintptr(unsafe.Pointer(ps)),
    		uintptr(unsafe.Pointer(&volumeName)),
    		uintptr(volumeNameSize),
    		uintptr(unsafe.Pointer(&lpVolumeSerialNumber)),
    		uintptr(unsafe.Pointer(&lpMaximumComponentLength)),
    		uintptr(unsafe.Pointer(&lpFileSystemFlags)),
    		uintptr(unsafe.Pointer(&lpFileSystemNameBuffer)),
    		uintptr(nFileSystemNameSize))
    
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Sun Jan 02 17:15:06 GMT 2022
    - 2.2K bytes
    - Viewed (0)
  7. internal/logger/target/testlogger/testlogger.go

    	errorMessage
    	fatalMessage
    )
    
    // T is the test logger.
    var T = &testLogger{}
    
    func init() {
    	logger.AddSystemTarget(context.Background(), T)
    }
    
    type testLogger struct {
    	current atomic.Pointer[testing.TB]
    	action  atomic.Int32
    }
    
    // SetLogTB will set the logger to output to tb.
    // Call the returned function to disable logging.
    func (t *testLogger) SetLogTB(tb testing.TB) func() {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Tue Nov 21 01:09:35 GMT 2023
    - 4K bytes
    - Viewed (0)
  8. internal/lock/lock_windows.go

    	reserved := uint32(0)
    	r1, _, e1 := syscall.Syscall6(procLockFileEx.Addr(), 6, uintptr(h), uintptr(flags),
    		uintptr(reserved), uintptr(locklow), uintptr(lockhigh), uintptr(unsafe.Pointer(ol)))
    	if r1 == 0 {
    		if e1 != 0 {
    			err = error(e1)
    		} else {
    			err = syscall.EINVAL
    		}
    	}
    	return
    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)
  9. internal/s3select/csv/reader.go

    			return nil, r.err
    		}
    		// Move to next block
    		item, ok := <-r.queue
    		if !ok {
    			r.err = io.EOF
    			return nil, r.err
    		}
    		//nolint:staticcheck // SA6002 Using pointer would allocate more since we would have to copy slice header before taking a pointer.
    		r.csvDstPool.Put(r.current)
    		r.current = <-item.dst
    		r.err = item.err
    		r.recordsRead = 0
    	}
    	csvRecord := r.current[r.recordsRead]
    	r.recordsRead++
    
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Feb 22 06:26:06 GMT 2024
    - 8.9K bytes
    - Viewed (0)
  10. internal/cachevalue/cache.go

    	ttl time.Duration
    
    	opts Opts
    
    	// Once can be used to initialize values for lazy initialization.
    	// Should be set before calling Get().
    	Once sync.Once
    
    	// Managed values.
    	valErr atomic.Pointer[struct {
    		v T
    		e error
    	}]
    	lastUpdateMs atomic.Int64
    	updating     sync.Mutex
    }
    
    // New allocates a new cached value instance. Tt must be initialized with
    // `.TnitOnce`.
    func New[T any]() *Cache[T] {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri Mar 01 16:00:42 GMT 2024
    - 4.2K bytes
    - Viewed (0)
Back to top