#include <ipcmessages.h> // AxWin3 common
#include "include/internal.h"
#include "include/ipc.h"
+#include <errno.h>
+
+#define assert(cnd) do{if(!(cnd)){_SysDebug("Assertion failed: %s", #cnd);}}while(0)
+
+#define STATICBUF_SIZE 0x1000
// === CONSTANTS ===
enum eConnectionType
{
CONNTYPE_NONE,
CONNTYPE_SENDMESSAGE,
+ CONNTYPE_IPCPIPE,
CONNTYPE_UDP,
CONNTYPE_TCP
};
// === CODE ===
void AxWin3_Connect(const char *ServerDesc)
{
- _SysDebug("ServerDesc (argument) = %s", ServerDesc);
if( !ServerDesc ) {
ServerDesc = gsAxWin3_int_ServerDesc;
}
}
break;
case 'u':
- while(*ServerDesc && *ServerDesc != ':') ServerDesc ++;
- ServerDesc ++;
+ assert( strncmp(ServerDesc, "udp:", 4) == 0 );
+ ServerDesc += 4;
+ _SysDebug("TODO: UDP connection to '%s'", ServerDesc);
// TODO: Open socket and create UDP header
break;
case 't':
- while(*ServerDesc && *ServerDesc != ':') ServerDesc ++;
- ServerDesc ++;
+ assert( strncmp(ServerDesc, "tcp:", 4) == 0 );
+ ServerDesc += 4;
+ _SysDebug("TODO: TCP connection to '%s'", ServerDesc);
// TODO: Open socket
break;
+ case 'p':
+ assert( strncmp(ServerDesc, "pipe:", 5) == 0 );
+ ServerDesc += 5;
+ giConnectionType = CONNTYPE_IPCPIPE;
+ giConnectionNum = _SysOpen(ServerDesc, OPENFLAG_READ|OPENFLAG_WRITE);
+ if( giConnectionNum == -1 ) {
+ _SysDebug("Cannot open IPC Pipe '%s'", ServerDesc);
+ exit(-1);
+ }
+ break;
+ default:
+ _SysDebug("Unknown server desc format '%s'", ServerDesc);
+ exit(-1);
+ break;
}
}
char tmpbuf[giAxWin3_int_UDPHeaderLen + size];
memcpy(tmpbuf, gaAxWin3_int_UDPHeader, giAxWin3_int_UDPHeaderLen);
memcpy(tmpbuf + giAxWin3_int_UDPHeaderLen, Msg, size);
- _SysWrite(giConnectionNum, tmpbuf, sizeof(tmpbuf));
+ size_t rv = _SysWrite(giConnectionNum, tmpbuf, sizeof(tmpbuf));
+ if( rv == -1 ) {
+ _SysDebug("AxWin3 SendIPCMessage: UDP Write Failed %s", strerror(errno));
+ exit(1);
+ }
}
break;
- case CONNTYPE_TCP:
- _SysWrite(giConnectionNum, Msg, size);
+ case CONNTYPE_IPCPIPE:
+ case CONNTYPE_TCP: {
+ size_t rv = _SysWrite(giConnectionNum, Msg, size);
+ if( rv != size ) {
+ _SysDebug("AxWin3 SendIPCMessage: Write Failed %s - sent %i want %i",
+ strerror(errno), rv, size);
+ exit(1);
+ }
+ }
break;
default:
break;
int len;
tAxWin_IPCMessage *ret = NULL;
int tid;
+ fd_set local_set;
+
+ if(!fds)
+ fds = &local_set;
+
+ if( giConnectionType != CONNTYPE_SENDMESSAGE )
+ {
+ if(nFD <= giConnectionNum)
+ nFD = giConnectionNum+1;
+ FD_SET(giConnectionNum, fds);
+ }
_SysSelect(nFD, fds, NULL, NULL, NULL, THREAD_EVENT_IPCMSG);
break;
}
- if( giConnectionType == CONNTYPE_TCP || giConnectionType == CONNTYPE_UDP )
+ if( giConnectionType != CONNTYPE_SENDMESSAGE )
{
- // Check fds
+ if( FD_ISSET(giConnectionNum, fds) )
+ {
+ char tmpbuf[STATICBUF_SIZE];
+ char *data = tmpbuf;
+ size_t len = _SysRead(giConnectionNum, tmpbuf, sizeof(tmpbuf));
+
+ if( giConnectionType == CONNTYPE_UDP )
+ {
+ assert(len > giAxWin3_int_UDPHeaderLen);
+ len -= giAxWin3_int_UDPHeaderLen;
+ data += giAxWin3_int_UDPHeaderLen;
+ }
+ assert(len >= sizeof(tAxWin_IPCMessage));
+ ret = malloc(len);
+ memcpy(ret, data, len);
+ }
}
return ret;