#ifndef MSP_NET_COMMUNICATOR_H_
#define MSP_NET_COMMUNICATOR_H_
+#include <msp/core/except.h>
+#include <sigc++/signal.h>
#include "protocol.h"
-#include "streamsocket.h"
namespace Msp {
namespace Net {
-class sequence_error: public std::logic_error
+class StreamSocket;
+
+class sequence_error: public invalid_state
+{
+public:
+ sequence_error(const std::string &w): invalid_state(w) { }
+};
+
+class incompatible_protocol: public std::runtime_error
{
public:
- sequence_error(const std::string &w): std::logic_error(w) { }
- virtual ~sequence_error() throw() { }
+ incompatible_protocol(const std::string &w): std::runtime_error(w) { }
};
const Protocol &protocol;
ReceiverBase &receiver;
int handshake_status;
- unsigned buf_size;
+ std::size_t buf_size;
char *in_buf;
char *in_begin;
char *in_end;
bool is_handshake_done() const { return handshake_status==2; }
template<typename P>
- void send(const P &pkt)
- {
- if(!good)
- throw sequence_error("connection aborted");
- if(handshake_status!=2)
- throw sequence_error("handshaking not done");
- unsigned size = protocol.assemble(pkt, out_buf, buf_size);
- try
- {
- socket.write(out_buf, size);
- }
- catch(const std::exception &e)
- {
- good = false;
- if(signal_error.empty())
- throw;
- signal_error.emit(e);
- }
- }
+ void send(const P &);
private:
+ void send_data(std::size_t);
+
void data_available();
bool receive_packet(const Protocol &, ReceiverBase &);
void send_handshake();
};
+template<typename P>
+void Communicator::send(const P &pkt)
+{
+ send_data(protocol.serialize(pkt, out_buf, buf_size));
+}
+
} // namespace Net
} // namespace Msp