index 89c20d66f281329cf3601f17e530d9d484b763ec..b56c1453c57dee199cecc0a24ea3891f60f2d5bc 100644 (file)
namespace Whiteboard {
-MessageQueue::MessageQueue(SessionManager* sm) : _sm(sm)
-{
-
-}
-
-MessageQueue::~MessageQueue()
-{
-
-}
+//###################################
+//# MESSAGE QUEUE
+//###################################
MessageNode*
MessageQueue::first()
{
- return this->_queue.front();
+ return _queue.front();
}
void
MessageQueue::popFront()
{
- this->_queue.pop_front();
-// g_log(NULL, G_LOG_LEVEL_DEBUG, "Removed element, queue size (for %s): %u", lm_connection_get_jid(this->_sm->session_data->connection), this->_queue.size());
+ _queue.pop_front();
+ //g_log(NULL, G_LOG_LEVEL_DEBUG,
+ // "Removed element, queue size (for %s): %u",
+ //lm_connection_get_jid(this->_sm->session_data->connection), this->_queue.size());
}
unsigned int
MessageQueue::size()
{
- return this->_queue.size();
+ return _queue.size();
}
bool
MessageQueue::empty()
{
- return this->_queue.empty();
+ return _queue.empty();
}
void
MessageQueue::clear()
{
- this->_queue.clear();
+ _queue.clear();
}
-ReceiveMessageQueue::ReceiveMessageQueue(SessionManager* sm) : MessageQueue(sm), _latest(0)
-{
-}
+//###################################
+//# RECEIVE MESSAGE QUEUE
+//###################################
void
ReceiveMessageQueue::insert(MessageNode* msg)
{
- // Check to see if the incoming message has a sequence number
- // lower than the sequence number of the latest message processed
- // by this message's sender. If it does, drop the message and produce
- // a warning.
- if (msg->sequence() < this->_latest) {
- g_warning("Received late message (message sequence number is %u, but latest processed message had sequence number %u). Discarding message; session may be desynchronized.", msg->sequence(), this->_latest);
- return;
- }
-
- // Otherwise, it is safe to insert this message.
-// Inkscape::GC::anchor(msg);
- this->_queue.push_back(msg);
- SP_DT_MSGSTACK(this->_sm->desktop())->flashF(Inkscape::NORMAL_MESSAGE,
- ngettext("%u change in receive queue.",
- "%u changes in receive queue.",
- this->_queue.size()),
- this->_queue.size());
-// g_log(NULL, G_LOG_LEVEL_DEBUG, "Receive queue size (for %s): %u", lm_connection_get_jid(this->_sm->session_data->connection), this->_queue.size());
+ // Check to see if the incoming message has a sequence number
+ // lower than the sequence number of the latest message processed
+ // by this message's sender. If it does, drop the message and produce
+ // a warning.
+ if (msg->sequence() < _latest) {
+ g_warning("Received late message (message sequence number is %u, but latest processed message had sequence number %u). Discarding message; session may be desynchronized.", msg->sequence(), this->_latest);
+ return;
+ }
+
+ // Otherwise, it is safe to insert this message.
+ //Inkscape::GC::anchor(msg);
+ _queue.push_back(msg);
+ /*
+ SP_DT_MSGSTACK(_sm->getDesktop())->flashF(
+ Inkscape::NORMAL_MESSAGE,
+ _("%u changes queued in receive queue."),
+ _queue.size());
+ */
+ //g_log(NULL, G_LOG_LEVEL_DEBUG, "Receive queue size (for %s): %u",
+ // lm_connection_get_jid(this->_sm->session_data->connection), this->_queue.size());
}
void
ReceiveMessageQueue::insertDeferred(MessageNode* msg)
{
- this->_deferred.push_back(msg);
+ _deferred.push_back(msg);
}
void
ReceiveMessageQueue::setLatestProcessedPacket(unsigned int seq)
{
- this->_latest = seq;
+ _latest = seq;
}
-SendMessageQueue::SendMessageQueue(SessionManager* sm) : MessageQueue(sm)
-{
-
-}
+//###################################
+//# SEND MESSAGE QUEUE
+//###################################
void
SendMessageQueue::insert(MessageNode* msg)
{
-// Inkscape::GC::anchor(msg);
- this->_queue.push_back(msg);
- SP_DT_MSGSTACK(this->_sm->desktop())->flashF(Inkscape::NORMAL_MESSAGE,
- ngettext("%u change in send queue.",
- "%u changes in send queue.",
- this->_queue.size()),
- this->_queue.size());
-// g_log(NULL, G_LOG_LEVEL_DEBUG, "Send queue size (for %s): %u", lm_connection_get_jid(this->_sm->session_data->connection), this->_queue.size());
+ //Inkscape::GC::anchor(msg);
+ _queue.push_back(msg);
+ /*
+ SP_DT_MSGSTACK(_sm->getDesktop())->flashF(
+ Inkscape::NORMAL_MESSAGE,
+ _("%u changes queued in send queue."),
+ _queue.size());
+ */
+ //g_log(NULL, G_LOG_LEVEL_DEBUG, "Send queue size (for %s): %u",
+ // lm_connection_get_jid(this->_sm->session_data->connection),
+ //this->_queue.size());
}
-}
+} // namespace Whiteboard
-}
+} // namespace Inkscape
/*
Local Variables:
mode:c++
c-file-style:"stroustrup"
- c-file-offsets:((innamespace . 0)(inline-open . 0)(case-label . +))
+ c-file-offsets:((innamespace . 0)(inline-open . 0))
indent-tabs-mode:nil
fill-column:99
End:
*/
-// vim: filetype=cpp:expandtab:shiftwidth=4:tabstop=8:softtabstop=4:encoding=utf-8:textwidth=99 :
+// vim: filetype=c++:expandtab:shiftwidth=4:tabstop=8:softtabstop=4 :