diff --git a/connection.cc b/connection.cc
index 454538d..9bdc3dd 100644
--- a/connection.cc
+++ b/connection.cc
@@ -114,6 +114,8 @@ connection::thread_loop(void)
 			len = read(fd, cbuf, sizeof(cbuf));
 			if (len < 0) {
 				error = true;
+			} else if (len == 0) {
+				break;
 			} else {
 				bool want_moar = false;
 				pthread_mutex_lock(&buf_lock);