From: John Hodge Date: Sat, 2 Jul 2011 10:00:20 +0000 (+0800) Subject: Kernel - Changed VFS_SelectNode to be able to watch multiple attribs X-Git-Tag: rel0.10~53 X-Git-Url: https://git.ucc.asn.au/?a=commitdiff_plain;h=4d498b090274b87befa5652589e0aa54b2b6fe0a;p=tpg%2Facess2.git Kernel - Changed VFS_SelectNode to be able to watch multiple attribs --- diff --git a/Kernel/include/vfs.h b/Kernel/include/vfs.h index cded047e..f13f1b69 100644 --- a/Kernel/include/vfs.h +++ b/Kernel/include/vfs.h @@ -356,13 +356,15 @@ extern void VFS_CleanupNode(tVFS_Node *Node); extern tVFS_ACL *VFS_UnixToAcessACL(Uint Mode, Uint Owner, Uint Group); /** + * \brief Flags fro \a TypeFlag of VFS_SelectNode + * \{ + */ +#define VFS_SELECT_READ 0x01 +#define VFS_SELECT_WRITE 0x02 +#define VFS_SELECT_ERROR 0x04 +/** + * \} */ -enum eVFS_SelectTypes -{ - VFS_SELECT_READ, - VFS_SELECT_WRITE, - VFS_SELECT_ERROR -}; /** * \brief Wait for an event on a node @@ -372,7 +374,7 @@ enum eVFS_SelectTypes * \param Name Name to show in debug output * \return Number of nodes that actioned (0 or 1) */ -extern int VFS_SelectNode(tVFS_Node *Node, enum eVFS_SelectTypes Type, tTime *Timeout, const char *Name); +extern int VFS_SelectNode(tVFS_Node *Node, int Type, tTime *Timeout, const char *Name); /** * \brief Change the full flag on a node diff --git a/Kernel/vfs/select.c b/Kernel/vfs/select.c index a092b07c..18fdab76 100644 --- a/Kernel/vfs/select.c +++ b/Kernel/vfs/select.c @@ -44,9 +44,9 @@ struct sVFS_SelectThread // int VFS_MarkFull(tVFS_Node *Node, BOOL IsBufferFull); // int VFS_MarkAvaliable(tVFS_Node *Node, BOOL IsDataAvaliable); // int VFS_MarkError(tVFS_Node *Node, BOOL IsErrorState); - int VFS_int_Select_GetType(enum eVFS_SelectTypes Type, tVFS_Node *Node, tVFS_SelectList ***List, int **Flag, int *WantedFlag, int *MaxAllowed); - int VFS_int_Select_Register(tVFS_SelectThread *Thread, int MaxHandle, fd_set *Handles, enum eVFS_SelectTypes Type, BOOL IsKernel); - int VFS_int_Select_Deregister(tVFS_SelectThread *Thread, int MaxHandle, fd_set *Handles, enum eVFS_SelectTypes Type, BOOL IsKernel); + int VFS_int_Select_GetType(int Type, tVFS_Node *Node, tVFS_SelectList ***List, int **Flag, int *WantedFlag, int *MaxAllowed); + int VFS_int_Select_Register(tVFS_SelectThread *Thread, int MaxHandle, fd_set *Handles, int Type, BOOL IsKernel); + int VFS_int_Select_Deregister(tVFS_SelectThread *Thread, int MaxHandle, fd_set *Handles, int Type, BOOL IsKernel); int VFS_int_Select_AddThread(tVFS_SelectList *List, tVFS_SelectThread *Thread, int MaxAllowed); void VFS_int_Select_RemThread(tVFS_SelectList *List, tVFS_SelectThread *Thread); void VFS_int_Select_SignalAll(tVFS_SelectList *List); @@ -54,40 +54,47 @@ void VFS_int_Select_SignalAll(tVFS_SelectList *List); // === GLOBALS === // === FUNCTIONS === -int VFS_SelectNode(tVFS_Node *Node, enum eVFS_SelectTypes Type, tTime *Timeout, const char *Name) +int VFS_SelectNode(tVFS_Node *Node, int TypeFlags, tTime *Timeout, const char *Name) { tVFS_SelectThread *thread_info; - tVFS_SelectList **list; - int *flag, wanted, maxAllowed; - - ENTER("pNode iType pTimeout", Node, Type, Timeout); + int ret, type; - if( VFS_int_Select_GetType(Type, Node, &list, &flag, &wanted, &maxAllowed) ) { - LEAVE('i', -1); - return -1; - } + ENTER("pNode iTypeFlags pTimeout", Node, TypeFlags, Timeout); thread_info = malloc(sizeof(tVFS_SelectThread)); if(!thread_info) LEAVE_RET('i', -1); - + Semaphore_Init(&thread_info->SleepHandle, 0, 0, "VFS_SelectNode()", Name); - LOG("list=%p, flag=%p, wanted=%i, maxAllowed=%i", list, flag, wanted, maxAllowed); + // Initialise + for( type = 0; type < 3; type ++ ) + { + tVFS_SelectList **list; + int *flag, wanted, maxAllowed; + if( !(TypeFlags & (1 << type)) ) continue; + if( VFS_int_Select_GetType(type, Node, &list, &flag, &wanted, &maxAllowed) ) { + free(thread_info); + LEAVE('i', -1); + return -1; + } - // Alloc if needed - if( !*list ) { - *list = calloc(1, sizeof(tVFS_SelectList)); - } + // Alloc if needed + if( !*list ) *list = calloc(1, sizeof(tVFS_SelectList)); - VFS_int_Select_AddThread(*list, thread_info, maxAllowed); - if( *flag == wanted ) - { - VFS_int_Select_RemThread(*list, thread_info); - free(thread_info); - LEAVE('i', 1); - return 1; + VFS_int_Select_AddThread(*list, thread_info, maxAllowed); + if( *flag == wanted ) + { + VFS_int_Select_RemThread(*list, thread_info); + free(thread_info); + LEAVE('i', 1); + return 1; + } } - + + // - Fast return for polling + if( Timeout && *Timeout == 0 ) return 0; + + // Wait for things if( !Timeout || *Timeout > 0 ) { LOG("Semaphore_Wait()"); @@ -95,13 +102,23 @@ int VFS_SelectNode(tVFS_Node *Node, enum eVFS_SelectTypes Type, tTime *Timeout, Semaphore_Wait(&thread_info->SleepHandle, 1); } - LOG("VFS_int_Select_RemThread()"); - VFS_int_Select_RemThread(*list, thread_info); + // Get return value + ret = 0; + for( type = 0; type < 3; type ++ ) + { + tVFS_SelectList **list; + int *flag, wanted, maxAllowed; + if( !(TypeFlags & (1 << type)) ) continue; + VFS_int_Select_GetType(type, Node, &list, &flag, &wanted, &maxAllowed); + LOG("VFS_int_Select_RemThread()"); + VFS_int_Select_RemThread(*list, thread_info); + ret = ret || *flag == wanted; + } free(thread_info); - LEAVE('i', *flag == wanted); - return *flag == wanted; + LEAVE('i', ret); + return ret; } int VFS_Select(int MaxHandle, fd_set *ReadHandles, fd_set *WriteHandles, fd_set *ErrHandles, tTime *Timeout, BOOL IsKernel) @@ -195,7 +212,7 @@ int VFS_MarkError(tVFS_Node *Node, BOOL IsErrorState) } // --- Internal --- -int VFS_int_Select_GetType(enum eVFS_SelectTypes Type, tVFS_Node *Node, tVFS_SelectList ***List, int **Flag, int *WantedFlag, int *MaxAllowed) +int VFS_int_Select_GetType(int Type, tVFS_Node *Node, tVFS_SelectList ***List, int **Flag, int *WantedFlag, int *MaxAllowed) { // Get the type of the listen switch(Type) @@ -228,7 +245,7 @@ int VFS_int_Select_GetType(enum eVFS_SelectTypes Type, tVFS_Node *Node, tVFS_Sel /** * \return Number of files with an action */ -int VFS_int_Select_Register(tVFS_SelectThread *Thread, int MaxHandle, fd_set *Handles, enum eVFS_SelectTypes Type, BOOL IsKernel) +int VFS_int_Select_Register(tVFS_SelectThread *Thread, int MaxHandle, fd_set *Handles, int Type, BOOL IsKernel) { int i, numFlagged = 0; tVFS_SelectList **list; @@ -290,7 +307,7 @@ int VFS_int_Select_Register(tVFS_SelectThread *Thread, int MaxHandle, fd_set *Ha /** * \return Number of files with an action */ -int VFS_int_Select_Deregister(tVFS_SelectThread *Thread, int MaxHandle, fd_set *Handles, enum eVFS_SelectTypes Type, BOOL IsKernel) +int VFS_int_Select_Deregister(tVFS_SelectThread *Thread, int MaxHandle, fd_set *Handles, int Type, BOOL IsKernel) { int i, numFlagged = 0; tVFS_SelectList **list;