(TSDB): reopen connection for error "broken pipe"

conf/libuniset2.spec

@@ -24,7 +24,7 @@
 
 Name: libuniset2
 Version: 2.8
-Release: alt5
+Release: alt6
 Summary: UniSet - library for building distributed industrial control systems
 
 License: LGPL
@@ -544,6 +544,9 @@ rm -f %buildroot%_docdir/%oname/html/*.md5
 # history of current unpublished changes
 
 %changelog
+* Mon Feb 11 2019 Pavel Vainerman <pv@altlinux.ru> 2.8-alt6
+- (TSDB): reopen connection for error "broken pipe"
+
 * Sat Feb 09 2019 Pavel Vainerman <pv@altlinux.ru> 2.8-alt5
 - (uniset-codegen): setup logrotate command
 

extensions/Backend-OpenTSDB/BackendOpenTSDB.cc

@@ -365,9 +365,16 @@ bool BackendOpenTSDB::flushBuffer()
 
 		return true;
 	}
+	catch( Poco::IOException& ex )
+	{
+		mywarn << "(flushBuffer): (io): " << ex.displayText() << endl;
+		lastError = ex.displayText();
+		if( !reconnect() )
+			askTimer(tmReconnect, reconnectTime);
+	}
 	catch( std::exception& ex )
 	{
-		mywarn << "(flushBuffer): " << ex.what() << endl;
+		mywarn << "(flushBuffer): (std): " << ex.what() << endl;
 		lastError = ex.what();
 	}
 

extensions/include/UObject_SK.h

@@ -8,7 +8,7 @@
  ВСЕ ВАШИ ИЗМЕНЕНИЯ БУДУТ ПОТЕРЯНЫ.
 */ 
 // --------------------------------------------------------------------------
-// generate timestamp: 2019-02-02+03:00
+// generate timestamp: 2019-02-09+03:00
 // -----------------------------------------------------------------------------
 #ifndef UObject_SK_H_
 #define UObject_SK_H_

extensions/lib/UObject_SK.cc

@@ -11,7 +11,7 @@
  ВСЕ ВАШИ ИЗМЕНЕНИЯ БУДУТ ПОТЕРЯНЫ.
 */ 
 // --------------------------------------------------------------------------
-// generate timestamp: 2019-02-02+03:00
+// generate timestamp: 2019-02-09+03:00
 // -----------------------------------------------------------------------------
 #include <memory>
 #include <iomanip>
@@ -491,7 +491,9 @@ void UObject_SK::preSysCommand( const SystemMessage* _sm )
 			string fname( log()->getLogFile() );
 			if( !fname.empty() )
 			{
-				mylog->logFile(fname.c_str(),true);
+			
+				mylog->logFile(fname.c_str(),false);
+			
 				mylogany << myname << "(preSysCommand): ***************** mylog LOG ROTATE *****************" << endl;
 			}
 			

src/Log/LogReader.cc

@@ -430,6 +430,11 @@ void LogReader::readlogs( const std::string& _addr, int _port, LogServerTypes::C
 		{
 			cerr << "(LogReader): " << e.displayText() << " (" << _addr << ")" << endl;
 		}
+		catch( Poco::IOException& ex )
+		{
+			cerr << "(LogReader): " << e.displayText() << " (" << _addr << ")" << endl;
+			disconnect();
+		}
 		catch( const std::exception& ex )
 		{
 			cerr << "(LogReader): " << ex.what() << endl;
@@ -470,6 +475,10 @@ void LogReader::sendCommand(LogServerTypes::lsMessage& msg, bool verbose )
 	{
 		cerr << "(LogReader): send error:  " << e.displayText() << endl; // " (" << _addr << ")" << endl;
 	}
+	catch( Poco::IOException& ex )
+	{
+		cerr << "(LogReader): send error:  " << ex.displayText() << endl;
+	}
 	catch( const std::exception& ex )
 	{
 		cerr << "(LogReader): send error: " << ex.what() << endl;