complextask.h

Go to the documentation of this file.

 
 
#pragma once
// This header file is auto-generated!
// Do not make changes to this file or they will be overwritten.
// clang-format off
#include <cx/obj.h>
#include <cx/struct.h>
#include "task.h"
#include <cx/thread/rwlock.h>
#include <cx/taskqueue/requires/taskrequires.h>
#include <cx/taskqueue/resource/taskresource.h>
 
CX_C_BEGIN
 
typedef struct TaskQueue TaskQueue;
typedef struct TaskQueue_WeakRef TaskQueue_WeakRef;
typedef struct TQWorker TQWorker;
typedef struct TQWorker_WeakRef TQWorker_WeakRef;
typedef struct ComplexTask ComplexTask;
typedef struct ComplexTask_WeakRef ComplexTask_WeakRef;
typedef struct ComplexTask ComplexTask;
typedef struct ComplexTask_WeakRef ComplexTask_WeakRef;
typedef struct TRGate TRGate;
typedef struct TRGate_WeakRef TRGate_WeakRef;
typedef struct ComplexTaskQueue ComplexTaskQueue;
typedef struct ComplexTaskQueue_WeakRef ComplexTaskQueue_WeakRef;
typedef struct TaskControl TaskControl;
typedef struct ComplexTask ComplexTask;
typedef struct ComplexTask_WeakRef ComplexTask_WeakRef;
saDeclarePtr(ComplexTask);
saDeclarePtr(ComplexTask_WeakRef);
#define _sti_ComplexTask _sti_object
#define SType_ComplexTask ComplexTask*
#define STStorageType_ComplexTask ComplexTask*
#define STypeArg_ComplexTask(type, val) stgeneric(object, (ObjInst*)objInstCheckClass(ComplexTask, val))
#define STypeArgPtr_ComplexTask(type, val) (stgeneric*)objInstCheckClassPtr(ComplexTask, val)
#define STypeCheckedArg_ComplexTask(type, val)    stType(type), stArg(type, val)
#define STypeCheckedPtrArg_ComplexTask(type, val) stType(type), stArgPtr(type, val)
 
#define ctaskDependOn(task, dep) ctaskRequireTask(task, dep, false)
#define ctaskWaitFor(task, dep) ctaskRequireTask(task, dep, true)
#define ctaskDependOnTimeout(task, dep, timeout) ctaskRequireTaskTimeout(task, dep, false, timeout)
#define ctaskWaitForTimeout(task, dep, timeout) ctaskRequireTaskTimeout(task, dep, true, timeout)
enum ComplexTaskRunResultEnum {
    TASK_Result_Schedule = TASK_Result_Basic_Count,     
    TASK_Result_Schedule_Progress,                      
    TASK_Result_Defer,                                  
    TASK_Result_Defer_Progress,                         
    TASK_Result_Complex_Count
};
enum ComplexTaskFlagsEnum {
    TASK_Cancel_Cascade = 0x01,         
    TASK_Retain_Requires = 0x02,        
    TASK_Soft_Requires = 0x04,          
    TASK_Cancel_Expired = 0x08,         
    TASK_Require_Failed = 0xa0,         
};
enum ComplexTaskInternalFlagsEnum {
    TASK_INTERNAL_Owns_Resources = 0x01,    
};
 
typedef struct ComplexTask_ClassIf {
    ObjIface* _implements;
    ObjIface* _parent;
    size_t _size;
 
    uint32 (*run)(_In_ void* self, _In_ TaskQueue* tq, _In_ TQWorker* worker, _Inout_ TaskControl* tcon);
    void (*runCancelled)(_In_ void* self, _In_ TaskQueue* tq, _In_ TQWorker* worker);
    bool (*cancel)(_In_ void* self);
    bool (*reset)(_In_ void* self);
    bool (*wait)(_In_ void* self, int64 timeout);
    intptr (*cmp)(_In_ void* self, void* other, uint32 flags);
    uint32 (*hash)(_In_ void* self, uint32 flags);
} ComplexTask_ClassIf;
extern ComplexTask_ClassIf ComplexTask_ClassIf_tmpl;
 
typedef struct ComplexTask {
    union {
        ComplexTask_ClassIf* _;
        void* _is_ComplexTask;
        void* _is_Task;
        void* _is_BasicTask;
        void* _is_ObjInst;
    };
    ObjClassInfo* _clsinfo;
    atomic(uintptr) _ref;
    atomic(ptr) _weakref;
 
    atomic(uint32) state;        
    void* logctx;
    string name;        
    int64 last;        
    cchain oncomplete;        
    int64 nextrun;        
    int64 lastprogress;        
    Weak(ComplexTaskQueue)* lastq;        
    sa_TaskRequires _requires;        
    uint16 flags;        
    uint16 _intflags;        
    atomic(uint32) _advcount;        
} ComplexTask;
extern ObjClassInfo ComplexTask_clsinfo;
#define ComplexTask(inst) objInstCheckClass(ComplexTask, inst)
#define ComplexTaskNone ((ComplexTask*)NULL)
 
