67 …  server->SetReadCallback([&received_bytes](Connection*, std::unique_ptr<apacket> packet) -> bool {  in BM_Connection_Unidirectional()  argument
68         received_bytes += packet->payload.size();  in BM_Connection_Unidirectional()
82         std::unique_ptr<apacket> packet = std::make_unique<apacket>();  in BM_Connection_Unidirectional()  local
83         memset(&packet->msg, 0, sizeof(packet->msg));  in BM_Connection_Unidirectional()
84         packet->msg.command = A_WRTE;  in BM_Connection_Unidirectional()
85         packet->msg.data_length = data_size;  in BM_Connection_Unidirectional()
86         packet->payload.resize(data_size);  in BM_Connection_Unidirectional()
88         memset(&packet->payload[0], 0xff, data_size);  in BM_Connection_Unidirectional()
91         client->Write(std::move(packet));  in BM_Connection_Unidirectional()
124 …  client->SetReadCallback([&received_bytes](Connection*, std::unique_ptr<apacket> packet) -> bool {  in BM_Connection_Echo()  argument
125         received_bytes += packet->payload.size();  in BM_Connection_Echo()
129     static const auto handle_packet = [](Connection* connection, std::unique_ptr<apacket> packet) {  in BM_Connection_Echo()  argument
130         connection->Write(std::move(packet));  in BM_Connection_Echo()
133     server->SetReadCallback([](Connection* connection, std::unique_ptr<apacket> packet) -> bool {  in BM_Connection_Echo()  argument
135             auto raw_packet = packet.release();  in BM_Connection_Echo()
137                 std::unique_ptr<apacket> packet(raw_packet);  in BM_Connection_Echo()  local
138                 handle_packet(connection, std::move(packet));  in BM_Connection_Echo()
141             handle_packet(connection, std::move(packet));  in BM_Connection_Echo()
156         std::unique_ptr<apacket> packet = std::make_unique<apacket>();  in BM_Connection_Echo()  local
157         memset(&packet->msg, 0, sizeof(packet->msg));  in BM_Connection_Echo()
158         packet->msg.command = A_WRTE;  in BM_Connection_Echo()
159         packet->msg.data_length = data_size;  in BM_Connection_Echo()
160         packet->payload.resize(data_size);  in BM_Connection_Echo()
162         memset(&packet->payload[0], 0xff, data_size);  in BM_Connection_Echo()
165         client->Write(std::move(packet));  in BM_Connection_Echo()