| /thrift-3.4.0/lib/java/gradle/ |
| D | generateTestThrift.gradle | 72 compileTestJava.dependsOn it
77 generate.dependsOn it
81 thriftCompile(it, 'ThriftTest.thrift')
82 thriftCompile(it, 'JavaTypes.thrift')
83 thriftCompile(it, 'DebugProtoTest.thrift')
84 thriftCompile(it, 'DoubleConstantsTest.thrift')
85 thriftCompile(it, 'OptionalRequiredTest.thrift')
86 thriftCompile(it, 'ManyOptionals.thrift')
87 thriftCompile(it, 'JavaDeepCopyTest.thrift')
88 thriftCompile(it, 'EnumContainersTest.thrift')
[all …]
|
| /thrift-3.4.0/contrib/fb303/cpp/ |
| D | FacebookBase.cpp | 52 // if we didn't find the key, we need to write lock the whole map to create it in incrementCounter()
53 ReadWriteCounterMap::iterator it = counters_.find(key); in incrementCounter() local
54 if (it == counters_.end()) { in incrementCounter()
58 it = counters_.find(key); in incrementCounter()
59 if(it == counters_.end()){ in incrementCounter()
66 it->second.lock(); in incrementCounter()
67 int64_t count = it->second.value + amount; in incrementCounter()
68 it->second.value = count; in incrementCounter()
69 it->second.unlock(); in incrementCounter()
77 // if we didn't find the key, we need to write lock the whole map to create it in setCounter()
[all …]
|
| /thrift-3.4.0/lib/rb/spec/ |
| D | json_protocol_spec.rb | 31 it "should write json escaped char" do
39 it "should write json char" do
53 it "should write json string" do
58 it "should write json base64" do
63 it "should write json integer" do
77 it "should write json double" do
94 it "should write json object start" do
99 it "should write json object end" do
104 it "should write json array start" do
109 it "should write json array end" do
[all …]
|
| D | binary_protocol_spec_shared.rb | 29 it "should define the proper VERSION_1, VERSION_MASK AND TYPE_MASK" do
35 it "should make strict_read readable" do
39 it "should make strict_write readable" do
43 it "should write the message header" do
48 it "should write the message header without version when writes are not strict" do
54 it "should write the message header with a version when writes are strict" do
63 it "should write the field header" do
70 it "should write the STOP field" do
75 it "should write the map header" do
82 it "should write the list header" do
[all …]
|
| D | base_transport_spec.rb | 25 it "should make type accessible" do
33 it "should read the specified size" do
41 it "should stub out the rest of the methods" do
48 it "should alias << to write" do
52 it "should provide a reasonable to_s" do
58 it "should stub out its methods" do
66 it "should return the transport it's given" do
71 it "should provide a reasonable to_s" do
77 it "should provide a to_s that describes the encapsulation" do
83 it "should pass through everything but write/flush/read" do
[all …]
|
| D | union_spec.rb | 25 it "should return nil value in unset union" do
31 it "should set a field and be accessible through get_value and the named field accessor" do
39 it "should work correctly when instantiated with static field constructors" do
45 it "should raise for wrong set field" do
51 it "should raise for wrong set field when hash initialized and type checking is off" do
57 it "should not be equal to nil" do
62 it "should not be equal with an empty String" do
67 it "should not equate two different unions, i32 vs. string" do
73 it "should properly reset setfield and setvalue" do
82 it "should not equate two different unions with different values" do
[all …]
|
| D | socket_spec_shared.rb | 23 it "should open a socket" do
27 it "should be open whenever it has a handle" do
38 it "should write data to the handle" do
46 it "should raise an error when it cannot read from the handle" do
52 it "should return the data read when reading from the handle works" do
58 it "should declare itself as closed when it has an error" do
66 it "should raise an error when the stream is closed" do
74 it "should support the timeout accessor for read" do
82 it "should support the timeout accessor for write" do
91 it "should raise an error when read times out" do
[all …]
|
| D | bytes_spec.rb | 26 it 'should create an empty buffer' do
32 it 'should create an empty buffer of given size' do
42 it 'should change encoding' do
51 it 'should get the byte at index' do
59 it 'should set byte value at index' do
68 it 'should convert UTF-8 String to byte buffer' do
78 it 'should convert ISO-8859-15 String to UTF-8 byte buffer' do
92 it 'should convert UTF-8 byte buffer to a UTF-8 String' do
103 it 'should create an empty buffer' do
108 it 'should create an empty buffer of given size' do
[all …]
|
| D | thin_http_server_spec.rb | 32 it "binds to port 80, with host 0.0.0.0, a path of '/'" do
37 it 'creates a ThinHTTPServer::RackApplicationContext' do
42 it "uses the BinaryProtocolFactory" do
51 it 'accepts :ip, :port, :path' do
62 it 'creates a ThinHTTPServer::RackApplicationContext with a different protocol factory' do
74 it 'starts the Thin server' do
99 it 'receives a non-POST' do
105 it 'receives a header other than application/x-thrift' do
120 it 'creates an IOStreamTransport' do
126 it 'fetches the right protocol based on the Transport' do
[all …]
|
| D | unix_socket_spec.rb | 36 it "should raise a TransportException when it cannot open a socket" do
41 it "should accept an optional timeout" do
46 it "should provide a reasonable to_s" do
58 it "should create a handle when calling listen" do
63 it "should create a Thrift::UNIXSocket to wrap accepted sockets" do
75 it "should close the handle when closed" do
84 it "should delete the socket when closed" do
93 it "should return nil when accepting if there is no handle" do
97 it "should return true for closed? when appropriate" do
112 it "should provide a reasonable to_s" do
|
| D | namespaced_spec.rb | 27 it "generated the right files" do
39 it "did not generate the wrong files" do
51 it "has a service class in the right place" do
55 it "has a struct in the right place" do
59 it "required an included file" do
63 it "extended a service" do
|
| D | server_socket_spec.rb | 30 it "should create a handle when calling listen" do
35 it "should accept an optional host argument" do
42 it "should create a Thrift::Socket to wrap accepted sockets" do
54 it "should close the handle when closed" do
62 it "should return nil when accepting if there is no handle" do
66 it "should return true for closed? when appropriate" do
80 it "should provide a reasonable to_s" do
|
| D | struct_nested_containers_spec.rb | 35 it "should support nested lists inside lists" do
48 it "should support nested lists inside sets" do
61 it "should support nested lists in map keys" do
74 it "should support nested lists in map values" do
87 it "should support nested sets inside lists" do
100 it "should support nested sets inside sets" do
113 it "should support nested sets in map keys" do
126 it "should support nested sets in map values" do
139 it "should support nested maps inside lists" do
152 it "should support nested maps inside sets" do
[all …]
|
| /thrift-3.4.0/compiler/cpp/src/thrift/generate/ |
| D | validator_parser.cc | 24 * The output of astyle should not be taken unquestioningly, but it is a good
171 for (auto it = annotations.begin(); it != annotations.end(); it++) { in parse_list_field() local
172 if (it->first.compare(0, elem_prefix.size(), elem_prefix) == 0) { in parse_list_field()
173 std::string elem_key = "vt" + it->first.substr(elem_prefix.size()); in parse_list_field()
174 elem_annotations[elem_key] = it->second; in parse_list_field()
183 for (auto it = elem_rules.begin(); it != elem_rules.end(); it++) { in parse_list_field() local
184 validation_rule* rule = new validation_rule(elem_prefix, *it); in parse_list_field()
198 for (auto it = annotations.begin(); it != annotations.end(); it++) { in parse_map_field() local
199 if (it->first.compare(0, key_prefix.size(), key_prefix) == 0) { in parse_map_field()
200 std::string key_key = "vt" + it->first.substr(key_prefix.size()); in parse_map_field()
[all …]
|
| D | go_validator_generator.cc | 24 * The output of astyle should not be taken unquestioningly, but it is a good
62 for (auto it = members.begin(); it != members.end(); it++) { in generate_struct_validator() local
63 t_field* field(*it); in generate_struct_validator()
139 for (auto it = context.rules.begin(); it != context.rules.end(); it++) { in generate_enum_field_validator() local
140 const std::vector<validation_value*>& values = (*it)->get_values(); in generate_enum_field_validator()
144 std::string key = (*it)->get_name(); in generate_enum_field_validator()
153 for (auto it = values.begin(); it != values.end(); it++) { in generate_enum_field_validator() local
154 if (it != values.begin()) { in generate_enum_field_validator()
158 if ((*it)->is_field_reference()) { in generate_enum_field_validator()
159 out << get_field_reference_name((*it)->get_field_reference()); in generate_enum_field_validator()
[all …]
|
| D | t_generator.cc | 80 …// Nothing by default. It makes no sense to restrict the whole world to use non-PHP keywords only. in lang_keywords_for_validation()
81 …// Override on a per-generator(!) basis if you cannot live without it, e.g. that particular langua… in lang_keywords_for_validation()
82 …// mechanism or way to deal with it properly, so we absolutely need to fail on it as the last poss… in lang_keywords_for_validation()
96 typename vector<T>::const_iterator it; in validate() local
97 for(it=list.begin(); it != list.end(); ++it) { in validate()
98 validate(*it); in validate()
137 // What the message really means is "we did not get it done yet" in validate_id()
144 for (string::const_iterator it = in.begin(); it < in.end(); it++) { in escape_string() local
145 std::map<char, std::string>::const_iterator res = escape_.find(*it); in escape_string()
149 result.push_back(*it); in escape_string()
|
| /thrift-3.4.0/compiler/cpp/src/thrift/parse/ |
| D | t_program.h | 128 // Ensure that it ends with a trailing '/' (or '\' for windows machines) in set_out_path()
143 for (auto it = includes_.cbegin(); it != includes_.cend(); ++it) { in is_unique_typename() local
144 occurrences += program_typename_count(*it, t); in is_unique_typename()
174 for (auto it = type_collection.cbegin(); it != type_collection.cend(); ++it) in collection_typename_count() local
175 if (t != *it && 0 == t->get_name().compare((*it)->get_name()) && is_common_namespace(prog, t)) in collection_typename_count()
204 for (auto it = prog->namespaces_.cbegin(); in is_common_namespace() local
205 it != prog->namespaces_.cend(); in is_common_namespace()
206 ++it) { in is_common_namespace()
207 if (0 == it->second.compare(t->get_program()->get_namespace(it->first))) { in is_common_namespace()
212 it->first.c_str(), in is_common_namespace()
[all …]
|
| /thrift-3.4.0/doc/licenses/ |
| D | lgpl-2.1.txt | 7 of this license document, but changing it is not allowed.
9 [This is the first released version of the Lesser GPL. It also counts
16 freedom to share and change it. By contrast, the GNU General Public
22 Free Software Foundation and other authors who decide to use it. You
23 can use it too, but we suggest you first think carefully about whether
31 it if you want it; that you can change the software and use pieces of
32 it in new free programs; and that you are informed that you can do
38 you if you distribute copies of the library or if you modify it.
46 it. And you must show them these terms so they know their rights.
52 To protect each distributor, we want to make it very clear that
[all …]
|
| /thrift-3.4.0/lib/go/thrift/ |
| D | socket_conn.go | 52 // return it as-is and avoid double wrapping.
64 // It's nil safe, and returns false if sc itself is nil, or if the underlying
67 // It's the same as the previous implementation of TSocket.IsOpen and
75 // It's nil safe, and returns false if sc itself is nil, or if the underlying
78 // Otherwise, it tries to do a connectivity check and returns the result.
80 // It also has the side effect of resetting the previously set read deadline on
81 // the socket. As a result, it shouldn't be called between setting read deadline
102 // On Windows, it behaves the same as the underlying net.Conn.Read.
104 // On non-Windows, it treats len(p) == 0 as a connectivity check instead of
107 // go's stdlib implementation on non-Windows), it never blocks, and will return
|
| /thrift-3.4.0/contrib/zeromq/ |
| D | README.md | 12 implementation makes it the client's responsibility to ensure that ZMQ_REQ
15 have to expose two servers (on two ports), but the TZmqMultiServer makes it
25 retrieve the stored value or with an integer argument to increment it by
28 This code is not quite what I would consider production-ready. It doesn't
30 sub-optimal because it does some unnecessary copying.
35 unless someone converts it to netstd
|
| /thrift-3.4.0/doc/specs/ |
| D | thrift-tconfiguration.md | 37 … transport stack should accept null TConfiguration argument, in which case it should fallback to a…
59 The difference between the two options is, that MaxFrameSize exists much longer and it is used only…
61 In order to combine both approaches in the most optimal way when using TFramedTransport, it is reco…
63 For calculation purposes it is important to know, that MaxFrameSize excludes the 4 bytes that hold …
67 If any limit is exceeded, an error should be thrown. Additionally, it may be helpful to check large…
75 1. If done right, it should not be a breaking change vis-á-vis compiling your source code that uses…
77 …It may, however, be a breaking change in the way it limits the accepted overall size of messages o…
81 No, it's not. However, it turned out that this split is a great help when it comes to managing the …
|
| /thrift-3.4.0/lib/java/src/test/java/org/apache/thrift/partial/ |
| D | ValidateTest.java | 40 // Verify it throws. in testCheckNotNull()
56 // Verify it throws. in testCheckPositiveInteger()
77 // Verify it throws. in testCheckNotNegative()
89 // Verify it throws. in testCheckRequired()
101 // Verify it throws. in testCheckValid()
115 // Verify it throws. in testCheckValidWithValues()
131 // Verify it throws. in testCheckNotNullAndNotEmpty()
193 // Verify it throws. in testCheckListNotNullAndNotEmpty()
210 // Verify it throws. in testCheckNotNullAndNumberOfElements()
216 // Verify it throws. in testCheckNotNullAndNumberOfElements()
[all …]
|
| /thrift-3.4.0/lib/cpp/test/processor/ |
| D | EventLog.cpp | 113 auto it = events_.begin(); in waitForConnEvent() local
116 // TODO: it would be nicer to honor timeout for the duration of this in waitForConnEvent()
117 // call, rather than restarting it for each call to wait(). It shouldn't in waitForConnEvent()
119 while (it == events_.end()) { in waitForConnEvent()
126 if (it->connectionId == connId) { in waitForConnEvent()
127 Event event = *it; in waitForConnEvent()
128 events_.erase(it); in waitForConnEvent()
|
| /thrift-3.4.0/build/docker/ |
| D | refresh.sh | 37 # image may not exist yet, so we have to let it fail silently:
44 # If this build has no DOCKER_PASS and it is in the docker stage
66 # Dockerfile has changed - rebuild it for the current build job.
67 # If it is a "docker" stage build then we want to push it back
68 # to the DOCKER_REPO. If it is a "test" stage build then we do
69 # not. If nobody defined a DOCKER_PASS then it doesn't matter.
|
| /thrift-3.4.0/lib/cpp/src/thrift/ |
| D | VirtualProfiling.cpp | 256 BacktraceMap::iterator it = map->find(*k); in _record_backtrace() local
257 if (it == map->end()) { in _record_backtrace()
262 // NOTE: we could assert if it->second is 0 afterwards, since that would in _record_backtrace()
264 ++(it->second); in _record_backtrace()
309 // We print the generic_calls info ahead of virtual_calls, since it is more in profile_print_info()
316 for (BacktraceVector::const_iterator it = gp_sorted.begin(); it != gp_sorted.end(); ++it) { in profile_print_info() local
317 Key const& key = it->first; in profile_print_info()
318 size_t const count = it->second; in profile_print_info()
332 for (BacktraceVector::const_iterator it = vc_sorted.begin(); it != vc_sorted.end(); ++it) { in profile_print_info() local
333 Key const& key = it->first; in profile_print_info()
[all …]
|
