Ankit Kumar

Compose the transport on a parser instead of a framing handler Summary: Inbound framing moves out of `FrameLengthParserHandler` and into a `Parser` that `TransportHandlerT` is templated on, so the socket reads straight into the same `IOBufQueue` frames are split out of — removing a 64 KiB `IOBuf::create` and a memcpy per frame, and with them the jemalloc arena lock that a 64 KiB allocation takes on every read. Reviewed By: robertroeser Differential Revision: D118389192 fbshipit-source-id: 13678e4f6d413703eb280430937c0a42f960ce90

Adds Thrift pipeline handler for Setup Messages Summary: This allows Thrift side handlers to work on setup request/responses. Reviewed By: robertroeser Differential Revision: D115324168 fbshipit-source-id: 76ffb5fbc268a1200edb179da5a5a29c319dcf66

Add CPUThreadPoolExecutor for fast_thrift server Summary: Adds a minimal CPU thread pool support for fast_thrift server. Moves FastHandlerCallback onto the cpu thread pool, and always destroys on evb to prevent lifetime issues without using an atomic. Reviewed By: robertroeser Differential Revision: D115117684 fbshipit-source-id: b3b122556f35a1229ba6462c83fdb728b858fab0

Adds compression handler Summary: Add a FastThrift duplex pipeline handler that decodes Rocket-compressed requests before generated dispatch and compresses replies using the response preference carried in `ThriftRequestContext`. Bound decompression to the FastThrift inbound size envelope and advertise supported codecs during setup. Reviewed By: robertroeser Differential Revision: D118737471 fbshipit-source-id: b4705522f7c87a2578aff2dce561438740d1d2de

Run TProcessorEventHandlers on the pipeline Summary: `TProcessorEventHandlerBridge` drives request- and connection-scoped `TProcessorEventHandler` / `TServerEventHandler` over the fast_thrift pipeline, mapping `SetupComplete`/`ConnectionClosed` onto `newConnection`/`connectionDestroyed` and each request onto preRead/postRead/preWrite/postWrite, with a throwing preRead refusing the request the way the classic server does. Reviewed By: robertroeser Differential Revision: D118378323 fbshipit-source-id: 7743a2589c445660bba22a0d5cfcc7bd5e6e839d

Write completion tracking E2E Summary: How write completion works: 1. Transport handler spawns a transport side event 2. Batching handler spawns a batch complete event with number of frames 3. RocketClient handler spawns a per-write complete event with the request context This allows 3 different points of write completion: 1. Transport write done 2. Batch write done 3. Rocket write done One remaining level in this is fragmentation support, which would be added in the next diff. Reviewed By: evanjzou Differential Revision: D109460051 fbshipit-source-id: ad04b6ebfcca5d5bb70c5a08a5cec9e0a883e1f1

Add extension points for connection establishment Summary: Adds events + extension points for: onConnectionEstablished onConnectionAttempted onConnectionRejected Reviewed By: robertroeser Differential Revision: D114281361 fbshipit-source-id: 34286623aec1f3ee617fd3de845e31ea2492cab4

Implement setup response handling Summary: Adds setup response handling for fast_thrift server Reviewed By: robertroeser Differential Revision: D113420893 fbshipit-source-id: 0c73829faddcd88fb2a1b2120f081a02c7018222

Integrate stats handlers into fast_thrift server Summary: Adds a stats object that tracks stats per evb. Wires-in handlers in the fast_thrift server side connection pipeline. Reviewed By: robertroeser Differential Revision: D114761706 fbshipit-source-id: 27f953bfa0a5e83670f2187c135e073c8d6d3302

Implement checksum handler for fast thrift server Summary: Similar to the client side only supports XXH3_64 Reviewed By: robertroeser Differential Revision: D113116541 fbshipit-source-id: 9c3718bc4155f191357d8fe67810111bda29ce04