/* * sys_thread_create.c - creates a new user thread * * Author Alain Greiner (2016,2017,2018,2019) * * Copyright (c) UPMC Sorbonne Universites * * This file is part of ALMOS-MKH. * * ALMOS-MKH is free software; you can redistribute it and/or modify it * under the terms of the GNU General Public License as published by * the Free Software Foundation; version 2.0 of the License. * * ALMOS-MKH is distributed in the hope that it will be useful, but * WITHOUT ANY WARRANTY; without even the implied warranty of * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU * General Public License for more details. * * You should have received a copy of the GNU General Public License * along with ALMOS-MKH; if not, write to the Free Software Foundation, * Inc., 51 Franklin St, Fifth Floor, Boston, MA 02110-1301 USA */ #include #include #include #include #include #include #include #include #include #include #include #include #include #include #include #include #include ///////////////////////////////////////////////////////// int sys_thread_create( trdid_t * trdid_ptr, struct pthread_attr_s * user_attr, void * start_func, void * start_args ) { pthread_attr_t kern_attr; // copy of pthread attributes in kernel space thread_t * parent; // pointer on thread executing the pthread_create cxy_t child_cxy; // created child thread cluster identifier thread_t * child_ptr; // pointer on created child thread xptr_t child_xp; // extended pointer on created thread trdid_t trdid; // created thread identifier process_t * process; // pointer on local process descriptor vseg_t * vseg; // required for user space checking error_t error; // get parent thead pointer, extended pointer, and process parent = CURRENT_THREAD; process = parent->process; #if (DEBUG_SYS_THREAD_CREATE || CONFIG_INSTRUMENTATION_SYSCALLS) uint64_t tm_start = hal_get_cycles(); #endif #if DEBUG_SYS_THREAD_CREATE if( DEBUG_SYS_THREAD_CREATE < tm_start ) printk("\n[%s] thread[%x,%x] enter / cycle %d\n", __FUNCTION__, process->pid, parent->trdid, (uint32_t)tm_start ); #endif // check trdid buffer in user space if( vmm_get_vseg( process , (intptr_t)trdid_ptr , &vseg ) ) { #if DEBUG_SYSCALLS_ERROR printk("\n[ERROR] in %s : thread[%x,%x] / trdid buffer %x unmapped %x\n", __FUNCTION__, process->pid, parent->trdid, (intptr_t)trdid_ptr ); #endif parent->errno = EINVAL; return -1; } // check user_attr buffer in user space & copy to kernel space if( user_attr != NULL ) { if( vmm_get_vseg( process , (intptr_t)user_attr , &vseg ) ) { #if DEBUG_SYSCALLS_ERROR printk("\n[ERROR] in %s : thread[%x,%x] / user_attr buffer unmapped %x\n", __FUNCTION__, process->pid, parent->trdid, (intptr_t)user_attr ); #endif parent->errno = EINVAL; return -1; } hal_copy_from_uspace( XPTR( local_cxy , &kern_attr ), user_attr, sizeof(pthread_attr_t) ); } // check start_func in user space if( vmm_get_vseg( process , (intptr_t)start_func , &vseg ) ) { #if DEBUG_SYSCALLS_ERROR printk("\n[ERROR] in %s : thread[%x,%x] / start_func unmapped %x\n", __FUNCTION__, process->pid, parent->trdid, (intptr_t)start_func ); #endif parent->errno = EINVAL; return -1; } // check start_args buffer in user space if( start_args != NULL ) { if( vmm_get_vseg( process , (intptr_t)start_args , &vseg ) ) { #if DEBUG_SYSCALLS_ERROR printk("\n[ERROR] in %s : thread[%x,%x] / start_args buffer unmapped %x\n", __FUNCTION__, process->pid, parent->trdid, (intptr_t)start_args ); #endif parent->errno = EINVAL; return -1; } } // define attributes and child_cxy if( user_attr != NULL ) // user defined attributes { // check / get child_cxy if( kern_attr.attributes & PT_ATTR_CLUSTER_DEFINED ) { if( cluster_is_active( kern_attr.cxy ) == false ) { #if DEBUG_SYSCALLS_ERROR printk("\n[ERROR] in %s : thread[%x,%x] / illegal target cluster %x\n", __FUNCTION__, process->pid, parent->trdid, kern_attr.cxy ); #endif parent->errno = EINVAL; return -1; } child_cxy = kern_attr.cxy; } else { child_cxy = dqdt_get_cluster_for_thread( LOCAL_CLUSTER->dqdt_root_xp ); } } else // set default attributes { kern_attr.attributes = PT_ATTR_DETACH | PT_ATTR_CLUSTER_DEFINED; child_cxy = dqdt_get_cluster_for_thread( LOCAL_CLUSTER->dqdt_root_xp ); } // create the thread, using a RPC if required // this returns "error", "child_ptr", and "child_xp" if( child_cxy == local_cxy ) // target cluster is local { // create thread in local cluster error = thread_user_create( process->pid, start_func, start_args, &kern_attr, &child_ptr ); child_xp = XPTR( local_cxy , child_ptr ); } else // target cluster is remote { rpc_thread_user_create_client( child_cxy, process->pid, start_func, start_args, &kern_attr, &child_xp, &error ); child_ptr = (thread_t *)GET_PTR( child_xp ); } // check successful thread creation if( error ) { #if DEBUG_SYSCALLS_ERROR printk("\n[ERROR] in %s : thread[%x,%x] cannot create new thread\n", __FUNCTION__ , process->pid, parent->trdid ); #endif parent->errno = ENOMEM; return -1; } // returns trdid to user space trdid = hal_remote_l32( XPTR( child_cxy , &child_ptr->trdid ) ); hal_copy_to_uspace( trdid_ptr, XPTR( local_cxy , &trdid ), sizeof(pthread_t) ); // activate new thread thread_unblock( child_xp , THREAD_BLOCKED_GLOBAL ); hal_fence(); #if (DEBUG_SYS_THREAD_CREATE || CONFIG_INSTRUMENTATION_SYSCALLS) uint64_t tm_end = hal_get_cycles(); #endif #if DEBUG_SYS_THREAD_CREATE if( DEBUG_SYS_THREAD_CREATE < tm_end ) printk("\n[%s] thread[%x,%x] created thread %x / cycle %d\n", __FUNCTION__, process->pid, parent->trdid, child_ptr->trdid, (uint32_t)tm_end ); #endif #if CONFIG_INSTRUMENTATION_SYSCALLS hal_atomic_add( &syscalls_cumul_cost[SYS_THREAD_CREATE] , tm_end - tm_start ); hal_atomic_add( &syscalls_occurences[SYS_THREAD_CREATE] , 1 ); #endif return 0; } // end sys_thread_create()