Method IsDone

internal/session/session.go:241–252

IsDone reports whether both FIN frames (sent and received) have flowed, OR whether we sent our FIN but the peer's FIN never arrived within sessionFinalTimeout. The timeout prevents orphaned sessions from accumulating in the carrier's session map when a relay response carrying the peer's FIN is dropp

()

// in the carrier's session map when a relay response carrying the peer's FIN
// is dropped.
func (s *Session) IsDone() bool {
	s.mu.Lock()
	defer s.mu.Unlock()
	if s.finSent && s.rxClosed {
		return true
	}
	// Reap orphaned sessions: we sent our FIN but never received the peer's.
	if s.finSent && !s.finSentAt.IsZero() && time.Since(s.finSentAt) > sessionFinalTimeout {
		return true
	}
	return false
}

// DrainSnapshot captures the pre-drain state of a session so the caller can
// roll back via RollbackDrain if the batch carrying the drained frames cannot