Function onConnectionUp

pkg/jobcontroller/jobcontroller.go:484–515

(connName string)

}

func onConnectionUp(connName string) {
	log.Printf("[conn:%s] connection became connected, reconnecting jobs", connName)
	ctx, cancelFn := context.WithTimeout(context.Background(), 5*time.Second)
	defer cancelFn()

	allJobs, err := wstore.DBGetAllObjsByType[*waveobj.Job](ctx, waveobj.OType_Job)
	if err != nil {
		log.Printf("[conn:%s] failed to get jobs for reconnection: %v", connName, err)
		return
	}

	var jobsToReconnect []*waveobj.Job
	for _, job := range allJobs {
		if job.Connection == connName && isJobManagerRunning(job) {
			jobsToReconnect = append(jobsToReconnect, job)
		}
	}

	log.Printf("[conn:%s] found %d jobs to reconnect", connName, len(jobsToReconnect))

	successCount := 0
	for _, job := range jobsToReconnect {
		err = ReconnectJob(ctx, job.OID, nil)
		if err != nil {
			log.Printf("[job:%s] error reconnecting: %v", job.OID, err)
		} else {
			successCount++
		}
	}

	log.Printf("[conn:%s] finished reconnecting jobs: %d/%d successful", connName, successCount, len(jobsToReconnect))
}

func onConnectionDown(connName string) {
	log.Printf("[conn:%s] connection became disconnected", connName)