session: actually use ns node

Signed-off-by: Felipe Contreras <felipe.contreras@gmail.com>

1 files changed, 7 insertions, 2 deletions

diff --git a/pn_session.c b/pn_session.c
index 8634298..119f119 100644
--- a/pn_session.c
+++ b/pn_session.c
@@ -1,10 +1,13 @@
 #include "pn_session.h"
+#include "pn_node.h"
 
 static void *parent_class;
 
 struct pn_session_priv {
 	char *username;
 	char *password;
+
+	struct pn_node *ns;
 };
 
 enum {
@@ -35,13 +38,13 @@ pn_session_connect(struct pn_session *session,
 		   const char *host,
 		   int port)
 {
-	/* stub */
+	pn_node_connect(session->priv->ns, host, port);
 }
 
 void
 pn_session_disconnect(struct pn_session *session)
 {
-	/* stub */
+	pn_node_close(session->priv->ns);
 }
 
 const char *
@@ -60,6 +63,7 @@ instance_init(GTypeInstance *instance,
 	struct pn_session_priv *priv;
 
 	self->priv = priv = G_TYPE_INSTANCE_GET_PRIVATE(instance, PN_SESSION_TYPE, struct pn_session_priv);
+	priv->ns = pn_node_new();
 }
 
 static void
@@ -112,6 +116,7 @@ finalize(GObject *obj)
 	struct pn_session *self = PN_SESSION(obj);
 	struct pn_session_priv *priv = self->priv;
 
+	g_object_unref(priv->ns);
 	g_free(priv->username);
 	g_free(priv->password);
 	G_OBJECT_CLASS(parent_class)->finalize(obj);