move_attachments.go RawHistoryFolder

1package daemon
2
3func moveAttachmentTokenCurrentLocked(token attachmentConnectionToken, sess *session) bool {
4	return token.sess == sess && token.ac != nil && token.generation == token.ac.connectionGeneration.Load() &&
5		token.ac.currentAttachmentSession() == sess && token.ac.transportSnapshotCurrent(token.transport) &&
6		attachmentRegisteredLocked(sess, token.ac)
7}
8
9// sameMoveAttachmentsLocked reports whether the source membership is unchanged
10// since admission. Caller holds the source session lock.
11func sameMoveAttachmentsLocked(sess *session, admitted []*attachedClient) bool {
12	if sess == nil || len(sess.attachments) != len(admitted) {
13		return false
14	}
15	for _, ac := range admitted {
16		if !attachmentRegisteredLocked(sess, ac) {
17			return false
18		}
19	}
20	return true
21}
22
23// detachMoveAttachmentsLocked invalidates every attachment of a source session
24// that became empty. Moves never transfer attachment ownership to the target;
25// each connection is retired independently after the shared content move.
26// Caller holds the source session lock and the affected attachment gates are
27// frozen.
28func detachMoveAttachmentsLocked(sess *session, transports map[*attachedClient]transportSnapshot) []detachedAttachmentSnapshot {
29	if sess == nil || len(sess.attachments) == 0 {
30		return nil
31	}
32	attachments := sess.snapshotAttachmentsLocked()
33	retired := make([]detachedAttachmentSnapshot, 0, len(attachments))
34	for _, ac := range attachments {
35		retired = append(retired, detachedAttachmentSnapshot{ac: ac, transport: transports[ac]})
36		ac.connectionGeneration.Add(1)
37		ac.setSession(nil)
38		ac.invalidateFrozenAttachmentCapability()
39	}
40	clear(sess.attachments)
41	return retired
42}