The Perl and Raku Conference 2025: Greenville, South Carolina - June 27-29 Learn more

SYBER / UniEvent-1.2.14 / clib / src / panda / unievent / Pipe.h 

            

              
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

              
#pragma once
#include "Stream.h"
#include "backend/PipeImpl.h"
namespace panda { namespace unievent {
struct IPipeListener     : IStreamListener     {};
struct IPipeSelfListener : IStreamSelfListener {};
struct Pipe : virtual Stream {
    using Mode = backend::PipeImpl::Mode;
    static const HandleType TYPE;
    Pipe (Loop* loop = Loop::default_loop(), bool ipc = false) : _ipc(ipc) {
        panda_log_ctor();
        _init(loop, loop->impl()->new_pipe(this, ipc));
    }
    Pipe (bool ipc) : Pipe(Loop::default_loop(), ipc) {}
    ~Pipe () { panda_log_dtor(); }
    const HandleType& type () const override;
    bool ipc () const { return _ipc; }
    virtual excepted<void, ErrorCode> open (fd_t, int mode, Ownership = Ownership::TRANSFER);
    virtual excepted<void, ErrorCode> bind (string_view name);
    virtual PipeConnectRequestSP connect (const PipeConnectRequestSP& req);
    /*INL*/ PipeConnectRequestSP connect (const string& name, connect_fn callback = nullptr);
    virtual void pending_instances (int count);
    virtual int  pending_count     () const;
    excepted<string, ErrorCode> sockname () const { return handle_fd_excepted(impl()->sockname()); }
    excepted<string, ErrorCode> peername () const { return handle_fd_excepted(impl()->peername()); }
     
    excepted<net::SockAddr, ErrorCode> sockaddr () const override;
    excepted<net::SockAddr, ErrorCode> peeraddr () const override;
    virtual excepted<void, ErrorCode> chmod (int mode);
    static excepted<std::pair<PipeSP,PipeSP>, ErrorCode> pair (const LoopSP& = Loop::default_loop());
    static excepted<std::pair<PipeSP,PipeSP>, ErrorCode> pair (const PipeSP&, const PipeSP&);
protected:
    StreamSP create_connection () override;
private:
    friend PipeConnectRequest;
    bool _ipc;
    backend::PipeImpl* impl () const { return static_cast<backend::PipeImpl*>(BackendHandle::impl()); }
    HandleImpl* new_impl () override;
};
struct PipeConnectRequest : ConnectRequest, AllocatedObject<PipeConnectRequest> {
    string name;
    PipeConnectRequest (const string& name, Stream::connect_fn callback = nullptr)
        : ConnectRequest(callback), name(name) {}
private:
    friend Pipe; friend StreamFilter;
    Pipe* handle;
    void set (Pipe* h) {
        handle = h;
        ConnectRequest::set(h);
    }
    void exec             () override;
    void finalize_connect ();
};
inline PipeConnectRequestSP Pipe::connect (const string& name, connect_fn callback) {
    PipeConnectRequestSP connect_request = new PipeConnectRequest(name, callback);
    return connect(connect_request);
}
}}