@@ -76,7 +76,7 @@ void sem_timedwait_relative(sem_t* sem, int timeout) {
7676void join_begin (join_t & join, std::string join_tag) {
7777 int fd;
7878 join.sem_name = fmt::format (" /uenv-run_sem-{}" , join_tag);
79- join.shm_name = fmt::format (" /uenv-run-shm -{}" , join_tag);
79+ join.shm_name = fmt::format (" /uenv-run_shm -{}" , join_tag);
8080
8181 // Serialize.
8282 join.sem = sem_open (join.sem_name .c_str (), O_CREAT , 0600 , 1 );
@@ -86,9 +86,9 @@ void join_begin(join_t& join, std::string join_tag) {
8686 // Am I the winner?
8787 fd = shm_open (join.shm_name .c_str (), O_CREAT | O_EXCL | O_RDWR , 0600 );
8888 if (fd > 0 ) {
89- spdlog::trace (" join: I won" );
89+ spdlog::trace (" join:: I won! PID {} " , getpid () );
9090 join.winner_p = true ;
91- // WARNING: The segment is resized later in join_env_save().
91+ // TODO WARNING: The segment is resized later in join_env_save().
9292 Z_e (ftruncate (fd, sizeof (*join.shared )));
9393 } else {
9494 std::string err{strerror (errno)};
@@ -112,23 +112,24 @@ void join_begin(join_t& join, std::string join_tag) {
112112/* End coordinated section of namespace joining. */
113113void join_end (join_t & join, int join_ct) {
114114 if (join.winner_p ) { // winner still serial
115- spdlog::warn (" join: winner initializing shared data" );
115+ spdlog::trace (" join: winner initializing shared data" );
116116 join.shared ->winner_pid = getpid ();
117117 join.shared ->proc_left_ct = join_ct;
118118 } else // losers serialize
119119 sem_timedwait_relative (join.sem , JOIN_TIMEOUT );
120120
121121 join.shared ->proc_left_ct --;
122- spdlog::warn (" join: {} peers left excluding myself" ,
123- join.shared ->proc_left_ct );
122+ spdlog::trace (" join: {} peers left excluding myself" ,
123+ join.shared ->proc_left_ct );
124124
125125 if (join.shared ->proc_left_ct <= 0 ) {
126- spdlog::warn (" join: cleaning up IPC resources" );
126+ spdlog::trace (" join: cleaning up IPC resources" );
127127 Tf_ (join.shared ->proc_left_ct == 0 ,
128- " expected 0 peers left but found {}" , join.shared ->proc_left_ct );
129- Zfe (sem_unlink (join.sem_name .c_str ()), " can't unlink sem: {}" ,
128+ " join: expected 0 peers left but found {}" ,
129+ join.shared ->proc_left_ct );
130+ Zfe (sem_unlink (join.sem_name .c_str ()), " join: can't unlink sem: {}" ,
130131 join.sem_name .c_str ());
131- Zfe (shm_unlink (join.shm_name .c_str ()), " can't unlink shm: {}" ,
132+ Zfe (shm_unlink (join.shm_name .c_str ()), " join: can't unlink shm: {}" ,
132133 join.shm_name .c_str ());
133134 }
134135
@@ -137,7 +138,7 @@ void join_end(join_t& join, int join_ct) {
137138 Z_e (munmap (join.shared , sizeof (*join.shared )));
138139 Z_e (sem_close (join.sem ));
139140
140- spdlog::warn (" join: done" );
141+ spdlog::trace (" join: done" );
141142}
142143
143144// / Same effect as `unshare --mount --map-root-user`
0 commit comments