- Sort Score
- Result 10 results
- Languages All
Results 51 - 60 of 736 for Leifer (0.27 sec)
-
docs/de/docs/deployment/server-workers.md
* Dann beginnt er zu lauschen: `Listening at: http://0.0.0.0:80`. * Dann erkennt er, dass er die Workerklasse `uvicorn.workers.UvicornWorker` verwenden muss. * Und dann werden **4 Worker** gestartet, jeder mit seiner eigenen PID: `19511`, `19513`, `19514` und `19515`.
Plain Text - Registered: Sun Apr 28 07:19:10 GMT 2024 - Last Modified: Sat Mar 30 18:19:25 GMT 2024 - 10.1K bytes - Viewed (0) -
cmd/site-replication-utils.go
sm.resyncStatus[rs.ResyncID] = rs } sm.Unlock() } return nil } func (sm *siteResyncMetrics) report(dID string) *madmin.SiteResyncMetrics { sm.RLock() defer sm.RUnlock() rst, ok := sm.peerResyncMap[dID] if !ok { return nil } rs, ok := sm.resyncStatus[rst.resyncID] if !ok { return nil } m := madmin.SiteResyncMetrics{
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Thu Jan 18 07:03:17 GMT 2024 - 8.9K bytes - Viewed (1) -
cmd/admin-heal-ops.go
func (ahs *allHealState) setDiskHealingStatus(ep Endpoint, healing bool) { ahs.Lock() defer ahs.Unlock() ahs.healLocalDisks[ep] = healing } func (ahs *allHealState) pushHealLocalDisks(healLocalDisks ...Endpoint) { ahs.Lock() defer ahs.Unlock() for _, ep := range healLocalDisks { ahs.healLocalDisks[ep] = false } } func (ahs *allHealState) periodicHealSeqsClean(ctx context.Context) {
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 25.1K bytes - Viewed (1) -
cmd/xl-storage-disk-id-check.go
if err != nil { return nil, err } defer done(&err) return p.storage.ListVols(ctx) } func (p *xlStorageDiskIDCheck) StatVol(ctx context.Context, volume string) (vol VolInfo, err error) { ctx, done, err := p.TrackDiskHealth(ctx, storageMetricStatVol, volume) if err != nil { return vol, err } defer done(&err)
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Sun Apr 28 17:53:50 GMT 2024 - 33K bytes - Viewed (0) -
istioctl/pkg/validate/validate_test.go
defer closeValidYAMLFile.Close() validFilenameJSON, closeValidJSONFile := createTestFile(t, validJSON) defer closeValidJSONFile.Close() invalidFilenameYAML, closeInvalidYAMLFile := createTestFile(t, invalidYAML) defer closeInvalidYAMLFile.Close() warningFilename, closeWarningFile := createTestFile(t, warningsYAML) defer closeWarningFile.Close()
Go - Registered: Wed Apr 24 22:53:08 GMT 2024 - Last Modified: Tue Jul 25 08:08:36 GMT 2023 - 21.5K bytes - Viewed (0) -
cmd/sftp-server-driver.go
} cctx, cancel := context.WithCancel(context.Background()) defer cancel() if prefix == "" { // if all objects are not deleted yet this call may fail. return clnt.RemoveBucket(cctx, bucket) } objectsCh := make(chan minio.ObjectInfo) // Send object names that are needed to be removed to objectsCh go func() { defer xioutil.SafeClose(objectsCh) opts := minio.ListObjectsOptions{
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Fri Apr 19 12:23:42 GMT 2024 - 12.9K bytes - Viewed (0) -
internal/config/lambda/event/targetlist.go
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Tue Mar 07 16:12:41 GMT 2023 - 4.3K bytes - Viewed (0) -
cmd/erasure-object_test.go
ctx, cancel := context.WithCancel(context.Background()) defer cancel() var objLayer ObjectLayer var disks []string var err error var opts ObjectOptions objLayer, disks, err = prepareErasure16(ctx) if err != nil { t.Fatal(err) } // cleaning up of temporary test directories defer objLayer.Shutdown(context.Background()) defer removeRoots(disks)
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Tue Jan 30 20:43:25 GMT 2024 - 36.8K bytes - Viewed (0) -
internal/grid/grid_test.go
connRemoteLocal := remote.Connection(localHost) t.Run("testStreamRoundtrip", func(t *testing.T) { defer timeout(5 * time.Second)() testStreamRoundtrip(t, local, remote) assertNoActive(t, connRemoteLocal) assertNoActive(t, connLocalToRemote) }) t.Run("testStreamCancel", func(t *testing.T) { defer timeout(5 * time.Second)() testStreamCancel(t, local, remote) assertNoActive(t, connRemoteLocal)
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Thu Feb 08 18:15:27 GMT 2024 - 30.1K bytes - Viewed (0) -
internal/config/batch/batch.go
func (opts Config) ExpirationWait() time.Duration { configMu.RLock() defer configMu.RUnlock() return opts.ExpirationWorkersWait } // ReplicationWait returns the duration for which a batch replication worker // would wait before working on next object. func (opts Config) ReplicationWait() time.Duration { configMu.RLock() defer configMu.RUnlock() return opts.ReplicationWorkersWait }
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Wed Dec 06 09:09:22 GMT 2023 - 4.7K bytes - Viewed (0)