diff options
| author | Garrett D'Amore <garrett@damore.org> | 2016-12-25 09:29:16 -0800 |
|---|---|---|
| committer | Garrett D'Amore <garrett@damore.org> | 2016-12-25 09:29:16 -0800 |
| commit | 7acc29013636d2ddc004acebe02d88722fe0c8db (patch) | |
| tree | a211c99284a165e3eb6f9d5f4fb71480e4873f7c /src/core/pipe.c | |
| parent | 147d8408f577678331daf1cd06ae9aac6c231dab (diff) | |
| download | nng-7acc29013636d2ddc004acebe02d88722fe0c8db.tar.gz nng-7acc29013636d2ddc004acebe02d88722fe0c8db.tar.bz2 nng-7acc29013636d2ddc004acebe02d88722fe0c8db.zip | |
Expose and implement pipe operations. (nng_pipe_close, nng_pipe_getopt).
Diffstat (limited to 'src/core/pipe.c')
| -rw-r--r-- | src/core/pipe.c | 11 |
1 files changed, 11 insertions, 0 deletions
diff --git a/src/core/pipe.c b/src/core/pipe.c index bf2e64fe..c9cc545c 100644 --- a/src/core/pipe.c +++ b/src/core/pipe.c @@ -76,3 +76,14 @@ nni_pipe_create(nni_pipe **pp, const nni_pipe_ops *ops) p->p_id = nni_plat_nextid(); return (0); } + + +int +nni_pipe_getopt(nni_pipe *p, int opt, void *val, size_t *szp) +{ + /* This should only be called with the mutex held... */ + if (p->p_ops.p_getopt == NULL) { + return (NNG_ENOTSUP); + } + return (p->p_ops.p_getopt(p->p_data, opt, val, szp)); +} |