From Code to Community: Sponsoring The Perl and Raku Conference 2025 Learn more

SYBER / UniEvent-1.2.14 / xs / FsPoll.xs 

            

              
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
81
82
83
84
85
86
87
88

              
#include <xs/unievent/FsPoll.h>
#include <xs/unievent/Listener.h>
#include <xs/CallbackDispatcher.h>
using namespace xs;
using namespace xs::unievent;
using namespace panda::unievent;
using panda::string;
using panda::string_view;
static PERL_ITHREADS_LOCAL struct {
    Simple on_fs_start = Simple::shared("on_fs_start");
    Simple on_fs_poll  = Simple::shared("on_fs_poll");
} cbn;
struct XSFsPollListener : IFsPollListener, XSListener {
    void on_fs_poll (const FsPollSP& h, const opt<Fs::FStat>& prev, const opt<Fs::FStat>& cur, const std::error_code& err) override {
        call(cbn.on_fs_poll, xs::out(h), xs::out(prev), xs::out(cur), xs::out(err));
    }
    void on_fs_start (const FsPollSP& h, const opt<Fs::FStat>& stat, const std::error_code& err) override {
        call(cbn.on_fs_start, xs::out(h), xs::out(stat), xs::out(err));
    }
};
MODULE = UniEvent::FsPoll                PACKAGE = UniEvent::FsPoll
PROTOTYPES: DISABLE
BOOT {
    Stash stash(__PACKAGE__);
    stash.inherit("UniEvent::Handle");
    stash.add_const_sub("TYPE", Simple(FsPoll::TYPE.name));
    xs::at_perl_destroy([]() {
        cbn.on_fs_poll  = nullptr;
        cbn.on_fs_start = nullptr;
    });
    unievent::register_perl_class(FsPoll::TYPE, stash);
}
FsPollSP create (Sv proto, string_view path, double interval, FsPoll::fs_poll_fn cb, DLoopSP loop = {}) {
    PROTO = proto;
    RETVAL = make_backref<FsPoll>(loop);
    RETVAL->start(path, interval*1000, cb);
}
FsPoll* FsPoll::new (DLoopSP loop = {}) {
    RETVAL = make_backref<FsPoll>(loop);
}
XSCallbackDispatcher* FsPoll::poll_event () : ALIAS(event=1) {
    (void)ix;
    RETVAL = XSCallbackDispatcher::create(THIS->poll_event);
}
void FsPoll::poll_callback (FsPoll::fs_poll_fn cb) : ALIAS(callback=1) {
    (void)ix;
    THIS->poll_event.remove_all();
    if (cb) THIS->poll_event.add(cb);
}
XSCallbackDispatcher* FsPoll::start_event () {
    RETVAL = XSCallbackDispatcher::create(THIS->start_event);
}
void FsPoll::start_callback (FsPoll::fs_start_fn cb) {
    THIS->start_event.remove_all();
    if (cb) THIS->start_event.add(cb);
}
Ref FsPoll::event_listener (Sv lst = Sv(), bool weak = false) {
    RETVAL = event_listener<XSFsPollListener>(THIS, ST(0), lst, weak);
}
void FsPoll::start (string_view path, double interval = 1, FsPoll::fs_poll_fn cb = {}) {
    THIS->start(path, interval*1000, cb);
}
void FsPoll::stop ()
string FsPoll::path ()
MODULE = UniEvent::FsPoll                PACKAGE = UniEvent
PROTOTYPES: DISABLE
FsPollSP fs_poll (string_view path, double interval, FsPoll::fs_poll_fn cb, DLoopSP loop = {}) {
    RETVAL = make_backref<FsPoll>(loop);
    RETVAL->start(path, interval*1000, cb);
}