1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768697071727374757677787980818283848586878889909192939495969798991001011021031041051061071081091101111121131141151161171181191201211221231241251261271281291301311321331341351361371381391401411421431441451461471481491501511521531541551561571581591601611621631641651661671681691701711721731741751761771781791801811821831841851861871881891901911921931941951961971981992002012022032042052062072082092102112122132142152162172182192202212222232242252262272282292302312322332342352362372382392402412422432442452462472482492502512522532542552562572582592602612622632642652662672682692702712722732742752762772782792802812822832842852862872882892902912922932942952962972982993003013023033043053063073083093103113123133143153163173183193203213223233243253263273283293303313323333343353363373383393403413423433443453463473483493503513523533543553563573583593603613623633643653663673683693703713723733743753763773783793803813823833843853863873883893903913923933943953963973983994004014024034044054064074084094104114124134144154164174184194204214224234244254264274284294304314324334344354364374384394404414424434444454464474484494504514524534544554564574584594604614624634644654664674684694704714724734744754764774784794804814824834844854864874884894904914924934944954964974984995005015025035045055065075085095105115125135145155165175185195205215225235245255265275285295305315325335345355365375385395405415425435445455465475485495505515525535545555565575585595605615625635645655665675685695705715725735745755765775785795805815825835845855865875885895905915925935945955965975985996006016026036046056066076086096106116126136146156166176186196206216226236246256266276286296306316326336346356366376386396406416426436446456466476486496506516526536546556566576586596606616626636646656666676686696706716726736746756766776786796806816826836846856866876886896906916926936946956966976986997007017027037047057067077087097107117127137147157167177187197207217227237247257267277287297307317327337347357367377387397407417427437447457467477487497507517527537547557567577587597607617627637647657667677687697707717727737747757767777787797807817827837847857867877887897907917927937947957967977987998008018028038048058068078088098108118128138148158168178188198208218228238248258268278288298308318328338348358368378388398408418428438448458468478488498508518528538548558568578588598608618628638648658668678688698708718728738748758768778788798808818828838848858868878888898908918928938948958968978988999009019029039049059069079089099109119129139149159169179189199209219229239249259269279289299309319329339349359369379389399409419429439449459469479489499509519529539549559569579589599609619629639649659669679689699709719729739749759769779789799809819829839849859869879889899909919929939949959969979989991000100110021003100410051006100710081009101010111012101310141015101610171018101910201021102210231024102510261027102810291030103110321033103410351036103710381039104010411042104310441045104610471048104910501051105210531054105510561057105810591060106110621063106410651066106710681069107010711072 |
- /* StarPU --- Runtime system for heterogeneous multicore architectures.
- *
- * Copyright (C) 2009-2017 Université de Bordeaux
- * Copyright (C) 2010, 2011, 2012, 2013, 2014, 2016, 2017 CNRS
- * Copyright (C) 2016 Inria
- *
- * StarPU is free software; you can redistribute it and/or modify
- * it under the terms of the GNU Lesser General Public License as published by
- * the Free Software Foundation; either version 2.1 of the License, or (at
- * your option) any later version.
- *
- * StarPU 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 Lesser General Public License in COPYING.LGPL for more details.
- */
- #ifndef __FXT_H__
- #define __FXT_H__
- #ifndef _GNU_SOURCE
- #define _GNU_SOURCE /* ou _BSD_SOURCE ou _SVID_SOURCE */
- #endif
- #include <string.h>
- #include <sys/types.h>
- #include <stdlib.h>
- #include <common/config.h>
- #ifdef HAVE_UNISTD_H
- #include <unistd.h>
- #endif
- #include <common/utils.h>
- #include <starpu.h>
- /* some key to identify the worker kind */
- #define _STARPU_FUT_APPS_KEY 0x100
- #define _STARPU_FUT_CPU_KEY 0x101
- #define _STARPU_FUT_CUDA_KEY 0x102
- #define _STARPU_FUT_OPENCL_KEY 0x103
- #define _STARPU_FUT_MIC_KEY 0x104
- #define _STARPU_FUT_SCC_KEY 0x105
- #define _STARPU_FUT_MPI_KEY 0x106
- #define _STARPU_FUT_WORKER_INIT_START 0x5100
- #define _STARPU_FUT_WORKER_INIT_END 0x5101
- #define _STARPU_FUT_START_CODELET_BODY 0x5102
- #define _STARPU_FUT_END_CODELET_BODY 0x5103
- #define _STARPU_FUT_JOB_PUSH 0x5104
- #define _STARPU_FUT_JOB_POP 0x5105
- #define _STARPU_FUT_UPDATE_TASK_CNT 0x5106
- #define _STARPU_FUT_START_FETCH_INPUT_ON_TID 0x5107
- #define _STARPU_FUT_END_FETCH_INPUT_ON_TID 0x5108
- #define _STARPU_FUT_START_PUSH_OUTPUT_ON_TID 0x5109
- #define _STARPU_FUT_END_PUSH_OUTPUT_ON_TID 0x5110
- #define _STARPU_FUT_TAG 0x5111
- #define _STARPU_FUT_TAG_DEPS 0x5112
- #define _STARPU_FUT_TASK_DEPS 0x5113
- #define _STARPU_FUT_DATA_COPY 0x5114
- #define _STARPU_FUT_WORK_STEALING 0x5115
- #define _STARPU_FUT_WORKER_DEINIT_START 0x5116
- #define _STARPU_FUT_WORKER_DEINIT_END 0x5117
- #define _STARPU_FUT_WORKER_SLEEP_START 0x5118
- #define _STARPU_FUT_WORKER_SLEEP_END 0x5119
- #define _STARPU_FUT_TASK_SUBMIT 0x511a
- #define _STARPU_FUT_CODELET_DATA_HANDLE 0x511b
- #define _STARPU_FUT_MODEL_NAME 0x511c
- #define _STARPU_FUT_USER_DEFINED_START 0x5120
- #define _STARPU_FUT_USER_DEFINED_END 0x5121
- #define _STARPU_FUT_NEW_MEM_NODE 0x5122
- #define _STARPU_FUT_START_CALLBACK 0x5123
- #define _STARPU_FUT_END_CALLBACK 0x5124
- #define _STARPU_FUT_TASK_DONE 0x5125
- #define _STARPU_FUT_TAG_DONE 0x5126
- #define _STARPU_FUT_START_ALLOC 0x5127
- #define _STARPU_FUT_END_ALLOC 0x5128
- #define _STARPU_FUT_START_ALLOC_REUSE 0x5129
- #define _STARPU_FUT_END_ALLOC_REUSE 0x5130
- #define _STARPU_FUT_USED_MEM 0x512a
- #define _STARPU_FUT_START_MEMRECLAIM 0x5131
- #define _STARPU_FUT_END_MEMRECLAIM 0x5132
- #define _STARPU_FUT_START_DRIVER_COPY 0x5133
- #define _STARPU_FUT_END_DRIVER_COPY 0x5134
- #define _STARPU_FUT_START_DRIVER_COPY_ASYNC 0x5135
- #define _STARPU_FUT_END_DRIVER_COPY_ASYNC 0x5136
- #define _STARPU_FUT_START_PROGRESS_ON_TID 0x5137
- #define _STARPU_FUT_END_PROGRESS_ON_TID 0x5138
- #define _STARPU_FUT_USER_EVENT 0x5139
- #define _STARPU_FUT_SET_PROFILING 0x513a
- #define _STARPU_FUT_TASK_WAIT_FOR_ALL 0x513b
- #define _STARPU_FUT_EVENT 0x513c
- #define _STARPU_FUT_THREAD_EVENT 0x513d
- #define _STARPU_FUT_CODELET_DETAILS 0x513e
- #define _STARPU_FUT_CODELET_DATA 0x513f
- #define _STARPU_FUT_LOCKING_MUTEX 0x5140
- #define _STARPU_FUT_MUTEX_LOCKED 0x5141
- #define _STARPU_FUT_UNLOCKING_MUTEX 0x5142
- #define _STARPU_FUT_MUTEX_UNLOCKED 0x5143
- #define _STARPU_FUT_TRYLOCK_MUTEX 0x5144
- #define _STARPU_FUT_RDLOCKING_RWLOCK 0x5145
- #define _STARPU_FUT_RWLOCK_RDLOCKED 0x5146
- #define _STARPU_FUT_WRLOCKING_RWLOCK 0x5147
- #define _STARPU_FUT_RWLOCK_WRLOCKED 0x5148
- #define _STARPU_FUT_UNLOCKING_RWLOCK 0x5149
- #define _STARPU_FUT_RWLOCK_UNLOCKED 0x514a
- #define _STARPU_FUT_LOCKING_SPINLOCK 0x514b
- #define _STARPU_FUT_SPINLOCK_LOCKED 0x514c
- #define _STARPU_FUT_UNLOCKING_SPINLOCK 0x514d
- #define _STARPU_FUT_SPINLOCK_UNLOCKED 0x514e
- #define _STARPU_FUT_TRYLOCK_SPINLOCK 0x514f
- #define _STARPU_FUT_COND_WAIT_BEGIN 0x5150
- #define _STARPU_FUT_COND_WAIT_END 0x5151
- #define _STARPU_FUT_MEMORY_FULL 0x5152
- #define _STARPU_FUT_DATA_LOAD 0x5153
- #define _STARPU_FUT_START_UNPARTITION_ON_TID 0x5154
- #define _STARPU_FUT_END_UNPARTITION_ON_TID 0x5155
- #define _STARPU_FUT_START_FREE 0x5156
- #define _STARPU_FUT_END_FREE 0x5157
- #define _STARPU_FUT_START_WRITEBACK 0x5158
- #define _STARPU_FUT_END_WRITEBACK 0x5159
- #define _STARPU_FUT_SCHED_COMPONENT_PUSH_PRIO 0x515a
- #define _STARPU_FUT_SCHED_COMPONENT_POP_PRIO 0x515b
- #define _STARPU_FUT_START_WRITEBACK_ASYNC 0x515c
- #define _STARPU_FUT_END_WRITEBACK_ASYNC 0x515d
- #define _STARPU_FUT_HYPERVISOR_BEGIN 0x5160
- #define _STARPU_FUT_HYPERVISOR_END 0x5161
- #define _STARPU_FUT_BARRIER_WAIT_BEGIN 0x5162
- #define _STARPU_FUT_BARRIER_WAIT_END 0x5163
- #define _STARPU_FUT_WORKER_SCHEDULING_START 0x5164
- #define _STARPU_FUT_WORKER_SCHEDULING_END 0x5165
- #define _STARPU_FUT_WORKER_SCHEDULING_PUSH 0x5166
- #define _STARPU_FUT_WORKER_SCHEDULING_POP 0x5167
- #define _STARPU_FUT_START_EXECUTING 0x5168
- #define _STARPU_FUT_END_EXECUTING 0x5169
- #define _STARPU_FUT_SCHED_COMPONENT_NEW 0x516a
- #define _STARPU_FUT_SCHED_COMPONENT_CONNECT 0x516b
- #define _STARPU_FUT_SCHED_COMPONENT_PUSH 0x516c
- #define _STARPU_FUT_SCHED_COMPONENT_PULL 0x516d
- #define _STARPU_FUT_TASK_SUBMIT_START 0x516e
- #define _STARPU_FUT_TASK_SUBMIT_END 0x516f
- #define _STARPU_FUT_TASK_BUILD_START 0x5170
- #define _STARPU_FUT_TASK_BUILD_END 0x5171
- #define _STARPU_FUT_TASK_MPI_DECODE_START 0x5172
- #define _STARPU_FUT_TASK_MPI_DECODE_END 0x5173
- #define _STARPU_FUT_TASK_MPI_PRE_START 0x5174
- #define _STARPU_FUT_TASK_MPI_PRE_END 0x5175
- #define _STARPU_FUT_TASK_MPI_POST_START 0x5176
- #define _STARPU_FUT_TASK_MPI_POST_END 0x5177
- #define _STARPU_FUT_TASK_WAIT_START 0x5178
- #define _STARPU_FUT_TASK_WAIT_END 0x5179
- #define _STARPU_FUT_TASK_WAIT_FOR_ALL_START 0x517a
- #define _STARPU_FUT_TASK_WAIT_FOR_ALL_END 0x517b
- #define _STARPU_FUT_HANDLE_DATA_REGISTER 0x517c
- #define _STARPU_FUT_DATA_INVALIDATE 0x517d
- #define _STARPU_FUT_START_FETCH_INPUT 0x517e
- #define _STARPU_FUT_END_FETCH_INPUT 0x517f
- #ifdef STARPU_USE_FXT
- #include <fxt/fxt.h>
- #include <fxt/fut.h>
- /* Some versions of FxT do not include the declaration of the function */
- #ifdef HAVE_ENABLE_FUT_FLUSH
- #if !HAVE_DECL_ENABLE_FUT_FLUSH
- void enable_fut_flush();
- #endif
- #endif
- #ifdef HAVE_FUT_SET_FILENAME
- #if !HAVE_DECL_FUT_SET_FILENAME
- void fut_set_filename(char *filename);
- #endif
- #endif
- extern int _starpu_fxt_started;
- extern starpu_pthread_mutex_t _starpu_fxt_started_mutex;
- extern starpu_pthread_cond_t _starpu_fxt_started_cond;
- static inline void _starpu_fxt_wait_initialisation()
- {
- STARPU_PTHREAD_MUTEX_LOCK(&_starpu_fxt_started_mutex);
- while (!_starpu_fxt_started)
- STARPU_PTHREAD_COND_WAIT(&_starpu_fxt_started_cond, &_starpu_fxt_started_mutex);
- STARPU_PTHREAD_MUTEX_UNLOCK(&_starpu_fxt_started_mutex);
- }
- long _starpu_gettid(void);
- /* Initialize the FxT library. */
- void _starpu_fxt_init_profiling(unsigned trace_buffer_size);
- /* Stop the FxT library, and generate the trace file. */
- void _starpu_stop_fxt_profiling(void);
- /* Associate the current processing unit to the identifier of the LWP that runs
- * the worker. */
- void _starpu_fxt_register_thread(unsigned);
- #ifdef FUT_NEEDS_COMMIT
- #define _STARPU_FUT_COMMIT(size) fut_commitstampedbuffer(size)
- #else
- #define _STARPU_FUT_COMMIT(size) do { } while (0)
- #endif
- #ifdef FUT_DO_PROBE1STR
- #define _STARPU_FUT_DO_PROBE1STR(CODE, P1, str) FUT_DO_PROBE1STR(CODE, P1, str)
- #else
- /* Sometimes we need something a little more specific than the wrappers from
- * FxT: these macro permit to put add an event with 3 (or 4) numbers followed
- * by a string. */
- #define _STARPU_FUT_DO_PROBE1STR(CODE, P1, str) \
- do { \
- if(fut_active) { \
- /* No more than FXT_MAX_PARAMS args are allowed */ \
- /* we add a \0 just in case ... */ \
- size_t len = STARPU_MIN(strlen(str)+1, (FXT_MAX_PARAMS - 1)*sizeof(unsigned long));\
- unsigned nbargs_str = (len + sizeof(unsigned long) - 1)/(sizeof(unsigned long));\
- unsigned nbargs = 1 + nbargs_str; \
- size_t total_len = FUT_SIZE(nbargs); \
- unsigned long *futargs = \
- fut_getstampedbuffer(FUT_CODE(CODE, nbargs), total_len);\
- *(futargs++) = (unsigned long)(P1); \
- snprintf((char *)futargs, len, "%s", str); \
- ((char *)futargs)[len - 1] = '\0'; \
- _STARPU_FUT_COMMIT(total_len); \
- } \
- } while (0);
- #endif
- #ifdef FUT_DO_PROBE2STR
- #define _STARPU_FUT_DO_PROBE2STR(CODE, P1, P2, str) FUT_DO_PROBE2STR(CODE, P1, P2, str)
- #else
- /* Sometimes we need something a little more specific than the wrappers from
- * FxT: these macro permit to put add an event with 3 (or 4) numbers followed
- * by a string. */
- #define _STARPU_FUT_DO_PROBE2STR(CODE, P1, P2, str) \
- do { \
- if(fut_active) { \
- /* No more than FXT_MAX_PARAMS args are allowed */ \
- /* we add a \0 just in case ... */ \
- size_t len = STARPU_MIN(strlen(str)+1, (FXT_MAX_PARAMS - 2)*sizeof(unsigned long));\
- unsigned nbargs_str = (len + sizeof(unsigned long) - 1)/(sizeof(unsigned long));\
- unsigned nbargs = 2 + nbargs_str; \
- size_t total_len = FUT_SIZE(nbargs); \
- unsigned long *futargs = \
- fut_getstampedbuffer(FUT_CODE(CODE, nbargs), total_len);\
- *(futargs++) = (unsigned long)(P1); \
- *(futargs++) = (unsigned long)(P2); \
- snprintf((char *)futargs, len, "%s", str); \
- ((char *)futargs)[len - 1] = '\0'; \
- _STARPU_FUT_COMMIT(total_len); \
- } \
- } while (0);
- #endif
- #ifdef FUT_DO_PROBE3STR
- #define _STARPU_FUT_DO_PROBE3STR(CODE, P1, P2, P3, str) FUT_DO_PROBE3STR(CODE, P1, P2, P3, str)
- #else
- #define _STARPU_FUT_DO_PROBE3STR(CODE, P1, P2, P3, str) \
- do { \
- if(fut_active) { \
- /* No more than FXT_MAX_PARAMS args are allowed */ \
- /* we add a \0 just in case ... */ \
- size_t len = STARPU_MIN(strlen(str)+1, (FXT_MAX_PARAMS - 3)*sizeof(unsigned long));\
- unsigned nbargs_str = (len + sizeof(unsigned long) - 1)/(sizeof(unsigned long));\
- unsigned nbargs = 3 + nbargs_str; \
- size_t total_len = FUT_SIZE(nbargs); \
- unsigned long *futargs = \
- fut_getstampedbuffer(FUT_CODE(CODE, nbargs), total_len);\
- *(futargs++) = (unsigned long)(P1); \
- *(futargs++) = (unsigned long)(P2); \
- *(futargs++) = (unsigned long)(P3); \
- snprintf((char *)futargs, len, "%s", str); \
- ((char *)futargs)[len - 1] = '\0'; \
- _STARPU_FUT_COMMIT(total_len); \
- } \
- } while (0);
- #endif
- #ifdef FUT_DO_PROBE4STR
- #define _STARPU_FUT_DO_PROBE4STR(CODE, P1, P2, P3, P4, str) FUT_DO_PROBE4STR(CODE, P1, P2, P3, P4, str)
- #else
- #define _STARPU_FUT_DO_PROBE4STR(CODE, P1, P2, P3, P4, str) \
- do { \
- if(fut_active) { \
- /* No more than FXT_MAX_PARAMS args are allowed */ \
- /* we add a \0 just in case ... */ \
- size_t len = STARPU_MIN(strlen(str)+1, (FXT_MAX_PARAMS - 4)*sizeof(unsigned long));\
- unsigned nbargs_str = (len + sizeof(unsigned long) - 1)/(sizeof(unsigned long));\
- unsigned nbargs = 4 + nbargs_str; \
- size_t total_len = FUT_SIZE(nbargs); \
- unsigned long *futargs = \
- fut_getstampedbuffer(FUT_CODE(CODE, nbargs), total_len);\
- *(futargs++) = (unsigned long)(P1); \
- *(futargs++) = (unsigned long)(P2); \
- *(futargs++) = (unsigned long)(P3); \
- *(futargs++) = (unsigned long)(P4); \
- snprintf((char *)futargs, len, "%s", str); \
- ((char *)futargs)[len - 1] = '\0'; \
- _STARPU_FUT_COMMIT(total_len); \
- } \
- } while (0);
- #endif
- #ifdef FUT_DO_PROBE5STR
- #define _STARPU_FUT_DO_PROBE5STR(CODE, P1, P2, P3, P4, P5, str) FUT_DO_PROBE5STR(CODE, P1, P2, P3, P4, P5, str)
- #else
- #define _STARPU_FUT_DO_PROBE5STR(CODE, P1, P2, P3, P4, P5, str) \
- do { \
- if(fut_active) { \
- /* No more than FXT_MAX_PARAMS args are allowed */ \
- /* we add a \0 just in case ... */ \
- size_t len = STARPU_MIN(strlen(str)+1, (FXT_MAX_PARAMS - 5)*sizeof(unsigned long));\
- unsigned nbargs_str = (len + sizeof(unsigned long) - 1)/(sizeof(unsigned long));\
- unsigned nbargs = 5 + nbargs_str; \
- size_t total_len = FUT_SIZE(nbargs); \
- unsigned long *futargs = \
- fut_getstampedbuffer(FUT_CODE(CODE, nbargs), total_len);\
- *(futargs++) = (unsigned long)(P1); \
- *(futargs++) = (unsigned long)(P2); \
- *(futargs++) = (unsigned long)(P3); \
- *(futargs++) = (unsigned long)(P4); \
- *(futargs++) = (unsigned long)(P5); \
- snprintf((char *)futargs, len, "%s", str); \
- ((char *)futargs)[len - 1] = '\0'; \
- _STARPU_FUT_COMMIT(total_len); \
- } \
- } while (0);
- #endif
- #ifdef FUT_DO_PROBE6STR
- #define _STARPU_FUT_DO_PROBE6STR(CODE, P1, P2, P3, P4, P5, P6, str) FUT_DO_PROBE6STR(CODE, P1, P2, P3, P4, P5, P6, str)
- #else
- #define _STARPU_FUT_DO_PROBE6STR(CODE, P1, P2, P3, P4, P5, P6, str) \
- do { \
- if(fut_active) { \
- /* No more than FXT_MAX_PARAMS args are allowed */ \
- /* we add a \0 just in case ... */ \
- size_t len = STARPU_MIN(strlen(str)+1, (FXT_MAX_PARAMS - 6)*sizeof(unsigned long));\
- unsigned nbargs_str = (len + sizeof(unsigned long) - 1)/(sizeof(unsigned long));\
- unsigned nbargs = 6 + nbargs_str; \
- size_t total_len = FUT_SIZE(nbargs); \
- unsigned long *futargs = \
- fut_getstampedbuffer(FUT_CODE(CODE, nbargs), total_len);\
- *(futargs++) = (unsigned long)(P1); \
- *(futargs++) = (unsigned long)(P2); \
- *(futargs++) = (unsigned long)(P3); \
- *(futargs++) = (unsigned long)(P4); \
- *(futargs++) = (unsigned long)(P5); \
- *(futargs++) = (unsigned long)(P6); \
- snprintf((char *)futargs, len, "%s", str); \
- ((char *)futargs)[len - 1] = '\0'; \
- _STARPU_FUT_COMMIT(total_len); \
- } \
- } while (0);
- #endif
- #ifdef FUT_DO_PROBE7STR
- #define _STARPU_FUT_DO_PROBE7STR(CODE, P1, P2, P3, P4, P5, P6, P7, str) FUT_DO_PROBE7STR(CODE, P1, P2, P3, P4, P5, P6, P7, str)
- #else
- #define _STARPU_FUT_DO_PROBE7STR(CODE, P1, P2, P3, P4, P5, P6, P7, str) \
- do { \
- if(fut_active) { \
- /* No more than FXT_MAX_PARAMS args are allowed */ \
- /* we add a \0 just in case ... */ \
- size_t len = STARPU_MIN(strlen(str)+1, (FXT_MAX_PARAMS - 7)*sizeof(unsigned long));\
- unsigned nbargs_str = (len + sizeof(unsigned long) - 1)/(sizeof(unsigned long));\
- unsigned nbargs = 7 + nbargs_str; \
- size_t total_len = FUT_SIZE(nbargs); \
- unsigned long *futargs = \
- fut_getstampedbuffer(FUT_CODE(CODE, nbargs), total_len);\
- *(futargs++) = (unsigned long)(P1); \
- *(futargs++) = (unsigned long)(P2); \
- *(futargs++) = (unsigned long)(P3); \
- *(futargs++) = (unsigned long)(P4); \
- *(futargs++) = (unsigned long)(P5); \
- *(futargs++) = (unsigned long)(P6); \
- *(futargs++) = (unsigned long)(P7); \
- snprintf((char *)futargs, len, "%s", str); \
- ((char *)futargs)[len - 1] = '\0'; \
- _STARPU_FUT_COMMIT(total_len); \
- } \
- } while (0);
- #endif
- #ifndef FUT_RAW_PROBE7
- #define FUT_RAW_PROBE7(CODE,P1,P2,P3,P4,P5,P6,P7) do { \
- if(fut_active) { \
- unsigned long *__args __attribute__((unused))= \
- fut_getstampedbuffer(CODE, \
- FUT_SIZE(7)); \
- *(__args++)=(unsigned long)(P1);*(__args++)=(unsigned long)(P2);*(__args++)=(unsigned long)(P3);*(__args++)=(unsigned long)(P4);*(__args++)=(unsigned long)(P5);*(__args++)=(unsigned long)(P6);*(__args++)=(unsigned long)(P7); \
- _STARPU_FUT_COMMIT(FUT_SIZE(7)); \
- } \
- } while (0)
- #endif
- #ifndef FUT_DO_PROBE7
- #define FUT_DO_PROBE7(CODE,P1,P2,P3,P4,P5,P6,P7) do { \
- FUT_RAW_PROBE7(FUT_CODE(CODE, 7),P1,P2,P3,P4,P5,P6,P7); \
- } while (0)
- #endif
- /* workerkind = _STARPU_FUT_CPU_KEY for instance */
- #define _STARPU_TRACE_NEW_MEM_NODE(nodeid) \
- FUT_DO_PROBE2(_STARPU_FUT_NEW_MEM_NODE, nodeid, _starpu_gettid());
- #define _STARPU_TRACE_WORKER_INIT_START(workerkind, workerid, devid, memnode, bindid, sync) \
- FUT_DO_PROBE7(_STARPU_FUT_WORKER_INIT_START, workerkind, workerid, devid, memnode, bindid, sync, _starpu_gettid());
- #define _STARPU_TRACE_WORKER_INIT_END(__workerid) \
- FUT_DO_PROBE2(_STARPU_FUT_WORKER_INIT_END, _starpu_gettid(), (__workerid));
- #define _STARPU_TRACE_START_CODELET_BODY(job, nimpl, perf_arch, workerid) \
- do { \
- const char *model_name = _starpu_job_get_model_name((job)), *name = _starpu_job_get_task_name((job)); \
- if (name) \
- { \
- /* we include the task name */ \
- _STARPU_FUT_DO_PROBE5STR(_STARPU_FUT_START_CODELET_BODY, (job)->job_id, ((job)->task)->sched_ctx, workerid, starpu_worker_get_memory_node(workerid), 1, name); \
- if (model_name && strcmp(model_name, name)) \
- _STARPU_FUT_DO_PROBE1STR(_STARPU_FUT_MODEL_NAME, (job)->job_id, model_name); \
- } \
- else { \
- FUT_DO_PROBE5(_STARPU_FUT_START_CODELET_BODY, (job)->job_id, ((job)->task)->sched_ctx, workerid, starpu_worker_get_memory_node(workerid), 0); \
- } \
- { \
- if ((job)->task->cl) \
- { \
- const int __nbuffers = STARPU_TASK_GET_NBUFFERS((job)->task); \
- char __buf[FXT_MAX_PARAMS*sizeof(long)]; \
- int __i; \
- for (__i = 0; __i < __nbuffers; __i++) \
- { \
- starpu_data_handle_t __handle = STARPU_TASK_GET_HANDLE((job)->task, __i); \
- void *__interface = _STARPU_TASK_GET_INTERFACES((job)->task)[__i]; \
- if (__handle->ops->describe) \
- { \
- __handle->ops->describe(__interface, __buf, sizeof(__buf)); \
- _STARPU_FUT_DO_PROBE1STR(_STARPU_FUT_CODELET_DATA, workerid, __buf); \
- } \
- FUT_DO_PROBE4(_STARPU_FUT_CODELET_DATA_HANDLE, (job)->job_id, (__handle), _starpu_data_get_size(__handle), STARPU_TASK_GET_MODE((job)->task, __i)); \
- } \
- } \
- const size_t __job_size = _starpu_job_get_data_size((job)->task->cl?(job)->task->cl->model:NULL, perf_arch, nimpl, (job)); \
- const uint32_t __job_hash = _starpu_compute_buffers_footprint((job)->task->cl?(job)->task->cl->model:NULL, perf_arch, nimpl, (job));\
- FUT_DO_PROBE7(_STARPU_FUT_CODELET_DETAILS, ((job)->task)->sched_ctx, __job_size, __job_hash, (job)->task->flops / 1000, (job)->task->tag_id, workerid, ((job)->job_id)); \
- } \
- } while(0);
- #define _STARPU_TRACE_END_CODELET_BODY(job, nimpl, perf_arch, workerid) \
- do { \
- const size_t job_size = _starpu_job_get_data_size((job)->task->cl?(job)->task->cl->model:NULL, perf_arch, nimpl, (job)); \
- const uint32_t job_hash = _starpu_compute_buffers_footprint((job)->task->cl?(job)->task->cl->model:NULL, perf_arch, nimpl, (job));\
- char _archname[32]=""; \
- starpu_perfmodel_get_arch_name(perf_arch, _archname, 32, 0); \
- _STARPU_FUT_DO_PROBE4STR(_STARPU_FUT_END_CODELET_BODY, (job)->job_id, (job_size), (job_hash), workerid, _archname); \
- } while(0);
- #define _STARPU_TRACE_START_EXECUTING() \
- FUT_DO_PROBE1(_STARPU_FUT_START_EXECUTING, _starpu_gettid());
- #define _STARPU_TRACE_END_EXECUTING() \
- FUT_DO_PROBE1(_STARPU_FUT_END_EXECUTING, _starpu_gettid());
- #define _STARPU_TRACE_START_CALLBACK(job) \
- FUT_DO_PROBE2(_STARPU_FUT_START_CALLBACK, job, _starpu_gettid());
- #define _STARPU_TRACE_END_CALLBACK(job) \
- FUT_DO_PROBE2(_STARPU_FUT_END_CALLBACK, job, _starpu_gettid());
- #define _STARPU_TRACE_JOB_PUSH(task, prio) \
- FUT_DO_PROBE3(_STARPU_FUT_JOB_PUSH, task, prio, _starpu_gettid());
- #define _STARPU_TRACE_JOB_POP(task, prio) \
- FUT_DO_PROBE3(_STARPU_FUT_JOB_POP, task, prio, _starpu_gettid());
- #define _STARPU_TRACE_UPDATE_TASK_CNT(counter) \
- FUT_DO_PROBE2(_STARPU_FUT_UPDATE_TASK_CNT, counter, _starpu_gettid())
- #define _STARPU_TRACE_START_FETCH_INPUT(job) \
- FUT_DO_PROBE2(_STARPU_FUT_START_FETCH_INPUT_ON_TID, job, _starpu_gettid());
- #define _STARPU_TRACE_END_FETCH_INPUT(job) \
- FUT_DO_PROBE2(_STARPU_FUT_END_FETCH_INPUT_ON_TID, job, _starpu_gettid());
- #define _STARPU_TRACE_START_PUSH_OUTPUT(job) \
- FUT_DO_PROBE2(_STARPU_FUT_START_PUSH_OUTPUT_ON_TID, job, _starpu_gettid());
- #define _STARPU_TRACE_END_PUSH_OUTPUT(job) \
- FUT_DO_PROBE2(_STARPU_FUT_END_PUSH_OUTPUT_ON_TID, job, _starpu_gettid());
- #define _STARPU_TRACE_WORKER_END_FETCH_INPUT(job, id) \
- FUT_DO_PROBE2(_STARPU_FUT_END_FETCH_INPUT, job, id);
- #define _STARPU_TRACE_WORKER_START_FETCH_INPUT(job, id) \
- FUT_DO_PROBE2(_STARPU_FUT_START_FETCH_INPUT, job, id);
- #define _STARPU_TRACE_TAG(tag, job) \
- FUT_DO_PROBE2(_STARPU_FUT_TAG, tag, (job)->job_id)
- #define _STARPU_TRACE_TAG_DEPS(tag_child, tag_father) \
- FUT_DO_PROBE2(_STARPU_FUT_TAG_DEPS, tag_child, tag_father)
- #define _STARPU_TRACE_TASK_DEPS(job_prev, job_succ) \
- FUT_DO_PROBE2(_STARPU_FUT_TASK_DEPS, (job_prev)->job_id, (job_succ)->job_id)
- #define _STARPU_TRACE_GHOST_TASK_DEPS(ghost_prev_id, job_succ_id) \
- FUT_DO_PROBE2(_STARPU_FUT_TASK_DEPS, (ghost_prev_id), (job_succ_id))
- #define _STARPU_TRACE_TASK_DONE(job) \
- do { \
- unsigned exclude_from_dag = (job)->exclude_from_dag; \
- const char *model_name = _starpu_job_get_task_name((job)); \
- if (model_name) \
- { \
- _STARPU_FUT_DO_PROBE4STR(_STARPU_FUT_TASK_DONE, (job)->job_id, _starpu_gettid(), (long unsigned)exclude_from_dag, 1, model_name);\
- } \
- else { \
- FUT_DO_PROBE4(_STARPU_FUT_TASK_DONE, (job)->job_id, _starpu_gettid(), (long unsigned)exclude_from_dag, 0);\
- } \
- } while(0);
- #define _STARPU_TRACE_TAG_DONE(tag) \
- do { \
- struct _starpu_job *job = (tag)->job; \
- const char *model_name = _starpu_job_get_task_name((job)); \
- if (model_name) \
- { \
- _STARPU_FUT_DO_PROBE3STR(_STARPU_FUT_TAG_DONE, (tag)->id, _starpu_gettid(), 1, model_name); \
- } \
- else { \
- FUT_DO_PROBE3(_STARPU_FUT_TAG_DONE, (tag)->id, _starpu_gettid(), 0);\
- } \
- } while(0);
- #define _STARPU_TRACE_DATA_COPY(src_node, dst_node, size) \
- FUT_DO_PROBE3(_STARPU_FUT_DATA_COPY, src_node, dst_node, size)
- #define _STARPU_TRACE_START_DRIVER_COPY(src_node, dst_node, size, com_id, prefetch, handle) \
- FUT_DO_PROBE6(_STARPU_FUT_START_DRIVER_COPY, src_node, dst_node, size, com_id, prefetch, handle)
- #define _STARPU_TRACE_END_DRIVER_COPY(src_node, dst_node, size, com_id, prefetch) \
- FUT_DO_PROBE5(_STARPU_FUT_END_DRIVER_COPY, src_node, dst_node, size, com_id, prefetch)
- #define _STARPU_TRACE_START_DRIVER_COPY_ASYNC(src_node, dst_node) \
- FUT_DO_PROBE2(_STARPU_FUT_START_DRIVER_COPY_ASYNC, src_node, dst_node)
- #define _STARPU_TRACE_END_DRIVER_COPY_ASYNC(src_node, dst_node) \
- FUT_DO_PROBE2(_STARPU_FUT_END_DRIVER_COPY_ASYNC, src_node, dst_node)
- #define _STARPU_TRACE_WORK_STEALING(empty_q, victim_q) \
- FUT_DO_PROBE2(_STARPU_FUT_WORK_STEALING, empty_q, victim_q)
- #define _STARPU_TRACE_WORKER_DEINIT_START \
- FUT_DO_PROBE1(_STARPU_FUT_WORKER_DEINIT_START, _starpu_gettid());
- #define _STARPU_TRACE_WORKER_DEINIT_END(workerkind) \
- FUT_DO_PROBE2(_STARPU_FUT_WORKER_DEINIT_END, workerkind, _starpu_gettid());
- #define _STARPU_TRACE_WORKER_SCHEDULING_START \
- FUT_DO_PROBE1(_STARPU_FUT_WORKER_SCHEDULING_START, _starpu_gettid());
- #define _STARPU_TRACE_WORKER_SCHEDULING_END \
- FUT_DO_PROBE1(_STARPU_FUT_WORKER_SCHEDULING_END, _starpu_gettid());
- #define _STARPU_TRACE_WORKER_SCHEDULING_PUSH \
- FUT_DO_PROBE1(_STARPU_FUT_WORKER_SCHEDULING_PUSH, _starpu_gettid());
- #define _STARPU_TRACE_WORKER_SCHEDULING_POP \
- FUT_DO_PROBE1(_STARPU_FUT_WORKER_SCHEDULING_POP, _starpu_gettid());
- #define _STARPU_TRACE_WORKER_SLEEP_START \
- FUT_DO_PROBE1(_STARPU_FUT_WORKER_SLEEP_START, _starpu_gettid());
- #define _STARPU_TRACE_WORKER_SLEEP_END \
- FUT_DO_PROBE1(_STARPU_FUT_WORKER_SLEEP_END, _starpu_gettid());
- #define _STARPU_TRACE_TASK_SUBMIT(job) \
- FUT_DO_PROBE2(_STARPU_FUT_TASK_SUBMIT, (job)->job_id, _starpu_gettid());
- #define _STARPU_TRACE_TASK_SUBMIT_START() \
- FUT_DO_PROBE1(_STARPU_FUT_TASK_SUBMIT_START, _starpu_gettid());
- #define _STARPU_TRACE_TASK_SUBMIT_END() \
- FUT_DO_PROBE1(_STARPU_FUT_TASK_SUBMIT_END, _starpu_gettid());
- #define _STARPU_TRACE_TASK_BUILD_START() \
- FUT_DO_PROBE1(_STARPU_FUT_TASK_BUILD_START, _starpu_gettid());
- #define _STARPU_TRACE_TASK_BUILD_END() \
- FUT_DO_PROBE1(_STARPU_FUT_TASK_BUILD_END, _starpu_gettid());
- #define _STARPU_TRACE_TASK_MPI_DECODE_START() \
- FUT_DO_PROBE1(_STARPU_FUT_TASK_MPI_DECODE_START, _starpu_gettid());
- #define _STARPU_TRACE_TASK_MPI_DECODE_END() \
- FUT_DO_PROBE1(_STARPU_FUT_TASK_MPI_DECODE_END, _starpu_gettid());
- #define _STARPU_TRACE_TASK_MPI_PRE_START() \
- FUT_DO_PROBE1(_STARPU_FUT_TASK_MPI_PRE_START, _starpu_gettid());
- #define _STARPU_TRACE_TASK_MPI_PRE_END() \
- FUT_DO_PROBE1(_STARPU_FUT_TASK_MPI_PRE_END, _starpu_gettid());
- #define _STARPU_TRACE_TASK_MPI_POST_START() \
- FUT_DO_PROBE1(_STARPU_FUT_TASK_MPI_POST_START, _starpu_gettid());
- #define _STARPU_TRACE_TASK_MPI_POST_END() \
- FUT_DO_PROBE1(_STARPU_FUT_TASK_MPI_POST_END, _starpu_gettid());
- #define _STARPU_TRACE_TASK_WAIT_START(job) \
- FUT_DO_PROBE2(_STARPU_FUT_TASK_WAIT_START, (job)->job_id, _starpu_gettid());
- #define _STARPU_TRACE_TASK_WAIT_END() \
- FUT_DO_PROBE1(_STARPU_FUT_TASK_WAIT_END, _starpu_gettid());
- #define _STARPU_TRACE_TASK_WAIT_FOR_ALL_START() \
- FUT_DO_PROBE1(_STARPU_FUT_TASK_WAIT_FOR_ALL_START, _starpu_gettid());
- #define _STARPU_TRACE_TASK_WAIT_FOR_ALL_END() \
- FUT_DO_PROBE1(_STARPU_FUT_TASK_WAIT_FOR_ALL_END, _starpu_gettid());
- #define _STARPU_TRACE_USER_DEFINED_START \
- FUT_DO_PROBE1(_STARPU_FUT_USER_DEFINED_START, _starpu_gettid());
- #define _STARPU_TRACE_USER_DEFINED_END \
- FUT_DO_PROBE1(_STARPU_FUT_USER_DEFINED_END, _starpu_gettid());
- #define _STARPU_TRACE_START_ALLOC(memnode, size) \
- FUT_DO_PROBE3(_STARPU_FUT_START_ALLOC, memnode, _starpu_gettid(), size);
- #define _STARPU_TRACE_END_ALLOC(memnode) \
- FUT_DO_PROBE2(_STARPU_FUT_END_ALLOC, memnode, _starpu_gettid());
- #define _STARPU_TRACE_START_ALLOC_REUSE(memnode, size) \
- FUT_DO_PROBE3(_STARPU_FUT_START_ALLOC_REUSE, memnode, _starpu_gettid(), size);
- #define _STARPU_TRACE_END_ALLOC_REUSE(memnode) \
- FUT_DO_PROBE2(_STARPU_FUT_END_ALLOC_REUSE, memnode, _starpu_gettid());
- #define _STARPU_TRACE_START_FREE(memnode, size) \
- FUT_DO_PROBE3(_STARPU_FUT_START_FREE, memnode, _starpu_gettid(), size);
- #define _STARPU_TRACE_END_FREE(memnode) \
- FUT_DO_PROBE2(_STARPU_FUT_END_FREE, memnode, _starpu_gettid());
- #define _STARPU_TRACE_START_WRITEBACK(memnode) \
- FUT_DO_PROBE2(_STARPU_FUT_START_WRITEBACK, memnode, _starpu_gettid());
- #define _STARPU_TRACE_END_WRITEBACK(memnode) \
- FUT_DO_PROBE2(_STARPU_FUT_END_WRITEBACK, memnode, _starpu_gettid());
- #define _STARPU_TRACE_USED_MEM(memnode,used) \
- FUT_DO_PROBE3(_STARPU_FUT_USED_MEM, memnode, used, _starpu_gettid());
- #define _STARPU_TRACE_START_MEMRECLAIM(memnode,is_prefetch) \
- FUT_DO_PROBE3(_STARPU_FUT_START_MEMRECLAIM, memnode, is_prefetch, _starpu_gettid());
- #define _STARPU_TRACE_END_MEMRECLAIM(memnode, is_prefetch) \
- FUT_DO_PROBE3(_STARPU_FUT_END_MEMRECLAIM, memnode, is_prefetch, _starpu_gettid());
- #define _STARPU_TRACE_START_WRITEBACK_ASYNC(memnode) \
- FUT_DO_PROBE2(_STARPU_FUT_START_WRITEBACK_ASYNC, memnode, _starpu_gettid());
- #define _STARPU_TRACE_END_WRITEBACK_ASYNC(memnode) \
- FUT_DO_PROBE2(_STARPU_FUT_END_WRITEBACK_ASYNC, memnode, _starpu_gettid());
- /* We skip these events becasue they are called so often that they cause FxT to
- * fail and make the overall trace unreadable anyway. */
- #define _STARPU_TRACE_START_PROGRESS(memnode) \
- FUT_DO_PROBE2(_STARPU_FUT_START_PROGRESS_ON_TID, memnode, _starpu_gettid());
- #define _STARPU_TRACE_END_PROGRESS(memnode) \
- FUT_DO_PROBE2(_STARPU_FUT_END_PROGRESS_ON_TID, memnode, _starpu_gettid());
- #define _STARPU_TRACE_USER_EVENT(code) \
- FUT_DO_PROBE2(_STARPU_FUT_USER_EVENT, code, _starpu_gettid());
- #define _STARPU_TRACE_SET_PROFILING(status) \
- FUT_DO_PROBE2(_STARPU_FUT_SET_PROFILING, status, _starpu_gettid());
- #define _STARPU_TRACE_TASK_WAIT_FOR_ALL \
- FUT_DO_PROBE0(_STARPU_FUT_TASK_WAIT_FOR_ALL)
- #define _STARPU_TRACE_EVENT(S) \
- FUT_DO_PROBESTR(_STARPU_FUT_EVENT,S)
- #define _STARPU_TRACE_THREAD_EVENT(S) \
- _STARPU_FUT_DO_PROBE1STR(_STARPU_FUT_THREAD_EVENT, _starpu_gettid(), S)
- #define _STARPU_TRACE_HYPERVISOR_BEGIN() \
- FUT_DO_PROBE1(_STARPU_FUT_HYPERVISOR_BEGIN, _starpu_gettid());
- #define _STARPU_TRACE_HYPERVISOR_END() \
- FUT_DO_PROBE1(_STARPU_FUT_HYPERVISOR_END, _starpu_gettid());
- #ifdef STARPU_FXT_LOCK_TRACES
- #define _STARPU_TRACE_LOCKING_MUTEX() do { \
- const char *file; \
- file = strrchr(__FILE__,'/') + 1; \
- _STARPU_FUT_DO_PROBE2STR(_STARPU_FUT_LOCKING_MUTEX,__LINE__,_starpu_gettid(),file); \
- } while (0)
- #define _STARPU_TRACE_MUTEX_LOCKED() do { \
- const char *file; \
- file = strrchr(__FILE__,'/') + 1; \
- _STARPU_FUT_DO_PROBE2STR(_STARPU_FUT_MUTEX_LOCKED,__LINE__,_starpu_gettid(),file); \
- } while(0)
- #define _STARPU_TRACE_UNLOCKING_MUTEX() do { \
- const char *file; \
- file = strrchr(__FILE__,'/') + 1; \
- _STARPU_FUT_DO_PROBE2STR(_STARPU_FUT_UNLOCKING_MUTEX,__LINE__,_starpu_gettid(),file); \
- } while(0)
- #define _STARPU_TRACE_MUTEX_UNLOCKED() do {\
- const char *file; \
- file = strrchr(__FILE__,'/') + 1; \
- _STARPU_FUT_DO_PROBE2STR(_STARPU_FUT_MUTEX_UNLOCKED,__LINE__,_starpu_gettid(),file); \
- } while(0)
- #define _STARPU_TRACE_TRYLOCK_MUTEX() do { \
- const char *file; \
- file = strrchr(__FILE__,'/') + 1; \
- _STARPU_FUT_DO_PROBE2STR(_STARPU_FUT_TRYLOCK_MUTEX,__LINE__,_starpu_gettid(),file); \
- } while(0)
- #define _STARPU_TRACE_RDLOCKING_RWLOCK() do { \
- const char *file; \
- file = strrchr(__FILE__,'/') + 1; \
- _STARPU_FUT_DO_PROBE2STR(_STARPU_FUT_RDLOCKING_RWLOCK,__LINE__,_starpu_gettid(),file); \
- } while(0)
- #define _STARPU_TRACE_RWLOCK_RDLOCKED() do { \
- const char *file; \
- file = strrchr(__FILE__,'/') + 1; \
- _STARPU_FUT_DO_PROBE2STR(_STARPU_FUT_RWLOCK_RDLOCKED,__LINE__,_starpu_gettid(),file); \
- } while(0)
- #define _STARPU_TRACE_WRLOCKING_RWLOCK() do { \
- const char *file; \
- file = strrchr(__FILE__,'/') + 1; \
- _STARPU_FUT_DO_PROBE2STR(_STARPU_FUT_WRLOCKING_RWLOCK,__LINE__,_starpu_gettid(),file); \
- } while(0)
- #define _STARPU_TRACE_RWLOCK_WRLOCKED() do { \
- const char *file; \
- file = strrchr(__FILE__,'/') + 1; \
- _STARPU_FUT_DO_PROBE2STR(_STARPU_FUT_RWLOCK_WRLOCKED,__LINE__,_starpu_gettid(),file); \
- } while(0)
- #define _STARPU_TRACE_UNLOCKING_RWLOCK() do { \
- const char *file; \
- file = strrchr(__FILE__,'/') + 1; \
- _STARPU_FUT_DO_PROBE2STR(_STARPU_FUT_UNLOCKING_RWLOCK,__LINE__,_starpu_gettid(),file); \
- } while(0)
- #define _STARPU_TRACE_RWLOCK_UNLOCKED() do { \
- const char *file; \
- file = strrchr(__FILE__,'/') + 1; \
- _STARPU_FUT_DO_PROBE2STR(_STARPU_FUT_RWLOCK_UNLOCKED,__LINE__,_starpu_gettid(),file); \
- } while(0)
- #define STARPU_TRACE_SPINLOCK_CONDITITION (starpu_worker_get_type(starpu_worker_get_id()) == STARPU_CUDA_WORKER)
- #define _STARPU_TRACE_LOCKING_SPINLOCK(file, line) do {\
- if (STARPU_TRACE_SPINLOCK_CONDITITION) { \
- const char *xfile; \
- xfile = strrchr(file,'/') + 1; \
- _STARPU_FUT_DO_PROBE2STR(_STARPU_FUT_LOCKING_SPINLOCK,line,_starpu_gettid(),xfile); \
- } \
- } while(0)
- #define _STARPU_TRACE_SPINLOCK_LOCKED(file, line) do { \
- if (STARPU_TRACE_SPINLOCK_CONDITITION) { \
- const char *xfile; \
- xfile = strrchr(file,'/') + 1; \
- _STARPU_FUT_DO_PROBE2STR(_STARPU_FUT_SPINLOCK_LOCKED,line,_starpu_gettid(),xfile); \
- } \
- } while(0)
- #define _STARPU_TRACE_UNLOCKING_SPINLOCK(file, line) do { \
- if (STARPU_TRACE_SPINLOCK_CONDITITION) { \
- const char *xfile; \
- xfile = strrchr(file,'/') + 1; \
- _STARPU_FUT_DO_PROBE2STR(_STARPU_FUT_UNLOCKING_SPINLOCK,line,_starpu_gettid(),xfile); \
- } \
- } while(0)
- #define _STARPU_TRACE_SPINLOCK_UNLOCKED(file, line) do { \
- if (STARPU_TRACE_SPINLOCK_CONDITITION) { \
- const char *xfile; \
- xfile = strrchr(file,'/') + 1; \
- _STARPU_FUT_DO_PROBE2STR(_STARPU_FUT_SPINLOCK_UNLOCKED,line,_starpu_gettid(),xfile); \
- } \
- } while(0)
- #define _STARPU_TRACE_TRYLOCK_SPINLOCK(file, line) do { \
- if (STARPU_TRACE_SPINLOCK_CONDITITION) { \
- const char *xfile; \
- xfile = strrchr(file,'/') + 1; \
- _STARPU_FUT_DO_PROBE2STR(_STARPU_FUT_TRYLOCK_SPINLOCK,line,_starpu_gettid(),xfile); \
- } \
- } while(0)
- #define _STARPU_TRACE_COND_WAIT_BEGIN() do { \
- const char *file; \
- file = strrchr(__FILE__,'/') + 1; \
- _STARPU_FUT_DO_PROBE2STR(_STARPU_FUT_COND_WAIT_BEGIN,__LINE__,_starpu_gettid(),file); \
- } while(0)
- #define _STARPU_TRACE_COND_WAIT_END() do { \
- const char *file; \
- file = strrchr(__FILE__,'/') + 1; \
- _STARPU_FUT_DO_PROBE2STR(_STARPU_FUT_COND_WAIT_END,__LINE__,_starpu_gettid(),file); \
- } while(0)
- #define _STARPU_TRACE_BARRIER_WAIT_BEGIN() do { \
- const char *file; \
- file = strrchr(__FILE__,'/') + 1; \
- _STARPU_FUT_DO_PROBE2STR(_STARPU_FUT_BARRIER_WAIT_BEGIN,__LINE__,_starpu_gettid(),file); \
- } while(0)
- #define _STARPU_TRACE_BARRIER_WAIT_END() do { \
- const char *file; \
- file = strrchr(__FILE__,'/') + 1; \
- _STARPU_FUT_DO_PROBE2STR(_STARPU_FUT_BARRIER_WAIT_END,__LINE__,_starpu_gettid(),file); \
- } while(0)
- #else // !STARPU_FXT_LOCK_TRACES
- #define _STARPU_TRACE_LOCKING_MUTEX() do {} while(0)
- #define _STARPU_TRACE_MUTEX_LOCKED() do {} while(0)
- #define _STARPU_TRACE_UNLOCKING_MUTEX() do {} while(0)
- #define _STARPU_TRACE_MUTEX_UNLOCKED() do {} while(0)
- #define _STARPU_TRACE_TRYLOCK_MUTEX() do {} while(0)
- #define _STARPU_TRACE_RDLOCKING_RWLOCK() do {} while(0)
- #define _STARPU_TRACE_RWLOCK_RDLOCKED() do {} while(0)
- #define _STARPU_TRACE_WRLOCKING_RWLOCK() do {} while(0)
- #define _STARPU_TRACE_RWLOCK_WRLOCKED() do {} while(0)
- #define _STARPU_TRACE_UNLOCKING_RWLOCK() do {} while(0)
- #define _STARPU_TRACE_RWLOCK_UNLOCKED() do {} while(0)
- #define _STARPU_TRACE_LOCKING_SPINLOCK(file, line) do {(void) file; (void)line;} while(0)
- #define _STARPU_TRACE_SPINLOCK_LOCKED(file, line) do {(void) file; (void)line;} while(0)
- #define _STARPU_TRACE_UNLOCKING_SPINLOCK(file, line) do {(void) file; (void)line;} while(0)
- #define _STARPU_TRACE_SPINLOCK_UNLOCKED(file, line) do {(void) file; (void)line;} while(0)
- #define _STARPU_TRACE_TRYLOCK_SPINLOCK(file, line) do {(void) file; (void)line;} while(0)
- #define _STARPU_TRACE_COND_WAIT_BEGIN() do {} while(0)
- #define _STARPU_TRACE_COND_WAIT_END() do {} while(0)
- #define _STARPU_TRACE_BARRIER_WAIT_BEGIN() do {} while(0)
- #define _STARPU_TRACE_BARRIER_WAIT_END() do {} while(0)
- #endif // STARPU_FXT_LOCK_TRACES
- #define _STARPU_TRACE_MEMORY_FULL(size) \
- FUT_DO_PROBE2(_STARPU_FUT_MEMORY_FULL,size,_starpu_gettid());
- #define _STARPU_TRACE_DATA_LOAD(workerid,size) \
- FUT_DO_PROBE2(_STARPU_FUT_DATA_LOAD, workerid, size);
- #define _STARPU_TRACE_START_UNPARTITION(handle, memnode) \
- FUT_DO_PROBE3(_STARPU_FUT_START_UNPARTITION_ON_TID, memnode, _starpu_gettid(), handle);
- #define _STARPU_TRACE_END_UNPARTITION(handle, memnode) \
- FUT_DO_PROBE3(_STARPU_FUT_END_UNPARTITION_ON_TID, memnode, _starpu_gettid(), handle);
- #define _STARPU_TRACE_SCHED_COMPONENT_PUSH_PRIO(workerid, ntasks, exp_len) \
- FUT_DO_PROBE4(_STARPU_FUT_SCHED_COMPONENT_PUSH_PRIO, _starpu_gettid(), workerid, ntasks, exp_len);
- #define _STARPU_TRACE_SCHED_COMPONENT_POP_PRIO(workerid, ntasks, exp_len) \
- FUT_DO_PROBE4(_STARPU_FUT_SCHED_COMPONENT_POP_PRIO, _starpu_gettid(), workerid, ntasks, exp_len);
- #define _STARPU_TRACE_SCHED_COMPONENT_NEW(component) \
- _STARPU_FUT_DO_PROBE1STR(_STARPU_FUT_SCHED_COMPONENT_NEW, component, (component)->name);
- #define _STARPU_TRACE_SCHED_COMPONENT_CONNECT(parent, child) \
- FUT_DO_PROBE2(_STARPU_FUT_SCHED_COMPONENT_CONNECT, parent, child);
- #define _STARPU_TRACE_SCHED_COMPONENT_PUSH(from, to, task) \
- FUT_DO_PROBE5(_STARPU_FUT_SCHED_COMPONENT_PUSH, _starpu_gettid(), from, to, task, (task)->priority);
- #define _STARPU_TRACE_SCHED_COMPONENT_PULL(from, to, task) \
- FUT_DO_PROBE5(_STARPU_FUT_SCHED_COMPONENT_PULL, _starpu_gettid(), from, to, task, (task)->priority);
- #define _STARPU_TRACE_HANDLE_DATA_REGISTER(handle) \
- FUT_DO_PROBE1(_STARPU_FUT_HANDLE_DATA_REGISTER, handle)
- #if 0
- #define _STARPU_TRACE_DATA_INVALIDATE(handle, node) \
- FUT_DO_PROBE2(_STARPU_FUT_DATA_INVALIDATE, handle, node)
- #else
- #define _STARPU_TRACE_DATA_INVALIDATE(handle, node) do {(void) handle; (void) node;} while (0)
- #endif
- #else // !STARPU_USE_FXT
- /* Dummy macros in case FxT is disabled */
- #define _STARPU_TRACE_NEW_MEM_NODE(nodeid) do {(void)(nodeid);} while(0)
- #define _STARPU_TRACE_WORKER_INIT_START(a,b,c,d,e,f) do {(void)(a); (void)(b); (void)(c); (void)(d); (void)(e); (void)(f);} while(0)
- #define _STARPU_TRACE_WORKER_INIT_END(workerid) do {(void)(workerid);} while(0)
- #define _STARPU_TRACE_START_CODELET_BODY(job, nimpl, perf_arch, workerid) do {(void)(job); (void)(nimpl); (void)(perf_arch); (void)(workerid);} while(0)
- #define _STARPU_TRACE_END_CODELET_BODY(job, nimpl, perf_arch, workerid) do {(void)(job); (void)(nimpl); (void)(perf_arch); (void)(workerid);} while(0)
- #define _STARPU_TRACE_START_EXECUTING() do {} while(0)
- #define _STARPU_TRACE_END_EXECUTING() do {} while(0)
- #define _STARPU_TRACE_START_CALLBACK(job) do {(void)(job);} while(0)
- #define _STARPU_TRACE_END_CALLBACK(job) do {(void)(job);} while(0)
- #define _STARPU_TRACE_JOB_PUSH(task, prio) do {(void)(task); (void)(prio);} while(0)
- #define _STARPU_TRACE_JOB_POP(task, prio) do {(void)(task); (void)(prio);} while(0)
- #define _STARPU_TRACE_UPDATE_TASK_CNT(counter) do {(void)(counter);} while(0)
- #define _STARPU_TRACE_START_FETCH_INPUT(job) do {(void)(job);} while(0)
- #define _STARPU_TRACE_END_FETCH_INPUT(job) do {(void)(job);} while(0)
- #define _STARPU_TRACE_START_PUSH_OUTPUT(job) do {(void)(job);} while(0)
- #define _STARPU_TRACE_END_PUSH_OUTPUT(job) do {(void)(job);} while(0)
- #define _STARPU_TRACE_TAG(tag, job) do {(void)(tag); (void)(job);} while(0)
- #define _STARPU_TRACE_TAG_DEPS(a, b) do {(void)(a); (void)(b);} while(0)
- #define _STARPU_TRACE_TASK_DEPS(a, b) do {(void)(a); (void)(b);} while(0)
- #define _STARPU_TRACE_GHOST_TASK_DEPS(a, b) do {(void)(a); (void)(b);} while(0)
- #define _STARPU_TRACE_TASK_DONE(a) do {(void)(a);} while(0)
- #define _STARPU_TRACE_TAG_DONE(a) do {(void)(a);} while(0)
- #define _STARPU_TRACE_DATA_COPY(a, b, c) do {(void)(a); (void)(b); (void)(c);} while(0)
- #define _STARPU_TRACE_START_DRIVER_COPY(a,b,c,d,e,f) do {(void)(a); (void)(b); (void)(c); (void)(d); (void)(e); (void)(f);} while(0)
- #define _STARPU_TRACE_END_DRIVER_COPY(a,b,c,d,e) do {(void)(a); (void)(b); (void)(c); (void)(d); (void)(e);} while(0)
- #define _STARPU_TRACE_START_DRIVER_COPY_ASYNC(a,b) do {(void)(a); (void)(b);} while(0)
- #define _STARPU_TRACE_END_DRIVER_COPY_ASYNC(a,b) do {(void)(a); (void)(b);} while(0)
- #define _STARPU_TRACE_WORK_STEALING(a, b) do {(void)(a); (void)(b);} while(0)
- #define _STARPU_TRACE_WORKER_DEINIT_START do {} while(0)
- #define _STARPU_TRACE_WORKER_DEINIT_END(a) do {(void)(a);} while(0)
- #define _STARPU_TRACE_WORKER_SCHEDULING_START do {} while(0)
- #define _STARPU_TRACE_WORKER_SCHEDULING_END do {} while(0)
- #define _STARPU_TRACE_WORKER_SCHEDULING_PUSH do {} while(0)
- #define _STARPU_TRACE_WORKER_SCHEDULING_POP do {} while(0)
- #define _STARPU_TRACE_WORKER_SLEEP_START do {} while(0)
- #define _STARPU_TRACE_WORKER_SLEEP_END do {} while(0)
- #define _STARPU_TRACE_TASK_SUBMIT(job) do {(void)(job);} while(0)
- #define _STARPU_TRACE_TASK_SUBMIT_START() do {} while(0)
- #define _STARPU_TRACE_TASK_SUBMIT_END() do {} while(0)
- #define _STARPU_TRACE_TASK_BUILD_START() do {} while(0)
- #define _STARPU_TRACE_TASK_BUILD_END() do {} while(0)
- #define _STARPU_TRACE_TASK_MPI_DECODE_START() do {} while(0)
- #define _STARPU_TRACE_TASK_MPI_DECODE_END() do {} while(0)
- #define _STARPU_TRACE_TASK_MPI_PRE_START() do {} while(0)
- #define _STARPU_TRACE_TASK_MPI_PRE_END() do {} while(0)
- #define _STARPU_TRACE_TASK_MPI_POST_START() do {} while(0)
- #define _STARPU_TRACE_TASK_MPI_POST_END() do {} while(0)
- #define _STARPU_TRACE_TASK_WAIT_START(job) do {(void)(job);} while(0)
- #define _STARPU_TRACE_TASK_WAIT_END() do {} while(0)
- #define _STARPU_TRACE_TASK_WAIT_FOR_ALL_START() do {} while(0)
- #define _STARPU_TRACE_TASK_WAIT_FOR_ALL_END() do {} while(0)
- #define _STARPU_TRACE_USER_DEFINED_START() do {} while(0)
- #define _STARPU_TRACE_USER_DEFINED_END() do {} while(0)
- #define _STARPU_TRACE_START_ALLOC(memnode, size) do {(void)(memnode); (void)(size);} while(0)
- #define _STARPU_TRACE_END_ALLOC(memnode) do {(void)(memnode);} while(0)
- #define _STARPU_TRACE_START_ALLOC_REUSE(a, size) do {(void)(a); (void)(size);} while(0)
- #define _STARPU_TRACE_END_ALLOC_REUSE(a) do {(void)(a);} while(0)
- #define _STARPU_TRACE_START_FREE(memnode, size) do {(void)(memnode); (void)(size);} while(0)
- #define _STARPU_TRACE_END_FREE(memnode) do {(void)(memnode);} while(0)
- #define _STARPU_TRACE_START_WRITEBACK(memnode) do {(void)(memnode);} while(0)
- #define _STARPU_TRACE_END_WRITEBACK(memnode) do {(void)(memnode);} while(0)
- #define _STARPU_TRACE_USED_MEM(memnode,used) do {(void)(memnode); (void)(used);} while (0)
- #define _STARPU_TRACE_START_MEMRECLAIM(memnode,is_prefetch) do {(void)(memnode); (void)(is_prefetch);} while(0)
- #define _STARPU_TRACE_END_MEMRECLAIM(memnode,is_prefetch) do {(void)(memnode); (void)(is_prefetch);} while(0)
- #define _STARPU_TRACE_START_WRITEBACK_ASYNC(memnode) do {(void)(memnode);} while(0)
- #define _STARPU_TRACE_END_WRITEBACK_ASYNC(memnode) do {(void)(memnode);} while(0)
- #define _STARPU_TRACE_START_PROGRESS(memnode) do {(void)( memnode);} while(0)
- #define _STARPU_TRACE_END_PROGRESS(memnode) do {(void)( memnode);} while(0)
- #define _STARPU_TRACE_USER_EVENT(code) do {(void)(code);} while(0)
- #define _STARPU_TRACE_SET_PROFILING(status) do {(void)(status);} while(0)
- #define _STARPU_TRACE_TASK_WAIT_FOR_ALL() do {} while(0)
- #define _STARPU_TRACE_EVENT(S) do {(void)(S);} while(0)
- #define _STARPU_TRACE_THREAD_EVENT(S) do {(void)(S);} while(0)
- #define _STARPU_TRACE_LOCKING_MUTEX() do {} while(0)
- #define _STARPU_TRACE_MUTEX_LOCKED() do {} while(0)
- #define _STARPU_TRACE_UNLOCKING_MUTEX() do {} while(0)
- #define _STARPU_TRACE_MUTEX_UNLOCKED() do {} while(0)
- #define _STARPU_TRACE_TRYLOCK_MUTEX() do {} while(0)
- #define _STARPU_TRACE_RDLOCKING_RWLOCK() do {} while(0)
- #define _STARPU_TRACE_RWLOCK_RDLOCKED() do {} while(0)
- #define _STARPU_TRACE_WRLOCKING_RWLOCK() do {} while(0)
- #define _STARPU_TRACE_RWLOCK_WRLOCKED() do {} while(0)
- #define _STARPU_TRACE_UNLOCKING_RWLOCK() do {} while(0)
- #define _STARPU_TRACE_RWLOCK_UNLOCKED() do {} while(0)
- #define _STARPU_TRACE_LOCKING_SPINLOCK(file, line) do {(void)(file); (void)(line);} while(0)
- #define _STARPU_TRACE_SPINLOCK_LOCKED(file, line) do {(void)(file); (void)(line);} while(0)
- #define _STARPU_TRACE_UNLOCKING_SPINLOCK(file, line) do {(void)(file); (void)(line);} while(0)
- #define _STARPU_TRACE_SPINLOCK_UNLOCKED(file, line) do {(void)(file); (void)(line);} while(0)
- #define _STARPU_TRACE_TRYLOCK_SPINLOCK(file, line) do {(void)(file); (void)(line);} while(0)
- #define _STARPU_TRACE_COND_WAIT_BEGIN() do {} while(0)
- #define _STARPU_TRACE_COND_WAIT_END() do {} while(0)
- #define _STARPU_TRACE_BARRIER_WAIT_BEGIN() do {} while(0)
- #define _STARPU_TRACE_BARRIER_WAIT_END() do {} while(0)
- #define _STARPU_TRACE_MEMORY_FULL(size) do {(void)(size);} while(0)
- #define _STARPU_TRACE_DATA_LOAD(workerid,size) do {(void)(workerid); (void)(size);} while(0)
- #define _STARPU_TRACE_START_UNPARTITION(handle, memnode) do {(void)(handle); (void)(memnode);} while(0)
- #define _STARPU_TRACE_END_UNPARTITION(handle, memnode) do {(void)(handle); (void)(memnode);} while(0)
- #define _STARPU_TRACE_SCHED_COMPONENT_PUSH_PRIO(workerid, ntasks, exp_len) do {(void)(workerid); (void)(ntasks); (void)(exp_len);} while(0)
- #define _STARPU_TRACE_SCHED_COMPONENT_POP_PRIO(workerid, ntasks, exp_len) do {(void)(workerid); (void)(ntasks); (void)(exp_len);} while(0)
- #define _STARPU_TRACE_HYPERVISOR_BEGIN() do {} while(0)
- #define _STARPU_TRACE_HYPERVISOR_END() do {} while(0)
- #define _STARPU_TRACE_SCHED_COMPONENT_NEW(component) do {(void)(component);} while (0)
- #define _STARPU_TRACE_SCHED_COMPONENT_CONNECT(parent, child) do {(void)(parent); (void)(child);} while (0)
- #define _STARPU_TRACE_SCHED_COMPONENT_PUSH(from, to, task) do {(void)(from); (void)(to); (void)(task);} while (0)
- #define _STARPU_TRACE_SCHED_COMPONENT_PULL(from, to, task) do {(void)(from); (void)(to); (void)(task);} while (0)
- #define _STARPU_TRACE_HANDLE_DATA_REGISTER(handle) do {(void)(handle);} while (0)
- #define _STARPU_TRACE_DATA_INVALIDATE(handle, node) do {(void)(handle); (void)(node);} while (0)
- #define _STARPU_TRACE_WORKER_START_FETCH_INPUT(job, id) do {(void)(job); (void)(id);} while(0)
- #define _STARPU_TRACE_WORKER_END_FETCH_INPUT(job, id) do {(void)(job); (void)(id);} while(0)
- #endif // STARPU_USE_FXT
- #endif // __FXT_H__
|