Emit rank information after ovni_thread_init
This commit is contained in:
		
							parent
							
								
									c9bbd542c5
								
							
						
					
					
						commit
						bb4e4d7e56
					
				| @ -102,12 +102,11 @@ instr_start(int rank, int nranks) | |||||||
| 
 | 
 | ||||||
| 	ovni_version_check(); | 	ovni_version_check(); | ||||||
| 	ovni_proc_init(1, rankname, getpid()); | 	ovni_proc_init(1, rankname, getpid()); | ||||||
|  | 	ovni_thread_init(get_tid()); | ||||||
| 
 | 
 | ||||||
| 	if (nranks > 0) | 	if (nranks > 0) | ||||||
| 		ovni_proc_set_rank(rank, nranks); | 		ovni_proc_set_rank(rank, nranks); | ||||||
| 
 | 
 | ||||||
| 	ovni_thread_init(get_tid()); |  | ||||||
| 
 |  | ||||||
| 	/* All ranks inform CPUs */ | 	/* All ranks inform CPUs */ | ||||||
| 	for (int i = 0; i < nranks; i++) | 	for (int i = 0; i < nranks; i++) | ||||||
| 		ovni_add_cpu(i, i); | 		ovni_add_cpu(i, i); | ||||||
|  | |||||||
| @ -31,8 +31,8 @@ main(void) | |||||||
| 		die("snprintf failed"); | 		die("snprintf failed"); | ||||||
| 
 | 
 | ||||||
| 	ovni_proc_init(1 + app, loom, getpid()); | 	ovni_proc_init(1 + app, loom, getpid()); | ||||||
| 	ovni_thread_init(get_tid()); |  | ||||||
| 	ovni_proc_set_rank(rank, nranks); | 	ovni_proc_set_rank(rank, nranks); | ||||||
|  | 	ovni_thread_init(get_tid()); | ||||||
| 
 | 
 | ||||||
| 	/* Leader of the segment, must emit CPUs */ | 	/* Leader of the segment, must emit CPUs */ | ||||||
| 	if (rank % N == 0) { | 	if (rank % N == 0) { | ||||||
|  | |||||||
| @ -37,8 +37,8 @@ start_delayed(int rank, int nranks) | |||||||
| 
 | 
 | ||||||
| 	ovni_version_check(); | 	ovni_version_check(); | ||||||
| 	ovni_proc_init(1, rankname, getpid()); | 	ovni_proc_init(1, rankname, getpid()); | ||||||
| 	ovni_proc_set_rank(rank, nranks); |  | ||||||
| 	ovni_thread_init(get_tid()); | 	ovni_thread_init(get_tid()); | ||||||
|  | 	ovni_proc_set_rank(rank, nranks); | ||||||
| 	instr_require("ovni"); | 	instr_require("ovni"); | ||||||
| 
 | 
 | ||||||
| 	/* All ranks inform CPUs */ | 	/* All ranks inform CPUs */ | ||||||
|  | |||||||
| @ -19,8 +19,8 @@ start(int rank, int nranks) | |||||||
| 
 | 
 | ||||||
| 	/* Only one loom */ | 	/* Only one loom */ | ||||||
| 	ovni_proc_init(1, hostname, getpid()); | 	ovni_proc_init(1, hostname, getpid()); | ||||||
| 	ovni_proc_set_rank(rank, nranks); |  | ||||||
| 	ovni_thread_init(get_tid()); | 	ovni_thread_init(get_tid()); | ||||||
|  | 	ovni_proc_set_rank(rank, nranks); | ||||||
| 
 | 
 | ||||||
| 	/* Only emit a subset of CPUs up to the rank number */ | 	/* Only emit a subset of CPUs up to the rank number */ | ||||||
| 	for (int i = 0; i <= rank; i++) | 	for (int i = 0; i <= rank; i++) | ||||||
|  | |||||||
		Loading…
	
	
			
			x
			
			
		
	
		Reference in New Issue
	
	Block a user