- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 23 for wrappers (0.34 sec)
-
misc/go_android_exec/main.go
// and temporary data. Then, it copies relevant parts of GOROOT to the device, // including the go tool built for android. // A lock file ensures this only happens once, even with concurrent exec // wrappers. func adbCopyGoroot() error { goTool, err := goTool() if err != nil { return err } cmd := exec.Command(goTool, "version") cmd.Stderr = os.Stderr out, err := cmd.Output() if err != nil {
Go - Registered: Tue Apr 30 11:13:12 GMT 2024 - Last Modified: Mon Aug 21 17:46:57 GMT 2023 - 15.3K bytes - Viewed (0) -
cmd/peer-rest-client.go
return nil } gridConn.Store(gc) return gc }, } } // Wrapper to restClient.Call to handle network errors, in case of network error the connection is marked disconnected // permanently. The only way to restore the connection is at the xl-sets layer by xlsets.monitorAndConnectEndpoints()
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 25.8K bytes - Viewed (0) -
cmd/erasure-metadata.go
if fi.Deleted { return fi.ReplicationState.CompositeReplicationStatus() } return replication.StatusType("") } // GetInternalReplicationState is a wrapper method to fetch internal replication state from the map m func GetInternalReplicationState(m map[string][]byte) ReplicationState { m1 := make(map[string]string, len(m)) for k, v := range m { m1[k] = string(v) }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sun Apr 28 17:53:50 GMT 2024 - 19.2K bytes - Viewed (1) -
internal/grid/connection.go
if client.deadline == 0 { client.cancelFn(context.DeadlineExceeded) return nil, context.DeadlineExceeded } } for { // Handle the extremely unlikely scenario that we wrapped. if _, loaded := c.outgoing.LoadOrStore(client.MuxID, client); client.MuxID != 0 && !loaded { if debugReqs { _, found := c.outgoing.Load(client.MuxID)
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/post-policy_test.go
retStr := "{" retStr = retStr + expirationStr + "," retStr += conditionStr retStr += "}" return []byte(retStr) } // Wrapper func TestPostPolicyReservedBucketExploit(t *testing.T) { ExecObjectLayerTestWithDirs(t, testPostPolicyReservedBucketExploit) } // testPostPolicyReservedBucketExploit is a test for the exploit fixed in PR // #16849
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri Apr 19 16:45:54 GMT 2024 - 29.6K bytes - Viewed (0) -
internal/rest/client.go
type NetworkError struct { Err error } func (n *NetworkError) Error() string { return n.Err.Error() } // Unwrap returns the error wrapped in NetworkError. func (n *NetworkError) Unwrap() error { return n.Err } // Client - http based RPC client. type Client struct { connected int32 // ref: https://golang.org/pkg/sync/atomic/#pkg-note-BUG
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sun Apr 28 17:53:50 GMT 2024 - 14.4K bytes - Viewed (0) -
cmd/storage-rest-client.go
} // Retrieve location indexes. func (client *storageRESTClient) GetDiskLoc() (poolIdx, setIdx, diskIdx int) { return client.endpoint.PoolIdx, client.endpoint.SetIdx, client.endpoint.DiskIdx } // Wrapper to restClient.Call to handle network errors, in case of network error the connection is disconnected // and a healthcheck routine gets invoked that would reconnect.
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sun Apr 28 17:53:50 GMT 2024 - 26.1K bytes - Viewed (0) -
cmd/object_api_suite_test.go
eof bool data []byte } func (r *testOneByteReadNoEOF) Read(p []byte) (n int, err error) { if r.eof { return 0, io.EOF } n = copy(p, r.data) r.eof = true return n, nil } // Wrapper for calling testMakeBucket for both Erasure and FS. func TestMakeBucket(t *testing.T) { ExecObjectLayerTest(t, testMakeBucket) } // Tests validate bucket creation.
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Feb 22 06:26:06 GMT 2024 - 32.3K bytes - Viewed (0) -
internal/grid/types.go
var t T return &t }, }, emptySz: sz, } } func (p *JSONPool[T]) new() *T { var zero T t := p.pool.Get().(*T) *t = zero return t } // JSON is a wrapper around a T object that can be serialized. // There is an internal value type JSON[T any] struct { p *JSONPool[T] val *T } // NewJSON returns a new JSONPool. // No initial value is set.
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Apr 01 23:42:09 GMT 2024 - 15.4K bytes - Viewed (0) -
cmd/xl-storage-disk-id-check.go
} n, err := d.w.Write(p) if err == nil && n == len(p) { d.tracker.logSuccess() } return n, err } // diskHealthReader provides a wrapper that will update disk health on // ctx, on every successful read. // This should only be used directly at the os/syscall level, // otherwise buffered operations may return false health checks.
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sun Apr 28 17:53:50 GMT 2024 - 33K bytes - Viewed (0)