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
|
#pragma once
#ifdef _WIN32
#include <windows.h>
#endif
#include <Handle.h>
#include <TaskMan.h>
#include <Task.h>
#include <StacklessTask.h>
#include <Printer.h>
namespace Balau {
class Selectable : public Handle {
public:
~Selectable();
virtual ssize_t read(void * buf, size_t count) throw (GeneralException);
virtual ssize_t write(const void * buf, size_t count) throw (GeneralException);
virtual bool isClosed();
virtual bool isEOF();
bool gotR() { return m_evtR->gotSignal(); }
bool gotW() { return m_evtW->gotSignal(); }
class SelectableEvent : public Events::BaseEvent {
public:
SelectableEvent(int fd, int evt = ev::READ | ev::WRITE) : m_task(NULL), m_evtType(evt), m_fd(fd) { Printer::elog(E_SELECT, "Got a new SelectableEvent at %p", this); m_evt.set<SelectableEvent, &SelectableEvent::evt_cb>(this); m_evt.set(fd, evt); }
virtual ~SelectableEvent() { Printer::elog(E_SELECT, "Destroying a SelectableEvent at %p", this); m_evt.stop(); }
void stop() { Printer::elog(E_SELECT, "Stopping a SelectableEvent at %p", this); resetMaybe(); m_evt.stop(); }
private:
void evt_cb(ev::io & w, int revents) { Printer::elog(E_SELECT, "Got a libev callback on a SelectableEvent at %p", this); doSignal(); }
virtual void gotOwner(Task * task);
virtual bool relaxed() { return true; }
ev::io m_evt;
int m_evtType;
int m_fd;
Task * m_task = NULL;
};
protected:
Selectable() { }
void setFD(int fd) throw (GeneralException);
void internalClose() { m_fd = -1; }
int getFD() { return m_fd; }
virtual ssize_t recv(int sockfd, void *buf, size_t len, int flags) = 0;
virtual ssize_t send(int sockfd, const void *buf, size_t len, int flags) = 0;
SelectableEvent * m_evtR = NULL, * m_evtW = NULL;
private:
int m_fd = -1;
};
};
|
