Skip to content
Snippets Groups Projects
Commit a25a5ee6 authored by Alessio Igor Bogani's avatar Alessio Igor Bogani
Browse files

Rewrite from scratch

parent 45ebc2eb
No related branches found
No related tags found
No related merge requests found
Expand all Hide whitespace changes
Inline Side-by-side
src/Socket2.cpp
+ 300
− 499
View file @ a25a5ee6
This diff is collapsed.
src/Socket2.h
+ 18
− 31
View file @ a25a5ee6
......@@ -41,8 +41,6 @@
#include <tango.h>
#include <netdb.h>
#define BUFFER_SIZE 1000
/*----- PROTECTED REGION END -----*/ // Socket2.h
#ifdef TANGO_LOG
......@@ -77,28 +75,22 @@ class Socket2 : public TANGO_BASE_CLASS
// Add your own data members
string init_error;
enum {TCP, UDP} proto;
int fd;
int conn_state;
sockaddr_in sa;
socklen_t sa_len;
enum { TCP, UDP } proto;
int fd;
fd_set readfds;
fd_set writefds;
fd_set errorfds;
enum event_type { READ, WRITE };
unsigned char buffer[ BUFFER_SIZE ];
vector< unsigned char > data;
enum event_type {READ, WRITE};
bool connecting;
long long reconnections;
vector<unsigned char> data;
enum { SLEEP, SELECT } multiplexing;
int reconnections;
timeval tout;
enum {SLEEP, SELECT} multiplexing;
timeval timeout_timeval, tout;
/*----- PROTECTED REGION END -----*/ // Socket2::Data Members
// Device property data members
......@@ -106,7 +98,7 @@ public:
// Hostname:
std::string hostname;
// Port:
Tango::DevUShort port;
Tango::DevLong port;
// Protocol:
std::string protocol;
// Timeout:
......@@ -267,22 +259,17 @@ public:
/*----- PROTECTED REGION ID(Socket2::Additional Method prototypes) ENABLED START -----*/
// Additional Method prototypes
void check_init();
void resolve();
bool sleep(timeval);
void open();
void close();
void check_connection( );
bool wait_for( event_type et, timeval *tv );
bool wait_for_with_sleep( event_type et, timeval *tv );
bool wait_for_with_select( event_type et, timeval *tv );
int input_queue_length();
int output_queue_length();
bool read( struct timeval *tv );
void close();
void resolve();
ssize_t _write(int, const void*, size_t);
ssize_t _read(int, void*, size_t);
void check_state(bool);
bool wait_for(event_type);
size_t common_read(size_t);
/*----- PROTECTED REGION END -----*/ // Socket2::Additional Method prototypes
};
......
src/Socket2.xmi
+ 12
− 8
View file @ a25a5ee6
<?xml version="1.0" encoding="ASCII"?>
<pogoDsl:PogoSystem xmi:version="2.0" xmlns:xmi="http://www.omg.org/XMI" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:pogoDsl="http://www.esrf.fr/tango/pogo/PogoDsl">
<classes name="Socket2" pogoRevision="9.7">
<description description="" title="" sourcePath="/home/alessio/Sources/git-trees/socket2/src" language="Cpp" filestogenerate="XMI file,Code files,Protected Regions" license="GPL" hasMandatoryProperty="true" hasConcreteProperty="true" hasAbstractCommand="false" hasAbstractAttribute="false">
<description description="" title="" sourcePath="/home/alessio.bogani/Sources/git-trees/linkstabilizer/deps/socket2/src" language="Cpp" filestogenerate="XMI file,Code files,Protected Regions" license="GPL" hasMandatoryProperty="true" hasConcreteProperty="true" hasAbstractCommand="false" hasAbstractAttribute="false">
<inheritances classname="Device_Impl" sourcePath=""/>
<identification contact="at elettra.eu> - Alessio Igor Bogani &lt;alessio.bogani" author="Alessio Igor Bogani &lt;alessio.bogani" emailDomain="elettra.eu>" classFamily="Communication" siteSpecific="" platform="Unix Like" bus="Socket" manufacturer="none" reference=""/>
</description>
......@@ -10,7 +10,7 @@
<status abstract="false" inherited="false" concrete="true" concreteHere="true"/>
</deviceProperties>
<deviceProperties name="Port" mandatory="true" description="">
<type xsi:type="pogoDsl:UShortType"/>
<type xsi:type="pogoDsl:IntType"/>
<status abstract="false" inherited="false" concrete="true" concreteHere="true"/>
</deviceProperties>
<deviceProperties name="Protocol" description="">
......@@ -25,8 +25,9 @@
<deviceProperties name="IOMultiplexing" description="Use `sleep` for fixed sleep and `select` for the syscall of the same name">
<type xsi:type="pogoDsl:StringType"/>
<status abstract="false" inherited="false" concrete="true" concreteHere="true"/>
<DefaultPropValue>SELECT</DefaultPropValue>
</deviceProperties>
<commands name="Write" description="" execMethod="write" displayLevel="OPERATOR" polledPeriod="0">
<commands name="Write" description="" execMethod="write" displayLevel="OPERATOR" polledPeriod="0" isDynamic="false">
<argin description="">
<type xsi:type="pogoDsl:CharArrayType"/>
</argin>
......@@ -34,7 +35,6 @@
<type xsi:type="pogoDsl:VoidType"/>
</argout>
<status abstract="false" inherited="false" concrete="true" concreteHere="true"/>
<excludedStates>INIT</excludedStates>
</commands>
<commands name="Read" description="" execMethod="read" displayLevel="OPERATOR" polledPeriod="0">
<argin description="">
......@@ -44,7 +44,6 @@
<type xsi:type="pogoDsl:CharArrayType"/>
</argout>
<status abstract="false" inherited="false" concrete="true" concreteHere="true"/>
<excludedStates>INIT</excludedStates>
</commands>
<commands name="ReadUntil" description="" execMethod="read_until" displayLevel="OPERATOR" polledPeriod="0">
<argin description="">
......@@ -54,7 +53,6 @@
<type xsi:type="pogoDsl:CharArrayType"/>
</argout>
<status abstract="false" inherited="false" concrete="true" concreteHere="true"/>
<excludedStates>INIT</excludedStates>
</commands>
<attributes name="InputLength" attType="Scalar" rwType="READ" displayLevel="OPERATOR" polledPeriod="0" maxX="" maxY="" allocReadMember="true" isDynamic="false">
<dataType xsi:type="pogoDsl:IntType"/>
......@@ -83,10 +81,16 @@
<states name="ON" description="Connected">
<status abstract="false" inherited="false" concrete="true" concreteHere="true"/>
</states>
<states name="FAULT" description="Connection failed">
<states name="INIT" description="">
<status abstract="false" inherited="false" concrete="true" concreteHere="true"/>
</states>
<states name="INIT" description="">
<states name="UNKNOWN" description="">
<status abstract="false" inherited="false" concrete="true" concreteHere="true"/>
</states>
<states name="ALARM" description="">
<status abstract="false" inherited="false" concrete="true" concreteHere="true"/>
</states>
<states name="FAULT" description="">
<status abstract="false" inherited="false" concrete="true" concreteHere="true"/>
</states>
<preferences docHome="./doc_html" makefileHome="$(TANGO_HOME)"/>
......
src/Socket2Class.cpp
+ 2
− 1
View file @ a25a5ee6
......@@ -338,8 +338,9 @@ void Socket2Class::set_default_property()
add_wiz_dev_prop(prop_name, prop_desc);
prop_name = "IOMultiplexing";
prop_desc = "Use `sleep` for fixed sleep and `select` for the syscall of the same name";
prop_def = "";
prop_def = "SELECT";
vect_data.clear();
vect_data.push_back("SELECT");
if (prop_def.length()>0)
{
Tango::DbDatum data(prop_name);
......
src/Socket2StateMachine.cpp
+ 9
− 19
View file @ a25a5ee6
......@@ -39,11 +39,13 @@
/*----- PROTECTED REGION END -----*/ // Socket2::Socket2StateMachine.cpp
//================================================================
// States | Description
// States | Description
//================================================================
// ON | Connected
// FAULT | Connection failed
// INIT |
// ON | Connected
// INIT |
// UNKNOWN |
// ALARM |
// FAULT |
namespace Socket2_ns
......@@ -113,14 +115,10 @@ bool Socket2::is_Reconnections_allowed(TANGO_UNUSED(Tango::AttReqType type))
//--------------------------------------------------------
bool Socket2::is_Write_allowed(TANGO_UNUSED(const CORBA::Any &any))
{
// Compare device state with not allowed states.
if (get_state()==Tango::INIT)
{
// Not any excluded states for Write command.
/*----- PROTECTED REGION ID(Socket2::WriteStateAllowed) ENABLED START -----*/
/*----- PROTECTED REGION END -----*/ // Socket2::WriteStateAllowed
return false;
}
return true;
}
......@@ -132,14 +130,10 @@ bool Socket2::is_Write_allowed(TANGO_UNUSED(const CORBA::Any &any))
//--------------------------------------------------------
bool Socket2::is_Read_allowed(TANGO_UNUSED(const CORBA::Any &any))
{
// Compare device state with not allowed states.
if (get_state()==Tango::INIT)
{
// Not any excluded states for Read command.
/*----- PROTECTED REGION ID(Socket2::ReadStateAllowed) ENABLED START -----*/
/*----- PROTECTED REGION END -----*/ // Socket2::ReadStateAllowed
return false;
}
return true;
}
......@@ -151,14 +145,10 @@ bool Socket2::is_Read_allowed(TANGO_UNUSED(const CORBA::Any &any))
//--------------------------------------------------------
bool Socket2::is_ReadUntil_allowed(TANGO_UNUSED(const CORBA::Any &any))
{
// Compare device state with not allowed states.
if (get_state()==Tango::INIT)
{
// Not any excluded states for ReadUntil command.
/*----- PROTECTED REGION ID(Socket2::ReadUntilStateAllowed) ENABLED START -----*/
/*----- PROTECTED REGION END -----*/ // Socket2::ReadUntilStateAllowed
return false;
}
return true;
}
......
0% or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment