| /thrift-3.4.0/lib/java/src/main/java/org/apache/thrift/ |
| D | ProcessFunction.java | 41 } catch (TTransportException ex) { in process()
42 LOGGER.error("Transport error while processing " + getMethodName(), ex); in process()
43 throw ex; in process()
44 } catch (TApplicationException ex) { in process()
45 LOGGER.error("Internal application error processing " + getMethodName(), ex); in process()
46 result = ex; in process()
48 } catch (Exception ex) { in process()
49 LOGGER.error("Internal error processing " + getMethodName(), ex); in process()
50 if (rethrowUnhandledExceptions()) throw new RuntimeException(ex.getMessage(), ex); in process()
|
| /thrift-3.4.0/test/netstd/Client/ |
| D | TestClient.cs | 340 catch (TTransportException ex) in Execute()
343 Console.WriteLine("Connect failed: " + ex.Message); in Execute()
345 Console.WriteLine(ex.Message + "\n" + ex.StackTrace); in Execute()
348 catch (Exception ex) in Execute()
351 Console.WriteLine("Connect failed: " + ex.Message); in Execute()
353 Console.WriteLine(ex.Message + "\n" + ex.StackTrace); in Execute()
361 catch (Exception ex) in Execute()
364 Console.WriteLine(ex.Message + "\n" + ex.StackTrace); in Execute()
372 catch (Exception ex) in Execute()
375 Console.WriteLine(ex.Message + "\n" + ex.StackTrace); in Execute()
[all …]
|
| /thrift-3.4.0/lib/cpp/test/ |
| D | TTransportCheckThrow.h | 27 } catch (TTransportException & ex) { \
28 BOOST_CHECK_EQUAL(ex.getType(), _TYPE); \
39 } catch (TTransportException & ex) { \
40 BOOST_REQUIRE_EQUAL(ex.getType(), _TYPE); \
|
| D | SecurityTest.cpp | 132 catch (apache::thrift::transport::TTransportException& ex) in server() local
135 …T_TEST_MESSAGE(boost::format("SRV %1% Exception: %2%") % boost::this_thread::get_id() % ex.what()); in server()
147 catch (std::exception& ex) in server() local
149 BOOST_FAIL(boost::format("%1%: %2%") % typeid(ex).name() % ex.what()); in server()
177 catch (apache::thrift::transport::TTransportException& ex) in client() local
180 …T_TEST_MESSAGE(boost::format("CLI %1% Exception: %2%") % boost::this_thread::get_id() % ex.what()); in client()
189 catch (std::exception& ex) in client() local
191 BOOST_FAIL(boost::format("%1%: %2%") % typeid(ex).name() % ex.what()); in client()
273 catch (std::exception& ex) in BOOST_FIXTURE_TEST_SUITE() local
275 BOOST_FAIL(boost::format("%1%: %2%") % typeid(ex).name() % ex.what()); in BOOST_FIXTURE_TEST_SUITE()
|
| D | SecurityFromBufferTest.cpp | 132 catch (apache::thrift::transport::TTransportException& ex) { in server() local
134 …T_TEST_MESSAGE(boost::format("SRV %1% Exception: %2%") % boost::this_thread::get_id() % ex.what()); in server()
144 } catch (std::exception& ex) { in server() local
145 BOOST_FAIL(boost::format("%1%: %2%") % typeid(ex).name() % ex.what()); in server()
169 } catch (apache::thrift::transport::TTransportException& ex) { in client() local
171 …T_TEST_MESSAGE(boost::format("CLI %1% Exception: %2%") % boost::this_thread::get_id() % ex.what()); in client()
178 } catch (std::exception& ex) { in client() local
179 BOOST_FAIL(boost::format("%1%: %2%") % typeid(ex).name() % ex.what()); in client()
248 } catch (std::exception& ex) { in BOOST_FIXTURE_TEST_SUITE() local
249 BOOST_FAIL(boost::format("%1%: %2%") % typeid(ex).name() % ex.what()); in BOOST_FIXTURE_TEST_SUITE()
|
| D | ZlibTest.cpp | 206 } catch (TTransportException& ex) { in test_incomplete_checksum() local
207 BOOST_CHECK_EQUAL(ex.getType(), TTransportException::CORRUPTED_DATA); in test_incomplete_checksum()
282 } catch (TZlibTransportException& ex) { in test_invalid_checksum() local
283 BOOST_CHECK_EQUAL(ex.getType(), TTransportException::INTERNAL_ERROR); in test_invalid_checksum()
301 } catch (TTransportException& ex) { in test_write_after_flush() local
302 BOOST_CHECK_EQUAL(ex.getType(), TTransportException::BAD_ARGS); in test_write_after_flush()
309 } catch (TTransportException& ex) { in test_write_after_flush() local
310 BOOST_CHECK_EQUAL(ex.getType(), TTransportException::BAD_ARGS); in test_write_after_flush()
317 } catch (TTransportException& ex) { in test_write_after_flush() local
318 BOOST_CHECK_EQUAL(ex.getType(), TTransportException::BAD_ARGS); in test_write_after_flush()
|
| /thrift-3.4.0/lib/java/src/main/java/org/apache/thrift/transport/ |
| D | TSimpleFileTransport.java | 193 } catch (IOException ex) { in seek()
194 throw new TTransportException(ex.getMessage()); in seek()
207 } catch (IOException ex) { in length()
208 throw new TTransportException(ex.getMessage()); in length()
221 } catch (IOException ex) { in getFilePointer()
222 throw new TTransportException(ex.getMessage()); in getFilePointer()
|
| /thrift-3.4.0/lib/php/src/ext/thrift_protocol/ |
| D | php_thrift_protocol.cpp | 108 ZVAL_COPY(&ex, _ex); in PHPExceptionWrapper()
113 ZVAL_OBJ(&ex, _exobj); in PHPExceptionWrapper()
117 zval_dtor(&ex); in ~PHPExceptionWrapper()
124 return const_cast<zval*>(&ex); in operator zval*()
127 zval ex; member in PHPExceptionWrapper
151 zend_object *ex = EG(exception); in PHPTransport() local
153 throw PHPExceptionWrapper(ex); in PHPTransport()
242 zend_object *ex = EG(exception); in directFlush() local
244 throw PHPExceptionWrapper(ex); in directFlush()
261 zend_object *ex = EG(exception); in directWrite() local
[all …]
|
| /thrift-3.4.0/lib/netstd/Thrift/Transport/Server/ |
| D | TServerSocketTransport.cs | 145 catch (Exception ex) in AcceptImplementationAsync()
147 throw new TTransportException(ex.ToString()); in AcceptImplementationAsync()
159 catch (Exception ex) in Close()
161 throw new TTransportException("WARNING: Could not close server socket: " + ex); in Close()
|
| D | TTlsServerSocketTransport.cs | 159 catch (Exception ex) in AcceptImplementationAsync()
161 throw new TTransportException(ex.ToString()); in AcceptImplementationAsync()
173 catch (Exception ex) in Close()
|
| /thrift-3.4.0/lib/d/src/thrift/transport/ |
| D | zlib.d | 436 auto ex = collectException!TTransportException(zlib.write([6])); variable
437 enforce(ex && ex.type == TTransportException.Type.BAD_ARGS);
439 ex = collectException!TTransportException(zlib.flush());
440 enforce(ex && ex.type == TTransportException.Type.BAD_ARGS);
442 ex = collectException!TTransportException(zlib.finish());
443 enforce(ex && ex.type == TTransportException.Type.BAD_ARGS);
488 auto ex = collectException!TTransportException(reader.verifyChecksum()); in testCorrupted() local
489 enforce(ex && ex.type == TTransportException.Type.CORRUPTED_DATA); in testCorrupted()
|
| /thrift-3.4.0/test/cpp/src/ |
| D | TestClient.cpp | 176 } catch (exception & ex) { \
177 cout << "*** FAILED ***" << endl << ex.what() << endl; \
411 } catch (TTransportException& ex) { in main() local
412 cout << "Connect failed: " << ex.what() << endl; in main()
433 } catch (exception& ex) { in main() local
434 cout << "*** FAILED ***" << endl << ex.what() << endl; in main()
513 } catch (exception& ex) { in main() local
514 cout << "*** FAILED ***" << endl << ex.what() << endl; in main()
539 } catch (exception& ex) { in main() local
540 cout << "*** FAILED ***" << endl << ex.what() << endl; in main()
[all …]
|
| /thrift-3.4.0/lib/cpp/src/thrift/transport/ |
| D | TFDTransport.h | 52 } catch (TTransportException& ex) { in ~TFDTransport()
53 GlobalOutput.printf("~TFDTransport TTransportException: '%s'", ex.what()); in ~TFDTransport()
|
| /thrift-3.4.0/tutorial/js/src/ |
| D | Httpd.java | 255 } catch (InterruptedIOException ex) { in run()
283 } catch (ConnectionClosedException ex) { in run()
285 } catch (IOException ex) { in run()
286 System.err.println("I/O error: " + ex.getMessage()); in run()
287 } catch (HttpException ex) { in run()
288 System.err.println("Unrecoverable HTTP protocol violation: " + ex.getMessage()); in run()
|
| /thrift-3.4.0/tutorial/py.tornado/ |
| D | PythonClient.py | 48 except TTransport.TTransportException as ex:
49 logging.error(ex)
|
| /thrift-3.4.0/lib/js/test/src/test/ |
| D | Httpd.java | 279 } catch (InterruptedIOException ex) { in run()
307 } catch (ConnectionClosedException ex) { in run()
309 } catch (IOException ex) { in run()
310 System.err.println("I/O error: " + ex.getMessage()); in run()
311 } catch (HttpException ex) { in run()
312 System.err.println("Unrecoverable HTTP protocol violation: " + ex.getMessage()); in run()
|
| /thrift-3.4.0/test/cl/ |
| D | tests.lisp | 191 (thrift.test:xception (ex) (and (= (thrift.test::xception-error-code ex) expected-code)
192 … (string= (thrift.test::xception-message ex) expected-message)))))
198 (thrift.test:xception2 (ex) (and (= (thrift.test::xception2-error-code ex) expected-code)
200 (thrift.test::xception2-struct-thing ex))
|
| /thrift-3.4.0/lib/py/src/transport/ |
| D | TSSLSocket.py | 294 except Exception as ex:
298 raise TTransportException(type=TTransportException.NOT_OPEN, message=msg, inner=ex)
309 except Exception as ex:
310 raise TTransportException(message=str(ex), inner=ex)
|
| /thrift-3.4.0/lib/java/src/test/java/org/apache/thrift/test/voidmethexceptions/ |
| D | TestVoidMethExceptions.java | 130 Exception ex = in checkSyncClient() local
136 assertEquals(expectedExceptionClass, ex.getClass()); in checkSyncClient()
138 assertEquals(expectedExceptionMsg, ex.getMessage()); in checkSyncClient()
195 Exception ex = in checkAsyncClient() local
205 assertEquals(expectedExceptionClass, ex.getClass()); in checkAsyncClient()
207 assertEquals(expectedExceptionMsg, ex.getMessage()); in checkAsyncClient()
|
| /thrift-3.4.0/test/py.tornado/ |
| D | test_suite.py | 209 except Xception as ex:
210 self.assertEqual(ex.errorCode, 1001)
211 self.assertEqual(ex.message, 'Xception')
|
| /thrift-3.4.0/lib/cpp/src/thrift/protocol/ |
| D | THeaderProtocol.cpp | 160 } catch (const TApplicationException& ex) { in readMessageBegin() local
162 ex.write((TProtocol*)this); in readMessageBegin()
169 throw ex; in readMessageBegin()
|
| /thrift-3.4.0/lib/javame/src/org/apache/thrift/protocol/ |
| D | TJSONProtocol.java | 682 catch (UnsupportedEncodingException ex) { in readJSONString()
686 catch (IOException ex) { in readJSONString()
759 } catch (NumberFormatException ex) { in readJSONInteger()
780 } catch (UnsupportedEncodingException ex) { in readJSONDouble()
791 } catch (NumberFormatException ex) { in readJSONDouble()
861 } catch (UnsupportedEncodingException ex) { in readMessageBegin()
964 } catch (UnsupportedEncodingException ex) { in readString()
|
| /thrift-3.4.0/lib/cpp/src/thrift/qt/ |
| D | TQTcpServer.cpp | 117 } catch (const TTransportException& ex) { in beginDecode() local
118 qWarning("[TQTcpServer] TTransportException during processing: '%s'", ex.what()); in beginDecode()
|
| /thrift-3.4.0/lib/java/src/main/java/org/apache/thrift/async/ |
| D | TAsyncClientManager.java | 123 } catch (IOException ex) { in run()
124 LOGGER.warn("Could not close selector. This may result in leaked resources!", ex); in run()
|
| /thrift-3.4.0/test/py/ |
| D | TestClient.py | 246 except Xception as ex:
247 self.assertEqual(ex.errorCode, 1001)
248 self.assertEqual(ex.message, 'This is an Xception')
252 except Xception2 as ex:
253 self.assertEqual(ex.errorCode, 2002)
254 self.assertEqual(ex.struct_thing.string_thing, 'This is an Xception2')
|
