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
89
90
91
92
93
94
95
|
#include <string.h>
#include <sys/types.h>
#include <sys/stat.h>
#include <fcntl.h>
#include "eio.h"
#include "Input.h"
#include "Task.h"
struct cbResults_t {
Balau::Events::Custom evt;
int result, errorno;
};
static int eioDone(eio_req * req) {
cbResults_t * cbResults = (cbResults_t *) req->data;
cbResults->result = req->result;
cbResults->errorno = req->errorno;
cbResults->evt.doSignal();
return 0;
}
struct cbStatsResults_t {
Balau::Events::Custom evt;
int result, errorno;
EIO_STRUCT_STAT statdata;
};
static int eioStatsDone(eio_req * req) {
cbStatsResults_t * cbStatsResults = (cbStatsResults_t *) req->data;
cbStatsResults->result = req->result;
cbStatsResults->errorno = req->errorno;
cbStatsResults->statdata = *(EIO_STRUCT_STAT *) req->ptr2;
cbStatsResults->evt.doSignal();
return 0;
}
Balau::Input::Input(const char * fname) throw (GeneralException) : m_fd(-1), m_size(-1), m_mtime(-1) {
m_name.set("Input(%s)", fname);
cbResults_t cbResults;
eio_req * r = eio_open(fname, O_RDONLY, 0, 0, eioDone, &cbResults);
Assert(r != 0);
Task::yield(&cbResults.evt);
Assert(cbResults.evt.gotSignal());
if (cbResults.result < 0) {
char str[4096];
throw GeneralException(String("Unable to open file ") + m_name + " for reading: " + strerror_r(cbResults.errorno, str, sizeof(str)) + " (err#" + cbResults.errorno + ")");
} else {
m_fd = cbResults.result;
}
cbStatsResults_t cbStatsResults;
r = eio_fstat(m_fd, 0, eioStatsDone, &cbStatsResults);
Assert(r != 0);
Task::yield(&cbStatsResults.evt);
Assert(cbStatsResults.evt.gotSignal());
if (cbStatsResults.result == 0) {
m_size = cbStatsResults.statdata.st_size;
m_mtime = cbStatsResults.statdata.st_mtime;
}
}
void Balau::Input::close() throw (GeneralException) {
if (m_fd < 0)
return;
cbResults_t cbResults;
eio_req * r = eio_close(m_fd, 0, eioDone, &cbResults);
Assert(r != 0);
m_fd = -1;
Task::yield(&cbResults.evt);
Assert(cbResults.evt.gotSignal());
if (cbResults.result < 0) {
char str[4096];
strerror_r(cbResults.errorno, str, sizeof(str));
throw GeneralException(String("Unable to close file ") + m_name + ": " + str);
} else {
m_fd = cbResults.result;
}
}
bool Balau::Input::isClosed() {
return m_fd < 0;
}
const char * Balau::Input::getName() {
return m_name.to_charp();
}
off_t Balau::Input::getSize() {
return m_size;
}
time_t Balau::Input::getMTime() {
return m_mtime;
}
|
