| /thrift-3.4.0/lib/erl/src/ |
| D | thrift_client.erl | 38 call(Client = #tclient{}, Function, Args)
40 case send_function_call(Client, Function, Args) of
51 send_call(Client = #tclient{}, Function, Args)
53 case send_function_call(Client, Function, Args) of
67 send_function_call(Client = #tclient{service = Service}, Function, Args) ->
78 {{error, {no_function, Function}}, Client};
80 {{error, {bad_args, Function, Args}}, Client};
81 {struct, _PList} -> write_message(Client, Function, Args, Params, MsgType)
86 write_message(Client = #tclient{protocol = P0, seqid = Seq}, Function, Args, Params, MsgType) ->
96 {ok, Client#tclient{protocol = P4}}
[all …]
|
| D | thrift_reconnecting_client.erl | 116 State=#state{ client = Client } ) ->
119 Result = ( catch thrift_client:call( Client, Op, Args) ),
172 terminate( _Reason, #state{ client = Client } ) ->
173 thrift_client:close( Client ),
198 { ok, Client } ->
199 State#state{ client = Client, reconn_time = 0 };
|
| /thrift-3.4.0/lib/d/src/thrift/codegen/ |
| D | client_pool.d | 42 alias TClientBase!Interface Client;
47 this(Client[] clients) { in this()
48 pool_ = new TResourcePool!Client(clients); in this()
76 ResultType execute(ResultType)(scope ResultType delegate(Client) work) { in execute()
77 return executeOnPool!Client(work); in execute()
83 void addClient(Client client) { in addClient()
92 bool removeClient(Client client) { in removeClient()
179 ResultType executeOnPool(ResultType)(scope ResultType delegate(Client) work) { in executeOnPool()
217 Client dummy; in executeOnPool()
231 TResourcePool!Client pool_;
|
| D | async_client_pool.d | 56 alias TAsyncClientBase!Interface Client;
61 void addClient(Client client);
68 bool removeClient(Client client);
130 this(Client[] clients) { in this()
131 pool_ = new TResourcePool!Client(clients); in this()
136 /+override+/ void addClient(Client client) { in addClient()
140 /+override+/ bool removeClient(Client client) { in removeClient()
237 Client next; in executeOnPool()
297 TResourcePool!Client pool_;
346 this(Client[] clients) { in this()
[all …]
|
| /thrift-3.4.0/contrib/zeromq/csharp/ |
| D | Main.cs | 15 Client.work(); in Main()
43 static class Client{ class in ZmqServer.MainClass
50 Storage.Client client=new Storage.Client(p); in work()
|
| /thrift-3.4.0/test/netstd/ |
| D | Makefile.am | 29 $(RM) -r Client/bin
31 $(RM) -r Client/obj
36 Client \
|
| /thrift-3.4.0/tutorial/netstd/ |
| D | Makefile.am | 27 $(RM) -r Client/bin
28 $(RM) -r Client/obj
35 Client \
|
| D | README.md | 16 …x, it is just "Client" or "Server", on Windows it is "Client.exe" and "Server.exe". In the followi…
19 - go to folder (Client/Server)
68 # NetCore Client
72 Client -help
75 Client -tr:<transport> -pr:<protocol> -mc:<numClients>
102 Client -tr:tcp -pr:binary -mc:10
126 **Python Client:**
153 client = Calculator.Client(protocol)
|
| /thrift-3.4.0/lib/java/src/test/java/org/apache/thrift/server/ |
| D | ServerTestBase.java | 346 private void testBool(ThriftTest.Client testClient) throws TException { in testBool()
353 private void testByte(ThriftTest.Client testClient) throws TException { in testByte()
358 private void testUuid(ThriftTest.Client testClient) throws TException { in testUuid()
364 private void testDouble(ThriftTest.Client testClient) throws TException { in testDouble()
369 private void testEnum(ThriftTest.Client testClient) throws TException { in testEnum()
377 private void testI32(ThriftTest.Client testClient) throws TException { in testI32()
382 private void testI64(ThriftTest.Client testClient) throws TException { in testI64()
388 private void testInsanity(ThriftTest.Client testClient) throws TException { in testInsanity()
466 ThriftTest.Client testClient = new ThriftTest.Client(protocol); in testIt()
505 private void testList(ThriftTest.Client testClient) throws TException { in testList()
[all …]
|
| /thrift-3.4.0/lib/netstd/Tests/Thrift.PublicInterfaces.Compile.Tests/Impl/Thrift5253/ |
| D | MyService.cs | 39 public Task<Client> Client_(Client? input, CancellationToken cancellationToken = default)
42 return Task.FromResult(new Client() { Foo = input?.Foo ?? 0 });
|
| /thrift-3.4.0/lib/nodejs/lib/thrift/ |
| D | create_client.js | 30 if (ServiceClient.Client) {
31 ServiceClient = ServiceClient.Client;
|
| D | multiplexed_protocol.js | 52 if (ServiceClient.Client) {
53 ServiceClient = ServiceClient.Client;
|
| /thrift-3.4.0/lib/netstd/Thrift/Transport/Client/ |
| D | TSocketTransport.cs | 24 namespace Thrift.Transport.Client
57 TcpClient.Client.NoDelay = true; in TSocketTransport()
88 TcpClient.Client.NoDelay = true; in TSocketTransport()
133 TcpClient.Client.NoDelay = true; in TSocketTransport()
|
| /thrift-3.4.0/lib/netstd/Tests/Thrift.PublicInterfaces.Compile.Tests/ |
| D | Thrift5253.thrift | 35 struct Client { 1: optional i32 foo }
46 Client Client ( 1: Client foo)
|
| /thrift-3.4.0/lib/py/test/ |
| D | thrift_TNonblockingServer.py | 59 class Client: class
65 client = TestServer.Client(protocol)
82 client = Client()
|
| /thrift-3.4.0/tutorial/java/src/ |
| D | JavaClient.java | 63 Calculator.Client client = new Calculator.Client(protocol); in main()
73 private static void perform(Calculator.Client client) throws TException in perform()
|
| /thrift-3.4.0/lib/netstd/Thrift/Transport/Layered/ |
| D | TFramedTransport.cs | 31 private readonly Client.TMemoryBufferTransport ReadBuffer;
32 private readonly Client.TMemoryBufferTransport WriteBuffer;
47 ReadBuffer = new Client.TMemoryBufferTransport(Configuration); in TFramedTransport()
48 WriteBuffer = new Client.TMemoryBufferTransport(Configuration); in TFramedTransport()
|
| D | TBufferedTransport.cs | 30 private readonly Client.TMemoryBufferTransport ReadBuffer;
31 private readonly Client.TMemoryBufferTransport WriteBuffer;
53 WriteBuffer = new Client.TMemoryBufferTransport(InnerTransport.Configuration, bufSize); in TBufferedTransport()
54 ReadBuffer = new Client.TMemoryBufferTransport(InnerTransport.Configuration, bufSize); in TBufferedTransport()
|
| /thrift-3.4.0/lib/go/thrift/ |
| D | http_client.go | 35 var DefaultHttpClient *http.Client = http.DefaultClient
38 client *http.Client
62 Client *http.Client member
79 client := options.Client
|
| D | http_client_test.go | 71 Client: &http.Client{
92 DefaultHttpClient = &http.Client{
|
| /thrift-3.4.0/lib/rb/benchmark/ |
| D | client.rb | 25 class Client class
74 Client.new(host, port.to_i, clients_per_process.to_i, calls_per_client.to_i, log_exceptions).run
|
| /thrift-3.4.0/lib/java/src/test/java/org/apache/thrift/protocol/ |
| D | ProtocolTestBase.java | 410 Srv.Client testClient = new Srv.Client(clientInProto, clientOutProto); in testServerRequest()
549 ThriftTest.Client testClient = new ThriftTest.Client(clientInProto, clientOutProto); in testReadCheckMaxMessageRequestForString()
565 ThriftTest.Client testClient = new ThriftTest.Client(clientInProto, clientOutProto); in testReadCheckMaxMessageRequestForList()
583 ThriftTest.Client testClient = new ThriftTest.Client(clientInProto, clientOutProto); in testReadCheckMaxMessageRequestForMap()
605 ThriftTest.Client testClient = new ThriftTest.Client(clientInProto, clientOutProto); in testReadCheckMaxMessageRequestForSet()
|
| /thrift-3.4.0/lib/cpp/test/processor/ |
| D | ProcessorTest.cpp | 200 typedef typename TemplateTraits_::ParentClient Client; typedef in ParentServiceTraits
211 typedef typename TemplateTraits_::ChildClient Client; typedef in ChildServiceTraits
232 typedef typename ServiceTraits_::Client Client; typedef in ServiceState
262 std::shared_ptr<Client> createClient() { in createClient()
270 std::shared_ptr<Client> client(new Client(protocol)); in createClient()
428 std::shared_ptr<typename State_::Client> client = state->createClient(); in testParentService()
450 std::shared_ptr<typename State_::Client> client = state->createClient(); in testChildService()
644 std::shared_ptr<typename State::Client> client1 = state->createClient(); in testSeparateConnections()
650 std::shared_ptr<typename State::Client> client2 = state->createClient(); in testSeparateConnections()
692 std::shared_ptr<typename State::Client> client = state->createClient(); in testOnewayCall()
[all …]
|
| /thrift-3.4.0/lib/haxe/src/org/apache/thrift/protocol/ |
| D | TMultiplexedProtocol.hx | 41 * Calculator.Client service = new Calculator.Client(mp);
44 * WeatherReport.Client service2 = new WeatherReport.Client(mp2);
|
| /thrift-3.4.0/lib/delphi/test/multiplexed/ |
| D | Multiplex.Test.Client.dpr | 21 program Multiplex.Test.Client;
27 Multiplex.Client.Main in 'Multiplex.Client.Main.pas',
|
