X-Git-Url: https://git.ucc.asn.au/?a=blobdiff_plain;ds=sidebyside;f=KernelLand%2FKernel%2Fdrv%2Ffifo.c;h=2adaec7c886d84716e5a35ad02c293846f3c68d3;hb=d0b4559f2936f6d9f06be0f7c3c51527a480ec0d;hp=0779a60b9ee014480a51ffb14ac5f3b782886948;hpb=48743e39650eb1ef988380e9d95f27fd40d3a9ce;p=tpg%2Facess2.git diff --git a/KernelLand/Kernel/drv/fifo.c b/KernelLand/Kernel/drv/fifo.c index 0779a60b..2adaec7c 100644 --- a/KernelLand/Kernel/drv/fifo.c +++ b/KernelLand/Kernel/drv/fifo.c @@ -26,14 +26,14 @@ typedef struct sPipe { // === PROTOTYPES === int FIFO_Install(char **Arguments); int FIFO_IOCtl(tVFS_Node *Node, int Id, void *Data); -char *FIFO_ReadDir(tVFS_Node *Node, int Id); + int FIFO_ReadDir(tVFS_Node *Node, int Id, char Dest[FILENAME_MAX]); tVFS_Node *FIFO_FindDir(tVFS_Node *Node, const char *Filename); - int FIFO_MkNod(tVFS_Node *Node, const char *Name, Uint Flags); +tVFS_Node *FIFO_MkNod(tVFS_Node *Node, const char *Name, Uint Flags); void FIFO_Reference(tVFS_Node *Node); void FIFO_Close(tVFS_Node *Node); - int FIFO_Relink(tVFS_Node *Node, const char *OldName, const char *NewName); -Uint64 FIFO_Read(tVFS_Node *Node, Uint64 Offset, Uint64 Length, void *Buffer); -Uint64 FIFO_Write(tVFS_Node *Node, Uint64 Offset, Uint64 Length, const void *Buffer); + int FIFO_Unlink(tVFS_Node *Node, const char *OldName); +size_t FIFO_Read(tVFS_Node *Node, off_t Offset, size_t Length, void *Buffer); +size_t FIFO_Write(tVFS_Node *Node, off_t Offset, size_t Length, const void *Buffer); tPipe *FIFO_Int_NewPipe(int Size, const char *Name); // === GLOBALS === @@ -43,7 +43,7 @@ tVFS_NodeType gFIFO_DirNodeType = { .ReadDir = FIFO_ReadDir, .FindDir = FIFO_FindDir, .MkNod = FIFO_MkNod, - .Relink = FIFO_Relink, + .Unlink = FIFO_Unlink, .IOCtl = FIFO_IOCtl }; tVFS_NodeType gFIFO_PipeNodeType = { @@ -92,19 +92,24 @@ int FIFO_IOCtl(tVFS_Node *Node, int Id, void *Data) * \fn char *FIFO_ReadDir(tVFS_Node *Node, int Id) * \brief Reads from the FIFO root */ -char *FIFO_ReadDir(tVFS_Node *Node, int Id) +int FIFO_ReadDir(tVFS_Node *Node, int Id, char Dest[FILENAME_MAX]) { tPipe *tmp = gFIFO_NamedPipes; // Entry 0 is Anon Pipes - if(Id == 0) return strdup("anon"); + if(Id == 0) { + strcpy(Dest, "anon"); + return 0; + } // Find the id'th node while(--Id && tmp) tmp = tmp->Next; - // If node found, return it - if(tmp) return strdup(tmp->Name); - // else error return - return NULL; + // If the list ended, error return + if(!tmp) + return -EINVAL; + // Return good + strncpy(Dest, tmp->Name, FILENAME_MAX); + return 0; } /** @@ -142,7 +147,7 @@ tVFS_Node *FIFO_FindDir(tVFS_Node *Node, const char *Filename) /** * \fn int FIFO_MkNod(tVFS_Node *Node, const char *Name, Uint Flags) */ -int FIFO_MkNod(tVFS_Node *Node, const char *Name, Uint Flags) +tVFS_Node *FIFO_MkNod(tVFS_Node *Node, const char *Name, Uint Flags) { return 0; } @@ -178,12 +183,11 @@ void FIFO_Close(tVFS_Node *Node) } /** - * \fn int FIFO_Relink(tVFS_Node *Node, const char *OldName, const char *NewName) - * \brief Relink a file (Deletes named pipes) + * \brief Delete a pipe */ -int FIFO_Relink(tVFS_Node *Node, const char *OldName, const char *NewName) +int FIFO_Unlink(tVFS_Node *Node, const char *OldName) { - tPipe *pipe, *tmp; + tPipe *pipe; if(Node != &gFIFO_DriverInfo.RootNode) return 0; @@ -200,22 +204,6 @@ int FIFO_Relink(tVFS_Node *Node, const char *OldName, const char *NewName) } if(!pipe) return 0; - // Relink a named pipe - if(NewName) { - // Check new name - for(tmp = gFIFO_NamedPipes; - tmp; - tmp = tmp->Next) - { - if(strcmp(tmp->Name, NewName) == 0) return 0; - } - // Create new name - free(pipe->Name); - pipe->Name = malloc(strlen(NewName)+1); - strcpy(pipe->Name, NewName); - return 1; - } - // Unlink the pipe if(Node->ImplPtr) { free(Node->ImplPtr); @@ -226,10 +214,9 @@ int FIFO_Relink(tVFS_Node *Node, const char *OldName, const char *NewName) } /** - * \fn Uint64 FIFO_Read(tVFS_Node *Node, Uint64 Offset, Uint64 Length, void *Buffer) * \brief Read from a fifo pipe */ -Uint64 FIFO_Read(tVFS_Node *Node, Uint64 Offset, Uint64 Length, void *Buffer) +size_t FIFO_Read(tVFS_Node *Node, off_t Offset, size_t Length, void *Buffer) { tPipe *pipe = Node->ImplPtr; Uint len; @@ -237,7 +224,7 @@ Uint64 FIFO_Read(tVFS_Node *Node, Uint64 Offset, Uint64 Length, void *Buffer) if(!pipe) return 0; - ENTER("pNode XOffset XLength pBuffer", Node, Offset, Length, Buffer); + ENTER("pNode XOffset xLength pBuffer", Node, Offset, Length, Buffer); while(remaining) { @@ -310,10 +297,9 @@ Uint64 FIFO_Read(tVFS_Node *Node, Uint64 Offset, Uint64 Length, void *Buffer) } /** - * \fn Uint64 FIFO_Write(tVFS_Node *Node, Uint64 Offset, Uint64 Length, void *Buffer) * \brief Write to a fifo pipe */ -Uint64 FIFO_Write(tVFS_Node *Node, Uint64 Offset, Uint64 Length, const void *Buffer) +size_t FIFO_Write(tVFS_Node *Node, off_t Offset, size_t Length, const void *Buffer) { tPipe *pipe = Node->ImplPtr; Uint len; @@ -321,7 +307,7 @@ Uint64 FIFO_Write(tVFS_Node *Node, Uint64 Offset, Uint64 Length, const void *Buf if(!pipe) return 0; - ENTER("pNode XOffset XLength pBuffer", Node, Offset, Length, Buffer); + ENTER("pNode XOffset xLength pBuffer", Node, Offset, Length, Buffer); while(remaining) {