Home
last modified time | relevance | path

Searched full:if (Results 1 – 25 of 1195) sorted by relevance

12345678910>>...48

/thrift-3.4.0/lib/go/test/tests/
Dvalidate_test.go34 if err := bt.Validate(); err != nil {
40 if err := bt.Validate(); err == nil {
42 } else if errors.As(err, &ve) {
43 if ve.Check() != "vt.const" {
46 if ve.Field() != "Bool1" {
54 if err := bt.Validate(); err == nil {
56 } else if errors.As(err, &ve) {
57 if ve.Check() != "vt.lt" {
60 if ve.Field() != "Byte1" {
68 if err := bt.Validate(); err == nil {
[all …]
Dclient_error_test.go34 // Setup mock to fail at a certain position. Return true if position exists otherwise false.
37 // this function. If more function calls are added in the future, this
44 // always be called by t.Cleanup, even if we return false here.
49 if failAt > lastFailAt {
55 if failAt == 0 {
59 if failAt == 0 {
62 if failAt == 1 {
66 if failAt == 1 {
69 if failAt == 2 {
73 if failAt == 2 {
[all …]
/thrift-3.4.0/lib/py/src/ext/
Dprotocol.tcc28 #if PY_MAJOR_VERSION < 3
38 #if PY_MAJOR_VERSION < 3
47 if (!PycStringIO) { in new_encode_buffer()
50 if (!PycStringIO) { in new_encode_buffer()
57 if (!PycStringIO) { in read_buffer()
60 if (!PycStringIO) { in read_buffer()
70 if (output_) { in ~ProtocolBase()
82 if (!PycStringIO) { in getEncodedValue()
85 if (!PycStringIO) { in getEncodedValue()
93 if (!PycStringIO) { in writeBuffer()
[all …]
/thrift-3.4.0/lib/
DMakefile.am23 if WITH_CPP
27 if WITH_C_GLIB
31 if WITH_JAVA
35 # so test only if java, ant & co is available
39 if WITH_KOTLIN
44 if WITH_PYTHON
48 if WITH_ERLANG
52 if WITH_RUBY
56 if WITH_PERL
60 if WITH_PHP
[all …]
/thrift-3.4.0/lib/d/test/
Dthrift_test_client.d86 if (parts.length > 1) { in main()
99 if (ssl) { in main()
127 if (zlib && transportType != TransportType.zlib) { in main()
144 if (trace) writefln("Test #%s, connect %s:%s", test + 1, host, port); in main()
146 if (trace) write("testVoid()"); in main()
148 if (trace) writeln(" = void"); in main()
150 if (trace) write("testString(\"Test\")"); in main()
152 if (trace) writefln(" = \"%s\"", s); in main()
155 if (trace) write("testByte(1)"); in main()
157 if (trace) writefln(" = %s", u8); in main()
[all …]
/thrift-3.4.0/lib/cpp/src/thrift/transport/
DTFileTransport.cpp102 // check if current file is still open in resetOutputFile()
103 if (fd_ > 0) { in resetOutputFile()
107 if (-1 == ::THRIFT_CLOSE(fd_)) { in resetOutputFile()
119 if (fd) { in resetOutputFile()
122 // open file if the input fd is 0 in resetOutputFile()
128 // flush the buffer if a writer thread is active in ~TFileTransport()
129 if (writerThread_.get()) { in ~TFileTransport()
141 if (dequeueBuffer_) { in ~TFileTransport()
146 if (enqueueBuffer_) { in ~TFileTransport()
151 if (readBuff_) { in ~TFileTransport()
[all …]
DTSSLSocket.cpp48 #if (OPENSSL_VERSION_NUMBER < OPENSSL_ENGINE_CLEANUP_REQUIRED_BEFORE)
77 if (mode & CRYPTO_LOCK) { in callbackLocking()
87 #if (OPENSSL_VERSION_NUMBER < OPENSSL_VERSION_NO_THREAD_ID_BEFORE)
102 if (lock != nullptr) { in dyn_lock()
103 if (mode & CRYPTO_LOCK) { in dyn_lock()
116 if (openSSLInitialized) { in initializeOpenSSL()
132 #if (OPENSSL_VERSION_NUMBER < OPENSSL_VERSION_NO_THREAD_ID_BEFORE) in initializeOpenSSL()
145 if (!openSSLInitialized) { in cleanupOpenSSL()
152 #if (OPENSSL_VERSION_NUMBER < OPENSSL_ENGINE_CLEANUP_REQUIRED_BEFORE) in cleanupOpenSSL()
158 #if OPENSSL_VERSION_NUMBER >= 0x10100000 in cleanupOpenSSL()
[all …]
DTSocket.cpp187 if (!isOpen()) { in hasPendingDataToRead()
195 if (r == -1) { in hasPendingDataToRead()
197 if (errno_copy == THRIFT_EINTR && (retries++ < maxRecvRetries_)) { in hasPendingDataToRead()
211 if (!isOpen()) { in peek()
214 if (interruptListener_) { in peek()
224 if (ret < 0) { in peek()
226 if (errno_copy == THRIFT_EINTR && (retries++ < maxRecvRetries_)) { in peek()
231 } else if (ret > 0) { in peek()
233 if (fds[1].revents & THRIFT_POLLIN) { in peek()
245 // Check to see if data is available or if the remote side closed in peek()
[all …]
/thrift-3.4.0/tutorial/
DMakefile.am22 if MINGW
26 if WITH_C_GLIB
30 if WITH_CPP
34 if WITH_D
38 if WITH_JAVA
43 if WITH_PYTHON
49 if WITH_RUBY
53 if WITH_HAXE
57 if WITH_DOTNET
61 if WITH_GO
[all …]
/thrift-3.4.0/lib/go/thrift/
Dserializer_types_test.go167 if _, err := iprot.ReadStructBegin(ctx); err != nil {
172 if err != nil {
175 if fieldTypeId == STOP {
180 if err := p.readField1(ctx, iprot); err != nil {
184 if err := p.readField2(ctx, iprot); err != nil {
188 if err := p.readField3(ctx, iprot); err != nil {
192 if err := p.readField4(ctx, iprot); err != nil {
196 if err := p.readField5(ctx, iprot); err != nil {
200 if err := p.readField6(ctx, iprot); err != nil {
204 if err := p.readField7(ctx, iprot); err != nil {
[all …]
Dsimple_json_protocol.go73 if l <= 0 {
81 if l <= 0 {
214 if e := p.OutputListBegin(); e != nil {
217 if e := p.WriteString(ctx, name); e != nil {
220 if e := p.WriteByte(ctx, int8(typeId)); e != nil {
223 if e := p.WriteI32(ctx, seqId); e != nil {
234 if e := p.OutputObjectBegin(); e != nil {
245 if e := p.WriteString(ctx, name); e != nil {
258 if e := p.OutputListBegin(); e != nil {
261 if e := p.WriteByte(ctx, int8(keyType)); e != nil {
[all …]
Diostream_transport.go43 if trans != nil {
45 if ok {
46 if t.isReadWriter {
49 if t.Reader != nil && t.Writer != nil {
52 if t.Reader != nil && t.Writer == nil {
55 if t.Reader == nil && t.Writer != nil {
61 if p.isReadWriter {
64 if p.Reader != nil && p.Writer != nil {
67 if p.Reader != nil && p.Writer == nil {
70 if p.Reader == nil && p.Writer != nil {
[all …]
Djson_protocol_test.go37 if e := p.WriteBool(context.Background(), value); e != nil {
40 if e := p.Flush(context.Background()); e != nil {
45 if value {
50 if s != expected {
54 if err := json.Unmarshal([]byte(s), &v); err != nil || (v != 0) != value {
67 if value {
75 if e != nil {
78 if v != value {
82 if err := json.Unmarshal([]byte(s), &vv); err != nil || (vv != 0) != value {
95 if e := p.WriteByte(context.Background(), value); e != nil {
[all …]
Dsimple_json_protocol_test.go38 if e := p.WriteBool(context.Background(), value); e != nil {
41 if e := p.Flush(context.Background()); e != nil {
45 if s != fmt.Sprint(value) {
49 if err := json.Unmarshal([]byte(s), &v); err != nil || v != value {
62 if value {
70 if e != nil {
73 if v != value {
76 if err := json.Unmarshal([]byte(s), &v); err != nil || v != value {
89 if e := p.WriteByte(context.Background(), value); e != nil {
92 if e := p.Flush(context.Background()); e != nil {
[all …]
Dheader_transport_test.go47 if err := writer.AddTransform(TransformZlib); err != nil {
54 if err := writer.AddTransform(TransformZlib); err != nil {
60 if err := writer.AddTransform(TransformNone); err != nil {
68 if _, err := writer.Write([]byte(payload1)); err != nil {
71 if err := writer.Flush(context.Background()); err != nil {
74 if _, err := writer.Write([]byte(payload2)); err != nil {
77 if err := writer.Flush(context.Background()); err != nil {
84 if err := reader.ReadFrame(context.Background()); err != nil {
87 if err := reader.ReadFrame(context.Background()); err != nil {
91 if err != nil {
[all …]
Dclient.go10 // The headers in the response, if any.
11 // If the underlying transport/protocol is not THeader, this will always be nil.
35 if headerProt, ok := oprot.(*THeaderProtocol); ok {
38 if value, ok := GetHeader(ctx, key); ok {
44 if err := oprot.WriteMessageBegin(ctx, method, CALL, seqId); err != nil {
47 if err := args.Write(ctx, oprot); err != nil {
50 if err := oprot.WriteMessageEnd(ctx); err != nil {
58 if err != nil {
62 if method != rMethod {
64 } else if seqId != rSeqId {
[all …]
Djson_protocol.go61 if e := p.OutputListBegin(); e != nil {
64 if e := p.WriteI32(ctx, THRIFT_JSON_PROTOCOL_VERSION); e != nil {
67 if e := p.WriteString(ctx, name); e != nil {
70 if e := p.WriteByte(ctx, int8(typeId)); e != nil {
73 if e := p.WriteI32(ctx, seqId); e != nil {
84 if e := p.OutputObjectBegin(); e != nil {
95 if e := p.WriteI16(ctx, id); e != nil {
98 if e := p.OutputObjectBegin(); e != nil {
102 if e1 != nil {
105 if e := p.WriteString(ctx, s); e != nil {
[all …]
/thrift-3.4.0/build/cmake/
Dconfig.h.in49 /* Define if the AI_ADDRCONFIG symbol is unavailable */
67 /* Define to 1 if strerror_r returns char *. */
73 /* Define to 1 if you have the <arpa/inet.h> header file. */
76 /* Define to 1 if you have the <fcntl.h> header file. */
79 /* Define to 1 if you have the <inttypes.h> header file. */
82 /* Define to 1 if you have the <netdb.h> header file. */
85 /* Define to 1 if you have the <netinet/in.h> header file. */
88 /* Define to 1 if you have the <signal.h> header file. */
91 /* Define to 1 if you have the <stdint.h> header file. */
94 /* Define to 1 if you have the <unistd.h> header file. */
[all …]
/thrift-3.4.0/test/go/src/bin/testclient/
Dmain.go45 if err != nil {
70 if err = client.TestVoid(defaultCtx); err != nil {
75 if err != nil {
78 if thing != "thing" {
83 if err != nil {
86 if !bl {
90 if err != nil {
93 if bl {
98 if err != nil {
101 if b != 42 {
[all …]
/thrift-3.4.0/compiler/cpp/src/thrift/generate/
Dgo_validator_generator.cc52 if (go_generator->is_pointer_field(field) in get_field_reference_name()
66 if (rules.size() == 0) { in generate_struct_validator()
80 if (type->is_typedef()) { in generate_field_validator()
83 if (type->is_enum()) { in generate_field_validator()
84 if (context.tgt[0] == '*') { in generate_field_validator()
85 out << indent() << "if " << context.tgt.substr(1) << " != nil {" << endl; in generate_field_validator()
89 if (context.tgt[0] == '*') { in generate_field_validator()
94 } else if (type->is_base_type()) { in generate_field_validator()
96 if (context.tgt[0] == '*') { in generate_field_validator()
97 out << indent() << "if " << context.tgt.substr(1) << " != nil {" << endl; in generate_field_validator()
[all …]
/thrift-3.4.0/test/haxe/src/
DArguments.hx74 #if sys
75 #if !phpwebserver
92 #if sys
141 if( (args == null) || (args.length <= 0)) {
148 if ( arg == "client") {
152 else if ( arg == "server") {
156 else if ( (arg == "-h") || (arg == "--help")) {
170 if ( (arg == "-h") || (arg == "--help")) {
176 else if (arg == "--port") {
180 if( tmp != null) {
[all …]
/thrift-3.4.0/lib/java/src/test/java/org/apache/thrift/test/
DJavaBeansTest.java32 if (ooe.is_set_a_bite()) in main()
34 if (ooe.is_set_base64()) in main()
36 if (ooe.is_set_byte_list()) in main()
38 if (ooe.is_set_double_precision()) in main()
40 if (ooe.is_set_i16_list()) in main()
42 if (ooe.is_set_i64_list()) in main()
44 if (ooe.is_set_boolean_field()) in main()
46 if (ooe.is_set_integer16()) in main()
48 if (ooe.is_set_integer32()) in main()
50 if (ooe.is_set_integer64()) in main()
[all …]
DEqualityTest.java89 nulls = matrix[0:1] if type == 'int' else matrix[-1::-1]
95 if type != 'int' and list(is_set) != [ not null for null in is_null ]:
102 print >> out, " rhs." + option + "_" + type, "=", vals[type][0 if equal else 1] + ";"
104 if (type == 'int' and is_set[0]): print >> out, " lhs." + isset_setter + "(true);"
105 if (type == 'int' and is_set[1]): print >> out, " rhs." + isset_setter + "(true);"
106 if (is_null[0]): print >> out, " lhs." + option + "_" + type, "= null;"
107 if (is_null[1]): print >> out, " rhs." + option + "_" + type, "= null;"
115 eq_str = 'true' if is_equal else 'false'
117 print >> out, " if (lhs.equals(rhs) != "+eq_str+")"
119 if is_equal:
[all …]
/thrift-3.4.0/lib/c_glib/src/thrift/c_glib/
Dthrift_application_exception.c45 if ((ret = thrift_protocol_read_struct_begin (protocol, &name, error)) < 0) in G_DEFINE_TYPE()
47 if (name) g_free (name); in G_DEFINE_TYPE()
51 if (name) g_free (name); in G_DEFINE_TYPE()
55 if ((ret = thrift_protocol_read_field_begin (protocol, &name, &ftype, in G_DEFINE_TYPE()
58 if (name) g_free (name); in G_DEFINE_TYPE()
62 if (name) g_free (name); in G_DEFINE_TYPE()
64 /* break if we get a STOP field */ in G_DEFINE_TYPE()
65 if (ftype == T_STOP) in G_DEFINE_TYPE()
73 if (ftype == T_STRING) in G_DEFINE_TYPE()
75 if ((ret = thrift_protocol_read_string (protocol, &this->message, in G_DEFINE_TYPE()
[all …]
/thrift-3.4.0/lib/cpp/src/thrift/processor/
DStatsProcessor.h33 * Class for keeping track of function call statistics and printing them if desired
52 if (mtype != apache::thrift::protocol::T_CALL && mtype != apache::thrift::protocol::T_ONEWAY) { in process()
53 if (print_) { in process()
58 if (print_) { in process()
61 if (frequency_) { in process()
62 if (frequency_map_.find(fname) != frequency_map_.end()) { in process()
74 if (ftype == apache::thrift::protocol::T_STOP) { in process()
79 if (print_) { in process()
84 if (print_) { in process()
98 if (print_) { in printAndPassToBuffer()
[all …]

12345678910>>...48