Home
last modified time | relevance | path

Searched refs:args (Results 1 – 25 of 172) sorted by relevance

1234567

/thrift-3.4.0/lib/php/test/Protocol/
DTJSONProtocolTest.php69 $args = new \ThriftTest\ThriftTest_testVoid_args();
70 $args->write($this->protocol);
80 $args = new \ThriftTest\ThriftTest_testString_args();
81 $args->thing = Fixtures::$testArgs['testString1'];
82 $args->write($this->protocol);
92 $args = new \ThriftTest\ThriftTest_testString_args();
93 $args->thing = Fixtures::$testArgs['testString2'];
94 $args->write($this->protocol);
104 $args = new \ThriftTest\ThriftTest_testDouble_args();
105 $args->thing = Fixtures::$testArgs['testDouble'];
[all …]
DTSimpleJSONProtocolTest.php70 $args = new \ThriftTest\ThriftTest_testVoid_args();
71 $args->write($this->protocol);
81 $args = new \ThriftTest\ThriftTest_testString_args();
82 $args->thing = Fixtures::$testArgs['testString1'];
83 $args->write($this->protocol);
93 $args = new \ThriftTest\ThriftTest_testString_args();
94 $args->thing = Fixtures::$testArgs['testString2'];
95 $args->write($this->protocol);
105 $args = new \ThriftTest\ThriftTest_testDouble_args();
106 $args->thing = Fixtures::$testArgs['testDouble'];
[all …]
/thrift-3.4.0/compiler/cpp/src/thrift/
Dlogging.cc34 va_list args; in pdebug() local
36 va_start(args, fmt); in pdebug()
37 vprintf(fmt, args); in pdebug()
38 va_end(args); in pdebug()
46 va_list args; in pverbose() local
47 va_start(args, fmt); in pverbose()
48 vprintf(fmt, args); in pverbose()
49 va_end(args); in pverbose()
56 va_list args; in pwarning() local
58 va_start(args, fmt); in pwarning()
[all …]
/thrift-3.4.0/lib/perl/lib/Thrift/
DServer.pm48 my @args = @_;
52 if (scalar @args == 2)
54 $self = _init($args[0], $args[1],
60 elsif (scalar @args == 4)
62 $self = _init($args[0], $args[1], $args[2], $args[2], $args[3], $args[3]);
64 elsif (scalar @args == 6)
66 $self = _init($args[0], $args[1], $args[2], $args[3], $args[4], $args[5]);
195 my @args = @_;
197 my $self = $classname->SUPER::new(@args);
/thrift-3.4.0/test/features/
Dtheader_binary.py41 args = p.parse_args()
42 assert args.protocol == 'header'
43 assert args.transport == 'buffered'
44 assert not args.ssl
46 sock = TSocket(args.host, args.port, socket_family=socket.AF_INET)
47 if not args.override_transport or args.override_transport == 'buffered':
49 elif args.override_transport == 'framed':
56 if not args.override_protocol or args.override_protocol == 'binary':
58 elif args.override_protocol == 'compact':
Dstring_limit.py44 args = p.parse_args()
45 proto = init_protocol(args)
46 test_string(proto, 'a' * (args.limit - 1))
47 test_string(proto, 'a' * (args.limit - 1))
49 test_string(proto, 'a' * args.limit)
50 test_string(proto, 'a' * args.limit)
53 test_string(proto, 'a' * (args.limit + 1))
Dcontainer_limit.py53 args = p.parse_args()
54 proto = init_protocol(args)
56 test_list(proto, list(range(args.limit - 1)))
57 test_list(proto, list(range(args.limit - 1)))
59 test_list(proto, list(range(args.limit)))
60 test_list(proto, list(range(args.limit)))
63 test_list(proto, list(range(args.limit + 1)))
Dutil.py27 def init_protocol(args): argument
28 sock = TSocket(args.host, args.port, socket_family=socket.AF_INET)
34 }[args.transport](sock)
40 }[args.protocol](trans)
/thrift-3.4.0/lib/py/src/server/
DTServer.py42 def __init__(self, *args): argument
43 if (len(args) == 2):
44 self.__initArgs__(args[0], args[1],
49 elif (len(args) == 4):
50 self.__initArgs__(args[0], args[1], args[2], args[2], args[3], args[3])
51 elif (len(args) == 6):
52 self.__initArgs__(args[0], args[1], args[2], args[3], args[4], args[5])
77 def __init__(self, *args): argument
78 TServer.__init__(self, *args)
116 def __init__(self, *args, **kwargs): argument
[all …]
/thrift-3.4.0/tutorial/netstd/Client/
DProgram.cs100 public static void Main(string[] args) in Main() argument
102 args ??= Array.Empty<string>(); in Main()
104 if (args.Any(x => x.StartsWith("-help", StringComparison.OrdinalIgnoreCase))) in Main()
114 RunAsync(args, source.Token).GetAwaiter().GetResult(); in Main()
119 private static async Task RunAsync(string[] args, CancellationToken cancellationToken) in RunAsync() argument
121 var numClients = GetNumberOfClients(args); in RunAsync()
125 var transport = GetTransport(args); in RunAsync()
128 var protocol = MakeProtocol( args, MakeTransport(args)); in RunAsync()
129 … Logger.LogInformation("Selected client protocol: {GetProtocol(args)}", GetProtocol(args)); in RunAsync()
131 var mplex = GetMultiplex(args); in RunAsync()
[all …]
/thrift-3.4.0/lib/py/src/ext/
Dmodule.cpp49 static PyObject* encode_impl(PyObject* args) { in encode_impl() argument
50 if (!args) in encode_impl()
55 if (!PyArg_ParseTuple(args, "OO", &enc_obj, &type_args)) { in encode_impl()
81 static PyObject* decode_impl(PyObject* args) { in decode_impl() argument
85 if (!PyArg_ParseTuple(args, "OOO", &output_obj, &oprot, &typeargs)) { in decode_impl()
123 static PyObject* encode_binary(PyObject*, PyObject* args) { in encode_binary() argument
124 return encode_impl<BinaryProtocol>(args); in encode_binary()
127 static PyObject* decode_binary(PyObject*, PyObject* args) { in decode_binary() argument
128 return decode_impl<BinaryProtocol>(args); in decode_binary()
131 static PyObject* encode_compact(PyObject*, PyObject* args) { in encode_compact() argument
[all …]
/thrift-3.4.0/lib/delphi/test/multiplexed/
DMultiplex.Client.Main.pas48 procedure ParseArgs( const args: array of string);
52 constructor Create( const args: array of string);
53 class procedure Execute( const args: array of string);
68 class procedure TTestClient.Execute( const args: array of string);
71 client := TTestClient.Create(args);
80 constructor TTestClient.Create( const args: array of string);
83 ParseArgs(args);
88 procedure TTestClient.ParseArgs( const args: array of string);
90 if Length(args) <> 0
/thrift-3.4.0/lib/js/test/
Ddeep-constructor.test.js174 const args = createJsObj();
175 assertValues(args, assert);
177 const tObj = new Complex(args);
180 args.struct_field.value = 'ZZZ';
181 args.struct_list_field[0].value = 'ZZZ';
182 args.struct_list_field[1].value = 'ZZZ';
183 args.struct_set_field[0].value = 'ZZZ';
184 args.struct_set_field[1].value = 'ZZZ';
185 args.struct_map_field.A.value = 'ZZZ';
186 args.struct_map_field.B.value = 'ZZZ';
[all …]
/thrift-3.4.0/lib/rb/lib/thrift/protocol/
Dbase_protocol.rb225 def write_field(*args) argument
226 if args.size == 3
228 field_info = args[0]
229 fid = args[1]
230 value = args[2]
231 elsif args.size == 4
233 field_info = {:name => args[0], :type => args[1]}
234 fid = args[2]
235 value = args[3]
237 raise ArgumentError, "wrong number of arguments (#{args.size} for 3)"
/thrift-3.4.0/lib/js/
DGruntfile.js128 args: ['--no-sandbox'],
139 args: ['--no-sandbox'],
150 args: ['--no-sandbox'],
162 args: ['--no-sandbox'],
174 args: ['--no-sandbox'],
185 args: ['--no-sandbox'],
197 args: ['--no-sandbox'],
209 args: ['--no-sandbox'],
221 args: ['--no-sandbox'],
232 args: ['--no-sandbox'],
/thrift-3.4.0/lib/java/src/main/java/org/apache/thrift/server/
DTHsHaServer.java117 private final Args args; field in THsHaServer
120 public THsHaServer(Args args) { in THsHaServer() argument
121 super(args); in THsHaServer()
123 invoker = args.executorService == null ? createInvokerPool(args) : args.executorService; in THsHaServer()
124 this.args = args; in THsHaServer()
161 long timeoutMS = args.stopTimeoutUnit.toMillis(args.stopTimeoutVal); in gracefullyShutdownInvokerPool()
/thrift-3.4.0/lib/rb/benchmark/
Dbenchmark.rb47 args = (File.basename(@interpreter) == "jruby" ? "-J-server" : "")
48 …@pipe = IO.popen("#{@interpreter} #{args} #{File.dirname(__FILE__)}/server.rb #{@host} #{@port} #{…
253 args = {}
254 args[:interpreter] = ENV['THRIFT_SERVER_INTERPRETER'] || ENV['THRIFT_INTERPRETER'] || "ruby"
255 args[:class] = resolve_const(ENV['THRIFT_SERVER']) || Thrift::NonblockingServer
256 args[:host] = ENV['THRIFT_HOST'] || HOST
257 args[:port] = (ENV['THRIFT_PORT'] || PORT).to_i
258 server = Server.new(args)
261 args = {}
262 args[:host] = ENV['THRIFT_HOST'] || HOST
[all …]
/thrift-3.4.0/lib/py/src/transport/
DTSSLSocket.py86 def _deprecated_arg(self, args, kwargs, pos, key): argument
87 if len(args) <= pos:
99 kwargs[key] = args[pos]
101 def _unix_socket_arg(self, host, port, args, kwargs): argument
103 if host is None and port is None and len(args) == 1 and key not in kwargs:
104 kwargs[key] = args[0]
218 def __init__(self, host='localhost', port=9090, *args, **kwargs): argument
240 if args:
241 if len(args) > 6:
243 if not self._unix_socket_arg(host, port, args, kwargs):
[all …]
/thrift-3.4.0/test/netstd/Server/
DTestServer.cs80 internal void Parse(List<string> args) in Parse() argument
82 for (var i = 0; i < args.Count; i++) in Parse()
84 if (args[i].StartsWith("--pipe=")) in Parse()
86 pipe = args[i].Substring(args[i].IndexOf("=") + 1); in Parse()
89 else if (args[i].StartsWith("--port=")) in Parse()
91 port = int.Parse(args[i].Substring(args[i].IndexOf("=") + 1)); in Parse()
95 … else if (args[i] == "-b" || args[i] == "--buffered" || args[i] == "--transport=buffered") in Parse()
99 … else if (args[i] == "-f" || args[i] == "--framed" || args[i] == "--transport=framed") in Parse()
103 else if (args[i] == "--binary" || args[i] == "--protocol=binary") in Parse()
107 else if (args[i] == "--compact" || args[i] == "--protocol=compact") in Parse()
[all …]
/thrift-3.4.0/lib/rb/lib/thrift/
Dclient.rb28 def send_message(name, args_class, args = {}) argument
30 send_message_args(args_class, args)
33 def send_oneway_message(name, args_class, args = {}) argument
35 send_message_args(args_class, args)
38 def send_message_args(args_class, args) argument
40 args.each do |k, v|
/thrift-3.4.0/lib/java/src/crossTest/java/org/apache/thrift/test/
DTestServer.java141 public static void main(String[] args) { in main() argument
153 for (int i = 0; i < args.length; i++) { in main()
154 if (args[i].startsWith("--port")) { in main()
155 port = Integer.valueOf(args[i].split("=")[1]); in main()
156 } else if (args[i].startsWith("--server-type")) { in main()
157 server_type = args[i].split("=")[1]; in main()
159 } else if (args[i].startsWith("--port")) { in main()
160 port = Integer.parseInt(args[i].split("=")[1]); in main()
161 } else if (args[i].startsWith("--protocol")) { in main()
162 protocol_type = args[i].split("=")[1]; in main()
[all …]
/thrift-3.4.0/tutorial/dart/console_client/bin/
Dmain.dart21 import 'package:args/args.dart';
38 main(List<String> args) {
49 results = parser.parse(args);
82 var args = parts.length > 1 ? parts.sublist(1) : [];
90 await _add(int.parse(args[0]), int.parse(args[1]));
94 int op = operationLookup[args[1]];
96 stdout.writeln('Unknown operator ${args[1]}');
101 ..num1 = int.parse(args[0])
103 ..num2 = int.parse(args[2])
104 ..comment = args.length > 3 ? args[3] : '';
[all …]
/thrift-3.4.0/lib/java/src/main/java/org/apache/thrift/
DTServiceClient.java63 protected void sendBase(String methodName, TBase<?, ?> args) throws TException { in sendBase() argument
64 sendBase(methodName, args, TMessageType.CALL); in sendBase()
67 protected void sendBaseOneway(String methodName, TBase<?, ?> args) throws TException { in sendBaseOneway() argument
68 sendBase(methodName, args, TMessageType.ONEWAY); in sendBaseOneway()
71 private void sendBase(String methodName, TBase<?, ?> args, byte type) throws TException { in sendBase() argument
73 args.write(oprot_); in sendBase()
/thrift-3.4.0/lib/java/src/main/java/org/apache/thrift/transport/
DTServerSocket.java79 public TServerSocket(ServerSocketTransportArgs args) throws TTransportException { in TServerSocket() argument
80 clientTimeout_ = args.clientTimeout; in TServerSocket()
81 if (args.serverSocket != null) { in TServerSocket()
82 this.serverSocket_ = args.serverSocket; in TServerSocket()
91 serverSocket_.bind(args.bindAddr, args.backlog); in TServerSocket()
95 "Could not create ServerSocket on address " + args.bindAddr.toString() + ".", ioe); in TServerSocket()
/thrift-3.4.0/test/cpp/src/
DStressTest.cpp301 map<string, string> args; in main() local
314 args[key] = string(arg, end + 1); in main()
316 args[key] = "true"; in main()
325 if (!args["clients"].empty()) { in main()
326 clientCount = atoi(args["clients"].c_str()); in main()
329 if (!args["help"].empty()) { in main()
334 if (!args["loop"].empty()) { in main()
335 loopCount = atoi(args["loop"].c_str()); in main()
338 if (!args["call"].empty()) { in main()
339 callName = args["call"]; in main()
[all …]

1234567