diff options
author | GENIVI Audio Manager Maintainer <GeniviAMmaintainer@users.noreply.github.com> | 2016-11-22 13:37:35 +0100 |
---|---|---|
committer | GitHub <noreply@github.com> | 2016-11-22 13:37:35 +0100 |
commit | 70f3263edf097b7990fcd2d27d4d47da34b6c0da (patch) | |
tree | f2a5e4482b4893315600fe7bcb822fa5260fb944 /AudioManagerUtilities/include/CAmSerializer.h | |
parent | 0b8e04d293612d119227809fc678c90a39a51d3d (diff) | |
parent | 90f28dc6a890f9732596e6550d138e997b186297 (diff) | |
download | audiomanager-70f3263edf097b7990fcd2d27d4d47da34b6c0da.tar.gz |
Merge pull request #7 from GENIVI/pull_request
talked through in telefone conference
Diffstat (limited to 'AudioManagerUtilities/include/CAmSerializer.h')
-rw-r--r-- | AudioManagerUtilities/include/CAmSerializer.h | 16 |
1 files changed, 10 insertions, 6 deletions
diff --git a/AudioManagerUtilities/include/CAmSerializer.h b/AudioManagerUtilities/include/CAmSerializer.h index 40f2f07..b0cd70e 100644 --- a/AudioManagerUtilities/include/CAmSerializer.h +++ b/AudioManagerUtilities/include/CAmSerializer.h @@ -254,6 +254,8 @@ private: int mPipe[2]; //!< the pipe int mReturnPipe[2]; //!< pipe handling returns + sh_pollHandle_t mHandle; + CAmSocketHandler* mpSocketHandler; std::deque<CAmDelegagePtr> mListDelegatePoiters; //!< intermediate queue to store the pipe results public: @@ -764,6 +766,8 @@ public: CAmSerializer(CAmSocketHandler *iSocketHandler) : mPipe(), // mReturnPipe(),// + mHandle(), + mpSocketHandler(iSocketHandler), mListDelegatePoiters(), // receiverCallbackT(this, &CAmSerializer::receiverCallback), // dispatcherCallbackT(this, &CAmSerializer::dispatcherCallback), // @@ -784,17 +788,17 @@ public: } short event = 0; - sh_pollHandle_t handle; event |= POLLIN; - iSocketHandler->addFDPoll(mPipe[0], event, NULL, &receiverCallbackT, &checkerCallbackT, &dispatcherCallbackT, NULL, handle); + mpSocketHandler->addFDPoll(mPipe[0], event, NULL, &receiverCallbackT, &checkerCallbackT, &dispatcherCallbackT, NULL, mHandle); } ~CAmSerializer() { - close(mPipe[0]); - close(mPipe[1]); - close(mReturnPipe[0]); - close(mReturnPipe[1]); + mpSocketHandler->removeFDPoll(mHandle); + close(mPipe[0]); + close(mPipe[1]); + close(mReturnPipe[0]); + close(mReturnPipe[1]); } }; } /* namespace am */ |