сделал ключ для управления "постоянством" соединения у "тестера"

Utilities/MBTester/mbtcptester.cc

@@ -199,7 +199,6 @@ int main( int argc, char **argv )
 		mb.connect(ia,port);
 		
 		mb.setForceDisconnect(!persist);
-		mb.setForceDisconnect(true);
 
 		if( verb )
 			cout << "connection: " << (mb.isConnection() ? "YES" : "NO") << endl;

include/modbus/ModbusTCPMaster.h

@@ -27,11 +27,12 @@ class ModbusTCPMaster:
 		{
 			force_disconnect = s;
 		}
-	protected:
 		
 		void reconnect();
 		void cleanInputStream();
 
+	protected:
+		
 		virtual int getNextData( unsigned char* buf, int len );
 		virtual void setChannelTimeout( timeout_t msec );
 		virtual ModbusRTU::mbErrCode sendData( unsigned char* buf, int len );
@@ -40,7 +41,7 @@ class ModbusTCPMaster:
 
 	private:
 		ost::TCPStream* tcp;
-		int nTransaction;
+		ModbusRTU::ModbusData nTransaction;
 		std::queue<unsigned char> qrecv;
 		PassiveTimer ptTimeout;
 		std::string iaddr;

src/Communications/Modbus/ModbusServer.cc

@@ -441,7 +441,6 @@ mbErrCode ModbusServer::processing( ModbusMessage& buf )
 		return res;
 	}
 
-
 	ErrorRetMessage em( buf.addr, buf.func, erUnExpectedPacketType );
 	buf = em.transport_msg();
 	send(buf);
@@ -1226,11 +1225,14 @@ mbErrCode ModbusServer::send( ModbusMessage& msg )
 
 	int len = szModbusHeader+msg.len;
 	if( crcNoCheckit )
+	{
+	    msg.len -= szCRC;
 		len -= szCRC;
+	}
 
 //	printf("send to %02x type=%d size=%d\n",m.dest,(m.type&TypeMask),slen);
 	if( dlog.debugging(Debug::INFO) )
-		dlog[Debug::INFO] << "(send data)(" << len << " bytes): " << msg << endl;
+		dlog[Debug::INFO] << "(send): data(" << len << " bytes): " << msg << endl;
 
 	try
 	{

src/Communications/Modbus/ModbusTCPCore.cc

@@ -58,9 +58,22 @@ mbErrCode ModbusTCPCore::sendData( unsigned char* buf, int len, ost::TCPStream*
 	if( !tcp || !tcp->isConnected() )
 		return erTimeOut;
 
+	try
+	{
 		for( int i=0; i<len; i++ )
 			(*tcp) << buf[i];
 		
 		return erNoError;
+	}
+	catch( ost::SockException& e ) 
+	{
+//		cerr << "(send): " << e.getString() << ": " << e.getSystemErrorString() << endl;
+	}
+	catch(...)
+	{
+//		cerr << "(send): cath..." << endl;
+	}	
+
+	return erHardwareError;
 }
 // -------------------------------------------------------------------------