luo980/uvw
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

code reusing

Browse Source
This commit is contained in:
Michele Caini 2016-07-27 16:47:35 +02:00
parent 762565e95b
commit 228309d9a7
2 changed files with 21 additions and 64 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

64
src/uvw/fs.hpp
View File

@ -173,19 +173,9 @@ using FsEvent = TypedEvent<details::UVFsType, e>;
class Fs final: public Request<Fs, uv_fs_t> {
template<details::UVFsType e>
static void fsGenericCallback(uv_fs_t *req) {
Fs &fs = *(static_cast<Fs*>(req->data));
auto ptr = fs.shared_from_this();
(void)ptr;
fs.reset();
if(req->result) {
int err = req->result;
fs.publish(ErrorEvent{err});
} else {
fs.publish(FsEvent<e>{req->path});
}
auto ptr = reserve(reinterpret_cast<uv_req_t*>(req));
if(req->result) { ptr->publish(ErrorEvent{static_cast<int>(req->result)}); }
else { ptr->publish(FsEvent<e>{req->path}); }
}
static void fsReadCallback(uv_fs_t *req) {
@ -193,52 +183,22 @@ class Fs final: public Request<Fs, uv_fs_t> {
}
static void fsWriteCallback(uv_fs_t *req) {
Fs &fs = *(static_cast<Fs*>(req->data));
auto ptr = fs.shared_from_this();
(void)ptr;
fs.reset();
if(req->result) {
int err = req->result;
fs.publish(ErrorEvent{err});
} else {
fs.publish(FsEvent<Type::WRITE>{req->path, req->result});
}
auto ptr = reserve(reinterpret_cast<uv_req_t*>(req));
if(req->result) { ptr->publish(ErrorEvent{static_cast<int>(req->result)}); }
else { ptr->publish(FsEvent<Type::WRITE>{req->path, req->result}); }
}
template<details::UVFsType e>
static void fsStatCallback(uv_fs_t *req) {
Fs &fs = *(static_cast<Fs*>(req->data));
auto ptr = fs.shared_from_this();
(void)ptr;
fs.reset();
if(req->result) {
int err = req->result;
fs.publish(ErrorEvent{err});
} else {
fs.publish(FsEvent<e>{req->path, req->statbuf});
}
auto ptr = reserve(reinterpret_cast<uv_req_t*>(req));
if(req->result) { ptr->publish(ErrorEvent{static_cast<int>(req->result)}); }
else { ptr->publish(FsEvent<e>{req->path, req->statbuf}); }
}
static void fsReadlinkCallback(uv_fs_t *req) {
Fs &fs = *(static_cast<Fs*>(req->data));
auto ptr = fs.shared_from_this();
(void)ptr;
fs.reset();
if(req->result) {
int err = req->result;
fs.publish(ErrorEvent{err});
} else {
fs.publish(FsEvent<Type::READLINK>{req->path, static_cast<char *>(req->ptr)});
}
auto ptr = reserve(reinterpret_cast<uv_req_t*>(req));
if(req->result) { ptr->publish(ErrorEvent{static_cast<int>(req->result)}); }
else { ptr->publish(FsEvent<Type::READLINK>{req->path, static_cast<char *>(req->ptr)}); }
}
using Request::Request;

21
src/uvw/request.hpp
View File

@ -16,20 +16,17 @@ class Request: public Resource<T, U> {
protected:
using Resource<T, U>::Resource;
static auto reserve(uv_req_t *req) {
auto ptr = static_cast<T*>(req->data)->shared_from_this();
ptr->reset();
return ptr;
}
template<typename R, typename E>
static void defaultCallback(R *req, int status) {
T &res = *(static_cast<T*>(req->data));
auto ptr = res.shared_from_this();
(void)ptr;
res.reset();
if(status) {
res.publish(ErrorEvent{status});
} else {
res.publish(E{});
}
auto ptr = reserve(reinterpret_cast<uv_req_t*>(req));
if(status) { ptr->publish(ErrorEvent{status}); }
else { ptr->publish(E{}); }
}
template<typename F, typename... Args>