|
struct ibv_comp_channel * | Channel () const |
|
virtual const char * | ClassName () const |
| Returns class name of the object instance. More...
|
|
void | CloseThread () |
|
virtual bool | CompatibleClass (const std::string &clname) const |
|
bool | IsFastModus () const |
|
ComplQueue * | MakeCQ () |
|
| Thread (dabc::Reference parent, const std::string &name, dabc::Command cmd, ContextRef ctx) |
|
virtual | ~Thread () |
|
bool | Execute (Command cmd, double tmout=-1) |
|
void | FireDoNothingEvent () |
|
double | GetStopTimeout () const |
|
bool | IsItself () const |
|
virtual void * | MainLoop () |
|
virtual void | Print (int lvl=0) |
| Print thread content on debug output. More...
|
|
void | RunEventLoop (double tmout=1.) |
| Runs thread event loop for specified time. More...
|
|
void | SetPriority (int prio=0) |
|
void | SetStopTimeout (double timeout_sec) |
|
bool | SingleLoop (unsigned workerid=0, double tmout=-1) |
| Processes single event from the thread queue. More...
|
|
bool | Start (double timeout_sec=-1., bool real_thread=true) |
|
bool | Stop (double timeout_sec=10) |
|
bool | Sync (double timeout_sec=-1) |
|
| Thread (Reference parent, const std::string &name, Command cmd=nullptr) |
|
unsigned | TotalNumberOfEvents () |
| Return total number of all events in the queues. More...
|
|
bool | AddChild (Object *child, bool withmutex=true) throw () |
| Add object to list of child objects, thread safe More...
|
|
bool | AddChildAt (Object *child, unsigned pos, bool withmutex=true) |
| Add object to list of child objects at specified position. More...
|
|
virtual void | BuildFieldsMap (RecordFieldsMap *cont) |
| Fill fields map, which is relevant for the object Objects hierarchy produced from dabc::Manager. More...
|
|
virtual bool | Find (ConfigIO &cfg) |
| Method to locate object in xml file. More...
|
|
Object * | FindChild (const char *name) const |
| returns pointer on child object with given name More...
|
|
Reference | FindChildRef (const char *name, bool force=false) const throw () |
| returns reference on child object with given name More...
|
|
bool | GetAllChildRef (ReferencesVector *vect) const |
|
Object * | GetChild (unsigned n) const |
| returns pointer on child object More...
|
|
Reference | GetChildRef (unsigned n) const |
| returns reference on child object More...
|
|
Reference | GetFolder (const std::string &name, bool force=false) throw () |
| Return folder of specified name, no special symbols allowed. More...
|
|
const char * | GetName () const |
| Returns name of the object, thread safe More...
|
|
Object * | GetParent () const |
| Returns pointer on parent object, thread safe More...
|
|
Reference | GetParentRef () const |
|
bool | IsChildsHidden () const |
| Return true if object wants to hide childs from hierarchy scan, thread safe More...
|
|
bool | IsHidden () const |
| Return true if object wants to be hidden from hierarchy scan, thread safe More...
|
|
bool | IsLogging () const |
| Return true if object selected for logging, thread safe More...
|
|
bool | IsName (const char *str) const |
| Checks if object name is same as provided string, thread safe More...
|
|
bool | IsName (const char *str, int len) const |
| Checks if object name is same as provided, thread safe More...
|
|
bool | IsName (const std::string &str) const |
| Checks if object name is same as provided string, thread safe More...
|
|
bool | IsNameMatch (const std::string &mask) const |
| Check if object name match to the mask. More...
|
|
bool | IsOwner () const |
| Returns true if object is owner of its children, thread safe More...
|
|
bool | IsParent (Object *obj) const |
| Checks if specified argument is in the list of object parents. More...
|
|
bool | IsTopXmlLevel () const |
| Return true if object should be searched in the top level of the xml file, thread safe More...
|
|
std::string | ItemName (bool compact=true) const |
| Produce string, which can be used as name argument in dabc::mgr.FindItem(name) call. More...
|
|
unsigned | NumChilds () const |
| returns number of child objects More...
|
|
| Object (const std::string &name, unsigned flags=flIsOwner) |
| Resolve problem with child-parent mutex locking. More...
|
|
| Object (Reference parent, const std::string &name, unsigned flags=flIsOwner) |
|
bool | RemoveChild (Object *child, bool cleanup=true) throw () |
| Detach child from parent object If cleanup==true and parent is owner of child, child will be destroyed. More...
|
|
bool | RemoveChildAt (unsigned n, bool cleanup=true) throw () |
| Detach child object from parent at specified position If cleanup==true and object is owner of child, child will be destroyed. More...
|
|
bool | RemoveChilds (bool cleanup=true) |
| Remove all childs. More...
|
|
void | SetLogging (bool on=true) |
| Sets logging flag, thread safe More...
|
|
virtual | ~Object () |
|
|
virtual void | _Fire (const dabc::EventId &evnt, int nq) |
|
virtual int | ExecuteThreadCommand (dabc::Command cmd) |
|
virtual void | ProcessExtraThreadEvent (const dabc::EventId &) |
| Method to process events which are not processed by Thread class itself Should be used in derived classes for their events processing. More...
|
|
virtual bool | WaitEvent (dabc::EventId &evid, double tmout) |
|
virtual void | WorkersSetChanged () |
| Virtual method, called from thread context to inform that number of workers are changed. More...
|
|
virtual bool | _DoDeleteItself () |
| This method is called at the moment when DecReference think that object can be destroyed and wants to return true. More...
|
|
bool | _GetNextEvent (EventId &) |
|
void | _PushEvent (const EventId &arg, int nq) |
|
unsigned | _TotalNumberOfEvents () |
|
bool | AddWorker (Reference ref, bool sync=true) |
| Internal DABC method, Add worker to thread; reference-safe Reference safe means - it is safe to call it as long as reference on thread is exists We use here reference on the worker to ensure that it does not disappear meanwhile. More...
|
|
void | ChangeRecursion (unsigned id, bool inc) |
| Method which allows to control recursion of each worker. More...
|
|
double | CheckTimeouts (bool forcerecheck=false) |
|
int | CheckWorkerCanBeHalted (unsigned id, unsigned request=0, Command cmd=nullptr) |
| Internal DABC method, used to verify if worker can be halted now while recursion is over Request indicates that halt action is requested : actDestroy = 1 or actHalt = 2. More...
|
|
void | Fire (const EventId &arg, int nq) |
|
bool | HaltWorker (Worker *proc) |
| Halt worker - stops any execution, break recursion. More...
|
|
void | IncWorkerFiredEvents (Worker *work) |
|
bool | InvokeWorkerDestroy (Worker *work) |
| Cleanup object asynchronously. More...
|
|
bool | IsTemporaryThread () const |
| Returns true is this is temporary thread for command execution. More...
|
|
unsigned | NumWorkers () |
| Returns actual number of workers. More...
|
|
virtual void | ObjectCleanup () |
| Cleanup thread that manager is allowed to delete it. More...
|
|
void | ProcessEvent (const EventId &) |
|
void | ProcessNoneEvent () |
|
int | RunCommandInTheThread (Worker *caller, Worker *dest, Command cmd) |
|
void | RunExplicitLoop () |
|
virtual void | RunnableCancelled () |
|
bool | SetExplicitLoop (Worker *work) |
|
Mutex * | ThreadMutex () const |
|
void | WorkerAddonChanged (Worker *work, bool assign=true) |
| Called when worker addon changed on the fly. More...
|
|
virtual void | _ChildsChanged () |
| Method called when new childs are add or old are removed. More...
|
|
bool | _IsNormalState () |
| Same as IsNormalState() but without mutex lock - user should lock mutex himself. More...
|
|
virtual Object * | CreateInstance (const std::string &name) |
| Method used to create new item to be placed as child of the object. More...
|
|
void | DeleteThis () |
| Method should be used by the object to delete itself. More...
|
|
virtual bool | DestroyByOwnThread () |
| Internal DABC method, used to activate object cleanup via object thread Returns: false - object cannot be cleanup by the thread, true - thread guarantees that DestroyCalledFromOwnThread() will be called from thread context. More...
|
|
bool | DestroyCalledFromOwnThread () |
| Internal DABC method, should be called by thread which was requested to destroy object. More...
|
|
void | FillFullName (std::string &fullname, Object *upto, bool exclude_top_parent=false) const |
| Method used to produce full item name,. More...
|
|
bool | GetFlag (unsigned fl) const |
| Return value of selected flag, not thread safe
More...
|
|
bool | IsNormalState () |
| Return true if object is in normal state. More...
|
|
unsigned | NumReferences () |
| Return number of references on the object. More...
|
|
| Object (const ConstructorPair &pair, unsigned flags=flIsOwner) |
|
virtual void | ObjectDestroyed (Object *) |
| Method called by the manager when registered dependent object is destroyed Should be used in user class to clear all references on the object to let destroy it. More...
|
|
Mutex * | ObjectMutex () const |
| Returns mutex, used for protection of Object data members. More...
|
|
void | SetAutoDestroy (bool on=true) |
| Set autodestroy flag for the object Once enabled, object will be destroyed when last reference will be cleared. More...
|
|
void | SetFlag (unsigned fl, bool on=true) |
| Change value of selected flag, not thread safe
More...
|
|
void | SetName (const char *name) |
| Changes object name. More...
|
|
void | SetNameDirect (const char *name) |
| Changes object name disregard of existing references. More...
|
|
void | SetOwner (bool on=true) |
| Specifies if object will be owner of its new childs. More...
|
|
void | UseCurrentAsSelf () |
|
void | Cancel () |
| Try to cancel thread execution. More...
|
|
bool | GetAffinity (bool actual, char *buf, unsigned maxbuf) |
| Provides thread affinity in form of "xxxooooo". More...
|
|
Thread_t | Id () const |
|
bool | IsItself () const |
| Returns true if called from thread context. More...
|
|
void | Join () |
| Join thread - method waits until thread execution is completed. More...
|
|
void | Kill (int sig=9) |
| Kill thread with specified signal. More...
|
|
| PosixThread () |
|
bool | SetAffinity (const char *aff) |
| Sets affinity mask for the thread. More...
|
|
void | SetPriority (int prio) |
| Change thread priority. More...
|
|
void | SetThreadName (const char *thrdname) |
| Set thread name, which can be seen from htop. More...
|
|
void | Start (Runnable *run) |
| Start thread with provided runnable. More...
|
|
void | Start (StartRoutine *func, void *args) |
| Start thread with provided routine and call arguments. More...
|
|
virtual | ~PosixThread () |
|
virtual | ~Runnable () |
|
|
enum | EEvents {
evntCheckTmoutWorker = 1
, evntCheckTmoutAddon
, evntCleanupThrd
, evntDoNothing
,
evntStopThrd
, evntLastThrd
, evntUser = 10000
} |
|
enum | EPriority { priorityHighest = 0
, priorityNormal = 1
, priorityLowest = -1
} |
|
static ConstructorPair | MakePair (const std::string &fullname, bool withmanager=true) |
| Internal DABC method, used to produce pair - object parent and object name, which is typically should be used as argument in class constructor. More...
|
|
static ConstructorPair | MakePair (Object *prnt, const std::string &fullname, bool withmanager=true) |
| Internal DABC method, used to produce pair - object parent and object name, which is typically should be used as argument in class constructor. More...
|
|
static ConstructorPair | MakePair (Reference prnt, const std::string &fullname, bool withmanager=true) |
| Internal DABC method, used to produce pair - object parent and object name, which is typically should be used as argument in class constructor. More...
|
|
static bool | GetDfltAffinity (char *buf, unsigned maxbuf) |
| Returns default affinity mask in form "xxxooosss". More...
|
|
static Thread_t | Self () |
|
static bool | SetDfltAffinity (const char *aff=nullptr) |
| Sets default affinity for next threads to be created and for main process. More...
|
|
static unsigned | fThreadInstances = 0 |
|
static cpu_set_t | fDfltSet |
| default affinity for new thread More...
|
|
static cpu_set_t | fSpecialSet |
| set of processors, which can be used for special threads More...
|
|
VERBS thread.
Definition at line 46 of file Thread.h.