| /thrift-3.4.0/lib/delphi/test/ |
| D | client.dpr | 7 * "License"); you may not use this file except in compliance
12 * Unless required by applicable law or agreed to in writing,
27 DataFactory in 'Performance\DataFactory.pas',
28 PerfTests in 'Performance\PerfTests.pas',
29 TestClient in 'TestClient.pas',
30 Thrift.Test in 'gen-delphi\Thrift.Test.pas',
31 Thrift in '..\src\Thrift.pas',
32 Thrift.Transport in '..\src\Thrift.Transport.pas',
33 Thrift.Socket in '..\src\Thrift.Socket.pas',
34 Thrift.Configuration in '..\src\Thrift.Configuration.pas',
[all …]
|
| D | server.dpr | 7 * "License"); you may not use this file except in compliance
12 * Unless required by applicable law or agreed to in writing,
26 TestServer in 'TestServer.pas',
27 TestServerEvents in 'TestServerEvents.pas',
28 Thrift.Test in 'gen-delphi\Thrift.Test.pas',
29 Thrift in '..\src\Thrift.pas',
30 Thrift.Exception in '..\src\Thrift.Exception.pas',
31 Thrift.Transport in '..\src\Thrift.Transport.pas',
32 Thrift.Socket in '..\src\Thrift.Socket.pas',
33 Thrift.Transport.Pipes in '..\src\Thrift.Transport.Pipes.pas',
[all …]
|
| /thrift-3.4.0/lib/delphi/test/serializer/ |
| D | TestSerializer.dpr | 7 * "License"); you may not use this file except in compliance
12 * Unless required by applicable law or agreed to in writing,
29 Thrift in '..\..\src\Thrift.pas',
30 Thrift.Exception in '..\..\src\Thrift.Exception.pas',
31 Thrift.Socket in '..\..\src\Thrift.Socket.pas',
32 Thrift.Transport in '..\..\src\Thrift.Transport.pas',
33 Thrift.Protocol in '..\..\src\Thrift.Protocol.pas',
34 Thrift.Protocol.JSON in '..\..\src\Thrift.Protocol.JSON.pas',
35 Thrift.Protocol.Compact in '..\..\src\Thrift.Protocol.Compact.pas',
36 Thrift.Collections in '..\..\src\Thrift.Collections.pas',
[all …]
|
| D | SerializerData.dpr | 8 * "License"); you may not use this file except in compliance
13 * Unless required by applicable law or agreed to in writing,
26 Thrift in '..\..\src\Thrift.pas',
27 Thrift.Exception in '..\..\src\Thrift.Exception.pas',
28 Thrift.Socket in '..\..\src\Thrift.Socket.pas',
29 Thrift.Transport in '..\..\src\Thrift.Transport.pas',
30 Thrift.Protocol in '..\..\src\Thrift.Protocol.pas',
31 Thrift.Protocol.JSON in '..\..\src\Thrift.Protocol.JSON.pas',
32 Thrift.Protocol.Compact in '..\..\src\Thrift.Protocol.Compact.pas',
33 Thrift.Collections in '..\..\src\Thrift.Collections.pas',
[all …]
|
| /thrift-3.4.0/lib/delphi/test/multiplexed/ |
| D | Multiplex.Test.Server.dpr | 7 * "License"); you may not use this file except in compliance
12 * Unless required by applicable law or agreed to in writing,
26 Multiplex.Server.Main in 'Multiplex.Server.Main.pas',
27 Benchmark in 'gen-delphi\Benchmark.pas',
28 Aggr in 'gen-delphi\Aggr.pas',
29 ConsoleHelper in '..\ConsoleHelper.pas',
30 Thrift in '..\..\src\Thrift.pas',
31 Thrift.Exception in '..\..\src\Thrift.Exception.pas',
32 Thrift.Socket in '..\..\src\Thrift.Socket.pas',
33 Thrift.Transport in '..\..\src\Thrift.Transport.pas',
[all …]
|
| D | Multiplex.Test.Client.dpr | 7 * "License"); you may not use this file except in compliance
12 * Unless required by applicable law or agreed to in writing,
27 Multiplex.Client.Main in 'Multiplex.Client.Main.pas',
28 Benchmark in 'gen-delphi\Benchmark.pas',
29 Aggr in 'gen-delphi\Aggr.pas',
30 Thrift in '..\..\src\Thrift.pas',
31 Thrift.Socket in '..\..\src\Thrift.Socket.pas',
32 Thrift.Exception in '..\..\src\Thrift.Exception.pas',
33 Thrift.Transport in '..\..\src\Thrift.Transport.pas',
34 Thrift.Transport.Pipes in '..\..\src\Thrift.Transport.Pipes.pas',
[all …]
|
| /thrift-3.4.0/lib/delphi/test/typeregistry/ |
| D | TestTypeRegistry.dpr | 7 * "License"); you may not use this file except in compliance
12 * Unless required by applicable law or agreed to in writing,
26 Thrift in '..\..\src\Thrift.pas',
27 Thrift.Transport in '..\..\src\Thrift.Transport.pas',
28 Thrift.Exception in '..\..\src\Thrift.Exception.pas',
29 Thrift.Socket in '..\..\src\Thrift.Socket.pas',
30 Thrift.Protocol in '..\..\src\Thrift.Protocol.pas',
31 Thrift.Protocol.JSON in '..\..\src\Thrift.Protocol.JSON.pas',
32 Thrift.Collections in '..\..\src\Thrift.Collections.pas',
33 Thrift.Configuration in '..\..\src\Thrift.Configuration.pas',
[all …]
|
| /thrift-3.4.0/test/ocaml/server/ |
| D | TestServer.ml | 7 "License"); you may not use this file except in compliance
12 Unless required by applicable law or agreed to in writing,
48 let mm = Hashtbl.create 3 in
49 let pos = Hashtbl.create 7 in
50 let neg = Hashtbl.create 7 in
60 let hello = new xtruct in
61 let goodbye = new xtruct in
62 let crazy = new insanity in
63 let looney = new insanity in
64 let cumap = Hashtbl.create 7 in
[all …]
|
| /thrift-3.4.0/lib/go/thrift/ |
| D | middleware.go | 7 * "License"); you may not use this file except in compliance
12 * Unless required by applicable law or agreed to in writing,
29 // Middlewares are passed in the name of the function as set in the processor
34 // TProcessorFunctions with the middlewares passed in and returns it.
36 // Middlewares will be called in the order that they are defined:
45 // Add middlewares in reverse so the first in the list is the outermost.
60 Wrapped func(ctx context.Context, seqId int32, in, out TProtocol) (bool, TException)
64 func (p WrappedTProcessorFunction) Process(ctx context.Context, seqID int32, in, out TProtocol) (bo…
65 return p.Wrapped(ctx, seqID, in, out)
74 // ClientMiddleware can be passed to WrapClient in order to wrap TClient calls
[all …]
|
| D | common_test.go | 7 * "License"); you may not use this file except in compliance
12 * Unless required by applicable law or agreed to in writing,
28 ProcessFunc func(in, out TProtocol) (bool, TException)
31 func (m *mockProcessor) Process(ctx context.Context, in, out TProtocol) (bool, TException) {
32 return m.ProcessFunc(in, out)
38 Wrapped: func(ctx context.Context, seqId int32, in, out TProtocol) (bool, TException) {
39 return m.ProcessFunc(in, out)
56 // In a normal TProcessor, the request name is read from the request itself
57 // which happens in TProcessor.Process, so it is not passed into the call to
58 // Process itself, to get around this in testing, mockWrappableProcessor calls
[all …]
|
| /thrift-3.4.0/lib/ocaml/src/ |
| D | TFramedTransport.ml | 9 let s = String.create 4 in
10 let n3 = Int32.to_int (Int32.shift_right_logical x 24) land 0xff in
11 let n2 = Int32.to_int (Int32.shift_right_logical x 16) land 0xff in
12 let n1 = Int32.to_int (Int32.shift_right_logical x 8) land 0xff in
13 let n0 = Int32.to_int (Int32.logand x c_0xff_32) in
21 let n3 = Int32.of_int (Char.code s.[0]) in
22 let n2 = Int32.of_int (Char.code s.[1]) in
23 let n1 = Int32.of_int (Char.code s.[2]) in
24 let n0 = Int32.of_int (Char.code s.[3]) in
46 let len_buf = String.create 4 in
[all …]
|
| D | TBinaryProtocol.ml | 7 "License"); you may not use this file except in compliance
12 Unless required by applicable law or agreed to in writing,
34 let s = ref 0l in
35 let sb = 32 - 8*n in
42 let s = ref 0L in
62 let gb = get_byte i in
67 let gb = get_byte32 i in
73 let gb = get_byte64 i in
81 let n = String.length s in
128 let sz = Int32.to_int (self#readI32) in
[all …]
|
| /thrift-3.4.0/compiler/cpp/src/thrift/generate/ |
| D | t_generator.h | 7 * "License"); you may not use this file except in compliance
12 * Unless required by applicable law or agreed to in writing,
64 * should not normally be overwritten in the subclasses.
93 * Escape string to use one in generated sources.
95 virtual std::string escape_string(const std::string& in) const;
200 * comments, which are also fair game in Java / PHP, yay!
229 pverbose("Wrong indent count in %s: difference = %i \n", func_name, (expected - indent_)); in indent_validate()
253 std::string capitalize(std::string in) { in capitalize() argument
254 in[0] = toupper(in[0]); in capitalize()
255 return in; in capitalize()
[all …]
|
| /thrift-3.4.0/doc/specs/ |
| D | thrift.tex | 48 that is implemented in each language. Specifically, Thrift allows developers to
49 define datatypes and service interfaces in a single language-neutral file
52 This paper details the motivations and design choices we made in Thrift, as
70 drastically outside the scope of the LAMP framework. In our implementation of
92 the necessary data structures and interfaces for a complex service in a single
99 In evaluating the challenges of cross-language interaction in a networked
114 raw data in memory, or files on disk. Section 3 details the Thrift Transport
121 All that matters is that the data can be read and written in a consistent,
126 it should be possible to add or remove fields in an object or alter the
127 argument list of a function without any interruption in service (or,
[all …]
|
| D | thrift-rpc.md | 12 "License"); you may not use this file except in compliance
17 Unless required by applicable law or agreed to in writing,
31 In addition, this document compares the binary protocol with the compact protocol. Finally, it desc…
34 The information here is _mostly_ based on the Java implementation in the Apache thrift library (ver…
61 The pattern is a simple half duplex protocol where the parties alternate in sending a `Message` fol…
75 … id* is a simple message id assigned by the client. The server will use the same sequence id in the
79 The *name* indicates the service method name to invoke. The server copies the name in the response …
85 `Oneway` (step 1 in the protocol exchange). Servers send responses with messages of type `Exception…
89 exceptions defined in the Thrift IDL file.
92 in the Thrift IDL file, or some other part of the Thrift stack throws an exception. For example whe…
[all …]
|
| /thrift-3.4.0/tutorial/delphi/DelphiClient/ |
| D | DelphiClient.dpr | 7 * "License"); you may not use this file except in compliance
12 * Unless required by applicable law or agreed to in writing,
27 Thrift in '..\..\..\lib\delphi\src\Thrift.pas',
28 Thrift.Collections in '..\..\..\lib\delphi\src\Thrift.Collections.pas',
29 Thrift.Configuration in '..\..\..\lib\delphi\src\Thrift.Configuration.pas',
30 Thrift.Exception in '..\..\..\lib\delphi\src\Thrift.Exception.pas',
31 Thrift.Utils in '..\..\..\lib\delphi\src\Thrift.Utils.pas',
32 Thrift.Stream in '..\..\..\lib\delphi\src\Thrift.Stream.pas',
33 Thrift.Protocol in '..\..\..\lib\delphi\src\Thrift.Protocol.pas',
34 Thrift.Server in '..\..\..\lib\delphi\src\Thrift.Server.pas',
[all …]
|
| /thrift-3.4.0/tutorial/ocaml/ |
| D | CalcClient.ml | 7 "License"); you may not use this file except in compliance
12 Unless required by applicable law or agreed to in writing,
37 let tx = new TSocket.t host port in
38 let proto = new TBinaryProtocol.t tx in
39 let calc = new Calculator.client proto proto in
45 let cli = connect ~host:"127.0.0.1" 9090 in
49 (let sum = cli.calc#add (Int32.of_int 1) (Int32.of_int 1) in
52 (let w = new work in
57 let quotient = cli.calc#calculate (Int32.of_int 1) w in
61 (let w = new work in
[all …]
|
| D | CalcServer.ml | 7 "License"); you may not use this file except in compliance
12 Unless required by applicable law or agreed to in writing,
39 let w = sod w in
51 let io = new invalidOperation in
56 Int32.div w#grab_num1 w#grab_num2 in
58 let ss = new sharedStruct in
60 let buffer = Int32.to_string rv in
75 let h = new calc_handler in
76 let proc = new Calculator.processor h in
77 let port = 9090 in
[all …]
|
| /thrift-3.4.0/lib/cpp/src/thrift/processor/ |
| D | PeekProcessor.cpp | 7 * "License"); you may not use this file except in compliance
12 * Unless required by applicable law or agreed to in writing,
45 std::shared_ptr<TTransport> PeekProcessor::getPipedTransport(std::shared_ptr<TTransport> in) { in getPipedTransport() argument
46 return transportFactory_->getTransport(in); in getPipedTransport()
64 bool PeekProcessor::process(std::shared_ptr<TProtocol> in, in process() argument
71 in->readMessageBegin(fname, mtype, seqid); in process()
83 in->readFieldBegin(fname, ftype, fid); in process()
89 peek(in, ftype, fid); in process()
90 in->readFieldEnd(); in process()
92 in->readMessageEnd(); in process()
[all …]
|
| /thrift-3.4.0/compiler/cpp/ |
| D | README.md | 10 - [Build with XCode IDE in MacOS](#build-with-xcode-ide-in-macos)
18 …- [Building the Thrift IDL compiler in Windows without CMake](#building-the-thrift-idl-compiler-in…
56 #### Build with XCode IDE in MacOS
67 - Run commands in command line:
87 - In case if you want to build without Git Bash - install winflexbison - https://sourceforge.net/pr…
88 - In case if you want to build with Visual Studio - install Visual Studio
89 …nt with C++" for VS2017) - Microsoft added some support for CMake and improving it in Visual Studio
107 - Run commands in command line:
125 ## Building the Thrift IDL compiler in Windows without CMake
135 Place these binaries somewhere in the path and rename win_flex.exe and win_bison.exe to flex.exe an…
[all …]
|
| /thrift-3.4.0/test/ocaml/client/ |
| D | TestClient.ml | 7 "License"); you may not use this file except in compliance
12 Unless required by applicable law or agreed to in writing,
44 let l = [1;2;3;4] in
46 let h = Hashtbl.create 5 in
47 let a = Hashtbl.add h in
51 let r = c#testMap h in
54 let g = Hashtbl.find r i in
62 let s = Hashtbl.create 5 in
63 let a = Hashtbl.add s in
67 let r = c#testSet s in
[all …]
|
| /thrift-3.4.0/compiler/cpp/tests/ocaml/ |
| D | snapshot_service_handle_ex.cc | 6 // "License"); you may not use this file except in compliance
11 // Unless required by applicable law or agreed to in writing,
27 let _new = Oo.copy self in
35 let _str2 = new ping_args in
38 let (_,_t3,_id4) = iprot#readFieldBegin in
60 let _new = Oo.copy self in
75 let _str8 = new ping_result in
78 let (_,_t9,_id10) = iprot#readFieldBegin in
107 let args = new ping_args in
112 let (fname, mtype, rseqid) = iprot#readMessageBegin in
[all …]
|
| /thrift-3.4.0/test/crossrunner/ |
| D | collect.py | 7 # "License"); you may not use this file except in compliance
12 # Unless required by applicable law or agreed to in writing,
41 # (e.g. "binary" is equivalent to "binary:binary" in tests.json)
61 for lib in config:
67 for base, conf in zip(base_configs, configs):
69 if not match or base['name'] in match:
71 if not platforms or platform.system() in platforms:
101 for v in values:
109 for spec1, impl1 in cached_set(o1):
110 for spec2, impl2 in cached_set(o2):
[all …]
|
| /thrift-3.4.0/lib/java/src/main/java/org/apache/thrift/partial/ |
| D | README.md | 5 1. Make it easier to understand the current Java implementation in this folder.
6 1. Be useful in implementing partial deserialization support in additional languages.
8 …eserialization. The second part describes components involved in the Java implementation in this f…
16 …in any Thrift object. This situation arises often when big data is stored in Thrift encoded format…
51 …of the key type. However, that limitation can be addressed in future by amending the syntax in a b…
53 … `structMap.stringValue` shown above has leaf segment `stringValue` which is a field in map values.
66 We saw in the previous section how we can identify the subset of fields to deserialize. As the firs…
86 …tation of each such method simply calls the corresponding `read*()` method in `TProtocol.java`. A …
95 …in the compiled `ThriftMetadata` to see if that field needs to be deserialized. If yes, then the f…
105 …in some intermediate form. The default implementation of this interface is `ThriftStructProcessor`…
|
| /thrift-3.4.0/lib/perl/ |
| D | README.md | 17 "License"); you may not use this file except in compliance
22 Unless required by applicable law or agreed to in writing,
37 Unexpected exceptions in a service handler are converted to
48 one cannot use a custom SIGCHLD handler in the consuming perl
88 The socket classes were refactored in 0.10.0 so that there is one package per
107 in your files with this technique to create an alias, which will allow you code to
112 * Packages found in Thrift.pm were moved into the Thrift/ directory in separate files:
113 ** Thrift::TApplicationException is now in Thrift/Exception.pm
114 ** Thrift::TException is now in Thrift/Exception.pm
115 ** Thrift::TMessageType is now in Thrift/MessageType.pm
[all …]
|
