Method StartMonitoring

utils/service_utils/ram_management.go:152–196

(name string)

}

func (sm *ServiceManager) StartMonitoring(name string) {
	sm.Mu.RLock()
	service, exists := sm.Services[name]
	sm.Mu.RUnlock()

	if !exists {
		return
	}

	limiter := &SoftLimiter{
		PID:       service.PID,
		SoftLimit: int64(float64(service.Config.RAMBytes) * 0.8),
		HardLimit: service.Config.RAMBytes,
	}

	go func() {
		ticker := time.NewTicker(10 * time.Second)
		defer ticker.Stop()

		for range ticker.C {
			service.mu.RLock()
			if service.Status != "running" {
				service.mu.RUnlock()
				return
			}
			service.mu.RUnlock()

			usage, err := getProcessTreeRAM(limiter.PID)
			if err != nil {
				log.Printf("Error checking RAM usage of service: %s", name)
				continue
			}

			if usage > limiter.HardLimit {
				log.Printf("Stopping Service: %s RAM Limit Exceeded! Usage: %s / Limit: %s",
					name,
					utils.ConvertBytesToString(usage),
					service.Config.RAM)

				go sm.StopService(name)
				return
			}
		}
	}()
}