aboutsummaryrefslogtreecommitdiff
Commit message (Collapse)AuthorAgeFilesLines
* try debugAlex Auvolat2022-09-011-0/+1
|
* Implement request cancellationAlex Auvolat2022-09-014-21/+159
|
* fix trace messageAlex Auvolat2022-09-011-0/+1
|
* Merge branch 'fix-ping' into stream-bodyAlex Auvolat2022-09-015-57/+61
|\
| * SVR -> SRVAlex Auvolat2022-08-311-1/+1
| |
| * Be more lenient on pingsAlex Auvolat2022-08-311-9/+5
| |
| * Better messages in proto.rsAlex Auvolat2022-08-311-12/+31
| |
| * add debug_name in proto to differenciate messagesAlex Auvolat2022-08-313-13/+25
| |
| * Add dump of sending queueAlex Auvolat2022-08-311-0/+11
| |
| * Ping less frequentlyAlex Auvolat2022-08-311-39/+36
| |
* | Add actual support for order tagAlex Auvolat2022-09-014-37/+81
| |
* | Add OrderTag to Req and Resp, refactor errorsAlex Auvolat2022-09-0110-119/+139
| |
* | Also encode errorkind in streamAlex Auvolat2022-09-014-46/+56
| |
* | Stream errors are now std::io::ErrorAlex Auvolat2022-09-014-54/+64
| |
* | Refactor: create a BytesBuf utility crate (will also be usefull in Garage)Alex Auvolat2022-09-013-43/+177
| |
* | recv side: use unbounded channel to remove deadlockAlex Auvolat2022-09-011-10/+8
| |
* | Remove useless phantom and pub(crate)Alex Auvolat2022-08-311-7/+2
| |
* | Fix things going wrong when sending chan is closedAlex Auvolat2022-07-263-15/+34
| |
* | Add stream example to fullmesh exampleAlex Auvolat2022-07-261-5/+130
| |
* | Add some debuggingAlex Auvolat2022-07-255-26/+63
| |
* | Cargo fmtAlex Auvolat2022-07-251-3/+2
| |
* | Remove broken testAlex Auvolat2022-07-251-95/+0
| |
* | Remove blocking_send that crashesAlex Auvolat2022-07-251-1/+3
| |
* | Conversion between ByteStream and AsyncReadAlex Auvolat2022-07-223-3/+52
| |
* | Bump netapp version to 0.5Alex Auvolat2022-07-222-2/+2
| |
* | Add Req::newAlex Auvolat2022-07-221-0/+4
| |
* | Impose static lifetime on message and responseAlex Auvolat2022-07-222-5/+5
| |
* | Remove copy of serialized thing in encodeAlex Auvolat2022-07-221-7/+4
| |
* | Cargo fmt; better adapt with_capacity_valuesAlex Auvolat2022-07-223-29/+18
| |
* | Terminology: don't use the word "body" anymore, talk of "attached stream"Alex Auvolat2022-07-222-45/+42
| |
* | Add Resp::into_partsAlex Auvolat2022-07-221-4/+8
| |
* | Small optimizationAlex Auvolat2022-07-222-1/+8
| |
* | Add commentAlex Auvolat2022-07-221-0/+3
| |
* | Simplify send.rsAlex Auvolat2022-07-222-166/+68
| |
* | Move things around and fix error bitAlex Auvolat2022-07-225-10/+9
| |
* | Use bounded channels on receive side for backpressureAlex Auvolat2022-07-224-32/+37
| |
* | Clean up framing protocolAlex Auvolat2022-07-229-265/+429
| |
* | Hide streaming versions as much as possibleAlex Auvolat2022-07-227-48/+59
| |
* | Propose alternative APIAlex Auvolat2022-07-217-93/+216
| |
* | One possibility, but I don't like itAlex Auvolat2022-07-218-55/+23
| |
* | Rename AutoSerialize into SimpleMessage and refactor a bitAlex Auvolat2022-07-218-69/+114
| |
* | Use Bytes instead of Vec<u8>Alex Auvolat2022-07-216-20/+17
| |
* | Refactor send.rsAlex Auvolat2022-07-212-60/+61
| |
* | Move things aroundAlex Auvolat2022-07-2116-412/+429
| |
* | add detection of premature eostrinity-1686a2022-07-184-19/+58
| |
* | use a framing protocol instead of even/odd channeltrinity-1686a2022-06-205-234/+193
| |
* | start supporting sending error on streamtrinity-1686a2022-06-192-29/+72
| |
* | wait for any ready stream instead of the highest priority onetrinity-1686a2022-06-193-71/+124
| |
* | further work on streamstrinity-1686a2022-06-086-40/+67
| | | | | | | | most changes still required are related to error handling
* | rechunk streamtrinity-1686a2022-06-051-65/+94
| |