| /thrift-3.4.0/lib/rs/test_recursive/src/ |
| D | lib.rs | 47 if let Some(route_number) = route.id { in handle_add_streetcar()
50 id: Some(4417), in handle_add_streetcar()
51 stock: Some(RollingStock::Flexity(Flexity { in handle_add_streetcar()
52 materials: Some(vec![Material::STEEL, Material::ALUMINUM]), in handle_add_streetcar()
53 locomotive: Some(Locomotive::ELECTRIC_PANTOGRAPH), in handle_add_streetcar()
55 route: Some(Route { in handle_add_streetcar()
56 id: Some(RouteNumber::LAKESHORE), in handle_add_streetcar()
73 if let Some(rolling_stock) = streetcar.stock { in handle_upgrade_streetcar()
76 stock: Some(RollingStock::Flexity(Flexity { in handle_upgrade_streetcar()
77 materials: Some(vec![Material::STEEL, Material::ALUMINUM]), in handle_upgrade_streetcar()
[all …]
|
| /thrift-3.4.0/test/rs/src/bin/ |
| D | test_client.rs | 95 Some(domain_socket) => { in run()
125 Some(SecondServiceSyncClient::new(i_prot, o_prot)) in bind()
153 Some(SecondServiceSyncClient::new(i_prot, o_prot)) in bind_uds()
282 string_thing: Some("foo".to_owned()), in make_thrift_calls()
283 byte_thing: Some(12), in make_thrift_calls()
284 i32_thing: Some(219_129), in make_thrift_calls()
285 i64_thing: Some(12_938_492_818), in make_thrift_calls()
288 string_thing: Some("foo".to_owned()), in make_thrift_calls()
289 byte_thing: Some(12), in make_thrift_calls()
290 i32_thing: Some(219_129), in make_thrift_calls()
[all …]
|
| D | test_server.rs | 78 Some(domain_socket) => info!("Server is binding to {} (UDS)", domain_socket), in run()
142 Some(domain_socket) => server.listen_uds(domain_socket), in run()
156 Some(domain_socket) => server.listen_uds(domain_socket), in run()
316 string_thing: Some("Hello2".to_owned()), in handle_test_multi()
317 byte_thing: Some(arg0), in handle_test_multi()
318 i32_thing: Some(arg1), in handle_test_multi()
319 i64_thing: Some(arg2), in handle_test_multi()
334 error_code: Some(1001), in handle_test_exception()
335 message: Some(arg), in handle_test_exception()
354 error_code: Some(1001), in handle_test_multi_exception()
[all …]
|
| /thrift-3.4.0/lib/rs/test/src/bin/ |
| D | kitchen_sink_client.rs | 79 Some(domain_socket) => { in run()
184 children: Some(vec![Box::new(RecTree { in exec_recursive_client()
185 children: Some(vec![ in exec_recursive_client()
188 item: Some(3), in exec_recursive_client()
192 item: Some(4), in exec_recursive_client()
195 item: Some(2), in exec_recursive_client()
197 item: Some(1), in exec_recursive_client()
201 children: Some(vec![Box::new(RecTree { in exec_recursive_client()
202 children: Some(vec![ in exec_recursive_client()
204 children: Some(Vec::new()), // remote returns an empty list in exec_recursive_client()
[all …]
|
| D | kitchen_sink_server.rs | 84 Some(domain_socket) => { in run()
|
| /thrift-3.4.0/lib/java/src/main/java/org/apache/thrift/ |
| D | Option.java | 93 public static class Some<T> extends Option<T> { class in Option
96 public Some(T value) { in Some() method in Option.Some
135 public static <T> Some<T> some(T value) { in some()
136 return new Some<T>(value); in some()
|
| /thrift-3.4.0/tutorial/rs/src/bin/ |
| D | tutorial_server.rs | 123 let res = if let Some(ref op) = w.op { in handle_calculate()
126 what_op: Some(op.into()), in handle_calculate()
127 why: Some("no operands specified".to_owned()), in handle_calculate()
141 what_op: Some(op.into()), in handle_calculate()
142 why: Some("divide by 0".to_owned()), in handle_calculate()
151 what_op: Some(op_val), in handle_calculate()
152 why: Some(format!("unsupported operation type '{}'", op_val)), in handle_calculate()
|
| /thrift-3.4.0/lib/rs/src/transport/ |
| D | socket.rs | 83 stream: Some(stream), in with_stream()
97 self.stream = Some(s); in open()
118 if let Some(ref mut s) = self.stream { in if_set()
144 stream: Some(cloned), in split()
|
| /thrift-3.4.0/lib/rs/test/src/ |
| D | lib.rs | 33 let _ = midlayer::Meal::new(Some(base_one::Noodle::default()), None); in must_be_able_to_use_constructor()
49 noodle: Some(base_one::Noodle::default()), in must_be_able_to_use_defaults()
|
| /thrift-3.4.0/lib/ocaml/src/ |
| D | TSocket.ml | 32 chans <- Some(Unix.open_connection (Unix.ADDR_INET (addr,port)))
40 | Some(inc,out) -> (Unix.shutdown_connection inc;
45 | Some(i,o) ->
53 | Some(i,o) -> output o buf off len
56 | Some(i,o) -> flush o
|
| D | TServerSocket.ml | 28 sock <- Some s;
33 Some s -> Unix.shutdown s Unix.SHUTDOWN_ALL; Unix.close s;
38 Some s -> let (fd,_) = Unix.accept s in
|
| D | TFramedTransport.ml | 59 read_buf <- Some buf;
70 | Some frame ->
|
| /thrift-3.4.0/lib/rs/src/server/ |
| D | multiplexed.rs | 91 stored.default_processor = Some(processor.clone()); in register()
116 if let Some(name) = svc_name { in process_message()
124 Some(arc) => { in process_message()
171 (Some(svc_name), svc_call) in split_ident_name()
178 Some(name) => format!("no processor found for service {}", name), in missing_processor_message()
201 assert_eq!(serv, Some("foo")); in should_split_name_into_proper_separator_and_service_call()
258 missing_processor_message(Some("missing")), in should_write_error_if_separator_exists_and_no_processor_found()
|
| /thrift-3.4.0/debian/ |
| D | README.md | 1 ## Some tips on Debian Packaging
|
| /thrift-3.4.0/lib/java/src/test/java/org/apache/thrift/ |
| D | TestOptionType.java | 36 assertTrue(option instanceof Option.Some); in testSome()
|
| /thrift-3.4.0/lib/haxe/src/org/apache/thrift/ |
| D | TBase.hx | 23 // Some Linux platforms have waaaay too old packages in their repos
|
| /thrift-3.4.0/test/ocaml/client/ |
| D | TestClient.ml | 27 Some v -> v
|
| /thrift-3.4.0/tutorial/ocaml/ |
| D | CalcClient.ml | 27 Some v -> v
|
| D | CalcServer.ml | 27 Some v -> v
|
| /thrift-3.4.0/lib/rs/src/protocol/ |
| D | binary.rs | 340 if let Some(id) = identifier.id { in write_field_begin()
695 id: Some(20), in must_round_trip_field_begin()
722 id: Some(0), in must_round_trip_field_stop()
|
| D | compact.rs | 169 self.pending_read_bool_value = Some(true); in read_field_begin()
173 self.pending_read_bool_value = Some(false); in read_field_begin()
197 id: Some(self.last_read_field_id), in read_field_begin()
209 Some(b) => Ok(b), in read_bool()
415 if let Some(ref f) = self.pending_write_bool_field_identifier { in assert_no_pending_bool_write()
465 self.pending_write_bool_field_identifier = Some(identifier.clone()); in write_field_begin()
488 Some(pending) => { in write_bool()
|
| /thrift-3.4.0/ |
| D | CMakeLists.txt | 40 # Some default settings
|
| D | sonar-project.properties | 28 # Some properties that will be inherited by the modules
|
| /thrift-3.4.0/test/ocaml/server/ |
| D | TestServer.ml | 26 Some v -> v
|
| /thrift-3.4.0/test/ |
| D | DocTest.thrift | 34 /** Some doc text goes here. Wow I am [nesting these] (no more nesting.) */
|
