cryptix/caberl - Change TXWXXWZTZBTCRZO53LZXDXTRILWL52CLGDIZSRKBJZJF32HTK7UAC

fix bug

Created by Henry on November 19, 2025

TXWXXWZTZBTCRZO53LZXDXTRILWL52CLGDIZSRKBJZJF32HTK7UAC

Dependencies

In channels

main

Change contents

Replacement in src/peer.erl at line 685 [4.854]

∅:D[2.4725] → [3.19351:19393]

B:BD[5.10252] → [3.19351:19393]

B:BD[3.19393] → [2.4726:4825]

∅:D[2.4825] → [3.19482:19500]

∅:D[6.12531] → [3.19482:19500]

B:BD[3.19482] → [3.19482:19500]

B:BD[3.19500] → [2.4826:4870]

∅:D[2.4870] → [3.19541:19563]

B:BD[3.19541] → [3.19541:19563]

B:BD[3.19563] → [2.4871:5009]

∅:D[2.5009] → [3.19695:19735]

B:BD[3.19695] → [3.19695:19735]

                %% TODO: handle send fail
                {ok, {ReqId, Msg, Size}} = send_channel_state_request(State, ConnPid, Chan, true),
                {
                    {sent, ReqId, ConnPid},
                    {
                        maps:put(ReqId, {ConnPid, Msg}, AccActiveOuts),
                        update_peer_sent(AccPeers, ConnPid, Size)
                    }
                }

[2.4725]

[3.19735]

                case send_channel_state_request(State, ConnPid, Chan, true) of
                    {ok, {ReqId, Msg, Size}} ->
                        {
                            {sent, ReqId, ConnPid},
                            {
                                update_peer_sent(AccPeers, ConnPid, Size),
                                maps:put(ReqId, {ConnPid, Msg}, AccActiveOuts)
                            }
                        };
                    {error, _Reason} ->
                        %% If send fails, we don't track the request
                        {
                            {error, send_failed},
                            {AccPeers, AccActiveOuts}
                        }
                end

Insertion in src/peer.erl at line 705 [4.854]

[3.19893]

[5.10889]

            %% Filter out failed requests from the list
            ValidReqs = [R || R <- Reqs, element(1, R) =/= error],

Replacement in src/peer.erl at line 708 [4.854]

B:BD[5.10914] → [3.19894:19950]

                channels = maps:put(Chan, Reqs, Chans),

[5.10914]

[3.19950]

                channels = maps:put(Chan, ValidReqs, Chans),

Replacement in src/peer.erl at line 734 [4.854]

∅:D[2.5241] → [3.20341:20383]

B:BD[3.20341] → [3.20341:20383]

B:BD[3.20383] → [2.5242:5323]

∅:D[2.5323] → [3.20454:20507]

∅:D[6.12610] → [3.20454:20507]

B:BD[3.20454] → [3.20454:20507]

B:BD[3.20507] → [2.5324:5386]

∅:D[2.5386] → [3.20566:20584]

B:BD[3.20566] → [3.20566:20584]

                %% TODO: handle send fail
                {ok, {_, _, Size}} = send_cancel_request(State, ConnPid, ReqId),
                {
                    NewActiveOuts,
                    update_peer_sent(AccPeers, ConnPid, Size)
                }

[2.5241]

[3.20584]

                case send_cancel_request(State, ConnPid, ReqId) of
                    {ok, {_, _, Size}} ->
                        {
                            NewActiveOuts,
                            update_peer_sent(AccPeers, ConnPid, Size)
                        };
                    {error, _} ->
                        {NewActiveOuts, AccPeers}
                end