29 #define _WIN32_WINNT 0x0501 40 #include <arpa/inet.h> 42 #include <netinet/in.h> 43 #include <sys/socket.h> 44 #include <sys/types.h> 50 #include <sys/select.h> 54 #include "libsigrok-internal.h" 60 #if !defined SHUT_RDWR && defined SD_BOTH 61 # define SHUT_RDWR SD_BOTH 64 #define LOG_PREFIX "tcp" 84 memset(fds, 0,
sizeof(fds));
86 fds[0].events = POLLIN;
87 ret = poll(fds, ARRAY_SIZE(fds), -1);
92 if (!(fds[0].revents & POLLIN))
103 memset(&tv, 0,
sizeof(tv));
104 ret = select(fd + 1, &rfds, NULL, NULL, &tv);
109 if (!FD_ISSET(fd, rfds))
129 const char *host_addr,
const char *tcp_port)
132 struct sr_tcp_dev_inst *tcp;
135 if (host_addr && *host_addr)
136 host = g_strdup(host_addr);
138 if (tcp_port && *tcp_port)
139 port = g_strdup(tcp_port);
141 tcp = g_malloc0(
sizeof(*tcp));
144 tcp->host_addr = host;
145 tcp->tcp_port = port;
167 g_free(tcp->host_addr);
185 const char *prefix,
char separator,
char *path,
size_t path_len)
190 if (!tcp || !tcp->host_addr || !tcp->tcp_port)
196 if (!*prefix && !separator)
200 sep_text[0] = separator;
204 snprintf(path, path_len,
"%s%s%s%s%s",
205 prefix, *prefix ? sep_text :
"",
206 tcp->host_addr, sep_text, tcp->tcp_port);
221 struct addrinfo hints;
222 struct addrinfo *results, *r;
228 if (!tcp->host_addr || !tcp->tcp_port)
232 memset(&hints, 0,
sizeof(hints));
233 hints.ai_family = AF_UNSPEC;
234 hints.ai_socktype = SOCK_STREAM;
235 hints.ai_protocol = IPPROTO_TCP;
236 ret = getaddrinfo(tcp->host_addr, tcp->tcp_port, &hints, &results);
238 sr_err(
"Address lookup failed: %s:%s: %s.",
239 tcp->host_addr, tcp->tcp_port, gai_strerror(ret));
245 for (r = results; r; r = r->ai_next) {
246 fd = socket(r->ai_family, r->ai_socktype, r->ai_protocol);
249 ret = connect(fd, r->ai_addr, r->ai_addrlen);
257 freeaddrinfo(results);
259 sr_err(
"Failed to connect to %s:%s: %s.",
260 tcp->host_addr, tcp->tcp_port, g_strerror(errno));
283 if (tcp->sock_fd < 0)
286 shutdown(tcp->sock_fd, SHUT_RDWR);
307 const uint8_t *data,
size_t dlen)
319 if (tcp->sock_fd < 0)
322 rc = send(tcp->sock_fd, data, dlen, 0);
325 written = (size_t)rc;
345 uint8_t *data,
size_t dlen, gboolean nonblocking)
357 if (tcp->sock_fd < 0)
363 rc = recv(tcp->sock_fd, data, dlen, 0);
390 struct sr_tcp_dev_inst *tcp,
int events,
int timeout,
393 if (!tcp || tcp->sock_fd < 0)
395 return sr_session_source_add(session, tcp->sock_fd,
396 events, timeout, cb, cb_data);
412 struct sr_tcp_dev_inst *tcp)
414 if (!tcp || tcp->sock_fd < 0)
416 return sr_session_source_remove(session, tcp->sock_fd);
SR_PRIV gboolean sr_fd_is_readable(int fd)
Check whether a file descriptor is readable (without blocking).
SR_PRIV int sr_tcp_read_bytes(struct sr_tcp_dev_inst *tcp, uint8_t *data, size_t dlen, gboolean nonblocking)
Fetch receive data from a TCP connection.
SR_PRIV int sr_tcp_disconnect(struct sr_tcp_dev_inst *tcp)
Disconnect from a remote TCP communication peer.
SR_PRIV int sr_tcp_write_bytes(struct sr_tcp_dev_inst *tcp, const uint8_t *data, size_t dlen)
Send transmit data to a TCP connection.
typedef void(__LZO_CDECL *lzo_free_func_t)(lzo_callback_p self
SR_PRIV int sr_tcp_source_add(struct sr_session *session, struct sr_tcp_dev_inst *tcp, int events, int timeout, sr_receive_data_callback cb, void *cb_data)
Register receive callback for a TCP connection.
Opaque structure representing a libsigrok session.
SR_PRIV void sr_tcp_dev_inst_free(struct sr_tcp_dev_inst *tcp)
Release a TCP communication instance.
SR_PRIV struct sr_tcp_dev_inst * sr_tcp_dev_inst_new(const char *host_addr, const char *tcp_port)
Create a TCP communication instance.
SR_PRIV int sr_tcp_source_remove(struct sr_session *session, struct sr_tcp_dev_inst *tcp)
Unregister receive callback for a TCP connection.
The public libsigrok header file to be used by frontends.
SR_PRIV int sr_tcp_connect(struct sr_tcp_dev_inst *tcp)
Connect to a remote TCP communication peer.
int(* sr_receive_data_callback)(int fd, int revents, void *cb_data)
Type definition for callback function for data reception.
SR_PRIV int sr_tcp_get_port_path(struct sr_tcp_dev_inst *tcp, const char *prefix, char separator, char *path, size_t path_len)
Construct display name for a TCP communication instance.