<p>Max <strong>merged</strong> this change.</p><p><a href="https://gerrit.osmocom.org/12827">View Change</a></p><div style="white-space:pre-wrap">Approvals:
  Harald Welte: Looks good to me, approved
  Jenkins Builder: Verified

</div><pre style="font-family: monospace,monospace; white-space: pre-wrap;">Add socket name functions to stream client/server<br><br>Add functions to get the description of a server link or client<br>connection which examine data on corresponding socket.<br><br>Those functions use static buffers and intended for single use in<br>log/printf statements as illustarted by corresponding example changes.<br><br>Change-Id: If9a8e211da85956781479862a63c4fc6e53ed6be<br>---<br>M examples/stream-client.c<br>M examples/stream-server.c<br>M include/osmocom/netif/stream.h<br>M src/stream.c<br>4 files changed, 35 insertions(+), 2 deletions(-)<br><br></pre><pre style="font-family: monospace,monospace; white-space: pre-wrap;"><span>diff --git a/examples/stream-client.c b/examples/stream-client.c</span><br><span>index 6178dcd..e2fb901 100644</span><br><span>--- a/examples/stream-client.c</span><br><span>+++ b/examples/stream-client.c</span><br><span>@@ -39,7 +39,7 @@</span><br><span> </span><br><span> static int connect_cb(struct osmo_stream_cli *conn)</span><br><span> {</span><br><span style="color: hsl(0, 100%, 40%);">-   LOGP(DSTREAMTEST, LOGL_NOTICE, "connected\n");</span><br><span style="color: hsl(120, 100%, 40%);">+      LOGP(DSTREAMTEST, LOGL_NOTICE, "connected: %s\n", osmo_stream_cli_get_sockname(conn));</span><br><span>     return 0;</span><br><span> }</span><br><span> </span><br><span>diff --git a/examples/stream-server.c b/examples/stream-server.c</span><br><span>index b02eefe..c1086ec 100644</span><br><span>--- a/examples/stream-server.c</span><br><span>+++ b/examples/stream-server.c</span><br><span>@@ -171,7 +171,7 @@</span><br><span>        kbd_ofd->cb = kbd_cb;</span><br><span>     osmo_fd_register(kbd_ofd);</span><br><span> </span><br><span style="color: hsl(0, 100%, 40%);">-  LOGP(DSTREAMTEST, LOGL_NOTICE, "Entering main loop\n");</span><br><span style="color: hsl(120, 100%, 40%);">+     LOGP(DSTREAMTEST, LOGL_NOTICE, "Entering main loop on %s\n", osmo_stream_srv_link_get_sockname(srv));</span><br><span> </span><br><span>  while(1) {</span><br><span>           osmo_select_main(0);</span><br><span>diff --git a/include/osmocom/netif/stream.h b/include/osmocom/netif/stream.h</span><br><span>index 969d42f..3044511 100644</span><br><span>--- a/include/osmocom/netif/stream.h</span><br><span>+++ b/include/osmocom/netif/stream.h</span><br><span>@@ -27,6 +27,7 @@</span><br><span> void osmo_stream_srv_link_set_accept_cb(struct osmo_stream_srv_link *link, int (*accept_cb)(struct osmo_stream_srv_link *link, int fd));</span><br><span> void osmo_stream_srv_link_set_data(struct osmo_stream_srv_link *link, void *data);</span><br><span> void *osmo_stream_srv_link_get_data(struct osmo_stream_srv_link *link);</span><br><span style="color: hsl(120, 100%, 40%);">+char *osmo_stream_srv_link_get_sockname(const struct osmo_stream_srv_link *link);</span><br><span> struct osmo_fd *osmo_stream_srv_link_get_ofd(struct osmo_stream_srv_link *link);</span><br><span> </span><br><span> int osmo_stream_srv_link_open(struct osmo_stream_srv_link *link);</span><br><span>@@ -60,6 +61,7 @@</span><br><span> void osmo_stream_cli_set_data(struct osmo_stream_cli *cli, void *data);</span><br><span> void osmo_stream_cli_set_reconnect_timeout(struct osmo_stream_cli *cli, int timeout);</span><br><span> void *osmo_stream_cli_get_data(struct osmo_stream_cli *cli);</span><br><span style="color: hsl(120, 100%, 40%);">+char *osmo_stream_cli_get_sockname(const struct osmo_stream_cli *cli);</span><br><span> struct osmo_fd *osmo_stream_cli_get_ofd(struct osmo_stream_cli *cli);</span><br><span> void osmo_stream_cli_set_connect_cb(struct osmo_stream_cli *cli, int (*connect_cb)(struct osmo_stream_cli *cli));</span><br><span> void osmo_stream_cli_set_read_cb(struct osmo_stream_cli *cli, int (*read_cb)(struct osmo_stream_cli *cli));</span><br><span>diff --git a/src/stream.c b/src/stream.c</span><br><span>index f1d87d4..7cc77c9 100644</span><br><span>--- a/src/stream.c</span><br><span>+++ b/src/stream.c</span><br><span>@@ -405,6 +405,18 @@</span><br><span>  return cli->data;</span><br><span> }</span><br><span> </span><br><span style="color: hsl(120, 100%, 40%);">+/*! \brief Get the stream client socket description.</span><br><span style="color: hsl(120, 100%, 40%);">+ *  \param[in] cli Stream Client to examine</span><br><span style="color: hsl(120, 100%, 40%);">+ *  \returns Socket description or NULL in case of error */</span><br><span style="color: hsl(120, 100%, 40%);">+char *osmo_stream_cli_get_sockname(const struct osmo_stream_cli *cli)</span><br><span style="color: hsl(120, 100%, 40%);">+{</span><br><span style="color: hsl(120, 100%, 40%);">+       static char buf[OSMO_SOCK_NAME_MAXLEN];</span><br><span style="color: hsl(120, 100%, 40%);">+</span><br><span style="color: hsl(120, 100%, 40%);">+     osmo_sock_get_name_buf(buf, OSMO_SOCK_NAME_MAXLEN, cli->ofd.fd);</span><br><span style="color: hsl(120, 100%, 40%);">+</span><br><span style="color: hsl(120, 100%, 40%);">+ return buf;</span><br><span style="color: hsl(120, 100%, 40%);">+}</span><br><span style="color: hsl(120, 100%, 40%);">+</span><br><span> /*! \brief Get Osmocom File Descriptor of the stream client socket</span><br><span>  *  \param[in] cli Stream Client to modify</span><br><span>  *  \returns Pointer to \ref osmo_fd */</span><br><span>@@ -711,6 +723,25 @@</span><br><span>       return link->data;</span><br><span> }</span><br><span> </span><br><span style="color: hsl(120, 100%, 40%);">+/*! \brief Get description of the stream server link e. g. 127.0.0.1:1234</span><br><span style="color: hsl(120, 100%, 40%);">+ *  \param[in] link Stream Server Link to examine</span><br><span style="color: hsl(120, 100%, 40%);">+ *  \returns Link description or NULL in case of error */</span><br><span style="color: hsl(120, 100%, 40%);">+char *osmo_stream_srv_link_get_sockname(const struct osmo_stream_srv_link *link)</span><br><span style="color: hsl(120, 100%, 40%);">+{</span><br><span style="color: hsl(120, 100%, 40%);">+  static char buf[INET6_ADDRSTRLEN + 6];</span><br><span style="color: hsl(120, 100%, 40%);">+        int rc = osmo_sock_get_local_ip(link->ofd.fd, buf, INET6_ADDRSTRLEN);</span><br><span style="color: hsl(120, 100%, 40%);">+      if (rc < 0)</span><br><span style="color: hsl(120, 100%, 40%);">+                return NULL;</span><br><span style="color: hsl(120, 100%, 40%);">+</span><br><span style="color: hsl(120, 100%, 40%);">+        buf[strnlen(buf, INET6_ADDRSTRLEN + 6)] = ':';</span><br><span style="color: hsl(120, 100%, 40%);">+</span><br><span style="color: hsl(120, 100%, 40%);">+      rc = osmo_sock_get_local_ip_port(link->ofd.fd, buf + strnlen(buf, INET6_ADDRSTRLEN + 6), 6);</span><br><span style="color: hsl(120, 100%, 40%);">+       if (rc < 0)</span><br><span style="color: hsl(120, 100%, 40%);">+                return NULL;</span><br><span style="color: hsl(120, 100%, 40%);">+</span><br><span style="color: hsl(120, 100%, 40%);">+        return buf;</span><br><span style="color: hsl(120, 100%, 40%);">+}</span><br><span style="color: hsl(120, 100%, 40%);">+</span><br><span> /*! \brief Get Osmocom File Descriptor of the stream server link</span><br><span>  *  \param[in] link Stream Server Link</span><br><span>  *  \returns Pointer to \ref osmo_fd */</span><br><span></span><br></pre><p>To view, visit <a href="https://gerrit.osmocom.org/12827">change 12827</a>. To unsubscribe, or for help writing mail filters, visit <a href="https://gerrit.osmocom.org/settings">settings</a>.</p><div itemscope itemtype="http://schema.org/EmailMessage"><div itemscope itemprop="action" itemtype="http://schema.org/ViewAction"><link itemprop="url" href="https://gerrit.osmocom.org/12827"/><meta itemprop="name" content="View Change"/></div></div>

<div style="display:none"> Gerrit-Project: libosmo-netif </div>
<div style="display:none"> Gerrit-Branch: master </div>
<div style="display:none"> Gerrit-MessageType: merged </div>
<div style="display:none"> Gerrit-Change-Id: If9a8e211da85956781479862a63c4fc6e53ed6be </div>
<div style="display:none"> Gerrit-Change-Number: 12827 </div>
<div style="display:none"> Gerrit-PatchSet: 4 </div>
<div style="display:none"> Gerrit-Owner: Max <msuraev@sysmocom.de> </div>
<div style="display:none"> Gerrit-Reviewer: Harald Welte <laforge@gnumonks.org> </div>
<div style="display:none"> Gerrit-Reviewer: Jenkins Builder (1000002) </div>
<div style="display:none"> Gerrit-Reviewer: Max <msuraev@sysmocom.de> </div>