| 829 | |
| 830 | |
| 831 | Future<WriteResponse> write( |
| 832 | size_t quorum, |
| 833 | const Shared<Network>& network, |
| 834 | uint64_t proposal, |
| 835 | const Action& action) |
| 836 | { |
| 837 | WriteProcess* process = |
| 838 | new WriteProcess( |
| 839 | quorum, |
| 840 | network, |
| 841 | proposal, |
| 842 | action); |
| 843 | |
| 844 | Future<WriteResponse> future = process->future(); |
| 845 | spawn(process, true); |
| 846 | return future; |
| 847 | } |
| 848 | |
| 849 | |
| 850 | Future<Nothing> learn(const Shared<Network>& network, const Action& action) |