1bfff6343845ad9ff062c5fd97bb3b9be1053340eDante Russo/* Copyright (c) 2011-2013, The Linux Foundation. All rights reserved. 234ee09551764b045fdc02df754157473125edf60Kevin Tang * 334ee09551764b045fdc02df754157473125edf60Kevin Tang * Redistribution and use in source and binary forms, with or without 434ee09551764b045fdc02df754157473125edf60Kevin Tang * modification, are permitted provided that the following conditions are 534ee09551764b045fdc02df754157473125edf60Kevin Tang * met: 634ee09551764b045fdc02df754157473125edf60Kevin Tang * * Redistributions of source code must retain the above copyright 734ee09551764b045fdc02df754157473125edf60Kevin Tang * notice, this list of conditions and the following disclaimer. 834ee09551764b045fdc02df754157473125edf60Kevin Tang * * Redistributions in binary form must reproduce the above 934ee09551764b045fdc02df754157473125edf60Kevin Tang * copyright notice, this list of conditions and the following 1034ee09551764b045fdc02df754157473125edf60Kevin Tang * disclaimer in the documentation and/or other materials provided 1134ee09551764b045fdc02df754157473125edf60Kevin Tang * with the distribution. 12e14a6c846df2ce4bb1847e4250991f7c52fd793dDante Russo * * Neither the name of The Linux Foundation, nor the names of its 1334ee09551764b045fdc02df754157473125edf60Kevin Tang * contributors may be used to endorse or promote products derived 1434ee09551764b045fdc02df754157473125edf60Kevin Tang * from this software without specific prior written permission. 1534ee09551764b045fdc02df754157473125edf60Kevin Tang * 1634ee09551764b045fdc02df754157473125edf60Kevin Tang * THIS SOFTWARE IS PROVIDED "AS IS" AND ANY EXPRESS OR IMPLIED 1734ee09551764b045fdc02df754157473125edf60Kevin Tang * WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED WARRANTIES OF 1834ee09551764b045fdc02df754157473125edf60Kevin Tang * MERCHANTABILITY, FITNESS FOR A PARTICULAR PURPOSE AND NON-INFRINGEMENT 1934ee09551764b045fdc02df754157473125edf60Kevin Tang * ARE DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT OWNER OR CONTRIBUTORS 2034ee09551764b045fdc02df754157473125edf60Kevin Tang * BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR 2134ee09551764b045fdc02df754157473125edf60Kevin Tang * CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF 2234ee09551764b045fdc02df754157473125edf60Kevin Tang * SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR 2334ee09551764b045fdc02df754157473125edf60Kevin Tang * BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, 2434ee09551764b045fdc02df754157473125edf60Kevin Tang * WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT (INCLUDING NEGLIGENCE 2534ee09551764b045fdc02df754157473125edf60Kevin Tang * OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN 2634ee09551764b045fdc02df754157473125edf60Kevin Tang * IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE. 2734ee09551764b045fdc02df754157473125edf60Kevin Tang * 2834ee09551764b045fdc02df754157473125edf60Kevin Tang */ 29bfff6343845ad9ff062c5fd97bb3b9be1053340eDante Russo#ifndef __MSG_TASK__ 30bfff6343845ad9ff062c5fd97bb3b9be1053340eDante Russo#define __MSG_TASK__ 31e14a6c846df2ce4bb1847e4250991f7c52fd793dDante Russo 32bfff6343845ad9ff062c5fd97bb3b9be1053340eDante Russo#include <stdbool.h> 33bfff6343845ad9ff062c5fd97bb3b9be1053340eDante Russo#include <ctype.h> 34bfff6343845ad9ff062c5fd97bb3b9be1053340eDante Russo#include <string.h> 35bfff6343845ad9ff062c5fd97bb3b9be1053340eDante Russo#include <pthread.h> 36e14a6c846df2ce4bb1847e4250991f7c52fd793dDante Russo 37e14a6c846df2ce4bb1847e4250991f7c52fd793dDante Russonamespace loc_core { 38e14a6c846df2ce4bb1847e4250991f7c52fd793dDante Russo 39bfff6343845ad9ff062c5fd97bb3b9be1053340eDante Russostruct LocMsg { 40bfff6343845ad9ff062c5fd97bb3b9be1053340eDante Russo inline LocMsg() {} 41bfff6343845ad9ff062c5fd97bb3b9be1053340eDante Russo inline virtual ~LocMsg() {} 42bfff6343845ad9ff062c5fd97bb3b9be1053340eDante Russo virtual void proc() const = 0; 43bfff6343845ad9ff062c5fd97bb3b9be1053340eDante Russo inline virtual void log() const {} 44bfff6343845ad9ff062c5fd97bb3b9be1053340eDante Russo}; 45e14a6c846df2ce4bb1847e4250991f7c52fd793dDante Russo 46bfff6343845ad9ff062c5fd97bb3b9be1053340eDante Russoclass MsgTask { 47e14a6c846df2ce4bb1847e4250991f7c52fd793dDante Russopublic: 48bfff6343845ad9ff062c5fd97bb3b9be1053340eDante Russo typedef void* (*tStart)(void*); 49bfff6343845ad9ff062c5fd97bb3b9be1053340eDante Russo typedef pthread_t (*tCreate)(const char* name, tStart start, void* arg); 50bfff6343845ad9ff062c5fd97bb3b9be1053340eDante Russo typedef int (*tAssociate)(); 51bfff6343845ad9ff062c5fd97bb3b9be1053340eDante Russo MsgTask(tCreate tCreator, const char* threadName); 52bfff6343845ad9ff062c5fd97bb3b9be1053340eDante Russo MsgTask(tAssociate tAssociator, const char* threadName); 53bfff6343845ad9ff062c5fd97bb3b9be1053340eDante Russo ~MsgTask(); 54bfff6343845ad9ff062c5fd97bb3b9be1053340eDante Russo void sendMsg(const LocMsg* msg) const; 55bfff6343845ad9ff062c5fd97bb3b9be1053340eDante Russo void associate(tAssociate tAssociator) const; 56e14a6c846df2ce4bb1847e4250991f7c52fd793dDante Russo 57bfff6343845ad9ff062c5fd97bb3b9be1053340eDante Russoprivate: 58bfff6343845ad9ff062c5fd97bb3b9be1053340eDante Russo const void* mQ; 59bfff6343845ad9ff062c5fd97bb3b9be1053340eDante Russo tAssociate mAssociator; 60bfff6343845ad9ff062c5fd97bb3b9be1053340eDante Russo MsgTask(const void* q, tAssociate associator); 61bfff6343845ad9ff062c5fd97bb3b9be1053340eDante Russo static void* loopMain(void* copy); 62bfff6343845ad9ff062c5fd97bb3b9be1053340eDante Russo void createPThread(const char* name); 63bfff6343845ad9ff062c5fd97bb3b9be1053340eDante Russo}; 64e14a6c846df2ce4bb1847e4250991f7c52fd793dDante Russo 65e14a6c846df2ce4bb1847e4250991f7c52fd793dDante Russo} // namespace loc_core 66e14a6c846df2ce4bb1847e4250991f7c52fd793dDante Russo 67bfff6343845ad9ff062c5fd97bb3b9be1053340eDante Russo#endif //__MSG_TASK__ 68