Compare commits

...

13 Commits
1.7.4 ... 1.7.7

Author SHA1 Message Date
c80b112ce7 release: 1.7.7: fix fput and mckernel.spec
Change-Id: I74f7530b067d44790e3f014479f580867387584a
2021-03-11 08:09:07 +00:00
4a05024656 spec: cmake-config cmake paramters
Change-Id: Ic0e7f62d9172f31afe90297bdd22b8e50cc6fc9e
2021-03-11 07:19:04 +00:00
7a04c6eb5c ihkmond: redirect kmsg to /dev/kmsg line by line
Change-Id: Iafc9d0eb47696073434dcc869a29336a51b8c50e
2021-03-11 16:11:17 +09:00
3e00189de0 kprintf: fix checking if interrupt is disabled
Change-Id: I2ee1a1e2438ae761c4136593953ede2738bc6f74
2021-03-11 07:03:04 +00:00
c94cf8e6f0 mcexec: fput executable just after its contents is transferred
Change-Id: I3fae841bd7341bca030fd6b7eceffa068c9e0f4e
2021-03-11 07:03:04 +00:00
ee974b200d mcexec_open_exec: fix missing fput on error
Change-Id: I3ac94e336dc54ec313e69c0fa85c17086dc256fd
2021-03-11 07:03:04 +00:00
546cafe6bc release: 1.7.6: fix ihk_reserve_mem_conf
Change-Id: I767f8eac655af9200f733c21353b1e141007df17
2021-03-11 15:22:36 +09:00
9dd4d99a1a docs: spec: ihk_reserve_mem_conf*: apply change only to the next reservation
Change-Id: Iaafd2ca4d96f227d03e9910a36b27801fb1e3da4
2021-03-11 15:17:44 +09:00
3a6273777a test: uti/tofu, issues/1507+1519: fix README
Change-Id: I3060e1273c8ef6a1b392a2c678da3bc02a25a4f8
2021-03-11 03:59:57 +00:00
daed585347 release: 1.7.5: fix ihk_*str() functions
Change-Id: Ic412029f856f34a10724f03e36f211f6026acd8e
2021-03-11 12:18:43 +09:00
11d7229525 docs: spec: ihk_reserve_mem_conf_str: use defaults for those not specified
Change-Id: I7cfddd3203b952cabb919ea6401e226e151e696a
2021-03-11 02:26:18 +00:00
e43d52df20 Revert "mcexec_open_exec: make fput and add to mckernel_exec_files atomic"
This reverts commit c80ea0ed23.

Change-Id: I0541e8af5157c7128f8774f6581cc207d13b649a
2021-03-10 14:21:57 +09:00
1c0da3c5b9 Revert "mcexec_open_exec: guard fput and add to mckernel_exec_files with spin_lock_irqsave"
This reverts commit cba263ff12.

Change-Id: Ifcd03a2048a3f9d6c155dd8ecd522081b5dde276
2021-03-10 14:21:49 +09:00
15 changed files with 324 additions and 71 deletions

View File

@ -7,7 +7,7 @@ endif (NOT CMAKE_BUILD_TYPE)
enable_language(C ASM) enable_language(C ASM)
project(mckernel C ASM) project(mckernel C ASM)
set(MCKERNEL_VERSION "1.7.4") set(MCKERNEL_VERSION "1.7.7")
# See "Fedora Packaging Guidelines -- Versioning" # See "Fedora Packaging Guidelines -- Versioning"
set(MCKERNEL_RELEASE "") set(MCKERNEL_RELEASE "")
@ -124,6 +124,14 @@ if(ENABLE_FUGAKU_DEBUG)
set(KBUILD_C_FLAGS "${KBUILD_C_FLAGS} -DENABLE_FUGAKU_DEBUG") set(KBUILD_C_FLAGS "${KBUILD_C_FLAGS} -DENABLE_FUGAKU_DEBUG")
endif() endif()
# redirect kernel messages to Linux's /dev/kmsg
option(ENABLE_KMSG_REDIRECT "Redirect kernel message to Linux's /dev/kmsg" OFF)
if(ENABLE_KMSG_REDIRECT)
add_definitions(-DENABLE_KMSG_REDIRECT)
set(KBUILD_C_FLAGS "${KBUILD_C_FLAGS} -DENABLE_KMSG_REDIRECT")
endif()
option(PROFILE_ENABLE "System call profile" ON) option(PROFILE_ENABLE "System call profile" ON)
if(PROFILE_ENABLE) if(PROFILE_ENABLE)
add_definitions(-DPROFILE_ENABLE) add_definitions(-DPROFILE_ENABLE)
@ -340,4 +348,5 @@ message("ENABLE_WERROR: ${ENABLE_WERROR}")
message("ENABLE_UBSAN: ${ENABLE_UBSAN}") message("ENABLE_UBSAN: ${ENABLE_UBSAN}")
message("ENABLE_LINUX_WORK_IRQ_FOR_IKC: ${ENABLE_LINUX_WORK_IRQ_FOR_IKC}") message("ENABLE_LINUX_WORK_IRQ_FOR_IKC: ${ENABLE_LINUX_WORK_IRQ_FOR_IKC}")
message("ENABLE_PER_CPU_ALLOC_CACHE: ${ENABLE_PER_CPU_ALLOC_CACHE}") message("ENABLE_PER_CPU_ALLOC_CACHE: ${ENABLE_PER_CPU_ALLOC_CACHE}")
message("ENABLE_KMSG_REDIRECT: ${ENABLE_KMSG_REDIRECT}")
message("-------------------------------") message("-------------------------------")