typedef struct ComplexTask_WeakRef {
    union {
        ObjInst* _inst;
        void* _is_ComplexTask_WeakRef;
        void* _is_Task_WeakRef;
        void* _is_BasicTask_WeakRef;
        void* _is_ObjInst_WeakRef;
    };
    atomic(uintptr) _ref;
    RWLock _lock;
} ComplexTask_WeakRef;
#define ComplexTask_WeakRef(inst) objWeakRefCheckClass(ComplexTask, inst)
 
void ComplexTask_requireTask(_In_ ComplexTask* self, _In_ Task* dep, bool failok);
#define ctaskRequireTask(self, dep, failok) ComplexTask_requireTask(ComplexTask(self), Task(dep), failok)
 
void ComplexTask_requireTaskTimeout(_In_ ComplexTask* self, _In_ Task* dep, bool failok, int64 timeout);
#define ctaskRequireTaskTimeout(self, dep, failok, timeout) ComplexTask_requireTaskTimeout(ComplexTask(self), Task(dep), failok, timeout)
 
void ComplexTask_requireResource(_In_ ComplexTask* self, _In_ TaskResource* res);
#define ctaskRequireResource(self, res) ComplexTask_requireResource(ComplexTask(self), TaskResource(res))
 
void ComplexTask_requireResourceTimeout(_In_ ComplexTask* self, _In_ TaskResource* res, int64 timeout);
#define ctaskRequireResourceTimeout(self, res, timeout) ComplexTask_requireResourceTimeout(ComplexTask(self), TaskResource(res), timeout)
 
void ComplexTask_requireGate(_In_ ComplexTask* self, _In_ TRGate* gate);
#define ctaskRequireGate(self, gate) ComplexTask_requireGate(ComplexTask(self), TRGate(gate))
 
void ComplexTask_requireGateTimeout(_In_ ComplexTask* self, _In_ TRGate* gate, int64 timeout);
#define ctaskRequireGateTimeout(self, gate, timeout) ComplexTask_requireGateTimeout(ComplexTask(self), TRGate(gate), timeout)
 
void ComplexTask_require(_In_ ComplexTask* self, _In_ TaskRequires* req);
#define ctaskRequire(self, req) ComplexTask_require(ComplexTask(self), TaskRequires(req))
 
bool ComplexTask_advance(_In_ ComplexTask* self);
#define ctaskAdvance(self) ComplexTask_advance(ComplexTask(self))
 
uint32 ComplexTask_checkRequires(_In_ ComplexTask* self, bool updateProgress, _Out_opt_ int64* expires);
#define ctaskCheckRequires(self, updateProgress, expires) ComplexTask_checkRequires(ComplexTask(self), updateProgress, expires)
 
void ComplexTask_cancelRequires(_In_ ComplexTask* self);
#define ctaskCancelRequires(self) ComplexTask_cancelRequires(ComplexTask(self))
 
bool ComplexTask_acquireRequires(_In_ ComplexTask* self, sa_TaskRequires* acquired);
#define ctaskAcquireRequires(self, acquired) ComplexTask_acquireRequires(ComplexTask(self), acquired)
 
bool ComplexTask_releaseRequires(_In_ ComplexTask* self, sa_TaskRequires resources);
#define ctaskReleaseRequires(self, resources) ComplexTask_releaseRequires(ComplexTask(self), resources)
 
bool ComplexTask_advanceCallback(stvlist* cvars, stvlist* args);
#define ctaskAdvanceCallback(cvars, args) ComplexTask_advanceCallback(cvars, args)
 
// bool ctask_setState(ComplexTask* self, uint32 newstate);
#define ctask_setState(self, newstate) BasicTask__setState(BasicTask(self), newstate)
 
#define ctaskRun(self, tq, worker, tcon) (self)->_->run(ComplexTask(self), TaskQueue(tq), TQWorker(worker), tcon)
#define ctaskRunCancelled(self, tq, worker) (self)->_->runCancelled(ComplexTask(self), TaskQueue(tq), TQWorker(worker))
// bool ctaskCancel(ComplexTask* self);
#define ctaskCancel(self) (self)->_->cancel(ComplexTask(self))
// bool ctaskReset(ComplexTask* self);
#define ctaskReset(self) (self)->_->reset(ComplexTask(self))
#define ctaskWait(self, timeout) (self)->_->wait(ComplexTask(self), timeout)
// intptr ctaskCmp(ComplexTask* self, ComplexTask* other, uint32 flags);
#define ctaskCmp(self, other, flags) (self)->_->cmp(ComplexTask(self), other, flags)
// uint32 ctaskHash(ComplexTask* self, uint32 flags);
#define ctaskHash(self, flags) (self)->_->hash(ComplexTask(self), flags)
 
CX_C_END