|
@@ -189,6 +189,20 @@ _bound_endpoint :: proc(sock: Any_Socket) -> (ep: Endpoint, err: Listen_Error) {
|
|
|
return
|
|
|
}
|
|
|
|
|
|
+@(private)
|
|
|
+_peer_endpoint :: proc(sock: Any_Socket) -> (ep: Endpoint, err: TCP_Recv_Error) {
|
|
|
+ sockaddr: win.SOCKADDR_STORAGE_LH
|
|
|
+ sockaddrlen := c.int(size_of(sockaddr))
|
|
|
+ res := win.getpeername(win.SOCKET(any_socket_to_socket(sock)), &sockaddr, &sockaddrlen)
|
|
|
+ if res < 0 {
|
|
|
+ err = _tcp_recv_error()
|
|
|
+ return
|
|
|
+ }
|
|
|
+
|
|
|
+ ep = _sockaddr_to_endpoint(&sockaddr)
|
|
|
+ return
|
|
|
+}
|
|
|
+
|
|
|
@(private)
|
|
|
_accept_tcp :: proc(sock: TCP_Socket, options := DEFAULT_TCP_OPTIONS) -> (client: TCP_Socket, source: Endpoint, err: Accept_Error) {
|
|
|
for {
|