graph TB
    %% Framework Initialization Phase
    subgraph "1. Framework Initialization"
        A[QpFramework.__init__] --> B[Initialize Plugin Registry]
        B --> C[Initialize Session Manager]
        C --> D{Plugin Registration Method?}
        
        D -->|Manual| E[framework.register_plugin<br/>VendorPlugin]
        D -->|Auto-Discovery| F[framework.discover_plugins<br/>Future Enhancement]
        
        E --> G[Validate Plugin Interface]
        F --> G
        G --> H[Check Conflicts with Existing Plugins]
        H --> I[Call plugin.initialize]
        I --> J[Plugin Validation Complete]
        
        J --> K[Verify Required Methods]
        K --> L[Check Variant Availability]
        L --> M[Validate Configuration Parameters]
        M --> N[Framework Ready]
    end

    %% Session Creation Phase
    subgraph "2. Session Creation"
        N --> O[framework.get_variant<br/>plugin_id, variant_id, config]
        O --> P[Validate Plugin Exists & Initialized]
        P --> Q[Check Variant Available in Plugin]
        Q --> R[Create Variant Instance with Config]
        R --> S[Return Configured Variant Instance]
        
        S --> T{Determine Transport Type}
        T -->|Python Module| U[Load PythonModuleTransport]
        T -->|C++ .so Library| V[Load SoLibraryTransport]
        
        U --> W[Configure Transport with Connection Parameters]
        V --> W
        W --> X[framework.create_session<br/>variant, server_address]
        X --> Y[Initialize ClientServerTransport]
        Y --> Z[Establish Connection to QP Server]
        Z --> AA[Validate Connectivity and Readiness]
        AA --> BB[Session Ready]
    end

    %% QP Exchange Phase
    subgraph "3. QP Exchange Process"
        BB --> CC[session.execute_exchange_with_server<br/>variant.rdma_info_exchange]
        
        %% Single Exchange Loop
        subgraph "Single Exchange Loop"
            CC --> DD[Framework calls variant method<br/>peer_data=None initial call]
            DD --> EE[Plugin serializes local QP data<br/>vendor-specific format]
            EE --> FF[Plugin maintains internal state<br/>for multi-round exchanges]
            FF --> GG[Returns data: serialized_data<br/>completed: False]
            
            GG --> HH[transport.send_message<br/>sends data to server]
            HH --> II[transport.receive_message<br/>waits for server response]
            II --> JJ[Handle network errors and retries]
            
            JJ --> KK[Framework calls variant method<br/>peer_data=received_data]
            KK --> LL[Plugin deserializes and<br/>processes peer data]
            LL --> MM[Plugin updates internal state<br/>and local QP structures]
            MM --> NN[Returns local_rcvd_data: processed_data<br/>completed: True/False]
            
            NN --> OO{Exchange Complete?}
            OO -->|completed=False| HH
            OO -->|completed=True| PP[Update exchange history<br/>for debugging/monitoring]
        end
        
        PP --> QQ[RDMA Info Exchange Complete]
    end

    %% Complete QP Negotiation
    subgraph "4. Complete QP Negotiation"
        QQ --> RR[Stage 1: RDMA Info Exchange]
        RR --> SS[Exchange QP numbers, addresses, keys]
        SS --> TT[Establish RDMA connection parameters]
        TT --> UU[Validate QP pair connectivity]
        
        UU --> VV[Stage 2: RDMA Ready Exchange]
        VV --> WW[session.execute_exchange_with_server<br/>variant.rdma_ready_exchange]
        WW --> XX[Signal readiness for RDMA operations]
        XX --> YY[Synchronize QP state transitions]
        YY --> ZZ[Confirm both sides ready for data transfer]
        
        ZZ --> AAA{Optional Stage 3?}
        AAA -->|Yes| BBB[Stage 3: RDMA Done Exchange]
        AAA -->|No| FFF[QP Negotiation Complete]
        
        BBB --> CCC[session.execute_exchange_with_server<br/>variant.rdma_done_exchange]
        CCC --> DDD[Signal completion of RDMA operations]
        DDD --> EEE[Cleanup temporary resources]
        EEE --> FFF
    end

    %% Error Handling
    subgraph "5. Error Handling"
        GGG[Transport Layer Errors]
        GGG --> HHH[Connection Timeout]
        GGG --> III[Server Unreachable]
        HHH --> JJJ[Retry with Exponential Backoff]
        III --> KKK[Failover to Backup Server<br/>Future Enhancement]
        
        LLL[Plugin Layer Errors]
        LLL --> MMM[Serialization Failure]
        LLL --> NNN[Invalid Peer Data]
        LLL --> OOO[Resource Exhaustion]
        LLL --> PPP[Vendor Library Error]
        LLL --> QQQ[Configuration Error]
        MMM --> RRR[Log Error Details, Abort Exchange]
        NNN --> RRR
        OOO --> RRR
        PPP --> RRR
        QQQ --> RRR
        
        SSS[Framework Layer Errors]
        SSS --> TTT[Plugin Not Found]
        SSS --> UUU[Variant Not Available]
        SSS --> VVV[Session Timeout]
        SSS --> WWW[Unexpected Exception]
        TTT --> XXX[Attempt Dynamic Loading or Report Error]
        UUU --> YYY[List Available Variants, Suggest Alternatives]
        VVV --> ZZZ[Cleanup Session, Report Error]
        WWW --> AAAA[Log Full Stack Trace, Abort Exchange]
    end

    %% Error connections (showing where errors can occur)
    HH -.->|Error| GGG
    II -.->|Error| GGG
    EE -.->|Error| LLL
    LL -.->|Error| LLL
    O -.->|Error| SSS
    X -.->|Error| SSS

    %% Styling
    classDef initPhase fill:#e1f5fe
    classDef sessionPhase fill:#f3e5f5
    classDef exchangePhase fill:#e8f5e8
    classDef negotiationPhase fill:#fff3e0
    classDef errorPhase fill:#ffebee
    
    class A,B,C,D,E,F,G,H,I,J,K,L,M,N initPhase
    class O,P,Q,R,S,T,U,V,W,X,Y,Z,AA,BB sessionPhase
    class CC,DD,EE,FF,GG,HH,II,JJ,KK,LL,MM,NN,OO,PP,QQ exchangePhase
    class RR,SS,TT,UU,VV,WW,XX,YY,ZZ,AAA,BBB,CCC,DDD,EEE,FFF negotiationPhase
    class GGG,HHH,III,JJJ,KKK,LLL,MMM,NNN,OOO,PPP,QQQ,RRR,SSS,TTT,UUU,VVV,WWW,XXX,YYY,ZZZ,AAAA errorPhase