- Sort Score
- Result 10 results
- Languages All
Results 61 - 70 of 142 for pcall (0.14 sec)
-
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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)