Ankit Kumar

Add type-based channel pipeline events Summary: Remove the need for one central event enum: each handler declares the typed events it can publish, while other handlers subscribe and implement `on<Event>()`. Event contracts and dispatch thunks are resolved at compile time, with routes cached when the pipeline is built; the bound typed path is also 13.1% faster than legacy enum dispatch. Reviewed By: robertroeser Differential Revision: D119018784 fbshipit-source-id: 7aa2ebaa2a5b8843c1c30b901eaf59b7fdad81a0

Add compile-time-shaped Fast Thrift channel pipelines Summary: Add `StaticPipelineBuilder` and `StaticPipeline`, which encode handler types, IDs, order, routing, event subscribers, and lifecycle dispatch in the pipeline type. Static pipelines keep only handler values and compact contexts per connection while retaining `PipelineImpl::Ptr` ownership compatibility. Preserve the existing runtime-shaped builder and add matched static-versus-dynamic eight-handler dispatch benchmarks. Reviewed By: robertroeser Differential Revision: D121542809 fbshipit-source-id: eccb32fec6b1c153dd36ab09e80ed14354b51aa6

Propagate request cancellation end to end Summary: Decode Rocket CANCEL as an explicit Thrift event and propagate cancellation to running Fast Thrift handlers when enableCancellation is enabled. Add shared request lifecycle arbitration so cancellation and response completion retire request, TPEH, close-handler, buffering, and metric state exactly once while losing responses are silently discarded. When enableCancellation is disabled, consume and ignore CANCEL without changing stream state, allowing application work and its response to complete normally. Cover queued work, timeout, duplicate cancellation, connection failure, response races, coroutine propagation, and teardown behavior. Reviewed By: robertroeser Differential Revision: D121225445 fbshipit-source-id: ac3c5706e118c2b705c35d5cf3150f9287b1843a

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 erased handlers to static channel pipelines Summary: Allow a `StaticPipelineBuilder` to splice runtime-selected handler types at one fixed position while preserving one pipeline and static contexts. Each concrete handler is stored with a compact static context, while its dispatch operations are shared by handler type. Pipelines that do not opt in retain empty-base storage. Reviewed By: robertroeser Differential Revision: D121624586 fbshipit-source-id: 4a18335b4573a1c798e88290bcbf2d73f1a93839

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

Move `EvbAllocator` into fast_thrift Summary: Move Robert Roesers EventBase allocator from `scripts/rroeser` into `fast_thrift/common/allocator` as tracked renames, and rename `EvbBumpAllocator` to `EvbAllocator`. Wire the allocator into `channel_pipeline` as a link-only dependency and register its source in the OSS build. Reviewed By: robertroeser Differential Revision: D119524257 fbshipit-source-id: 18a7882d9ce83676c993694da1eeedbf2491f260