| OLD | NEW |
| 1 // Copyright (c) 2011 The Chromium Authors. All rights reserved. | 1 // Copyright (c) 2011 The Chromium Authors. All rights reserved. |
| 2 // Use of this source code is governed by a BSD-style license that can be | 2 // Use of this source code is governed by a BSD-style license that can be |
| 3 // found in the LICENSE file. | 3 // found in the LICENSE file. |
| 4 | 4 |
| 5 #include "base/message_pump_libevent.h" | 5 #include "base/message_pump_libevent.h" |
| 6 | 6 |
| 7 #include <errno.h> | 7 #include <errno.h> |
| 8 #include <fcntl.h> | 8 #include <fcntl.h> |
| 9 | 9 |
| 10 #include "base/auto_reset.h" | 10 #include "base/auto_reset.h" |
| (...skipping 36 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 47 int flags = fcntl(fd, F_GETFL, 0); | 47 int flags = fcntl(fd, F_GETFL, 0); |
| 48 if (flags == -1) | 48 if (flags == -1) |
| 49 flags = 0; | 49 flags = 0; |
| 50 return fcntl(fd, F_SETFL, flags | O_NONBLOCK); | 50 return fcntl(fd, F_SETFL, flags | O_NONBLOCK); |
| 51 } | 51 } |
| 52 | 52 |
| 53 MessagePumpLibevent::FileDescriptorWatcher::FileDescriptorWatcher() | 53 MessagePumpLibevent::FileDescriptorWatcher::FileDescriptorWatcher() |
| 54 : is_persistent_(false), | 54 : is_persistent_(false), |
| 55 event_(NULL), | 55 event_(NULL), |
| 56 pump_(NULL), | 56 pump_(NULL), |
| 57 watcher_(NULL), |
| 57 ALLOW_THIS_IN_INITIALIZER_LIST(weak_factory_(this)) { | 58 ALLOW_THIS_IN_INITIALIZER_LIST(weak_factory_(this)) { |
| 58 } | 59 } |
| 59 | 60 |
| 60 MessagePumpLibevent::FileDescriptorWatcher::~FileDescriptorWatcher() { | 61 MessagePumpLibevent::FileDescriptorWatcher::~FileDescriptorWatcher() { |
| 61 if (event_) { | 62 if (event_) { |
| 62 StopWatchingFileDescriptor(); | 63 StopWatchingFileDescriptor(); |
| 63 } | 64 } |
| 64 } | 65 } |
| 65 | 66 |
| 66 bool MessagePumpLibevent::FileDescriptorWatcher::StopWatchingFileDescriptor() { | 67 bool MessagePumpLibevent::FileDescriptorWatcher::StopWatchingFileDescriptor() { |
| (...skipping 276 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 343 base::WeakPtr<FileDescriptorWatcher> controller = | 344 base::WeakPtr<FileDescriptorWatcher> controller = |
| 344 static_cast<FileDescriptorWatcher*>(context)->weak_factory_.GetWeakPtr(); | 345 static_cast<FileDescriptorWatcher*>(context)->weak_factory_.GetWeakPtr(); |
| 345 DCHECK(controller.get()); | 346 DCHECK(controller.get()); |
| 346 | 347 |
| 347 MessagePumpLibevent* pump = controller->pump(); | 348 MessagePumpLibevent* pump = controller->pump(); |
| 348 pump->processed_io_events_ = true; | 349 pump->processed_io_events_ = true; |
| 349 | 350 |
| 350 if (flags & EV_WRITE) { | 351 if (flags & EV_WRITE) { |
| 351 controller->OnFileCanWriteWithoutBlocking(fd, pump); | 352 controller->OnFileCanWriteWithoutBlocking(fd, pump); |
| 352 } | 353 } |
| 353 // Check |controller| in case it's been deleted in this callback. | 354 // Check |controller| in case it's been deleted in |
| 355 // controller->OnFileCanWriteWithoutBlocking(). |
| 354 if (controller.get() && flags & EV_READ) { | 356 if (controller.get() && flags & EV_READ) { |
| 355 controller->OnFileCanReadWithoutBlocking(fd, pump); | 357 controller->OnFileCanReadWithoutBlocking(fd, pump); |
| 356 } | 358 } |
| 357 } | 359 } |
| 358 | 360 |
| 359 // Called if a byte is received on the wakeup pipe. | 361 // Called if a byte is received on the wakeup pipe. |
| 360 // static | 362 // static |
| 361 void MessagePumpLibevent::OnWakeup(int socket, short flags, void* context) { | 363 void MessagePumpLibevent::OnWakeup(int socket, short flags, void* context) { |
| 362 base::MessagePumpLibevent* that = | 364 base::MessagePumpLibevent* that = |
| 363 static_cast<base::MessagePumpLibevent*>(context); | 365 static_cast<base::MessagePumpLibevent*>(context); |
| 364 DCHECK(that->wakeup_pipe_out_ == socket); | 366 DCHECK(that->wakeup_pipe_out_ == socket); |
| 365 | 367 |
| 366 // Remove and discard the wakeup byte. | 368 // Remove and discard the wakeup byte. |
| 367 char buf; | 369 char buf; |
| 368 int nread = HANDLE_EINTR(read(socket, &buf, 1)); | 370 int nread = HANDLE_EINTR(read(socket, &buf, 1)); |
| 369 DCHECK_EQ(nread, 1); | 371 DCHECK_EQ(nread, 1); |
| 370 that->processed_io_events_ = true; | 372 that->processed_io_events_ = true; |
| 371 // Tell libevent to break out of inner loop. | 373 // Tell libevent to break out of inner loop. |
| 372 event_base_loopbreak(that->event_base_); | 374 event_base_loopbreak(that->event_base_); |
| 373 } | 375 } |
| 374 | 376 |
| 375 } // namespace base | 377 } // namespace base |
| OLD | NEW |