walkero
/
nghttp2
1
0
Fork 0
Code Issues Pull Requests Projects Releases 1 Wiki Activity

shrxp_worker.cc: Use std::unique_ptr for ThreadEventReceiver

This commit is contained in:
Tatsuhiro Tsujikawa 2013-09-24 00:14:55 +09:00
parent b459e42ee5
commit 811173f5c8
1 changed files with 6 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
src/shrpx_worker.cc
View File

@ -26,6 +26,7 @@
#include <unistd.h> #include <unistd.h>
#include <sys/socket.h> #include <sys/socket.h>
#include <memory>
#include <event.h> #include <event.h>
#include <event2/bufferevent.h> #include <event2/bufferevent.h>
@ -34,6 +35,9 @@
#include "shrpx_thread_event_receiver.h" #include "shrpx_thread_event_receiver.h"
#include "shrpx_log.h" #include "shrpx_log.h"
#include "shrpx_spdy_session.h" #include "shrpx_spdy_session.h"
#include "util.h"
using namespace nghttp2;
namespace shrpx { namespace shrpx {
@ -80,13 +84,11 @@ void Worker::run()
DIE(); DIE();
} }
} }
auto receiver = new ThreadEventReceiver(sv_ssl_ctx_, spdy); auto receiver = util::make_unique<ThreadEventReceiver>(sv_ssl_ctx_, spdy);
bufferevent_enable(bev, EV_READ); bufferevent_enable(bev, EV_READ);
bufferevent_setcb(bev, readcb, 0, eventcb, receiver); bufferevent_setcb(bev, readcb, 0, eventcb, receiver.get());
event_base_loop(evbase, 0); event_base_loop(evbase, 0);
delete receiver;
} }
void start_threaded_worker(WorkerInfo *info) void start_threaded_worker(WorkerInfo *info)