Fix time execute

fastogt · Feb 14, 2015 · 1aed3a4 · 1aed3a4
1 parent b401dbd
commit 1aed3a4
Show file tree

Hide file tree

Showing 4 changed files with 17 additions and 3 deletions.
diff --git a/src/core/events/events_info.cpp b/src/core/events/events_info.cpp
@@ -12,6 +12,12 @@ namespace fastoredis
 
         }
 
+        EventInfoBase::EventInfoBase(const common::time64_t time_start, const error_type &er)
+            : base_class(er), time_start_(time_start)
+        {
+
+        }
+
         common::time64_t EventInfoBase::elapsedTime() const
         {
             return common::time::current_mstime() - time_start_;
@@ -101,6 +107,12 @@ namespace fastoredis
 
         }
 
+        CommandRootCompleatedInfo::CommandRootCompleatedInfo(common::time64_t timest, FastoObjectIPtr root, const error_type &er)
+            : base_class(timest, er), root_(root)
+        {
+
+        }
+
         DisonnectInfoRequest::DisonnectInfoRequest(const error_type &er)
             : base_class(er)
         {

diff --git a/src/core/events/events_info.h b/src/core/events/events_info.h
@@ -12,7 +12,7 @@ namespace fastoredis
         {
             typedef common::utils_qt::EventInfo<common::ErrorValueSPtr > base_class;
             EventInfoBase(const error_type &er = error_type());
-
+            EventInfoBase(const common::time64_t time_start, const error_type &er = error_type());
             common::time64_t elapsedTime() const;
 
         private:
@@ -122,6 +122,7 @@ namespace fastoredis
         {
             typedef EventInfoBase base_class;
             CommandRootCompleatedInfo(FastoObjectIPtr root, const error_type &er = error_type());
+            CommandRootCompleatedInfo(common::time64_t timest, FastoObjectIPtr root, const error_type &er = error_type());
 
             FastoObjectIPtr root_;
         };

diff --git a/src/core/idriver.cpp b/src/core/idriver.cpp
@@ -184,15 +184,15 @@ namespace fastoredis
     }
 
     IDriver::RootLocker::RootLocker(IDriver* parent, QObject *reciver, const std::string &text)
-        : parent_(parent), reciver_(reciver)
+        : parent_(parent), reciver_(reciver), tstart_(common::time::current_mstime())
     {
         DCHECK(parent_);
         root_ = createRoot(reciver, text);
     }
 
     IDriver::RootLocker::~RootLocker()
     {
-        events::CommandRootCompleatedEvent::value_type res(root_);
+        events::CommandRootCompleatedEvent::value_type res(tstart_, root_);
         parent_->reply(reciver_, new events::CommandRootCompleatedEvent(parent_, res));
     }
 

diff --git a/src/core/idriver.h b/src/core/idriver.h
@@ -100,6 +100,7 @@ namespace fastoredis
 
             IDriver* parent_;
             QObject* reciver_;
+            const common::time64_t tstart_;
         };
 
         RootLocker make_locker(QObject* reciver, const std::string& text)