1 /**
2  * Autogenerated by Thrift for src/module.thrift
3  *
4  * DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
5  *  @generated @nocommit
6  */
7 
8 #include "thrift/compiler/test/fixtures/sink/gen-cpp2/SinkService.h"
9 #include "thrift/compiler/test/fixtures/sink/gen-cpp2/SinkService.tcc"
10 #include "thrift/compiler/test/fixtures/sink/gen-cpp2/module_metadata.h"
11 #include <thrift/lib/cpp2/gen/service_cpp.h>
12 
13 namespace cpp2 {
getProcessor()14 std::unique_ptr<apache::thrift::AsyncProcessor> SinkServiceSvIf::getProcessor() {
15   return std::make_unique<SinkServiceAsyncProcessor>(this);
16 }
17 
createMethodMetadata()18 SinkServiceSvIf::CreateMethodMetadataResult SinkServiceSvIf::createMethodMetadata() {
19   return ::apache::thrift::detail::ap::createMethodMetadataMap<SinkServiceAsyncProcessor>();
20 }
21 
22 
method()23 ::apache::thrift::SinkConsumer<::cpp2::SinkPayload, ::cpp2::FinalResponse> SinkServiceSvIf::method() {
24   apache::thrift::detail::si::throw_app_exn_unimplemented("method");
25 }
26 
semifuture_method()27 folly::SemiFuture<::apache::thrift::SinkConsumer<::cpp2::SinkPayload, ::cpp2::FinalResponse>> SinkServiceSvIf::semifuture_method() {
28   auto expected{apache::thrift::detail::si::InvocationType::SemiFuture};
29   __fbthrift_invocation_method.compare_exchange_strong(expected, apache::thrift::detail::si::InvocationType::Sync, std::memory_order_relaxed);
30   return method();
31 }
32 
future_method()33 folly::Future<::apache::thrift::SinkConsumer<::cpp2::SinkPayload, ::cpp2::FinalResponse>> SinkServiceSvIf::future_method() {
34   auto expected{apache::thrift::detail::si::InvocationType::Future};
35   __fbthrift_invocation_method.compare_exchange_strong(expected, apache::thrift::detail::si::InvocationType::SemiFuture, std::memory_order_relaxed);
36   return apache::thrift::detail::si::future(semifuture_method(), getInternalKeepAlive());
37 }
38 
async_tm_method(std::unique_ptr<apache::thrift::HandlerCallback<::apache::thrift::SinkConsumer<::cpp2::SinkPayload,::cpp2::FinalResponse>>> callback)39 void SinkServiceSvIf::async_tm_method(std::unique_ptr<apache::thrift::HandlerCallback<::apache::thrift::SinkConsumer<::cpp2::SinkPayload, ::cpp2::FinalResponse>>> callback) {
40   // It's possible the coroutine versions will delegate to a future-based
41   // version. If that happens, we need the RequestParams arguments to be
42   // available to the future through the thread-local backchannel, so we create
43   // a RAII object that sets up RequestParams and clears them on destruction.
44   apache::thrift::detail::si::AsyncTmPrep asyncTmPrep(this, callback.get());
45   auto invocationType = __fbthrift_invocation_method.load(std::memory_order_relaxed);
46   try {
47     switch (invocationType) {
48       case apache::thrift::detail::si::InvocationType::AsyncTm:
49       {
50         __fbthrift_invocation_method.compare_exchange_strong(invocationType, apache::thrift::detail::si::InvocationType::Future, std::memory_order_relaxed);
51         FOLLY_FALLTHROUGH;
52       }
53       case apache::thrift::detail::si::InvocationType::Future:
54       {
55         auto fut = future_method();
56         apache::thrift::detail::si::async_tm_future(std::move(callback), std::move(fut));
57         return;
58       }
59       case apache::thrift::detail::si::InvocationType::SemiFuture:
60       {
61         auto fut = semifuture_method();
62         apache::thrift::detail::si::async_tm_semifuture(std::move(callback), std::move(fut));
63         return;
64       }
65       case apache::thrift::detail::si::InvocationType::Sync:
66       {
67         callback->result(method());
68         return;
69       }
70       default:
71       {
72         folly::assume_unreachable();
73       }
74     }
75   } catch (...) {
76     callback->exception(std::current_exception());
77   }
78 }
79 
methodAndReponse()80 ::apache::thrift::ResponseAndSinkConsumer<::cpp2::InitialResponse, ::cpp2::SinkPayload, ::cpp2::FinalResponse> SinkServiceSvIf::methodAndReponse() {
81   apache::thrift::detail::si::throw_app_exn_unimplemented("methodAndReponse");
82 }
83 
semifuture_methodAndReponse()84 folly::SemiFuture<::apache::thrift::ResponseAndSinkConsumer<::cpp2::InitialResponse, ::cpp2::SinkPayload, ::cpp2::FinalResponse>> SinkServiceSvIf::semifuture_methodAndReponse() {
85   auto expected{apache::thrift::detail::si::InvocationType::SemiFuture};
86   __fbthrift_invocation_methodAndReponse.compare_exchange_strong(expected, apache::thrift::detail::si::InvocationType::Sync, std::memory_order_relaxed);
87   return methodAndReponse();
88 }
89 
future_methodAndReponse()90 folly::Future<::apache::thrift::ResponseAndSinkConsumer<::cpp2::InitialResponse, ::cpp2::SinkPayload, ::cpp2::FinalResponse>> SinkServiceSvIf::future_methodAndReponse() {
91   auto expected{apache::thrift::detail::si::InvocationType::Future};
92   __fbthrift_invocation_methodAndReponse.compare_exchange_strong(expected, apache::thrift::detail::si::InvocationType::SemiFuture, std::memory_order_relaxed);
93   return apache::thrift::detail::si::future(semifuture_methodAndReponse(), getInternalKeepAlive());
94 }
95 
async_tm_methodAndReponse(std::unique_ptr<apache::thrift::HandlerCallback<::apache::thrift::ResponseAndSinkConsumer<::cpp2::InitialResponse,::cpp2::SinkPayload,::cpp2::FinalResponse>>> callback)96 void SinkServiceSvIf::async_tm_methodAndReponse(std::unique_ptr<apache::thrift::HandlerCallback<::apache::thrift::ResponseAndSinkConsumer<::cpp2::InitialResponse, ::cpp2::SinkPayload, ::cpp2::FinalResponse>>> callback) {
97   // It's possible the coroutine versions will delegate to a future-based
98   // version. If that happens, we need the RequestParams arguments to be
99   // available to the future through the thread-local backchannel, so we create
100   // a RAII object that sets up RequestParams and clears them on destruction.
101   apache::thrift::detail::si::AsyncTmPrep asyncTmPrep(this, callback.get());
102   auto invocationType = __fbthrift_invocation_methodAndReponse.load(std::memory_order_relaxed);
103   try {
104     switch (invocationType) {
105       case apache::thrift::detail::si::InvocationType::AsyncTm:
106       {
107         __fbthrift_invocation_methodAndReponse.compare_exchange_strong(invocationType, apache::thrift::detail::si::InvocationType::Future, std::memory_order_relaxed);
108         FOLLY_FALLTHROUGH;
109       }
110       case apache::thrift::detail::si::InvocationType::Future:
111       {
112         auto fut = future_methodAndReponse();
113         apache::thrift::detail::si::async_tm_future(std::move(callback), std::move(fut));
114         return;
115       }
116       case apache::thrift::detail::si::InvocationType::SemiFuture:
117       {
118         auto fut = semifuture_methodAndReponse();
119         apache::thrift::detail::si::async_tm_semifuture(std::move(callback), std::move(fut));
120         return;
121       }
122       case apache::thrift::detail::si::InvocationType::Sync:
123       {
124         callback->result(methodAndReponse());
125         return;
126       }
127       default:
128       {
129         folly::assume_unreachable();
130       }
131     }
132   } catch (...) {
133     callback->exception(std::current_exception());
134   }
135 }
136 
methodThrow()137 ::apache::thrift::SinkConsumer<::cpp2::SinkPayload, ::cpp2::FinalResponse> SinkServiceSvIf::methodThrow() {
138   apache::thrift::detail::si::throw_app_exn_unimplemented("methodThrow");
139 }
140 
semifuture_methodThrow()141 folly::SemiFuture<::apache::thrift::SinkConsumer<::cpp2::SinkPayload, ::cpp2::FinalResponse>> SinkServiceSvIf::semifuture_methodThrow() {
142   auto expected{apache::thrift::detail::si::InvocationType::SemiFuture};
143   __fbthrift_invocation_methodThrow.compare_exchange_strong(expected, apache::thrift::detail::si::InvocationType::Sync, std::memory_order_relaxed);
144   return methodThrow();
145 }
146 
future_methodThrow()147 folly::Future<::apache::thrift::SinkConsumer<::cpp2::SinkPayload, ::cpp2::FinalResponse>> SinkServiceSvIf::future_methodThrow() {
148   auto expected{apache::thrift::detail::si::InvocationType::Future};
149   __fbthrift_invocation_methodThrow.compare_exchange_strong(expected, apache::thrift::detail::si::InvocationType::SemiFuture, std::memory_order_relaxed);
150   return apache::thrift::detail::si::future(semifuture_methodThrow(), getInternalKeepAlive());
151 }
152 
async_tm_methodThrow(std::unique_ptr<apache::thrift::HandlerCallback<::apache::thrift::SinkConsumer<::cpp2::SinkPayload,::cpp2::FinalResponse>>> callback)153 void SinkServiceSvIf::async_tm_methodThrow(std::unique_ptr<apache::thrift::HandlerCallback<::apache::thrift::SinkConsumer<::cpp2::SinkPayload, ::cpp2::FinalResponse>>> callback) {
154   // It's possible the coroutine versions will delegate to a future-based
155   // version. If that happens, we need the RequestParams arguments to be
156   // available to the future through the thread-local backchannel, so we create
157   // a RAII object that sets up RequestParams and clears them on destruction.
158   apache::thrift::detail::si::AsyncTmPrep asyncTmPrep(this, callback.get());
159   auto invocationType = __fbthrift_invocation_methodThrow.load(std::memory_order_relaxed);
160   try {
161     switch (invocationType) {
162       case apache::thrift::detail::si::InvocationType::AsyncTm:
163       {
164         __fbthrift_invocation_methodThrow.compare_exchange_strong(invocationType, apache::thrift::detail::si::InvocationType::Future, std::memory_order_relaxed);
165         FOLLY_FALLTHROUGH;
166       }
167       case apache::thrift::detail::si::InvocationType::Future:
168       {
169         auto fut = future_methodThrow();
170         apache::thrift::detail::si::async_tm_future(std::move(callback), std::move(fut));
171         return;
172       }
173       case apache::thrift::detail::si::InvocationType::SemiFuture:
174       {
175         auto fut = semifuture_methodThrow();
176         apache::thrift::detail::si::async_tm_semifuture(std::move(callback), std::move(fut));
177         return;
178       }
179       case apache::thrift::detail::si::InvocationType::Sync:
180       {
181         callback->result(methodThrow());
182         return;
183       }
184       default:
185       {
186         folly::assume_unreachable();
187       }
188     }
189   } catch (...) {
190     callback->exception(std::current_exception());
191   }
192 }
193 
methodSinkThrow()194 ::apache::thrift::SinkConsumer<::cpp2::SinkPayload, ::cpp2::FinalResponse> SinkServiceSvIf::methodSinkThrow() {
195   apache::thrift::detail::si::throw_app_exn_unimplemented("methodSinkThrow");
196 }
197 
semifuture_methodSinkThrow()198 folly::SemiFuture<::apache::thrift::SinkConsumer<::cpp2::SinkPayload, ::cpp2::FinalResponse>> SinkServiceSvIf::semifuture_methodSinkThrow() {
199   auto expected{apache::thrift::detail::si::InvocationType::SemiFuture};
200   __fbthrift_invocation_methodSinkThrow.compare_exchange_strong(expected, apache::thrift::detail::si::InvocationType::Sync, std::memory_order_relaxed);
201   return methodSinkThrow();
202 }
203 
future_methodSinkThrow()204 folly::Future<::apache::thrift::SinkConsumer<::cpp2::SinkPayload, ::cpp2::FinalResponse>> SinkServiceSvIf::future_methodSinkThrow() {
205   auto expected{apache::thrift::detail::si::InvocationType::Future};
206   __fbthrift_invocation_methodSinkThrow.compare_exchange_strong(expected, apache::thrift::detail::si::InvocationType::SemiFuture, std::memory_order_relaxed);
207   return apache::thrift::detail::si::future(semifuture_methodSinkThrow(), getInternalKeepAlive());
208 }
209 
async_tm_methodSinkThrow(std::unique_ptr<apache::thrift::HandlerCallback<::apache::thrift::SinkConsumer<::cpp2::SinkPayload,::cpp2::FinalResponse>>> callback)210 void SinkServiceSvIf::async_tm_methodSinkThrow(std::unique_ptr<apache::thrift::HandlerCallback<::apache::thrift::SinkConsumer<::cpp2::SinkPayload, ::cpp2::FinalResponse>>> callback) {
211   // It's possible the coroutine versions will delegate to a future-based
212   // version. If that happens, we need the RequestParams arguments to be
213   // available to the future through the thread-local backchannel, so we create
214   // a RAII object that sets up RequestParams and clears them on destruction.
215   apache::thrift::detail::si::AsyncTmPrep asyncTmPrep(this, callback.get());
216   auto invocationType = __fbthrift_invocation_methodSinkThrow.load(std::memory_order_relaxed);
217   try {
218     switch (invocationType) {
219       case apache::thrift::detail::si::InvocationType::AsyncTm:
220       {
221         __fbthrift_invocation_methodSinkThrow.compare_exchange_strong(invocationType, apache::thrift::detail::si::InvocationType::Future, std::memory_order_relaxed);
222         FOLLY_FALLTHROUGH;
223       }
224       case apache::thrift::detail::si::InvocationType::Future:
225       {
226         auto fut = future_methodSinkThrow();
227         apache::thrift::detail::si::async_tm_future(std::move(callback), std::move(fut));
228         return;
229       }
230       case apache::thrift::detail::si::InvocationType::SemiFuture:
231       {
232         auto fut = semifuture_methodSinkThrow();
233         apache::thrift::detail::si::async_tm_semifuture(std::move(callback), std::move(fut));
234         return;
235       }
236       case apache::thrift::detail::si::InvocationType::Sync:
237       {
238         callback->result(methodSinkThrow());
239         return;
240       }
241       default:
242       {
243         folly::assume_unreachable();
244       }
245     }
246   } catch (...) {
247     callback->exception(std::current_exception());
248   }
249 }
250 
methodFinalThrow()251 ::apache::thrift::SinkConsumer<::cpp2::SinkPayload, ::cpp2::FinalResponse> SinkServiceSvIf::methodFinalThrow() {
252   apache::thrift::detail::si::throw_app_exn_unimplemented("methodFinalThrow");
253 }
254 
semifuture_methodFinalThrow()255 folly::SemiFuture<::apache::thrift::SinkConsumer<::cpp2::SinkPayload, ::cpp2::FinalResponse>> SinkServiceSvIf::semifuture_methodFinalThrow() {
256   auto expected{apache::thrift::detail::si::InvocationType::SemiFuture};
257   __fbthrift_invocation_methodFinalThrow.compare_exchange_strong(expected, apache::thrift::detail::si::InvocationType::Sync, std::memory_order_relaxed);
258   return methodFinalThrow();
259 }
260 
future_methodFinalThrow()261 folly::Future<::apache::thrift::SinkConsumer<::cpp2::SinkPayload, ::cpp2::FinalResponse>> SinkServiceSvIf::future_methodFinalThrow() {
262   auto expected{apache::thrift::detail::si::InvocationType::Future};
263   __fbthrift_invocation_methodFinalThrow.compare_exchange_strong(expected, apache::thrift::detail::si::InvocationType::SemiFuture, std::memory_order_relaxed);
264   return apache::thrift::detail::si::future(semifuture_methodFinalThrow(), getInternalKeepAlive());
265 }
266 
async_tm_methodFinalThrow(std::unique_ptr<apache::thrift::HandlerCallback<::apache::thrift::SinkConsumer<::cpp2::SinkPayload,::cpp2::FinalResponse>>> callback)267 void SinkServiceSvIf::async_tm_methodFinalThrow(std::unique_ptr<apache::thrift::HandlerCallback<::apache::thrift::SinkConsumer<::cpp2::SinkPayload, ::cpp2::FinalResponse>>> callback) {
268   // It's possible the coroutine versions will delegate to a future-based
269   // version. If that happens, we need the RequestParams arguments to be
270   // available to the future through the thread-local backchannel, so we create
271   // a RAII object that sets up RequestParams and clears them on destruction.
272   apache::thrift::detail::si::AsyncTmPrep asyncTmPrep(this, callback.get());
273   auto invocationType = __fbthrift_invocation_methodFinalThrow.load(std::memory_order_relaxed);
274   try {
275     switch (invocationType) {
276       case apache::thrift::detail::si::InvocationType::AsyncTm:
277       {
278         __fbthrift_invocation_methodFinalThrow.compare_exchange_strong(invocationType, apache::thrift::detail::si::InvocationType::Future, std::memory_order_relaxed);
279         FOLLY_FALLTHROUGH;
280       }
281       case apache::thrift::detail::si::InvocationType::Future:
282       {
283         auto fut = future_methodFinalThrow();
284         apache::thrift::detail::si::async_tm_future(std::move(callback), std::move(fut));
285         return;
286       }
287       case apache::thrift::detail::si::InvocationType::SemiFuture:
288       {
289         auto fut = semifuture_methodFinalThrow();
290         apache::thrift::detail::si::async_tm_semifuture(std::move(callback), std::move(fut));
291         return;
292       }
293       case apache::thrift::detail::si::InvocationType::Sync:
294       {
295         callback->result(methodFinalThrow());
296         return;
297       }
298       default:
299       {
300         folly::assume_unreachable();
301       }
302     }
303   } catch (...) {
304     callback->exception(std::current_exception());
305   }
306 }
307 
methodBothThrow()308 ::apache::thrift::SinkConsumer<::cpp2::SinkPayload, ::cpp2::FinalResponse> SinkServiceSvIf::methodBothThrow() {
309   apache::thrift::detail::si::throw_app_exn_unimplemented("methodBothThrow");
310 }
311 
semifuture_methodBothThrow()312 folly::SemiFuture<::apache::thrift::SinkConsumer<::cpp2::SinkPayload, ::cpp2::FinalResponse>> SinkServiceSvIf::semifuture_methodBothThrow() {
313   auto expected{apache::thrift::detail::si::InvocationType::SemiFuture};
314   __fbthrift_invocation_methodBothThrow.compare_exchange_strong(expected, apache::thrift::detail::si::InvocationType::Sync, std::memory_order_relaxed);
315   return methodBothThrow();
316 }
317 
future_methodBothThrow()318 folly::Future<::apache::thrift::SinkConsumer<::cpp2::SinkPayload, ::cpp2::FinalResponse>> SinkServiceSvIf::future_methodBothThrow() {
319   auto expected{apache::thrift::detail::si::InvocationType::Future};
320   __fbthrift_invocation_methodBothThrow.compare_exchange_strong(expected, apache::thrift::detail::si::InvocationType::SemiFuture, std::memory_order_relaxed);
321   return apache::thrift::detail::si::future(semifuture_methodBothThrow(), getInternalKeepAlive());
322 }
323 
async_tm_methodBothThrow(std::unique_ptr<apache::thrift::HandlerCallback<::apache::thrift::SinkConsumer<::cpp2::SinkPayload,::cpp2::FinalResponse>>> callback)324 void SinkServiceSvIf::async_tm_methodBothThrow(std::unique_ptr<apache::thrift::HandlerCallback<::apache::thrift::SinkConsumer<::cpp2::SinkPayload, ::cpp2::FinalResponse>>> callback) {
325   // It's possible the coroutine versions will delegate to a future-based
326   // version. If that happens, we need the RequestParams arguments to be
327   // available to the future through the thread-local backchannel, so we create
328   // a RAII object that sets up RequestParams and clears them on destruction.
329   apache::thrift::detail::si::AsyncTmPrep asyncTmPrep(this, callback.get());
330   auto invocationType = __fbthrift_invocation_methodBothThrow.load(std::memory_order_relaxed);
331   try {
332     switch (invocationType) {
333       case apache::thrift::detail::si::InvocationType::AsyncTm:
334       {
335         __fbthrift_invocation_methodBothThrow.compare_exchange_strong(invocationType, apache::thrift::detail::si::InvocationType::Future, std::memory_order_relaxed);
336         FOLLY_FALLTHROUGH;
337       }
338       case apache::thrift::detail::si::InvocationType::Future:
339       {
340         auto fut = future_methodBothThrow();
341         apache::thrift::detail::si::async_tm_future(std::move(callback), std::move(fut));
342         return;
343       }
344       case apache::thrift::detail::si::InvocationType::SemiFuture:
345       {
346         auto fut = semifuture_methodBothThrow();
347         apache::thrift::detail::si::async_tm_semifuture(std::move(callback), std::move(fut));
348         return;
349       }
350       case apache::thrift::detail::si::InvocationType::Sync:
351       {
352         callback->result(methodBothThrow());
353         return;
354       }
355       default:
356       {
357         folly::assume_unreachable();
358       }
359     }
360   } catch (...) {
361     callback->exception(std::current_exception());
362   }
363 }
364 
async_eb_methodFast(std::unique_ptr<apache::thrift::HandlerCallback<::apache::thrift::SinkConsumer<::cpp2::SinkPayload,::cpp2::FinalResponse>>> callback)365 void SinkServiceSvIf::async_eb_methodFast(std::unique_ptr<apache::thrift::HandlerCallback<::apache::thrift::SinkConsumer<::cpp2::SinkPayload, ::cpp2::FinalResponse>>> callback) {
366   callback->exception(apache::thrift::detail::si::create_app_exn_unimplemented("methodFast"));
367 }
368 
method()369 ::apache::thrift::SinkConsumer<::cpp2::SinkPayload, ::cpp2::FinalResponse> SinkServiceSvNull::method() {
370   return {};
371 }
372 
methodAndReponse()373 ::apache::thrift::ResponseAndSinkConsumer<::cpp2::InitialResponse, ::cpp2::SinkPayload, ::cpp2::FinalResponse> SinkServiceSvNull::methodAndReponse() {
374   return {};
375 }
376 
methodThrow()377 ::apache::thrift::SinkConsumer<::cpp2::SinkPayload, ::cpp2::FinalResponse> SinkServiceSvNull::methodThrow() {
378   return {};
379 }
380 
methodSinkThrow()381 ::apache::thrift::SinkConsumer<::cpp2::SinkPayload, ::cpp2::FinalResponse> SinkServiceSvNull::methodSinkThrow() {
382   return {};
383 }
384 
methodFinalThrow()385 ::apache::thrift::SinkConsumer<::cpp2::SinkPayload, ::cpp2::FinalResponse> SinkServiceSvNull::methodFinalThrow() {
386   return {};
387 }
388 
methodBothThrow()389 ::apache::thrift::SinkConsumer<::cpp2::SinkPayload, ::cpp2::FinalResponse> SinkServiceSvNull::methodBothThrow() {
390   return {};
391 }
392 
393 
394 
getServiceName()395 const char* SinkServiceAsyncProcessor::getServiceName() {
396   return "SinkService";
397 }
398 
getServiceMetadata(apache::thrift::metadata::ThriftServiceMetadataResponse & response)399 void SinkServiceAsyncProcessor::getServiceMetadata(apache::thrift::metadata::ThriftServiceMetadataResponse& response) {
400   ::apache::thrift::detail::md::ServiceMetadata<SinkServiceSvIf>::gen(response);
401 }
402 
processSerializedCompressedRequest(apache::thrift::ResponseChannelRequest::UniquePtr req,apache::thrift::SerializedCompressedRequest && serializedRequest,apache::thrift::protocol::PROTOCOL_TYPES protType,apache::thrift::Cpp2RequestContext * context,folly::EventBase * eb,apache::thrift::concurrency::ThreadManager * tm)403 void SinkServiceAsyncProcessor::processSerializedCompressedRequest(apache::thrift::ResponseChannelRequest::UniquePtr req, apache::thrift::SerializedCompressedRequest&& serializedRequest, apache::thrift::protocol::PROTOCOL_TYPES protType, apache::thrift::Cpp2RequestContext* context, folly::EventBase* eb, apache::thrift::concurrency::ThreadManager* tm) {
404   apache::thrift::detail::ap::process(this, std::move(req), std::move(serializedRequest), protType, context, eb, tm);
405 }
406 
processSerializedCompressedRequestWithMetadata(apache::thrift::ResponseChannelRequest::UniquePtr req,apache::thrift::SerializedCompressedRequest && serializedRequest,const apache::thrift::AsyncProcessorFactory::MethodMetadata & methodMetadata,apache::thrift::protocol::PROTOCOL_TYPES protType,apache::thrift::Cpp2RequestContext * context,folly::EventBase * eb,apache::thrift::concurrency::ThreadManager * tm)407 void SinkServiceAsyncProcessor::processSerializedCompressedRequestWithMetadata(apache::thrift::ResponseChannelRequest::UniquePtr req, apache::thrift::SerializedCompressedRequest&& serializedRequest, const apache::thrift::AsyncProcessorFactory::MethodMetadata& methodMetadata, apache::thrift::protocol::PROTOCOL_TYPES protType, apache::thrift::Cpp2RequestContext* context, folly::EventBase* eb, apache::thrift::concurrency::ThreadManager* tm) {
408   apache::thrift::detail::ap::process(this, std::move(req), std::move(serializedRequest), methodMetadata, protType, context, eb, tm);
409 }
410 
getOwnProcessMap()411 const SinkServiceAsyncProcessor::ProcessMap& SinkServiceAsyncProcessor::getOwnProcessMap() {
412   return kOwnProcessMap_;
413 }
414 
415 const SinkServiceAsyncProcessor::ProcessMap SinkServiceAsyncProcessor::kOwnProcessMap_ {
416   {"method", {&SinkServiceAsyncProcessor::setUpAndProcess_method<apache::thrift::CompactProtocolReader, apache::thrift::CompactProtocolWriter>, &SinkServiceAsyncProcessor::setUpAndProcess_method<apache::thrift::BinaryProtocolReader, apache::thrift::BinaryProtocolWriter>}},
417   {"methodAndReponse", {&SinkServiceAsyncProcessor::setUpAndProcess_methodAndReponse<apache::thrift::CompactProtocolReader, apache::thrift::CompactProtocolWriter>, &SinkServiceAsyncProcessor::setUpAndProcess_methodAndReponse<apache::thrift::BinaryProtocolReader, apache::thrift::BinaryProtocolWriter>}},
418   {"methodThrow", {&SinkServiceAsyncProcessor::setUpAndProcess_methodThrow<apache::thrift::CompactProtocolReader, apache::thrift::CompactProtocolWriter>, &SinkServiceAsyncProcessor::setUpAndProcess_methodThrow<apache::thrift::BinaryProtocolReader, apache::thrift::BinaryProtocolWriter>}},
419   {"methodSinkThrow", {&SinkServiceAsyncProcessor::setUpAndProcess_methodSinkThrow<apache::thrift::CompactProtocolReader, apache::thrift::CompactProtocolWriter>, &SinkServiceAsyncProcessor::setUpAndProcess_methodSinkThrow<apache::thrift::BinaryProtocolReader, apache::thrift::BinaryProtocolWriter>}},
420   {"methodFinalThrow", {&SinkServiceAsyncProcessor::setUpAndProcess_methodFinalThrow<apache::thrift::CompactProtocolReader, apache::thrift::CompactProtocolWriter>, &SinkServiceAsyncProcessor::setUpAndProcess_methodFinalThrow<apache::thrift::BinaryProtocolReader, apache::thrift::BinaryProtocolWriter>}},
421   {"methodBothThrow", {&SinkServiceAsyncProcessor::setUpAndProcess_methodBothThrow<apache::thrift::CompactProtocolReader, apache::thrift::CompactProtocolWriter>, &SinkServiceAsyncProcessor::setUpAndProcess_methodBothThrow<apache::thrift::BinaryProtocolReader, apache::thrift::BinaryProtocolWriter>}},
422   {"methodFast", {&SinkServiceAsyncProcessor::setUpAndProcess_methodFast<apache::thrift::CompactProtocolReader, apache::thrift::CompactProtocolWriter>, &SinkServiceAsyncProcessor::setUpAndProcess_methodFast<apache::thrift::BinaryProtocolReader, apache::thrift::BinaryProtocolWriter>}},
423 };
424 
425 } // cpp2
426