libretro/scummvm
1
0
Fork 0
mirror of https://github.com/libretro/scummvm.git synced 2025-01-13 13:10:53 +00:00
Code Issues Actions Packages Projects Releases Wiki Activity

FULLPIPE: More message handler-related functions

Browse Source
This commit is contained in:
Eugene Sandulenko 2013-07-22 23:38:11 +03:00
parent 9d83eb1aea
commit 4dc47c5c08
2 changed files with 144 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

136
engines/fullpipe/messagequeue.cpp
View File

@ -119,4 +119,140 @@ void updateMessageHandlerIndex(MessageHandler *msg, int offset) {
msg->index += offset;
}
void addMessageHandler(int (*callback)(ExCommand *), int16 id) {
if (getMessageHandlerById(id))
return;
MessageHandler *curItem = g_fullpipe->_messageHandlers;
if (!curItem)
return;
int index = 0;
for (MessageHandler *i = g_fullpipe->_messageHandlers->nextItem; i; i = i->nextItem) {
curItem = i;
index++;
}
allocMessageHandler(curItem, id, callback, index);
if (curItem)
updateMessageHandlerIndex(curItem->nextItem->nextItem, 1);
}
MessageHandler *getMessageHandlerById(int16 id) {
MessageHandler *curItem = g_fullpipe->_messageHandlers;
if (!curItem)
return 0;
while (id != curItem->id) {
curItem = curItem->nextItem;
if (!curItem)
return 0;
}
return curItem;
}
bool allocMessageHandler(MessageHandler *where, int16 id, int (*callback)(ExCommand *), int index) {
MessageHandler *msg = new MessageHandler;
if (where) {
msg->nextItem = where->nextItem;
where->nextItem = msg;
msg->id = id;
msg->callback = callback;
msg->index = index;
} else {
msg->nextItem = 0;
msg->id = id;
msg->callback = callback;
msg->index = 0;
g_fullpipe->_messageHandlers = msg;
}
return true;
}
int getMessageHandlersCount() {
int result;
MessageHandler *curItem = g_fullpipe->_messageHandlers;
for (result = 0; curItem; result++)
curItem = curItem->nextItem;
return result;
}
bool addMessageHandlerByIndex(int (*callback)(ExCommand *), int index, int16 id) {
if (getMessageHandlerById(id))
return false;
if (index) {
MessageHandler *curItem = g_fullpipe->_messageHandlers;
for (int i = index - 1; i > 0; i--)
if (curItem)
curItem = curItem->nextItem;
bool res = allocMessageHandler(curItem, id, callback, index);
if (res)
updateMessageHandlerIndex(curItem->nextItem->nextItem, 1);
return res;
} else {
MessageHandler *newItem = new MessageHandler;
newItem->nextItem = g_fullpipe->_messageHandlers;
newItem->id = id;
newItem->callback = callback;
newItem->index = 0;
updateMessageHandlerIndex(g_fullpipe->_messageHandlers, 1);
g_fullpipe->_messageHandlers = newItem;
return true;
}
}
bool insertMessageHandler(int (*callback)(ExCommand *), int index, int16 id) {
if (getMessageHandlerById(id))
return false;
MessageHandler *curItem = g_fullpipe->_messageHandlers;
for (int i = index; i > 0; i--)
if (curItem)
curItem = curItem->nextItem;
bool res = allocMessageHandler(curItem, id, callback, index + 1);
if (curItem)
updateMessageHandlerIndex(curItem->nextItem->nextItem, 1);
return res;
}
void clearMessageHandlers() {
MessageHandler *curItem;
MessageHandler *nextItem;
curItem = g_fullpipe->_messageHandlers;
if (curItem) {
do {
nextItem = curItem->nextItem;
delete curItem;
curItem = nextItem;
} while (nextItem);
g_fullpipe->_messageHandlers = 0;
}
}
} // End of namespace Fullpipe

8
engines/fullpipe/messagequeue.h
View File

@ -72,6 +72,14 @@ struct MessageHandler {
bool removeMessageHandler(int16 id, int pos);
void updateMessageHandlerIndex(MessageHandler *msg, int offset);
void addMessageHandler(int (*callback)(ExCommand *), int16 id);
MessageHandler *getMessageHandlerById(int16 id);
bool allocMessageHandler(MessageHandler *where, int16 id, int (*callback)(ExCommand *), int index);
int getMessageHandlersCount();
bool addMessageHandlerByIndex(int (*callback)(ExCommand *), int index, int16 id);
bool insertMessageHandler(int (*callback)(ExCommand *), int index, int16 id);
void clearMessageHandlers();
} // End of namespace Fullpipe