Lines Matching refs:asocket

53 static auto& local_socket_list = *new std::vector<asocket*>();
59 static auto& local_socket_closing_list = *new std::vector<asocket*>();
64 asocket* find_local_socket(unsigned local_id, unsigned peer_id) { in find_local_socket()
65 asocket* result = nullptr; in find_local_socket()
68 for (asocket* s : local_socket_list) { in find_local_socket()
81 void install_local_socket(asocket* s) { in install_local_socket()
94 void remove_socket(asocket* s) { in remove_socket()
97 list->erase(std::remove_if(list->begin(), list->end(), [s](asocket* x) { return x == s; }), in remove_socket()
108 for (asocket* s : local_socket_list) { in close_all_sockets()
122 static SocketFlushResult local_socket_flush_incoming(asocket* s) { in local_socket_flush_incoming()
176 static bool local_socket_flush_outgoing(asocket* s) { in local_socket_flush_outgoing()
252 static int local_socket_enqueue(asocket* s, apacket::payload_type data) { in local_socket_enqueue()
270 static void local_socket_ready(asocket* s) { in local_socket_ready()
328 static void local_socket_destroy(asocket* s) { in local_socket_destroy()
344 static void local_socket_close(asocket* s) { in local_socket_close()
383 asocket* s = reinterpret_cast<asocket*>(_s); in local_socket_event_func()
418 void local_socket_ack(asocket* s, std::optional<int32_t> acked_bytes) { in local_socket_ack()
444 asocket* create_local_socket(unique_fd ufd) { in create_local_socket()
446 asocket* s = new asocket(); in create_local_socket()
459 asocket* create_local_service_socket(std::string_view name, atransport* transport) { in create_local_service_socket()
461 if (asocket* s = daemon_service_to_socket(name, transport); s) { in create_local_service_socket()
471 asocket* s = create_local_socket(std::move(fd)); in create_local_service_socket()
487 static int remote_socket_enqueue(asocket* s, apacket::payload_type data) { in remote_socket_enqueue()
507 static void remote_socket_ready(asocket* s) { in remote_socket_ready()
516 static void remote_socket_shutdown(asocket* s) { in remote_socket_shutdown()
528 static void remote_socket_close(asocket* s) { in remote_socket_close()
544 asocket* create_remote_socket(unsigned id, atransport* t) { in create_remote_socket()
548 asocket* s = new asocket(); in create_remote_socket()
560 void connect_to_remote(asocket* s, std::string_view destination) { in connect_to_remote()
594 static void local_socket_ready_notify(asocket* s) { in local_socket_ready_notify()
605 static void local_socket_close_notify(asocket* s) { in local_socket_close_notify()
784 static int smart_socket_enqueue(asocket* s, apacket::payload_type data) { in smart_socket_enqueue()
852 asocket* s2; in smart_socket_enqueue()
947 static void smart_socket_ready(asocket* s) { in smart_socket_ready()
951 static void smart_socket_close(asocket* s) { in smart_socket_close()
961 static asocket* create_smart_socket(void) { in create_smart_socket()
963 asocket* s = new asocket(); in create_smart_socket()
973 void connect_to_smartsocket(asocket* s) { in connect_to_smartsocket()
975 asocket* ss = create_smart_socket(); in connect_to_smartsocket()
982 size_t asocket::get_max_payload() const { in get_max_payload()