Print done when done.

1 files changed, 166 insertions, 0 deletions

diff --git a/indra/newview/lleventpoll.cpp b/indra/newview/lleventpoll.cpp
new file mode 100644
index 0000000000..5e12916975
--- /dev/null
+++ b/indra/newview/lleventpoll.cpp
@@ -0,0 +1,166 @@
+/** 
+ * @file lleventpoll.cpp
+ * @brief Implementation of the LLEventPoll class.
+ *
+ * Copyright (c) 2006-$CurrentYear$, Linden Research, Inc.
+ * $License$
+ */
+
+#include "llviewerprecompiledheaders.h"
+
+#include "lleventpoll.h"
+
+#include "llhttpclient.h"
+#include "llhttpnode.h"
+#include "llsdserialize.h"
+
+
+
+class LLEventPoll::Impl : LLHTTPClient::Responder
+{
+public:
+	static Impl& start(
+		const std::string& pollURL, const LLHTTPNode& treeRoot)
+	{
+		Impl* i = new Impl(pollURL, treeRoot);
+		llinfos << "LLEventPoll::Impl::start <" << i->mCount << "> "
+			<< pollURL << llendl;
+		return *i;
+	}
+	
+	void stop()
+	{
+		llinfos << "LLEventPoll::Impl::stop <" << mCount << "> "
+			<< mPollURL << llendl;
+		// there should be a way to stop a LLHTTPClient request in progress
+		mDone = true;
+		mPtr = NULL;
+	}
+	
+private:
+	Impl(const std::string& pollURL, const LLHTTPNode& treeRoot)
+		: mPtr(NULL), mDone(false),
+		  mPollURL(pollURL), mTreeRoot(treeRoot),
+		  mCount(++sCount)
+	{
+		mPtr = this;
+		makeRequest();
+	}
+		
+	~Impl()
+	{
+		lldebugs << "LLEventPoll::Impl::~Impl <" << mCount << "> "
+			<< mPollURL << llendl;
+	}
+
+
+	void makeRequest()
+	{
+		LLSD request;
+		request["ack"] = mAcknowledge;
+		request["done"] = mDone;
+		
+		lldebugs << "LLEventPoll::Impl::makeRequest <" << mCount << "> ack = "
+			<< LLSDXMLStreamer(mAcknowledge) << llendl;
+		LLHTTPClient::post(mPollURL, request, mPtr);
+	}
+	
+	void handleMessage(const LLSD& content)
+	{
+		std::string message = content["message"];
+		if (message.empty())
+		{
+			llwarns << "LLEventPoll::Impl::handleMessage <" << mCount
+					<< "> empty message name" << llendl;
+			return;
+		}
+		
+		std::string path = "/message/" + message;
+		
+		LLSD context;
+		const LLHTTPNode* handler = mTreeRoot.traverse(path, context);
+		if (!handler)
+		{
+			llwarns << "LLEventPoll::Impl::handleMessage <" << mCount
+					<< "> no handler for " << path << llendl;
+			return;
+		}
+		LLPointer<LLSimpleResponse> responsep = LLSimpleResponse::create();
+		handler->post((LLHTTPNode::ResponsePtr)responsep, context, content["body"]);
+		
+		lldebugs << "LLEventPoll::Impl::handleMessage handled <" << mCount << "> "
+			<< message << ": " << *responsep << llendl;
+	}
+
+	virtual void error(U32 status, const std::string& reason)
+	{
+		lldebugs << "LLEventPoll::Impl::error <" << mCount << "> got "
+			<< status << ": " << reason
+			<< (mDone ? " -- done" : "") << llendl;
+
+		if (mDone) return;
+		
+		if (status == 404)
+		{
+			// the capability has been revoked
+			stop();
+			return;
+		}
+		
+		makeRequest();
+	}
+	
+	
+	virtual void result(const LLSD& content)
+	{
+		lldebugs << "LLEventPoll::Impl::result <" << mCount << ">"
+			<< (mDone ? " -- done" : "") << llendl;
+
+		if (mDone) return;
+
+		mAcknowledge = content["id"];
+		LLSD events = content["events"];
+		
+		lldebugs << "LLEventPoll::Impl::completed <" << mCount << "> ack =  "
+			<< LLSDXMLStreamer(mAcknowledge) << llendl;
+
+		LLSD::array_const_iterator i = events.beginArray();
+		LLSD::array_const_iterator end = events.endArray();
+		for (; i != end; ++i)
+		{
+			if (i->has("message"))
+			{
+				handleMessage(*i);
+			}
+		}
+		
+		makeRequest();
+	}
+
+private:
+	typedef LLHTTPClient::ResponderPtr Ptr;
+
+	Ptr		mPtr;
+	bool	mDone;
+
+	std::string			mPollURL;
+	const LLHTTPNode&	mTreeRoot;
+	
+	LLSD	mAcknowledge;
+	
+	// these are only here for debugging so we can see which poller is which
+	static int sCount;
+	int mCount;
+};
+
+int LLEventPoll::Impl::sCount = 0;
+
+
+LLEventPoll::LLEventPoll(const std::string& pollURL, const LLHTTPNode& treeRoot)
+	: impl(Impl::start(pollURL, treeRoot))
+	{ }
+
+LLEventPoll::~LLEventPoll()
+{
+	impl.stop();
+}