Lines Matching refs:asocket
50 static auto& local_socket_list = *new std::vector<asocket*>();
56 static auto& local_socket_closing_list = *new std::vector<asocket*>();
61 asocket* find_local_socket(unsigned local_id, unsigned peer_id) { in find_local_socket()
62 asocket* result = nullptr; in find_local_socket()
65 for (asocket* s : local_socket_list) { in find_local_socket()
78 void install_local_socket(asocket* s) { in install_local_socket()
91 void remove_socket(asocket* s) { in remove_socket()
94 list->erase(std::remove_if(list->begin(), list->end(), [s](asocket* x) { return x == s; }), in remove_socket()
105 for (asocket* s : local_socket_list) { in close_all_sockets()
119 static SocketFlushResult local_socket_flush_incoming(asocket* s) { in local_socket_flush_incoming()
151 static bool local_socket_flush_outgoing(asocket* s) { in local_socket_flush_outgoing()
220 static int local_socket_enqueue(asocket* s, apacket::payload_type data) { in local_socket_enqueue()
238 static void local_socket_ready(asocket* s) { in local_socket_ready()
296 static void local_socket_destroy(asocket* s) { in local_socket_destroy()
312 static void local_socket_close(asocket* s) { in local_socket_close()
351 asocket* s = reinterpret_cast<asocket*>(_s); in local_socket_event_func()
387 asocket* create_local_socket(unique_fd ufd) { in create_local_socket()
389 asocket* s = new asocket(); in create_local_socket()
402 asocket* create_local_service_socket(std::string_view name, atransport* transport) { in create_local_service_socket()
404 if (asocket* s = daemon_service_to_socket(name); s) { in create_local_service_socket()
414 asocket* s = create_local_socket(std::move(fd)); in create_local_service_socket()
429 static int remote_socket_enqueue(asocket* s, apacket::payload_type data) { in remote_socket_enqueue()
449 static void remote_socket_ready(asocket* s) { in remote_socket_ready()
458 static void remote_socket_shutdown(asocket* s) { in remote_socket_shutdown()
470 static void remote_socket_close(asocket* s) { in remote_socket_close()
486 asocket* create_remote_socket(unsigned id, atransport* t) { in create_remote_socket()
490 asocket* s = new asocket(); in create_remote_socket()
502 void connect_to_remote(asocket* s, std::string_view destination) { in connect_to_remote()
524 static void local_socket_ready_notify(asocket* s) { in local_socket_ready_notify()
535 static void local_socket_close_notify(asocket* s) { in local_socket_close_notify()
717 static int smart_socket_enqueue(asocket* s, apacket::payload_type data) { in smart_socket_enqueue()
784 asocket* s2; in smart_socket_enqueue()
888 static void smart_socket_ready(asocket* s) { in smart_socket_ready()
892 static void smart_socket_close(asocket* s) { in smart_socket_close()
902 static asocket* create_smart_socket(void) { in create_smart_socket()
904 asocket* s = new asocket(); in create_smart_socket()
914 void connect_to_smartsocket(asocket* s) { in connect_to_smartsocket()
916 asocket* ss = create_smart_socket(); in connect_to_smartsocket()
922 size_t asocket::get_max_payload() const { in get_max_payload()