From: Michal Sojka <sojkam1@fel.cvut.cz>
Date: Wed, 23 Jun 2010 15:31:33 +0000 (+0200)
Subject: fcb: Add skeleton of transaction handling
X-Git-Url: https://rtime.felk.cvut.cz/gitweb/frescor/frsh.git/commitdiff_plain/5dd2691282152e544df1d076e44f740226a19249

fcb: Add skeleton of transaction handling
---

diff --git a/fres/cbroker/fcb.c b/fres/cbroker/fcb.c
index f34d47f..7f74dab 100644
--- a/fres/cbroker/fcb.c
+++ b/fres/cbroker/fcb.c
@@ -903,6 +903,31 @@ void get_resources(fres_contract_broker obj, fres_resource_seq** resources, CORB
 	*resources = seq;
 }
 
+CORBA_long
+negotiate_transaction(fres_contract_broker _obj,
+		      const fres_transaction_t* transaction,
+		      CORBA_Environment *ev)
+{
+	return FRSH_ERR_NOT_IMPLEMENTED;
+}
+
+CORBA_long
+wait_transaction(fres_contract_broker _obj,
+		 const CORBA_char * name,
+		 CORBA_Environment *ev)
+{
+	return FRSH_ERR_NOT_IMPLEMENTED;
+}
+
+CORBA_long
+allocate_transaction_vres(fres_contract_broker _obj,
+			  const CORBA_long id,
+			  CORBA_Environment *ev)
+{
+	return FRSH_ERR_NOT_IMPLEMENTED;
+}
+
+
 #if CONFIG_FCB_INET && !CONFIG_FORB_PROTO_INET_DEFAULT
 static int register_inet_port(forb_orb orb)
 {
@@ -928,6 +953,9 @@ struct forb_fres_contract_broker_impl impl = {
 	.register_allocator = register_allocator,
 	.redistribute_spare_capacity = redistribute_spare_capacity,
 	.get_resources = get_resources,
+	.negotiate_transaction = negotiate_transaction,
+	.wait_transaction = wait_transaction,
+	.allocate_transaction_vres = allocate_transaction_vres,
 };
 
 void peer_discovery_callback(const forb_orb peer_orb, const char *orb_id)
diff --git a/fres/cbroker/fcb.idl b/fres/cbroker/fcb.idl
index 58d4c66..70eb59a 100644
--- a/fres/cbroker/fcb.idl
+++ b/fres/cbroker/fcb.idl
@@ -58,6 +58,7 @@
 #define _CM_IDL
 
 #include "../contract/fres_contract_idl.idl"
+#include "../contract/fres_transaction_idl.idl"
 #include "../contract/fres_blocks.idl"
 #include "../resmng/frm.idl"
 #include "../resalloc/fra.idl"
@@ -153,6 +154,11 @@ module fres {
 		 * @param[out] resources
 		 */
 		void get_resources(out resource_seq resources);
+
+		long negotiate_transaction(in transaction_t transaction);
+		long wait_transaction(in string name,
+				      out transaction_t transaction);
+		long allocate_transaction_vres(in long id);
 	};
 };