mirror of
https://github.com/zeromq/libzmq.git
synced 2024-12-29 00:32:34 +08:00
8fe5b54b8a
Solution: refactor it
216 lines
6.5 KiB
C++
216 lines
6.5 KiB
C++
/*
|
|
Copyright (c) 2007-2016 Contributors as noted in the AUTHORS file
|
|
|
|
This file is part of libzmq, the ZeroMQ core engine in C++.
|
|
|
|
libzmq is free software; you can redistribute it and/or modify it under
|
|
the terms of the GNU Lesser General Public License (LGPL) as published
|
|
by the Free Software Foundation; either version 3 of the License, or
|
|
(at your option) any later version.
|
|
|
|
As a special exception, the Contributors give you permission to link
|
|
this library with independent modules to produce an executable,
|
|
regardless of the license terms of these independent modules, and to
|
|
copy and distribute the resulting executable under terms of your choice,
|
|
provided that you also meet, for each linked independent module, the
|
|
terms and conditions of the license of that module. An independent
|
|
module is a module which is not derived from or based on this library.
|
|
If you modify this library, you must extend this exception to your
|
|
version of the library.
|
|
|
|
libzmq is distributed in the hope that it will be useful, but WITHOUT
|
|
ANY WARRANTY; without even the implied warranty of MERCHANTABILITY or
|
|
FITNESS FOR A PARTICULAR PURPOSE. See the GNU Lesser General Public
|
|
License for more details.
|
|
|
|
You should have received a copy of the GNU Lesser General Public License
|
|
along with this program. If not, see <http://www.gnu.org/licenses/>.
|
|
*/
|
|
|
|
#include "precompiled.hpp"
|
|
|
|
#include "vmci_listener.hpp"
|
|
|
|
#if defined ZMQ_HAVE_VMCI
|
|
|
|
#include <new>
|
|
|
|
//#include "stream_engine.hpp"
|
|
#include "vmci_address.hpp"
|
|
#include "io_thread.hpp"
|
|
#include "session_base.hpp"
|
|
#include "config.hpp"
|
|
#include "err.hpp"
|
|
#include "ip.hpp"
|
|
#include "socket_base.hpp"
|
|
#include "vmci.hpp"
|
|
|
|
#if defined ZMQ_HAVE_WINDOWS
|
|
#include "windows.hpp"
|
|
#else
|
|
#include <unistd.h>
|
|
#include <fcntl.h>
|
|
#endif
|
|
|
|
zmq::vmci_listener_t::vmci_listener_t (io_thread_t *io_thread_,
|
|
socket_base_t *socket_,
|
|
const options_t &options_) :
|
|
stream_listener_base_t (io_thread_, socket_, options_)
|
|
{
|
|
}
|
|
|
|
void zmq::vmci_listener_t::in_event ()
|
|
{
|
|
fd_t fd = accept ();
|
|
|
|
// If connection was reset by the peer in the meantime, just ignore it.
|
|
if (fd == retired_fd) {
|
|
_socket->event_accept_failed (
|
|
make_unconnected_bind_endpoint_pair (_endpoint), zmq_errno ());
|
|
return;
|
|
}
|
|
|
|
tune_vmci_buffer_size (this->get_ctx (), fd, options.vmci_buffer_size,
|
|
options.vmci_buffer_min_size,
|
|
options.vmci_buffer_max_size);
|
|
|
|
if (options.vmci_connect_timeout > 0) {
|
|
#if defined ZMQ_HAVE_WINDOWS
|
|
tune_vmci_connect_timeout (this->get_ctx (), fd,
|
|
options.vmci_connect_timeout);
|
|
#else
|
|
struct timeval timeout = {0, options.vmci_connect_timeout * 1000};
|
|
tune_vmci_connect_timeout (this->get_ctx (), fd, timeout);
|
|
#endif
|
|
}
|
|
|
|
// Create the engine object for this connection.
|
|
create_engine (fd);
|
|
}
|
|
|
|
std::string
|
|
zmq::vmci_listener_t::get_socket_name (zmq::fd_t fd_,
|
|
socket_end_t socket_end_) const
|
|
{
|
|
struct sockaddr_storage ss;
|
|
const zmq_socklen_t sl = get_socket_address (fd_, socket_end_, &ss);
|
|
if (sl == 0) {
|
|
return std::string ();
|
|
}
|
|
|
|
const vmci_address_t addr (reinterpret_cast<struct sockaddr *> (&ss), sl,
|
|
this->get_ctx ());
|
|
std::string address_string;
|
|
addr.to_string (address_string);
|
|
return address_string;
|
|
}
|
|
|
|
int zmq::vmci_listener_t::set_local_address (const char *addr_)
|
|
{
|
|
// Create addr on stack for auto-cleanup
|
|
std::string addr (addr_);
|
|
|
|
// Initialise the address structure.
|
|
vmci_address_t address (this->get_ctx ());
|
|
int rc = address.resolve (addr.c_str ());
|
|
if (rc != 0)
|
|
return -1;
|
|
|
|
// Create a listening socket.
|
|
_s =
|
|
open_socket (this->get_ctx ()->get_vmci_socket_family (), SOCK_STREAM, 0);
|
|
#ifdef ZMQ_HAVE_WINDOWS
|
|
if (s == INVALID_SOCKET) {
|
|
errno = wsa_error_to_errno (WSAGetLastError ());
|
|
return -1;
|
|
}
|
|
#if !defined _WIN32_WCE
|
|
// On Windows, preventing sockets to be inherited by child processes.
|
|
BOOL brc = SetHandleInformation ((HANDLE) _s, HANDLE_FLAG_INHERIT, 0);
|
|
win_assert (brc);
|
|
#endif
|
|
#else
|
|
if (_s == -1)
|
|
return -1;
|
|
#endif
|
|
|
|
address.to_string (_endpoint);
|
|
|
|
// Bind the socket.
|
|
rc = bind (_s, address.addr (), address.addrlen ());
|
|
#ifdef ZMQ_HAVE_WINDOWS
|
|
if (rc == SOCKET_ERROR) {
|
|
errno = wsa_error_to_errno (WSAGetLastError ());
|
|
goto error;
|
|
}
|
|
#else
|
|
if (rc != 0)
|
|
goto error;
|
|
#endif
|
|
|
|
// Listen for incoming connections.
|
|
rc = listen (_s, options.backlog);
|
|
#ifdef ZMQ_HAVE_WINDOWS
|
|
if (rc == SOCKET_ERROR) {
|
|
errno = wsa_error_to_errno (WSAGetLastError ());
|
|
goto error;
|
|
}
|
|
#else
|
|
if (rc != 0)
|
|
goto error;
|
|
#endif
|
|
|
|
_socket->event_listening (make_unconnected_bind_endpoint_pair (_endpoint),
|
|
_s);
|
|
return 0;
|
|
|
|
error:
|
|
int err = errno;
|
|
close ();
|
|
errno = err;
|
|
return -1;
|
|
}
|
|
|
|
zmq::fd_t zmq::vmci_listener_t::accept ()
|
|
{
|
|
// Accept one connection and deal with different failure modes.
|
|
// The situation where connection cannot be accepted due to insufficient
|
|
// resources is considered valid and treated by ignoring the connection.
|
|
zmq_assert (_s != retired_fd);
|
|
fd_t sock = ::accept (_s, NULL, NULL);
|
|
|
|
#ifdef ZMQ_HAVE_WINDOWS
|
|
if (sock == INVALID_SOCKET) {
|
|
wsa_assert (WSAGetLastError () == WSAEWOULDBLOCK
|
|
|| WSAGetLastError () == WSAECONNRESET
|
|
|| WSAGetLastError () == WSAEMFILE
|
|
|| WSAGetLastError () == WSAENOBUFS);
|
|
return retired_fd;
|
|
}
|
|
#if !defined _WIN32_WCE
|
|
// On Windows, preventing sockets to be inherited by child processes.
|
|
BOOL brc = SetHandleInformation ((HANDLE) sock, HANDLE_FLAG_INHERIT, 0);
|
|
win_assert (brc);
|
|
#endif
|
|
#else
|
|
if (sock == -1) {
|
|
errno_assert (errno == EAGAIN || errno == EWOULDBLOCK || errno == EINTR
|
|
|| errno == ECONNABORTED || errno == EPROTO
|
|
|| errno == ENOBUFS || errno == ENOMEM || errno == EMFILE
|
|
|| errno == ENFILE);
|
|
return retired_fd;
|
|
}
|
|
#endif
|
|
|
|
// Race condition can cause socket not to be closed (if fork happens
|
|
// between accept and this point).
|
|
#ifdef FD_CLOEXEC
|
|
int rc = fcntl (sock, F_SETFD, FD_CLOEXEC);
|
|
errno_assert (rc != -1);
|
|
#endif
|
|
|
|
return sock;
|
|
}
|
|
|
|
#endif
|