1 /*
2 Copyright (c) 2007-2017 Contributors as noted in the AUTHORS file
3
4 This file is part of libzmq, the ZeroMQ core engine in C++.
5
6 libzmq is free software; you can redistribute it and/or modify it under
7 the terms of the GNU Lesser General Public License (LGPL) as published
8 by the Free Software Foundation; either version 3 of the License, or
9 (at your option) any later version.
10
11 As a special exception, the Contributors give you permission to link
12 this library with independent modules to produce an executable,
13 regardless of the license terms of these independent modules, and to
14 copy and distribute the resulting executable under terms of your choice,
15 provided that you also meet, for each linked independent module, the
16 terms and conditions of the license of that module. An independent
17 module is a module which is not derived from or based on this library.
18 If you modify this library, you must extend this exception to your
19 version of the library.
20
21 libzmq is distributed in the hope that it will be useful, but WITHOUT
22 ANY WARRANTY; without even the implied warranty of MERCHANTABILITY or
23 FITNESS FOR A PARTICULAR PURPOSE. See the GNU Lesser General Public
24 License for more details.
25
26 You should have received a copy of the GNU Lesser General Public License
27 along with this program. If not, see <http://www.gnu.org/licenses/>.
28 */
29
30 #include "testutil.hpp"
31 #include "testutil_unity.hpp"
32
33 #include <string.h>
34
35 SETUP_TEARDOWN_TESTCONTEXT
36
37 #define MSG_SIZE 20
38
39 #ifdef _WIN32
40 #include <winsock2.h>
41 #include <ws2tcpip.h>
42 #else
43 #include <sys/types.h>
44 #include <sys/socket.h>
45 #include <netdb.h>
46 #endif
47
test_srcfd()48 void test_srcfd ()
49 {
50 char my_endpoint[MAX_SOCKET_STRING];
51
52 // Create the infrastructure
53
54 void *rep = test_context_socket (ZMQ_REP);
55 void *req = test_context_socket (ZMQ_REQ);
56
57 bind_loopback_ipv4 (rep, my_endpoint, sizeof (my_endpoint));
58
59 TEST_ASSERT_SUCCESS_ERRNO (zmq_connect (req, my_endpoint));
60
61 char tmp[MSG_SIZE];
62 memset (tmp, 0, MSG_SIZE);
63 zmq_send (req, tmp, MSG_SIZE, 0);
64
65 zmq_msg_t msg;
66 TEST_ASSERT_SUCCESS_ERRNO (zmq_msg_init (&msg));
67
68 zmq_recvmsg (rep, &msg, 0);
69 TEST_ASSERT_EQUAL_UINT (MSG_SIZE, zmq_msg_size (&msg));
70
71 // get the messages source file descriptor
72 int src_fd = zmq_msg_get (&msg, ZMQ_SRCFD);
73 TEST_ASSERT_GREATER_OR_EQUAL (0, src_fd);
74
75 TEST_ASSERT_SUCCESS_ERRNO (zmq_msg_close (&msg));
76
77 // get the remote endpoint
78 struct sockaddr_storage ss;
79 #ifdef ZMQ_HAVE_HPUX
80 int addrlen = sizeof ss;
81 #else
82 socklen_t addrlen = sizeof ss;
83 #endif
84 TEST_ASSERT_SUCCESS_RAW_ERRNO (
85 getpeername (src_fd, (struct sockaddr *) &ss, &addrlen));
86
87 char host[NI_MAXHOST];
88 TEST_ASSERT_SUCCESS_RAW_ERRNO (getnameinfo ((struct sockaddr *) &ss,
89 addrlen, host, sizeof host,
90 NULL, 0, NI_NUMERICHOST));
91
92 // assert it is localhost which connected
93 TEST_ASSERT_EQUAL_STRING ("127.0.0.1", host);
94
95 test_context_socket_close (rep);
96 test_context_socket_close (req);
97
98 // sleep a bit for the socket to be freed
99 msleep (SETTLE_TIME);
100
101 // getting name from closed socket will fail
102 #ifdef ZMQ_HAVE_WINDOWS
103 const int expected_errno = WSAENOTSOCK;
104 #else
105 const int expected_errno = EBADF;
106 #endif
107 TEST_ASSERT_FAILURE_RAW_ERRNO (
108 expected_errno, getpeername (src_fd, (struct sockaddr *) &ss, &addrlen));
109 }
110
main()111 int main ()
112 {
113 setup_test_environment ();
114
115 UNITY_BEGIN ();
116 RUN_TEST (test_srcfd);
117 return UNITY_END ();
118 }
119