Working on IPC client module.

Perry Werneck
1 parent 79de4453
Showing 5 changed files with 113 additions and 6 deletions Show diff stats
src/lib3270++/Makefile.in
src/lib3270++/ipc/session.cc
src/lib3270++/linux/request.cc
src/lib3270++/private.h
src/lib3270++/testprogram/testprogram.cc
@@ -32,7 +32,7 @@ SOURCES= \
 	$(wildcard *.cc) \
 	$(wildcard local/*.cc) \
 	$(wildcard ipc/*.cc) \
-        $(wildcard @OSNAME@/*.c) \
+        $(wildcard @OSNAME@/*.cc) \
         $(wildcard @OSNAME@/*.rc)
 TEST_SOURCES= \
@@ -89,6 +89,7 @@
 		this->name += ".";
 		this->name += (sep+1);
 		this->path = "/br/com/bb/tn3270/session";
+		this->interface = "br.com.bb.tn3270.session";
 		debug("D-Bus Object name=\"",this->name,"\" D-Bus Object path=\"",this->path,"\"");
@@ -0,0 +1,101 @@
+/*
+ * "Software pw3270, desenvolvido com base nos códigos fontes do WC3270  e X3270
+ * (Paul Mattes Paul.Mattes@usa.net), de emulação de terminal 3270 para acesso a
+ * aplicativos mainframe. Registro no INPI sob o nome G3270.
+ *
+ * Copyright (C) <2008> <Banco do Brasil S.A.>
+ *
+ * Este programa é software livre. Você pode redistribuí-lo e/ou modificá-lo sob
+ * os termos da GPL v.2 - Licença Pública Geral  GNU,  conforme  publicado  pela
+ * Free Software Foundation.
+ *
+ * Este programa é distribuído na expectativa de  ser  útil,  mas  SEM  QUALQUER
+ * GARANTIA; sem mesmo a garantia implícita de COMERCIALIZAÇÃO ou  de  ADEQUAÇÃO
+ * A QUALQUER PROPÓSITO EM PARTICULAR. Consulte a Licença Pública Geral GNU para
+ * obter mais detalhes.
+ *
+ * Você deve ter recebido uma cópia da Licença Pública Geral GNU junto com este
+ * programa; se não, escreva para a Free Software Foundation, Inc., 51 Franklin
+ * St, Fifth Floor, Boston, MA  02110-1301  USA
+ *
+ * Este programa está nomeado como - e possui - linhas de código.
+ *
+ * Contatos:
+ *
+ * perry.werneck@gmail.com	(Alexandre Perry de Souza Werneck)
+ * erico.mendonca@gmail.com	(Erico Mascarenhas Mendonça)
+ *
+ */
+
+/**
+ * @file src/lib3270++/linux/request.cc
+ *
+ * @brief Implements D-Bus message.
+ *
+ * @author perry.werneck@gmail.com
+ *
+ */
+
+ #include "../private.h"
+
+ using std::string;
+
+/*---[ Implement ]----------------------------------------------------------------------------------*/
+
+ namespace TN3270 {
+
+	IPC::Request::Request(Session &session, const char *method) {
+
+		this->conn = session.conn;
+		this->msg.in = nullptr;
+
+		this->msg.out = dbus_message_new_method_call(	session.name.c_str(),		// Destination
+														session.path.c_str(),		// Path
+														session.interface.c_str(),	// Interface
+														method						// method
+													);
+
+		if(!msg.out) {
+			throw std::runtime_error("Can't create D-Bus Method Call");
+		}
+
+	}
+
+	IPC::Request::~Request() {
+		if(msg.out) {
+			dbus_message_unref(msg.out);
+		}
+		if(msg.in) {
+			dbus_message_unref(msg.in);
+		}
+	}
+
+	IPC::Request & IPC::Request::call() {
+
+		if(msg.in) {
+			dbus_message_unref(msg.in);
+			msg.in = nullptr;
+		}
+
+		DBusError error;
+		dbus_error_init(&error);
+		this->msg.in = dbus_connection_send_with_reply_and_block(this->conn,this->msg.out,10000,&error);
+
+		if(!this->msg.in) {
+			string message = error.message;
+			dbus_error_free(&error);
+			throw std::runtime_error(message.c_str());
+		}
+
+		return *this;
+
+	}
+
+	IPC::Request & IPC::Request::push(const char *arg) {
+		dbus_message_append_args(this->msg.out,DBUS_TYPE_STRING,&arg,DBUS_TYPE_INVALID);
+		return *this;
+	}
+
+ }
+
+
@@ -232,14 +232,17 @@
 				/// @brief Compacta array de argumentos em um bloco de dados.
 				static DWORD pack(std::vector<DataBlock *> &args, uint8_t * outBuffer, size_t szBuffer);
 #else
-
-				DBusMessage		* msg;
+				struct {
+					DBusMessage	* in;
+					DBusMessage	* out;
+				} msg;
 				DBusConnection	* conn;
 #endif // _WIN32
 			public:
 				Request(Session &session, const char *method);
+				~Request();
 				Request & call();
 				Request & push(const char *arg);
@@ -257,8 +260,9 @@
 #else
 				DBusConnection	* conn;
-				std::string		  name;	///< @brief D-Bus Object name.
-				std::string		  path;	///< @brief D-Bus Object path.
+				std::string		  name;			///< @brief D-Bus Object name.
+				std::string		  path;			///< @brief D-Bus Object path.
+				std::string		  interface;	///< @brief D-Bus interface.
 #endif // _WIN32
@@ -47,8 +47,9 @@
 	TN3270::Host host("pw3270:a");
-	/*
 	host.connect(getenv("LIB3270_DEFAULT_HOST"));
+
+	/*
 	cout << host << endl;
 	host << TN3270::ENTER;
	@@ -32,7 +32,7 @@ SOURCES= \		@@ -32,7 +32,7 @@ SOURCES= \
32	$(wildcard *.cc) \	32	$(wildcard *.cc) \
33	$(wildcard local/*.cc) \	33	$(wildcard local/*.cc) \
34	$(wildcard ipc/*.cc) \	34	$(wildcard ipc/*.cc) \
35	- $(wildcard @OSNAME@/*.c) \	35	+ $(wildcard @OSNAME@/*.cc) \
36	$(wildcard @OSNAME@/*.rc)	36	$(wildcard @OSNAME@/*.rc)
37		37
38	TEST_SOURCES= \	38	TEST_SOURCES= \
	@@ -89,6 +89,7 @@		@@ -89,6 +89,7 @@
89	this->name += ".";	89	this->name += ".";
90	this->name += (sep+1);	90	this->name += (sep+1);
91	this->path = "/br/com/bb/tn3270/session";	91	this->path = "/br/com/bb/tn3270/session";
		92	+ this->interface = "br.com.bb.tn3270.session";
92		93
93	debug("D-Bus Object name=\"",this->name,"\" D-Bus Object path=\"",this->path,"\"");	94	debug("D-Bus Object name=\"",this->name,"\" D-Bus Object path=\"",this->path,"\"");
94		95
@@ -0,0 +1,101 @@		@@ -0,0 +1,101 @@
	1	+/*
	2	+ * "Software pw3270, desenvolvido com base nos códigos fontes do WC3270 e X3270
	3	+ * (Paul Mattes Paul.Mattes@usa.net), de emulação de terminal 3270 para acesso a
	4	+ * aplicativos mainframe. Registro no INPI sob o nome G3270.
	5	+ *
	6	+ * Copyright (C) <2008> <Banco do Brasil S.A.>
	7	+ *
	8	+ * Este programa é software livre. Você pode redistribuí-lo e/ou modificá-lo sob
	9	+ * os termos da GPL v.2 - Licença Pública Geral GNU, conforme publicado pela
	10	+ * Free Software Foundation.
	11	+ *
	12	+ * Este programa é distribuído na expectativa de ser útil, mas SEM QUALQUER
	13	+ * GARANTIA; sem mesmo a garantia implícita de COMERCIALIZAÇÃO ou de ADEQUAÇÃO
	14	+ * A QUALQUER PROPÓSITO EM PARTICULAR. Consulte a Licença Pública Geral GNU para
	15	+ * obter mais detalhes.
	16	+ *
	17	+ * Você deve ter recebido uma cópia da Licença Pública Geral GNU junto com este
	18	+ * programa; se não, escreva para a Free Software Foundation, Inc., 51 Franklin
	19	+ * St, Fifth Floor, Boston, MA 02110-1301 USA
	20	+ *
	21	+ * Este programa está nomeado como - e possui - linhas de código.
	22	+ *
	23	+ * Contatos:
	24	+ *
	25	+ * perry.werneck@gmail.com (Alexandre Perry de Souza Werneck)
	26	+ * erico.mendonca@gmail.com (Erico Mascarenhas Mendonça)
	27	+ *
	28	+ */
	29	+
	30	+/**
	31	+ * @file src/lib3270++/linux/request.cc
	32	+ *
	33	+ * @brief Implements D-Bus message.
	34	+ *
	35	+ * @author perry.werneck@gmail.com
	36	+ *
	37	+ */
	38	+
	39	+ #include "../private.h"
	40	+
	41	+ using std::string;
	42	+
	43	+/---[ Implement ]----------------------------------------------------------------------------------/
	44	+
	45	+ namespace TN3270 {
	46	+
	47	+ IPC::Request::Request(Session &session, const char *method) {
	48	+
	49	+ this->conn = session.conn;
	50	+ this->msg.in = nullptr;
	51	+
	52	+ this->msg.out = dbus_message_new_method_call( session.name.c_str(), // Destination
	53	+ session.path.c_str(), // Path
	54	+ session.interface.c_str(), // Interface
	55	+ method // method
	56	+ );
	57	+
	58	+ if(!msg.out) {
	59	+ throw std::runtime_error("Can't create D-Bus Method Call");
	60	+ }
	61	+
	62	+ }
	63	+
	64	+ IPC::Request::~Request() {
	65	+ if(msg.out) {
	66	+ dbus_message_unref(msg.out);
	67	+ }
	68	+ if(msg.in) {
	69	+ dbus_message_unref(msg.in);
	70	+ }
	71	+ }
	72	+
	73	+ IPC::Request & IPC::Request::call() {
	74	+
	75	+ if(msg.in) {
	76	+ dbus_message_unref(msg.in);
	77	+ msg.in = nullptr;
	78	+ }
	79	+
	80	+ DBusError error;
	81	+ dbus_error_init(&error);
	82	+ this->msg.in = dbus_connection_send_with_reply_and_block(this->conn,this->msg.out,10000,&error);
	83	+
	84	+ if(!this->msg.in) {
	85	+ string message = error.message;
	86	+ dbus_error_free(&error);
	87	+ throw std::runtime_error(message.c_str());
	88	+ }
	89	+
	90	+ return *this;
	91	+
	92	+ }
	93	+
	94	+ IPC::Request & IPC::Request::push(const char *arg) {
	95	+ dbus_message_append_args(this->msg.out,DBUS_TYPE_STRING,&arg,DBUS_TYPE_INVALID);
	96	+ return *this;
	97	+ }
	98	+
	99	+ }
	100	+
	101	+