Custom IO Device: Difference between revisions

From Qt Wiki
Jump to navigation Jump to search
No edit summary
No edit summary
 
(5 intermediate revisions by 2 users not shown)
Line 1: Line 1:
[[Category:Snippets]]
[[Category:Snippets]]


'''English''' | [[Custom_IO_Device_German|German]]
'''English''' | [[Custom_IO_Device_German|German]]


[toc align_right="yes" depth="2"]
 


= Writing a Custom I/O Device =
= Writing a Custom I/O Device =


This is a port of the article in "Qt Quarterly 12 about writing a custom QIODevice":http://doc.qt.nokia.com/qq/qq12-iodevice.html
This is a port of the article in [http://doc.qt.io/qt-5/qiodevice.html Qt Quarterly 12 about writing a custom QIODevice]


* Note: a more complex example can be found here [[Simple_Crypt_IO_Device]]
* Note: a more complex example can be found here [[Simple_Crypt_IO_Device]]
Line 15: Line 17:
The following code snippet shows how we would use the custom I/O device to encrypt data and store the result in a file:
The following code snippet shows how we would use the custom I/O device to encrypt data and store the result in a file:


<code><br /> QFile file&amp;amp;#40;&quot;output.dat&amp;quot;&amp;#41;;<br /> CryptDevice cryptDevice(&amp;file)<br /> QTextStream out(&amp;cryptDevice);<br /> cryptDevice.open(QIODevice::WriteOnly);<br /> out &lt;&lt; &quot;Hello World&amp;quot;;<br /></code>
<code>
QFile file("output.dat");
CryptDevice cryptDevice(&file)
QTextStream out(&cryptDevice);
cryptDevice.open(QIODevice::WriteOnly);
out << "Hello World";
</code>


And on the possible usage (in our example code in git &quot;qtdevnet-wiki-mvc/qtdevnet-custom-iodevice&amp;quot;:http://www.gitorious.org/qtdevnet-wiki-mvc/qtdevnet-custom-iodevice)
And on the possible usage (in our example code in git [http://code.qt.io/cgit/%7bnon-gerrit%7d/qt-labs/devnet-examples.git/tree/])


&amp;#32;


=== Encryption ===
=== Encryption ===


<code><br /> QByteArray dataArray;
<code>
QByteArray dataArray;


QBuffer bufferUsedLikeAFile&amp;amp;#40;&amp;dataArray&amp;amp;#41;;<br /> CryptDevice deviceFilter(&amp;bufferUsedLikeAFile);<br /> deviceFilter.open(QIODevice::WriteOnly);<br /> QTextStream stream(&amp;deviceFilter);<br /> QString szText = rawText-&gt;toPlainText();<br /> stream &lt;&lt; szText;<br /></code>
QBuffer bufferUsedLikeAFile(&dataArray);
CryptDevice deviceFilter(&bufferUsedLikeAFile);
deviceFilter.open(QIODevice::WriteOnly);
QTextStream stream(&deviceFilter);
QString szText = rawText->toPlainText();
stream << szText;
</code>


&amp;#32;


=== Decryption ===
=== Decryption ===


<code><br /> QBuffer bufferUsedLikeAFile&amp;amp;#40;&amp;dataArray&amp;amp;#41;;<br /> CryptDevice deviceFilter(&amp;bufferUsedLikeAFile);<br /> deviceFilter.open(QIODevice::ReadOnly);<br /> QTextStream stream(&amp;deviceFilter);<br /> QString szText = stream.readAll();<br /> decryptedText-&gt;setPlainText(szText);<br /></code>
<code>
QBuffer bufferUsedLikeAFile(&dataArray);
CryptDevice deviceFilter(&bufferUsedLikeAFile);
deviceFilter.open(QIODevice::ReadOnly);
QTextStream stream(&deviceFilter);
QString szText = stream.readAll();
decryptedText->setPlainText(szText);
</code>


Example image of the test app:
Example image of the test app:


[[Image:https://lh3.googleusercontent.com/_m1PNLlZctqY/TYpctkjGvTI/AAAAAAAAAFI/BjZnvJhatRY/s800/CustomIoDevice.jpg|Test app]]
https://lh3.googleusercontent.com/_m1PNLlZctqY/TYpctkjGvTI/AAAAAAAAAFI/BjZnvJhatRY/s800/CustomIoDevice.jpg


== The Custom I/O Device ==
== The Custom I/O Device ==
Line 52: Line 74:
The class definition looks like this:
The class definition looks like this:


<code><br />class CryptDevice : public QIODevice<br />{<br /> Q_OBJECT<br />public:<br /> CryptDevice(QIODevice* deviceToUse, QObject* parent = 0);<br /> bool open(OpenMode mode);<br /> void close();<br /> bool isSequential() const;<br />protected:<br /> qint64 readData(char* data, qint64 maxSize);<br /> qint64 writeData(const char* data, qint64 maxSize);<br />private:<br /> QIODevice* underlyingDevice;<br /> Q_DISABLE_COPY(CryptDevice)<br />};<br /></code>
<code>
class CryptDevice : public QIODevice
{
Q_OBJECT
public:
CryptDevice(QIODevice* deviceToUse, QObject* parent = 0);
bool open(OpenMode mode);
void close();
bool isSequential() const;
protected:
qint64 readData(char* data, qint64 maxSize);
qint64 writeData(const char* data, qint64 maxSize);
private:
QIODevice* underlyingDevice;
Q_DISABLE_COPY(CryptDevice)
};
</code>


The constructor definition is pretty straightforward
The constructor definition is pretty straightforward


<code><br />CryptDevice::CryptDevice(QIODevice* deviceToUse, QObject* parent) :<br /> QIODevice(parent),<br /> underlyingDevice(deviceToUse)<br />{<br />}<br /></code>
<code>
CryptDevice::CryptDevice(QIODevice* deviceToUse, QObject* parent) :
QIODevice(parent),
underlyingDevice(deviceToUse)
{
}
</code>


As our device should be sequential, we re-implement isSequential<br /><code><br />bool CryptDevice::isSequential() const<br />{<br /> return true;<br />}<br /></code>
As our device should be sequential, we re-implement isSequential
<code>
bool CryptDevice::isSequential() const
{
return true;
}
</code>


In &lt;code&amp;gt;open()&lt;/code&amp;gt;, we open the underlying device if it's not already open and set the device state to ''mode''.
In <code>open()</code>, we open the underlying device if it's not already open and set the device state to ''mode''.


<code><br />bool CryptDevice::open(OpenMode mode)<br />{<br /> bool underlyingOk;<br /> if (underlyingDevice-&gt;isOpen())<br /> underlyingOk = (underlyingDevice-&gt;openMode() != mode);<br /> else<br /> underlyingOk = underlyingDevice-&gt;open(mode);
<code>
bool CryptDevice::open(OpenMode mode)
{
bool underlyingOk;
if (underlyingDevice->isOpen())
underlyingOk = (underlyingDevice->openMode() != mode);
else
underlyingOk = underlyingDevice->open(mode);


if (underlyingOk)<br /> {<br /> setOpenMode(mode);<br /> return true;<br /> }<br /> return false;<br />}<br /></code>
if (underlyingOk)
{
setOpenMode(mode);
return true;
}
return false;
}
</code>


Closing is trivial.
Closing is trivial.


<code><br />void CryptDevice::close()<br />{<br /> underlyingDevice-&gt;close();<br /> setOpenMode(NotOpen);<br />}<br /></code>
<code>
void CryptDevice::close()
{
underlyingDevice->close();
setOpenMode(NotOpen);
}
</code>
 
When reading a block, we call <code>read()</code> on the underlying device. At the end, we XOR each byte read from the device with the magic constant 0x5E.
 
<code>
qint64 CryptDevice::readData(char* data, qint64 maxSize)
{
qint64 deviceRead = underlyingDevice->read(data, maxSize);
if (deviceRead == –1)
return -1;
for (qint64 i = 0; i < deviceRead; +''i)
data[i] = data[i] ^ 0x5E;
 
return deviceRead;
}
</code>


When reading a block, we call &lt;code&amp;gt;read()&lt;/code&amp;gt; on the underlying device. At the end, we XOR each byte read from the device with the magic constant 0x5E.
When writing a block, we create a temporary buffer with the XOR'd data. A more efficient implementation would use a 4096-byte buffer on the stack and call <code>write()</code> multiple times if size is larger than the buffer.  


<code><br />qint64 CryptDevice::readData(char* data, qint64 maxSize)<br />{<br /> qint64 deviceRead = underlyingDevice-&gt;read(data, maxSize);<br /> if (deviceRead == –1)<br /> return <s>1;<br /> for (qint64 i = 0; i &lt; deviceRead; +''i)<br /> data[i] = data[i] ^ 0x5E;
<code>
<br /> return deviceRead;<br />}<br /></code>
qint64 CryptDevice::writeData(const char* data, qint64 maxSize)
<br />When writing a block, we create a temporary buffer with the XOR'd data. A more efficient implementation would use a 4096-byte buffer on the stack and call &lt;code&amp;gt;write()&lt;/code&amp;gt; multiple times if size is larger than the buffer.
{
<br /><code><br />qint64 CryptDevice::writeData(const char* data, qint64 maxSize)<br />{<br /> QByteArray buffer((int)maxSize, 0);<br /> for (int i = 0; i &lt; (int)maxSize;''+i)<br /> buffer[i] = data[i] ^ 0x5E;<br /> return underlyingDevice</s>&gt;write(buffer.data(), maxSize);<br />}<br /></code>
QByteArray buffer((int)maxSize, 0);
for (int i = 0; i < (int)maxSize;''+i)
buffer[i] = data[i] ^ 0x5E;
return underlyingDevice->write(buffer.data(), maxSize);
}
</code>

Latest revision as of 12:10, 30 March 2015


English | German


Writing a Custom I/O Device

This is a port of the article in Qt Quarterly 12 about writing a custom QIODevice

Usage:

The following code snippet shows how we would use the custom I/O device to encrypt data and store the result in a file:

 QFile file("output.dat");
 CryptDevice cryptDevice(&file)
 QTextStream out(&cryptDevice);
 cryptDevice.open(QIODevice::WriteOnly);
 out << "Hello World";

And on the possible usage (in our example code in git [1])


Encryption

 QByteArray dataArray;

QBuffer bufferUsedLikeAFile(&dataArray);
 CryptDevice deviceFilter(&bufferUsedLikeAFile);
 deviceFilter.open(QIODevice::WriteOnly);
 QTextStream stream(&deviceFilter);
 QString szText = rawText->toPlainText();
 stream << szText;


Decryption

 QBuffer bufferUsedLikeAFile(&dataArray);
 CryptDevice deviceFilter(&bufferUsedLikeAFile);
 deviceFilter.open(QIODevice::ReadOnly);
 QTextStream stream(&deviceFilter);
 QString szText = stream.readAll();
 decryptedText->setPlainText(szText);

Example image of the test app:

CustomIoDevice.jpg

The Custom I/O Device

Writing a custom QIODevice class in Qt 4 involves inheriting QIODevice and then reimplementing a set of virtual functions.

There is a big difference regarding writing a custom IO device compared to Qt 3: you only have to rewrite 2 functions:

  • qint64 QIODevice::readData ( char * data, qint64 maxSize )
  • qint64 QIODevice::writeData ( const char * data, qint64 maxSize )

Our CryptDevice class will be a sequential I/O device. Whether it's synchronous or asynchronous depends on the underlying QIODevice.

Source Code

The class definition looks like this:

class CryptDevice : public QIODevice
{
 Q_OBJECT
public:
 CryptDevice(QIODevice* deviceToUse, QObject* parent = 0);
 bool open(OpenMode mode);
 void close();
 bool isSequential() const;
protected:
 qint64 readData(char* data, qint64 maxSize);
 qint64 writeData(const char* data, qint64 maxSize);
private:
 QIODevice* underlyingDevice;
 Q_DISABLE_COPY(CryptDevice)
};

The constructor definition is pretty straightforward

CryptDevice::CryptDevice(QIODevice* deviceToUse, QObject* parent) :
 QIODevice(parent),
 underlyingDevice(deviceToUse)
{
}

As our device should be sequential, we re-implement isSequential

bool CryptDevice::isSequential() const
{
 return true;
}

In

open()

, we open the underlying device if it's not already open and set the device state to mode.

bool CryptDevice::open(OpenMode mode)
{
 bool underlyingOk;
 if (underlyingDevice->isOpen())
 underlyingOk = (underlyingDevice->openMode() != mode);
 else
 underlyingOk = underlyingDevice->open(mode);

if (underlyingOk)
 {
 setOpenMode(mode);
 return true;
 }
 return false;
}

Closing is trivial.

void CryptDevice::close()
{
 underlyingDevice->close();
 setOpenMode(NotOpen);
}

When reading a block, we call

read()

on the underlying device. At the end, we XOR each byte read from the device with the magic constant 0x5E.

qint64 CryptDevice::readData(char* data, qint64 maxSize)
{
 qint64 deviceRead = underlyingDevice->read(data, maxSize);
 if (deviceRead == 1)
 return -1;
 for (qint64 i = 0; i < deviceRead; +''i)
 data[i] = data[i] ^ 0x5E;

 return deviceRead;
}

When writing a block, we create a temporary buffer with the XOR'd data. A more efficient implementation would use a 4096-byte buffer on the stack and call

write()

multiple times if size is larger than the buffer.

qint64 CryptDevice::writeData(const char* data, qint64 maxSize)
{
 QByteArray buffer((int)maxSize, 0);
 for (int i = 0; i < (int)maxSize;''+i)
 buffer[i] = data[i] ^ 0x5E;
 return underlyingDevice->write(buffer.data(), maxSize);
}