PIP 0.5.0_alpha Platform-Independent Primitives

- Main Page
- Related Pages
- Namespaces
- Classes
- Files

- Class List
- Class Index
- Class Hierarchy
- Class Members

Classes | Public Types | Public Member Functions | Static Public Member Functions | Protected Member Functions | List of all members
PIEthernet Class Reference

Ethernet device. More...

Inheritance diagram for PIEthernet:
[legend]

## Classes
struct | Interface
| Network interface descriptor. More...
class | InterfaceList
| Array of Interface with some features. More...

## Public Types
enum | Type { UDP, TCP_Client, TCP_Server }
| Type of PIEthernet. More...
enum | Parameters { ReuseAddress = 0x1, Broadcast = 0x2, SeparateSockets = 0x4, MulticastLoop = 0x8 }
| Parameters of PIEthernet. More...
enum | InterfaceFlag { ifActive = 0x1, ifRunning = 0x2, ifBroadcast = 0x4, ifMulticast = 0x8, ifLoopback = 0x10, ifPTP = 0x20 }
| Flags of network interface. More...
typedef PIFlags< InterfaceFlag > | InterfaceFlags
| PIFlags of network interface flags
Public Types inherited from PIIODevice
enum | DeviceMode { ReadOnly = 0x01, WriteOnly = 0x02, ReadWrite = 0x03 }
| Open modes for PIIODevice. More...
Public Types inherited from PIThread
enum | Priority { piLowerst, piLow, piNormal, piHigh, piHighest }
| Priority of thread. More...

