Search Options

Results per page
Sort
Preferred Languages
Advance

Results 61 - 70 of 142 for pcall (0.14 sec)

  1. cmd/os-rename_linux.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 (
    	"syscall"
    )
    
    // RenameSys is low level call in case of Linux this uses syscall.Rename() directly.
    func RenameSys(src, dst string) (err error) {
    	return syscall.Rename(src, dst)
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Feb 15 01:09:38 GMT 2024
    - 999 bytes
    - Viewed (0)
  2. internal/config/drive/help.go

    	MaxTimeout = "max_timeout"
    	// HelpDrive is help for drive
    	HelpDrive = config.HelpKVS{
    		config.HelpKV{
    			Key:         MaxTimeout,
    			Type:        "string",
    			Description: "set per call max_timeout for the drive, defaults to 2 minutes",
    			Optional:    true,
    		},
    	}
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Mon Nov 27 17:15:06 GMT 2023
    - 1.1K bytes
    - Viewed (0)
  3. internal/disk/type_windows.go

    	// _Out_opt_ LPDWORD lpMaximumComponentLength,
    	// _Out_opt_ LPDWORD lpFileSystemFlags,
    	// _Out_opt_ LPTSTR  lpFileSystemNameBuffer,
    	// _In_      DWORD   nFileSystemNameSize
    	// );
    
    	_, _, _ = GetVolumeInformation.Call(uintptr(unsafe.Pointer(ps)),
    		uintptr(unsafe.Pointer(&volumeName)),
    		uintptr(volumeNameSize),
    		uintptr(unsafe.Pointer(&lpVolumeSerialNumber)),
    		uintptr(unsafe.Pointer(&lpMaximumComponentLength)),
    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)
  4. internal/http/dial_dnscache.go

    // is given, it sets default dial function.
    //
    // You can use returned dial function for `http.Transport.DialContext`.
    //
    // In this function, it uses functions from `rand` package. To make it really random,
    // you MUST call `rand.Seed` and change the value from the default in your application
    func DialContextWithLookupHost(lookupHost LookupHost, baseDialCtx DialContext) DialContext {
    	if lookupHost == nil {
    		lookupHost = net.DefaultResolver.LookupHost
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Mon Jul 03 19:30:51 GMT 2023
    - 2.6K bytes
    - Viewed (0)
  5. cmd/leak-detect_test.go

    	// since the snapshot is taken here the entry will have the current function too.
    	"pickRelevantGoroutines",
    	"runtime.MHeap_Scavenger",
    	"signal.signal_recv",
    	"sigterm.handler",
    	"runtime_mcall",
    	"goroutine in C code",
    }
    
    // Identify whether the stack trace entry is part of ignoredStackFn .
    func isIgnoredStackFn(stack string) (ok bool) {
    	ok = true
    	for _, stackFn := range ignoredStackFns {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Jan 18 07:03:17 GMT 2024
    - 5.2K bytes
    - Viewed (0)
  6. internal/grid/debug.go

    	Mux         []*mux.Router
    	Hosts       []string
    	cleanupOnce sync.Once
    	cancel      context.CancelFunc
    }
    
    // SetupTestGrid creates a new grid for testing purposes.
    // Select the number of hosts to create.
    // Call (TestGrid).Cleanup() when done.
    func SetupTestGrid(n int) (*TestGrid, error) {
    	hosts, listeners, err := getHosts(n)
    	if err != nil {
    		return nil, err
    	}
    	dialer := &net.Dialer{
    		Timeout: 5 * time.Second,
    	}
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Feb 08 18:15:27 GMT 2024
    - 4.2K bytes
    - Viewed (0)
  7. cmd/bucket-versioning-handler.go

    		return
    	}
    
    	updatedAt, err := globalBucketMetadataSys.Update(ctx, bucket, bucketVersioningConfig, 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)
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Mon Apr 22 17:49:30 GMT 2024
    - 5K bytes
    - Viewed (0)
  8. internal/cachevalue/cache.go

    // An Update function must be set to provide an updated value when needed.
    type Cache[T any] struct {
    	// updateFn must return an updated value.
    	// If an error is returned the cached value is not set.
    	// Only one caller will call this function at any time, others will be blocking.
    	// The returned value can no longer be modified once returned.
    	// Should be set before calling Get().
    	updateFn func() (T, error)
    
    	// ttl for a cached value.
    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)
  9. internal/grid/connection.go

    // 'req' will not be used after the call and caller can reuse.
    // If no deadline is set on ctx, a 1-minute deadline will be added.
    func (c *Connection) Request(ctx context.Context, h HandlerID, req []byte) ([]byte, error) {
    	if !h.valid() {
    		return nil, ErrUnknownHandler
    	}
    	if c.State() != StateConnected {
    		return nil, ErrDisconnected
    	}
    	// Create mux client and call.
    	client, err := c.newMuxClient(ctx)
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 42.6K bytes
    - Viewed (0)
  10. cmd/object-api-utils.go

    func NewGetObjectReaderFromReader(r io.Reader, oi ObjectInfo, opts ObjectOptions, cleanupFns ...func()) (*GetObjectReader, error) {
    	if opts.CheckPrecondFn != nil && opts.CheckPrecondFn(oi) {
    		// Call the cleanup funcs
    		for i := len(cleanupFns) - 1; i >= 0; i-- {
    			cleanupFns[i]()
    		}
    		return nil, PreConditionFailed{}
    	}
    	return &GetObjectReader{
    		ObjInfo:    oi,
    		Reader:     r,
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Mon Mar 11 11:55:34 GMT 2024
    - 35.6K bytes
    - Viewed (1)
Back to top