/thrift-3.4.0/lib/java/src/test/java/org/apache/thrift/partial/ |
D | PartialThriftTestData.java | 10 * http://www.apache.org/licenses/LICENSE-2.0 103 for (int j = 0; j < numItems; j++) { in initListFields() 104 listItem.add(j); in initListFields() 105 setItem.add(j); in initListFields() 106 mapItem.put(Integer.toString(j), j); in initListFields() local 154 for (int j = 0; j < numItems; j++) { in initSetFields() 155 setItem.add(j); in initSetFields() 156 listItem.add(j); in initSetFields() 157 mapItem.put(Integer.toString(j), j); in initSetFields() local 214 for (int j = 0; j < numItems; j++) { in initMapFields() [all …]
|
D | TestPartialThriftDeserializer.java | 10 * http://www.apache.org/licenses/LICENSE-2.0 65 () -> new TDeserializer(null, fieldNames, binaryProtocolFactory), in testArgChecks() 70 () -> new TDeserializer(TestStruct.class, null, binaryProtocolFactory), in testArgChecks() 75 () -> new TDeserializer(TestStruct.class, fieldNames, null, binaryProtocolFactory), in testArgChecks() 294 // ---------------------------------------------------------------------- 332 for (int j = 0; j < numItems; j++) { in validateListOfSet() 333 assertTrue(set.contains(j)); in validateListOfSet() 345 for (int j = 0; j < numItems; j++) { in validateListOfMap() 346 String key = Integer.toString(j); in validateListOfMap() 348 assertEquals(j, map.get(key)); in validateListOfMap() [all …]
|
/thrift-3.4.0/lib/java/src/main/java/org/apache/thrift/protocol/ |
D | TTupleProtocol.java | 10 * http://www.apache.org/licenses/LICENSE-2.0 56 for (int j = 0; j < length; j++) { in readBitSet() 57 bytes[j] = readByte(); in readBitSet() 63 /** Returns a bitset containing the values in bytes. The byte-ordering must be big-endian. */ 67 if ((bytes[bytes.length - i / 8 - 1] & (1 << (i % 8))) > 0) { in fromByteArray() 76 * not to be a 1 (since BitSet does not support sign extension). The byte-ordering of the result 77 * is big-endian which means the most significant bit is in element 0. The bit at index 0 of the 88 bytes[bytes.length - i / 8 - 1] |= 1 << (i % 8); in toByteArray()
|
D | TSimpleJSONProtocol.java | 10 * http://www.apache.org/licenses/LICENSE-2.0 33 * <p>This protocol is write-only and produces a simple output format suitable for parsing by 34 * scripting languages. It should not be confused with the full-featured TJSONProtocol. 150 resetWriteContext(); // THRIFT-3743 in writeMessageBegin() 329 for (int j = 4; j > hex.length(); --j) { in writeString() 350 bin.limit() - bin.position() - bin.arrayOffset(), in writeBinary() 357 * <p>simplejson is not meant to be read back into thrift - see <a 358 * href="http://wiki.apache.org/thrift/ThriftUsageJava">ThriftUsageJava</a> - use JSON instead
|
/thrift-3.4.0/lib/delphi/test/ |
D | TestClient.pas | 10 * http://www.apache.org/licenses/LICENSE-2.0 24 {.$DEFINE StressTest} // activate to stress-test the server with frequent connects/disconnects 97 Empty, // Edge case: the zero-length empty binary 99 ByteArrayTest, // THRIFT-4454 Large writes/reads may cause range check errors in debug mode 100 …PipeWriteLimit, // THRIFT-4372 Pipe write operations across a network are limited to 65,535 bytes… 204 + ' -h | --help Produces this help message'#10 205 + ' --host=arg (localhost) Host to connect'#10 206 + ' --port=arg (9090) Port number to connect'#10 207 + ' --pipe=arg Windows Named Pipe (e.g. MyThriftPipe)'#10 208 + ' --anon-pipes hRead hWrite Windows Anonymous Pipes pair (handles)'#10 [all …]
|
/thrift-3.4.0/test/ |
D | test.py | 11 # http://www.apache.org/licenses/LICENSE-2.0 22 # Apache Thrift - integration (cross) test suite 24 # tests different server-client, protocol and transport combinations 59 j = json.load(fp) 60 tests = crossrunner.collect_cross_tests(j, server_match, client_match, regex) 93 j = json.load(fp) 96 tests = crossrunner.collect_feature_tests(j, j2, server_match, feature_match, regex) 134 parser.add_argument('--server', default='', nargs='*', 136 parser.add_argument('--client', default='', nargs='*', 138 parser.add_argument('-F', '--features', nargs='*', default=None, [all …]
|
/thrift-3.4.0/lib/dart/lib/src/protocol/ |
D | t_binary_protocol.dart | 9 /// http://www.apache.org/licenses/LICENSE-2.0 155 for (var j = 0; j < 8; j++) { 156 _i64Out[j] = bts[8 - j - 1];
|
/thrift-3.4.0/test/haxe/src/ |
D | TestClient.hx | 10 * http://www.apache.org/licenses/LICENSE-2.0 136 difft = Math.round( 1000 * (Timer.stamp() - difft)) / 1000; 218 trace('- http client : ${uri}'); 226 trace("- framed transport"); 230 trace("- buffered transport"); 239 trace("- binary protocol"); 242 trace("- json protocol"); 245 trace("- compact protocol"); 254 trace('- ${args.numIterations} iterations'); 277 map32.set( -517, 23); [all …]
|
/thrift-3.4.0/lib/go/thrift/ |
D | uuid.go | 10 * http://www.apache.org/licenses/LICENSE-2.0 33 // This type should be directly cast-able with most popular third party UUID 52 buf[8] = '-' 54 buf[13] = '-' 56 buf[18] = '-' 58 buf[23] = '-' 66 return b - '0', true 68 return b - 'a' + 10, true 70 return b - 'A' + 10, true 91 // (8-4-4-4-12/xxxxxxxx-xxxx-xxxx-xxxx-xxxxxxxxxxxx), [all …]
|
/thrift-3.4.0/test/netstd/Client/ |
D | TestClient.cs | 9 // http://www.apache.org/licenses/LICENSE-2.0 85 if (args[i] == "-u") in Parse() 90 else if (args[i] == "-n") in Parse() 94 else if (args[i].StartsWith("--pipe=")) in Parse() 99 else if (args[i].StartsWith("--host=")) in Parse() 106 else if (args[i].StartsWith("--port=")) in Parse() 112 … else if (args[i] == "-b" || args[i] == "--buffered" || args[i] == "--transport=buffered") in Parse() 116 … else if (args[i] == "-f" || args[i] == "--framed" || args[i] == "--transport=framed") in Parse() 120 else if (args[i] == "-t") in Parse() 124 else if (args[i] == "--binary" || args[i] == "--protocol=binary") in Parse() [all …]
|
/thrift-3.4.0/.github/workflows/ |
D | cmake.yml | 10 BUILD_DEPS: bison flex g++ libboost-all-dev libevent-dev libssl-dev make cmake 17 runs-on: ubuntu-20.04 19 - uses: actions/checkout@v3 21 - name: Install dependencies 23 sudo apt-get update -yq 24 sudo apt-get install -y --no-install-recommends $BUILD_DEPS 26 - name: Generate makefile using CMake 30 cmake .. -DBUILD_LIBRARIES=OFF 32 - name: Run make 35 cmake --build . [all …]
|
/thrift-3.4.0/test/keys/ |
D | client_v3.key | 1 -----BEGIN RSA PRIVATE KEY----- 12 DH2O5xuA6TnFosBsMlvVhrjqPUB/j/aGMb2+kyBl2JUEvwaeuatYdwdoOdARJ7gI 27 -----END RSA PRIVATE KEY-----
|
/thrift-3.4.0/lib/cpp/src/thrift/transport/ |
D | TSocketPool.cpp | 10 * http://www.apache.org/licenses/LICENSE-2.0 20 #include <thrift/thrift-config.h> 172 host_ = server->host_; in setCurrentServer() 173 port_ = server->port_; in setCurrentServer() 174 socket_ = server->socket_; in setCurrentServer() 215 bool retryIntervalPassed = (server->lastFailTime_ == 0); in open() 216 bool isLastServer = alwaysTryLast_ ? (i == (numServers - 1)) : false; in open() 218 if (server->lastFailTime_ > 0) { in open() 220 time_t elapsedTime = time(nullptr) - server->lastFailTime_; in open() 227 for (int j = 0; j < numRetries_; ++j) { in open() local [all …]
|
D | TSSLSocket.cpp | 10 * http://www.apache.org/licenses/LICENSE-2.0 20 #include <thrift/thrift-config.h> 104 lock->mutex.lock(); in dyn_lock() 106 lock->mutex.unlock(); in dyn_lock() 125 // newer versions of OpenSSL changed CRYPTO_num_locks - see THRIFT-3878 in initializeOpenSSL() 153 … // https://www.openssl.org/docs/man1.1.0/crypto/ENGINE_cleanup.html - cleanup call is need… in cleanupOpenSSL() 206 SSL_CTX_set_options(ctx_, SSL_OP_NO_SSLv3); // THRIFT-3164 in SSLContext() 289 // "!!" is squelching C4800 "forcing bool -> true or false" performance warning in isOpen() 477 readRetryCount_--; in read() 501 int32_t bytes = SSL_write(ssl_, &buf[written], len - written); in write() [all …]
|
/thrift-3.4.0/lib/erl/test/ |
D | Thrift1475.thrift | 10 * http://www.apache.org/licenses/LICENSE-2.0 36 10: required i32 j,
|
/thrift-3.4.0/lib/nodejs/test/ |
D | deep-constructor.test.js | 10 * http://www.apache.org/licenses/LICENSE-2.0 20 const ttypes = require("./gen-nodejs/JsDeepConstructorTest_types"); 23 const bufferEquals = require("buffer-equals"); 100 DA: new ttypes.Simple({ value: "j" }) 158 DA: { value: "j" } 202 assert.equals(obj.struct_nested_containers_field2.D[0].DA.value, "j");
|
/thrift-3.4.0/lib/haxe/src/org/apache/thrift/protocol/ |
D | TProtocolUtil.hx | 10 * http://www.apache.org/licenses/LICENSE-2.0 85 for (j in 0 ... set.size) {
|
/thrift-3.4.0/lib/java/src/main/java/org/apache/thrift/transport/ |
D | TFileTransport.java | 10 * http://www.apache.org/licenses/LICENSE-2.0 87 return (navailable_ - nread_); in getRemaining() 132 return (chunk_size_ - ((int) (offset_ % chunk_size_))); in getRemaining() 142 WAIT_FOREVER(500, -1); 147 /** Number of retries before giving up if 0, no retries if -1, retry forever */ 243 len -= cnt; in tailRead() 246 } else if (cnt == -1) { in tailRead() 250 if ((tp.retries_ != -1) && tp.retries_ < retries) return (orig_len - len); in tailRead() 259 // either non-zero or -1 is what the contract says! in tailRead() 267 return (orig_len - len); in tailRead() [all …]
|
/thrift-3.4.0/aclocal/ |
D | ax_check_openssl.m4 | 2 # https://www.gnu.org/software/autoconf-archive/ax_check_openssl.html 7 # AX_CHECK_OPENSSL([action-if-found[, action-if-not-found]]) 11 # Look for OpenSSL in a number of default spots, or in a user-selected 12 # spot (via --with-openssl). Sets 15 # OPENSSL_LIBS to the -l directives required 16 # OPENSSL_LDFLAGS to the -L or -R flags required 18 # and calls ACTION-IF-FOUND or ACTION-IF-NOT-FOUND appropriately 28 # Copyright (c) 2009,2010 Dustin J. Mitchell <dustin@zmanda.com> 32 # and this notice are preserved. This file is offered as-is, without any 41 [AS_HELP_STRING([--with-openssl=DIR], [all …]
|
D | ax_cxx_compile_stdcxx.m4 | 2 # https://www.gnu.org/software/autoconf-archive/ax_cxx_compile_stdcxx.html 17 # extended mode (e.g. -std=gnu++11) or a strict conformance mode (e.g. 18 # -std=c++11). If neither is specified, you get whatever works, with 40 # and this notice are preserved. This file is offered as-is, without any 67 switch="-std=gnu++${alternative}" 79 if test -n "$CXXCPP" ; then 91 dnl http://h21007.www2.hp.com/portal/download/files/unprot/aCxx/PDF_Release_Notes/769149-001.pdf 92 dnl Cray's crayCC needs "-h std=c++11" 94 for switch in -std=c++${alternative} +std=c++${alternative} "-h std=c++${alternative}"; do 106 if test -n "$CXXCPP" ; then [all …]
|
/thrift-3.4.0/test/c_glib/src/ |
D | test_client.c | 10 * http://www.apache.org/licenses/LICENSE-2.0 20 #include <glib-object.h> 38 #include "../gen-c_glib/t_test_second_service.h" 39 #include "../gen-c_glib/t_test_thrift_test.h" 56 /* Re-raise the signal, this time invoking the default signal in sigpipe_handler() 71 result = -1; in gint32_compare() 95 { "domain-socket", 0, 0, G_OPTION_ARG_STRING, &path, in main() 140 /* Configure and parse our command-line options */ in main() 149 fprintf (stderr, "%s\n", error->message); in main() 196 socket_name = "ip-ssl"; in main() [all …]
|
/thrift-3.4.0/lib/swift/Sources/ |
D | TSSLSocketTransport.swift | 10 * http://www.apache.org/licenses/LICENSE-2.0 75 if sd == -1 { 81 // need a non-self ref to sd, otherwise the j complains 86 if connectResult == -1 { 132 func recoverFromTrustFailure(_ myTrust: SecTrust, lastTrustResult: SecTrustResultType) -> Bool { in recoverFromTrustFailure() 137 let newTime = currentTime - Double(timeIncrement) in recoverFromTrustFailure() 139 if trustTime - newTime != 0 { in recoverFromTrustFailure() 144 let success = withUnsafeMutablePointer(to: &tr) { trPtr -> Bool in in recoverFromTrustFailure() 160 public func isOpen() -> Bool { in isOpen() 199 let success = withUnsafeMutablePointer(to: &trustResult) { trustPtr -> Bool in in stream()
|
/thrift-3.4.0/lib/c_glib/test/ |
D | testzlibtransport.c | 10 * http://www.apache.org/licenses/LICENSE-2.0 30 { 'a', 'b', 'c', 'd', 'e', 'f', 'g', 'h', 'i', 'j', \
|
/thrift-3.4.0/build/docker/old/ubuntu-artful/ |
D | Dockerfile | 5 # http://www.apache.org/licenses/LICENSE-2.0 16 # - cpp: stock boost 1.62 in artful has a nasty bug so we use stock boost 1.63 17 # - d: dmd does not come with Ubuntu 18 # - dart: does not come with Ubuntu. Pinned to last 1.x release 19 # - dotnet: does not come with Ubuntu 20 # - haxe: version 3.4.2 that comes with Ubuntu cores in our CI build 21 # - go: artful comes with 1.9, we want the latest (supported) 22 # - nodejs: want v8, artful comes with v6 25 FROM buildpack-deps:artful-scm 31 RUN apt-get update && \ [all …]
|
/thrift-3.4.0/lib/erl/src/ |
D | thrift_json_protocol.erl | 10 %% http://www.apache.org/licenses/LICENSE-2.0 23 -module(thrift_json_protocol). 25 -behaviour(thrift_protocol). 27 -include("thrift_constants.hrl"). 28 -include("thrift_protocol.hrl"). 30 -export([new/1, new/2, 38 -record(json_context, { 45 -record(json_protocol, { 50 -type state() :: #json_protocol{}. 51 -include("thrift_protocol_behaviour.hrl"). [all …]
|