| Index: net/docs/code-patterns.md
|
| diff --git a/net/docs/code-patterns.md b/net/docs/code-patterns.md
|
| new file mode 100644
|
| index 0000000000000000000000000000000000000000..27a37136728885d3442004c5551e59b4d582a164
|
| --- /dev/null
|
| +++ b/net/docs/code-patterns.md
|
| @@ -0,0 +1,240 @@
|
| +# Chrome Network Stack Common Coding Patterns
|
| +
|
| +## Combined error and byte count into a single value
|
| +
|
| +At many places in the network stack, functions return a value that, if
|
| +positive, indicate a count of bytes that the the function read or
|
| +wrote, and if negative, indicates a network stack error code (see
|
| +[net_error_list.h][]).
|
| +Zero indicates either `net::OK` or zero bytes read (usually EOF)
|
| +depending on the context. This pattern is generally specified by
|
| +an `int` return type.
|
| +
|
| +Many functions also have variables (often named `result` or `rv`) containing
|
| +such a value; this is especially common in the [DoLoop](#DoLoop) pattern
|
| +described below.
|
| +
|
| +## Sync/Async Return
|
| +
|
| +Many network stack routines may return synchronously or
|
| +asynchronously. These functions generally return an int as described
|
| +above. There are three cases:
|
| +
|
| +* If the value is positive or zero, that indicates a synchronous
|
| + successful return, with a zero return value indicating either zero
|
| + bytes/EOF or indicating `net::OK`, depending on context.
|
| +* If the value is negative and != `net::ERR_IO_PENDING`, it is an error
|
| + code specifying a synchronous failure.
|
| +* If the return value is the special value `net::ERR_IO_PENDING`, it
|
| + indicates that the routine will complete asynchronously. A reference to
|
| + any provided IOBuffer will be retained by the called entity until
|
| + completion, to be written into or read from as required.
|
| + If there is a callback argument, that callback will be called upon
|
| + completion with the return value; if there is no callback argument, it
|
| + usually means that some known callback mechanism will be employed.
|
| +
|
| +## DoLoop
|
| +
|
| +The DoLoop pattern is used in the network stack to construct simple
|
| +state machines. It is used for cases in which processing is basically
|
| +single-threaded and could be written in a single function, if that
|
| +function could block waiting for input. Generally, initiation of a
|
| +state machine is triggered by some method invocation by a class
|
| +consumer, and that state machine is driven (possibly across
|
| +asynchronous IO initiated by the class) until the operation requested
|
| +by the method invocation completes, at which point the state variable is
|
| +set to `STATE_NONE` and the consumer notified.
|
| +
|
| +Cases which do not fit into this single-threaded, single consumer
|
| +operation model are generally adapted in some way to fit the model,
|
| +either by multiple state machines (e.g. independent state machines for
|
| +reading and writing, if each can be initiated while the other is
|
| +outstanding) or by storing information across consumer invocations and
|
| +returns that can be used to restart the state machine in the proper
|
| +state.
|
| +
|
| +Any class using this pattern will contain an enum listing all states
|
| +of that machine, and define a function, `DoLoop()`, to drive that state
|
| +machine. If a class has multiple state machines (as above) it will
|
| +have multiple methods (e.g. `DoReadLoop()` and `DoWriteLoop()`) to drive
|
| +those different machines.
|
| +
|
| +The characteristics of the DoLoop pattern are:
|
| +
|
| +* Each state has a corresponding function which is called by `DoLoop()`
|
| + for handling when the state machine is in that state. Generally the
|
| + states are named STATE`_<`STATE_NAME`>` (upper case separated by
|
| + underscores), and the routine is named Do`<`StateName`>` (CamelCase).
|
| + For example:
|
| +
|
| + enum State {
|
| + STATE_NONE,
|
| + STATE_INIT,
|
| + STATE_FOO,
|
| + STATE_FOO_COMPLETE,
|
| + };
|
| + int DoInit();
|
| + int DoFoo();
|
| + int DoFooComplete(int result);
|
| +
|
| +* Each state handling function has two basic responsibilities in
|
| + addition to state specific handling: Setting the data member
|
| + (named `next_state_` or something similar)
|
| + to specify the next state, and returning a `net::Error` (or combined
|
| + error and byte count, as above).
|
| +
|
| +* On each `DoLoop()` iteration, the function saves the next state to a local
|
| + variable and resets to a default state (`STATE_NONE`),
|
| + and then calls the appropriate state handling based on the
|
| + original value of the next state. This looks like:
|
| +
|
| + do {
|
| + State state = io_state_;
|
| + next_state_ = STATE_NONE;
|
| + switch (state) {
|
| + case STATE_INIT:
|
| + result = DoInit();
|
| + break;
|
| + ...
|
| +
|
| + This pattern is followed primarily to ensure that in the event of
|
| + a bug where the next state isn't set, the loop terminates rather
|
| + than loops infinitely. It's not a perfect mitigation, but works
|
| + well as a defensive measure.
|
| +
|
| +* If a given state may complete asynchronously (for example,
|
| + writing to an underlying transport socket), then there will often
|
| + be split states, such as `STATE_WRITE` and
|
| + `STATE_WRITE_COMPLETE`. The first state is responsible for
|
| + starting/continuing the original operation, while the second state
|
| + is responsible for handling completion (e.g. success vs error,
|
| + complete vs. incomplete writes), and determining the next state to
|
| + transition to.
|
| +
|
| +* While the return value from each call is propagated through the loop
|
| + to the next state, it is expected that for most state transitions the
|
| + return value will be `net::OK`, and that an error return will also
|
| + set the state to `STATE_NONE` or fail to override the default
|
| + assignment to `STATE_DONE` to exit the loop and return that
|
| + error to the caller. This is often asserted with a DCHECK, e.g.
|
| +
|
| + case STATE_FOO:
|
| + DCHECK_EQ(result, OK);
|
| + result = DoFoo();
|
| + break;
|
| +
|
| + The exception to this pattern is split states, where an IO
|
| + operation has been dispatched, and the second state is handling
|
| + the result. In that case, the second state's function takes the
|
| + result code:
|
| +
|
| + case STATE_FOO_COMPLETE:
|
| + result = DoFooComplete(result);
|
| + break;
|
| +
|
| +* If the return value from the state handling function is
|
| + `net::ERR_IO_PENDING`, that indicates that the function has arranged
|
| + for `DoLoop()` to be called at some point in the future, when further
|
| + progress can be made on the state transitions. The `next_state_` variable
|
| + will have been set to the proper value for handling that incoming
|
| + call. In this case, `DoLoop()` will exit. This often occurs between
|
| + split states, as described above.
|
| +
|
| +* The DoLoop mechanism is generally invoked in response to a consumer
|
| + calling one of its methods. While the operation that method
|
| + requested is occuring, the state machine stays active, possibly
|
| + over multiple asynchronous operations and state transitions. When
|
| + that operation is complete, the state machine transitions to
|
| + `STATE_NONE` (by a `DoLoop()` callee not setting `next_state_`) or
|
| + explicitly to `STATE_DONE` (indicating that the operation is
|
| + complete *and* the state machine is not amenable to further
|
| + driving). At this point the consumer is notified of the completion
|
| + of the operation (by synchronous return or asynchronous callback).
|
| +
|
| + Note that this implies that when `DoLoop()` returns, one of two
|
| + things will be true:
|
| +
|
| + * The return value will be `net::ERR_IO_PENDING`, indicating that the
|
| + caller should take no action and instead wait for asynchronous
|
| + notification.
|
| + * The state of the machine will be either `STATE_DONE` or `STATE_NONE`,
|
| + indicating that the operation that first initiated the `DoLoop()` has
|
| + completed.
|
| +
|
| + This invariant reflects and enforces the single-threaded (though
|
| + possibly asynchronous) nature of the driven state machine--the
|
| + machine is always executing one requested operation.
|
| +
|
| +* `DoLoop()` is called from two places: a) methods exposed to the consumer
|
| + for specific operations (e.g. `ReadHeaders()`), and b) an IO completion
|
| + callbacks called asynchronously by spawned IO operations.
|
| +
|
| + In the first case, the return value from `DoLoop()` is returned directly
|
| + to the caller; if the operation completed synchronously, that will
|
| + contain the operation result, and if it completed asynchronously, it
|
| + will be `net::ERR_IO_PENDING`. For example (from
|
| + `HttpStreamParser`, abridged for clarity):
|
| +
|
| + int HttpStreamParser::ReadResponseHeaders(
|
| + const CompletionCallback& callback) {
|
| + DCHECK(io_state_ == STATE_NONE || io_state_ == STATE_DONE);
|
| + DCHECK(callback_.is_null());
|
| + DCHECK(!callback.is_null());
|
| +
|
| + int result = OK;
|
| + io_state_ = STATE_READ_HEADERS;
|
| +
|
| + result = DoLoop(result);
|
| +
|
| + if (result == ERR_IO_PENDING)
|
| + callback_ = callback;
|
| +
|
| + return result > 0 ? OK : result;
|
| + }
|
| +
|
| + In the second case, the IO completion callback will examine the
|
| + return value from `DoLoop()`. If it is `net::ERR_IO_PENDING`, no
|
| + further action will be taken, and the IO completion callback will be
|
| + called again at some future point. If it is not
|
| + `net::ERR_IO_PENDING`, that is a signal that the operation has
|
| + completed, and the IO completion callback will call the appropriate
|
| + consumer callback to notify the consumer that the operation has
|
| + completed. Note that it is important that this callback be done
|
| + from the IO completion callback and not from `DoLoop()` or a
|
| + `DoLoop()` callee, both to support the sync/async error return
|
| + (DoLoop and its callees don't know the difference) and to avoid
|
| + consumer callbacks deleting the object out from under `DoLoop()`.
|
| + Example:
|
| +
|
| + void HttpStreamParser::OnIOComplete(int result) {
|
| + result = DoLoop(result);
|
| +
|
| + if (result != ERR_IO_PENDING && !callback_.is_null())
|
| + base::ResetAndReturn(&callback_).Run(result);
|
| + }
|
| +
|
| +* The DoLoop pattern has no concept of different events arriving for
|
| + a single state; each state, if waiting, is waiting for one
|
| + particular event, and when `DoLoop()` is invoked when the machine is
|
| + in that state, it will handle that event. This reflects the
|
| + single-threaded model for operations spawned by the state machine.
|
| +
|
| +Public class methods generally have very little processing, primarily wrapping
|
| +`DoLoop()`. For `DoLoop()` entry this involves setting the `next_state_`
|
| +variable, and possibly making copies of arguments into class members. For
|
| +`DoLoop()` exit, it involves inspecting the return and passing it back to
|
| +the caller, and in the asynchronous case, saving any passed completion callback
|
| +for executing by a future subsidiary IO completion (see above example).
|
| +
|
| +This idiom allows synchronous and asynchronous logic to be written in
|
| +the same fashion; it's all just state transition handling. For mostly
|
| +linear state diagrams, the handling code can be very easy to
|
| +comprehend, as such code is usually written linearly (in different
|
| +handling functions) in the order it's executed.
|
| +
|
| +For examples of this idiom, see
|
| +
|
| +* [HttpStreamParser::DoLoop](https://code.google.com/p/chromium/codesearch#chromium/src/net/http/http_stream_parser.cc&q=HttpStreamParser::DoLoop&sq=package:chromium).
|
| +* [HttpNetworkTransaction::DoLoop](https://code.google.com/p/chromium/codesearch#chromium/src/net/http/http_network_transaction.cc&q=HttpNetworkTransaction::DoLoop&sq=package:chromium)
|
| +
|
| +[net_error_list.h]: https://chromium.googlesource.com/chromium/src/+/master/net/base/net_error_list.h#1
|
|
|