* - Interprocess communication
*/
#include <common.h>
-#include <acess/sys.h>
-#include <net.h>
#include <string.h>
#include <ipcmessages.h>
#include <stdio.h>
#include <wm_internals.h>
#include <wm_hotkeys.h> // Hotkey registration
#include <wm_renderer.h> // Renderer IPC messages
+#include <ipc_int.h>
-#define AXWIN_PORT 4101
-
-#define STATICBUF_SIZE 64
#define MAX_WINDOWS_PER_APP 128
-// === TYPES ===
-typedef struct sIPC_Type tIPC_Type;
-
-struct sIPC_Type
-{
- int (*GetIdentSize)(const void *Ident);
- int (*CompareIdent)(const void *Ident1, const void *Ident2);
- void (*SendMessage)(const void *Ident, size_t Length, const void *Data);
-};
-
-struct sIPC_Client
-{
- const tIPC_Type *IPCType;
- const void *Ident; // Stored after structure
-
- int nWindows;
- tWindow **Windows;
-};
-
// === IMPORTS ===
extern tWindow *gpWM_FocusedWindow; // Needed for _FocusWindow
// === PROTOTYPES ===
-void IPC_Init(void);
-void IPC_FillSelect(int *nfds, fd_set *set);
-void IPC_HandleSelect(fd_set *set);
- int IPC_Type_Datagram_GetSize(const void *Ident);
- int IPC_Type_Datagram_Compare(const void *Ident1, const void *Ident2);
-void IPC_Type_Datagram_Send(const void *Ident, size_t Length, const void *Data);
- int IPC_Type_Sys_GetSize(const void *Ident);
- int IPC_Type_Sys_Compare(const void *Ident1, const void *Ident2);
-void IPC_Type_Sys_Send(const void *Ident, size_t Length, const void *Data);
-void IPC_Handle(const tIPC_Type *IPCType, const void *Ident, size_t MsgLen, tAxWin_IPCMessage *Msg);
+tIPC_Client *IPC_int_GetClient(const tIPC_Type *IPCType, const void *Ident);
+void IPC_int_DropClient(tIPC_Client *Client);
+void IPC_Handle(tIPC_Client *Client, size_t MsgLen, tAxWin_IPCMessage *Msg);
// === GLOBALS ===
-const tIPC_Type gIPC_Type_Datagram = {
- IPC_Type_Datagram_GetSize,
- IPC_Type_Datagram_Compare,
- IPC_Type_Datagram_Send
-};
-const tIPC_Type gIPC_Type_SysMessage = {
- IPC_Type_Sys_GetSize,
- IPC_Type_Sys_Compare,
- IPC_Type_Sys_Send
-};
- int giNetworkFileHandle = -1;
- int giMessagesFileHandle = -1;
int giIPC_ClientCount;
tIPC_Client **gIPC_Clients;
// === CODE ===
-void IPC_Init(void)
-{
- int tmp;
- // TODO: Check this
- giNetworkFileHandle = _SysOpen("/Devices/ip/loop/udp", OPENFLAG_READ);
- if( giNetworkFileHandle != -1 )
- {
- tmp = AXWIN_PORT;
- _SysIOCtl(giNetworkFileHandle, 4, &tmp); // TODO: Don't hard-code IOCtl number
- }
-}
-
-void IPC_FillSelect(int *nfds, fd_set *set)
-{
- if( giNetworkFileHandle != -1 )
- {
- if( giNetworkFileHandle > *nfds ) *nfds = giNetworkFileHandle;
- FD_SET(giNetworkFileHandle, set);
- }
-}
-
-void IPC_HandleSelect(fd_set *set)
-{
- if( giNetworkFileHandle != -1 )
- {
- if( FD_ISSET(giNetworkFileHandle, set) )
- {
- char staticBuf[STATICBUF_SIZE];
- int readlen, identlen;
- char *msg;
-
- readlen = _SysRead(giNetworkFileHandle, staticBuf, sizeof(staticBuf));
-
- identlen = 4 + Net_GetAddressSize( ((uint16_t*)staticBuf)[1] );
- msg = staticBuf + identlen;
-
- IPC_Handle(&gIPC_Type_Datagram, staticBuf, readlen - identlen, (void*)msg);
-// _SysDebug("IPC_HandleSelect: UDP handled");
- }
- }
-
- size_t len;
- int tid;
- while( (len = _SysGetMessage(&tid, 0, NULL)) )
- {
- char data[len];
- _SysGetMessage(NULL, len, data);
-
- IPC_Handle(&gIPC_Type_SysMessage, &tid, len, (void*)data);
-// _SysDebug("IPC_HandleSelect: Message handled");
- }
-}
-
-int IPC_Type_Datagram_GetSize(const void *Ident)
-{
- return 4 + Net_GetAddressSize( ((const uint16_t*)Ident)[1] );
-}
-
-int IPC_Type_Datagram_Compare(const void *Ident1, const void *Ident2)
-{
- // Pass the buck :)
- // - No need to worry about mis-matching sizes, as the size is computed
- // from the 3rd/4th bytes, hence it will differ before the size is hit.
- return memcmp(Ident1, Ident2, IPC_Type_Datagram_GetSize(Ident1));
-}
-
-void IPC_Type_Datagram_Send(const void *Ident, size_t Length, const void *Data)
-{
- int identlen = IPC_Type_Datagram_GetSize(Ident);
- char tmpbuf[ identlen + Length ];
- memcpy(tmpbuf, Ident, identlen); // Header
- memcpy(tmpbuf + identlen, Data, Length); // Data
- // TODO: Handle fragmented packets
- _SysWrite(giNetworkFileHandle, tmpbuf, sizeof(tmpbuf));
-}
-
-int IPC_Type_Sys_GetSize(const void *Ident)
-{
- return sizeof(pid_t);
-}
-
-int IPC_Type_Sys_Compare(const void *Ident1, const void *Ident2)
-{
- return *(const tid_t*)Ident1 - *(const tid_t*)Ident2;
-}
-
-void IPC_Type_Sys_Send(const void *Ident, size_t Length, const void *Data)
-{
- _SysSendMessage( *(const tid_t*)Ident, Length, Data );
-}
-
// --- Client -> Window Mappings
int _CompareClientPtrs(const void *_a, const void *_b)
{
tIPC_Client *a = *(tIPC_Client**)_a;
tIPC_Client *b = *(tIPC_Client**)_b;
-
+
+ ASSERT(a);
+ if(!b) return -1;
+
if(a->IPCType < b->IPCType) return -1;
if(a->IPCType > b->IPCType) return 1;
return a->IPCType->CompareIdent(a->Ident, b->Ident);
}
+int IPC_int_BSearchClients(const tIPC_Client *TargetClient, int *Pos)
+{
+ int div;
+ int cmp = -1;
+ int pos = 0;
+
+ div = giIPC_ClientCount;
+ pos = div/2;
+ while(div > 0)
+ {
+ div /= 2;
+ _SysDebug("Cmp with %i [%i] (%p)", pos, div, gIPC_Clients[pos]);
+ cmp = _CompareClientPtrs(&TargetClient, &gIPC_Clients[pos]);
+// _SysDebug("Checking against %i gives %i", pos, cmp);
+ if(cmp == 0) break;
+ if(cmp < 0)
+ pos -= div;
+ else
+ pos += div;
+ }
+
+ // - Return if found
+ if(cmp == 0) {
+ *Pos = pos;
+ return 1;
+ }
+
+ // Adjust pos to be the index where the new client will be placed
+ if(cmp > 0) pos ++;
+ *Pos = pos;
+ return 0;
+}
+
tIPC_Client *IPC_int_GetClient(const tIPC_Type *IPCType, const void *Ident)
{
int pos = 0; // Position where the new client will be inserted
if(giIPC_ClientCount > 0)
{
tIPC_Client target;
- int div;
- int cmp = -1;
-
target.IPCType = IPCType;
target.Ident = Ident;
- ret = ⌖ // Abuse ret to get a pointer
-
- div = giIPC_ClientCount;
- pos = div/2;
- while(div > 0)
- {
- div /= 2;
- cmp = _CompareClientPtrs(&ret, &gIPC_Clients[pos]);
-// _SysDebug("Checking against %i gives %i", pos, cmp);
- if(cmp == 0) break;
- if(cmp < 0)
- pos -= div;
- else
- pos += div;
- }
-
- // - Return if found
- if(cmp == 0)
+ if( IPC_int_BSearchClients(&target, &pos) )
return gIPC_Clients[pos];
-
- // Adjust pos to be the index where the new client will be placed
- if(cmp > 0) pos ++;
}
return ret;
}
+void IPC_int_DropClient(tIPC_Client *Client)
+{
+ // Remove from client list
+ int pos;
+ if( !IPC_int_BSearchClients(Client, &pos) ) {
+ _SysDebug("IPC_int_DropClient: Can't find client %p", Client);
+ return ;
+ }
+
+ giIPC_ClientCount --;
+ memmove(&gIPC_Clients[pos], &gIPC_Clients[pos+1], (giIPC_ClientCount-pos)*sizeof(tIPC_Client*));
+
+ // Terminate client's windows
+ // - If there were active windows, show an error?
+ int nWindowsDestroyed = 0;
+ for(int i = 0; i < Client->nWindows; i ++)
+ {
+ if( Client->Windows[i] )
+ {
+ _SysDebug("Window %p:%i %p still exists", Client, i, Client->Windows[i]);
+ WM_DestroyWindow(Client->Windows[i]);
+ nWindowsDestroyed ++;
+ }
+ }
+ if( nWindowsDestroyed )
+ {
+ _SysDebug("TODO: Show notice that application exited without destroying windows");
+ }
+
+ // Free client structure
+ free(Client);
+ _SysDebug("Dropped client %p", Client);
+}
+
tWindow *IPC_int_GetWindow(tIPC_Client *Client, uint32_t WindowID)
{
if( WindowID == -1 )
return 0;
}
+int IPC_Msg_DestroyWin(tIPC_Client *Client, tAxWin_IPCMessage *Msg)
+{
+ tWindow *win;
+
+ ASSERT(Msg->ID == IPCMSG_DESTROYWIN);
+
+ win = IPC_int_GetWindow(Client, Msg->Window);
+ if( !win )
+ return 0;
+
+ WM_DestroyWindow(win);
+ IPC_int_SetWindow(Client, Msg->Window, NULL);
+ return 0;
+}
+
int IPC_Msg_SetWindowTitle(tIPC_Client *Client, tAxWin_IPCMessage *Msg)
{
tWindow *win;
IPC_Msg_GetDisplayDims,
IPC_Msg_SendMsg,
IPC_Msg_CreateWin,
- NULL, // Destroy window
+ IPC_Msg_DestroyWin, // Destroy window
IPC_Msg_SetWindowTitle,
IPC_Msg_ShowWindow,
IPC_Msg_DecorateWindow,
};
const int giIPC_NumMessageHandlers = sizeof(gIPC_MessageHandlers)/sizeof(gIPC_MessageHandlers[0]);
-void IPC_Handle(const tIPC_Type *IPCType, const void *Ident, size_t MsgLen, tAxWin_IPCMessage *Msg)
+void IPC_Handle(tIPC_Client *Client, size_t MsgLen, tAxWin_IPCMessage *Msg)
{
- tIPC_Client *client;
int rv = 0;
// _SysDebug("IPC_Handle: (IPCType=%p, Ident=%p, MsgLen=%i, Msg=%p)",
// IPCType, Ident, MsgLen, Msg);
- if( MsgLen < sizeof(tAxWin_IPCMessage) )
+ if( MsgLen < sizeof(*Msg) ) {
+ _SysDebug("IPC_Handle: %p Dropped full undersize message (%i < %i)",
+ Client, MsgLen, sizeof(*Msg));
return ;
- if( MsgLen < sizeof(tAxWin_IPCMessage) + Msg->Size )
+ }
+ if( MsgLen < sizeof(*Msg) + Msg->Size ) {
+ _SysDebug("IPC_Handle: %p Dropped undersize message (%i < %i+%i)",
+ Client, MsgLen, sizeof(*Msg), Msg->Size);
return ;
-
- client = IPC_int_GetClient(IPCType, Ident);
- if( !client ) {
- // Oops?
}
if( Msg->Flags & IPCMSG_FLAG_RENDERER )
{
- tWindow *win = IPC_int_GetWindow(client, Msg->Window);
+ tWindow *win = IPC_int_GetWindow(Client, Msg->Window);
if( !win ) {
- _SysDebug("WARNING: NULL window in message %i", Msg->ID);
+ _SysDebug("WARNING: NULL window in message %i (%x)", Msg->ID, Msg->Window);
return ;
}
tWMRenderer *renderer = win->Renderer;
_SysDebug("WARNING: Message %i has no handler in %s", Msg->ID, renderer->Name);
return ;
}
- _SysDebug("IPC_Handle: Call %s-%i", renderer->Name, Msg->ID);
+ _SysDebug("IPC_Handle: Call %s-%i %ib", renderer->Name, Msg->ID, Msg->Size);
rv = renderer->IPCHandlers[Msg->ID](win, Msg->Size, Msg->Data);
if( rv )
_SysDebug("IPC_Handle: rv != 0 (%i)", rv);
else
{
if( Msg->ID >= giIPC_NumMessageHandlers ) {
- fprintf(stderr, "WARNING: Unknown message %i (%p)\n", Msg->ID, IPCType);
- _SysDebug("WARNING: Unknown message %i (%p)", Msg->ID, IPCType);
+ fprintf(stderr, "WARNING: Unknown message %i (%p)\n", Msg->ID, Client);
+ _SysDebug("WARNING: Unknown message %i (%p)", Msg->ID, Client);
return ;
}
return ;
}
- _SysDebug("IPC_Handle: Call WM-%i", Msg->ID);
- rv = gIPC_MessageHandlers[Msg->ID](client, Msg);
+ _SysDebug("IPC_Handle: Call WM-%i %ib", Msg->ID, Msg->Size);
+ rv = gIPC_MessageHandlers[Msg->ID](Client, Msg);
if( rv )
_SysDebug("IPC_Handle: rv != 0 (%i)", rv);
}
git.ucc.asn.au / tpg / acess2.git / blobdiff
UCC git Repository :: git.ucc.asn.au