1 /* 2 * Copyright (C) 2021 Huawei Device Co., Ltd. 3 * Licensed under the Apache License, Version 2.0 (the "License"); 4 * you may not use this file except in compliance with the License. 5 * You may obtain a copy of the License at 6 * 7 * http://www.apache.org/licenses/LICENSE-2.0 8 * 9 * Unless required by applicable law or agreed to in writing, software 10 * distributed under the License is distributed on an "AS IS" BASIS, 11 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. 12 * See the License for the specific language governing permissions and 13 * limitations under the License. 14 */ 15 16 #include "message_handler.h" 17 18 namespace OHOS { 19 namespace MiscServices { MessageHandler()20MessageHandler::MessageHandler() 21 { 22 } 23 ~MessageHandler()24MessageHandler::~MessageHandler() 25 { 26 std::unique_lock<std::mutex> lock(mMutex); 27 while (!mQueue.empty()) { 28 Message *msg = mQueue.front(); 29 mQueue.pop(); 30 delete msg; 31 msg = nullptr; 32 } 33 } 34 35 /*! Send a message 36 * @param msg a message to be sent 37 * @note the msg pointer should not be freed by the caller 38 */ SendMessage(Message * msg)39void MessageHandler::SendMessage(Message *msg) 40 { 41 { 42 std::unique_lock<std::mutex> lock(mMutex); 43 mQueue.push(msg); 44 } 45 mCV.notify_one(); 46 } 47 48 /*! Get a message 49 * @return a pointer referred to an object of message 50 * @note the returned pointer should be freed by the caller. 51 */ GetMessage()52Message *MessageHandler::GetMessage() 53 { 54 std::unique_lock<std::mutex> lock(mMutex); 55 mCV.wait(lock, [this] { return !this->mQueue.empty(); }); 56 57 Message *msg = (Message *)mQueue.front(); 58 mQueue.pop(); 59 return msg; 60 } 61 62 /*! The single instance of MessageHandler in the service 63 * @return the pointer referred to an object. 64 */ Instance()65MessageHandler *MessageHandler::Instance() 66 { 67 static MessageHandler *handler = nullptr; 68 if (handler == nullptr) { 69 handler = new MessageHandler(); 70 } 71 return handler; 72 } 73 } // namespace MiscServices 74 } // namespace OHOS 75