diff -r 240620f46dd7 -r 613998625a3c project_files/frontlib/ipc/gameconn.c --- a/project_files/frontlib/ipc/gameconn.c Fri Jun 15 19:57:25 2012 +0200 +++ b/project_files/frontlib/ipc/gameconn.c Tue Jun 19 21:17:05 2012 +0200 @@ -1,5 +1,5 @@ #include "gameconn.h" -#include "ipcconn.h" +#include "ipcbase.h" #include "ipcprotocol.h" #include "../util/logging.h" #include "../util/util.h" @@ -15,7 +15,7 @@ } gameconn_state; struct _flib_gameconn { - flib_ipcconn *connection; + flib_ipcbase *ipcBase; flib_vector *configBuffer; flib_vector *demoBuffer; char *playerName; @@ -38,8 +38,8 @@ void (*onGameRecordedCb)(void *context, const uint8_t *record, int size, bool isSavegame); void *onGameRecordedCtx; - void (*onNetMessageCb)(void *context, const uint8_t *em, int size); - void *onNetMessageCtx; + void (*onEngineMessageCb)(void *context, const uint8_t *em, int size); + void *onEngineMessageCtx; bool running; bool destroyRequested; @@ -52,7 +52,7 @@ } static void defaultCallback_onChat(void* context, const char *msg, bool teamchat) {} static void defaultCallback_onGameRecorded(void *context, const uint8_t *record, int size, bool isSavegame) {} -static void defaultCallback_onNetMessage(void *context, const uint8_t *em, int size) {} +static void defaultCallback_onEngineMessage(void *context, const uint8_t *em, int size) {} static void clearCallbacks(flib_gameconn *conn) { conn->onConnectCb = &defaultCallback_onConnect; @@ -60,17 +60,17 @@ conn->onErrorMessageCb = &defaultCallback_onErrorMessage; conn->onChatCb = &defaultCallback_onChat; conn->onGameRecordedCb = &defaultCallback_onGameRecorded; - conn->onNetMessageCb = &defaultCallback_onNetMessage; + conn->onEngineMessageCb = &defaultCallback_onEngineMessage; } static flib_gameconn *flib_gameconn_create_partial(bool record, const char *playerName, bool netGame) { flib_gameconn *result = NULL; flib_gameconn *tempConn = flib_calloc(1, sizeof(flib_gameconn)); if(tempConn) { - tempConn->connection = flib_ipcconn_create(); + tempConn->ipcBase = flib_ipcbase_create(); tempConn->configBuffer = flib_vector_create(); tempConn->playerName = flib_strdupnull(playerName); - if(tempConn->connection && tempConn->configBuffer && tempConn->playerName) { + if(tempConn->ipcBase && tempConn->configBuffer && tempConn->playerName) { if(record) { tempConn->demoBuffer = flib_vector_create(); } @@ -135,7 +135,7 @@ clearCallbacks(conn); conn->destroyRequested = true; } else { - flib_ipcconn_destroy(conn->connection); + flib_ipcbase_destroy(conn->ipcBase); flib_vector_destroy(conn->configBuffer); flib_vector_destroy(conn->demoBuffer); free(conn->playerName); @@ -149,7 +149,7 @@ flib_log_e("null parameter in flib_gameconn_getport"); return 0; } else { - return flib_ipcconn_port(conn->connection); + return flib_ipcbase_port(conn->ipcBase); } } @@ -201,7 +201,7 @@ int result = -1; if(!conn || (!data && len>0)) { flib_log_e("null parameter in flib_gameconn_send_enginemsg"); - } else if(!flib_ipcconn_send_raw(conn->connection, data, len)) { + } else if(!flib_ipcbase_send_raw(conn->ipcBase, data, len)) { demo_append(conn, data, len); result = 0; } @@ -217,7 +217,7 @@ int size = snprintf((char*)converted+1, 256, "s%c%s", (char)msgtype, msg); if(size>0) { converted[0] = size>255 ? 255 : size; - if(!flib_ipcconn_send_raw(conn->connection, converted, converted[0]+1)) { + if(!flib_ipcbase_send_raw(conn->ipcBase, converted, converted[0]+1)) { demo_append(conn, converted, converted[0]+1); result = 0; } @@ -233,7 +233,7 @@ flib_log_e("null parameter in flib_gameconn_send_chatmsg"); } else if(format_chatmessage(converted, playername, msg)) { flib_log_e("Error formatting message in flib_gameconn_send_chatmsg"); - } else if(!flib_ipcconn_send_raw(conn->connection, converted, converted[0]+1)) { + } else if(!flib_ipcbase_send_raw(conn->ipcBase, converted, converted[0]+1)) { demo_append(conn, converted, converted[0]+1); result = 0; } @@ -285,23 +285,23 @@ } } -void flib_gameconn_onNetMessage(flib_gameconn *conn, void (*callback)(void *context, const uint8_t *em, int size), void* context) { +void flib_gameconn_onEngineMessage(flib_gameconn *conn, void (*callback)(void *context, const uint8_t *em, int size), void* context) { if(!conn) { - flib_log_e("null parameter in flib_gameconn_onNetMessage"); + flib_log_e("null parameter in flib_gameconn_onEngineMessage"); } else { - conn->onNetMessageCb = callback ? callback : &defaultCallback_onNetMessage; - conn->onNetMessageCtx = context; + conn->onEngineMessageCb = callback ? callback : &defaultCallback_onEngineMessage; + conn->onEngineMessageCtx = context; } } static void flib_gameconn_wrappedtick(flib_gameconn *conn) { if(conn->state == AWAIT_CONNECTION) { - flib_ipcconn_accept(conn->connection); - switch(flib_ipcconn_state(conn->connection)) { + flib_ipcbase_accept(conn->ipcBase); + switch(flib_ipcbase_state(conn->ipcBase)) { case IPC_CONNECTED: { flib_constbuffer configBuffer = flib_vector_as_constbuffer(conn->configBuffer); - if(flib_ipcconn_send_raw(conn->connection, configBuffer.data, configBuffer.size)) { + if(flib_ipcbase_send_raw(conn->ipcBase, configBuffer.data, configBuffer.size)) { conn->state = FINISHED; conn->onDisconnectCb(conn->onDisconnectCtx, GAME_END_ERROR); return; @@ -327,7 +327,7 @@ if(conn->state == CONNECTED) { uint8_t msgbuffer[257]; int len; - while(!conn->destroyRequested && (len = flib_ipcconn_recv_message(conn->connection, msgbuffer))>=0) { + while(!conn->destroyRequested && (len = flib_ipcbase_recv_message(conn->ipcBase, msgbuffer))>=0) { if(len<2) { flib_log_w("Received short message from IPC (<2 bytes)"); continue; @@ -383,13 +383,13 @@ default: // Engine message demo_append(conn, msgbuffer, len); - conn->onNetMessageCb(conn->onNetMessageCtx, msgbuffer, len); + conn->onEngineMessageCb(conn->onEngineMessageCtx, msgbuffer, len); break; } } } - if(flib_ipcconn_state(conn->connection) == IPC_NOT_CONNECTED) { + if(flib_ipcbase_state(conn->ipcBase) == IPC_NOT_CONNECTED) { conn->state = FINISHED; conn->onDisconnectCb(conn->onDisconnectCtx, GAME_END_ERROR); }