ephemeral_close.go RawHistoryFolder

1package daemon
2
3import (
4	"errors"
5
6	"github.com/bnema/vev/internal/protocol"
7)
8
9// reapAbandonedEphemeral removes an ephemeral session whose last attachment
10// ended definitively (a closed client process, or an expired park or
11// suspension) when ephemeral.close-on-exit is on. A user detach or picker
12// switch never calls it: those keep the session for later reattach.
13//
14// The emptiness and ephemeral checks run under the architecture locks at
15// snapshot and publication, so any live, suspended, parked, or parking
16// attachment, or a concurrent rename into a named session, keeps it.
17// Callers must not hold daemon, session, or attachment locks.
18func (d *Daemon) reapAbandonedEphemeral(sess *session) {
19	if sess == nil || !d.currentEphemeralConfig().CloseOnExit {
20		return
21	}
22	err := d.killEphemeralSessionIfEmpty(sess, protocol.ReasonSessionKilled)
23	switch {
24	case errors.Is(err, errSessionKillParticipantsChanged):
25		// An attachment or rename won the race: the session stays by design.
26		d.log.Debug("ephemeral close-on-exit skipped", "session", sess.nameSnapshot())
27	case err != nil:
28		d.log.Warn("ephemeral close-on-exit failed", "err", err, "session", sess.nameSnapshot())
29	case !d.sessionRegistered(sess):
30		d.log.Info("ephemeral session gone after last attachment ended", "session", sess.nameSnapshot())
31	}
32}
33
34// sessionHasPendingResumeLocked reports whether sess still retains a parked or
35// in-flight parking attachment that a reconnecting client may resume. Caller
36// holds d.mu.
37func (d *Daemon) sessionHasPendingResumeLocked(sess *session) bool {
38	return d.resume.retainsSession(sess)
39}