diff options
author | James E. King III <jking@apache.org> | 2018-03-03 12:00:05 -0500 |
---|---|---|
committer | James E. King III <jking@apache.org> | 2018-03-03 12:01:19 -0500 |
commit | 641b139fd60649b588beb10b58a1c483b0ee5685 (patch) | |
tree | 53e432e5822bc60111831e47f4ef887a42bd2811 /lib/d | |
parent | 6aa4c0f448d8f2573d2abcc8c3724bd18b3f8d1d (diff) | |
download | thrift-641b139fd60649b588beb10b58a1c483b0ee5685.tar.gz |
THRIFT-4503: fix dlang server logging on client disconnect so it does not report an error for normal operation
Diffstat (limited to 'lib/d')
-rw-r--r-- | lib/d/src/thrift/server/simple.d | 4 | ||||
-rw-r--r-- | lib/d/src/thrift/server/taskpool.d | 4 | ||||
-rw-r--r-- | lib/d/src/thrift/server/threaded.d | 4 |
3 files changed, 9 insertions, 3 deletions
diff --git a/lib/d/src/thrift/server/simple.d b/lib/d/src/thrift/server/simple.d index f7183a751..5aba4c169 100644 --- a/lib/d/src/thrift/server/simple.d +++ b/lib/d/src/thrift/server/simple.d @@ -140,7 +140,9 @@ class TSimpleServer : TServer { } } } catch (TTransportException ttx) { - logError("Client died: %s", ttx); + if (ttx.type() != TTransportException.Type.END_OF_FILE) { + logError("Client died unexpectedly: %s", ttx); + } } catch (Exception e) { logError("Uncaught exception: %s", e); } diff --git a/lib/d/src/thrift/server/taskpool.d b/lib/d/src/thrift/server/taskpool.d index b4720a48e..670e720fc 100644 --- a/lib/d/src/thrift/server/taskpool.d +++ b/lib/d/src/thrift/server/taskpool.d @@ -268,7 +268,9 @@ protected: } } } catch (TTransportException ttx) { - logError("Client died: %s", ttx); + if (ttx.type() != TTransportException.Type.END_OF_FILE) { + logError("Client died unexpectedly: %s", ttx); + } } catch (Exception e) { logError("Uncaught exception: %s", e); } diff --git a/lib/d/src/thrift/server/threaded.d b/lib/d/src/thrift/server/threaded.d index 1cde983a4..300cc8457 100644 --- a/lib/d/src/thrift/server/threaded.d +++ b/lib/d/src/thrift/server/threaded.d @@ -173,7 +173,9 @@ private class WorkerThread : Thread { } } } catch (TTransportException ttx) { - logError("Client died: %s", ttx); + if (ttx.type() != TTransportException.Type.END_OF_FILE) { + logError("Client died unexpectedly: %s", ttx); + } } catch (Exception e) { logError("Uncaught exception: %s", e); } |