Commit message (Collapse) | Author | Age | Files | Lines | |
---|---|---|---|---|---|
* | Implement request cancellation | Alex Auvolat | 2022-09-01 | 4 | -21/+159 |
| | |||||
* | fix trace message | Alex Auvolat | 2022-09-01 | 1 | -0/+1 |
| | |||||
* | Merge branch 'fix-ping' into stream-body | Alex Auvolat | 2022-09-01 | 5 | -57/+61 |
|\ | |||||
| * | SVR -> SRV | Alex Auvolat | 2022-08-31 | 1 | -1/+1 |
| | | |||||
| * | Be more lenient on pings | Alex Auvolat | 2022-08-31 | 1 | -9/+5 |
| | | |||||
| * | Better messages in proto.rs | Alex Auvolat | 2022-08-31 | 1 | -12/+31 |
| | | |||||
| * | add debug_name in proto to differenciate messages | Alex Auvolat | 2022-08-31 | 3 | -13/+25 |
| | | |||||
| * | Add dump of sending queue | Alex Auvolat | 2022-08-31 | 1 | -0/+11 |
| | | |||||
| * | Ping less frequently | Alex Auvolat | 2022-08-31 | 1 | -39/+36 |
| | | |||||
* | | Add actual support for order tag | Alex Auvolat | 2022-09-01 | 4 | -37/+81 |
| | | |||||
* | | Add OrderTag to Req and Resp, refactor errors | Alex Auvolat | 2022-09-01 | 9 | -116/+136 |
| | | |||||
* | | Also encode errorkind in stream | Alex Auvolat | 2022-09-01 | 4 | -46/+56 |
| | | |||||
* | | Stream errors are now std::io::Error | Alex Auvolat | 2022-09-01 | 4 | -54/+64 |
| | | |||||
* | | Refactor: create a BytesBuf utility crate (will also be usefull in Garage) | Alex Auvolat | 2022-09-01 | 3 | -43/+177 |
| | | |||||
* | | recv side: use unbounded channel to remove deadlock | Alex Auvolat | 2022-09-01 | 1 | -10/+8 |
| | | |||||
* | | Remove useless phantom and pub(crate) | Alex Auvolat | 2022-08-31 | 1 | -7/+2 |
| | | |||||
* | | Fix things going wrong when sending chan is closed | Alex Auvolat | 2022-07-26 | 2 | -12/+31 |
| | | |||||
* | | Add some debugging | Alex Auvolat | 2022-07-25 | 5 | -26/+63 |
| | | |||||
* | | Cargo fmt | Alex Auvolat | 2022-07-25 | 1 | -3/+2 |
| | | |||||
* | | Remove broken test | Alex Auvolat | 2022-07-25 | 1 | -95/+0 |
| | | |||||
* | | Remove blocking_send that crashes | Alex Auvolat | 2022-07-25 | 1 | -1/+3 |
| | | |||||
* | | Conversion between ByteStream and AsyncRead | Alex Auvolat | 2022-07-22 | 1 | -1/+50 |
| | | |||||
* | | Bump netapp version to 0.5 | Alex Auvolat | 2022-07-22 | 1 | -1/+1 |
| | | |||||
* | | Add Req::new | Alex Auvolat | 2022-07-22 | 1 | -0/+4 |
| | | |||||
* | | Impose static lifetime on message and response | Alex Auvolat | 2022-07-22 | 2 | -5/+5 |
| | | |||||
* | | Remove copy of serialized thing in encode | Alex Auvolat | 2022-07-22 | 1 | -7/+4 |
| | | |||||
* | | Cargo fmt; better adapt with_capacity_values | Alex Auvolat | 2022-07-22 | 3 | -29/+18 |
| | | |||||
* | | Terminology: don't use the word "body" anymore, talk of "attached stream" | Alex Auvolat | 2022-07-22 | 2 | -45/+42 |
| | | |||||
* | | Add Resp::into_parts | Alex Auvolat | 2022-07-22 | 1 | -4/+8 |
| | | |||||
* | | Small optimization | Alex Auvolat | 2022-07-22 | 2 | -1/+8 |
| | | |||||
* | | Add comment | Alex Auvolat | 2022-07-22 | 1 | -0/+3 |
| | | |||||
* | | Simplify send.rs | Alex Auvolat | 2022-07-22 | 2 | -166/+68 |
| | | |||||
* | | Move things around and fix error bit | Alex Auvolat | 2022-07-22 | 5 | -10/+9 |
| | | |||||
* | | Use bounded channels on receive side for backpressure | Alex Auvolat | 2022-07-22 | 4 | -32/+37 |
| | | |||||
* | | Clean up framing protocol | Alex Auvolat | 2022-07-22 | 9 | -265/+429 |
| | | |||||
* | | Hide streaming versions as much as possible | Alex Auvolat | 2022-07-22 | 6 | -41/+56 |
| | | |||||
* | | Propose alternative API | Alex Auvolat | 2022-07-21 | 6 | -90/+209 |
| | | |||||
* | | One possibility, but I don't like it | Alex Auvolat | 2022-07-21 | 7 | -52/+21 |
| | | |||||
* | | Rename AutoSerialize into SimpleMessage and refactor a bit | Alex Auvolat | 2022-07-21 | 7 | -68/+113 |
| | | |||||
* | | Use Bytes instead of Vec<u8> | Alex Auvolat | 2022-07-21 | 4 | -8/+11 |
| | | |||||
* | | Refactor send.rs | Alex Auvolat | 2022-07-21 | 2 | -60/+61 |
| | | |||||
* | | Move things around | Alex Auvolat | 2022-07-21 | 13 | -410/+424 |
| | | |||||
* | | add detection of premature eos | trinity-1686a | 2022-07-18 | 4 | -19/+58 |
| | | |||||
* | | use a framing protocol instead of even/odd channel | trinity-1686a | 2022-06-20 | 5 | -234/+193 |
| | | |||||
* | | start supporting sending error on stream | trinity-1686a | 2022-06-19 | 2 | -29/+72 |
| | | |||||
* | | wait for any ready stream instead of the highest priority one | trinity-1686a | 2022-06-19 | 3 | -71/+124 |
| | | |||||
* | | further work on streams | trinity-1686a | 2022-06-08 | 6 | -40/+67 |
| | | | | | | | | most changes still required are related to error handling | ||||
* | | rechunk stream | trinity-1686a | 2022-06-05 | 1 | -65/+94 |
| | | |||||
* | | initial work on associated stream | trinity-1686a | 2022-06-05 | 6 | -81/+338 |
|/ | | | | | | | | | still require testing, and fixing a few kinks: - sending packets > 16k truncate them - send one more packet than it could at eos - probably update documentation /!\ contains breaking changes | ||||
* | Also add addresses from incoming connections | Alex Auvolat | 2022-05-09 | 1 | -9/+10 |
| |