- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 18 for Wignall (0.2 sec)
-
cmd/object-api-interface.go
MaxParts int // used in GetObjectAttributes. Signals how many parts we should return PartNumberMarker int // used in GetObjectAttributes. Signals the part number after which results should be returned PartNumber int // only useful in case of GetObject/HeadObject
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Sat Apr 20 09:05:54 GMT 2024 - 16.9K bytes - Viewed (0) -
cmd/notification.go
} client := client ng.Go(GlobalContext, func() error { return client.SignalService(serviceReloadDynamic, subSys, false) }, idx, *client.host) } return ng.Wait() } // SignalService - calls signal service RPC call on all peers. func (sys *NotificationSys) SignalService(sig serviceSignal) []NotificationPeerErr { ng := WithNPeers(len(sys.peerClients)) for idx, client := range sys.peerClients { if client == nil {
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Fri Apr 12 18:13:36 GMT 2024 - 44.5K bytes - Viewed (0) -
cmd/admin-handlers.go
} } prs, ok := peerResults[local] if ok { prs.WaitingDrives = waitingDrivesNode() peerResults[local] = prs } if globalIsDistErasure { // Notify all other MinIO peers signal service. ng := WithNPeers(len(globalNotificationSys.peerClients)) for idx, client := range globalNotificationSys.peerClients { _, ok := failedClients[idx] if ok { continue } client := client
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Sun Apr 21 11:43:18 GMT 2024 - 97.3K bytes - Viewed (2) -
cmd/admin-handlers_test.go
case stopCmd: return madmin.ServiceActionStop } return madmin.ServiceActionRestart } // testServiceSignalReceiver - Helper function that simulates a // go-routine waiting on service signal. func testServiceSignalReceiver(cmd cmdType, t *testing.T) { expectedCmd := cmd.toServiceSignal() serviceCmd := <-globalServiceSignalCh if serviceCmd != expectedCmd {
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Thu Feb 22 06:26:06 GMT 2024 - 13.8K bytes - Viewed (0) -
cmd/service.go
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Wed Feb 28 07:02:14 GMT 2024 - 3.8K bytes - Viewed (0) -
cmd/peer-rest-common.go
peerRESTUserTemp = "user-temp" peerRESTPolicy = "policy" peerRESTUserOrGroup = "user-or-group" peerRESTUserType = "user-type" peerRESTIsGroup = "is-group" peerRESTSignal = "signal" peerRESTSubSys = "sub-sys" peerRESTProfiler = "profiler" peerRESTSize = "size" peerRESTConcurrent = "concurrent" peerRESTDuration = "duration"
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Fri Mar 08 19:08:18 GMT 2024 - 2.7K bytes - Viewed (0) -
cmd/server-main.go
// along with this program. If not, see <http://www.gnu.org/licenses/>. package cmd import ( "context" "encoding/hex" "errors" "fmt" "io" "log" "math/rand" "net" "os" "os/signal" "runtime" "strings" "syscall" "time" "github.com/coreos/go-systemd/v22/daemon" "github.com/dustin/go-humanize" "github.com/minio/cli" "github.com/minio/madmin-go/v3"
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Wed Apr 24 04:08:47 GMT 2024 - 33K bytes - Viewed (1) -
internal/grid/stream.go
responses <-chan Response cancel context.CancelCauseFunc // Requests sent to the server. // If the handler is defined with 0 incoming capacity this will be nil. // Channel *must* be closed to signal the end of the stream. // If the request context is canceled, the stream will no longer process requests. // Requests sent cannot be used any further by the called. Requests chan<- []byte muxID uint64
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Wed Feb 28 18:05:18 GMT 2024 - 2.8K bytes - Viewed (0) -
cmd/xl-storage.go
} if st.pendingCount > 0 { res["repl-pending-"+tgt] = fmt.Sprintf("%d versions, %d bytes", st.pendingCount, st.pendingSize) } } } if objDeleted { // we return errIgnoreFileContrib to signal this function's // callers to skip this object's contribution towards // usage. return sizeSummary{}, errIgnoreFileContrib } return sizeS, nil }, scanMode, weSleep) if err != nil {
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Sun Apr 28 17:53:50 GMT 2024 - 84.7K bytes - Viewed (0) -
cmd/signals.go
exit(stopProcess()) case osSignal := <-globalOSSignalCh: logger.Info("Exiting on signal: %s", strings.ToUpper(osSignal.String())) daemon.SdNotify(false, daemon.SdNotifyStopping) exit(stopProcess()) case signal := <-globalServiceSignalCh: switch signal { case serviceRestart: logger.Info("Restarting on service signal") daemon.SdNotify(false, daemon.SdNotifyReloading) stop := stopProcess()
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 2.7K bytes - Viewed (0)