| /thrift-3.4.0/lib/netstd/Thrift/Protocol/ |
| D | TProtocolDecorator.cs | 42 …public override async Task WriteMessageBeginAsync(TMessage message, CancellationToken cancellation… in WriteMessageBeginAsync()
47 public override async Task WriteMessageEndAsync(CancellationToken cancellationToken) in WriteMessageEndAsync()
52 …public override async Task WriteStructBeginAsync(TStruct @struct, CancellationToken cancellationTo…
57 public override async Task WriteStructEndAsync(CancellationToken cancellationToken) in WriteStructEndAsync()
62 … public override async Task WriteFieldBeginAsync(TField field, CancellationToken cancellationToken) in WriteFieldBeginAsync()
67 public override async Task WriteFieldEndAsync(CancellationToken cancellationToken) in WriteFieldEndAsync()
72 public override async Task WriteFieldStopAsync(CancellationToken cancellationToken) in WriteFieldStopAsync()
77 public override async Task WriteMapBeginAsync(TMap map, CancellationToken cancellationToken) in WriteMapBeginAsync()
82 public override async Task WriteMapEndAsync(CancellationToken cancellationToken) in WriteMapEndAsync()
87 … public override async Task WriteListBeginAsync(TList list, CancellationToken cancellationToken) in WriteListBeginAsync()
[all …]
|
| D | TJSONProtocol.cs | 102 … protected async Task ReadJsonSyntaxCharAsync(byte[] bytes, CancellationToken cancellationToken) in ReadJsonSyntaxCharAsync()
114 private async Task WriteJsonStringAsync(byte[] bytes, CancellationToken cancellationToken) in WriteJsonStringAsync()
162 private async Task WriteJsonIntegerAsync(long num, CancellationToken cancellationToken) in WriteJsonIntegerAsync()
186 private async Task WriteJsonDoubleAsync(double num, CancellationToken cancellationToken) in WriteJsonDoubleAsync()
226 private async Task WriteJsonBase64Async(byte[] bytes, CancellationToken cancellationToken) in WriteJsonBase64Async()
253 private async Task WriteJsonObjectStartAsync(CancellationToken cancellationToken) in WriteJsonObjectStartAsync()
260 private async Task WriteJsonObjectEndAsync(CancellationToken cancellationToken) in WriteJsonObjectEndAsync()
266 private async Task WriteJsonArrayStartAsync(CancellationToken cancellationToken) in WriteJsonArrayStartAsync()
273 private async Task WriteJsonArrayEndAsync(CancellationToken cancellationToken) in WriteJsonArrayEndAsync()
279 …public override async Task WriteMessageBeginAsync(TMessage message, CancellationToken cancellation… in WriteMessageBeginAsync()
[all …]
|
| D | TBinaryProtocol.cs | 55 …public override async Task WriteMessageBeginAsync(TMessage message, CancellationToken cancellation… in WriteMessageBeginAsync()
92 … public override async Task WriteFieldBeginAsync(TField field, CancellationToken cancellationToken) in WriteFieldBeginAsync()
105 public override async Task WriteFieldStopAsync(CancellationToken cancellationToken) in WriteFieldStopAsync()
112 public override async Task WriteMapBeginAsync(TMap map, CancellationToken cancellationToken) in WriteMapBeginAsync()
129 … public override async Task WriteListBeginAsync(TList list, CancellationToken cancellationToken) in WriteListBeginAsync()
142 public override async Task WriteSetBeginAsync(TSet set, CancellationToken cancellationToken) in WriteSetBeginAsync()
155 public override async Task WriteBoolAsync(bool b, CancellationToken cancellationToken) in WriteBoolAsync()
161 public override async Task WriteByteAsync(sbyte b, CancellationToken cancellationToken) in WriteByteAsync()
169 public override async Task WriteI16Async(short i16, CancellationToken cancellationToken) in WriteI16Async()
178 public override async Task WriteI32Async(int i32, CancellationToken cancellationToken) in WriteI32Async()
[all …]
|
| D | TCompactProtocol.cs | 126 …public override async Task WriteMessageBeginAsync(TMessage message, CancellationToken cancellation… in WriteMessageBeginAsync()
168 …private async Task WriteFieldBeginInternalAsync(TField field, byte fieldType, CancellationToken ca… in WriteFieldBeginInternalAsync()
196 … public override async Task WriteFieldBeginAsync(TField field, CancellationToken cancellationToken) in WriteFieldBeginAsync()
214 public override async Task WriteFieldStopAsync(CancellationToken cancellationToken) in WriteFieldStopAsync()
222 …protected async Task WriteCollectionBeginAsync(TType elemType, int size, CancellationToken cancell… in WriteCollectionBeginAsync()
246 … public override async Task WriteListBeginAsync(TList list, CancellationToken cancellationToken) in WriteListBeginAsync()
257 public override async Task WriteSetBeginAsync(TSet set, CancellationToken cancellationToken) in WriteSetBeginAsync()
270 public override async Task WriteBoolAsync(bool b, CancellationToken cancellationToken) in WriteBoolAsync()
296 public override async Task WriteByteAsync(sbyte b, CancellationToken cancellationToken) in WriteByteAsync()
304 public override async Task WriteI16Async(short i16, CancellationToken cancellationToken) in WriteI16Async()
[all …]
|
| /thrift-3.4.0/lib/js/test/ |
| D | test-async.js | 51 const done = assert.async();
61 const done = assert.async(3);
83 const done = assert.async(4);
104 const done = assert.async(2);
116 const done = assert.async(3);
132 const done = assert.async(3);
155 const done = assert.async();
175 const done = assert.async();
202 const done = assert.async();
215 const done = assert.async();
[all …]
|
| D | test-es6.js | 52 const done = assert.async();
61 const done = assert.async(3);
83 const done = assert.async(4);
104 const done = assert.async(2);
116 const done = assert.async(3);
132 const done = assert.async(3);
153 const done = assert.async();
173 const done = assert.async();
200 const done = assert.async();
213 const done = assert.async();
[all …]
|
| D | test-jq.js | 41 const done = assert.async(2);
68 const done = assert.async(2);
100 const done = assert.async(3);
120 const done = assert.async(4);
147 const done = assert.async(2);
|
| /thrift-3.4.0/lib/dart/test/protocol/ |
| D | t_protocol_test.dart | 20 import 'dart:async';
60 Future primitiveTest(Primitive primitive, input) async {
72 Future primitiveNullTest(Primitive primitive) async {
85 test('Test message', () async {
97 test('Test struct', () async {
113 test('Test field', () async {
130 test('Test map', () async {
147 test('Test list', () async {
163 test('Test set', () async {
179 test('Test bool', () async {
[all …]
|
| /thrift-3.4.0/test/dart/test_client/bin/ |
| D | main.dart | 18 import 'dart:async';
61 main(List<String> args) async {
150 {String host, int port, String transportType, String protocolType}) async {
182 tests.add(new TTest(TEST_BASETYPES, 'testVoid', () async {
186 tests.add(new TTest(TEST_BASETYPES, 'testString', () async {
192 tests.add(new TTest(TEST_BASETYPES, 'testBool', () async {
198 tests.add(new TTest(TEST_BASETYPES, 'testByte', () async {
204 tests.add(new TTest(TEST_BASETYPES, 'testI32', () async {
210 tests.add(new TTest(TEST_BASETYPES, 'testI64', () async {
216 tests.add(new TTest(TEST_BASETYPES, 'testDouble', () async {
[all …]
|
| /thrift-3.4.0/test/netstd/Client/Performance/ |
| D | PerformanceTests.cs | 44 internal static async Task<int> Execute() in Execute()
64 private async Task ProtocolPeformanceTestAsync() in ProtocolPeformanceTestAsync()
73 …await RunTestAsync(async (bool b) => { return await GenericProtocolFactory<TBinaryProtocol>(b); }); in ProtocolPeformanceTestAsync()
74 …await RunTestAsync(async (bool b) => { return await GenericProtocolFactory<TCompactProtocol>(b); }… in ProtocolPeformanceTestAsync()
75 … await RunTestAsync(async (bool b) => { return await GenericProtocolFactory<TJsonProtocol>(b); }); in ProtocolPeformanceTestAsync()
79 private async Task<TProtocol> GenericProtocolFactory<T>(bool forWrite)
131 private async Task RunTestAsync(Func<bool, Task<TProtocol>> factory) in RunTestAsync()
|
| /thrift-3.4.0/tutorial/dart/server/bin/ |
| D | main.dart | 18 import 'dart:async';
68 Future _runWebSocketServer(int port) async {
72 httpServer.listen((HttpRequest request) async {
82 Future _runTcpServer(int port) async {
90 Future _initProcessor(TSocket socket) async {
100 Future _processMessage(_) async {
107 Future ping() async {
111 Future<int> add(int num1, int num2) async {
117 Future<int> calculate(int logid, Work work) async {
154 Future zip() async {
[all …]
|
| /thrift-3.4.0/contrib/async-test/ |
| D | test-server.cpp | 14 using apache::thrift::async::TEvhttpServer;
15 using apache::thrift::async::TAsyncProcessor;
16 using apache::thrift::async::TAsyncBufferProcessor;
17 using apache::thrift::async::TAsyncProtocolProcessor;
18 using apache::thrift::async::TAsyncChannel;
19 using apache::thrift::async::TEvhttpClientChannel;
|
| /thrift-3.4.0/lib/js/ |
| D | Gruntfile.js | 81 async: true,
91 async: true,
101 async: true,
111 async: true,
282 var done = this.async();
|
| /thrift-3.4.0/lib/dart/test/transport/ |
| D | t_socket_transport_test.dart | 20 import 'dart:async';
45 setUp(() async {
53 test('Test client sending data over transport', () async {
80 setUp(() async {
89 test('Test client sending data over framed transport', () async {
111 setUp(() async {
124 test('Test response correlates to correct request', () async {
148 test('Test response timeout', () async {
159 setUp(() async {
175 test('Test async client sending data over framed transport', () async {
[all …]
|
| /thrift-3.4.0/lib/netstd/Tests/Thrift.IntegrationTests/Protocols/ |
| D | ProtocolsOperationsTests.cs | 51 public async Task WriteReadMessage_Test(Type protocolType, TMessageType messageType) in WriteReadMessage_Test()
85 public async Task WriteReadStruct_Test(Type protocolType) in WriteReadStruct_Test()
120 public async Task WriteReadField_Test(Type protocolType) in WriteReadField_Test()
153 public async Task WriteReadMap_Test(Type protocolType) in WriteReadMap_Test()
187 public async Task WriteReadList_Test(Type protocolType) in WriteReadList_Test()
220 public async Task WriteReadSet_Test(Type protocolType) in WriteReadSet_Test()
253 public async Task WriteReadBool_Test(Type protocolType) in WriteReadBool_Test()
284 public async Task WriteReadByte_Test(Type protocolType) in WriteReadByte_Test()
315 public async Task WriteReadI16_Test(Type protocolType) in WriteReadI16_Test()
346 public async Task WriteReadI32_Test(Type protocolType) in WriteReadI32_Test()
[all …]
|
| /thrift-3.4.0/lib/cpp/ |
| D | Makefile.am | 61 src/thrift/async/TAsyncChannel.cpp \
62 src/thrift/async/TAsyncProtocolProcessor.cpp \
63 src/thrift/async/TConcurrentClientSyncInfo.cpp \
105 src/thrift/async/TEvhttpServer.cpp \
106 src/thrift/async/TEvhttpClientChannel.cpp
231 include_asyncdir = $(include_thriftdir)/async
233 src/thrift/async/TAsyncChannel.h \
234 src/thrift/async/TAsyncDispatchProcessor.h \
235 src/thrift/async/TAsyncProcessor.h \
236 src/thrift/async/TAsyncBufferProcessor.h \
[all …]
|
| /thrift-3.4.0/lib/netstd/Thrift/Transport/ |
| D | TTransport.cs | 45 public async ValueTask<bool> PeekAsync(CancellationToken cancellationToken) in PeekAsync()
110 …public virtual async ValueTask<int> ReadAllAsync(byte[] buffer, int offset, int length, Cancellati… in ReadAllAsync()
153 public virtual async Task WriteAsync(byte[] buffer, CancellationToken cancellationToken) in WriteAsync()
158 public virtual async Task WriteAsync(byte[] buffer, int offset, int length) in WriteAsync()
|
| /thrift-3.4.0/lib/netstd/Thrift/Transport/Layered/ |
| D | TFramedTransport.cs | 54 public override async Task OpenAsync(CancellationToken cancellationToken) in OpenAsync()
68 …public override async ValueTask<int> ReadAsync(byte[] buffer, int offset, int length, Cancellation… in ReadAsync()
87 private async ValueTask ReadFrameAsync(CancellationToken cancellationToken) in ReadFrameAsync()
104 …public override async Task WriteAsync(byte[] buffer, int offset, int length, CancellationToken can… in WriteAsync()
122 public override async Task FlushAsync(CancellationToken cancellationToken) in FlushAsync()
|
| D | TBufferedTransport.cs | 72 public override async Task OpenAsync(CancellationToken cancellationToken) in OpenAsync()
86 …public override async ValueTask<int> ReadAsync(byte[] buffer, int offset, int length, Cancellation… in ReadAsync()
122 …public override async Task WriteAsync(byte[] buffer, int offset, int length, CancellationToken can… in WriteAsync()
153 public override async Task FlushAsync(CancellationToken cancellationToken) in FlushAsync()
|
| /thrift-3.4.0/lib/netstd/Thrift/Transport/Client/ |
| D | TNamedPipeTransport.cs | 49 public override async Task OpenAsync(CancellationToken cancellationToken) in OpenAsync()
71 …public override async ValueTask<int> ReadAsync(byte[] buffer, int offset, int length, Cancellation… in ReadAsync()
88 …public override async Task WriteAsync(byte[] buffer, int offset, int length, CancellationToken can… in WriteAsync()
112 public override async Task FlushAsync(CancellationToken cancellationToken) in FlushAsync()
|
| D | TStreamTransport.cs | 76 …public override async ValueTask<int> ReadAsync(byte[] buffer, int offset, int length, Cancellation… in ReadAsync()
91 …public override async Task WriteAsync(byte[] buffer, int offset, int length, CancellationToken can… in WriteAsync()
106 public override async Task FlushAsync(CancellationToken cancellationToken) in FlushAsync()
|
| /thrift-3.4.0/tutorial/dart/console_client/bin/ |
| D | main.dart | 18 import 'dart:async';
64 Future _initConnection(int port) async {
74 Future _run() async {
131 Future _ping() async {
136 Future _add(int x, int y) async {
141 Future _calc(Work work) async {
146 Future _struct(int key) async {
|
| /thrift-3.4.0/tutorial/netstd/Server/ |
| D | Program.cs | 124 private static async Task RunAsync(string[] args, CancellationToken cancellationToken) in RunAsync()
189 …private static async Task RunSelectedConfigurationAsync(Transport transport, Buffering buffering, … in RunSelectedConfigurationAsync()
378 public async Task<SharedStruct> getStruct(int key, in getStruct()
385 public async Task ping(CancellationToken cancellationToken) in ping()
391 public async Task<int> add(int num1, int num2, CancellationToken cancellationToken) in add()
397 public async Task<int> calculate(int logid, Work w, CancellationToken cancellationToken) in calculate()
453 public async Task zip(CancellationToken cancellationToken) in zip()
462 public async Task<SharedStruct> getStruct(int key, CancellationToken cancellationToken) in getStruct()
|
| /thrift-3.4.0/lib/netstd/Benchmarks/Thrift.Benchmarks/ |
| D | CompactProtocolBenchmarks.cs | 52 public async Task WriteString() in WriteString()
65 public async Task ReadString() in ReadString()
|
| /thrift-3.4.0/lib/swift/Sources/ |
| D | TSocketServer.swift | 107 DispatchQueue(label: "TSocketServer.connectionAccept").async { in acceptConnectionInBackgroundAndNotify()
109 DispatchQueue.main.async { in acceptConnectionInBackgroundAndNotify()
116 processingQueue.async { in connectionAccepted()
140 DispatchQueue.main.async { in handleClientConnection()
|
