491     p->msg.command = A_WRTE;  in remote_socket_enqueue()
510     p->msg.command = A_OKAY;  in remote_socket_ready()
520     p->msg.command = A_CLSE;  in remote_socket_shutdown()
571     p->msg.command = A_OPEN;  in connect_to_remote()
669     std::string_view command = full_service;  in parse_host_service()  local
671     auto consume = [&full_service, &serial, &command](size_t count) {  in parse_host_service()
672         CHECK_LE(count, command.size());  in parse_host_service()
674             CHECK_EQ(serial.data() + serial.size(), command.data());  in parse_host_service()
678         command.remove_prefix(count);  in parse_host_service()
682     auto finish = [out_serial, out_command, &serial, &command] {  in parse_host_service()
683         if (serial.empty() || command.empty()) {  in parse_host_service()
691         *out_command = command;  in parse_host_service()
698         if (command.starts_with(prefix)) {  in parse_host_service()
701             size_t offset = command.find_first_of(':');  in parse_host_service()
711     if (command.starts_with("tcp:") || command.starts_with("udp:")) {  in parse_host_service()
713         if (command.empty()) {  in parse_host_service()
717     if (command.starts_with("vsock:")) {  in parse_host_service()
719         size_t next_colon = command.find(':');  in parse_host_service()
727     if (command[0] == '[') {  in parse_host_service()
730         size_t ipv6_end = command.find_first_of(']');  in parse_host_service()
733             if (command.empty()) {  in parse_host_service()
736             } else if (command[0] != ':') {  in parse_host_service()
747         size_t offset = command.find_first_of(':');  in parse_host_service()
756     size_t next_colon = command.find_first_of(':');  in parse_host_service()
763     if (command.size() <= next_colon) {  in parse_host_service()
767     std::string_view port = command.substr(0, next_colon);  in parse_host_service()