Home
last modified time | relevance | path

Searched refs:var (Results 1 – 25 of 112) sorted by relevance

12345

/thrift-3.4.0/lib/php/src/
DThrift.php79 $var = $fspec['var'];
80 if (isset($vals[$var])) {
81 $this->$var = $vals[$var];
97 private function _readMap(&$var, $spec, $input) argument
113 $var = array();
158 $var[$key] = $val;
165 private function _readList(&$var, $spec, $input, $set=false) argument
175 $var = array();
206 $var[$elem] = true;
208 $var []= $elem;
[all …]
/thrift-3.4.0/lib/php/lib/Base/
DTBase.php54 $var = $fspec['var'];
55 if (isset($vals[$var])) {
56 $this->$var = $vals[$var];
67 private function _readMap(&$var, $spec, $input) argument
83 $var = array();
128 $var[$key] = $val;
135 private function _readList(&$var, $spec, $input, $set = false) argument
145 $var = array();
176 $var[$elem] = true;
178 $var [] = $elem;
[all …]
/thrift-3.4.0/lib/php/lib/Exception/
DTException.php49 $var = $fspec['var'];
50 if (isset($vals[$var])) {
51 $this->$var = $vals[$var];
69 private function _readMap(&$var, $spec, $input) argument
85 $var = array();
130 $var[$key] = $val;
137 private function _readList(&$var, $spec, $input, $set = false) argument
147 $var = array();
178 $var[$elem] = true;
180 $var [] = $elem;
[all …]
/thrift-3.4.0/lib/haxe/src/org/apache/thrift/protocol/
DTBinaryProtocol.hx39 private static var ANONYMOUS_STRUCT:TStruct = new TStruct();
41 private static inline var VERSION_MASK : haxe.Int32 = 0xffff0000;
42 private static inline var VERSION_1 : haxe.Int32 = 0x80010000;
44 private var strictRead_ : Bool = false;
45 private var strictWrite_ : Bool = true;
58 var version : Int = VERSION_1 | message.type;
114 var out = new BytesOutput();
121 var out = new BytesOutput();
128 var out = new BytesOutput();
135 var out = new BytesOutput();
[all …]
DTCompactTypes.hx27 public static inline var STOP = 0x00;
28 public static inline var BOOLEAN_TRUE = 0x01;
29 public static inline var BOOLEAN_FALSE = 0x02;
30 public static inline var BYTE = 0x03;
31 public static inline var I16 = 0x04;
32 public static inline var I32 = 0x05;
33 public static inline var I64 = 0x06;
34 public static inline var DOUBLE = 0x07;
35 public static inline var BINARY = 0x08;
36 public static inline var LIST = 0x09;
[all …]
DTType.hx24 public static inline var STOP : Int = 0;
25 …public static inline var VOID_ : Int = 1; // VOID produces collisions with cpp targets in some c…
26 public static inline var BOOL : Int = 2;
27 public static inline var BYTE : Int = 3;
28 public static inline var DOUBLE : Int = 4;
29 public static inline var I16 : Int = 6;
30 public static inline var I32 : Int = 8;
31 public static inline var I64 : Int = 10;
32 public static inline var STRING : Int = 11;
33 public static inline var STRUCT : Int = 12;
[all …]
DTJSONProtocol.hx54 private var contextStack : GenericStack<JSONBaseContext> = new GenericStack<JSONBaseContext>();
57 private var context : JSONBaseContext;
60 private var reader : LookaheadReader;
175 var message : TMessage = new TMessage();
203 var field : TField = new TField();
204 var ch = reader.Peek();
224 var KeyType = JSONConstants.GetTypeIDForTypeName( ReadJSONString(false));
225 var ValueType = JSONConstants.GetTypeIDForTypeName( ReadJSONString(false));
226 var Count : Int = ReadJSONInteger();
229 var map = new TMap( KeyType, ValueType, Count);
[all …]
DTCompactProtocol.hx44 private static var ANONYMOUS_STRUCT : TStruct = new TStruct("");
45 private static var TSTOP : TField = new TField("", TType.STOP, 0);
47 private static inline var PROTOCOL_ID : Int = 0x82;
48 private static inline var VERSION : Int = 1;
49 private static inline var VERSION_MASK : Int = 0x1f; // 0001 1111
50 private static inline var TYPE_MASK : Int = 0xE0; // 1110 0000
51 private static inline var TYPE_BITS : Int = 0x07; // 0000 0111
52 private static inline var TYPE_SHIFT_AMOUNT : Int = 5;
55 private static var ttypeToCompactType = [
71 private static var tcompactTypeToType = [
[all …]
DTProtocolException.hx28 public static inline var UNKNOWN : Int = 0;
29 public static inline var INVALID_DATA : Int = 1;
30 public static inline var NEGATIVE_SIZE : Int = 2;
31 public static inline var SIZE_LIMIT : Int = 3;
32 public static inline var BAD_VERSION : Int = 4;
33 public static inline var NOT_IMPLEMENTED : Int = 5;
34 public static inline var DEPTH_LIMIT : Int = 6;
/thrift-3.4.0/lib/haxe/test/src/
DMultiplexTest.hx54 var next : Int;
55 var prev = 0;
56 var result = 1;
71 private var values : List<haxe.Int32> = new List<haxe.Int32>();
91 private inline static var NAME_BENCHMARKSERVICE : String = "BenchmarkService";
92 private inline static var NAME_AGGR : String = "Aggr";
109 var benchHandler : BenchmarkService_service = new BenchmarkServiceHandler();
110 var benchProcessor : TProcessor = new BenchmarkServiceProcessor( benchHandler);
112 var aggrHandler : Aggr_service = new AggrServiceHandler();
113 var aggrProcessor : TProcessor = new AggrProcessor( aggrHandler);
[all …]
DStreamTest.hx38 private inline static var tmpfile : String = "data.tmp";
42 var data : Xtruct = new Xtruct();
52 var config : TConfiguration = new TConfiguration();
53 var stream : TStream = new TFileStream( tmpfile, CreateNew);
54 var trans : TTransport = new TStreamTransport( null, stream, config);
55 var prot = new TJSONProtocol( trans);
57 var data = MakeTestData();
66 var config : TConfiguration = new TConfiguration();
67 var stream : TStream = new TFileStream( tmpfile, Read);
68 var trans : TTransport = new TStreamTransport( stream, null, config);
[all …]
/thrift-3.4.0/lib/haxe/src/org/apache/thrift/transport/
DTSocket.hx53 private var host : String;
55 private var host : Host;
58 private var port : Int;
61 private var socket : WebSocket = null;
63 private var socket : Socket = null;
67 private var input : Dynamic = null;
68 private var output : WebSocket = null;
70 private var input : Socket = null;
71 private var output : Socket = null;
73 private var input : Input = null;
[all …]
DTBufferedTransport.hx35 public static inline var DEFAULT_BUFSIZE : Int = 0x1000; // 4096 Bytes
36 public static inline var MIN_BUFSIZE : Int = 0x100; // 256 Bytes
37 public static inline var MAX_BUFSIZE : Int = 0x100000; // 1 MB
40 private var readBuffer_ : BytesInput = null;
41 private var writeBuffer_ : BytesOutput = null;
42 private var bufSize : Int;
73 var data = Bytes.alloc(len);
77 var got = readBuffer_.readBytes(data, 0, len);
87 var got = InnerTransport.read( buf, off, len);
107 var size = bufSize;
[all …]
DTFramedTransport.hx38 private static inline var HEADER_SIZE = 4;
43 var writeBuffer_ : BytesOutput = new BytesOutput();
48 var readBuffer_ : BytesInput = null;
71 var data = Bytes.alloc(len);
74 var got : Int = readBuffer_.readBytes(data, off, len);
84 var got = readBuffer_.readBytes(data, off, len);
96 var buffer = new BytesBuffer();
97 var len = InnerTransport.readAll( buffer, 0, HEADER_SIZE);
98 var inp = new BytesInput( buffer.getBytes(), 0, HEADER_SIZE);
109 var size : Int = readFrameSize();
[all …]
DTFullDuplexHttpClient.hx47 private var socket : Socket = null;
48 private var host : String;
49 private var port : Int;
50 private var resource : String;
51 private var stripped : Bool = false;
52 private var obuffer : Bytes = new Bytes();
53 private var input : IDataInput;
54 private var output : IDataOutput;
55 private var bytesInChunk : Int = 0;
56 private var CRLF : Bytes = new Bytes();
[all …]
/thrift-3.4.0/test/dart/test_client/bin/
Dmain.dart103 var parser = new ArgParser();
152 var protocolFactory = getProtocolFactory(protocolType);
155 var httpClient = new http.IOClient();
156 var uri = Uri.parse('http://$host:$port');
157 var config = new THttpConfig(uri, {});
160 var socket = await Socket.connect(host, port);
167 var protocol = protocolFactory.getProtocol(transport);
176 var xtruct = new Xtruct()
187 var input = 'Test';
188 var result = await client.testString(input);
[all …]
/thrift-3.4.0/lib/haxe/src/org/apache/thrift/
DTApplicationException.hx33 private static var TAPPLICATION_EXCEPTION_STRUCT = { new TStruct("TApplicationException"); };
34 private static var MESSAGE_FIELD = { new TField("message", TType.STRING, 1); };
35 private static var TYPE_FIELD = { new TField("type", TType.I32, 2); };
39 public static inline var UNKNOWN : Int = 0;
40 public static inline var UNKNOWN_METHOD : Int = 1;
41 public static inline var INVALID_MESSAGE_TYPE : Int = 2;
42 public static inline var WRONG_METHOD_NAME : Int = 3;
43 public static inline var BAD_SEQUENCE_ID : Int = 4;
44 public static inline var MISSING_RESULT : Int = 5;
45 public static inline var INTERNAL_ERROR : Int = 6;
[all …]
DTConfiguration.hx24 public static inline var DEFAULT_MAX_MESSAGE_SIZE = 100 * 1024 * 1024;
25 …public static inline var DEFAULT_MAX_FRAME_SIZE = 16384000; // this value is used consistentl…
26 public static inline var DEFAULT_RECURSION_DEPTH = 64;
28 public var MaxMessageSize(default,null) : Int = DEFAULT_MAX_MESSAGE_SIZE;
29 public var MaxFrameSize(default,null) : Int = DEFAULT_MAX_FRAME_SIZE;
30 public var RecursionLimit(default,null) : Int = DEFAULT_RECURSION_DEPTH;
/thrift-3.4.0/test/haxe/src/
DTestClient.hx51 private var successCnt : Int = 0;
52 private var errorCnt : Int = 0;
53 private var failedTests : String = "";
54 private var print_direct : Bool = false;
56 public static var EXITCODE_SUCCESS = 0x00; // no errors bits set
58 public static var EXITCODE_FAILBIT_BASETYPES = 0x01;
59 public static var EXITCODE_FAILBIT_STRUCTS = 0x02;
60 public static var EXITCODE_FAILBIT_CONTAINERS = 0x04;
61 public static var EXITCODE_FAILBIT_EXCEPTIONS = 0x08;
63 public static var EXITCODE_ALL_FAILBITS = 0x0F;
[all …]
/thrift-3.4.0/tutorial/haxe/src/
DMain.hx45 private static var server : Bool = false;
46 private static var framed : Bool = false;
47 private static var buffered : Bool = false;
48 private static var prot : Prot = binary;
49 private static var trns : Trns = socket;
51 private static var targetHost : String = "localhost";
52 private static var targetPort : Int = 9090;
96 var newValue : Dynamic;
98 var extra:String = "";
106 var msg = infos != null ? infos.fileName + ':' + infos.lineNumber + ': ' : '';
[all …]
/thrift-3.4.0/lib/js/
DREADME.md88 var transport = new Thrift.TXHRTransport("/hello");
89 var protocol = new Thrift.TJSONProtocol(transport);
90 var client = new hello_svcClient(protocol);
91 var nameElement = document.getElementById("name_in");
92 var outputElement = document.getElementById("output");
105 var thrift = require('thrift');
106 var hello_svc = require('./gen-nodejs/hello_svc.js');
108 var hello_handler = {
110 var msg = "Hello " + name + "!";
115 var hello_svc_opt = {
[all …]
/thrift-3.4.0/lib/haxe/src/org/apache/thrift/server/
DTServer.hx29 private var processor : TProcessor = null;
30 private var serverTransport : TServerTransport = null;
31 private var inputTransportFactory : TTransportFactory = null;
32 private var outputTransportFactory : TTransportFactory = null;
33 private var inputProtocolFactory : TProtocolFactory = null;
34 private var outputProtocolFactory : TProtocolFactory = null;
37 public var serverEventHandler : TServerEventHandler = null;
40 private var _logDelegate : Dynamic->Void = null;
41 public var logDelegate(get,set) : Dynamic->Void;
/thrift-3.4.0/lib/dart/test/transport/
Dt_http_transport_test.dart42 var config = THttpConfig(Uri.parse('http://localhost'), {});
47 var expectedText = 'my request';
56 var requestText = utf8Codec.decode(base64.decode(client.postRequest));
61 var expectedText = 'my response';
62 var expectedBytes = utf8Codec.encode(expectedText);
72 var buffer = Uint8List(expectedBytes.length);
75 var bufferText = utf8Codec.decode(buffer);
86 var config = THttpConfig(Uri.parse('http://localhost'), {});
92 var expectedText = 'response 1';
93 var expectedBytes = utf8Codec.encode(expectedText);
[all …]
Dt_socket_transport_test.dart68 var buffer = Uint8List(responseBytes.length);
70 var bufferText = utf8Codec.decode(buffer);
93 var buffer = Uint8List(responseBytes.length);
128 var buffer = Uint8List(responseBytes.length);
138 var response2Text = 'response 2';
139 var response2Bytes = Uint8List.fromList(utf8Codec.encode(response2Text));
140 var response2Base64 = base64.encode(response2Bytes);
165 var messageReader = TMessageReader(protocolFactory,
179 var buffer = Uint8List(responseBytes.length);
195 var socket = FakeSocket();
[all …]
/thrift-3.4.0/lib/dart/test/protocol/
Dt_protocol_test.dart67 var output = primitive.read();
79 var output = primitive.read();
84 var sharedTests = () {
90 var subject = protocol.readMessageBegin();
98 var input = TStruct();
107 var output = protocol.readStructBegin();
114 var input = TField('my field', TType.MAP, 123);
123 var output = protocol.readFieldBegin();
131 var input = TMap(TType.STRING, TType.STRUCT, 123);
140 var output = protocol.readMapBegin();
[all …]

12345