Transport disembark #4220
Merged
Transport disembark #4220
Conversation
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
nigoroll
force-pushed
the
transport_disembark
branch
2 times, most recently
from
357f202 to
4fd6489
Compare
nigoroll
force-pushed
the
transport_disembark
branch
from
4fd6489 to
0238f28
Compare
|
force-pushed after #4224 merge |
|
bugwash: OK, need to resolve conflicts, will merge then |
This is in preparation of simplifications and to be able disembark during delivery.
now that boc lives in struct req, it is obsolete also change some subordinate helper functions
To prepare for the next commit, we introduce a new finish step to the request FSM, which is just the former tail of cnt_transmit().
This allows the transport's delivery function to disembark the thread by returning VTR_D_DISEMBARK. In this case, CNT_Request() needs to be called at a later time to continue. It is the vtr_deliver_f's responsibility to clear req->wrk because only it can ensure proper synchronization with another thread which might already be running.
vmod_debug_transports.c demonstrates the basic mechanics of disembarking a request from the vrt_deliver_f, delivering a body from another worker and finishing the request.
nigoroll
force-pushed
the
transport_disembark
branch
from
0238f28 to
0cfd6cd
Compare
Sign up for free
to join this conversation on GitHub.
Already have an account?
Sign in to comment
Add this suggestion to a batch that can be applied as a single commit.
This suggestion is invalid because no changes were made to the code.
Suggestions cannot be applied while the pull request is closed.
Suggestions cannot be applied while viewing a subset of changes.
Only one suggestion per line can be applied in a batch.
Add this suggestion to a batch that can be applied as a single commit.
Applying suggestions on deleted lines is not supported.
You must change the existing code in this line in order to create a valid suggestion.
Outdated suggestions cannot be applied.
This suggestion has been applied or marked resolved.
Suggestions cannot be applied from pending reviews.
Suggestions cannot be applied on multi-line comments.
Suggestions cannot be applied while the pull request is queued to merge.
Suggestion cannot be applied right now. Please check back later.
This is the next chapter of the book of AI, see #4209
To eventually get to event driven, asynchronous IO where a smaller number of threads handles a large number of requests, we also need a way to disembark a request from a worker and have another thread pick up where it left of, then reentering the state machine later to finish off.
Thanks to the already existing disembark facility used for waitinglist wakeups, implementing this is pretty straight forward: We basically only need to allow the vtr_deliver_f (transport deliver function) to tell the state engine to disembark, add a "finish" state, and everything else more or less works out of the box.
The last commit has a demonstration in a test case.
Everything else in this patch is refactoring.