Changeset 637 for trunk/kernel/syscalls/sys_thread_create.c

Timestamp:

Jul 18, 2019, 2:06:55 PM (5 years ago)

Author:

alain

Message:

Introduce the non-standard pthread_parallel_create() system call
and re-write the <fft> and <sort> applications to improve the
intrinsic paralelism in applications.

File:

• trunk/kernel/syscalls/sys_thread_create.c (modified) (10 diffs)

trunk/kernel/syscalls/sys_thread_create.c

@@ -66 +66 @@
 
 #if DEBUG_SYS_THREAD_CREATE
-tm_start = hal_get_cycles();
 if( DEBUG_SYS_THREAD_CREATE < tm_start )
 printk("\n[%s] thread[%x,%x] enter / cycle %d\n",
@@ -73 +72 @@
 
     // check trdid buffer in user space
-    error = vmm_get_vseg( process , (intptr_t)trdid_ptr , &vseg );
-
-    if ( error )
+    if( vmm_get_vseg( process , (intptr_t)trdid_ptr , &vseg ) )
     {
 
@@ -89 +86 @@
     if( user_attr != NULL )
     {
-            error = vmm_get_vseg( process , (intptr_t)user_attr , &vseg );
-
-            if( error )
+            if( vmm_get_vseg( process , (intptr_t)user_attr , &vseg ) )
             {
 
@@ -102 +97 @@
             }
         
-            hal_copy_from_uspace( local_cxy, 
-                              &kern_attr,
+            hal_copy_from_uspace( XPTR( local_cxy , &kern_attr ),
                               user_attr,
                               sizeof(pthread_attr_t) );
@@ -109 +103 @@
 
         // check start_func in user space
-        error = vmm_get_vseg( process , (intptr_t)start_func , &vseg );
-
-    if( error )
+        if( vmm_get_vseg( process , (intptr_t)start_func , &vseg ) )
     {
 
@@ -125 +117 @@
         if( start_args != NULL )
     {
-        error = vmm_get_vseg( process , (intptr_t)start_args , &vseg );
-
-            if( error )
+        if( vmm_get_vseg( process , (intptr_t)start_args , &vseg ) )
             {
 
@@ -145 +135 @@
             if( kern_attr.attributes & PT_ATTR_CLUSTER_DEFINED )
             {
-                    if( cluster_is_undefined( kern_attr.cxy ) )
+                    if( cluster_is_active( kern_attr.cxy ) == false )
                     {
 
@@ -159 +149 @@
         else
         {
-            child_cxy = dqdt_get_cluster_for_process();
+            child_cxy = dqdt_get_cluster_for_thread( LOCAL_CLUSTER->dqdt_root_xp );
         }
         }
@@ -165 +155 @@
         {
         kern_attr.attributes = PT_ATTR_DETACH | PT_ATTR_CLUSTER_DEFINED;
-        child_cxy           = dqdt_get_cluster_for_process();
+        child_cxy = dqdt_get_cluster_for_thread( LOCAL_CLUSTER->dqdt_root_xp );
         }
 
@@ -209 +199 @@
         // returns trdid to user space
         trdid = hal_remote_l32( XPTR( child_cxy , &child_ptr->trdid ) );
-        hal_copy_to_uspace( local_cxy,
-                        &trdid,
-                        trdid_ptr,
+        hal_copy_to_uspace( trdid_ptr,
+                        XPTR( local_cxy , &trdid ),
                         sizeof(pthread_t) );