| /dports/devel/fbthrift/fbthrift-2021.12.27.00/thrift/lib/cpp2/async/tests/ |
| H A D | ServerStreamTest.cpp | 106 &clientCallback, in TEST()
142 &clientCallback, in TEST()
173 &clientCallback, in TEST()
200 &clientCallback, in TEST()
230 &clientCallback, in TEST()
252 &clientCallback, in TEST()
274 &clientCallback, in TEST()
297 &clientCallback, in TEST()
326 &clientCallback, in TEST()
352 &clientCallback, in TEST()
[all …]
|
| /dports/games/bzflag-server/bzflag-2.4.22/src/common/ |
| H A D | BZDBCache.cxx | 101 BZDB.addCallback("radarStyle", clientCallback, NULL); in init()
103 BZDB.addCallback("blend", clientCallback, NULL); in init()
104 BZDB.addCallback("texture", clientCallback, NULL); in init()
105 BZDB.addCallback("shadows", clientCallback, NULL); in init()
107 BZDB.addCallback("zbuffer", clientCallback, NULL); in init()
110 BZDB.addCallback("lighting", clientCallback, NULL); in init()
111 BZDB.addCallback("smooth", clientCallback, NULL); in init()
112 BZDB.addCallback("colorful", clientCallback, NULL); in init()
114 BZDB.addCallback("shotLength", clientCallback, NULL); in init()
117 BZDB.addCallback("flagChunks", clientCallback, NULL); in init()
[all …]
|
| /dports/games/bzflag/bzflag-2.4.22/src/common/ |
| H A D | BZDBCache.cxx | 101 BZDB.addCallback("radarStyle", clientCallback, NULL); in init()
103 BZDB.addCallback("blend", clientCallback, NULL); in init()
104 BZDB.addCallback("texture", clientCallback, NULL); in init()
105 BZDB.addCallback("shadows", clientCallback, NULL); in init()
107 BZDB.addCallback("zbuffer", clientCallback, NULL); in init()
110 BZDB.addCallback("lighting", clientCallback, NULL); in init()
111 BZDB.addCallback("smooth", clientCallback, NULL); in init()
112 BZDB.addCallback("colorful", clientCallback, NULL); in init()
114 BZDB.addCallback("shotLength", clientCallback, NULL); in init()
117 BZDB.addCallback("flagChunks", clientCallback, NULL); in init()
[all …]
|
| /dports/devel/fbthrift/fbthrift-2021.12.27.00/thrift/lib/cpp2/async/ |
| H A D | RequestChannel.cpp | 35 std::move(clientCallback)); in sendRequestResponse()
49 std::move(clientCallback)); in sendRequestNoResponse()
57 StreamClientCallback* clientCallback) { in sendRequestStream() argument
63 clientCallback); in sendRequestStream()
71 SinkClientCallback* clientCallback) { in sendRequestSink() argument
77 clientCallback); in sendRequestSink()
91 std::move(clientCallback)); in sendRequestResponse()
105 std::move(clientCallback)); in sendRequestNoResponse()
119 clientCallback); in sendRequestStream()
127 SinkClientCallback* clientCallback) { in sendRequestSink() argument
[all …]
|
| H A D | ServerGeneratorStream.cpp | 32 StreamClientCallback* clientCallback, folly::EventBase* clientEb) in ServerGeneratorStream() argument
33 : streamClientCallback_(clientCallback), clientEventBase_(clientEb) {} in ServerGeneratorStream()
70 StreamClientCallback& clientCallback) { in resetClientCallback() argument
71 streamClientCallback_ = &clientCallback; in resetClientCallback()
|
| H A D | RetryingRequestChannel.cpp | 127 apache::thrift::StreamClientCallback& clientCallback, in StreamCallback() argument
139 clientCallback_(clientCallback) {} in StreamCallback()
196 apache::thrift::SinkClientCallback& clientCallback, in SinkCallback() argument
208 clientCallback_(clientCallback) {} in SinkCallback()
261 apache::thrift::StreamClientCallback* clientCallback) { in sendRequestStream() argument
267 *clientCallback, in sendRequestStream()
285 apache::thrift::SinkClientCallback* clientCallback) { in sendRequestSink() argument
291 *clientCallback, in sendRequestSink()
|
| H A D | HibernatingRequestChannel.h | 73 StreamClientCallback* clientCallback) override { in sendRequestStream() argument
74 clientCallback->onFirstResponseError( in sendRequestStream()
84 SinkClientCallback* clientCallback) override { in sendRequestSink() argument
85 clientCallback->onFirstResponseError( in sendRequestSink()
|
| H A D | ThreadBoundAdaptorChannel.cpp | 87 EvbStreamCallback(StreamClientCallback* clientCallback, folly::EventBase* evb) in EvbStreamCallback() argument
88 : clientCallback_(clientCallback), in EvbStreamCallback()
176 StreamClientCallback& clientCallback) noexcept override { in resetClientCallback() argument
178 DCHECK(&clientCallback); in resetClientCallback()
179 clientCallback_ = &clientCallback; in resetClientCallback()
206 void setClientCallback(StreamClientCallback* clientCallback) { in setClientCallback() argument
208 clientCallback_ = clientCallback; in setClientCallback()
|
| H A D | HeaderClientChannel.h | 182 StreamClientCallback* clientCallback) override { in sendRequestStream() argument
183 clientCallback->onFirstResponseError( in sendRequestStream()
193 SinkClientCallback* clientCallback) override { in sendRequestSink() argument
194 clientCallback->onFirstResponseError( in sendRequestSink()
332 StreamClientCallback* clientCallback) override { in sendRequestStream() argument
333 clientCallback->onFirstResponseError( in sendRequestStream()
343 SinkClientCallback* clientCallback) override { in sendRequestSink() argument
344 clientCallback->onFirstResponseError( in sendRequestSink()
|
| H A D | ReconnectingRequestChannel.cpp | 65 StreamClientCallback& clientCallback) in ChannelKeepAliveStream() argument
66 : keepAlive_(std::move(impl)), clientCallback_(clientCallback) {} in ChannelKeepAliveStream()
98 SinkClientCallback& clientCallback) in ChannelKeepAliveSink() argument
99 : keepAlive_(std::move(impl)), clientCallback_(clientCallback) {} in ChannelKeepAliveSink()
|
| H A D | RocketClientChannel.cpp | 327 StreamClientCallback* clientCallback, in FirstRequestProcessorStream() argument
331 clientCallback_(clientCallback), in FirstRequestProcessorStream()
381 clientCallback_ = &clientCallback; in resetClientCallback()
397 SinkClientCallback* clientCallback, in FirstRequestProcessorSink() argument
401 clientCallback_(clientCallback), in FirstRequestProcessorSink()
466 clientCallback_ = &clientCallback; in resetClientCallback()
705 StreamClientCallback* clientCallback) { in sendRequestStream() argument
720 metadata, rpcOptions, clientCallback, firstResponseTimeout)) { in sendRequestStream()
737 clientCallback, in sendRequestStream()
746 SinkClientCallback* clientCallback) { in sendRequestSink() argument
[all …]
|
| H A D | HTTPClientChannel.h | 122 StreamClientCallback* clientCallback) override { in sendRequestStream() argument
123 clientCallback->onFirstResponseError( in sendRequestStream()
133 SinkClientCallback* clientCallback) override { in sendRequestSink() argument
134 clientCallback->onFirstResponseError( in sendRequestSink()
|
| /dports/devel/fbthrift/fbthrift-2021.12.27.00/thrift/lib/cpp2/util/ |
| H A D | ScopedServerInterfaceThread-inl.h | 44 RequestClientCallback::Ptr clientCallback) override { in sendRequestResponse() argument
46 clientCallback.release()->onResponseError(std::move(ex)); in sendRequestResponse()
54 std::move(clientCallback)); in sendRequestResponse()
61 RequestClientCallback::Ptr clientCallback) override { in sendRequestNoResponse() argument
71 std::move(clientCallback)); in sendRequestNoResponse()
78 StreamClientCallback* clientCallback) override { in sendRequestStream() argument
80 clientCallback->onFirstResponseError(std::move(ex)); in sendRequestStream()
88 clientCallback); in sendRequestStream()
95 SinkClientCallback* clientCallback) override { in sendRequestSink() argument
97 clientCallback->onFirstResponseError(std::move(ex)); in sendRequestSink()
[all …]
|
| /dports/devel/fbthrift/fbthrift-2021.12.27.00/thrift/lib/cpp2/transport/rocket/client/ |
| H A D | RocketStreamServerCallback.h | 61 StreamClientCallback& clientCallback) in RocketStreamServerCallback() argument
63 clientCallback_(&clientCallback), in RocketStreamServerCallback()
71 void resetClientCallback(StreamClientCallback& clientCallback) override { in resetClientCallback() argument
72 clientCallback_ = &clientCallback; in resetClientCallback()
100 StreamClientCallback& clientCallback, in RocketStreamServerCallbackWithChunkTimeout() argument
103 : RocketStreamServerCallback(streamId, client, clientCallback), in RocketStreamServerCallbackWithChunkTimeout()
129 SinkClientCallback& clientCallback, in RocketSinkServerCallback() argument
133 clientCallback_(&clientCallback), in RocketSinkServerCallback()
142 void resetClientCallback(SinkClientCallback& clientCallback) override { in resetClientCallback() argument
143 clientCallback_ = &clientCallback; in resetClientCallback()
|
| /dports/devel/fbthrift/fbthrift-2021.12.27.00/thrift/lib/cpp2/transport/rocket/server/ |
| H A D | RocketServerConnection.cpp | 321 clientCallback) { in handleFrame() argument
328 *clientCallback); in handleFrame()
331 clientCallback) { in handleFrame() argument
338 *clientCallback); in handleFrame()
425 clientCallback) { in handleUntrackedFrame() argument
457 RocketStreamClientCallback& clientCallback) { in handleStreamFrame() argument
458 if (!clientCallback.serverCallbackReady()) { in handleStreamFrame()
461 return clientCallback.earlyCancelled(); in handleStreamFrame()
481 clientCallback.onStreamCancel(); in handleStreamFrame()
534 RocketSinkClientCallback& clientCallback) { in handleSinkFrame() argument
[all …]
|
| H A D | RocketServerFrameContext.cpp | 94 auto& clientCallback = connection.createStreamClientCallback( in onFullFrame() local
97 std::move(fullFrame), std::move(*this), &clientCallback); in onFullFrame()
109 auto& clientCallback = in onFullFrame() local
113 std::move(fullFrame), std::move(*this), &clientCallback); in onFullFrame()
|
| /dports/www/firefox-esr/firefox-91.8.0/netwerk/test/gtest/ |
| H A D | TestBind.cpp | 129 RefPtr<ClientInputCallback> clientCallback; in TEST() local
147 clientCallback = new ClientInputCallback(waiter); in TEST()
154 rv = asyncInputStream->AsyncWait(clientCallback, 0, 0, nullptr); in TEST()
158 if (clientCallback->mFailed) { in TEST()
173 ASSERT_TRUE(clientCallback->mFailed); in TEST()
|
| /dports/www/firefox/firefox-99.0/netwerk/test/gtest/ |
| H A D | TestBind.cpp | 130 RefPtr<ClientInputCallback> clientCallback; in TEST() local
157 clientCallback = new ClientInputCallback(waiter); in TEST()
164 rv = asyncInputStream->AsyncWait(clientCallback, 0, 0, nullptr); in TEST()
170 if (clientCallback->mFailed) { in TEST()
186 ASSERT_TRUE(clientCallback->mFailed); in TEST()
|
| /dports/lang/spidermonkey60/firefox-60.9.0/netwerk/test/ |
| H A D | TestBind.cpp | 129 RefPtr<ClientInputCallback> clientCallback; in TEST() local
147 clientCallback = new ClientInputCallback(waiter); in TEST()
154 rv = asyncInputStream->AsyncWait(clientCallback, 0, 0, nullptr); in TEST()
158 if (clientCallback->mFailed) { in TEST()
173 ASSERT_TRUE(clientCallback->mFailed); in TEST()
|
| /dports/mail/thunderbird/thunderbird-91.8.0/netwerk/test/gtest/ |
| H A D | TestBind.cpp | 129 RefPtr<ClientInputCallback> clientCallback; in TEST() local
147 clientCallback = new ClientInputCallback(waiter); in TEST()
154 rv = asyncInputStream->AsyncWait(clientCallback, 0, 0, nullptr); in TEST()
158 if (clientCallback->mFailed) { in TEST()
173 ASSERT_TRUE(clientCallback->mFailed); in TEST()
|
| /dports/lang/spidermonkey78/firefox-78.9.0/netwerk/test/gtest/ |
| H A D | TestBind.cpp | 129 RefPtr<ClientInputCallback> clientCallback; in TEST() local
148 clientCallback = new ClientInputCallback(waiter); in TEST()
155 rv = asyncInputStream->AsyncWait(clientCallback, 0, 0, nullptr); in TEST()
159 if (clientCallback->mFailed) { in TEST()
174 ASSERT_TRUE(clientCallback->mFailed); in TEST()
|
| /dports/devel/fbthrift/fbthrift-2021.12.27.00/thrift/lib/cpp2/transport/rocket/test/network/ |
| H A D | ClientServerTestUtil.cpp | 245 auto clientCallback = new TestStreamCallback(kChunkTimeout, std::move(p)); in sendRequestStreamSync() local
421 RocketStreamClientCallback* clientCallback) final { in handleRequestStreamFrame() argument
426 : clientCallback_(clientCallback), in handleRequestStreamFrame()
465 clientCallback_ = &clientCallback; in handleRequestStreamFrame()
479 clientCallback->onFirstResponseError( in handleRequestStreamFrame()
493 new TestRocketStreamServerCallback(clientCallback, n, nEchoHeaders); in handleRequestStreamFrame()
495 auto alive = clientCallback->onFirstResponse( in handleRequestStreamFrame()
507 auto alive = clientCallback->onStreamHeaders({std::move(header), {}}); in handleRequestStreamFrame()
518 RocketSinkClientCallback* clientCallback) final { in handleRequestChannelFrame() argument
536 std::move(impl), ioEvb_, clientCallback); in handleRequestChannelFrame()
[all …]
|
| H A D | RocketNetworkTest.cpp | 825 &clientCallback); in TEST_F()
829 EXPECT_FALSE(clientCallback.getError()); in TEST_F()
853 &clientCallback); in TEST_F()
857 EXPECT_TRUE(clientCallback.getError()); in TEST_F()
858 EXPECT_EQ(0, clientCallback.payloadsReceived()); in TEST_F()
884 &clientCallback); in TEST_F()
888 EXPECT_FALSE(clientCallback.getError()); in TEST_F()
889 EXPECT_EQ(0, clientCallback.payloadsReceived()); in TEST_F()
907 &clientCallback); in TEST_F()
911 EXPECT_FALSE(clientCallback.getError()); in TEST_F()
[all …]
|
| /dports/devel/thrift/thrift-0.14.0/lib/nodejs/lib/thrift/ |
| H A D | ws_transport.js | 65 var clientCallback = callback;
68 clientCallback();
88 var clientCallback = elem.cb;
91 clientCallback();
|
| /dports/www/firefox-legacy/firefox-52.8.0esr/netwerk/test/ |
| H A D | TestBind.cpp | 177 RefPtr<ClientInputCallback> clientCallback = new ClientInputCallback(); in main() local
186 rv = asyncInputStream->AsyncWait(clientCallback, 0, 0, nullptr); in main()
190 if (clientCallback->mFailed) { in main()
|