PIP  0.4.0_beta2
Platform-Independent Primitives
 All Classes Namespaces Files Functions Variables Typedefs Enumerations Enumerator Friends Macros Pages
PIEthernet Class Reference

Ethernet device. More...

+ Inheritance diagram for PIEthernet:

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 }
 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< InterfaceFlagInterfaceFlags
 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 {
  piHighest, piHigh, piNormal, piLow,
  piLowerst
}
 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.
 
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::Parametersparameters () const
 Returns parameters.
 
Type type () const
 Returns PIEthernet type.
 
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 PIStringListmulticastGroups () 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 ()
 Start listen for incoming TCP connections on address readAddress(). Use only for TCP_Server.
 
bool listen (const PIString &ip, int port)
 Start listen for incoming TCP connections on address "ip":"port". Use only for TCP_Server.
 
bool listen (const PIString &ip_port)
 Start listen for incoming TCP connections on address "ip_port". Use only for TCP_Server.
 
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 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 PIByteArray &data, bool threaded=false)
 Send data "data" to address sendAddress() for UDP or readAddress() for TCP_Client.
 
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.
 
PIString constructFullPath () const
 Reimplement to construct full unambiguous string, describes this device, default returns 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.
 
bool canRead () const
 Return true if device can read now.
 
bool canWrite () const
 Return true if device can write 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 timer_delay=-1)
 Contructs thread with custom data "data", external function "func" and main cycle delay "timer_delay".
 
 PIThread (bool startNow=false, int timer_delay=-1)
 Contructs thread with main cycle delay "timer_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.
 
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.
 
PIMutexmutex ()
 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.
 
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 PIIODevicecreateFromFullPath (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 PIObjectfindByName (const PIString &name)
 Returns PIObject* with name "name" or 0, if there is no object found.
 

Protected Member Functions

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
PIObjectemitter () const
 Returns PIObject* which has raised an event. This value is correct only in definition of some event handler.
 
virtual void propertyChanged (const PIString &name)
 Virtual function executes after property with name "name" has been changed.
 

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
 
bool broadcast
 Broadcast parameter, default false.
 
bool reuseAddress
 ReuseAddress parameter, default false.
 

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
 

Detailed Description

Ethernet device.

Synopsis

PIEthernet designed to work with IPv4 network by two protocols: UDP and TCP. This class allow you send and receive packets to/from another computer through network.

IPv4

UDP

User Datagram Protocol

TCP

Transmission Control Protocol

Member Enumeration Documentation

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

Parameters of PIEthernet.

Enumerator
ReuseAddress 

Rebind address if there is already binded

Broadcast 

Broadcast send

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