//===- ThreadAPI.h -- API for threads-----------------------------------------//
//
//                     SVF: Static Value-Flow Analysis
//
// Copyright (C) <2013-2017>  <Yulei Sui>
//

// This program is free software: you can redistribute it and/or modify
// it under the terms of the GNU Affero General Public License as published by
// the Free Software Foundation, either version 3 of the License, or
// (at your option) any later version.

// This program is distributed in the hope that it will be useful,
// but WITHOUT ANY WARRANTY; without even the implied warranty of
// MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
// GNU Affero General Public License for more details.

// You should have received a copy of the GNU Affero General Public License
// along with this program.  If not, see <http://www.gnu.org/licenses/>.
//
//===----------------------------------------------------------------------===//

/*
 * ThreadAPI.h
 *
 *  Created on: Jan 21, 2014
 *      Author: Yulei Sui, dye
 */

#ifndef THREADAPI_H_
#define THREADAPI_H_

#include "SVFIR/SVFValue.h"

namespace SVF
{

class ICFGNode;
class CallICFGNode;
class SVFVar;
class ValVar;
class ObjVar;
class FunObjVar;

/*
 * ThreadAPI class contains interfaces for pthread programs
 */
class ThreadAPI
{

public:
    enum TD_TYPE
    {
        TD_DUMMY = 0,   /// dummy type
        TD_FORK,        /// create a new thread
        TD_JOIN,        /// wait for a thread to join
        TD_DETACH,      /// detach a thread directly instead wait for it to join
        TD_ACQUIRE,     /// acquire a lock
        TD_TRY_ACQUIRE, /// try to acquire a lock
        TD_RELEASE,     /// release a lock
        TD_EXIT,        /// exit/kill a thread
        TD_CANCEL,      /// cancel a thread by another
        TD_COND_WAIT,   /// wait a condition
        TD_COND_SIGNAL, /// signal a condition
        TD_COND_BROADCAST,  /// broadcast a condition
        TD_MUTEX_INI,       /// initial a mutex variable
        TD_MUTEX_DESTROY,   /// initial a mutex variable
        TD_CONDVAR_INI,     /// initial a mutex variable
        TD_CONDVAR_DESTROY, /// initial a mutex variable
        TD_BAR_INIT,        /// Barrier init
        TD_BAR_WAIT,        /// Barrier wait
        HARE_PAR_FOR
    };

    typedef Map<std::string, TD_TYPE> TDAPIMap;

private:
    /// API map, from a string to threadAPI type
    TDAPIMap tdAPIMap;

    /// Constructor
    ThreadAPI ()
    {
        init();
    }

    /// Initialize the map
    void init();

    /// Static reference
    static ThreadAPI* tdAPI;

    /// Get the function type if it is a threadAPI function
    TD_TYPE getType(const FunObjVar* F) const;

public:
    /// Return a static reference
    static ThreadAPI* getThreadAPI()
    {
        if(tdAPI == nullptr)
        {
            tdAPI = new ThreadAPI();
        }
        return tdAPI;
    }

    static void destroy()
    {
        if(tdAPI != nullptr)
        {
            delete tdAPI;
            tdAPI = nullptr;
        }
    }

    /// Return arguments/attributes of pthread_create / hare_parallel_for
    //@{
    /// Return the first argument of the call,
    /// Note that, it is the pthread_t pointer
    const ValVar* getForkedThread(const CallICFGNode *inst) const;
    /// Return the third argument of the call,
    /// Note that, it could be function type or a void* pointer
    const ValVar* getForkedFun(const CallICFGNode *inst) const;

    /// Return the forth argument of the call,
    /// Note that, it is the sole argument of start routine ( a void* pointer )
    const ValVar* getActualParmAtForkSite(const CallICFGNode *inst) const;

    /// Return the formal parm of forked function (the first arg in pthread)
    const SVFVar* getFormalParmOfForkedFun(const FunObjVar* F) const;
    //@}



    /// Return true if this call create a new thread
    //@{
    bool isTDFork(const CallICFGNode *inst) const;
    //@}

    /// Return true if this call wait for a worker thread
    //@{
    bool isTDJoin(const CallICFGNode *inst) const;
    //@}

    /// Return arguments/attributes of pthread_join
    //@{
    /// Return the first argument of the call,
    /// Note that, it is the pthread_t pointer
    const SVFVar* getJoinedThread(const CallICFGNode *inst) const;
    /// Return the send argument of the call,
    /// Note that, it is the pthread_t pointer
    const SVFVar* getRetParmAtJoinedSite(const CallICFGNode *inst) const;
    //@}


    /// Return true if this call exits/terminate a thread
    //@{
    bool isTDExit(const CallICFGNode *inst) const;
    //@}

    /// Return true if this call acquire a lock
    //@{
    bool isTDAcquire(const CallICFGNode* inst) const;
    //@}

    /// Return true if this call release a lock
    //@{
    bool isTDRelease(const CallICFGNode *inst) const;
    //@}

    /// Return lock value
    //@{
    /// First argument of pthread_mutex_lock/pthread_mutex_unlock
    const SVFVar* getLockVal(const ICFGNode *inst) const;
    //@}

    /// Return true if this call waits for a barrier
    //@{
    bool isTDBarWait(const CallICFGNode *inst) const;
    //@}

    void performAPIStat();
    void statInit(Map<std::string, u32_t>& tdAPIStatMap);
};

} // End namespace SVF

#endif /* THREADAPI_H_ */