service/resource-manipulation/modules/common/expiryTimer/src/ExpiryTimer_Impl.h

   1 //******************************************************************
   2 //
   3 // Copyright 2015 Samsung Electronics All Rights Reserved.
   4 //
   5 //-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=
   6 //
   7 // Licensed under the Apache License, Version 2.0 (the "License");
   8 // you may not use this file except in compliance with the License.
   9 // You may obtain a copy of the License at
  10 //
  11 //      http://www.apache.org/licenses/LICENSE-2.0
  12 //
  13 // Unless required by applicable law or agreed to in writing, software
  14 // distributed under the License is distributed on an "AS IS" BASIS,
  15 // WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
  16 // See the License for the specific language governing permissions and
  17 // limitations under the License.
  18 //
  19 //-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=
  20
  21 #ifndef _EXPIRY_TIMER_Impl_H_
  22 #define _EXPIRY_TIMER_Impl_H_
  23
  24 // CHECKER_WAIT_TIME : checker thread waits new request for 10 seconds
  25 #define CHECKER_WAIT_TIME 10
  26
  27 #include <iostream>
  28 #include <functional>
  29 #include <map>
  30 #include <mutex>
  31 #include <thread>
  32 #include <chrono>
  33 #include <condition_variable>
  34
  35 class ExpiryTimer_Impl
  36 {
  37 public:
  38     typedef unsigned int Id;
  39     typedef std::function<void*(Id)> TimerCb;
  40
  41     typedef long long DelayMilliSec;
  42     typedef std::chrono::milliseconds milliSeconds;
  43     typedef std::chrono::duration<int64_t, std::milli> milliDelayTime;
  44     typedef std::chrono::duration<int64_t, std::milli> ExpiredTime;
  45
  46 private:
  47     struct TimerCBInfo
  48     {
  49         Id m_id;
  50         TimerCb m_cb;
  51     };
  52
  53 private:
  54    ExpiryTimer_Impl();
  55    ExpiryTimer_Impl(const ExpiryTimer_Impl&);
  56    ExpiryTimer_Impl& operator=(const ExpiryTimer_Impl&);
  57    ~ExpiryTimer_Impl();
  58
  59 public:
  60     static ExpiryTimer_Impl* getInstance();
  61     void destroy();
  62
  63     Id postTimer(DelayMilliSec, TimerCb);
  64     bool cancelTimer(Id);
  65
  66 private:
  67    Id generateID();
  68
  69    void insertTimerCBInfo(ExpiredTime, TimerCb ,Id);
  70    ExpiredTime countExpireTime(milliSeconds);
  71
  72    void createChecker();
  73    void doChecker();
  74
  75    void doExecutor(ExpiredTime);
  76
  77 private:
  78    static ExpiryTimer_Impl* s_instance;
  79    static std::once_flag* mflag;
  80
  81    std::multimap<ExpiredTime, TimerCBInfo> mTimerCBList;
  82
  83    std::thread check;
  84    std::mutex m_mutex;
  85    std::mutex id_mutex;
  86    std::mutex cond_mutex;
  87    std::condition_variable m_cond;
  88
  89 public:
  90    class ExecutorThread
  91    {
  92    public:
  93        ExecutorThread(TimerCBInfo);
  94        ~ExecutorThread();
  95
  96    public:
  97        void executorFunc(TimerCBInfo);
  98
  99    private:
 100        std::thread execute;
 101    };
 102 };
 103
 104 #endif //_EXPIRY_TIMER_Impl_H_