From 98ec00d8d22fa855710a13aa21cfe1f66114a55b Mon Sep 17 00:00:00 2001 From: Pablo Neira Ayuso Date: Mon, 17 Oct 2011 12:50:58 +0200 Subject: stream: add osmo_stream_*_conn_recv Like c43bb089067ca05af4992fbafe46827a1f0a6e9b but for stream sockets. --- examples/stream-client.c | 15 ++++++++++++++- examples/stream-server.c | 15 ++++++++++++++- 2 files changed, 28 insertions(+), 2 deletions(-) (limited to 'examples') diff --git a/examples/stream-client.c b/examples/stream-client.c index 7f95800..8836223 100644 --- a/examples/stream-client.c +++ b/examples/stream-client.c @@ -43,9 +43,22 @@ static int connect_cb(struct osmo_stream_client_conn *conn) return 0; } -static int read_cb(struct osmo_stream_client_conn *conn, struct msgb *msg) +static int read_cb(struct osmo_stream_client_conn *conn) { + struct msgb *msg; + LOGP(DSTREAMTEST, LOGL_NOTICE, "received message from stream\n"); + + msg = msgb_alloc(1024, "STREAMCLIENT/test"); + if (msg == NULL) { + LOGP(DSTREAMTEST, LOGL_ERROR, "cannot allocate message\n"); + return 0; + } + if (osmo_stream_client_conn_recv(conn, msg) < 0) { + LOGP(DSTREAMTEST, LOGL_ERROR, "cannot receive message\n"); + return 0; + } + msgb_free(msg); return 0; } diff --git a/examples/stream-server.c b/examples/stream-server.c index d8eb380..ec9f903 100644 --- a/examples/stream-server.c +++ b/examples/stream-server.c @@ -41,9 +41,22 @@ void sighandler(int foo) exit(EXIT_SUCCESS); } -int read_cb(struct osmo_stream_server_conn *conn, struct msgb *msg) +int read_cb(struct osmo_stream_server_conn *conn) { + struct msgb *msg; + LOGP(DSTREAMTEST, LOGL_NOTICE, "received message from stream\n"); + + msg = msgb_alloc(1024, "STREAMSERVER/test"); + if (msg == NULL) { + LOGP(DSTREAMTEST, LOGL_ERROR, "cannot allocate message\n"); + return 0; + } + if (osmo_stream_server_conn_recv(conn, msg) < 0) { + LOGP(DSTREAMTEST, LOGL_ERROR, "cannot receive message\n"); + return 0; + } + msgb_free(msg); return 0; } -- cgit v1.2.3