nrtb-core team mailing list archive

[noreply@xxxxxxxxxxxxx]

------------------------------------------------------------
revno: 24
committer: Rick Stovall <fpstovall>
branch nick: ricks-sprint-003
timestamp: Fri 2013-08-23 21:23:10 -0400
message:
  Roughed out the initial structures for the IPC support library. The header compiles clean. After review, I'll be completing the IPC classes shortly.
added:
  cpp/common/ipc_channel/Makefile
  cpp/common/ipc_channel/ipc_channel.cpp
  cpp/common/ipc_channel/ipc_channel.h
  cpp/common/ipc_channel/ipc_channel_test.cpp


--
lp:~fpstovall/nrtb/fps-sprint-003
https://code.launchpad.net/~fpstovall/nrtb/fps-sprint-003

Your team NRTB Core is subscribed to branch lp:~fpstovall/nrtb/fps-sprint-003.
To unsubscribe from this branch go to https://code.launchpad.net/~fpstovall/nrtb/fps-sprint-003/+edit-subscription

=== added file 'cpp/common/ipc_channel/Makefile'
--- cpp/common/ipc_channel/Makefile	1970-01-01 00:00:00 +0000
+++ cpp/common/ipc_channel/Makefile	2013-08-24 01:23:10 +0000
@@ -0,0 +1,47 @@
+#***********************************************
+# This file is part of the NRTB project (https://launchpad.net/nrtb).
+#
+#    NRTB is free software: you can redistribute it and/or modify
+#    it under the terms of the GNU General Public License as published by
+#    the Free Software Foundation, either version 3 of the License, or
+#    (at your option) any later version.
+#
+#    NRTB is distributed in the hope that it will be useful,
+#    but WITHOUT ANY WARRANTY; without even the implied warranty of
+#    MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
+#    GNU General Public License for more details.
+#
+#    You should have received a copy of the GNU General Public License
+#    along with NRTB.  If not, see <http://www.gnu.org/licenses/>.
+#
+#***********************************************
+
+target=ipc_channel
+
+lib:	${target}_test
+	@./${target}_test
+	@cp -v ${target}.h ../include/
+	@cp -v ${target}.o ../obj/
+	@echo build complete
+
+${target}_test:	${target}.o ${target}_test.cpp
+	@rm -f ${target}_test
+	g++ -c -O3 ${target}_test.cpp -I ../include ${bargs} 
+	g++ -o ${target}_test ${target}_test.o ${target}.o ${largs}
+
+
+${target}.o:	${target}.cpp ${target}.h Makefile
+	@rm -f ${target}.o
+	g++ -c -O3 ${target}.cpp -I ../include ${bargs} 
+
+clean:
+	@rm -vf *.o ../include/${target}.h ../obj/${target}.o ${target}_test
+	@echo all objects and executables have been erased.
+
+switches=-std=gnu++11 -D _GLIBCXX_USE_SCHED_YIELD -D _GLIBCXX_USE_NANOSLEEP 
+libs=../obj/common.o ../obj/logger.o  ../obj/serializer.o -lpthread
+include=-I../include
+bargs=${switches} ${include}
+largs=${switches} ${libs}
+
+

=== added file 'cpp/common/ipc_channel/ipc_channel.cpp'
--- cpp/common/ipc_channel/ipc_channel.cpp	1970-01-01 00:00:00 +0000
+++ cpp/common/ipc_channel/ipc_channel.cpp	2013-08-24 01:23:10 +0000
@@ -0,0 +1,27 @@
+/***********************************************
+ This file is part of the NRTB project (https://*launchpad.net/nrtb).
+ 
+ NRTB is free software: you can redistribute it and/or modify
+ it under the terms of the GNU General Public License as published by
+ the Free Software Foundation, either version 3 of the License, or
+ (at your option) any later version.
+ 
+ NRTB is distributed in the hope that it will be useful,
+ but WITHOUT ANY WARRANTY; without even the implied warranty of
+ MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
+ GNU General Public License for more details.
+ 
+ You should have received a copy of the GNU General Public License
+ along with NRTB.  If not, see <http://www.gnu.org/licenses/>.
+ 
+ **********************************************/
+
+// see base_socket.h for documentation
+
+#include "ipc_channel.h"
+
+namespace nrtb 
+{
+
+} // namespace nrtb
+

