Attachment 58662 Details for Bug 173319 – transport components (transportSupport and SharedMemTL) patch

Some Eclipse Foundation services are deprecated, or will be soon. Please ensure you've read this important communication.

[patch] transport components (transportSupport and SharedMemTL) patch

transport.txt (text/plain), 5.34 KB, created by Igor Alelekov

on 2007-02-09 10:41:29 EST

(hide)

Description:

Filename:

MIME Type:

Creator: Igor Alelekov

Created: 2007-02-09 10:41:29 EST

Size: 5.34 KB

patch

obsolete

>### Eclipse Workspace Patch 1.0
>#P org.eclipse.tptp.platform.agentcontroller
>Index: src-native-new/src/transport/sharedMemTL/SharedMemListener.c
>===================================================================
>RCS file: /cvsroot/tptp/platform/org.eclipse.tptp.platform.agentcontroller/src-native-new/src/transport/sharedMemTL/SharedMemListener.c,v
>retrieving revision 1.25
>diff -u -r1.25 SharedMemListener.c
>--- src-native-new/src/transport/sharedMemTL/SharedMemListener.c	27 Sep 2006 23:01:45 -0000	1.25
>+++ src-native-new/src/transport/sharedMemTL/SharedMemListener.c	9 Feb 2007 14:26:55 -0000
>@@ -71,7 +71,11 @@
> enum ThreadStatus { IDLE, RUNNING } ;
> 
> static int acShmMemCount = 0;
>+static int shMemInitialized = 0;
> 
>+void destroyMem (mem_map_block_ptr_t  pMemBlockInfo);
>+
>+extern void ossSleep (long ms);
> 
> /*====================================================================*/
> /*    internal function prototypes                                    */
>@@ -224,10 +228,8 @@
> 	else
> 	{
> 		pServerData->serverMemInfo = memBlockInfo ;
>+		shMemInitialized = 1;
> 		
>-		/* attach to this block so that it will not be deleted */
>-		ipcMemOpen(pServerData->sharedMemName, &memBlockInfo);
>-	
> 		/* create new thread to listen to connection request */
> 		rc = startNewThread(doListening, 
> 				(LPVOID) pServerData, &threadId, &threadHandle) ;
>@@ -250,11 +252,37 @@
> 
> tptp_int32   stopSharedMemListener(server_block_t* pServerData)
> {
>+	int cnt;
>+	
> 	pServerData->threadStatus = IDLE ;
>+	ipcStopFlusher (&pServerData->serverMemInfo);
> 
>+	cnt = 20;
>+	while (shMemInitialized && cnt-- > 0) {	// wait 2 sec for flusher termination
>+		ossSleep (100L);	
>+	} 
>+	
>+	if (shMemInitialized) {
>+		destroyMem (&pServerData->serverMemInfo);
>+	}
>+	
> 	return 0 ;
> }
> 
>+/**
>+ *********************************************************
>+ *
>+ * @brief
>+ *    destroy shared memory block
>+ *
>+ *********************************************************/
>+
>+void destroyMem (mem_map_block_ptr_t  pMemBlockInfo) {
>+	ipcStopFlushing (pMemBlockInfo); // let shared memory get deleted when it is destroyed
>+	ipcMemDestroy (pMemBlockInfo);
>+	shMemInitialized = 0;
>+}
>+
> 
> /**
>  *********************************************************
>@@ -321,8 +349,6 @@
> 	return 0 ;
> }
> 
>-
>-
> /**
>  *********************************************************
>  *
>@@ -376,13 +402,15 @@
> 
> 	while (pServerData->threadStatus == RUNNING)
> 	{
>+		/* attach to this block so that it will not be deleted */
>+		ipcMemOpen(pServerData->sharedMemName, pMemBlockInfo);
>+	
> 	    rc =  ipcFlushToFunc(pMemBlockInfo, sharedMemMainDataProcessorFunc, (void *) pServerData) ;
>-	    ipcMemOpen(pServerData->sharedMemName, pMemBlockInfo);
>-    	}
>+   	}
> 
> 	TPTP_LOG_DEBUG_MSG(pServerData, "Shared memory server ends...\n") ;
> 
>-	ipcMemDestroy(pMemBlockInfo);
>+	destroyMem (pMemBlockInfo);
> 
> 	return ( rc ) ;
> }
>Index: src-native-new/src/transport/transportSupport/TransportSupport.def
>===================================================================
>RCS file: /cvsroot/tptp/platform/org.eclipse.tptp.platform.agentcontroller/src-native-new/src/transport/transportSupport/TransportSupport.def,v
>retrieving revision 1.15
>diff -u -r1.15 TransportSupport.def
>--- src-native-new/src/transport/transportSupport/TransportSupport.def	12 Jan 2007 21:54:59 -0000	1.15
>+++ src-native-new/src/transport/transportSupport/TransportSupport.def	9 Feb 2007 14:26:55 -0000
>@@ -48,4 +48,5 @@
> 	getPeerIPString				      @45
> 	convertIPAddressUlongToString     @46
> 	getSocketPort                     @47
>-	
>+	ipcStopFlusher                    @48
>+
>Index: src-native-new/src/transport/transportSupport/TransportSupportSharedMemExt.c
>===================================================================
>RCS file: /cvsroot/tptp/platform/org.eclipse.tptp.platform.agentcontroller/src-native-new/src/transport/transportSupport/TransportSupportSharedMemExt.c,v
>retrieving revision 1.7
>diff -u -r1.7 TransportSupportSharedMemExt.c
>--- src-native-new/src/transport/transportSupport/TransportSupportSharedMemExt.c	5 Jun 2006 17:59:57 -0000	1.7
>+++ src-native-new/src/transport/transportSupport/TransportSupportSharedMemExt.c	9 Feb 2007 14:26:55 -0000
>@@ -25,6 +25,7 @@
> 
> //We need to reference this stop flushing routine.
> extern tptp_int32 ra_setShmAttachCount(ra_shm_handle_t *, tptp_int32);
>+extern tptp_int32 ra_stopFlusher(ra_shm_handle_t *);
> 
> /**
>  *********************************************************
>@@ -97,4 +98,16 @@
> 	return ( rc ) ;
> }
> 
>+int ipcStopFlusher(mem_map_block_ptr_t pBlockInfo)
>+{
>+	int    rc = 0 ;
>+
>+	ra_shm_handle_t *pShmHdl = (ra_shm_handle_t *) pBlockInfo->pRamboBlock ;
>+
>+	if (pShmHdl != NULL) {
>+		rc = ra_stopFlusher(pShmHdl);
>+	}
>+
>+	return ( rc ) ;
>+}
> 
>Index: src-native-new/include/tptp/TransportSupportSharedMem.h
>===================================================================
>RCS file: /cvsroot/tptp/platform/org.eclipse.tptp.platform.agentcontroller/src-native-new/include/tptp/TransportSupportSharedMem.h,v
>retrieving revision 1.10
>diff -u -r1.10 TransportSupportSharedMem.h
>--- src-native-new/include/tptp/TransportSupportSharedMem.h	5 Apr 2006 23:57:20 -0000	1.10
>+++ src-native-new/include/tptp/TransportSupportSharedMem.h	9 Feb 2007 14:26:54 -0000
>@@ -239,6 +239,7 @@
>  *********************************************************/
> 
> int ipcStopFlushing(mem_map_block_ptr_t pBlockInfo);
>+int ipcStopFlusher(mem_map_block_ptr_t pBlockInfo);
> 
> 
> #ifdef __cplusplus
>@@ -247,5 +248,3 @@
> 
> 
> #endif
>-
>-

Actions: View | Diff

Attachments on bug 173319: 58661 | 58662 | 58753 | 60903