## Public Member Functions
| PIEthernet ()
| Contructs UDP PIEthernet with empty read address.
| PIEthernet (Type type, const PIString &ip_port=PIString(), const PIFlags< Parameters > params=0)
| Contructs PIEthernet with type "type", read address "ip_port" and parameters "params".
void | setReadAddress (const PIString &ip, int port)
| Set read address.
void | setReadAddress (const PIString &ip_port)
| Set read address in format "i.i.i.i:p".
void | setReadIP (const PIString &ip)
| Set read IP.
void | setReadPort (int port)
| Set read port.
void | setSendAddress (const PIString &ip, int port)
| Set send address.
void | setSendAddress (const PIString &ip_port)
| Set send address in format "i.i.i.i:p".
void | setSendIP (const PIString &ip)
| Set send IP.
void | setSendPort (int port)
| Set send port.
PIString | readAddress () const
| Returns read address in format "i.i.i.i:p".
PIString | readIP () const
| Returns read IP.
int | readPort () const
| Returns read port.
PIString | sendAddress () const
| Returns send address in format "i.i.i.i:p".
PIString | sendIP () const
| Returns send IP.
int | sendPort () const
| Returns send port.
PIString | lastReadAddress () const
| Returns address of last received UDP packet in format "i.i.i.i:p".
PIString | lastReadIP () const
| Returns IP of last received UDP packet.
int | lastReadPort () const
| Returns port of last received UDP packet.
void | setParameters (PIFlags< PIEthernet::Parameters > parameters_)
| Set parameters to "parameters_". You should to reopen PIEthernet to apply them.
void | setParameter (PIEthernet::Parameters parameter, bool on=true)
| Set parameter "parameter" to state "on". You should to reopen PIEthernet to apply this.
bool | isParameterSet (PIEthernet::Parameters parameter) const
| Returns if parameter "parameter" is set.
PIFlags< PIEthernet::Parameters > | parameters () const
| Returns parameters.
Type | type () const
| Returns PIEthernet type.
double | readTimeout () const
| Returns read timeout.
double | writeTimeout () const
| Returns write timeout.
void | setReadTimeout (double ms)
| Set timeout for read.
void | setWriteTimeout (double ms)
| Set timeout for write.
int | TTL () const
| Returns TTL (Time To Live)
int | multicastTTL () const
| Returns multicast TTL (Time To Live)
void | setTTL (int ttl)
| Set TTL (Time To Live), default is 64.
void | setMulticastTTL (int ttl)
| Set multicast TTL (Time To Live), default is 1.
bool | joinMulticastGroup (const PIString &group)
| Join to multicast group with address "group". Use only for UDP.
bool | leaveMulticastGroup (const PIString &group)
| Leave multicast group with address "group". Use only for UDP.
const PIStringList & | multicastGroups () const
| Returns joined multicast groups. Use only for UDP.
bool | connect ()
| Connect to TCP server with address readAddress(). Use only for TCP_Client.
bool | connect (const PIString &ip, int port)
| Connect to TCP server with address "ip":"port". Use only for TCP_Client.
bool | connect (const PIString &ip_port)
| Connect to TCP server with address "ip_port". Use only for TCP_Client.
bool | isConnected () const
| Returns if PIEthernet connected to TCP server. Use only for TCP_Client.
bool | listen (bool threaded=false)
| Start listen for incoming TCP connections on address readAddress(). Use only for TCP_Server.
bool | listen (const PIString &ip, int port, bool threaded=false)
| Start listen for incoming TCP connections on address "ip":"port". Use only for TCP_Server.
bool | listen (const PIString &ip_port, bool threaded=false)
| Start listen for incoming TCP connections on address "ip_port". Use only for TCP_Server.
bool | send (const void *data, int size, bool threaded=false)
| Send data "data" with size "size" to address sendAddress() for UDP or readAddress() for TCP_Client.
bool | send (const PIString &ip, int port, const void *data, int size, bool threaded=false)
| Send data "data" with size "size" to address "ip":"port".
bool | send (const PIString &ip_port, const void *data, int size, bool threaded=false)
| Send data "data" with size "size" to address "ip_port".
bool | send (const PIByteArray &data, bool threaded=false)
| Send data "data" to address sendAddress() for UDP or readAddress() for TCP_Client.
bool | send (const PIString &ip, int port, const PIByteArray &data, bool threaded=false)
| Send data "data" to address "ip":"port" for UDP.
bool | send (const PIString &ip_port, const PIByteArray &data, bool threaded=false)
| Send data "data" to address "ip_port" for UDP.
int | read (void *read_to, int max_size)
| Wait for some data and read it to "read_to".
int | write (const void *data, int max_size)
| Send data "read_to" with size "max_size" to address sendAddress() for UDP or readAddress() for TCP_Client.
int | write (const PIByteArray &data)
| Send data "data" to address sendAddress() for UDP or readAddress() for TCP_Client.
virtual bool | canWrite () const
| Return true if device can write now.
PIString | constructFullPath () const
| Reimplement to construct full unambiguous string, describes this device, default returns fullPathPrefix() + "://" + path()
Public Member Functions inherited from PIIODevice
| PIIODevice ()
| Constructs a empty PIIODevice.
| PIIODevice (const PIString &path, DeviceMode mode=ReadWrite)
| Constructs a PIIODevice with path and mode. More...
DeviceMode | mode () const
| Current open mode of device.
PIString | path () const
| Current path of device.
void | setPath (const PIString &path)
| Set path of device.
bool | isReadable () const
| Return true if mode is ReadOnly or ReadWrite.
bool | isWriteable () const
| Return true if mode is WriteOnly or ReadWrite.
bool | isOpened () const
| Return true if device is successfully opened.
bool | isClosed () const
| Return true if device is closed.
virtual bool | canRead () const
| Return true if device can read now.
void | setReopenEnabled (bool yes=true)
| Set execution of open enabled while threaded read on closed device.
void | setReopenTimeout (int msecs)
| Set timeout in milliseconds between open tryings if reopen is enabled.
bool | isReopenEnabled () const
| Return reopen enable.
int | reopenTimeout ()
| Return reopen timeout.
void | setThreadedReadSlot (ReadRetFunc func)
| Set "threaded read slot". More...
void | setThreadedReadData (void *d)
| Set custom data that will be passed to "threaded read slot".
void | setThreadedReadBufferSize (int new_size)
| Set size of threaded read buffer. More...
int | threadedReadBufferSize () const
| Return size of threaded read buffer.
const uchar * | threadedReadBuffer () const
| Return content of threaded read buffer.
void * | threadedReadData () const
| Return custom data that will be passed to "threaded read slot".
bool | isThreadedRead () const
| Return true if threaded read is started.
void | startThreadedRead ()
| Start threaded read.
void | startThreadedRead (ReadRetFunc func)
| Start threaded read and assign "threaded read slot" to "func".
void | stopThreadedRead ()
| Stop threaded read.
bool | isThreadedWrite () const
| Return true if threaded write is started.
void | startThreadedWrite ()
| Start threaded write.
void | stopThreadedWrite ()
| Stop threaded write.
void | clearThreadedWriteQueue ()
| Clear threaded write task queue.
void | start ()
| Start both threaded read and threaded write.
void | stop (bool wait=false)
| Stop both threaded read and threaded write and if "wait" block until both threads are stop.
PIByteArray | read (int max_size)
| Read from device maximum "max_size" bytes and return them as PIByteArray.
PIByteArray | readForTime (double timeout_ms)
| Read from device for "timeout_ms" milliseconds and return readed data as PIByteArray. Timeout should to be greater than 0.
int | write (const PIByteArray &data)
| Write "data" to device.
ullong | writeThreaded (const void *data, int max_size)
| Add task to threaded write queue and return task ID.
ullong | writeThreaded (const PIByteArray &data)
| Add task to threaded write queue and return task ID.
bool | configure (const PIString &config_file, const PIString &section, bool parent_section=false)
| Configure device from section "section" of file "config_file", if "parent_section" parent section also will be read.
bool | open ()
| Open device.
bool | open (const PIString &_path)
| Open device with path "path".
bool | open (const DeviceMode &_mode)
| Open device with mode "mode".
bool | open (const PIString &_path, const DeviceMode &_mode)
| Open device with path "path" and mode "mode".
bool | close ()
| Close device.
bool | initialize ()
| Initialize device.
virtual void | flush ()
| Immediate write all buffers.
void | opened ()
| Raise if succesfull open.
void | closed ()
| Raise if succesfull close.
void | threadedReadEvent (uchar *readed, int size)
| Raise if read thread succesfull read some data.
void | threadedWriteEvent (ullong id, int written_size)
| Raise if write thread succesfull write some data of task with ID "id".
Public Member Functions inherited from PIThread
| PIThread (void *data, ThreadFunc func, bool startNow=false, int loop_delay=-1)
| Contructs thread with custom data "data", external function "func" and main loop delay "loop_delay".
| PIThread (bool startNow=false, int loop_delay=-1)
| Contructs thread with main loop delay "loop_delay".
void | setData (void *d)
| Set common data passed to external function.
void | setSlot (ThreadFunc func)
| Set external function that will be executed after every run()
void | setPriority (PIThread::Priority prior)
| Set priority of thread.
void * | data () const
| Returns common data passed to external function.
PIThread::Priority | priority () const
| Return priority of thread.
bool | isRunning () const
| Return `true` if thread is running.
void | needLockRun (bool need)
| Set necessity of lock every run with internal mutex.
PIMutex & | mutex ()
| Return internal mutex.
bool | start (int timer_delay)
| Start thread. More...
bool | start (ThreadFunc func, int timer_delay)
| Start thread. More...
bool | startOnce ()
| Start thread without internal loop. More...
bool | startOnce (ThreadFunc func)
| Start thread without internal loop. More...
void | stop (bool wait)
| Stop thread. More...
void | terminate ()
| Strongly stop thread. More...
bool | waitForStart (int timeout_msecs)
| Wait for thread start. More...
bool | waitForFinish (int timeout_msecs)
| Wait for thread finish. More...
void | lock ()
| Lock internal mutex.
void | unlock ()
| Unlock internal mutex.
void | started ()
| Raise on thread start.
void | stopped ()
| Raise on thread stop.
Public Member Functions inherited from PIObject
| PIObject (const PIString &name=PIString())
| Contructs PIObject with name "name".
PIString | name () const
| Returns object name.
virtual const char * | className () const
| Returns object class name.
virtual const char * | superClassName () const
| Returns object superclass name.
bool | debug () const
| Return if debug of this object is active.
void | setName (const PIString &name)
| Set object name.
void | setDebug (bool debug)
| Set object debug active.
const PIMap< PIString, PIVariant > & | properties () const
| Returns properties of the object.
int | propertiesCount () const
| Returns properties count of the object.
PIVariant | property (const PIString &name) const
| Returns property with name "name".
void | setProperty (const PIString &name, const PIVariant &value)
| Set property with name "name" to "value". If there is no such property in object it will be added.
bool | isPropertyExists (const PIString &name) const
| Returns if property with name "name" exists.

