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