[XrdCl] Make the AsyncSocketHandler remember time of last activity

xrootd · Jan 24, 2014 · ec36aa4 · ec36aa4
1 parent df4eaff
commit ec36aa4
Show file tree

Hide file tree

Showing 2 changed files with 13 additions and 1 deletion.
diff --git a/src/XrdCl/XrdClAsyncSocketHandler.cc b/src/XrdCl/XrdClAsyncSocketHandler.cc
@@ -58,6 +58,7 @@ namespace XrdCl
 
     pSocket = new Socket();
     pIncHandler = std::make_pair( (IncomingMsgHandler*)0, false );
+    pLastActivity = time(0);
   }
 
   //----------------------------------------------------------------------------
@@ -75,7 +76,7 @@ namespace XrdCl
   Status AsyncSocketHandler::Connect( time_t timeout )
   {
     Log *log = DefaultEnv::GetLog();
-    pConnectionStarted = ::time(0);
+    pLastActivity = pConnectionStarted = ::time(0);
     pConnectionTimeout = timeout;
 
     //--------------------------------------------------------------------------
@@ -166,6 +167,8 @@ namespace XrdCl
   //----------------------------------------------------------------------------
   void AsyncSocketHandler::Event( uint8_t type, XrdCl::Socket */*socket*/ )
   {
+    pLastActivity = time(0);
+
     //--------------------------------------------------------------------------
     // Read event
     //--------------------------------------------------------------------------

diff --git a/src/XrdCl/XrdClAsyncSocketHandler.hh b/src/XrdCl/XrdClAsyncSocketHandler.hh
@@ -124,6 +124,14 @@ namespace XrdCl
         pSocketDomain = domain;
       }
 
+      //------------------------------------------------------------------------
+      //! Get timestamp of last registered socket activity
+      //------------------------------------------------------------------------
+      time_t GetLastActivity()
+      {
+        return pLastActivity;
+      }
+
     private:
 
       //------------------------------------------------------------------------
@@ -211,6 +219,7 @@ namespace XrdCl
       uint32_t                       pIncMsgSize;
       uint32_t                       pOutMsgSize;
       int                            pSocketDomain;
+      time_t                         pLastActivity;
   };
 }