## Static Public Member Functions
static InterfaceList | interfaces ()
| Returns all system network interfaces.
static PIStringList | allAddresses ()
| Returns all system network IP addresses.
Static Public Member Functions inherited from PIIODevice
static PIIODevice * | createFromFullPath (const PIString &full_path)
| Try to determine suitable device, create new one, configure it with configureFromFullPath() and returns it. More...
Static Public Member Functions inherited from PIObject
static void | piDisconnect (PIObject *src, const PIString &sig)
| Disconnect object "src" from all connections with event name "sig".
static void | piDisconnect (PIObject *src)
| Disconnect object "src" from all connections, i.e. all connections where object "src" is emitter.
static PIObject * | findByName (const PIString &name)
| Returns PIObject* with name "name" or 0, if there is no object found.

## Protected Member Functions
void | propertyChanged (const PIString &name)
| Virtual function executes after property with name "name" has been changed.
PIString | fullPathPrefix () const
| Reimplement to construct full unambiguous string prefix. Creating devices by unambiguous string.
void | configureFromFullPath (const PIString &full_path)
| Reimplement to configure your device with parameters of full unambiguous string. Default implementation does nothing.
bool | configureDevice (const void *e_main, const void *e_parent=0)
| Reimplement to configure device from entries "e_main" and "e_parent", cast arguments to PIConfig::Entry*.
virtual void | received (const void *data, int size)
| Executes when any read function was successful. Default implementation does nothing.
bool | init ()
| Function executed before first openDevice() or from constructor.
bool | openDevice ()
| Reimplement to open device, return value will be set to "opened_" variable.
bool | closeDevice ()
| Reimplement to close device, inverse return value will be set to "opened_" variable.
Protected Member Functions inherited from PIIODevice
virtual bool | threadedRead (uchar *readed, int size)
| Function executed when thread read some data, default implementation execute external slot "ret_func_".
Protected Member Functions inherited from PIObject
PIObject * | emitter () const
| Returns PIObject* which has raised an event. This value is correct only in definition of some event handler.
void | deleted ()
| Raise before object delete. More...

