X-Git-Url: https://git.ucc.asn.au/?a=blobdiff_plain;f=AcessNative%2Facesskernel_src%2Fvfs_handle.c;h=cfe048980469b9e75f96b3dede2cc3dbf7e082df;hb=45c91b880402af13c4b8f934c53780d7cba24aac;hp=aab30fc08b20496b81623b5e241ee694ca522d28;hpb=b5a1402b18d2f8cb360bf2fc524609b374bac8ec;p=tpg%2Facess2.git

diff --git a/AcessNative/acesskernel_src/vfs_handle.c b/AcessNative/acesskernel_src/vfs_handle.c
index aab30fc0..cfe04898 100644
--- a/AcessNative/acesskernel_src/vfs_handle.c
+++ b/AcessNative/acesskernel_src/vfs_handle.c
@@ -4,18 +4,23 @@
  */
 #define DEBUG	0
 #include <acess.h>
-#include "vfs.h"
-#include "vfs_int.h"
-#include "vfs_ext.h"
+#include <vfs.h>
+#include <vfs_int.h>
+#include <vfs_ext.h>
+#include <threads.h>
 
 // === CONSTANTS ===
 #define MAX_KERNEL_FILES	128
 #define MAX_USER_FILES	64
 
+// === IMPORTS ===
+extern int	Server_GetClientID(void);
+
 // === PROTOTYPES ===
 tVFS_Handle	*VFS_GetHandle(int FD);
  int	VFS_AllocHandle(int FD, tVFS_Node *Node, int Mode);
 
+// === Types ===
 typedef struct sUserHandles
 {
 	struct sUserHandles	*Next;
@@ -28,6 +33,61 @@ tUserHandles	*gpUserHandles = NULL;
 tVFS_Handle	gaKernelHandles[MAX_KERNEL_FILES];
 
 // === CODE ===
+tUserHandles *VFS_int_GetUserHandles(int PID, int bCreate)
+{
+	tUserHandles	*ent, *prev = NULL;
+	for( ent = gpUserHandles; ent; prev = ent, ent = ent->Next ) {
+		if( ent->PID == PID ) {
+			if( bCreate )
+				Log_Warning("VFS", "Process %i already has a handle list", PID);
+			return ent;
+		}
+		if( ent->PID > PID )	break;
+	}
+	
+	if(!bCreate)
+		return NULL;
+	
+	ent = calloc( 1, sizeof(tUserHandles) );
+	ent->PID = PID;
+	if( prev ) {
+		ent->Next = prev->Next;
+		prev->Next = ent;
+	}
+	else {
+		ent->Next = gpUserHandles;
+		gpUserHandles = ent;
+	}
+	Log_Notice("VFS", "Created handle list for process %i", PID);
+	return ent;
+}
+
+/**
+ * \brief Clone the handle list of the current process into another
+ */
+void VFS_CloneHandleList(int PID)
+{
+	tUserHandles	*ent;
+	tUserHandles	*cur;
+	 int	i, maxhandles;
+	
+	cur = VFS_int_GetUserHandles(Threads_GetPID(), 0);
+	if(!cur)	return ;	// Don't need to do anything if the current list is empty
+	
+	ent = VFS_int_GetUserHandles(PID, 1);
+	
+	maxhandles = *Threads_GetMaxFD();
+	memcpy(ent->Handles, cur->Handles, maxhandles*sizeof(tVFS_Handle));
+	
+	for( i = 0; i < maxhandles; i ++ )
+	{
+		if(!cur->Handles[i].Node)	continue;
+		
+		if(ent->Handles[i].Node->Type->Reference)
+			ent->Handles[i].Node->Type->Reference(ent->Handles[i].Node);
+	}
+}
+
 /**
  * \fn tVFS_Handle *VFS_GetHandle(int FD)
  * \brief Gets a pointer to the handle information structure
@@ -38,28 +98,43 @@ tVFS_Handle *VFS_GetHandle(int FD)
 	
 	//Log_Debug("VFS", "VFS_GetHandle: (FD=0x%x)", FD);
 	
-	if(FD < 0)	return NULL;
+	if(FD < 0) {
+		LOG("FD (%i) < 0, RETURN NULL", FD);
+		return NULL;
+	}
 	
 	if(FD & VFS_KERNEL_FLAG) {
 		FD &= (VFS_KERNEL_FLAG - 1);
-		if(FD >= MAX_KERNEL_FILES)	return NULL;
+		if(FD >= MAX_KERNEL_FILES) {
+			LOG("FD (%i) > MAX_KERNEL_FILES (%i), RETURN NULL", FD, MAX_KERNEL_FILES);
+			return NULL;
+		}
 		h = &gaKernelHandles[ FD ];
 	}
-	else {
+	else
+	{
 		tUserHandles	*ent;
 		 int	pid = Threads_GetPID();
-		for( ent = gpUserHandles; ent; ent = ent->Next ) {
-			if( ent->PID == pid )	break;
-			if( ent->PID > pid ) {
-				Log_Error("VFS", "PID %i does not have a handle list", pid);
-				return NULL;
-			}
+		 int	maxhandles = *Threads_GetMaxFD();
+		
+		ent = VFS_int_GetUserHandles(pid, 0);
+		if(!ent) {
+			Log_Error("VFS", "Client %i does not have a handle list (>)", pid);
+			return NULL;
+		}
+		
+		if(FD >= maxhandles) {
+			LOG("FD (%i) > Limit (%i), RETURN NULL", FD, maxhandles);
+			return NULL;
 		}
-		if(FD >= CFGINT(CFG_VFS_MAXFILES))	return NULL;
 		h = &ent->Handles[ FD ];
+		LOG("FD (%i) -> %p (Mode:0x%x,Node:%p)", FD, h, h->Mode, h->Node);
 	}
 	
-	if(h->Node == NULL)	return NULL;
+	if(h->Node == NULL) {
+		LOG("FD (%i) Unused", FD);
+		return NULL;
+	}
 	//Log_Debug("VFS", "VFS_GetHandle: RETURN %p", h);
 	return h;
 }
@@ -71,25 +146,12 @@ int VFS_AllocHandle(int bIsUser, tVFS_Node *Node, int Mode)
 	// Check for a user open
 	if(bIsUser)
 	{
-		tUserHandles	*ent, *prev;
-		 int	pid = Threads_GetPID();
-		for( ent = gpUserHandles; ent; prev = ent, ent = ent->Next ) {
-			if( ent->PID == pid )	break;
-			if( ent->PID > pid )	break;
-		}
-		if( ent->PID > pid ) {
-			ent = calloc( 1, sizeof(tUserHandles) );
-			if( prev ) {
-				ent->Next = prev->Next;
-				prev->Next = ent;
-			}
-			else {
-				ent->Next = gpUserHandles;
-				gpUserHandles = ent;
-			}
-		}
+		tUserHandles	*ent;
+		 int	maxhandles = *Threads_GetMaxFD();
+		// Find the PID's handle list
+		ent = VFS_int_GetUserHandles(Threads_GetPID(), 1);
 		// Get a handle
-		for(i=0;i<CFGINT(CFG_VFS_MAXFILES);i++)
+		for( i = 0; i < maxhandles; i ++ )
 		{
 			if(ent->Handles[i].Node)	continue;
 			ent->Handles[i].Node = Node;