moving trunk for module inkscape

(bzr r1)

1 files changed, 64 insertions, 0 deletions

diff --git a/src/jabber_whiteboard/message-aggregator.cpp b/src/jabber_whiteboard/message-aggregator.cpp
new file mode 100644
index 000000000..2077dcc6d
--- /dev/null
+++ b/src/jabber_whiteboard/message-aggregator.cpp
@@ -0,0 +1,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 :