┌─────────────┐     ┌─────────────┐     ┌─────────────┐
│  信令接入层  │────▶│  事件总线   │────▶│  FSM 引擎   │
│  (SIP/WS/HTTP)│     │  (Kafka/    │     │  (状态机核心)│
└─────────────┘     │   Pulsar)   │     └──────┬──────┘
                    └─────────────┘            │
                           │                   ▼
                    ┌──────┴──────┐     ┌─────────────┐
                    │  状态持久化  │◀───▶│  会议上下文  │
                    │  (Redis/    │     │  缓存层     │
                    │   etcd)     │     └─────────────┘
                    └─────────────┘

[CHAIR_VACANT] 
    │ 指定/首入
    ▼
[CHAIR_ACTIVE] ◀──────────────────┐
    │ 主席主动离会/网络超时        │ 主席委托/抢占成功
    ▼                              │
[CHAIR_ELECTION] ──────────────────┘
    │ 选举算法（Raft/优先级/时长）
    ▼
[CHAIR_ACTIVE] (新主席)

sequenceDiagram
    participant Chair as 主席客户端
    participant Signal as 信令服务
    participant Media as 媒体服务器
    participant Member as 普通成员

    Chair->>Signal: MuteAllRequest {confId, chairToken}
    Signal->>Signal: 校验主席权限 + 会议状态=ACTIVE
    Signal->>Media: BatchMute {confId, memberIds[]}
    Media-->>Signal: MuteResult {success[], failed[]}
    Signal->>Member: NotifyMute {reason: "CHAIR_CONTROL"}
    Signal-->>Chair: MuteAllResponse {report}

fsm: ConferenceSession
version: "v2.1.0"
states:
  - name: ACTIVE
    on_enter: [AllocMediaPorts, StartRecordingIfNeeded, SyncLayoutToNewComers]
    on_exit: [ReleaseMediaPorts, StopRecording, PersistFinalMetadata]
    transitions:
      - event: LockMeeting
        target: LOCKED
        guard: "ctx.chair_id == evt.operator_id && !ctx.is_locked"
        action: [SetLockFlag, NotifyAllMembers]
      - event: ParticipantJoinRequest
        target: ACTIVE          # 自环迁移
        guard: "!ctx.is_locked || evt.is_chair"
        action: [AdmitParticipant, SyncCurrentState]
      - event: ForceEndByAdmin
        target: ENDED
        guard: "evt.operator_role == 'SUPER_ADMIN'"
        action: [BroadcastEndReason, TriggerGracefulShutdown]

// 内存布局优化：热字段前置，冷字段分离，避免伪共享
type ConferenceContext struct {
    // 热字段（高频读写，64字节缓存行对齐）
    ConferenceID   uint64
    State          StateID
    Version        uint64        // 乐观锁版本号
    ChairID        uint64
    MemberBitmap   *roaring.Bitmap // 亿级成员在线状态压缩存储
    MediaConfig    MediaProfile
    _              [48]byte      // Padding to next cache line

    // 温字段
    ScheduleInfo   *ScheduleMeta
    RecordingState *RecordingContext
    
    // 冷字段（指针引用，按需分配）
    ExtensionData  map[string][]byte // 插件扩展数据
}

// 对象池管理
var ctxPool = sync.Pool{
    New: func() interface{} {
        return &ConferenceContext{
            MemberBitmap: roaring.NewBitmap(),
            ExtensionData: make(map[string][]byte, 4),
        }
    },
}

// 租用/归还埋点
func AcquireCtx(confID uint64) *ConferenceContext {
    ctx := ctxPool.Get().(*ConferenceContext)
    ctx.ConferenceID = confID
    ctx.Version = 0
    metrics.ObjPoolAcquire.Inc()
    return ctx
}

// 只有收到 Quorum 确认“旧主席真下线”，才允许进入选举
func guardEnterElection(ctx *Context, evt *Event) bool {
    if ctx.ChairSuspectSince.IsZero() { return false }
    // 必须满足：怀疑期超时 && 收到多数派确认下线
    return time.Since(ctx.ChairSuspectSince) > SuspectTimeout && 
           ctx.DownVotes >= ctx.QuorumSize
}

// 统一内部事件，屏蔽 SIP/HTTP/WebSocket 差异
message UnifiedSignalEvent {
  string conference_id = 1;
  string participant_id = 2;
  EventType type = 3;        // INVITE, BYE, REINVITE, INFO, NOTIFY...
  google.protobuf.Any payload = 4; // 承载 SIP Headers / SDP / JSON Body
  uint64 timestamp_ms = 5;
  map<string, string> metadata = 6; // 透传 Call-ID, CSeq, Tag 等
}

// 插件接口定义
#[no_mangle]
pub extern "C" fn pre_transition_guard(
    ctx_ptr: *const u8, ctx_len: usize,
    evt_ptr: *const u8, evt_len: usize,
    next_state: u32
) -> i32 { // 返回码: 0=Allow, 1=Deny, >1=Redirect StateID
    // 反序列化 Protobuf，执行业务逻辑
    // 严格限制：CPU < 1ms, Memory < 2MB, 无网络/文件 IO 权限
}

用户语音指令："把张三的画面放大并静音其他人"
LLM 解析 -> Intent: {action: "SPOTLIGHT", target: "zhangsan", side_effect: "MUTE_OTHERS"}
FSM 校验 -> 权限检查(主席/协助) -> 状态合法性(ACTIVE) -> 执行 BatchAction
审计日志 -> 记录 "AI_ASSISTED: SPOTLIGHT+MUTE_OTHERS by Chair"

// 核心状态机句柄 (C 风格伪代码，便于跨语言理解)
typedef struct {
    uint64_t        conference_id;      // 全局唯一
    uint32_t        fsm_version;        // 热更新版本号
    StateID         current_state;      // 原子读写
    uint64_t        version;            // 乐观锁
    
    // 主席相关
    uint64_t        chair_user_id;
    ChairMode       chair_mode;         // DESIGNATED / FIRST_JOIN / ELECTED
    Timestamp       chair_heartbeat_at;
    uint8_t         chair_priority;     // 选举权重
    
    // 成员管理 (Roaring Bitmap 压缩)
    RoaringBitmap*  online_members;     // 在线成员 ID 集合
    RoaringBitmap*  muted_members;      // 静音成员
    RoaringBitmap*  hand_raised;        // 举手队列
    
    // 媒体控制
    MediaLayout     current_layout;     // 当前布局模板 ID
    RecordingState  rec_state;          // 录制状态机子状态
    
    // 扩展插件数据 (Key: plugin_name, Value: serialized bytes)
    HashMap*        plugin_data;        
    
    // 统计指标
    uint64_t        total_join_cnt;
    uint64_t        total_kick_cnt;
    uint64_t        chair_switch_cnt;
} ConferenceFSMHandle;