From patchwork Tue Sep 27 01:12:23 2022 Content-Type: text/plain; charset="utf-8" MIME-Version: 1.0 Content-Transfer-Encoding: 7bit X-Patchwork-Submitter: Ahmed Sayed Mousse X-Patchwork-Id: 1480 Return-Path: Delivered-To: ouuuleilei@gmail.com Received: by 2002:a5d:5044:0:0:0:0:0 with SMTP id h4csp90260wrt; Mon, 26 Sep 2022 18:13:19 -0700 (PDT) X-Google-Smtp-Source: AMsMyM4cycwS18RxfmteqcR24Aa1DrMOkPQjg6CuOZYL0ZXvYL2UxhQww1fxhW/8ddC5Z71rwLWP X-Received: by 2002:a17:906:eec9:b0:73d:c369:690f with SMTP id wu9-20020a170906eec900b0073dc369690fmr20650567ejb.767.1664241199555; Mon, 26 Sep 2022 18:13:19 -0700 (PDT) ARC-Seal: i=1; a=rsa-sha256; t=1664241199; cv=none; d=google.com; s=arc-20160816; b=QiFxmeW58Q8PL+Qxlp/MAPomeKtb7wN5zb17T4maWl7/Z/XFqmwmlaOQO5CYLSsERm FGX1cedmcM6vI8C4Jyoh8LFqc6nonBUux4iX9nulmPhsGqUcaeTH64wTkCwMqFuyAfF6 s2Cqca33BOLFW1fMyCmPHFju8Yixnj4H+XKSB9tt1nhi9hceljtgf5k5qJqD7XafV89Q +PMAKY0vbOy42gDR/2O8ZzDbvQ8X6FkISwOGgdmmvKvCnNnD8FrCnzOeHK0WJexn25p+ 6gScpSZT4g2vHfWhpRaUPgS4PdEDSq243mVRUKL5M56dpajAJCw7ZJjmnYw+p/CaMSf4 rc0g== ARC-Message-Signature: i=1; a=rsa-sha256; c=relaxed/relaxed; d=google.com; s=arc-20160816; h=sender:errors-to:cc:reply-to:from:list-subscribe:list-help :list-post:list-archive:list-unsubscribe:list-id:precedence:subject :to:content-language:user-agent:mime-version:date:message-id :dmarc-filter:delivered-to:dkim-signature:dkim-filter; bh=vYFQjryN+L+CjD3OMslhFm3Qekm8AJS86sy7cMoVyRU=; b=0p245dAtFmw/DIBT+nehR0B9PeiCeOhC1tyihZmMBXFR3RV+V5HvSSYeQUvoI9KOlJ x50PRXd2lGvnH4jf35VIr9UkeNMNLfP3vqibwK9RANjL06b/u7s9f9JX6XPLlSB+xabN IwRBDKP3aE2f/S70Gtcb3S4I7kE5ND1+3NTTthhE97z4gwsQbXalr2gTrC3hCdkT9Mof 856XWJrLrGdwe7oKWDbKnWA87yvWUKQ6YvqXy6suPr2o0WFSXrhKs4gXKSAcpGHwRuvm vtaHCOicA21aH/MYdCgAYQocHU7IEJBstlaY5kn58FTK/wc+z+eRMVziC5/S07hKhWhe SlFg== ARC-Authentication-Results: i=1; mx.google.com; dkim=pass header.i=@gcc.gnu.org header.s=default header.b=MgQmRZDT; spf=pass (google.com: domain of gcc-patches-bounces+ouuuleilei=gmail.com@gcc.gnu.org designates 8.43.85.97 as permitted sender) smtp.mailfrom="gcc-patches-bounces+ouuuleilei=gmail.com@gcc.gnu.org"; dmarc=pass (p=NONE sp=NONE dis=NONE) header.from=gnu.org Received: from sourceware.org (server2.sourceware.org. [8.43.85.97]) by mx.google.com with ESMTPS id di20-20020a170906731400b00783c42d2da1si1861333ejc.425.2022.09.26.18.13.19 for (version=TLS1_3 cipher=TLS_AES_256_GCM_SHA384 bits=256/256); Mon, 26 Sep 2022 18:13:19 -0700 (PDT) Received-SPF: pass (google.com: domain of gcc-patches-bounces+ouuuleilei=gmail.com@gcc.gnu.org designates 8.43.85.97 as permitted sender) client-ip=8.43.85.97; Authentication-Results: mx.google.com; dkim=pass header.i=@gcc.gnu.org header.s=default header.b=MgQmRZDT; spf=pass (google.com: domain of gcc-patches-bounces+ouuuleilei=gmail.com@gcc.gnu.org designates 8.43.85.97 as permitted sender) smtp.mailfrom="gcc-patches-bounces+ouuuleilei=gmail.com@gcc.gnu.org"; dmarc=pass (p=NONE sp=NONE dis=NONE) header.from=gnu.org Received: from server2.sourceware.org (localhost [IPv6:::1]) by sourceware.org (Postfix) with ESMTP id 7F7B03858C53 for ; Tue, 27 Sep 2022 01:13:18 +0000 (GMT) DKIM-Filter: OpenDKIM Filter v2.11.0 sourceware.org 7F7B03858C53 DKIM-Signature: v=1; a=rsa-sha256; c=relaxed/relaxed; d=gcc.gnu.org; s=default; t=1664241198; bh=vYFQjryN+L+CjD3OMslhFm3Qekm8AJS86sy7cMoVyRU=; h=Date:To:Subject:List-Id:List-Unsubscribe:List-Archive:List-Post: List-Help:List-Subscribe:From:Reply-To:Cc:From; b=MgQmRZDTCzJgXC8zUBZvIGO7/eiwE7KHw1rrjevXDuizhNrmtqHJYr/qkheK3t8eu JnZXlsUtNSoawLqEc0K8wlZzYUJzFeOvOd6+wDetTiRZaMmkrLtCx4G9CLDWuh8o5T VYNM+PdaiROja9o1aojbX4uqmouyB2JWTTk44e4c= X-Original-To: gcc-patches@gcc.gnu.org Delivered-To: gcc-patches@gcc.gnu.org Received: from mail-wr1-x42f.google.com (mail-wr1-x42f.google.com [IPv6:2a00:1450:4864:20::42f]) by sourceware.org (Postfix) with ESMTPS id B76E53858D37 for ; Tue, 27 Sep 2022 01:12:28 +0000 (GMT) DMARC-Filter: OpenDMARC Filter v1.4.1 sourceware.org B76E53858D37 Received: by mail-wr1-x42f.google.com with SMTP id n10so12652627wrw.12 for ; Mon, 26 Sep 2022 18:12:28 -0700 (PDT) X-Google-DKIM-Signature: v=1; a=rsa-sha256; c=relaxed/relaxed; d=1e100.net; s=20210112; h=subject:cc:to:content-language:user-agent:mime-version:date :message-id:from:x-gm-message-state:from:to:cc:subject:date; bh=ujIDWNAly0TCuEMIg0sX98xlyPybEcHNmsqTcH+2BpM=; b=TLE4ul0L7KGBBG/QFN72nyFr3mFV0wxBRI1efJqlq6LknRDbEncAYywHfVZlXFI6Ob z2tlAlCU3UWBkeK5abnKlK5g7Q+zbGvRYB8YMciPdMeXWuht2EBN7UymoM0KuU6PsCOc infY+1Rvbayp63LZJvutjLeA9vFY6JEygDVFg5phPOyl8DcJadPTeMmAGXssbuWZww5I ZE8EdRQ7hMwmybJCbMzWTPgJlvGJJ3njZV7xadlnLDCMRbE0awipkgSLOz57cYKQJx37 J5JAQR8iGcAHc8wLFL31tLQV7yAYeV5pT2B1E9HievyM979hplmhEbwfvV2OEZMnGCE7 8bug== X-Gm-Message-State: ACrzQf2hzSF6kgjvf2kOrLy7cooCQvgNfrZZflfBvNnr/pzVOEl5AQPO Ff9ktKCBNNp2lOD5AMaDORGqT3ROdWbMCA== X-Received: by 2002:adf:e24d:0:b0:22a:4a40:d5cc with SMTP id bl13-20020adfe24d000000b0022a4a40d5ccmr15557314wrb.494.1664241146946; Mon, 26 Sep 2022 18:12:26 -0700 (PDT) Received: from [192.168.1.10] ([197.33.9.130]) by smtp.gmail.com with ESMTPSA id o3-20020a5d4743000000b00225307f43fbsm297598wrs.44.2022.09.26.18.12.25 (version=TLS1_3 cipher=TLS_AES_128_GCM_SHA256 bits=128/128); Mon, 26 Sep 2022 18:12:26 -0700 (PDT) X-Google-Original-From: Ahmed Sayed Mousse Message-ID: <4086807d-97d1-ec58-1617-24dda537010a@gmail.com> Date: Tue, 27 Sep 2022 03:12:23 +0200 MIME-Version: 1.0 User-Agent: Mozilla/5.0 (X11; Linux x86_64; rv:102.0) Gecko/20100101 Thunderbird/102.3.0 Content-Language: en-US To: gcc-patches@gcc.gnu.org Subject: [patch] libgompd: Add thread handles X-Spam-Status: No, score=-10.5 required=5.0 tests=BAYES_00, DKIM_SIGNED, DKIM_VALID, DKIM_VALID_AU, DKIM_VALID_EF, FREEMAIL_FROM, GIT_PATCH_0, HTML_MESSAGE, KAM_SHORT, RCVD_IN_DNSWL_NONE, SPF_HELO_NONE, SPF_PASS, TXREP autolearn=ham autolearn_force=no version=3.4.6 X-Spam-Checker-Version: SpamAssassin 3.4.6 (2021-04-09) on server2.sourceware.org X-Content-Filtered-By: Mailman/MimeDel 2.1.29 X-BeenThere: gcc-patches@gcc.gnu.org X-Mailman-Version: 2.1.29 Precedence: list List-Id: Gcc-patches mailing list List-Unsubscribe: , List-Archive: List-Post: List-Help: List-Subscribe: , X-Patchwork-Original-From: Ahmed Sayed Mousse via Gcc-patches From: Ahmed Sayed Mousse Reply-To: Ahmed Sayed Mousse Cc: jakub@redhat.com Errors-To: gcc-patches-bounces+ouuuleilei=gmail.com@gcc.gnu.org Sender: "Gcc-patches" X-getmail-retrieved-from-mailbox: =?utf-8?q?INBOX?= X-GMAIL-THRID: =?utf-8?q?1745083379952226004?= X-GMAIL-MSGID: =?utf-8?q?1745083379952226004?= /This patch is the initial implementation of OpenMP-API specs book section //20.5.5 with title "Thread Handles". //libgomp/ChangeLog ///2022-07-01 Ahmed Sayed ///* Makefile.am (libgompd_la_SOURCES): Add ompd-threads.c.///* Makefile.in: Regenerate. * team.c (gomp_free_thread): Call ompd_bp_thread_end./* ompd-support.c (gompd_thread_initial_tls_bias): New variable. (gompd_load): Initialize gompd_thread_initial_tls_bias. * ompd-threads.c: New file./// diff --git a/libgomp/Makefile.am b/libgomp/Makefile.am index 6d913a93e7f..23f5bede1bf 100644 --- a/libgomp/Makefile.am +++ b/libgomp/Makefile.am @@ -94,7 +94,7 @@ libgomp_la_SOURCES = alloc.c atomic.c barrier.c critical.c env.c error.c \ priority_queue.c affinity-fmt.c teams.c allocator.c oacc-profiling.c \ oacc-target.c ompd-support.c -libgompd_la_SOURCES = ompd-init.c ompd-helper.c ompd-icv.c +libgompd_la_SOURCES = ompd-init.c ompd-helper.c ompd-icv.c ompd-threads.c include $(top_srcdir)/plugin/Makefrag.am diff --git a/libgomp/Makefile.in b/libgomp/Makefile.in index 40f896b5f03..7acdcbf31d5 100644 --- a/libgomp/Makefile.in +++ b/libgomp/Makefile.in @@ -233,7 +233,8 @@ am_libgomp_la_OBJECTS = alloc.lo atomic.lo barrier.lo critical.lo \ affinity-fmt.lo teams.lo allocator.lo oacc-profiling.lo \ oacc-target.lo ompd-support.lo $(am__objects_1) libgomp_la_OBJECTS = $(am_libgomp_la_OBJECTS) -am_libgompd_la_OBJECTS = ompd-init.lo ompd-helper.lo ompd-icv.lo +am_libgompd_la_OBJECTS = ompd-init.lo ompd-helper.lo ompd-icv.lo \ + ompd-threads.lo libgompd_la_OBJECTS = $(am_libgompd_la_OBJECTS) AM_V_P = $(am__v_P_@AM_V@) am__v_P_ = $(am__v_P_@AM_DEFAULT_V@) @@ -583,7 +584,7 @@ libgomp_la_SOURCES = alloc.c atomic.c barrier.c critical.c env.c \ oacc-async.c oacc-plugin.c oacc-cuda.c priority_queue.c \ affinity-fmt.c teams.c allocator.c oacc-profiling.c \ oacc-target.c ompd-support.c $(am__append_7) -libgompd_la_SOURCES = ompd-init.c ompd-helper.c ompd-icv.c +libgompd_la_SOURCES = ompd-init.c ompd-helper.c ompd-icv.c ompd-threads.c # Nvidia PTX OpenACC plugin. @PLUGIN_NVPTX_TRUE@libgomp_plugin_nvptx_version_info = -version-info $(libtool_VERSION) @@ -801,6 +802,7 @@ distclean-compile: @AMDEP_TRUE@@am__include@ @am__quote@./$(DEPDIR)/ompd-icv.Plo@am__quote@ @AMDEP_TRUE@@am__include@ @am__quote@./$(DEPDIR)/ompd-init.Plo@am__quote@ @AMDEP_TRUE@@am__include@ @am__quote@./$(DEPDIR)/ompd-support.Plo@am__quote@ +@AMDEP_TRUE@@am__include@ @am__quote@./$(DEPDIR)/ompd-threads.Plo@am__quote@ @AMDEP_TRUE@@am__include@ @am__quote@./$(DEPDIR)/ordered.Plo@am__quote@ @AMDEP_TRUE@@am__include@ @am__quote@./$(DEPDIR)/parallel.Plo@am__quote@ @AMDEP_TRUE@@am__include@ @am__quote@./$(DEPDIR)/priority_queue.Plo@am__quote@ diff --git a/libgomp/ompd-support.c b/libgomp/ompd-support.c index 27c5ad148e0..5b1afd37788 100644 --- a/libgomp/ompd-support.c +++ b/libgomp/ompd-support.c @@ -33,6 +33,8 @@ const unsigned short gompd_sizeof_gomp_thread_handle __attribute__ ((used)) OMPD_SECTION = 0; #endif +unsigned long gompd_thread_initial_tls_bias __attribute__ ((used)); + /* Get offset of the member m in struct t. */ #define gompd_get_offset(t, m) \ const unsigned short gompd_access_##t##_##m __attribute__ ((used)) \ @@ -67,6 +69,11 @@ gompd_load (void) gompd_state |= OMPD_ENABLED; ompd_dll_locations = &ompd_dll_locations_array[0]; ompd_dll_locations_valid (); + + #if defined(LIBGOMP_USE_PTHREADS) && !defined(GOMP_NEEDS_THREAD_HANDLE) + gompd_thread_initial_tls_bias = (unsigned long) ((char *) &gomp_tls_data + - (char *) pthread_self ()); + #endif } #ifndef __ELF__ diff --git a/libgomp/ompd-threads.c b/libgomp/ompd-threads.c new file mode 100644 index 00000000000..723ef740181 --- /dev/null +++ b/libgomp/ompd-threads.c @@ -0,0 +1,222 @@ +/* Copyright (C) The GNU Toolchain Authors. + Contributed by Ahmed Sayed . + This file is part of the GNU Offloading and Multi Processing Library + (libgomp). + + Libgomp 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; either version 3, or (at your option) + any later version. + + Libgomp 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. + + Under Section 7 of GPL version 3, you are granted additional + permissions described in the GCC Runtime Library Exception, version + 3.1, as published by the Free Software Foundation. + + You should have received a copy of the GNU General Public License and + a copy of the GCC Runtime Library Exception along with this program; + see the files COPYING3 and COPYING.RUNTIME respectively. If not, see + . */ + +/* This file contains the implementation of functions defined in + Section 5.5 ThreadHandles. */ + + +#include "ompd-helper.h" + +ompd_rc_t +ompd_get_thread_in_parallel (ompd_parallel_handle_t *parallel_handle, + int thread_num, + ompd_thread_handle_t **thread_handle) +{ + + if (parallel_handle == NULL) + return ompd_rc_stale_handle; + CHECK (parallel_handle->ah); + + ompd_address_space_context_t *context = parallel_handle->ah->context; + ompd_rc_t ret; + + ompd_word_t team_size_var = 1; + if (parallel_handle->th.address) + gompd_get_team_size (parallel_handle, &team_size_var); + + if (thread_num < 0 || thread_num >= team_size_var) + return ompd_rc_bad_input; + + ompd_word_t temp_offset; + ompd_address_t temp_symbol_addr, symbol_addr = {OMPD_SEGMENT_UNSPECIFIED, 0}; + ompd_addr_t temp_addr; + + ACCESS_VALUE (context, NULL, "gompd_access_gomp_thread_pool_threads", + temp_offset, 1, ret, symbol_addr, temp_symbol_addr, temp_addr); + + symbol_addr.address += thread_num * target_sizes.sizeof_pointer; + + DEREFERENCE (context, NULL, symbol_addr, target_sizes.sizeof_pointer, 1, + temp_addr, ret, 1); + + ret = callbacks->alloc_memory (sizeof (ompd_thread_handle_t), + (void **) thread_handle); + + CHECK_RET (ret); + + if (symbol_addr.address == 0) + return ompd_rc_unsupported; + + (*thread_handle)->th = symbol_addr; + (*thread_handle)->ah = parallel_handle->ah; + return ret; +} + +/* The ompd_get_thread_handle function that maps a native thread to an + OMPD thread handle. */ + +ompd_rc_t +ompd_get_thread_handle (ompd_address_space_handle_t *handle, + ompd_thread_id_t kind, ompd_size_t sizeof_thread_id, + const void *thread_id, + ompd_thread_handle_t **thread_handle) +{ + CHECK (handle); + if (kind != OMPD_THREAD_ID_PTHREAD) + return ompd_rc_unsupported; + + ompd_address_space_context_t *context = handle->context; + ompd_thread_context_t *tcontext; + ompd_rc_t ret; + + ret = callbacks->get_thread_context_for_thread_id (context, kind, + sizeof_thread_id, + thread_id, &tcontext); + CHECK_RET (ret); + + ompd_size_t temp_symbol_size, symbol_size; + ompd_address_t temp_symbol_addr, symbol_addr = {OMPD_SEGMENT_UNSPECIFIED, 0}; + + GET_VALUE (context, NULL, "gompd_sizeof_gomp_thread", symbol_size, + temp_symbol_size, target_sizes.sizeof_short, 1, ret, + temp_symbol_addr); + + GET_VALUE (context, tcontext, "gomp_tls_data", symbol_addr.address, + temp_symbol_addr.address, symbol_size, 1, ret, symbol_addr); + + ret = callbacks->alloc_memory (sizeof (ompd_thread_handle_t), + (void **) thread_handle); + + CHECK_RET (ret); + + (*thread_handle)->ah = handle; + (*thread_handle)->th = symbol_addr; + (*thread_handle)->thread_context = tcontext; + return ret; +} + + +ompd_rc_t +ompd_rel_thread_handle (ompd_thread_handle_t *thread_handle) +{ + if (thread_handle == NULL) + return ompd_rc_stale_handle; + + ompd_rc_t ret; + ret = callbacks->free_memory ((void *) thread_handle); + if (ret != ompd_rc_ok) + return ret; + + return ompd_rc_ok; +} + + +/* Return -1, 0 or 1 for thread_handle_1 <, == or > thread_handle_2. */ +ompd_rc_t +ompd_thread_handle_compare (ompd_thread_handle_t *thread_handle_1, + ompd_thread_handle_t *thread_handle_2, + int *cmp_value) +{ + + if (thread_handle_1 == NULL || thread_handle_2 == NULL) + return ompd_rc_stale_handle; + if (cmp_value == NULL) + return ompd_rc_bad_input; + if (thread_handle_1->ah->kind != thread_handle_2->ah->kind) + return ompd_rc_bad_input; + + if (thread_handle_1->th.address < thread_handle_2->th.address) + *cmp_value = -1; + else if (thread_handle_1->th.address > thread_handle_2->th.address) + *cmp_value = 1; + else + *cmp_value = 0; + + return ompd_rc_ok; +} + + +ompd_rc_t +ompd_get_thread_id (ompd_thread_handle_t *thread_handle, ompd_thread_id_t kind, + ompd_size_t sizeof_thread_id, void *thread_id) +{ + if (kind != OMPD_THREAD_ID_PTHREAD) + return ompd_rc_unsupported; + if (thread_id == NULL) + return ompd_rc_bad_input; + if (thread_handle == NULL) + return ompd_rc_stale_handle; + + CHECK (thread_handle->ah); + ompd_address_space_context_t *context = thread_handle->ah->context; + + ompd_rc_t ret; + ompd_address_t taddr = thread_handle->th; + ompd_address_t temp_symbol_addr, symbol_addr = {OMPD_SEGMENT_UNSPECIFIED, 0}; + ompd_size_t temp_symbol_size, symbol_size; + ompd_word_t temp_offset, offset; + + GET_VALUE (context, NULL, "gompd_sizeof_gomp_thread_handle", symbol_size, + temp_symbol_size, target_sizes.sizeof_short, 1, ret, symbol_addr); + + if (symbol_size == 0) + { + GET_VALUE (context, NULL, "gompd_thread_initial_tls_bias", offset, + temp_offset, target_sizes.sizeof_long, 1, ret, symbol_addr); + + ret = callbacks->symbol_addr_lookup (context, NULL,"gomp_tls_data", + &symbol_addr, NULL); + ret = callbacks->device_to_host (context, &temp_symbol_addr.address, + target_sizes.sizeof_long_long, 1, + &symbol_addr.address); + CHECK_RET (ret); + + taddr.address = symbol_addr.address + offset; + ret = callbacks->read_memory (context, NULL, &taddr, + target_sizes.sizeof_long_long, thread_id); + } + else + { + if (sizeof_thread_id != symbol_size) + return ompd_rc_bad_input; + + GET_VALUE (context, NULL, "gompd_access_gomp_thread_handle", offset, + temp_offset, target_sizes.sizeof_short, 1, ret, symbol_addr); + taddr.address += offset; + + ret = callbacks->read_memory (context, NULL, &taddr, symbol_size, + thread_id); + } + return ret; +} + + +/* OMPD doesn't support GPUs for now. */ +ompd_rc_t ompd_get_device_from_thread (ompd_thread_handle_t *thread_handle, + ompd_address_space_handle_t **device) +{ + if (thread_handle == NULL) + return ompd_rc_stale_handle; + return ompd_rc_unsupported; +} diff --git a/libgomp/team.c b/libgomp/team.c index d53246961b7..9a84dc18bdb 100644 --- a/libgomp/team.c +++ b/libgomp/team.c @@ -77,6 +77,7 @@ gomp_thread_start (void *xdata) void *local_data; ompd_bp_thread_begin (); + #if defined HAVE_TLS || defined USE_EMUTLS thr = &gomp_tls_data; #else @@ -313,6 +314,8 @@ gomp_free_thread (void *arg __attribute__((unused))) gomp_end_task (); free (task); } + + ompd_bp_thread_end (); } /* Launch a team. */