View File

@ -912,7 +912,6 @@ unsigned long cpu_enable_interrupt_save(void)
return flags; return flags;
} }
#ifdef ENABLE_FUGAKU_HACKS
int cpu_interrupt_disabled(void) int cpu_interrupt_disabled(void)
{ {
unsigned long flags; unsigned long flags;
@ -925,7 +924,6 @@ int cpu_interrupt_disabled(void)
: "memory"); : "memory");
return (flags == masked); return (flags == masked);
} }
#endif
#else /* defined(CONFIG_HAS_NMI) */ #else /* defined(CONFIG_HAS_NMI) */
@ -989,6 +987,18 @@ unsigned long cpu_enable_interrupt_save(void)
: "memory"); : "memory");
return flags; return flags;
} }
int cpu_interrupt_disabled(void)
{
unsigned long flags;
asm volatile(
"mrs %0, daif // arch_local_irq_save\n"
: "=r" (flags)
:
: "memory");
return !!(flags & 0x2);
}
#endif /* defined(CONFIG_HAS_NMI) */ #endif /* defined(CONFIG_HAS_NMI) */
/* we not have "pause" instruction, instead "yield" instruction */ /* we not have "pause" instruction, instead "yield" instruction */

View File

@ -1273,6 +1273,15 @@ unsigned long cpu_enable_interrupt_save(void)
return flags; return flags;
} }
int cpu_interrupt_disabled(void)
{
unsigned long flags;
asm volatile("pushf; pop %0" : "=r"(flags) : : "memory", "cc");
return !(flags & 0x200);
}
/*@ /*@
@ behavior valid_vector: @ behavior valid_vector:
@ assumes 32 <= vector <= 255; @ assumes 32 <= vector <= 255;

View File

@ -1,3 +1,222 @@
=============================================
Version 1.7.7 (Mar 11, 2021)
=============================================
----------------------
IHK major updates
----------------------
N/A
------------------------
IHK major bug fixes
------------------------
N/A
----------------------
McKernel major updates
----------------------
N/A
------------------------
McKernel major bug fixes
------------------------
#. mcexec: fput executable just after its contents is transferred
#. spec: cmake-config cmake parameters
=============================================
Version 1.7.6 (Mar 11, 2021)
=============================================
----------------------
IHK major updates
----------------------
N/A
------------------------
IHK major bug fixes
------------------------
#. ihklib: ihk_reserve_mem_conf*: apply change only to the next reservation
----------------------
McKernel major updates
----------------------
N/A
------------------------
McKernel major bug fixes
------------------------
N/A
=============================================
Version 1.7.5 (Mar 11, 2021)
=============================================
----------------------
IHK major updates
----------------------
N/A
------------------------
IHK major bug fixes
------------------------
#. ihklib: fix cgroup cpuset.cpus/mems check when using krm
#. ihklib: ihk_reserve_mem_conf_str: set default values to those not specified
----------------------
McKernel major updates
----------------------
N/A
------------------------
McKernel major bug fixes
------------------------
N/A
=============================================
Version 1.7.4 (Mar 7, 2021)
=============================================
----------------------
IHK major updates
----------------------
N/A
------------------------
IHK major bug fixes
------------------------
N/A
----------------------
McKernel major updates
----------------------
N/A
------------------------
McKernel major bug fixes
------------------------
N/A
=============================================
Version 1.7.3 (Mar 5, 2021)
=============================================
----------------------
IHK major updates
----------------------
N/A
------------------------
IHK major bug fixes
------------------------
N/A
----------------------
McKernel major updates
----------------------
N/A
------------------------
McKernel major bug fixes
------------------------
N/A
=============================================
Version 1.7.2 (Mar 5, 2021)
=============================================
----------------------
IHK major updates
----------------------
#. ihklib: add *_str() functions for reserve, assign, IKC-map, kargs
#. smp: make smp_call_func() arch independent
------------------------
IHK major bug fixes
------------------------
#. ihklib: ihk_reserve_mem: fix capped best-effort
#. TO RESET: fake missing NUMA node pieces, 90% memory limit
#. ihklib: ihk_reserve_mem_conf: range-check for IHK_RESERVE_MEM_MAX_SIZE_RATIO_ALL
#. ihklib: ihk_os_kargs: check if "hidos" is included
#. SMP: omit slab/slub shrink, use 95% limit by default
#. check cpu / numa cgroup set by krm
#. SMP: __ihk_smp_reserve_mem: add __GFP_COMP to __GFP_ATOMIC allocation
#. ihk_register_device: record minor to IHK device object
----------------------
McKernel major updates
----------------------
#. mcexec: memory policy control by environmental variable
#. mempolicy: Support MPOL_INTERLEAVE
#. uti: futex call function in mcctrl
#. uti: integrate libuti and redirect to mck/libuti.so
#. uti: integrate syscall_intercept
#. shmobj: support large page
#. xpmem: support large page
#. MM: handle zero_at_free in page faults
------------------------
McKernel major bug fixes
------------------------
#. TO RESET: stack changes
#. Tofu: keep track of stags per memory range
#. Tofu: match page sizes to MBPT and fault PTEs if not present
#. Tofu: fix phys addr calculation for contiguous pages in MBPT/BCH update
#. rus_vm_fault: vmf_insert_pfn: treat VM_FAULT_NOPAGE as success
#. Tofu: mcctrl side MMU notifier and CQ/BCH cleanup
#. copy_user_ranges: copy straight_start of struct vm_range
#. mcctrl: abort on invalid addr in mcexec_transfer_image()
#. mcctrl: fix access to uninitialized usrdata->cpu_topology_list
#. mcexec: propagate error in __NR_gettid handler
#. mcexec_transfer_image(): map exact size of remote memory (instead of forcing PAGE_SIZE)
#. xpmem: fault stack area of remote process if VM range doesn't yet exist
#. Tofu: fault stack area if VM range doesn't exist in STAG registration
#. __mcctrl_os_read_write_cpu_register: fix timeout
#. mbind: Use range_policy's numamask as priority on MPOL_BIND
#. migrate: Don't migrate on in-kernel interrupt
#. Send a signal to mcexec after switching to that process.
#. uti: fix syscall response is mis-consumed by __do_in_kernel_irq_syscall
#. uti: fix handling UTI_CPU_SET env
#. do_execveat: kill instead of panic when init_process_stack fails
#. remote_page_fault is handled by the offloaded thread.
#. coredump: fix behavior when gencore fail
#. xpmem: truncates the size of xpmem_attach at the page boundary (workaround for fjmpi)
#. __mcctrl_os_read_write_cpu_register: spin timeout in mcctrl_ikc_send_wait()
=============================================
Version 1.7.1 (Dec 23, 2020)
=============================================
----------------------
IHK major updates
----------------------
#. d5d5c23 Tofu: support for barrier gate
#. Tofu: proper cleanup of premapped DMA regions
#. Tofu: initial version
#. SMP: try with GFP_ATOMIC as well in mem reserve
------------------------
IHK major bug fixes
------------------------
#. ihklib: ihk(_os)_query_{cpu,mem}: allow to pass empty array
#. SMP: non compound page free and GFP_ATOMIC
#. ihk_get_num_os_instances: don't open /dev/mcdN
#. ihklib: ihk_create_os_str: fix variable prefix
----------------------
McKernel major updates
----------------------
#. stragiht map: creates a straight map covering the whole physical memory, and gives virtual address ranges out of it to maps to which physical pages are allocated on map
#. free-time, lazy, potentially Linux-side page-zeroing
#. Tofu built-in driver: supports memory registration and barrier gate setup
#. kmalloc cache
------------------------
McKernel major bug fixes
------------------------
#. mmap: return -EINVAL for non-anonymous, MAP_HUGETLB map
#. kernel: increase stack size
#. Tofu: proper cleanup of device files when mcexec gets killed
============================================= =============================================
Version 1.7.0 (Nov 25, 2020) Version 1.7.0 (Nov 25, 2020)
============================================= =============================================

View File

@ -166,22 +166,6 @@ Create the tarball and the spec file:
make dist make dist
cp mckernel-<version>.tar.gz <rpmbuild>/SOURCES cp mckernel-<version>.tar.gz <rpmbuild>/SOURCES
(optional) Edit the following line in ``scripts/mckernel.spec`` to change
cmake options. For example:
::
%cmake -DCMAKE_BUILD_TYPE=Release \
-DUNAME_R=%{kernel_version} \
-DKERNEL_DIR=%{kernel_dir} \
%{?cmake_libdir:-DCMAKE_INSTALL_LIBDIR=%{cmake_libdir}} \
%{?build_target:-DBUILD_TARGET=%{build_target}} \
%{?toolchain_file:-DCMAKE_TOOLCHAIN_FILE=%{toolchain_file}} \
-DENABLE_TOFU=ON -DENABLE_FUGAKU_HACKS=ON \
-DENABLE_KRM_WORKAROUND=OFF -DWITH_KRM=ON \
-DENABLE_FUGAKU_DEBUG=OFF -DENABLE_UTI=ON \
.
Create the rpm package: Create the rpm package:
When not cross-compiling: When not cross-compiling:

Binary file not shown.

View File

@ -649,7 +649,9 @@ IHKはLinuxに以下の機能を提供する。
\begin{tabular}[t]{@{}l@{}} \begin{tabular}[t]{@{}l@{}}
{\quad} \texttt{int ihk\_reserve\_mem\_conf(int index, int key, void *value)}\\ {\quad} \texttt{int ihk\_reserve\_mem\_conf(int index, int key, void *value)}\\
\end{tabular} \end{tabular}
\subsubsection*{説明}{\quad} \texttt{index}で指定されたIHKデバイスに対する\texttt{ihk\_reserve\_mem()}の動作を\texttt{key}\texttt{value}のペアで指定したものに変更する。\texttt{value}は値へのポインタで指定する。\texttt{key}\texttt{value}のペアの意味は以下のように定義される。 \subsubsection*{説明}{\quad} \texttt{index}で指定されたIHKデバイスに対する\texttt{ihk\_reserve\_mem()}の動作を\texttt{key}\texttt{value}のペアで指定したものに変更する。なお、設定は次の1回の予約に限り有効で、予約後にはデフォルト設定に戻る。
\texttt{value}は値へのポインタで指定する。\texttt{key}\texttt{value}のペアの意味は以下のように定義される。
\subsubsection*{\texttt{IHK\_RESERVE\_MEM\_BALANCED\_\{ENABLE,BEST\_EFFORT,VARIANCE\_LIMIT\}}} \subsubsection*{\texttt{IHK\_RESERVE\_MEM\_BALANCED\_\{ENABLE,BEST\_EFFORT,VARIANCE\_LIMIT\}}}
\verb|IHK_RESERVE_MEM_BALANCED_ENABLE|(型は\verb|int|、デフォルトは0が非ゼロの場合は、NUMAードごとの予約サイズがNUMAード間でなるべく均等になるように予約する。目的は、NUMAードごとのメモリ空き容量にNUMAード間でばらつきがあり、またそれらの空き容量が事前にわからないようなシステムで、合計予約サイズをより大きくすることである。ステップは以下の通り。 \verb|IHK_RESERVE_MEM_BALANCED_ENABLE|(型は\verb|int|、デフォルトは0が非ゼロの場合は、NUMAードごとの予約サイズがNUMAード間でなるべく均等になるように予約する。目的は、NUMAードごとのメモリ空き容量にNUMAード間でばらつきがあり、またそれらの空き容量が事前にわからないようなシステムで、合計予約サイズをより大きくすることである。ステップは以下の通り。
@ -686,7 +688,7 @@ IHKはLinuxに以下の機能を提供する。
\subsubsection{設定リストによるメモリ予約動作設定} \subsubsection{設定リストによるメモリ予約動作設定}
\subsubsection*{書式}{\quad} \verb:int ihk_reserve_mem_conf_str(int dev_index, const char *envp, int num_env);: \subsubsection*{書式}{\quad} \verb:int ihk_reserve_mem_conf_str(int dev_index, const char *envp, int num_env);:
\subsubsection*{説明}{\quad} \verb:dev_index:で指定されたIHKデバイスに対し、\verb:envp:と\verb:num_env:で指定された文字列形式の設定リストに従ってメモリ予約の動作設定を行う。本関数は特権ユーザのみが呼び出せる。 \subsubsection*{説明}{\quad} \verb:dev_index:で指定されたIHKデバイスに対し、\verb:envp:と\verb:num_env:で指定された文字列形式の設定リストに従ってメモリ予約の動作設定を行う。なお、設定は次の1回の予約に限り有効で、予約後にはデフォルト設定に戻る。本関数は特権ユーザのみが呼び出せる。
\verb:envp:は\verb:NULL:文字で結合された\verb:num_env:個の設定文字列からなる。各設定文字列は\verb:"KEY=VAL":の形式を持つ。設定可能な項目は以下の通り。 \verb:envp:は\verb:NULL:文字で結合された\verb:num_env:個の設定文字列からなる。各設定文字列は\verb:"KEY=VAL":の形式を持つ。設定可能な項目は以下の通り。
\begin{table}[!h] \begin{table}[!h]
@ -702,7 +704,7 @@ IHKはLinuxに以下の機能を提供する。
\end{tabular} \end{tabular}
\vspace{-0em} \vspace{-0em}
\end{table} \end{table}
\\なお、これ以外の設定は無視される。 \\また、これ以外の設定項目は無視される。
\FloatBarrier \FloatBarrier
\subsubsection*{戻り値} \subsubsection*{戻り値}

View File

@ -1799,7 +1799,8 @@ out:
} }
LIST_HEAD(mckernel_exec_files); LIST_HEAD(mckernel_exec_files);
static DEFINE_SPINLOCK(mckernel_exec_file_lock); DEFINE_SEMAPHORE(mckernel_exec_file_lock);
struct mckernel_exec_file { struct mckernel_exec_file {
ihk_os_t os; ihk_os_t os;
@ -1976,7 +1977,6 @@ int mcexec_open_exec(ihk_os_t os, char * __user filename)
char *fullpath = NULL; char *fullpath = NULL;
char *kfilename = NULL; char *kfilename = NULL;
int len; int len;
unsigned long flags;
if (os_ind < 0) { if (os_ind < 0) {
return -EINVAL; return -EINVAL;
@ -1991,42 +1991,36 @@ int mcexec_open_exec(ihk_os_t os, char * __user filename)
kfilename = kmalloc(PATH_MAX, GFP_KERNEL); kfilename = kmalloc(PATH_MAX, GFP_KERNEL);
if (!kfilename) { if (!kfilename) {
retval = -ENOMEM; retval = -ENOMEM;
kfree(pathbuf);
goto out; goto out;
} }
len = strncpy_from_user(kfilename, filename, PATH_MAX); len = strncpy_from_user(kfilename, filename, PATH_MAX);
if (unlikely(len < 0)) { if (unlikely(len < 0)) {
retval = -EINVAL; retval = -EINVAL;
goto out; goto out_free;
} }
/* fget and list_add should not be interrupted by hardware interrupt */
spin_lock_irqsave(&mckernel_exec_file_lock, flags);
file = open_exec(kfilename); file = open_exec(kfilename);
retval = PTR_ERR(file); retval = PTR_ERR(file);
if (IS_ERR(file)) { if (IS_ERR(file)) {
spin_unlock_irqrestore(&mckernel_exec_file_lock, flags); goto out_free;
goto out;
} }
fullpath = d_path(&file->f_path, pathbuf, PATH_MAX); fullpath = d_path(&file->f_path, pathbuf, PATH_MAX);
if (IS_ERR(fullpath)) { if (IS_ERR(fullpath)) {
fput(file);
spin_unlock_irqrestore(&mckernel_exec_file_lock, flags);
retval = PTR_ERR(fullpath); retval = PTR_ERR(fullpath);
goto out; goto out_put_file;
} }
mcef = kmalloc(sizeof(*mcef), GFP_KERNEL); mcef = kmalloc(sizeof(*mcef), GFP_KERNEL);
if (!mcef) { if (!mcef) {
fput(file);
spin_unlock_irqrestore(&mckernel_exec_file_lock, flags);
retval = -ENOMEM; retval = -ENOMEM;
goto out; goto out_put_file;
} }
memset(mcef, 0, sizeof(struct mckernel_exec_file)); /* debug */ memset(mcef, 0, sizeof(struct mckernel_exec_file)); /* debug */
down(&mckernel_exec_file_lock);
/* Find previous file (if exists) and drop it */ /* Find previous file (if exists) and drop it */
list_for_each_entry(mcef_iter, &mckernel_exec_files, list) { list_for_each_entry(mcef_iter, &mckernel_exec_files, list) {
if (mcef_iter->os == os && mcef_iter->pid == task_tgid_vnr(current)) { if (mcef_iter->os == os && mcef_iter->pid == task_tgid_vnr(current)) {
@ -2047,15 +2041,22 @@ int mcexec_open_exec(ihk_os_t os, char * __user filename)
/* Create /proc/self/exe entry */ /* Create /proc/self/exe entry */
add_pid_entry(os_ind, task_tgid_vnr(current)); add_pid_entry(os_ind, task_tgid_vnr(current));
proc_exe_link(os_ind, task_tgid_vnr(current), fullpath); proc_exe_link(os_ind, task_tgid_vnr(current), fullpath);
spin_unlock_irqrestore(&mckernel_exec_file_lock, flags); up(&mckernel_exec_file_lock);
dprintk("%d open_exec and holding file: %s\n", (int)task_tgid_vnr(current), dprintk("%d open_exec and holding file: %s\n", (int)task_tgid_vnr(current),
kfilename); kfilename);
retval = 0; kfree(kfilename);
out: kfree(pathbuf);
return 0;
out_put_file:
fput(file);
out_free:
kfree(pathbuf); kfree(pathbuf);
kfree(kfilename); kfree(kfilename);
out:
return retval; return retval;
} }
@ -2063,14 +2064,13 @@ int mcexec_close_exec(ihk_os_t os, int pid)
{ {
struct mckernel_exec_file *mcef = NULL; struct mckernel_exec_file *mcef = NULL;
int found = 0; int found = 0;
int os_ind = ihk_host_os_get_index(os); int os_ind = ihk_host_os_get_index(os);
unsigned long flags;
if (os_ind < 0) { if (os_ind < 0) {
return EINVAL; return EINVAL;
} }
spin_lock_irqsave(&mckernel_exec_file_lock, flags); down(&mckernel_exec_file_lock);
list_for_each_entry(mcef, &mckernel_exec_files, list) { list_for_each_entry(mcef, &mckernel_exec_files, list) {
if (mcef->os == os && mcef->pid == pid) { if (mcef->os == os && mcef->pid == pid) {
allow_write_access(mcef->fp); allow_write_access(mcef->fp);
@ -2083,7 +2083,7 @@ int mcexec_close_exec(ihk_os_t os, int pid)
} }
} }
spin_unlock_irqrestore(&mckernel_exec_file_lock, flags); up(&mckernel_exec_file_lock);
return (found ? 0 : EINVAL); return (found ? 0 : EINVAL);
} }

View File

@ -2419,6 +2419,7 @@ int main(int argc, char **argv)
} }
#endif // MCEXEC_BIND_MOUNT #endif // MCEXEC_BIND_MOUNT
/* fget executable as well */
if ((ret = load_elf_desc_shebang(argv[optind], &desc, if ((ret = load_elf_desc_shebang(argv[optind], &desc,
&shebang_argv, 1 /* execvp */))) { &shebang_argv, 1 /* execvp */))) {
fprintf(stderr, "%s: could not load program: %s\n", fprintf(stderr, "%s: could not load program: %s\n",
@ -2860,6 +2861,14 @@ int main(int argc, char **argv)
fprintf(stderr, "error: transferring image\n"); fprintf(stderr, "error: transferring image\n");
return -1; return -1;
} }
/* fput executable */
if ((ret = ioctl(fd, MCEXEC_UP_CLOSE_EXEC)) != 0) {
fprintf(stderr, "error: MCEXEC_UP_CLOSE_EXEC failed with %d\n",
ret);
return 1;
}
fflush(stdout); fflush(stdout);
fflush(stderr); fflush(stderr);
@ -4111,11 +4120,6 @@ int main_loop(struct thread_data_s *my_thread)
It is done by not calling do_syscall_return(fd, cpu, 0, 0, 0, 0, 0); It is done by not calling do_syscall_return(fd, cpu, 0, 0, 0, 0, 0);
here and making McKernel side wait until release_handler() is called. */ here and making McKernel side wait until release_handler() is called. */
/* Drop executable file */
if ((ret = ioctl(fd, MCEXEC_UP_CLOSE_EXEC)) != 0) {
fprintf(stderr, "WARNING: close_exec() couldn't find exec file?\n");
}
__dprintf("__NR_exit/__NR_exit_group: %ld (cpu_id: %d)\n", __dprintf("__NR_exit/__NR_exit_group: %ld (cpu_id: %d)\n",
w.sr.args[0], cpu); w.sr.args[0], cpu);
if(w.sr.number == __NR_exit_group){ if(w.sr.number == __NR_exit_group){
@ -4308,15 +4312,6 @@ gettid_out:
__dprintf("pid(%d): signals and syscall threads OK\n", __dprintf("pid(%d): signals and syscall threads OK\n",
getpid()); getpid());
/* Hold executable also in the child process */
if ((ret = ioctl(fd, MCEXEC_UP_OPEN_EXEC, exec_path))
!= 0) {
fprintf(stderr, "Error: open_exec() fails for %s: %d (fd: %d)\n",
exec_path, ret, fd);
fs->status = -errno;
goto fork_child_sync_pipe;
}
/* Check if we need to limit number of threads in the pool */ /* Check if we need to limit number of threads in the pool */
if ((ret = ioctl(fd, MCEXEC_UP_GET_NUM_POOL_THREADS)) < 0) { if ((ret = ioctl(fd, MCEXEC_UP_GET_NUM_POOL_THREADS)) < 0) {
fprintf(stderr, "Error: obtaining thread pool count\n"); fprintf(stderr, "Error: obtaining thread pool count\n");
@ -4472,6 +4467,7 @@ fork_err:
} }
filename = pathbuf; filename = pathbuf;
/* fget executable as well */
if ((ret = load_elf_desc_shebang(filename, &desc, if ((ret = load_elf_desc_shebang(filename, &desc,
&shebang_argv, 0)) != 0) { &shebang_argv, 0)) != 0) {
goto return_execve1; goto return_execve1;
@ -4569,6 +4565,13 @@ return_execve1:
} }
__dprintf("%s", "execve(): image transferred\n"); __dprintf("%s", "execve(): image transferred\n");
/* fput executable */
if ((ret = ioctl(fd, MCEXEC_UP_CLOSE_EXEC)) != 0) {
fprintf(stderr, "error: MCEXEC_UP_CLOSE_EXEC failed with %d\n",
ret);
return 1;
}
if (close_cloexec_fds(fd) < 0) { if (close_cloexec_fds(fd) < 0) {
ret = EINVAL; ret = EINVAL;
goto return_execve2; goto return_execve2;

2
ihk

Submodule ihk updated: 17cd4c9656...8da0917878

View File

@ -87,7 +87,7 @@ void kputs(char *buf)
debug_spin_unlock_irqrestore(&kmsg_buf->lock, flags_inner); debug_spin_unlock_irqrestore(&kmsg_buf->lock, flags_inner);
kprintf_unlock(flags_outer); kprintf_unlock(flags_outer);
if (irqflags_can_interrupt(flags_outer) && if (!cpu_interrupt_disabled() &&
DEBUG_KMSG_USED > IHK_KMSG_HIGH_WATER_MARK) { DEBUG_KMSG_USED > IHK_KMSG_HIGH_WATER_MARK) {
eventfd(IHK_OS_EVENTFD_TYPE_KMSG); eventfd(IHK_OS_EVENTFD_TYPE_KMSG);
ihk_mc_delay_us(IHK_KMSG_NOTIFY_DELAY); ihk_mc_delay_us(IHK_KMSG_NOTIFY_DELAY);
@ -128,7 +128,7 @@ int __kprintf(const char *format, ...)
} }
debug_spin_unlock_irqrestore(&kmsg_buf->lock, flags_inner); debug_spin_unlock_irqrestore(&kmsg_buf->lock, flags_inner);
if (irqflags_can_interrupt(flags_inner) && if (!cpu_interrupt_disabled() &&
DEBUG_KMSG_USED > IHK_KMSG_HIGH_WATER_MARK) { DEBUG_KMSG_USED > IHK_KMSG_HIGH_WATER_MARK) {
eventfd(IHK_OS_EVENTFD_TYPE_KMSG); eventfd(IHK_OS_EVENTFD_TYPE_KMSG);
ihk_mc_delay_us(IHK_KMSG_NOTIFY_DELAY); ihk_mc_delay_us(IHK_KMSG_NOTIFY_DELAY);
@ -171,7 +171,7 @@ int kprintf(const char *format, ...)
debug_spin_unlock_irqrestore(&kmsg_buf->lock, flags_inner); debug_spin_unlock_irqrestore(&kmsg_buf->lock, flags_inner);
kprintf_unlock(flags_outer); kprintf_unlock(flags_outer);
if (irqflags_can_interrupt(flags_outer) && if (!cpu_interrupt_disabled() &&
DEBUG_KMSG_USED > IHK_KMSG_HIGH_WATER_MARK) { DEBUG_KMSG_USED > IHK_KMSG_HIGH_WATER_MARK) {
eventfd(IHK_OS_EVENTFD_TYPE_KMSG); eventfd(IHK_OS_EVENTFD_TYPE_KMSG);
ihk_mc_delay_us(IHK_KMSG_NOTIFY_DELAY); ihk_mc_delay_us(IHK_KMSG_NOTIFY_DELAY);

View File

@ -23,9 +23,7 @@ extern int num_processors;
void cpu_enable_interrupt(void); void cpu_enable_interrupt(void);
void cpu_disable_interrupt(void); void cpu_disable_interrupt(void);
#ifdef ENABLE_FUGAKU_HACKS
int cpu_interrupt_disabled(void); int cpu_interrupt_disabled(void);
#endif
void cpu_halt(void); void cpu_halt(void);
#ifdef ENABLE_FUGAKU_HACKS #ifdef ENABLE_FUGAKU_HACKS
void cpu_halt_panic(void); void cpu_halt_panic(void);

View File

@ -15,6 +15,11 @@
%{!?kernel_dir: %global kernel_dir /usr/src/kernels/%{kernel_version}} %{!?kernel_dir: %global kernel_dir /usr/src/kernels/%{kernel_version}}
%define krequires %(echo %{kernel_version} | sed "s/.%{_target_cpu}$//") %define krequires %(echo %{kernel_version} | sed "s/.%{_target_cpu}$//")
%define ktag %(echo %{krequires} | tr '-' '_' | sed -e 's/\.el[0-9_]*$//' | sed -e 's/\.\([a-zA-Z]\)/_\1/') %define ktag %(echo %{krequires} | tr '-' '_' | sed -e 's/\.el[0-9_]*$//' | sed -e 's/\.\([a-zA-Z]\)/_\1/')
%if "@ENABLE_UTI@" == "ON"
%define enable_uti 1
%else
%define enable_uti 0
%endif
Name: mckernel Name: mckernel
Version: @MCKERNEL_VERSION@ Version: @MCKERNEL_VERSION@
@ -77,9 +82,10 @@ pushd build
%{?cmake_libdir:-DCMAKE_INSTALL_LIBDIR=%{cmake_libdir}} \ %{?cmake_libdir:-DCMAKE_INSTALL_LIBDIR=%{cmake_libdir}} \
%{?build_target:-DBUILD_TARGET=%{build_target}} \ %{?build_target:-DBUILD_TARGET=%{build_target}} \
%{?toolchain_file:-DCMAKE_TOOLCHAIN_FILE=%{toolchain_file}} \ %{?toolchain_file:-DCMAKE_TOOLCHAIN_FILE=%{toolchain_file}} \
-DENABLE_TOFU=ON -DENABLE_FUGAKU_HACKS=ON \ -DENABLE_TOFU=@ENABLE_TOFU@ -DENABLE_FUGAKU_HACKS=@ENABLE_FUGAKU_HACKS@ \
-DENABLE_KRM_WORKAROUND=OFF -DWITH_KRM=ON \ -DENABLE_KRM_WORKAROUND=@ENABLE_KRM_WORKAROUND@ -DWITH_KRM=@WITH_KRM@ \
-DENABLE_FUGAKU_DEBUG=OFF -DENABLE_UTI=ON \ -DENABLE_FUGAKU_DEBUG=@ENABLE_FUGAKU_DEBUG@ -DENABLE_UTI=@ENABLE_UTI@ \
-DENABLE_FJMPI_WORKAROUND=@ENABLE_FJMPI_WORKAROUND@ \
.. ..
%make_build %make_build
popd popd
@ -112,6 +118,7 @@ popd
%{_libdir}/libsched_yield.so.1.0.0 %{_libdir}/libsched_yield.so.1.0.0
%{_libdir}/libsched_yield.so %{_libdir}/libsched_yield.so
%{_libdir}/libldump2mcdump.so %{_libdir}/libldump2mcdump.so
%if 0%{?enable_uti}
%{_libdir}/libmck_syscall_intercept.so %{_libdir}/libmck_syscall_intercept.so
%{_libdir}/libsyscall_intercept.so.0.1.0 %{_libdir}/libsyscall_intercept.so.0.1.0
%{_libdir}/libsyscall_intercept.so.0 %{_libdir}/libsyscall_intercept.so.0
@ -119,6 +126,7 @@ popd
%{_libdir}/mck/libuti.so.1.0.0 %{_libdir}/mck/libuti.so.1.0.0
%{_libdir}/mck/libuti.so.1 %{_libdir}/mck/libuti.so.1
%{_libdir}/mck/libuti.so %{_libdir}/mck/libuti.so
%endif
%{_sysconfdir}/irqbalance_mck.in %{_sysconfdir}/irqbalance_mck.in
%{_mandir}/man1/mcreboot.1.gz %{_mandir}/man1/mcreboot.1.gz
%{_mandir}/man1/ihkconfig.1.gz %{_mandir}/man1/ihkconfig.1.gz

View File

@ -7,7 +7,7 @@ xpmemやshmobjを利用するライブラリの初期化および基本動作を
□実行手順 □実行手順
1. 1.
SSMで以下のとおりサンプルプログラムをビルドする。 ログインノードで以下のとおりサンプルプログラムをビルドする。
必要に応じて PATHを設定すること。 必要に応じて PATHを設定すること。
tradモード: tradモード:
@ -18,7 +18,7 @@ $ mpifccpx -DMPI -DOPENMP -Kopenmp mpi+affinity.c -o mpi+llvmopenmp-affinity
2. 2.
インタラクティブモードでジョブ実行を開始する。 インタラクティブモードでジョブ実行を開始する。
SSMで以下のように pjsubコマンドを発行する。 ログインノードで以下のように pjsubコマンドを発行する。
rscunitやrscgrp、jobenvは環境に応じて指定すること。 rscunitやrscgrp、jobenvは環境に応じて指定すること。
$ pjsub --interact -L "rscunit=xxx,rscgrp=xxx,jobenv=xxx,node=1" --mpi "proc=2" --sparam wait-time=1000 $ pjsub --interact -L "rscunit=xxx,rscgrp=xxx,jobenv=xxx,node=1" --mpi "proc=2" --sparam wait-time=1000

View File

@ -54,7 +54,8 @@ sudo ./ctrl 1 1 1 0 0 0 1 1 1
(2) uti_perf (2) uti_perf
progress threadを用いたtofu get通信速度を測する。 progress threadを用いたtofu get通信速度を測する。
測定結果は 10 ns 単位で出力される。
オプションは以下のとおり。 オプションは以下のとおり。
-a <x>,<y>,<z>,<a>,<b>,<c> -a <x>,<y>,<z>,<a>,<b>,<c>
@ -80,7 +81,7 @@ progress threadを用いたtofu get通信速度を計測する。
-l <length> -l <length>
tofu get通信するデータサイズ(byte)を指定する。 tofu get通信するデータサイズ(byte)を指定する。
(64 byte 16*1024*1024 - 256 byte、既定値は 16*1024*1024 - 256 byte) (16 Kbyte 16 Mbyte - 256 byte、既定値は 16 Mbyte - 256 byte)
-v -v
デバッグ出力を有効にする。 デバッグ出力を有効にする。
@ -110,3 +111,13 @@ progress threadを用いたtofu get通信速度を計測する。
--recvusleep=<us> --recvusleep=<us>
progress threadの受信完了を確認する間隔 (usec) を指定する。 (既定値は0) progress threadの受信完了を確認する間隔 (usec) を指定する。 (既定値は0)
例えば、tofu座標が 0,0,0,0,0,0 (受信側) と 0,0,0,1,0,0 (送信側) の間で
24プロセス生成して 16 Kbyte のデータを送信する測定を 100回繰り返す場合は
次のように指定する。
(受信側)
./uti_perf -a 0,0,0,1,0,0 -n 100 -f 24 -l 16384 -r
(送信側)
./uti_perf -a 0,0,0,0,0,0 -n 100 -f 24 -l 16384