|
|
|
@@ -19,11 +19,39 @@
|
|
|
|
|
|
|
|
|
|
#ifdef JERRY_DEBUGGER
|
|
|
|
|
|
|
|
|
|
#include <arpa/inet.h>
|
|
|
|
|
#include <errno.h>
|
|
|
|
|
|
|
|
|
|
#ifdef WIN32
|
|
|
|
|
#include <BaseTsd.h>
|
|
|
|
|
typedef SSIZE_T ssize_t;
|
|
|
|
|
#include <WS2tcpip.h>
|
|
|
|
|
#include <winsock2.h>
|
|
|
|
|
|
|
|
|
|
/* On Windows the WSAEWOULDBLOCK value can be returned for non-blocking operations */
|
|
|
|
|
#define JERRYX_EWOULDBLOCK WSAEWOULDBLOCK
|
|
|
|
|
|
|
|
|
|
/* On Windows the invalid socket's value of INVALID_SOCKET */
|
|
|
|
|
#define JERRYX_SOCKET_INVALID INVALID_SOCKET
|
|
|
|
|
|
|
|
|
|
/* On Windows sockets have a SOCKET typedef */
|
|
|
|
|
typedef SOCKET jerryx_socket;
|
|
|
|
|
|
|
|
|
|
#else /* !WIN32 */
|
|
|
|
|
|
|
|
|
|
#include <arpa/inet.h>
|
|
|
|
|
#include <fcntl.h>
|
|
|
|
|
#include <unistd.h>
|
|
|
|
|
#include <sys/socket.h>
|
|
|
|
|
#include <unistd.h>
|
|
|
|
|
|
|
|
|
|
/* On *nix the EWOULDBLOCK errno value can be returned for non-blocking operations */
|
|
|
|
|
#define JERRYX_EWOULDBLOCK EWOULDBLOCK
|
|
|
|
|
|
|
|
|
|
/* On *nix the invalid socket has a value of -1 */
|
|
|
|
|
#define JERRYX_SOCKET_INVALID (-1)
|
|
|
|
|
|
|
|
|
|
/* On *nix the sockets are integer identifiers */
|
|
|
|
|
typedef int jerryx_socket;
|
|
|
|
|
#endif /* WIN32 */
|
|
|
|
|
|
|
|
|
|
/**
|
|
|
|
|
* Implementation of transport over tcp/ip.
|
|
|
|
@@ -31,16 +59,66 @@
|
|
|
|
|
typedef struct
|
|
|
|
|
{
|
|
|
|
|
jerry_debugger_transport_header_t header; /**< transport header */
|
|
|
|
|
int tcp_socket; /**< tcp socket */
|
|
|
|
|
jerryx_socket tcp_socket; /**< tcp socket */
|
|
|
|
|
} jerryx_debugger_transport_tcp_t;
|
|
|
|
|
|
|
|
|
|
/**
|
|
|
|
|
* Get the network error value.
|
|
|
|
|
*
|
|
|
|
|
* On Windows this returns the result of the `WSAGetLastError ()` call and
|
|
|
|
|
* on any other system the `errno` value.
|
|
|
|
|
*
|
|
|
|
|
*
|
|
|
|
|
* @return last error value.
|
|
|
|
|
*/
|
|
|
|
|
static inline int
|
|
|
|
|
jerryx_debugger_tcp_get_errno (void)
|
|
|
|
|
{
|
|
|
|
|
#ifdef WIN32
|
|
|
|
|
return WSAGetLastError ();
|
|
|
|
|
#else /* !WIN32 */
|
|
|
|
|
return errno;
|
|
|
|
|
#endif /* WIN32 */
|
|
|
|
|
} /* jerryx_debugger_tcp_get_errno */
|
|
|
|
|
|
|
|
|
|
/**
|
|
|
|
|
* Correctly close a single socket.
|
|
|
|
|
*/
|
|
|
|
|
static inline void
|
|
|
|
|
jerryx_debugger_tcp_close_socket (jerryx_socket socket_id) /**< socket to close */
|
|
|
|
|
{
|
|
|
|
|
#ifdef WIN32
|
|
|
|
|
closesocket (socket_id);
|
|
|
|
|
#else /* !WIN32 */
|
|
|
|
|
close (socket_id);
|
|
|
|
|
#endif /* WIN32 */
|
|
|
|
|
} /* jerryx_debugger_tcp_close_socket */
|
|
|
|
|
|
|
|
|
|
/**
|
|
|
|
|
* Log tcp error message.
|
|
|
|
|
*/
|
|
|
|
|
static void
|
|
|
|
|
jerryx_debugger_tcp_log_error (int err_val)
|
|
|
|
|
jerryx_debugger_tcp_log_error (int errno_value) /**< error value to log */
|
|
|
|
|
{
|
|
|
|
|
JERRYX_ERROR_MSG ("TCP Error: %s\n", strerror (err_val));
|
|
|
|
|
if (errno_value == 0)
|
|
|
|
|
{
|
|
|
|
|
return;
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
#ifdef WIN32
|
|
|
|
|
char *error_message = NULL;
|
|
|
|
|
FormatMessage (FORMAT_MESSAGE_ALLOCATE_BUFFER | FORMAT_MESSAGE_FROM_SYSTEM | FORMAT_MESSAGE_IGNORE_INSERTS,
|
|
|
|
|
NULL,
|
|
|
|
|
errno_value,
|
|
|
|
|
MAKELANGID (LANG_NEUTRAL, SUBLANG_DEFAULT),
|
|
|
|
|
(LPTSTR) &error_message,
|
|
|
|
|
0,
|
|
|
|
|
NULL);
|
|
|
|
|
jerry_port_log (JERRY_LOG_LEVEL_ERROR, "TCP Error: %s\n", error_message);
|
|
|
|
|
LocalFree (error_message);
|
|
|
|
|
#else /* !WIN32 */
|
|
|
|
|
jerry_port_log (JERRY_LOG_LEVEL_ERROR, "TCP Error: %s\n", strerror (errno_value));
|
|
|
|
|
#endif /* WIN32 */
|
|
|
|
|
} /* jerryx_debugger_tcp_log_error */
|
|
|
|
|
|
|
|
|
|
/**
|
|
|
|
@@ -55,7 +133,7 @@ jerryx_debugger_tcp_close (jerry_debugger_transport_header_t *header_p) /**< tcp
|
|
|
|
|
|
|
|
|
|
JERRYX_DEBUG_MSG ("TCP connection closed.\n");
|
|
|
|
|
|
|
|
|
|
close (tcp_p->tcp_socket);
|
|
|
|
|
jerryx_debugger_tcp_close_socket (tcp_p->tcp_socket);
|
|
|
|
|
|
|
|
|
|
jerry_heap_free ((void *) header_p, sizeof (jerryx_debugger_transport_tcp_t));
|
|
|
|
|
} /* jerryx_debugger_tcp_close */
|
|
|
|
@@ -80,7 +158,7 @@ jerryx_debugger_tcp_send (jerry_debugger_transport_header_t *header_p, /**< tcp
|
|
|
|
|
#ifdef __linux__
|
|
|
|
|
ssize_t is_err = recv (tcp_p->tcp_socket, NULL, 0, MSG_PEEK);
|
|
|
|
|
|
|
|
|
|
if (is_err == 0 && errno != EWOULDBLOCK)
|
|
|
|
|
if (is_err == 0 && errno != JERRYX_EWOULDBLOCK)
|
|
|
|
|
{
|
|
|
|
|
int err_val = errno;
|
|
|
|
|
jerry_debugger_transport_close ();
|
|
|
|
@@ -93,12 +171,13 @@ jerryx_debugger_tcp_send (jerry_debugger_transport_header_t *header_p, /**< tcp
|
|
|
|
|
|
|
|
|
|
if (sent_bytes < 0)
|
|
|
|
|
{
|
|
|
|
|
if (errno == EWOULDBLOCK)
|
|
|
|
|
int err_val = jerryx_debugger_tcp_get_errno ();
|
|
|
|
|
|
|
|
|
|
if (err_val == JERRYX_EWOULDBLOCK)
|
|
|
|
|
{
|
|
|
|
|
continue;
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
int err_val = errno;
|
|
|
|
|
jerry_debugger_transport_close ();
|
|
|
|
|
jerryx_debugger_tcp_log_error (err_val);
|
|
|
|
|
return false;
|
|
|
|
@@ -128,9 +207,10 @@ jerryx_debugger_tcp_receive (jerry_debugger_transport_header_t *header_p, /**< t
|
|
|
|
|
|
|
|
|
|
if (length <= 0)
|
|
|
|
|
{
|
|
|
|
|
if (errno != EWOULDBLOCK || length == 0)
|
|
|
|
|
int err_val = jerryx_debugger_tcp_get_errno ();
|
|
|
|
|
|
|
|
|
|
if (err_val != JERRYX_EWOULDBLOCK || length == 0)
|
|
|
|
|
{
|
|
|
|
|
int err_val = errno;
|
|
|
|
|
jerry_debugger_transport_close ();
|
|
|
|
|
jerryx_debugger_tcp_log_error (err_val);
|
|
|
|
|
return false;
|
|
|
|
@@ -149,6 +229,47 @@ jerryx_debugger_tcp_receive (jerry_debugger_transport_header_t *header_p, /**< t
|
|
|
|
|
return true;
|
|
|
|
|
} /* jerryx_debugger_tcp_receive */
|
|
|
|
|
|
|
|
|
|
/**
|
|
|
|
|
* Utility method to prepare the server socket to accept connections.
|
|
|
|
|
*
|
|
|
|
|
* The following steps are performed:
|
|
|
|
|
* * Configure address re-use.
|
|
|
|
|
* * Bind the socket to the given port
|
|
|
|
|
* * Start listening on the socket.
|
|
|
|
|
*
|
|
|
|
|
* @return true if everything is ok
|
|
|
|
|
* false if there was an error
|
|
|
|
|
*/
|
|
|
|
|
static bool
|
|
|
|
|
jerryx_debugger_tcp_configure_socket (jerryx_socket server_socket, /** < socket to configure */
|
|
|
|
|
uint16_t port) /** < port number to be used for the socket */
|
|
|
|
|
{
|
|
|
|
|
struct sockaddr_in addr;
|
|
|
|
|
|
|
|
|
|
addr.sin_family = AF_INET;
|
|
|
|
|
addr.sin_port = htons (port);
|
|
|
|
|
addr.sin_addr.s_addr = INADDR_ANY;
|
|
|
|
|
|
|
|
|
|
int opt_value = 1;
|
|
|
|
|
|
|
|
|
|
if (setsockopt (server_socket, SOL_SOCKET, SO_REUSEADDR, &opt_value, sizeof (int)) != 0)
|
|
|
|
|
{
|
|
|
|
|
return false;
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
if (bind (server_socket, (struct sockaddr *)&addr, sizeof (struct sockaddr_in)) != 0)
|
|
|
|
|
{
|
|
|
|
|
return false;
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
if (listen (server_socket, 1) != 0)
|
|
|
|
|
{
|
|
|
|
|
return false;
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
return true;
|
|
|
|
|
} /* jerryx_debugger_tcp_configure_socket */
|
|
|
|
|
|
|
|
|
|
/**
|
|
|
|
|
* Create a tcp connection.
|
|
|
|
|
*
|
|
|
|
@@ -158,56 +279,55 @@ jerryx_debugger_tcp_receive (jerry_debugger_transport_header_t *header_p, /**< t
|
|
|
|
|
bool
|
|
|
|
|
jerryx_debugger_tcp_create (uint16_t port) /**< listening port */
|
|
|
|
|
{
|
|
|
|
|
int server_socket;
|
|
|
|
|
struct sockaddr_in addr;
|
|
|
|
|
socklen_t sin_size = sizeof (struct sockaddr_in);
|
|
|
|
|
|
|
|
|
|
addr.sin_family = AF_INET;
|
|
|
|
|
addr.sin_port = htons (port);
|
|
|
|
|
addr.sin_addr.s_addr = INADDR_ANY;
|
|
|
|
|
|
|
|
|
|
if ((server_socket = socket (AF_INET, SOCK_STREAM, 0)) == -1)
|
|
|
|
|
#ifdef WIN32
|
|
|
|
|
WSADATA wsaData;
|
|
|
|
|
int wsa_init_status = WSAStartup (MAKEWORD (2, 2), &wsaData);
|
|
|
|
|
if (wsa_init_status != NO_ERROR)
|
|
|
|
|
{
|
|
|
|
|
JERRYX_ERROR_MSG ("Error: %s\n", strerror (errno));
|
|
|
|
|
JERRYX_ERROR_MSG ("WSA Error: %d\n", wsa_init_status);
|
|
|
|
|
return false;
|
|
|
|
|
}
|
|
|
|
|
#endif /* WIN32*/
|
|
|
|
|
|
|
|
|
|
jerryx_socket server_socket = socket (AF_INET, SOCK_STREAM, 0);
|
|
|
|
|
if (server_socket == JERRYX_SOCKET_INVALID)
|
|
|
|
|
{
|
|
|
|
|
jerryx_debugger_tcp_log_error (jerryx_debugger_tcp_get_errno ());
|
|
|
|
|
return false;
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
int opt_value = 1;
|
|
|
|
|
|
|
|
|
|
if (setsockopt (server_socket, SOL_SOCKET, SO_REUSEADDR, &opt_value, sizeof (int)) == -1)
|
|
|
|
|
if (!jerryx_debugger_tcp_configure_socket (server_socket, port))
|
|
|
|
|
{
|
|
|
|
|
close (server_socket);
|
|
|
|
|
JERRYX_ERROR_MSG ("Error: %s\n", strerror (errno));
|
|
|
|
|
return false;
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
if (bind (server_socket, (struct sockaddr *)&addr, sizeof (struct sockaddr)) == -1)
|
|
|
|
|
{
|
|
|
|
|
close (server_socket);
|
|
|
|
|
JERRYX_ERROR_MSG ("Error: %s\n", strerror (errno));
|
|
|
|
|
return false;
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
if (listen (server_socket, 1) == -1)
|
|
|
|
|
{
|
|
|
|
|
close (server_socket);
|
|
|
|
|
JERRYX_ERROR_MSG ("Error: %s\n", strerror (errno));
|
|
|
|
|
int error = jerryx_debugger_tcp_get_errno ();
|
|
|
|
|
jerryx_debugger_tcp_close_socket (server_socket);
|
|
|
|
|
jerryx_debugger_tcp_log_error (error);
|
|
|
|
|
return false;
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
JERRYX_DEBUG_MSG ("Waiting for client connection\n");
|
|
|
|
|
|
|
|
|
|
int tcp_socket = accept (server_socket, (struct sockaddr *)&addr, &sin_size);
|
|
|
|
|
struct sockaddr_in addr;
|
|
|
|
|
socklen_t sin_size = sizeof (struct sockaddr_in);
|
|
|
|
|
|
|
|
|
|
close (server_socket);
|
|
|
|
|
jerryx_socket tcp_socket = accept (server_socket, (struct sockaddr *)&addr, &sin_size);
|
|
|
|
|
|
|
|
|
|
if (tcp_socket == -1)
|
|
|
|
|
jerryx_debugger_tcp_close_socket (server_socket);
|
|
|
|
|
|
|
|
|
|
if (tcp_socket == JERRYX_SOCKET_INVALID)
|
|
|
|
|
{
|
|
|
|
|
JERRYX_ERROR_MSG ("Error: %s\n", strerror (errno));
|
|
|
|
|
jerryx_debugger_tcp_log_error (jerryx_debugger_tcp_get_errno ());
|
|
|
|
|
return false;
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
/* Set non-blocking mode. */
|
|
|
|
|
#ifdef WIN32
|
|
|
|
|
u_long nonblocking_enabled = 1;
|
|
|
|
|
if (ioctlsocket (tcp_socket, FIONBIO, &nonblocking_enabled) != NO_ERROR)
|
|
|
|
|
{
|
|
|
|
|
jerryx_debugger_tcp_close_socket (tcp_socket);
|
|
|
|
|
return false;
|
|
|
|
|
}
|
|
|
|
|
#else /* !WIN32 */
|
|
|
|
|
int socket_flags = fcntl (tcp_socket, F_GETFL, 0);
|
|
|
|
|
|
|
|
|
|
if (socket_flags < 0)
|
|
|
|
@@ -221,6 +341,7 @@ jerryx_debugger_tcp_create (uint16_t port) /**< listening port */
|
|
|
|
|
close (tcp_socket);
|
|
|
|
|
return false;
|
|
|
|
|
}
|
|
|
|
|
#endif /* WIN32 */
|
|
|
|
|
|
|
|
|
|
JERRYX_DEBUG_MSG ("Connected from: %s\n", inet_ntoa (addr.sin_addr));
|
|
|
|
|
|
|
|
|
@@ -231,7 +352,7 @@ jerryx_debugger_tcp_create (uint16_t port) /**< listening port */
|
|
|
|
|
|
|
|
|
|
if (!header_p)
|
|
|
|
|
{
|
|
|
|
|
close (tcp_socket);
|
|
|
|
|
jerryx_debugger_tcp_close_socket (tcp_socket);
|
|
|
|
|
return false;
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|