Fixed default message size.

This commit is contained in:
Martin Preuss
2023-09-16 15:48:03 +02:00
parent 8c60c3c8e4
commit 5f6581d126

View File

@@ -27,6 +27,8 @@
#include <unistd.h> #include <unistd.h>
#define UTILS_IPC_ENDPOINT_DEFAULT_MSGSIZE 4096
GWEN_MSG_ENDPOINT *Utils_SetupIpcEndpoint(GWEN_DB_NODE *dbArgs) GWEN_MSG_ENDPOINT *Utils_SetupIpcEndpoint(GWEN_DB_NODE *dbArgs)
@@ -45,6 +47,7 @@ GWEN_MSG_ENDPOINT *Utils_SetupIpcEndpoint(GWEN_DB_NODE *dbArgs)
DBG_ERROR(NULL, "Error creating endpoint TCPc"); DBG_ERROR(NULL, "Error creating endpoint TCPc");
return NULL; return NULL;
} }
GWEN_MsgEndpoint_SetDefaultMessageSize(epTcp, UTILS_IPC_ENDPOINT_DEFAULT_MSGSIZE);
rv=GWEN_TcpcEndpoint_StartConnect(epTcp); rv=GWEN_TcpcEndpoint_StartConnect(epTcp);
if (rv<0 && rv!=GWEN_ERROR_IN_PROGRESS) { if (rv<0 && rv!=GWEN_ERROR_IN_PROGRESS) {
DBG_ERROR(NULL, "Error connecting (%d)", rv); DBG_ERROR(NULL, "Error connecting (%d)", rv);
@@ -132,6 +135,9 @@ GWEN_MSG *Utils_WaitForSpecificIpcMessage(GWEN_MSG_ENDPOINT *epTcp,
DBG_INFO(NULL, "Received IPC result message"); DBG_INFO(NULL, "Received IPC result message");
return msg; return msg;
} }
else {
DBG_INFO(NULL, "Received unexpected message %d (%x)", code, code);
}
GWEN_Msg_free(msg); GWEN_Msg_free(msg);
} }
now=time(NULL); now=time(NULL);