209    std::unique_ptr<IptablesProcess> *process =  in sendCommand()  local
220     IptablesProcess *existingProcess = process->get();  in sendCommand()
234         process->reset(newProcess);  in sendCommand()
237     if (!android::base::WriteFully((*process)->stdIn, command.data(), command.length())) {  in sendCommand()
242     if (!android::base::WriteFully((*process)->stdIn, PING, PING_SIZE)) {  in sendCommand()
247     if (!drainAndWaitForAck(*process, command, output)) {  in sendCommand()
255 void IptablesRestoreController::maybeLogStderr(const std::unique_ptr<IptablesProcess> &process,  in maybeLogStderr()  argument
257     if (process->errBuf.empty()) {  in maybeLogStderr()
267           command.c_str(), process->errBuf.c_str());  in maybeLogStderr()
268     process->errBuf.clear();  in maybeLogStderr()
272 bool IptablesRestoreController::drainAndWaitForAck(const std::unique_ptr<IptablesProcess> &process,  in drainAndWaitForAck()  argument
279             poll(process->pollFds, ARRAY_SIZE(process->pollFds), POLL_TIMEOUT_MS));  in drainAndWaitForAck()
293         for (size_t i = 0; i < ARRAY_SIZE(process->pollFds); ++i) {  in drainAndWaitForAck()
294             const struct pollfd &pollfd = process->pollFds[i];  in drainAndWaitForAck()
323                         process->errBuf.append(buffer, size);  in drainAndWaitForAck()
330                 process->stop();  in drainAndWaitForAck()
336     if (!receivedAck && !process->processTerminated) {  in drainAndWaitForAck()
337         ALOGE("Timed out waiting for response from iptables process %d", process->pid);  in drainAndWaitForAck()
340         process->stop();  in drainAndWaitForAck()
343     maybeLogStderr(process, command);  in drainAndWaitForAck()