source: libs/SAMGAR V2/Module/InteruptOverlay.h @ 521

Revision 521, 1.4 KB checked in by KDucasse, 9 years ago (diff)
Line 
1#include <yarp/os/all.h>
2
3
4#include <stdlib.h>
5#include <stdio.h>
6#include <string.h>
7
8#include <iostream>
9using namespace yarp;
10using namespace yarp::os;
11using namespace std;
12
13
14
15
16
17///// a special class for sending and reciving data from the server, HIVE mind
18class MainPortOverlay : public BufferedPort<Bottle>
19{
20private:
21
22public:
23        void SetUp(string name)
24        {
25                this->open(name.c_str());
26        }
27        virtual void onRead(Bottle& b)
28         {
29          // process data in b
30     }
31};
32
33
34 class myPortReport : public PortReport
35        {
36        public:
37        BufferedPort<Bottle> *CopyMainPort;
38        void report(const PortInfo& info)
39                {
40                string s1,s2;
41                s1 = info.sourceName.c_str();
42                s2 = info.targetName.c_str();
43
44                if(s1.compare("/Control")!=0 && s2.compare("/Control")!=0)
45                {
46                if(info.created)
47                        {
48                //              puts("********************************* active connection********************");
49                                while(CopyMainPort->isWriting()){}
50                                Bottle& B = CopyMainPort->prepare();
51                                B.clear();
52                                B.addString("Active_connection");
53                                B.addString(info.sourceName.c_str());
54                                B.addString(info.targetName.c_str());
55                                CopyMainPort->write(); 
56                        }
57                else
58                        {
59                                while(CopyMainPort->isWriting()){}
60                                Bottle& B = CopyMainPort->prepare();
61                                B.clear();
62                                B.addString("Disactive_connection");
63                                B.addString(info.sourceName.c_str());
64                                B.addString(info.targetName.c_str());
65                                CopyMainPort->write();
66                        }
67                }
68                }
69        };
70
71
72
73
Note: See TracBrowser for help on using the repository browser.