| 239 | } |
| 240 | |
| 241 | void resetCoordinatorSocket(int sock) |
| 242 | { |
| 243 | JASSERT(Util::isValidFd(sock)); |
| 244 | JASSERT(sock != PROTECTED_COORD_FD); |
| 245 | Util::changeFd(sock, PROTECTED_COORD_FD); |
| 246 | JASSERT(Util::isValidFd(coordinatorSocket)); |
| 247 | |
| 248 | JTRACE("Informing coordinator of new process") (UniquePid::ThisProcess()); |
| 249 | |
| 250 | DmtcpMessage msg(DMT_UPDATE_PROCESS_INFO_AFTER_FORK); |
| 251 | if (dmtcp_virtual_to_real_pid) { |
| 252 | msg.realPid = dmtcp_virtual_to_real_pid(getpid()); |
| 253 | } else { |
| 254 | msg.realPid = getpid(); |
| 255 | } |
| 256 | sendMsgToCoordinator(msg); |
| 257 | } |
| 258 | |
| 259 | void atForkPrepare() |
| 260 | { |
no test coverage detected