<commit_before>diff -Naur TAO.org/ACE_wrappers/TAO/orbsvcs/orbsvcs/AV/AVStreams_i.cpp TAO/ACE_wrappers/TAO/orbsvcs/orbsvcs/AV/AVStreams_i.cpp
--- TAO.org/ACE_wrappers/TAO/orbsvcs/orbsvcs/AV/AVStreams_i.cpp	2007-07-07 22:06:46.000000000 +0200
+++ TAO/ACE_wrappers/TAO/orbsvcs/orbsvcs/AV/AVStreams_i.cpp	2007-08-14 17:03:09.000000000 +0200
@@ -108,10 +108,18 @@
             }
         }
     }
+  catch(AVStreams::noSuchFlow& ex)
+      {
+      throw; //ACS mod 2007-08
+      }
   catch (const CORBA::Exception& ex)
     {
-      ex._tao_print_exception ("TAO_Basic_StreamCtrl::stop");
-      return;
+    ex._tao_print_exception ("TAO_Basic_StreamCtrl::stop");
+    throw;  //ACS mod 2007-08
+    }
+  catch(...)
+    {
+      printf ("TAO_Basic_StreamCtrl::stop - unknown exception\n");
     }
 }
 
@@ -151,10 +159,18 @@
             }
         }
     }
+ catch(AVStreams::noSuchFlow& ex)
+      {
+      throw; //ACS mod 2007-08
+      }
   catch (const CORBA::Exception& ex)
     {
-      ex._tao_print_exception ("TAO_Basic_StreamCtrl::start");
-      return;
+    ex._tao_print_exception ("TAO_Basic_StreamCtrl::start");
+    throw;  //ACS mod 2007-08
+    }
+  catch(...)
+    {
+      printf ("TAO_Basic_StreamCtrl::start - unknown exception\n");
     }
 }
 
@@ -435,10 +451,18 @@
           entry->int_id_.sep_->stop (flow_spec);
         }
     }
+  catch(AVStreams::noSuchFlow& ex)
+    {
+    throw; //ACS mod 2007-08
+    }
   catch (const CORBA::Exception& ex)
     {
-      ex._tao_print_exception ("TAO_Basic_StreamCtrl::stop");
-      return;
+    ex._tao_print_exception ("TAO_StreamCtrl::stop");
+    throw;  //ACS mod 2007-08
+    }
+  catch(...)
+    {
+      printf ("TAO_StreamCtrl::stop - unknow exception\n");
     }
 }
 
@@ -465,10 +489,18 @@
           entry->int_id_.sep_->start (flow_spec);
         }
     }
+ catch(AVStreams::noSuchFlow& ex)
+    {
+    throw; //ACS mod 2007-08
+    }
   catch (const CORBA::Exception& ex)
     {
-      ex._tao_print_exception ("TAO_StreamCtrl::start");
-      return;
+    ex._tao_print_exception ("TAO_StreamCtrl::start");
+    throw;  //ACS mod 2007-08
+    }
+  catch(...)
+    {
+      printf ("TAO_StreamCtrl::start - unknow exception\n");
     }
 }
 
@@ -3367,10 +3399,18 @@
           (*consumer_begin)->stop ();
         }
     }
+ catch(AVStreams::noSuchFlow& ex)
+    {
+    throw; //ACS mod 2007-08
+    }
   catch (const CORBA::Exception& ex)
     {
-      ex._tao_print_exception ("TAO_FlowConnection::stop");
-      return;
+    ex._tao_print_exception ("TAO_FlowConnection::stop");
+    throw;  //ACS mod 2007-08
+    }
+  catch(...)
+    {
+      printf ("TAO_FlowConnection::stop - unknown exception\n");
     }
 }
 
@@ -3397,10 +3437,18 @@
           (*producer_begin)->start ();
         }
     }
+ catch(AVStreams::noSuchFlow& ex)
+    {
+    throw; //ACS mod 2007-08
+    }
   catch (const CORBA::Exception& ex)
     {
-      ex._tao_print_exception ("TAO_FlowConnection::start");
-      return;
+    ex._tao_print_exception ("TAO_FlowConnection::start");
+    throw;  //ACS mod 2007-08
+    }
+  catch(...)
+    {
+      printf ("TAO_FlowConnection::start - unknown exception\n");
     }
 }
 
diff -Naur TAO.org/ACE_wrappers/TAO/orbsvcs/orbsvcs/AV/TCP.cpp TAO/ACE_wrappers/TAO/orbsvcs/orbsvcs/AV/TCP.cpp
--- TAO.org/ACE_wrappers/TAO/orbsvcs/orbsvcs/AV/TCP.cpp	2006-05-16 16:09:14.000000000 +0200
+++ TAO/ACE_wrappers/TAO/orbsvcs/orbsvcs/AV/TCP.cpp	2007-08-14 13:37:21.000000000 +0200
@@ -656,6 +656,19 @@
                       -1);
 #endif /* TCP_NODELAY */
 
