- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 26 for Readlink (0.31 sec)
-
internal/deadlineconn/deadlineconn.go
type DeadlineConn struct { net.Conn readDeadline time.Duration // sets the read deadline on a connection. writeDeadline time.Duration // sets the write deadline on a connection. } // Sets read deadline func (c *DeadlineConn) setReadDeadline() { if c.readDeadline > 0 { c.SetReadDeadline(time.Now().UTC().Add(c.readDeadline)) } }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sat Nov 05 18:09:21 GMT 2022 - 2.3K bytes - Viewed (0) -
internal/config/api/api.go
) // API sub-system constants const ( apiRequestsMax = "requests_max" apiRequestsDeadline = "requests_deadline" apiClusterDeadline = "cluster_deadline" apiCorsAllowOrigin = "cors_allow_origin" apiRemoteTransportDeadline = "remote_transport_deadline" apiListQuorum = "list_quorum" apiReplicationPriority = "replication_priority"
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Mar 28 01:08:07 GMT 2024 - 11.1K bytes - Viewed (1) -
internal/grid/grid_test.go
Handle: func(ctx context.Context, payload []byte, request <-chan []byte, resp chan<- []byte) *RemoteErr { started := time.Now() dl, _ := ctx.Deadline() if testing.Verbose() { fmt.Println(GetCaller(ctx).Name, "Server deadline:", time.Until(dl)) } <-ctx.Done() serverCanceled <- time.Since(started) if testing.Verbose() {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Apr 30 15:03:35 GMT 2024 - 30.1K bytes - Viewed (0) -
cmd/leak-detect_test.go
deadline := UTCNow().Add(leakDetectDeadline * time.Second) for { // get sack snapshot of relevant go routines. leaked := initialSnapShot.CompareCurrentSnapshot() // current stack snapshot matches the initial one, no leaks, return. if len(leaked) == 0 { return } // wait a test again will deadline. if UTCNow().Before(deadline) {
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/connection.go
func (c *Connection) newMuxClient(ctx context.Context) (*muxClient, error) { client := newMuxClient(ctx, atomic.AddUint64(&c.NextID, 1), c) if dl, ok := ctx.Deadline(); ok { client.deadline = getDeadline(time.Until(dl)) if client.deadline == 0 { client.cancelFn(context.DeadlineExceeded) return nil, context.DeadlineExceeded } } for { // Handle the extremely unlikely scenario that we wrapped.
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) -
internal/rest/client.go
req, err := c.newRequest(ctx, u, body) if err != nil { return nil, &NetworkError{Err: err} } if length > 0 { req.ContentLength = length } _, expectTimeouts := ctx.Deadline() req, update := setupReqStatsUpdate(req) defer update() resp, err := c.httpClient.Do(req) if err != nil { if xnet.IsNetworkOrHostDown(err, expectTimeouts) { if !c.NoMetrics {
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) -
internal/grid/handlers.go
} // Call the remote with the request and return the response. // The response should be returned with PutResponse when no error. // If no deadline is set, a 1-minute deadline is added. func (h *SingleHandler[Req, Resp]) Call(ctx context.Context, c Requester, req Req) (resp Resp, err error) { if c == nil { if h.ignoreNilConn { return resp, nil }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Apr 23 17:15:52 GMT 2024 - 27.1K bytes - Viewed (0) -
cmd/admin-handlers-users-race_test.go
// along with this program. If not, see <http://www.gnu.org/licenses/>. //go:build !race // +build !race // Tests in this file are not run under the `-race` flag as they are too slow // and cause context deadline errors. package cmd import ( "context" "fmt" "runtime" "testing" "time" "github.com/minio/madmin-go/v3" minio "github.com/minio/minio-go/v7" "github.com/minio/pkg/v2/sync/errgroup"
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Sep 04 19:57:37 GMT 2023 - 3.9K bytes - Viewed (0) -
internal/ioutil/ioutil.go
} type ioret[V any] struct { val V err error } // DeadlineWriter deadline writer with timeout type DeadlineWriter struct { io.WriteCloser timeout time.Duration err error } // WithDeadline will execute a function with a deadline and return a value of a given type. // If the deadline/context passes before the function finishes executing, // the zero value and the context error is returned.
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri Apr 19 11:26:59 GMT 2024 - 10.3K bytes - Viewed (0) -
cmd/callhome.go
} } } func performCallhome(ctx context.Context) { deadline := 10 * time.Second // Default deadline is 10secs for callhome objectAPI := newObjectLayerFn() if objectAPI == nil { internalLogIf(ctx, errors.New("Callhome: object layer not ready")) return } healthCtx, healthCancel := context.WithTimeout(ctx, deadline) defer healthCancel() healthInfoCh := make(chan madmin.HealthInfo)
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 5.1K bytes - Viewed (1)