=== added file 'cpp/common/ipc_channel/ipc_channel.h'
--- cpp/common/ipc_channel/ipc_channel.h	1970-01-01 00:00:00 +0000
+++ cpp/common/ipc_channel/ipc_channel.h	2013-08-24 01:23:10 +0000
@@ -0,0 +1,75 @@
+/***********************************************
+ This file is part of the NRTB project (https://*launchpad.net/nrtb).
+ 
+ NRTB is free software: you can redistribute it and/or modify
+ it under the terms of the GNU General Public License as published by
+ the Free Software Foundation, either version 3 of the License, or
+ (at your option) any later version.
+ 
+ NRTB is distributed in the hope that it will be useful,
+ but WITHOUT ANY WARRANTY; without even the implied warranty of
+ MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
+ GNU General Public License for more details.
+ 
+ You should have received a copy of the GNU General Public License
+ along with NRTB.  If not, see <http://www.gnu.org/licenses/>.
+ 
+ **********************************************/
+ 
+#ifndef ipc_channel_header
+#define ipc_channel_header
+
+#include <common.h>
+#include <linear_queue.h>
+#include <memory>
+#include <boost/concept_check.hpp>
+#include <serializer.h>
+#include <singleton.h>
+
+
+namespace nrtb
+{
+  
+class abs_ipc_record;
+
+typedef std::unique_ptr<abs_ipc_record> ipc_record_p;
+
+typedef linear_queue<ipc_record_p> ipc_queue;
+
+/** abs_ipc_record is the base for all ipc messages.
+ * This abstract includes a return_address (the
+ * ipc_queue the a return should be put to). but 
+ * no other payload. It'll need to be overriden to 
+ * provide whatever payload a given channel may 
+ * need.
+ */
+class abs_ipc_record
+{
+  ipc_queue & return_address;
+};
+
+/** ipc_channel_manager provides a place to stash ipc_queues
+ * so that their scope is not tied to the lifetime of any
+ * particular thread.  Ideally, this should be used as s 
+ * singleton class.
+ */
+class ipc_channel_manager
+{
+public:
+  typedef std::map<std::string,ipc_queue> channel_List;
+  typedef channel_List::iterator iterator;
+  
+  ipc_queue & get(std::string name);
+  iterator begin();
+  iterator end();
+  
+private:
+  channel_List channels;
+};
+
+/// And here is the singleton class to make ipc channels safe.
+typedef singleton<ipc_channel_manager> global_ipc_channel_manager;
+
+} // namepace nrtb
+
+#endif // ipc_channel_header

=== added file 'cpp/common/ipc_channel/ipc_channel_test.cpp'
--- cpp/common/ipc_channel/ipc_channel_test.cpp	1970-01-01 00:00:00 +0000
+++ cpp/common/ipc_channel/ipc_channel_test.cpp	2013-08-24 01:23:10 +0000
@@ -0,0 +1,61 @@
+/***********************************************
+ This file is part of the NRTB project (https://*launchpad.net/nrtb).
+ 
+ NRTB is free software: you can redistribute it and/or modify
+ it under the terms of the GNU General Public License as published by
+ the Free Software Foundation, either version 3 of the License, or
+ (at your option) any later version.
+ 
+ NRTB is distributed in the hope that it will be useful,
+ but WITHOUT ANY WARRANTY; without even the implied warranty of
+ MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
+ GNU General Public License for more details.
+ 
+ You should have received a copy of the GNU General Public License
+ along with NRTB.  If not, see <http://www.gnu.org/licenses/>.
+ 
+ **********************************************/
+
+#include "ipc_channel.h"
+#include <iostream>
+
+using namespace nrtb;
+using namespace std;
+
+
+int main()
+{
+  cout << "=========== IPC Channel test ============="
+    << endl;
+
+  cout << "=========== IPC Channel test complete ============="
+    << endl;
+  
+};
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+