+//begin: BJE: (allign the sizes of the buffers)
+  int bufSize=BUFSIZ;
+  int s= sizeof (bufSize);
+  if(  this->peer ().get_option (SOL_SOCKET, /*IPPROTO_TCP,*/
+				  SO_RCVBUF,
+                                (void *) &bufSize,&s
+			     ) == -1)
+       bufSize=BUFSIZ;
+
+    
+    ((TAO_AV_TCP_Object*)(this->protocol_object_))->frame_.size (bufSize);
+//end: BJE
+
   // Called by the <Strategy_Acceptor> when the handler is completely
   // connected.
   ACE_INET_Addr addr;
diff -Naur TAO.org/ACE_wrappers/TAO/orbsvcs/orbsvcs/AV/TCP.h TAO/ACE_wrappers/TAO/orbsvcs/orbsvcs/AV/TCP.h
--- TAO.org/ACE_wrappers/TAO/orbsvcs/orbsvcs/AV/TCP.h	2006-03-14 07:14:35.000000000 +0100
+++ TAO/ACE_wrappers/TAO/orbsvcs/orbsvcs/AV/TCP.h	2007-08-14 13:37:21.000000000 +0200
@@ -248,7 +248,7 @@
   /// end the stream.
   virtual int destroy (void);
 
-private:
+public:
   /// Pre-allocated memory to receive the data...
   ACE_Message_Block frame_;
 };<commit_msg>in case of normal close of TAO_AV_TCP_Flow_Handler message "TAO_AV_TCP_Flow_Handler::handle_input connection closed" is DEBUG and not ERROR<commit_after>diff -Naur TAO.org/ACE_wrappers/TAO/orbsvcs/orbsvcs/AV/AVStreams_i.cpp TAO/ACE_wrappers/TAO/orbsvcs/orbsvcs/AV/AVStreams_i.cpp
--- TAO.org/ACE_wrappers/TAO/orbsvcs/orbsvcs/AV/AVStreams_i.cpp	2007-07-07 20:06:46.000000000 +0000
+++ TAO/ACE_wrappers/TAO/orbsvcs/orbsvcs/AV/AVStreams_i.cpp	2008-12-29 10:14:55.242014000 +0000
@@ -108,10 +108,18 @@
             }
         }
     }
+  catch(AVStreams::noSuchFlow& ex)
+      {
+      throw; //ACS mod 2007-08
+      }
   catch (const CORBA::Exception& ex)
     {
-      ex._tao_print_exception ("TAO_Basic_StreamCtrl::stop");
-      return;
+    ex._tao_print_exception ("TAO_Basic_StreamCtrl::stop");
+    throw;  //ACS mod 2007-08
+    }
+  catch(...)
+    {
+      printf ("TAO_Basic_StreamCtrl::stop - unknown exception\n");
     }
 }
 
@@ -151,10 +159,18 @@
             }
         }
     }
+ catch(AVStreams::noSuchFlow& ex)
+      {
+      throw; //ACS mod 2007-08
+      }
   catch (const CORBA::Exception& ex)
     {
-      ex._tao_print_exception ("TAO_Basic_StreamCtrl::start");
-      return;
+    ex._tao_print_exception ("TAO_Basic_StreamCtrl::start");
+    throw;  //ACS mod 2007-08
+    }
+  catch(...)
+    {
+      printf ("TAO_Basic_StreamCtrl::start - unknown exception\n");
     }
 }
 
@@ -435,10 +451,18 @@
           entry->int_id_.sep_->stop (flow_spec);
         }
     }
+  catch(AVStreams::noSuchFlow& ex)
+    {
+    throw; //ACS mod 2007-08
+    }
   catch (const CORBA::Exception& ex)
     {
-      ex._tao_print_exception ("TAO_Basic_StreamCtrl::stop");
-      return;
+    ex._tao_print_exception ("TAO_StreamCtrl::stop");
+    throw;  //ACS mod 2007-08
+    }
+  catch(...)
+    {
+      printf ("TAO_StreamCtrl::stop - unknow exception\n");
     }
 }
 
@@ -465,10 +489,18 @@
           entry->int_id_.sep_->start (flow_spec);
         }
     }
+ catch(AVStreams::noSuchFlow& ex)
+    {
+    throw; //ACS mod 2007-08
+    }
   catch (const CORBA::Exception& ex)
     {
-      ex._tao_print_exception ("TAO_StreamCtrl::start");
-      return;
+    ex._tao_print_exception ("TAO_StreamCtrl::start");
+    throw;  //ACS mod 2007-08
+    }
+  catch(...)
+    {
+      printf ("TAO_StreamCtrl::start - unknow exception\n");
     }
 }
 
@@ -3367,10 +3399,18 @@
           (*consumer_begin)->stop ();
         }
     }
+ catch(AVStreams::noSuchFlow& ex)
+    {
+    throw; //ACS mod 2007-08
+    }
   catch (const CORBA::Exception& ex)
     {
-      ex._tao_print_exception ("TAO_FlowConnection::stop");
-      return;
+    ex._tao_print_exception ("TAO_FlowConnection::stop");
+    throw;  //ACS mod 2007-08
+    }
+  catch(...)
+    {
+      printf ("TAO_FlowConnection::stop - unknown exception\n");
     }
 }
 
@@ -3397,10 +3437,18 @@
           (*producer_begin)->start ();
         }
     }
+ catch(AVStreams::noSuchFlow& ex)
+    {
+    throw; //ACS mod 2007-08
+    }
   catch (const CORBA::Exception& ex)
     {
-      ex._tao_print_exception ("TAO_FlowConnection::start");
-      return;
+    ex._tao_print_exception ("TAO_FlowConnection::start");
+    throw;  //ACS mod 2007-08
+    }
+  catch(...)
+    {
+      printf ("TAO_FlowConnection::start - unknown exception\n");
     }
 }
 
diff -Naur TAO.org/ACE_wrappers/TAO/orbsvcs/orbsvcs/AV/TCP.cpp TAO/ACE_wrappers/TAO/orbsvcs/orbsvcs/AV/TCP.cpp
--- TAO.org/ACE_wrappers/TAO/orbsvcs/orbsvcs/AV/TCP.cpp	2006-05-16 14:09:14.000000000 +0000
+++ TAO/ACE_wrappers/TAO/orbsvcs/orbsvcs/AV/TCP.cpp	2008-12-29 10:25:18.643514000 +0000
@@ -210,7 +210,7 @@
   if (n == -1)
     ACE_ERROR_RETURN ((LM_ERROR,"TAO_AV_TCP_Flow_Handler::handle_input recv failed\n"),-1);
   if (n == 0)
-    ACE_ERROR_RETURN ((LM_ERROR,"TAO_AV_TCP_Flow_Handler::handle_input connection closed\n"),-1);
+    ACE_ERROR_RETURN ((LM_DEBUG,"TAO_AV_TCP_Flow_Handler::handle_input connection closed\n"),-1);
   this->frame_.wr_ptr (this->frame_.rd_ptr () + n);
 
   return this->callback_->receive_frame (&this->frame_);
@@ -656,6 +656,19 @@
                       -1);
 #endif /* TCP_NODELAY */
 
+//begin: BJE: (allign the sizes of the buffers)
+  int bufSize=BUFSIZ;
+  int s= sizeof (bufSize);
+  if(  this->peer ().get_option (SOL_SOCKET, /*IPPROTO_TCP,*/
+				  SO_RCVBUF,
+                                (void *) &bufSize,&s
+			     ) == -1)
+       bufSize=BUFSIZ;
+
+    
+    ((TAO_AV_TCP_Object*)(this->protocol_object_))->frame_.size (bufSize);
+//end: BJE
+
   // Called by the <Strategy_Acceptor> when the handler is completely
   // connected.
   ACE_INET_Addr addr;
diff -Naur TAO.org/ACE_wrappers/TAO/orbsvcs/orbsvcs/AV/TCP.h TAO/ACE_wrappers/TAO/orbsvcs/orbsvcs/AV/TCP.h
--- TAO.org/ACE_wrappers/TAO/orbsvcs/orbsvcs/AV/TCP.h	2006-03-14 06:14:35.000000000 +0000
+++ TAO/ACE_wrappers/TAO/orbsvcs/orbsvcs/AV/TCP.h	2008-12-29 10:14:55.246018000 +0000
@@ -248,7 +248,7 @@
   /// end the stream.
   virtual int destroy (void);
 
-private:
+public:
   /// Pre-allocated memory to receive the data...
   ACE_Message_Block frame_;
 };
{'fraction_non_alphanumeric': 0.17019060514529735, 'fraction_numerical': 0.0673888136652432, 'mean_word_length': 2.5681902638424376, 'pattern_counts': {'":': 0, '<': 5, '<?xml version=': 0, '>': 28, 'https://': 0, 'lorem ipsum': 0, 'www.': 0, 'xml': 0}, 'pii_count': 0, 'substrings_counts': 9, 'word_list_counts': {'cursed_substrings.json': 0, 'profanity_word_list.json': 0, 'sexual_word_list.json': 0, 'zh_pornsignals.json': 0}}
{'dir': 'git-commits-cleaned', 'id': '3423619', 'n_tokens_mistral': 4338, 'n_tokens_neox': 3790, 'n_words': 565}