| OLD | NEW |
| 1 // Copyright 2014 The Chromium Authors. All rights reserved. | 1 // Copyright 2014 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 "mojo/shell/incoming_connection_listener_posix.h" | 5 #include "shell/incoming_connection_listener_posix.h" |
| 6 | 6 |
| 7 #include "base/callback.h" | 7 #include "base/callback.h" |
| 8 #include "base/files/file_path.h" | 8 #include "base/files/file_path.h" |
| 9 #include "base/files/file_util.h" | 9 #include "base/files/file_util.h" |
| 10 #include "base/logging.h" | 10 #include "base/logging.h" |
| 11 #include "base/memory/scoped_ptr.h" | 11 #include "base/memory/scoped_ptr.h" |
| 12 #include "base/sequenced_task_runner.h" | 12 #include "base/sequenced_task_runner.h" |
| 13 #include "base/tracked_objects.h" | 13 #include "base/tracked_objects.h" |
| 14 #include "mojo/shell/domain_socket/net_errors.h" | 14 #include "shell/domain_socket/net_errors.h" |
| 15 #include "mojo/shell/domain_socket/socket_descriptor.h" | 15 #include "shell/domain_socket/socket_descriptor.h" |
| 16 #include "mojo/shell/domain_socket/unix_domain_server_socket_posix.h" | 16 #include "shell/domain_socket/unix_domain_server_socket_posix.h" |
| 17 | 17 |
| 18 namespace mojo { | 18 namespace mojo { |
| 19 namespace shell { | 19 namespace shell { |
| 20 | 20 |
| 21 namespace { | 21 namespace { |
| 22 // TODO(cmasone): Figure out what we should be doing about "authenticating" the | 22 // TODO(cmasone): Figure out what we should be doing about "authenticating" the |
| 23 // process trying to connect. | 23 // process trying to connect. |
| 24 bool Yes(const UnixDomainServerSocket::Credentials& ignored) { | 24 bool Yes(const UnixDomainServerSocket::Credentials& ignored) { |
| 25 return true; | 25 return true; |
| 26 } | 26 } |
| (...skipping 37 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 64 // Call OnListening() before Accept(), so that the delegate is certain to | 64 // Call OnListening() before Accept(), so that the delegate is certain to |
| 65 // hear about listening before a connection might be accepted below. | 65 // hear about listening before a connection might be accepted below. |
| 66 delegate_->OnListening(rv); | 66 delegate_->OnListening(rv); |
| 67 if (rv == net::OK) | 67 if (rv == net::OK) |
| 68 Accept(); | 68 Accept(); |
| 69 } | 69 } |
| 70 | 70 |
| 71 void IncomingConnectionListenerPosix::Accept() { | 71 void IncomingConnectionListenerPosix::Accept() { |
| 72 DCHECK(listen_thread_checker_.CalledOnValidThread()); | 72 DCHECK(listen_thread_checker_.CalledOnValidThread()); |
| 73 int rv = listen_socket_.Accept( | 73 int rv = listen_socket_.Accept( |
| 74 &incoming_socket_, | 74 &incoming_socket_, base::Bind(&IncomingConnectionListenerPosix::OnAccept, |
| 75 base::Bind(&IncomingConnectionListenerPosix::OnAccept, | 75 weak_ptr_factory_.GetWeakPtr())); |
| 76 weak_ptr_factory_.GetWeakPtr())); | |
| 77 | 76 |
| 78 // If rv == net::ERR_IO_PENDING), listen_socket_ will call | 77 // If rv == net::ERR_IO_PENDING), listen_socket_ will call |
| 79 // OnAccept() later, when a connection attempt comes in. | 78 // OnAccept() later, when a connection attempt comes in. |
| 80 if (rv != net::ERR_IO_PENDING) { | 79 if (rv != net::ERR_IO_PENDING) { |
| 81 DVLOG_IF(1, rv == net::OK) << "Accept succeeded immediately"; | 80 DVLOG_IF(1, rv == net::OK) << "Accept succeeded immediately"; |
| 82 OnAccept(rv); | 81 OnAccept(rv); |
| 83 } | 82 } |
| 84 } | 83 } |
| 85 | 84 |
| 86 void IncomingConnectionListenerPosix::OnAccept(int rv) { | 85 void IncomingConnectionListenerPosix::OnAccept(int rv) { |
| 87 DCHECK(listen_thread_checker_.CalledOnValidThread()); | 86 DCHECK(listen_thread_checker_.CalledOnValidThread()); |
| 88 | 87 |
| 89 if (rv != net::OK || incoming_socket_ == kInvalidSocket) { | 88 if (rv != net::OK || incoming_socket_ == kInvalidSocket) { |
| 90 LOG_IF(ERROR, rv != net::OK) << "Accept failed " << net::ErrorToString(rv); | 89 LOG_IF(ERROR, rv != net::OK) << "Accept failed " << net::ErrorToString(rv); |
| 91 PLOG_IF(ERROR, rv == net::OK) << "Socket invalid"; | 90 PLOG_IF(ERROR, rv == net::OK) << "Socket invalid"; |
| 92 } else { | 91 } else { |
| 93 // Passes ownership of incoming_socket_ to delegate_. | 92 // Passes ownership of incoming_socket_ to delegate_. |
| 94 delegate_->OnConnection(incoming_socket_); | 93 delegate_->OnConnection(incoming_socket_); |
| 95 incoming_socket_ = kInvalidSocket; | 94 incoming_socket_ = kInvalidSocket; |
| 96 } | 95 } |
| 97 | 96 |
| 98 // Continue waiting to accept incoming connections... | 97 // Continue waiting to accept incoming connections... |
| 99 Accept(); | 98 Accept(); |
| 100 } | 99 } |
| 101 | 100 |
| 102 } // namespace shell | 101 } // namespace shell |
| 103 } // namespace mojo | 102 } // namespace mojo |
| OLD | NEW |