Method execute

library/RemoteClient.cpp:371–467

}

command_result RemoteFunctionBase::execute(color_ostream &out,
                                           const message_type *input, message_type *output)
{
    if (!isValid())
    {
        out.printerr("Calling an unbound RPC function {}:{}.\n",
                     this->plugin, this->name);
        return CR_NOT_IMPLEMENTED;
    }

    if (!p_client->socket->IsSocketValid())
    {
        out.printerr("In call to {}:{}: invalid socket.\n",
                     this->plugin, this->name);
        return CR_LINK_FAILURE;
    }

    int send_size = input->ByteSize();

    if (send_size > RPCMessageHeader::MAX_MESSAGE_SIZE)
    {
        out.printerr("In call to {}:{}: message too large: {}.\n",
                     this->plugin, this->name, send_size);
        return CR_LINK_FAILURE;
    }

    if (!sendRemoteMessage(p_client->socket, id, input, true))
    {
        out.printerr("In call to {}:{}: I/O error in send.\n",
                     this->plugin, this->name);
        return CR_LINK_FAILURE;
    }

    color_ostream_proxy text_decoder(out);
    CoreTextNotification text_data;

    output->Clear();

    for (;;) {
        RPCMessageHeader header;

        if (!readFullBuffer(p_client->socket, &header, sizeof(header)))
        {
            out.printerr("In call to {}:{}: I/O error in receive header.\n",
                         this->plugin, this->name);
            return CR_LINK_FAILURE;
        }

        //out.print("Received %d:%d\n", header.id, header.size);

        if ((DFHack::DFHackReplyCode)header.id == RPC_REPLY_FAIL)
            return header.size == CR_OK ? CR_FAILURE : command_result(header.size);

        if (header.size < 0 || header.size > RPCMessageHeader::MAX_MESSAGE_SIZE)
        {
            out.printerr("In call to {}:{}: invalid received size {}.\n",
                         this->plugin, this->name, header.size);
            return CR_LINK_FAILURE;