FULLPIPE: Implement MessageQueue::sendNextCommand()

2 files changed, 31 insertions, 1 deletions

diff --git a/engines/fullpipe/messages.cpp b/engines/fullpipe/messages.cpp
index e7b317116c..9260da6438 100644
--- a/engines/fullpipe/messages.cpp
+++ b/engines/fullpipe/messages.cpp
@@ -98,6 +98,12 @@ bool ExCommand::handleMessage() {
 	return (cnt > 0);
 }
 
+void ExCommand::sendMessage() {
+	g_fullpipe->_exCommandList.push_back(this);
+
+	processMessages();
+}
+
 Message::Message() {
 	_messageKind = 0;
 	_parentId = 0;
@@ -240,8 +246,29 @@ void MessageQueue::update() {
 	}
 }
 
+void MessageQueue::messageQueueCallback1(int par) {
+	warning("STUB: MessageQueue::messageQueueCallback1()");
+}
+
 void MessageQueue::sendNextCommand() {
-	warning("STUB: MessageQueue::sendNextCommand()");
+	if (_exCommands.size()) {
+		if (!(_flags & 4) && (_flags & 1)) {
+			messageQueueCallback1(16);
+		}
+		ExCommand *ex = (ExCommand *)_exCommands.front();
+		_exCommands.remove_at(0);
+
+		ex->handleMessage();
+		_counter++;
+		ex->_parId = _id;
+		ex->_excFlags |= (ex->_field_24 == 0 ? 1 : 0) | (ex->_field_3C != 0 ? 2 : 0);
+
+		_flags |= 4;
+		ex->sendMessage();
+	} else if (_counter <= 0) {
+		_isFinished = 1;
+		finish();
+	}
 }
 
 void MessageQueue::finish() {
diff --git a/engines/fullpipe/messages.h b/engines/fullpipe/messages.h
index 9a2f0134c9..da91fd2189 100644
--- a/engines/fullpipe/messages.h
+++ b/engines/fullpipe/messages.h
@@ -71,6 +71,7 @@ class ExCommand : public Message {
 	virtual bool load(MfcArchive &file);
 
 	bool handleMessage();
+	void sendMessage();
 };
 
 class CObjstateCommand : public CObject {
@@ -114,6 +115,8 @@ class MessageQueue : public CObject {
 	void update();
 	void sendNextCommand();
 	void finish();
+
+	void messageQueueCallback1(int par);
 };
 
 class GlobalMessageQueueList : public CPtrList {