| 103 | } |
| 104 | |
| 105 | void |
| 106 | dmtcp_ssh_drain() |
| 107 | { |
| 108 | if (!sshPluginEnabled) { |
| 109 | return; |
| 110 | } |
| 111 | |
| 112 | JASSERT(theDrainer == NULL); |
| 113 | theDrainer = new SSHDrainer(); |
| 114 | if (isSshdProcess) { // dmtcp_ssh process |
| 115 | theDrainer->beginDrainOf(STDIN_FILENO, sshStdin); |
| 116 | theDrainer->beginDrainOf(STDOUT_FILENO); |
| 117 | theDrainer->beginDrainOf(STDERR_FILENO); |
| 118 | } else { |
| 119 | theDrainer->beginDrainOf(sshStdin); |
| 120 | theDrainer->beginDrainOf(sshStdout, STDOUT_FILENO); |
| 121 | theDrainer->beginDrainOf(sshStderr, STDERR_FILENO); |
| 122 | } |
| 123 | theDrainer->monitorSockets(DRAINER_CHECK_FREQ); |
| 124 | } |
| 125 | |
| 126 | void |
| 127 | dmtcp_ssh_resume() |
no test coverage detected