- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 68 for trac (0.13 sec)
-
cmd/erasure-object.go
} } if err != nil { return toObjectErr(err, bucket, object) } } for i, r := range readers { if r == nil { onlineDisks[i] = OfflineDisk } } // Track total bytes read from disk and written to the client. totalBytesRead += partLength // partOffset will be valid only for the first part, hence reset it to 0 for // the remaining parts. partOffset = 0
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sun May 05 16:56:21 GMT 2024 - 77.2K bytes - Viewed (2) -
internal/rest/client.go
_ int32 // For 64 bits alignment lastConn int64 // HealthCheckFn is the function set to test for health. // If not set the client will not keep track of health. // Calling this returns true or false if the target // is online or offline. HealthCheckFn func() bool // HealthCheckRetryUnit will be used to calculate the exponential
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/logger/target/console/console.go
return nil } traceLength := len(entry.Trace.Source) trace := make([]string, traceLength) // Add a sequence number and formatting for each stack trace // No formatting is required for the first entry for i, element := range entry.Trace.Source { trace[i] = fmt.Sprintf("%8v: %s", traceLength-i, element) } tagString := "" for key, value := range entry.Trace.Variables { if value != "" { if tagString != "" {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed May 01 17:57:52 GMT 2024 - 3.9K bytes - Viewed (0) -
internal/logger/logrotate.go
Message: msg, Time: time.Now().UTC(), Trace: &log.Trace{Message: msg}, }) } if err := w.rotate(); err != nil { msg := fmt.Sprintf("unable to rotate log file %v: %v", w.f.Name(), err) stdErrEnc.Encode(&log.Entry{ Level: ErrorKind, Message: msg, Time: time.Now().UTC(), Trace: &log.Trace{Message: msg}, }) } } }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu May 02 11:38:40 GMT 2024 - 5.8K bytes - Viewed (0) -
internal/logger/target/testlogger/testlogger.go
fmt.Fprintf(os.Stdout, format+"\n", args...) } } } switch v := entry.(type) { case log.Entry: if v.Trace == nil { logf("%s: %s", v.Level, v.Message) } else { msg := fmt.Sprintf("%s: %+v", v.Level, v.Trace.Message) for i, m := range v.Trace.Source { if i == 0 && strings.Contains(m, "logger.go:") { continue } msg += fmt.Sprintf("\n%s", m) }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Nov 21 01:09:35 GMT 2023 - 4K bytes - Viewed (0) -
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/bucket-lifecycle.go
Duration: duration, Path: pathJoin(oi.Bucket, oi.Name), Error: "", Message: getSource(4), Custom: map[string]string{"version-id": oi.VersionID}, } } func (sys *LifecycleSys) trace(oi ObjectInfo) func(event string) { startTime := time.Now() return func(event string) { duration := time.Since(startTime) if globalTrace.NumSubscribers(madmin.TraceILM) > 0 {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed Apr 17 05:09:58 GMT 2024 - 33.1K 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) -
docs/bucket/replication/setup_2site_existing_replication.sh
#!/usr/bin/env bash echo "Running $0" set -x trap 'catch $LINENO' ERR # shellcheck disable=SC2120 catch() { if [ $# -ne 0 ]; then echo "error on line $1" for site in sitea siteb; do echo "$site server logs =========" cat "/tmp/${site}_1.log" echo "===========================" cat "/tmp/${site}_2.log" done fi echo "Cleaning up instances of MinIO" pkill minio pkill -9 minio
Shell Script - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Mar 04 18:05:56 GMT 2024 - 5.6K bytes - Viewed (0) -
internal/grid/manager.go
// It also handles incoming requests and routes them to the appropriate connection. type Manager struct { // ID is an instance ID, that will change whenever the server restarts. // This allows remotes to keep track of whether state is preserved. ID uuid.UUID // Immutable after creation, so no locks. targets map[string]*Connection // serverside handlers. handlers handlers // local host name. local string
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 9.5K bytes - Viewed (0)