aiouring/AIOUringTask.cpp at main · wapxmas/aiouring · GitHub

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
//
// Created by sergei on 06.06.22.
//

#include "include/aiouring/AIOUringTask.h"

AIOUringTask::AIOUringTask() {
    taskfd = std::make_shared<int>(eventfd(0, EFD_SEMAPHORE));
}

void AIOUringTask::setUringId(int id) {
    uringId = id;
}

int AIOUringTask::getUringId() const {
    return uringId;
}

std::weak_ptr<int> AIOUringTask::getTaskfd() const {
    return taskfd;
}

void AIOUringTask::setState(const AIOUringTask::TaskState newState) {
    taskState = newState;
}

AIOUringTask::TaskState AIOUringTask::getState() const {
    return taskState;
}

bool AIOUringTask::init() {
    return true;
}

void AIOUringTask::free() {
    if(*taskfd > 0) {
        close(*taskfd);
    }
}

AIOUringTask::TaskFuture AIOUringTask::finally(int io_result) {
    return futureEmpty();
}

AIOUringTask::TaskFuture AIOUringTask::futureEmpty() {
    return std::make_tuple(std::nullopt, std::nullopt);
}

AIOUringTask::TaskFuture AIOUringTask::futureOp(AIOUringOp op) {
    return std::make_tuple(std::optional{op}, std::nullopt);
}

AIOUringTask::TaskFuture AIOUringTask::futureResult(std::any result) {
    return std::make_tuple(std::nullopt, std::optional{result});
}

void AIOUringTask::setUring(io_uring *newRing) {
    ring = newRing;
}

void AIOUringTask::setClassName(std::string className) {
    this->className = std::move(className);
}

std::string AIOUringTask::getClassName() const {
    return className;
}

void AIOUringTask::asyncReset() {
    asyncStep = nullptr;
}

void AIOUringTask::setTaskFinal() {
    finalization = true;
    asyncReset();
}

bool AIOUringTask::isTaskFinal() {
    return finalization;
}