blob: 154acdb3dd7695746110342edc7459c5ec9d7173 (
plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
|
#ifndef PIONIOPROCESSOR_H_VAITDNCN
#define PIONIOPROCESSOR_H_VAITDNCN
#include "uscxml/Interpreter.h"
#include "uscxml/Factory.h"
#include "uscxml/concurrency/DelayedEventQueue.h"
#include <pion/http/request_writer.hpp>
#include <pion/http/request_writer.hpp>
#include <pion/tcp/server.hpp>
namespace uscxml {
class PionIOServer : public pion::tcp::server {
public:
PionIOServer();
virtual ~PionIOServer();
DelayedEventQueue _eventQueue;
virtual void handle_connection(pion::tcp::connection_ptr& tcp_conn);
static PionIOServer* getInstance();
static PionIOServer* _instance;
pion::http::request_writer_ptr _writer;
pion::tcp::connection_ptr _conn;
};
class PionIOProcessor : public IOProcessor {
public:
PionIOProcessor();
virtual ~PionIOProcessor();
virtual IOProcessor* create(Interpreter* interpreter);
virtual void send(SendRequest& req);
virtual void invoke(InvokeRequest& req);
virtual void cancel(const std::string sendId);
protected:
Interpreter* _interpreter;
PionIOServer* _ioServer;
};
}
#endif /* end of include guard: PIONIOPROCESSOR_H_VAITDNCN */
|
