forked from etr/libhttpserver
-
Notifications
You must be signed in to change notification settings - Fork 0
Expand file tree
/
Copy pathcomet_manager.hpp
More file actions
107 lines (82 loc) · 3.4 KB
/
comet_manager.hpp
File metadata and controls
107 lines (82 loc) · 3.4 KB
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
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
/*
This file is part of libhttpserver
Copyright (C) 2011, 2012, 2013, 2014 Sebastiano Merlino
This library is free software; you can redistribute it and/or
modify it under the terms of the GNU Lesser General Public
License as published by the Free Software Foundation; either
version 2.1 of the License, or (at your option) any later version.
This library is distributed in the hope that it will be useful,
but WITHOUT ANY WARRANTY; without even the implied warranty of
MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
Lesser General Public License for more details.
You should have received a copy of the GNU Lesser General Public
License along with this library; if not, write to the Free Software
Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301
USA
*/
#if !defined (_HTTPSERVER_HPP_INSIDE_) && !defined (HTTPSERVER_COMPILATION)
#error "Only <httpserver.hpp> or <httpserverpp> can be included directly."
#endif
#ifndef _COMET_MANAGER_HPP_
#define _COMET_MANAGER_HPP_
#include <pthread.h>
#include <vector>
#include <set>
#include <map>
#include <deque>
#include <string>
#include "http_utils.hpp"
namespace httpserver
{
class webserver;
namespace http
{
struct httpserver_ska;
};
namespace details
{
class comet_manager
{
private:
comet_manager();
~comet_manager();
void send_message_to_topic(const std::string& topic,
const std::string& message, const httpserver::http::http_utils::start_method_T& start_method
);
void send_message_to_consumer(const http::httpserver_ska& connection_id,
const std::string& message, bool to_lock,
const httpserver::http::http_utils::start_method_T& start_method
);
void register_to_topics(const std::vector<std::string>& topics,
const http::httpserver_ska& connection_id, int keepalive_secs,
std::string keepalive_msg, const httpserver::http::http_utils::start_method_T& start_method
);
size_t read_message(const http::httpserver_ska& connection_id,
std::string& message
);
size_t get_topic_consumers(const std::string& topic,
std::set<http::httpserver_ska>& consumers
);
bool pop_signaled(const http::httpserver_ska& consumer, const httpserver::http::http_utils::start_method_T& start_method);
void complete_request(const http::httpserver_ska& connection_id);
void comet_select(unsigned long long* timeout_secs,
unsigned long long* timeout_microsecs,
const httpserver::http::http_utils::start_method_T& start_method
);
comet_manager(const comet_manager&)
{
}
std::map<http::httpserver_ska, std::deque<std::string> > q_messages;
std::map<std::string, std::set<http::httpserver_ska> > q_waitings;
std::map<http::httpserver_ska, std::pair<pthread_mutex_t, pthread_cond_t> > q_blocks;
std::set<http::httpserver_ska> q_signal;
std::map<http::httpserver_ska, long> q_keepalives;
std::map<http::httpserver_ska, std::pair<int, std::string> > q_keepalives_mem;
pthread_rwlock_t comet_guard;
pthread_mutex_t cleanmux;
pthread_cond_t cleancond;
friend class httpserver::webserver;
};
} //details
} //httpserver
#endif //_COMET_MANAGER_HPP_