| 375 | |
| 376 | |
| 377 | Timeout TaskStatusUpdateManagerProcess::forward( |
| 378 | const StatusUpdate& update, |
| 379 | const Duration& duration) |
| 380 | { |
| 381 | CHECK(!paused); |
| 382 | |
| 383 | VLOG(1) << "Forwarding task status update " << update << " to the agent"; |
| 384 | |
| 385 | // Forward the update. |
| 386 | forward_(update); |
| 387 | |
| 388 | // Send a message to self to resend after some delay if no ACK is received. |
| 389 | return delay(duration, |
| 390 | self(), |
| 391 | &TaskStatusUpdateManagerProcess::timeout, |
| 392 | duration).timeout(); |
| 393 | } |
| 394 | |
| 395 | |
| 396 | Future<bool> TaskStatusUpdateManagerProcess::acknowledgement( |