1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
|
/***************************************************************************
* Copyright (c) 2024 Microsoft Corporation
* Copyright (c) 2025-present Eclipse ThreadX Contributors
*
* This program and the accompanying materials are made available under the
* terms of the MIT License which is available at
* https://opensource.org/licenses/MIT.
*
* SPDX-License-Identifier: MIT
**************************************************************************/
/**************************************************************************/
/**************************************************************************/
/** */
/** NetX Component */
/** */
/** Transmission Control Protocol (TCP) */
/** */
/**************************************************************************/
/**************************************************************************/
#define NX_SOURCE_CODE
/* Include necessary system files. */
#include "nx_api.h"
#include "nx_tcp.h"
#include "nx_ipv6.h"
/**************************************************************************/
/* */
/* FUNCTION RELEASE */
/* */
/* _nxd_tcp_socket_peer_info_get PORTABLE C */
/* 6.4.3 */
/* AUTHOR */
/* */
/* Yuxin Zhou, Microsoft Corporation */
/* */
/* DESCRIPTION */
/* */
/* This function retrieves IP address and port number of the peer */
/* connected to the specified TCP socket. */
/* */
/* INPUT */
/* */
/* socket_ptr Pointer to the TCP sockete */
/* peer_ip_address Pointer to the IP address */
/* of the peer. */
/* peer_port Pointer to the port number */
/* of the peer. */
/* */
/* OUTPUT */
/* */
/* NX_SUCCESS Actual completion status */
/* NX_NOT_CONNECTED TCP socket is not connected */
/* */
/* CALLS */
/* */
/* tx_mutex_get Obtain protection */
/* tx_mutex_put Release protection */
/* */
/* CALLED BY */
/* */
/* Application Code */
/* */
/**************************************************************************/
UINT _nxd_tcp_socket_peer_info_get(NX_TCP_SOCKET *socket_ptr,
NXD_ADDRESS *peer_ip_address,
ULONG *peer_port)
{
#ifdef TX_ENABLE_EVENT_TRACE
ULONG ip_address_lsw = 0;
#endif /* TX_ENABLE_EVENT_TRACE */
NX_IP *ip_ptr;
/* Setup IP pointer. */
ip_ptr = socket_ptr -> nx_tcp_socket_ip_ptr;
/* Obtain the IP mutex so we can examine the bound port. */
tx_mutex_get(&(ip_ptr -> nx_ip_protection), TX_WAIT_FOREVER);
/* Make sure the TCP connection has been established. */
if ((socket_ptr -> nx_tcp_socket_state <= NX_TCP_LISTEN_STATE) ||
(socket_ptr -> nx_tcp_socket_state > NX_TCP_ESTABLISHED))
{
/* Release protection. */
tx_mutex_put(&(ip_ptr -> nx_ip_protection));
return(NX_NOT_CONNECTED);
}
/* Determine the peer IP address */
/* Assign the IP address type (IPv4 or IPv6) */
peer_ip_address -> nxd_ip_version = socket_ptr -> nx_tcp_socket_connect_ip.nxd_ip_version;
/* If address type is IPv4, just copy one word. */
#ifndef NX_DISABLE_IPV4
if (socket_ptr -> nx_tcp_socket_connect_ip.nxd_ip_version == NX_IP_VERSION_V4)
{
peer_ip_address -> nxd_ip_address.v4 = socket_ptr -> nx_tcp_socket_connect_ip.nxd_ip_address.v4;
}
#endif /* !NX_DISABLE_IPV4 */
#ifdef FEATURE_NX_IPV6
if (socket_ptr -> nx_tcp_socket_connect_ip.nxd_ip_version == NX_IP_VERSION_V6)
{
/* Return the IP address of the peer connected to the TCP socket. */
COPY_IPV6_ADDRESS(socket_ptr -> nx_tcp_socket_connect_ip.nxd_ip_address.v6,
peer_ip_address -> nxd_ip_address.v6);
}
#endif /* FEATURE_NX_IPV6 */
/* Determine the peer port number and return the port number of the peer
connected to the TCP socket. */
*peer_port = socket_ptr -> nx_tcp_socket_connect_port;
/* Release protection. */
tx_mutex_put(&(ip_ptr -> nx_ip_protection));
#ifdef TX_ENABLE_EVENT_TRACE
#ifndef NX_DISABLE_IPV4
if (peer_ip_address -> nxd_ip_version == NX_IP_VERSION_V4)
{
ip_address_lsw = peer_ip_address -> nxd_ip_address.v4;
}
#endif /* NX_DISABLE_IPV4 */
#ifdef FEATURE_NX_IPV6
if (peer_ip_address -> nxd_ip_version == NX_IP_VERSION_V6)
{
ip_address_lsw = peer_ip_address -> nxd_ip_address.v6[3];
}
#endif /* FEATURE_NX_IPV6 */
/* If trace is enabled, insert this event into the trace buffer. */
NX_TRACE_IN_LINE_INSERT(NXD_TRACE_TCP_SOCKET_PEER_INFO_GET, socket_ptr, ip_address_lsw, *peer_port, 0, NX_TRACE_TCP_EVENTS, 0, 0);
#endif /* TX_ENABLE_EVENT_TRACE */
/* Return successful completion status. */
return(NX_SUCCESS);
}
|
