- Sort Score
- Result 10 results
- Languages All
Results 21 - 30 of 67 for trac (0.14 sec)
-
internal/http/listener.go
} for i, serverAddr := range serverAddrs { l, e := listenCfg.Listen(ctx, "tcp", serverAddr) if e != nil { if opts.Trace != nil { opts.Trace(fmt.Sprint("listenCfg.Listen: ", e)) } listenErrs[i] = e continue } if opts.Trace != nil { opts.Trace(fmt.Sprint("adding listener to ", l.Addr())) } listeners = append(listeners, l) } if len(listeners) == 0 {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed Apr 24 04:08:47 GMT 2024 - 5.6K bytes - Viewed (0) -
cmd/batch-expire.go
for _, exp := range toExpire { if exp.ExpireAll { toExpireAll = append(toExpireAll, exp.ObjectInfo) continue } // Cache ObjectInfo value via pointers for // subsequent use to track objects which // couldn't be deleted. od := ObjectToDelete{ ObjectV: ObjectV{ ObjectName: exp.Name, VersionID: exp.VersionID, }, } toDel = append(toDel, od)
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 21K bytes - Viewed (1) -
cmd/xl-storage.go
// suspended or disabled on this bucket. RenameData will replace // the 'null' version. We add a free-version to track its tiered // content for asynchronous deletion. // // Note: RestoreObject and HealObject requests don't end up replacing the // null version and therefore don't require the free-version to track // anything if fi.VersionID == "" && !fi.IsRestoreObjReq() && !fi.Healing() {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sun Apr 28 17:53:50 GMT 2024 - 84.7K bytes - Viewed (0) -
cmd/leak-detect_test.go
} for _, g := range pickRelevantGoroutines() { snapshot.relevantRoutines[g] = true } return snapshot } // CompareCurrentSnapshot - Compares the initial relevant stack trace with the current one (during the time of invocation). func (initialSnapShot LeakDetect) CompareCurrentSnapshot() []string { var stackDiff []string for _, g := range pickRelevantGoroutines() {
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) -
cmd/http-tracer.go
op = strings.Replace(op, "ReadinessCheckHandler", "health.Readiness", 1) op = strings.Replace(op, "-fm", "", 1) return op } // If trace is enabled, execute the request if it is traced by other handlers // otherwise, generate a trace event with request information but no response. func httpTracerMiddleware(h http.Handler) http.Handler { return http.HandlerFunc(func(w http.ResponseWriter, r *http.Request) {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Nov 21 01:09:35 GMT 2023 - 5.9K bytes - Viewed (0) -
internal/grid/connection.go
func (c *Connection) Subroute(s string) *Subroute { if c == nil { return nil } return &Subroute{ Connection: c, route: s, subID: makeSubHandlerID(0, s), trace: c.trace.subroute(s), } } // Subroute adds a subroute to the subroute. // The subroutes are combined with '/'. func (c *Subroute) Subroute(s string) *Subroute { route := strings.Join([]string{c.route, s}, "/")
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/peer-rest-client.go
default: // There was error in the REST request, retry after sometime as probably the peer is down. time.Sleep(5 * time.Second) } } }() } // Trace - send http trace request to peer nodes func (client *peerRESTClient) Trace(ctx context.Context, traceCh chan<- []byte, traceOpts madmin.ServiceTraceOpts) { go func() { for { // Blocks until context is canceled or an error occurs.
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/admin-router.go
adminRouter.Methods(http.MethodPost).Path(adminVersion + adminAPIClientDevExtraTime).HandlerFunc(adminMiddleware(adminAPI.ClientDevNullExtraTime, noGZFlag)) // HTTP Trace adminRouter.Methods(http.MethodGet).Path(adminVersion + "/trace").HandlerFunc(adminMiddleware(adminAPI.TraceHandler, noObjLayerFlag)) // Console Logs
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sun Mar 10 21:09:36 GMT 2024 - 25.5K bytes - Viewed (0) -
cmd/api-router.go
// // The passed in handler function must be a method of `objectAPIHandlers` for // the name displayed in logs and trace to be accurate. The name is extracted // via reflection. // // When **no** flags are passed, the behavior is to trace both headers and body, // gzip the response and throttle the handler via `maxClients`. Each of these // can be disabled via the corresponding `s3HFlag`. //
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Mar 04 18:05:56 GMT 2024 - 22.8K bytes - Viewed (0) -
internal/s3select/csv/reader.go
csvDstPool sync.Pool // pool of [][]string used for output close chan struct{} // used for shutting down the splitter before end of stream readerWg sync.WaitGroup // used to keep track of async reader. } // queueItem is an item in the queue. type queueItem struct { input []byte // raw input sent to the worker dst chan [][]string // result of block decode
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)