2 files changed, 13 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));
+}
diff --git a/src/core/pipe.h b/src/core/pipe.h
index 6688f837..5349bbb1 100644
--- a/src/core/pipe.h
+++ b/src/core/pipe.h
@@ -37,4 +37,6 @@ extern int nni_pipe_create(nni_pipe **, const nni_pipe_ops *);
 
 extern void nni_pipe_destroy(nni_pipe *);
 
+extern int nni_pipe_getopt(nni_pipe *, int, void *, size_t *sizep);
+
 #endif // CORE_PIPE_H