No OneTemporary
Actions

Authored By

Unknown

Size

1009 B

Referenced Files

None

Subscribers

None

View Options

	diff --git a/util/message-queue.cpp b/util/message-queue.cpp
	index 1543acb5..8f32624c 100644
	--- a/util/message-queue.cpp
	+++ b/util/message-queue.cpp
	@@ -1,34 +1,36 @@
	#include <queue>
	#include <pthread.h>
	#include <string>
	#include "message-queue.h"

	MessageQueue::MessageQueue(){
	pthread_mutex_init(&lock, NULL);
	}

	void MessageQueue::add(const std::string & str){
	pthread_mutex_lock(&lock);
	messages.push(str);
	pthread_mutex_unlock(&lock);
	}

	bool MessageQueue::hasAny(){
	bool any = false;
	pthread_mutex_lock(&lock);
	- any = messages.size() == 0;
	+ any = messages.size() > 0;
	pthread_mutex_unlock(&lock);
	return any;
	}

	std::string MessageQueue::get(){
	std::string str;
	pthread_mutex_lock(&lock);
	- str = messages.front();
	- messages.pop();
	+ if (messages.size() > 0){
	+ str = messages.front();
	+ messages.pop();
	+ }
	pthread_mutex_unlock(&lock);
	return str;
	}

	MessageQueue::~MessageQueue(){
	}