Skip to content

Commit

Permalink
add test6
Browse files Browse the repository at this point in the history
  • Loading branch information
zhaozhengcoder committed Nov 3, 2018
1 parent 9b557af commit 7f00603
Show file tree
Hide file tree
Showing 20 changed files with 1,240 additions and 4 deletions.
5 changes: 4 additions & 1 deletion example/recipes-master/reactor/s03/EventLoop.cc
Original file line number Diff line number Diff line change
Expand Up @@ -14,7 +14,7 @@
#include "logging/Logging.h"

#include <boost/bind.hpp>

#include <stdio.h>
#include <assert.h>
#include <sys/eventfd.h>

Expand Down Expand Up @@ -101,12 +101,15 @@ void EventLoop::quit()

void EventLoop::runInLoop(const Functor& cb)
{
printf("[debug] runInLoop(): pid = %d, tid = %d\n", getpid(), muduo::CurrentThread::tid());
if (isInLoopThread())
{
printf("[debug] runInLoop() : isInLoopThread \n");
cb();
}
else
{
printf("[debug] runInLoop() : not isInLoopThread \n");
queueInLoop(cb);
}
}
Expand Down
6 changes: 3 additions & 3 deletions example/recipes-master/reactor/s03/EventLoopThread.cc
Original file line number Diff line number Diff line change
Expand Up @@ -8,7 +8,7 @@
#include "EventLoopThread.h"

#include "EventLoop.h"

#include <iostream>
#include <boost/bind.hpp>

using namespace muduo;
Expand All @@ -33,11 +33,11 @@ EventLoop* EventLoopThread::startLoop()
{
assert(!thread_.started());
thread_.start();

{
MutexLockGuard lock(mutex_);
while (loop_ == NULL)
{
std::cout<<"wait..."<<std::endl;
cond_.wait();
}
}
Expand All @@ -48,7 +48,7 @@ EventLoop* EventLoopThread::startLoop()
void EventLoopThread::threadFunc()
{
EventLoop loop;

std::cout<<"notify ... "<<std::endl;
{
MutexLockGuard lock(mutex_);
loop_ = &loop;
Expand Down
25 changes: 25 additions & 0 deletions muduo_tutorial/recipes/reactor/s03/Callbacks.h
Original file line number Diff line number Diff line change
@@ -0,0 +1,25 @@
// excerpts from http://code.google.com/p/muduo/
//
// Use of this source code is governed by a BSD-style license
// that can be found in the License file.
//
// Author: Shuo Chen (chenshuo at chenshuo dot com)

#ifndef MUDUO_NET_CALLBACKS_H
#define MUDUO_NET_CALLBACKS_H

#include <boost/function.hpp>
#include <boost/shared_ptr.hpp>

#include "datetime/Timestamp.h"

namespace muduo
{

// All client visible callbacks go here.

typedef boost::function<void()> TimerCallback;

}

#endif // MUDUO_NET_CALLBACKS_H
58 changes: 58 additions & 0 deletions muduo_tutorial/recipes/reactor/s03/Channel.cc
Original file line number Diff line number Diff line change
@@ -0,0 +1,58 @@
// excerpts from http://code.google.com/p/muduo/
//
// Use of this source code is governed by a BSD-style license
// that can be found in the License file.
//
// Author: Shuo Chen (chenshuo at chenshuo dot com)

#include "Channel.h"
#include "EventLoop.h"
#include "logging/Logging.h"

#include <sstream>

#include <poll.h>

using namespace muduo;

const int Channel::kNoneEvent = 0;
const int Channel::kReadEvent = POLLIN | POLLPRI;
const int Channel::kWriteEvent = POLLOUT;

Channel::Channel(EventLoop *loop, int fdArg)
: loop_(loop),
fd_(fdArg),
events_(0),
revents_(0),
index_(-1)
{
}

void Channel::update()
{
loop_->updateChannel(this);
}

void Channel::handleEvent()
{
if (revents_ & POLLNVAL)
{
LOG_WARN << "Channel::handle_event() POLLNVAL";
}

if (revents_ & (POLLERR | POLLNVAL))
{
if (errorCallback_)
errorCallback_();
}
if (revents_ & (POLLIN | POLLPRI | POLLRDHUP))
{
if (readCallback_)
readCallback_();
}
if (revents_ & POLLOUT)
{
if (writeCallback_)
writeCallback_();
}
}
85 changes: 85 additions & 0 deletions muduo_tutorial/recipes/reactor/s03/Channel.h
Original file line number Diff line number Diff line change
@@ -0,0 +1,85 @@
// excerpts from http://code.google.com/p/muduo/
//
// Use of this source code is governed by a BSD-style license
// that can be found in the License file.
//
// Author: Shuo Chen (chenshuo at chenshuo dot com)

#ifndef MUDUO_NET_CHANNEL_H
#define MUDUO_NET_CHANNEL_H

#include <boost/function.hpp>
#include <boost/noncopyable.hpp>

namespace muduo
{

class EventLoop;

///
/// A selectable I/O channel.
///
/// This class doesn't own the file descriptor.
/// The file descriptor could be a socket,
/// an eventfd, a timerfd, or a signalfd
class Channel : boost::noncopyable
{
public:
typedef boost::function<void()> EventCallback;

Channel(EventLoop *loop, int fd);

void handleEvent();
void setReadCallback(const EventCallback &cb)
{
readCallback_ = cb;
}
void setWriteCallback(const EventCallback &cb)
{
writeCallback_ = cb;
}
void setErrorCallback(const EventCallback &cb)
{
errorCallback_ = cb;
}

int fd() const { return fd_; }
int events() const { return events_; }
void set_revents(int revt) { revents_ = revt; }
bool isNoneEvent() const { return events_ == kNoneEvent; }

void enableReading()
{
events_ |= kReadEvent;
update();
}
// void enableWriting() { events_ |= kWriteEvent; update(); }
// void disableWriting() { events_ &= ~kWriteEvent; update(); }
// void disableAll() { events_ = kNoneEvent; update(); }

// for Poller
int index() { return index_; }
void set_index(int idx) { index_ = idx; }

EventLoop *ownerLoop() { return loop_; }

private:
void update();

static const int kNoneEvent;
static const int kReadEvent;
static const int kWriteEvent;

EventLoop *loop_;
const int fd_;
int events_;
int revents_;
int index_; // used by Poller.

EventCallback readCallback_;
EventCallback writeCallback_;
EventCallback errorCallback_;
};

} // namespace muduo
#endif // MUDUO_NET_CHANNEL_H
Loading

0 comments on commit 7f00603

Please sign in to comment.