Changeset 632 for trunk/kernel/libk/remote_barrier.c

Timestamp:

May 28, 2019, 2:56:04 PM (5 years ago)

Author:

alain

Message:

This version replace the RPC by direct remote memory access
for physical pages allacation/release.
It is commited before being tested.

File:

• trunk/kernel/libk/remote_barrier.c (modified) (5 diffs)

trunk/kernel/libk/remote_barrier.c

@@ -506 +506 @@
                                     uint32_t    nthreads )
 {
-    page_t        * dqt_page;
     xptr_t          dqt_page_xp;     
     page_t        * rpc_page;
@@ -514 +513 @@
     uint32_t        z;             // actual DQT size == max(x_size,y_size)
     uint32_t        levels;        // actual number of DQT levels
-    kmem_req_t      req;           // kmem request
     xptr_t          rpc_xp;        // extended pointer on RPC descriptors array
     rpc_desc_t    * rpc;           // pointer on RPC descriptors array
@@ -522 +520 @@
     uint32_t        y;             // Y coordinate in QDT mesh
     uint32_t        l;             // level coordinate
+    kmem_req_t      req;           // kmem request
 
     // compute size and number of DQT levels
@@ -554 +553 @@
     cxy_t          ref_cxy = GET_CXY( ref_xp );
 
-    // 1. allocate memory for DQT barrier descriptor in reference cluster
-    if( ref_cxy == local_cxy )                    
-     {
-        req.type     = KMEM_PAGE;
-        req.size     = 2;               // 4 pages == 16 Kbytes
-        req.flags    = AF_ZERO;
-        dqt_page     = kmem_alloc( &req );
-        dqt_page_xp  = XPTR( local_cxy , dqt_page );
-    }
-    else                                         
-    {
-        rpc_pmem_get_pages_client( ref_cxy,
-                                   2,
-                                   &dqt_page );
-        dqt_page_xp  = XPTR( ref_cxy , dqt_page );
-    }
-
-    if( dqt_page == NULL ) return NULL;
+    // 1. allocate 4 4 Kbytes pages for DQT barrier descriptor in reference cluster
+    dqt_page_xp = ppm_remote_alloc_pages( ref_cxy , 2 );
+
+    if( dqt_page_xp == XPTR_NULL ) return NULL;
 
     // get pointers on DQT barrier descriptor
@@ -948 +933 @@
 
     // 4. release memory allocated for barrier descriptor 
-    xptr_t   page_xp = ppm_base2page( barrier_xp );
-    page_t * page    = GET_PTR( page_xp );
-
-    if( barrier_cxy == local_cxy )                    
-    {
-        req.type      = KMEM_PAGE;
-        req.ptr       = page;
-        kmem_free( &req );
-    }
-    else                                         
-    {
-        rpc_pmem_release_pages_client( barrier_cxy,
-                                       page );
-    }
+    xptr_t   page_xp  = ppm_base2page( barrier_xp );
+    cxy_t    page_cxy = GET_CXY( page_xp );
+    page_t * page_ptr = GET_PTR( page_xp );
+
+    ppm_remote_free_pages( page_cxy , page_ptr );
 
 #if DEBUG_BARRIER_DESTROY