summaryrefslogtreecommitdiff
path: root/src/client/requestbroker/RequestBroker.cpp
diff options
context:
space:
mode:
Diffstat (limited to 'src/client/requestbroker/RequestBroker.cpp')
-rw-r--r--src/client/requestbroker/RequestBroker.cpp8
1 files changed, 5 insertions, 3 deletions
diff --git a/src/client/requestbroker/RequestBroker.cpp b/src/client/requestbroker/RequestBroker.cpp
index 21194ce..1516b26 100644
--- a/src/client/requestbroker/RequestBroker.cpp
+++ b/src/client/requestbroker/RequestBroker.cpp
@@ -114,10 +114,11 @@ void RequestBroker::RetrieveAvatar(std::string username, int width, int height,
RetrieveImage(urlStream.str(), width, height, tListener);
}
-void RequestBroker::Start(Request * request, RequestListener * tListener)
+void RequestBroker::Start(Request * request, RequestListener * tListener, int identifier)
{
ListenerHandle handle = AttachRequestListener(tListener);
+ request->Identifier = identifier;
request->Listener = handle;
pthread_mutex_lock(&requestQueueMutex);
requestQueue.push_back(request);
@@ -152,7 +153,7 @@ void RequestBroker::FlushThumbQueue()
{
if(CheckRequestListener(completeQueue.front()->Listener))
{
- completeQueue.front()->Listener.second->OnResponseReady(completeQueue.front()->ResultObject);
+ completeQueue.front()->Listener.second->OnResponseReady(completeQueue.front()->ResultObject, completeQueue.front()->Identifier);
}
else
{
@@ -288,11 +289,12 @@ void RequestBroker::DetachRequestListener(RequestListener * tListener)
pthread_mutex_unlock(&listenersMutex);
}
-RequestBroker::Request::Request(RequestType type, ListenerHandle listener)
+RequestBroker::Request::Request(RequestType type, ListenerHandle listener, int identifier)
{
Type = type;
Listener = listener;
ResultObject = NULL;
+ Identifier = identifier;
}
RequestBroker::Request::~Request()
{