From 45ebc2ebb137febfea19d23e468f776155122f19 Mon Sep 17 00:00:00 2001
From: Alessio Igor Bogani <alessioigorbogani@gmail.com>
Date: Wed, 7 Feb 2024 12:34:17 +0100
Subject: [PATCH] Add a sleep if write() fails immediately
---
src/Socket2.cpp | 20 ++++++++++++++------
1 file changed, 14 insertions(+), 6 deletions(-)
diff --git a/src/Socket2.cpp b/src/Socket2.cpp
index 6c535ba..7cb26fb 100644
--- a/src/Socket2.cpp
+++ b/src/Socket2.cpp
@@ -532,14 +532,19 @@ void Socket2::write(const Tango::DevVarCharArray *argin)
{
delete argin_data;
- string error_mesg = "Connection refused";
-
close();
open();
+
+ string error_mesg = "Connection refused";
DEBUG_STREAM << error_mesg << endl;
+
set_state( Tango::FAULT );
set_status( error_mesg );
+ sleep( tout.tv_sec );
+ usleep( tout.tv_usec );
+ timerclear( &tout );
+
Tango::Except::throw_exception( "",
error_mesg,
"Socket2::write()");
@@ -586,11 +591,12 @@ void Socket2::write(const Tango::DevVarCharArray *argin)
if( (bytes_total - output_queue_length()) != bytes_to_write )
{
- string error_mesg = "Unable to send request to device";
-
close();
open();
+
+ string error_mesg = "Unable to send request to device";
DEBUG_STREAM << error_mesg << endl;
+
set_state( Tango::FAULT );
set_status( error_mesg );
@@ -997,9 +1003,11 @@ bool Socket2::read(timeval *tv)
close();
open();
- DEBUG_STREAM << "Server shutting down" << endl;
+ string error_mesg = "Server shutting down";
+ DEBUG_STREAM << error_mesg << endl;
+
set_state(Tango::FAULT);
- set_status("Server shutting down");
+ set_status(error_mesg);
sleep( tv->tv_sec );
usleep( tv->tv_usec );
--
GitLab