Outbound message handler. Called each time a message is submitted to the outbound_messages BPF table.
(_, data, size)
| 142 | |
| 143 | # BCC: perf buffer handle function for outbound_messages |
| 144 | def handle_outbound(_, data, size): |
| 145 | """ Outbound message handler. |
| 146 | |
| 147 | Called each time a message is submitted to the outbound_messages BPF table.""" |
| 148 | event = bpf["outbound_messages"].event(data) |
| 149 | if event.peer_id not in peers: |
| 150 | peer = Peer(event.peer_id, event.peer_addr.decode( |
| 151 | "utf-8"), event.peer_conn_type.decode("utf-8")) |
| 152 | peers[peer.id] = peer |
| 153 | peers[event.peer_id].add_message( |
| 154 | Message(event.msg_type.decode("utf-8"), event.msg_size, False)) |
| 155 | |
| 156 | # BCC: add handlers to the inbound and outbound perf buffers |
| 157 | bpf["inbound_messages"].open_perf_buffer(handle_inbound) |
nothing calls this directly
no test coverage detected