blob: 2077dcc6dc2436617567cd0cbd65174aa84897e3 (
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
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
|
/**
* Aggregates individual serialized XML::Events into larger packages
* for more efficient delivery
*
* Authors:
* David Yip <yipdw@rose-hulman.edu>
*
* Copyright (c) 2005 Authors
*
* Released under GNU GPL, read the file 'COPYING' for more information
*/
#include <glibmm.h>
#include "jabber_whiteboard/message-aggregator.h"
namespace Inkscape {
namespace Whiteboard {
bool
MessageAggregator::addOne(Glib::ustring const& msg, Glib::ustring& buf)
{
// 1. If msg.bytes() > maximum size and the buffer is clear,
// then we have to send an oversize packet --
// we won't be able to deliver the message any other way.
// Add it to the buffer and return true. Any further attempt to
// aggregate a message will be handled by condition #2.
if (msg.bytes() > MessageAggregator::MAX_SIZE && buf.empty()) {
buf += msg;
return true;
}
// 2. If msg.bytes() + buf.bytes() > maximum size, return false.
// The user of this class is responsible for retrieving the aggregated message,
// doing something with it, clearing the buffer, and trying again.
// Otherwise, append the message to the buffer and return true.
if (msg.bytes() + buf.bytes() > MessageAggregator::MAX_SIZE) {
return false;
} else {
buf += msg;
return true;
}
}
bool
MessageAggregator::addOne(Glib::ustring const& msg)
{
return this->addOne(msg, this->_buf);
}
}
}
/*
Local Variables:
mode:c++
c-file-style:"stroustrup"
c-file-offsets:((innamespace . 0)(inline-open . 0)(case-label . +))
indent-tabs-mode:nil
fill-column:99
End:
*/
// vim: filetype=cpp:expandtab:shiftwidth=4:tabstop=8:softtabstop=4:encoding=utf-8:textwidth=99 :
|
