| 1552 | } |
| 1553 | |
| 1554 | void retry(const id::UUID& _connectionId, const TaskID& taskId) |
| 1555 | { |
| 1556 | if (connectionId != _connectionId) { |
| 1557 | VLOG(1) << "Ignoring retry attempt from a stale connection"; |
| 1558 | return; |
| 1559 | } |
| 1560 | |
| 1561 | CHECK_EQ(SUBSCRIBED, state); |
| 1562 | |
| 1563 | process::http::connect(agent) |
| 1564 | .onAny(defer(self(), |
| 1565 | &Self::_retry, |
| 1566 | lambda::_1, |
| 1567 | connectionId.get(), |
| 1568 | taskId)); |
| 1569 | } |
| 1570 | |
| 1571 | void _retry( |
| 1572 | const Future<Connection>& connection, |