mirror of
https://fuchsia.googlesource.com/third_party/pigweed.googlesource.com/pigweed/pigweed
synced 2024-09-20 22:00:58 +00:00
1e63673a37
- Create the pw_transfer module. - Start the pw_transfer docs. Change-Id: I2d3b4f3e719960167ee28ba4ca84eb809bf94bc1 Reviewed-on: https://pigweed-review.googlesource.com/c/pigweed/pigweed/+/49022 Pigweed-Auto-Submit: Wyatt Hepler <hepler@google.com> Reviewed-by: Keir Mierle <keir@google.com> Reviewed-by: Alexei Frolov <frolv@google.com> Commit-Queue: Wyatt Hepler <hepler@google.com>
155 lines
3.5 KiB
ReStructuredText
155 lines
3.5 KiB
ReStructuredText
.. _module-pw_transfer:
|
|
|
|
===========
|
|
pw_transfer
|
|
===========
|
|
|
|
.. attention::
|
|
|
|
``pw_transfer`` is under construction and so is its documentation.
|
|
|
|
--------
|
|
Protocol
|
|
--------
|
|
|
|
Protocol buffer definition
|
|
==========================
|
|
.. literalinclude:: transfer.proto
|
|
:language: protobuf
|
|
:lines: 14-
|
|
|
|
Server to client transfer (read)
|
|
================================
|
|
.. seqdiag::
|
|
:scale: 110
|
|
|
|
seqdiag {
|
|
default_note_color = aliceblue;
|
|
|
|
client -> server [
|
|
label = "set transfer parameters",
|
|
leftnote = "transfer_id\noffset\npending_bytes\nmax_chunk_size\nchunk_delay"
|
|
];
|
|
|
|
client <-- server [
|
|
noactivate,
|
|
label = "requested bytes\n(zero or more chunks)",
|
|
rightnote = "offset\ndata\n(remaining_bytes)"
|
|
];
|
|
|
|
client --> server [
|
|
noactivate,
|
|
label = "update transfer parameters\n(as needed)",
|
|
leftnote = "offset\npending_bytes\n(max_chunk_size)\n(chunk_delay)"
|
|
];
|
|
|
|
client <- server [
|
|
noactivate,
|
|
label = "final chunk",
|
|
rightnote = "offset\ndata\nremaining_bytes=0"
|
|
];
|
|
|
|
client -> server [
|
|
noactivate,
|
|
label = "received final chunk",
|
|
leftnote = "pending_bytes=0"
|
|
];
|
|
|
|
client <- server [
|
|
label = "done"
|
|
];
|
|
}
|
|
|
|
Client to server transfer (write)
|
|
=================================
|
|
.. seqdiag::
|
|
:scale: 110
|
|
|
|
seqdiag {
|
|
default_note_color = aliceblue;
|
|
|
|
client -> server [
|
|
label = "start",
|
|
leftnote = "transfer_id"
|
|
];
|
|
|
|
client <- server [
|
|
noactivate,
|
|
label = "set transfer parameters",
|
|
rightnote = "offset\npending_bytes\nmax_chunk_size\nchunk_delay"
|
|
];
|
|
|
|
client --> server [
|
|
noactivate,
|
|
label = "requested bytes\n(zero or more chunks)",
|
|
leftnote = "offset\ndata\n(remaining_bytes)"
|
|
];
|
|
|
|
client <-- server [
|
|
noactivate,
|
|
label = "update transfer parameters\n(as needed)",
|
|
rightnote = "offset\npending_bytes\n(max_chunk_size)\n(chunk_delay)"
|
|
];
|
|
|
|
client -> server [
|
|
noactivate,
|
|
label = "final chunk",
|
|
leftnote = "offset\ndata\nremaining_bytes=0"
|
|
];
|
|
|
|
client <- server [
|
|
label = "done"
|
|
];
|
|
}
|
|
|
|
Transmitter flow
|
|
================
|
|
.. mermaid::
|
|
|
|
graph TD
|
|
start([Client initiates<br>transfer]) -->data_request
|
|
data_request[Receive transfer<br>parameters]-->send_chunk
|
|
|
|
send_chunk[Send chunk]-->sent_all
|
|
|
|
sent_all{Sent final<br>chunk?} -->|yes|wait
|
|
sent_all-->|no|sent_requested
|
|
|
|
sent_requested{Sent all<br>pending?}-->|yes|data_request
|
|
sent_requested-->|no|send_chunk
|
|
|
|
wait[Wait for receiver]-->is_done
|
|
|
|
is_done{Received<br>final chunk?}-->|yes|done
|
|
is_done-->|no|data_request
|
|
|
|
done([Transfer complete])
|
|
|
|
Receiver flow
|
|
=============
|
|
.. mermaid::
|
|
|
|
graph TD
|
|
start([Client initiates<br>transfer]) -->request_bytes
|
|
request_bytes[Set transfer<br>parameters]-->wait
|
|
|
|
wait[Wait for chunk]-->received_chunk
|
|
|
|
received_chunk{Received<br>chunk by<br>deadline?}-->|no|request_bytes
|
|
received_chunk-->|yes|check_chunk
|
|
|
|
check_chunk{Correct<br>offset?} -->|yes|process_chunk
|
|
check_chunk --> |no|request_bytes
|
|
|
|
process_chunk[Process chunk]-->final_chunk
|
|
|
|
final_chunk{Final<br>chunk?}-->|yes|signal_completion
|
|
final_chunk{Final<br>chunk?}-->|no|received_requested
|
|
|
|
received_requested{Received all<br>pending?}-->|yes|request_bytes
|
|
received_requested-->|no|wait
|
|
|
|
signal_completion[Signal completion]-->done
|
|
|
|
done([Transfer complete])
|