# 
# patch "netsync.cc"
#  from [6dd8f5df72a84e4f9a45629b04e59cbeb2b6a0d7]
#    to [d5a9fa2db591fd5edc381f048ed8a0bf1dd5a53f]
# 
========================================================================
--- netsync.cc	6dd8f5df72a84e4f9a45629b04e59cbeb2b6a0d7
+++ netsync.cc	d5a9fa2db591fd5edc381f048ed8a0bf1dd5a53f
@@ -3358,9 +3358,7 @@
         }
 
       probe.clear();
-      Netxx::PipeStream *pipe=dynamic_cast<Netxx::PipeStream*>(&*sess.str);
-      if (!pipe) probe.add(*(sess.str), sess.which_events());
-      else probe.add(*pipe, sess.which_events());
+      probe.add(*(sess.str), sess.which_events());
       Netxx::Probe::result_type res = probe.ready(armed ? instant : timeout);
       Netxx::Probe::ready_type event = res.second;
       Netxx::socket_type fd = res.first;
@@ -3716,6 +3714,7 @@
   
   if (sess->str->get_socketfd()!=-1) 
     sessions[sess->str->get_socketfd()]=sess;
+  // pipes have two filedescriptors
   Netxx::PipeStream *pipe=dynamic_cast<Netxx::PipeStream*>(&*sess->str);
   if (pipe) 
   { sessions[pipe->get_writefd()]=sess;