diff options
| author | Pablo Neira Ayuso <pablo@gnumonks.org> | 2011-10-17 12:50:58 +0200 |
|---|---|---|
| committer | Pablo Neira Ayuso <pablo@gnumonks.org> | 2011-10-17 12:51:18 +0200 |
| commit | 98ec00d8d22fa855710a13aa21cfe1f66114a55b (patch) | |
| tree | 29b937eff0b85144385df2e128f3ec5b99f24dde /examples | |
| parent | c43bb089067ca05af4992fbafe46827a1f0a6e9b (diff) | |
stream: add osmo_stream_*_conn_recv
Like c43bb089067ca05af4992fbafe46827a1f0a6e9b but for stream
sockets.
Diffstat (limited to 'examples')
| -rw-r--r-- | examples/stream-client.c | 15 | ||||
| -rw-r--r-- | examples/stream-server.c | 15 |
2 files changed, 28 insertions, 2 deletions
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; } |