couple of bugs fixed

src/Makefile.am

@@ -1,5 +1,9 @@
 lib_LTLIBRARIES = libzmq.la
 
+pkginclude_HEADERS = \
+    ../include/zmq.h \
+    ../include/zmq.hpp
+
 libzmq_la_SOURCES = \
     app_thread.hpp \
     atomic_bitmap.hpp \
@@ -29,7 +33,7 @@ libzmq_la_SOURCES = \
     mutex.hpp \
     object.hpp \
     options.hpp \
-    owner.hpp \
+    owned.hpp \
     pipe.hpp \
     platform.hpp \
     poll.hpp \

src/tcp_socket.cpp

@@ -81,7 +81,7 @@ int zmq::tcp_socket_t::write (const void *data, int size)
         return 0;
 
     //  Signalise peer failure.
-    if (nbytes == -1 && errno == ECONNRESET)
+    if (nbytes == -1 && (errno == ECONNRESET || errno == EPIPE))
         return -1;
 
     errno_assert (nbytes != -1);

src/zmq_connecter_init.cpp

@@ -77,7 +77,6 @@ bool zmq::zmq_connecter_init_t::write (::zmq_msg_t *msg_)
 void zmq::zmq_connecter_init_t::flush ()
 {
     //  We are not expecting any messages. No point in flushing.
-    zmq_assert (false);
 }
 
 void zmq::zmq_connecter_init_t::detach ()

src/zmq_engine.cpp

@@ -97,11 +97,8 @@ void zmq::zmq_engine_t::in_event ()
     if (inpos < insize)
         reset_pollin (handle);
 
-    //  If at least one byte was processed, flush all messages the decoder
+    //  Flush all messages the decoder may have produced.
-    //  may have produced.
+    inout->flush ();
-    if (nbytes > 0)
-        inout->flush ();
-
 }
 
 void zmq::zmq_engine_t::out_event ()

src/zmq_listener_init.cpp

@@ -62,7 +62,8 @@ bool zmq::zmq_listener_init_t::write (::zmq_msg_t *msg_)
 
 void zmq::zmq_listener_init_t::flush ()
 {
-    zmq_assert (has_peer_identity);
+    if (!has_peer_identity)
+        return;
 
     //  Initialisation is done. Disconnect the engine from the init object.
     engine->unplug ();