## Events
void | newConnection (PIEthernet *client)
| Raise on new TCP connection received.
void | connected ()
| Raise if succesfull TCP connection.
void | disconnected (bool withError)
| Raise if TCP connection was closed.

## Configurable parameters
string | ip
| read ip, default ""
int | port
| read port, default 0
int | parameters
| ethernet parameters
double | readTimeout
| read timeout, default 1000 ms
double | writeTimeout
| write timeout, default 1000 ms
int | TTL
| time-to-live, default 64
int | multicastTTL
| time-to-live for multicast, default 1

## Additional Inherited Members
Public Attributes inherited from PIIODevice
bool | reopenEnabled
| setReopenEnabled, default "true"
int | reopenTimeout
| setReopenTimeout in ms, default 1000
int | threadedReadBufferSize
| setThreadedReadBufferSize in bytes, default 4096
Related Functions inherited from PIIODevice
template<typename T >
T | readDeviceSetting (const PIString &name, const T &def, const PIConfig::Entry *em, const PIConfig::Entry *ep)
| Service function. useful for configuring devices. More...
#define | REGISTER_DEVICE(class)
| Use this macro to enable automatic creation instances of your class with createFromFullPath() function.
#define | PIIODEVICE(class)
| Use this macro instead of PIOBJECT when describe your own PIIODevice.
Related Functions inherited from PIObject
#define | piCoutObj
| Macro used for conditional (piDebug and PIObject::debug()) output to PICout for subclasses of PIObject.
#define | PIOBJECT(name)
| you should use this macro after class declaration to use EVENT and EVENT_HANDLER and correct piCoutObj output
#define | PIOBJECT_SUBCLASS(name, parent)
| you should use this macro after class declaration to use EVENT and EVENT_HANDLER of parent class
#define | EVENT_HANDLER0(ret, name) ret name()
| declare event handler "event" with name "name" and return type "ret", ret name()
#define | EVENT_HANDLER1(ret, name, type0, var0) ret name(type0 var0)
| declare event handler "event" with name "name" and return type "ret", ret name(type0 var0)
#define | EVENT_HANDLER2(ret, name, type0, var0, type1, var1) ret name(type0 var0, type1 var1)
| declare event handler "event" with name "name" and return type "ret", ret name(type0 var0, type1 var1)
#define | EVENT_HANDLER3(ret, name, type0, var0, type1, var1, type2, var2) ret name(type0 var0, type1 var1, type2 var2)
| declare event handler "event" with name "name" and return type "ret", ret name(type0 var0, type1 var1, type2 var2)
#define | EVENT_HANDLER4(ret, name, type0, var0, type1, var1, type2, var2, type3, var3) ret name(type0 var0, type1 var1, type2 var2, type3 var3)
| declare event handler "event" with name "name" and return type "ret", ret name(type0 var0, type1 var1, type2 var2, type3 var3)
#define | EVENT_HANDLER EVENT_HANDLER0
| EVENT_HANDLER is synonym of EVENT_HANDLER0.
#define | EVENT_VHANDLER0(ret, name) virtual ret name()
| declare virtual event handler "event" with name "name" and return type "ret", virtual ret name()
#define | EVENT_VHANDLER1(ret, name, type0, var0) virtual ret name(type0 var0)
| declare virtual event handler "event" with name "name" and return type "ret", virtual ret name(type0 var0)
#define | EVENT_VHANDLER2(ret, name, type0, var0, type1, var1) virtual ret name(type0 var0, type1 var1)
| declare virtual event handler "event" with name "name" and return type "ret", virtual ret name(type0 var0, type1 var1)
#define | EVENT_VHANDLER3(ret, name, type0, var0, type1, var1, type2, var2) virtual ret name(type0 var0, type1 var1, type2 var2)
| declare virtual event handler "event" with name "name" and return type "ret", virtual ret name(type0 var0, type1 var1, type2 var2)
#define | EVENT_VHANDLER4(ret, name, type0, var0, type1, var1, type2, var2, type3, var3) virtual ret name(type0 var0, type1 var1, type2 var2, type3 var3)
| declare virtual event handler "event" with name "name" and return type "ret", virtual ret name(type0 var0, type1 var1, type2 var2, type3 var3)
#define | EVENT_VHANDLER EVENT_VHANDLER0
| EVENT_VHANDLER is synonym of EVENT_VHANDLER0.
#define | EVENT0(name) void name();
| declare event "event" with name "name", void name();
#define | EVENT1(name, type0, var0) void name(type0 var0);
| declare event "event" with name "name", void name(type0 var0);
#define | EVENT2(name, type0, var0, type1, var1) void name(type0 var0, type1 var1);
| declare event "event" with name "name", void name(type0 var0, type1 var1);
#define | EVENT3(name, type0, var0, type1, var1, type2, var2) void name(type0 var0, type1 var1, type2 var2);
| declare event "event" with name "name", void name(type0 var0, type1 var1, type2 var2);
#define | EVENT4(name, type0, var0, type1, var1, type2, var2, type3, var3) void name(type0 var0, type1 var1, type2 var2, type3 var3);
| declare event "event" with name "name", void name(type0 var0, type1 var1, type2 var2, type3 var3);
#define | EVENT EVENT0
| EVENT is synonym of EVENT0.
#define | CONNECTU(src, event, dest, handler)
| connect event "event" from object "src" to event handler "handler". "Event" and "handler" must has equal argument lists.
#define | CONNECT0(ret, src, event, dest, handler)
| connect event "event" from object "src" to event handler "handler" with return type "ret" from object "dest" with check of event and handler exists
#define | CONNECT1(ret, type0, src, event, dest, handler)
| connect event "event" from object "src" to event handler "handler" with return type "ret" from object "dest" with check of event and handler exists
#define | CONNECT2(ret, type0, type1, src, event, dest, handler)
| connect event "event" from object "src" to event handler "handler" with return type "ret" from object "dest" with check of event and handler exists
#define | CONNECT3(ret, type0, type1, type2, src, event, dest, handler)
| connect event "event" from object "src" to event handler "handler" with return type "ret" from object "dest" with check of event and handler exists
#define | CONNECT4(ret, type0, type1, type2, type3, src, event, dest, handler)
| connect event "event" from object "src" to event handler "handler" with return type "ret" from object "dest" with check of event and handler exists
#define | CONNECT CONNECT0
| CONNECT is synonym of CONNECT0.
#define | WEAK_CONNECT0(ret, src, event, dest, handler)
| connect event "event" from object "src" to event handler "handler" with return type "ret" from object "dest" without check of event exists
#define | WEAK_CONNECT1(ret, type0, src, event, dest, handler)
| connect event "event" from object "src" to event handler "handler" with return type "ret" from object "dest" without check of event exists
#define | WEAK_CONNECT2(ret, type0, type1, src, event, dest, handler)
| connect event "event" from object "src" to event handler "handler" with return type "ret" from object "dest" without check of event exists
#define | WEAK_CONNECT3(ret, type0, type1, type2, src, event, dest, handler)
| connect event "event" from object "src" to event handler "handler" with return type "ret" from object "dest" without check of event exists
#define | WEAK_CONNECT4(ret, type0, type1, type2, type3, src, event, dest, handler)
| connect event "event" from object "src" to event handler "handler" with return type "ret" from object "dest" without check of event exists
#define | WEAK_CONNECT WEAK_CONNECT0
| WEAK_CONNECT is synonym of WEAK_CONNECT0.
#define | DISCONNECT0(ret, src, event, dest, handler)
| piDisconnect event "event" from object "src" from event handler "handler" with return type "ret" from object "dest"
#define | DISCONNECT1(ret, type0, src, event, dest, handler)
| piDisconnect event "event" from object "src" from event handler "handler" with return type "ret" from object "dest"
#define | DISCONNECT2(ret, type0, type1, src, event, dest, handler)
| piDisconnect event "event" from object "src" from event handler "handler" with return type "ret" from object "dest"
#define | DISCONNECT3(ret, type0, type1, type2, src, event, dest, handler)
| piDisconnect event "event" from object "src" from event handler "handler" with return type "ret" from object "dest"
#define | DISCONNECT4(ret, type0, type1, type2, type3, src, event, dest, handler)
| piDisconnect event "event" from object "src" from event handler "handler" with return type "ret" from object "dest"
#define | DISCONNECT DISCONNECT0
| DISCONNECT is synonym of DISCONNECT0.
#define | HANDLER(handler)
| Returns pointer to events handler "handler".

## Detailed Description

Ethernet device.

# Synopsis

PIEthernet designed to work with IPv4 network via two protocols: UDP and TCP. This class allow you send and receive packets to/from another computer through network. Also it supports broadcast and multicast extensions.

# IPv4

# UDP

User Datagram Protocol

# TCP

Transmission Control Protocol

## Member Enumeration Documentation

enum PIEthernet::Type

Type of PIEthernet.

Enumerator
UDP | UDP - User Datagram Protocol
TCP_Client | TCP client - allow connection to TCP server
TCP_Server | TCP server - receive connections from TCP clients

enum PIEthernet::Parameters

Parameters of PIEthernet.

Enumerator
ReuseAddress | Rebind address if there is already binded. Enabled by default
Broadcast | Broadcast send. Disabled by default
SeparateSockets | If this parameter is set, PIEthernet will initialize two different sockets, for receive and send, instead of single one. Disabled by default
MulticastLoop | Enable receiving multicast packets from same host. Enabled by default

enum PIEthernet::InterfaceFlag

Flags of network interface.

Enumerator
ifActive | Is active
ifRunning | Is running
ifBroadcast | Support broadcast
ifMulticast | Support multicast
ifLoopback | Is loopback
ifPTP | Is point-to-point