outgoing_message.h

// Copyright Maciej Sobczak 2008-2022.
// This file is part of YAMI4.
// See the package-level LICENSE.txt file.
 
#ifndef YAMICPP_OUTGOING_MESSAGE_H_INCLUDED
#define YAMICPP_OUTGOING_MESSAGE_H_INCLUDED
 
#include "message_state.h"
#include <yami4-core/dll.h>
#include <cstddef>
#include <string>
#include <vector>
 
namespace yami
{
 
namespace details
{
struct outgoing_message_info;
class outgoing_message_manager;
} // namespace details
 
class parameters;
 
class DLL outgoing_message
{
public:
 
    typedef long long outgoing_message_id;
 
    outgoing_message();
 
    ~outgoing_message();
 
    void reset(details::outgoing_message_manager & manager,
        details::outgoing_message_info & info);
    
    void disown_info_object();
 
    message_state get_state() const;
 
    message_state get_state(std::size_t & sent_bytes,
        std::size_t & total_byte_count) const;
 
    void wait_for_transmission() const;
 
    bool wait_for_transmission(std::size_t relative_timeout) const;
 
    void wait_for_completion() const;
 
    bool wait_for_completion(std::size_t relative_timeout) const;
 
    const parameters & get_header() const;
    
    const parameters & get_reply() const;
 
    const std::vector<char> & get_raw_reply() const;
 
    parameters * extract_reply();
 
    const std::string & get_exception_msg() const;
    
    outgoing_message_id get_message_id() const;
 
private:
    outgoing_message(const outgoing_message &);
    void operator=(const outgoing_message &);
 
    void clean();
 
    details::outgoing_message_manager * manager_;
    details::outgoing_message_info * info_;
    bool owner_of_info_;
};
 
} // namespace yami
 
#endif // YAMICPP_OUTGOING_MESSAGE_H_INCLUDED