Russian Qt Forum

...
...
qint64 TMyDevice::bytesAvailable () const 
{
   qint64 mybav =0;
   qint64  bav = QIODevice::bytesAvailable () ;
   cout << "mybav = " << mybav << "| bav =  " << bav << endl;
   return mybav + bav ;

}
...
...

...
qint64 MyDevice.open();
qint64 rbav= MyDevice.bytesAvailable ();
cout<<" rbav = " << rbav << endl;
MyDevice.close();
...

qint64 TPosixSerialDevice::readData(char * data, qint64 maxSize)
{
    int bytesRead=0;//кол-во реально прочитанных байт за один проход
    int retVal=0;//кол-во реально прочитанных байт за все проходы
    int bav=0;//количество байт готовых бля чтения, которые находятся в текущий момент в приемном буфере последовательного устройства
    do {
        if (maxSize>retVal) {
            bav=bytesAvailable(); // ВОТ ТУТ ОНА НЕПРАВИЛЬНО ВОЗВРАЩАЕТ ЗНАЧЕНИЕ = 16384 !!! о_О
            if (bav>0) {
                if ((maxSize-retVal)<=bav) {
                    bav=maxSize-retVal;
                }
				bytesRead = ::read(fd, (void*)(data+retVal), bav);
                if  (bytesRead==-1) {
                	TTY_PORTABILITY_DEBUG("TPosixSerialDevice::readData->bytesRead==-1! Error!");
                    return -1;
                }//if read == -1
                else {
                    if (bytesRead==bav) {
                        retVal+=bytesRead;//with OK
                    }//if bytesRead==bav
                    else {
                        TTY_PORTABILITY_DEBUG("TPosixSerialDevice::readData->(bytesRead!=bav) with OK! Error!");
                        return -1;
                    }//else bytesRead!=bav
                }//else read
            }//if bav>0
            else {
                TTY_PORTABILITY_DEBUG("TPosixSerialDevice::readData-> (bav<=0)! Error!");
                return -1;
            }//else bav<=0
        }//if maxSize>retVal
        else {
            return retVal;
        }
    } while (waitForReadyRead(parameters->charIntervalTimeout));//ожидаем прихода в приемный буфер устройства следующего символа
    return retVal;
}

...
static const qint64 QIODEVICE_BUFFERSIZE = 16384;
...
...
qint64 QIODevice::read(char *data, qint64 maxSize)
{
...
...
     qint64 readSoFar = 0;
    bool moreToRead = true;
    do {
        int lastReadChunkSize = 0;

        // Try reading from the buffer.
        if (!d->buffer.isEmpty()) {
            lastReadChunkSize = d->buffer.read(data + readSoFar, maxSize - readSoFar);
            readSoFar += lastReadChunkSize;
            if (!sequential)
                d->pos += lastReadChunkSize;
#if defined QIODEVICE_DEBUG
            printf("%p \treading %d bytes from buffer into position %d\n", this, lastReadChunkSize,
                   int(readSoFar) - lastReadChunkSize);
#endif
        } else if ((d->openMode & Unbuffered) == 0 && maxSize < QIODEVICE_BUFFERSIZE) { // <<<<<<<< ========= ВОТ ИЗЗА ЭТОГО ЕСТЬ НЕПОНЯТКА!!!
            // In buffered mode, we try to fill up the QIODevice buffer before
            // we do anything else.
            int bytesToBuffer = qMax(maxSize - readSoFar, QIODEVICE_BUFFERSIZE);
            char *writePointer = d->buffer.reserve(bytesToBuffer);
...
...
}

...
else if ((d->openMode & Unbuffered) == 0 && maxSize < QIODEVICE_BUFFERSIZE) 
...

..
    QString hostName;
    quint16 port;
    QHostAddress host;
    QList<QHostAddress> addresses;

    quint16 localPort;
    quint16 peerPort;
    QHostAddress localAddress;
    QHostAddress peerAddress;
    QString peerName;
..

bool waitForReadyRead ( int msecs )
{
    readNotifier->setEnabled (false);
    /*
        тут выполняем действия
    */
    readNotifier->setEnabled (true);
}

AbstractSerialEngine::AbstractSerialEngine(QObject *parent)
	: QObject(parent), d_ptr(new AbstractSerialEnginePrivate)
{
}

AbstractSerialEngine::AbstractSerialEngine(QObject *parent)
	: QObject(parent), d_ptr(new AbstractSerialEnginePrivate)
{
}

NativeSerialEngine::NativeSerialEngine(QObject *parent)
	: AbstractSerialEngine(*new NativeSerialEnginePrivate(), parent)
{
}

/*** KFooBase ***/
KFooBase::KFooBase(QObject *parent) 
    : QObject(parent), d_ptr(new KFooBasePrivate)
{
}
 
/*** KFooDerived ***/
KFooDerived::KFooDerived(QObject *parent)
    : KFooBase(*new KFooDerivedPrivate, parent)
{
}

...
MyDevice->open(QIODevice::ReadOnly | QIODevice::Unbuffered);
...

...
MyDevice->setParity(AbstractSerial::ParityEven);
...

class Reader : public QObject
{
	Q_OBJECT

public:
	Reader(QObject *parent = 0) {
		MyDevice = new AbstractSerial();
		connect(MyDevice, SIGNAL(readyRead()), this, SLOT(slotReadData()));
		if (!MyDevice->open(QIODevice::ReadOnly | QIODevice::Unbuffered)) {
			qDebug() << "Open fail";
			return;
		}
                if (!MyDevice->setParity(AbstractSerial::ParityEven)) {
			qDebug() << "Set parity fail";
			return;
                }

		qDebug() << "= Parameters =";
		qDebug() << "Device name            : " << MyDevice->deviceName();
		qDebug() << "Baud rate              : " << MyDevice->baudRate();
		qDebug() << "Data bits              : " << MyDevice->dataBits();
		qDebug() << "Parity                 : " << MyDevice->parity();
		qDebug() << "Stop bits              : " << MyDevice->stopBits();
		qDebug() << "Flow                   : " << MyDevice->flowControl();
		qDebug() << "Char timeout, msec     : " << MyDevice->charIntervalTimeout();
	}
	~Reader() {
		MyDevice->close();
		delete MyDevice; 
		MyDevice = 0;
	}
private slots:
	void slotReadData() { 
                QByteArray ba = MyDevice->read(10); 
                qDebug() << "Readed " << ba.size() << "bytes";
        }
private:
	AbstractSerial *MyDevice;
};

qint64 AbstractSerial::readData(char *data, qint64 maxSize)
{
	Q_D(AbstractSerial);

	qint64 ret = d->serialEngine->read(data, maxSize);
	if (ret < 0)
		emitStatusString(EReadDataIO);
	d->emittedReadyRead = false;
	return ret;
}

int NativeSerialEnginePrivate::nativeSelect(int timeout, bool checkRead, bool checkWrite,
					bool *selectForRead, bool *selectForWrite) 
{
...
int ret = ::select(fd + 1, &fdread, &fdwrite, 0, timeout < 0 ? 0 : &tv);
...
}

int ret = ::select(fd + 1, &fdread, 0, 0, timeout < 0 ? 0 : &tv);

int NativeSerialEnginePrivate::nativeSelect(int timeout, bool checkRead, bool checkWrite,
					bool *selectForRead, bool *selectForWrite) const
{
	fd_set fdread;
	FD_ZERO(&fdread);
	if (checkRead)
		FD_SET(fd, &fdread);

	fd_set fdwrite;
	FD_ZERO(&fdwrite);
	if (checkWrite)
		FD_SET(fd, &fdwrite);


	struct timeval tv;
	tv.tv_sec = timeout / 1000;
	tv.tv_usec = (timeout % 1000) * 1000;

	//int ret = ::select(fd + 1, &fdread, &fdwrite, 0, timeout < 0 ? 0 : &tv); // <- ЕСЛИ ТАК - ТО НЕ РАБОТАЕТ, А ВСЕГДА ВОЗВРАЩАЕТ 1
	int ret = ::select(fd + 1, &fdread, 0, 0, timeout < 0 ? 0 : &tv); // <- ЕСЛИ ТАК -ТО РАБОТАЕТ, НО БЕЗ НОТИФИКАЦИИ ЗАПИСИ

	if (ret <= 0)
		return ret;

	*selectForRead = FD_ISSET(fd, &fdread);
	*selectForWrite = FD_ISSET(fd, &fdwrite);

	return ret;
}

bool NativeSerialEngine::waitForReadOrWrite(bool *readyToRead, bool *readyToWrite,
											bool checkRead, bool checkWrite,
											int msecs, bool *timedOut) const
{
	Q_D(const NativeSerialEngine);

	int ret = d->nativeSelect(msecs, checkRead, checkWrite, readyToRead, readyToWrite);

	if (ret == 0) {
		if (timedOut)
			*timedOut = true;
		if (checkRead) {
			//
		}
		if (checkWrite) {
			//
		}
		return false;
	}
	return ret > 0;
}

bool AbstractSerial::waitForReadyRead(int msecs)
{
	Q_D(AbstractSerial);

	if (!isOpen()) {
		emitStatusString(EDeviceIsNotOpen);
		return false;
	}

	QTime stopWatch;
	stopWatch.start();

	d->stopSerialNotifiers();
	forever {
		bool readyToRead = false;
		bool readyToWrite = false;
		if (!d->serialEngine->waitForReadOrWrite(&readyToRead, &readyToWrite, true, true,
													qt_timeout_value(msecs, stopWatch.elapsed()))) {
			emitStatusString(EWaitReadyReadTimeout);
			d->startSerialNotifiers();
			return false;
		}
		if (readyToRead) {
			d->waitForReadyReadCalled = true;
			if (d->canReadNotification()) {
				d->startSerialNotifiers();
				return true;
			}
		}
		if (readyToWrite)
			d->canWriteNotification();
	}
}

...
#define NATIVESERIALENGINE_WIN_DEBUG
...

In file included from nativeserialengine_win.cpp:24:
/usr/local/Trolltech/Qt4.6-static/include/QtCore/qt_windows.h:63:21: error: windows.h: Нет такого файла или каталога
nativeserialengine_win.cpp: In constructor ‘NativeSerialEnginePrivate::NativeSerialEnginePrivate()’:
nativeserialengine_win.cpp:42: error: class ‘NativeSerialEnginePrivate’ does not have any field named ‘hd’
....

#if defined(SKDDEVICE) && defined(ARM_DEBUG)
    #include <QtDebug>
    #define SKD_DBG qDebug
#else
    #define SKD_DBG if(0) qDebug
#endif

class SKDDevice: public QObject
{
    ... 
}

...
    SKD_DBG() << "This is debug message 1" << "\nThis is debug message 2";
    либо
    SKD_DBG("New value for param XYZ: %02d", XYZ);
...

#if defined(SKDDEVICE)
   qDebug() << "This is debug message 1" << "\nThis is debug message 2";
#endif

#if defined(ABSTRACTSERIAL) && defined(QSERIALDEVICE_DEBUG)
    #include <QtDebug>
    #define ABS_DBG qDebug
#else
    #define ABS_DBG if(0) qDebug
#endif

#if defined (ABSTRACTSERIAL_DEBUG)
    qDebug() << "AbstractSerial::setBaudRate(const QString &) returned false because input parameter  speed:" <<  baudRate << "\n is not defined in hash. Error!";
#endif

ABS_DBG() << "AbstractSerial::setBaudRate(const QString &) returned false because input parameter  speed:" <<  baudRate << "\n is not defined in hash. Error!";

bool NativeSerialEnginePrivate::nativeClose()
{
           ...
	if (closeResult)
		this->m_isOpen = false;
		
	return closeResult;
}

bool NativeSerialEnginePrivate::nativeClose()
{
...
...
    if (closeResult) {
        this->m_isOpen = false;
        this->hd = INVALID_HANDLE_VALUE;
    }
    
    return closeResult;
}

    m_exch = new ExchangerPolycrystal(this);
    m_exch->setPortName(m_settings->value("port/portName", AbstractSerialEnginePrivate::m_defaultDeviceName).toString());

d->readNotifier = new WinSerialNotifier(d->hd, WinSerialNotifier::Read, this);

if (closeResult)
    this->m_isOpen = false;

#ifndef SERIALDEVICEINFO_H
#define SERIALDEVICEINFO_H

#ifndef SERIALDEVICEWATCHER_H
#define SERIALDEVICEWATCHER_H

#endif // ABSTRACTSERIALINFO_H

ssh-keygen -t rsa

cat ~/.ssh/id_rsa.pub

.gitignore

doc/html/
sql/
winbuild/
build/
*.dll
!doc/src
bin
lib

# object files
*.[oa]
*.so
*.so.*

# qt creator projects
*.cbp
*.user

# qt creator cmake directories
qtcreator*/

# manually cmake build directories
build*/

# win32 libs
*.dll
# win32 impl
*.lib

# temporary dirs
tmp/

# logger dirs
log/

# html docs because it's generated by doxygen
doc/html/

# test
test/
test*/

# qmake mocs
moc_*.cpp

# qt ui headers
ui*.h

# qt translations files
*.qm

# temporary files
*~

# emacs temporary files
##*##

# make files
Makefile

# cmake build system
CMakeFiles/
CMakeCache.txt

# cmake mocs
moc*.cxx
*.moc

# include cmake build file
#!CMakeLists.txt

git init

git add .

git commit -a -m "initial commit"

git remote add origin @gitorious.org/qserialdevice/qserialdevice.git

git push origin master

git add .

git commit -a -m "we change build system"

git push

#if defined(MYSHAREDLIB_LIBRARY)
 #  define MYSHAREDLIB_EXPORT Q_DECL_EXPORT
 #else
.........
class MYSHAREDLIB_EXPORT MyClass

void MainWindow::slot_readUart()
{
    // Поставил на всякий случай
    if (!m_pSerial->isOpen()) {
        return;
    }

    qint64 numBytes;
    numBytes = m_pSerial->bytesAvailable();
    if ( numBytes < 0) {
        m_pSerial->close();
        //qDebug("Read port error %ld", m_pSerial->lastError());
        qDebug("Read port error ");
        return;
    }
    if ( numBytes == 0) {
        //qDebug("Read 0");
        // Windows patch
        m_pSerial->read(numBytes);
        return;
    }
....
}

#if defined(Q_OS_WIN32)
        m_pSerial->setDeviceName(m_pCBSerialPort->currentText());
#else
        m_pSerial->setDeviceName(QString("/dev/") + m_pCBSerialPort->currentText());
#endif
        if (!m_pSerial->open(AbstractSerial::ReadWrite)) {
            qDebug("Error open port");
            return;
        }
/*
            qDebug() << "= New parameters =";
            qDebug() << "Device name            : " << m_pSerial->deviceName();
            qDebug() << "Baud rate              : " << m_pSerial->baudRate();
            qDebug() << "Data bits              : " << m_pSerial->dataBits();
            qDebug() << "Parity                 : " << m_pSerial->parity();
            qDebug() << "Stop bits              : " << m_pSerial->stopBits();
            qDebug() << "Flow                   : " << m_pSerial->flowControl();
            qDebug() << "Char timeout, msec     : " << m_pSerial->charIntervalTimeout();
//*/
        switch (m_pCBSerialSpeed->currentIndex()) {
        case 0: m_pSerial->setBaudRate(AbstractSerial::BaudRate1200);   break;
        case 1: m_pSerial->setBaudRate(AbstractSerial::BaudRate2400);   break;
        case 2: m_pSerial->setBaudRate(AbstractSerial::BaudRate4800);   break;
        case 3: m_pSerial->setBaudRate(AbstractSerial::BaudRate9600);   break;
        case 4: m_pSerial->setBaudRate(AbstractSerial::BaudRate19200);  break;
        case 5: m_pSerial->setBaudRate(AbstractSerial::BaudRate38400);  break;
        case 6: m_pSerial->setBaudRate(AbstractSerial::BaudRate57600);  break;
        case 7: m_pSerial->setBaudRate(AbstractSerial::BaudRate115200); break;
        }
        m_pSerial->setDataBits(AbstractSerial::DataBits8);
        m_pSerial->setParity(AbstractSerial::ParityNone);
        m_pSerial->setStopBits(AbstractSerial::StopBits1);
        m_pSerial->setFlowControl(AbstractSerial::FlowControlOff);
        m_pSerial->flush();
    }

...
    ::DEV_BROADCAST_DEVICEINTERFACE notificationFilter;
    int size = sizeof(::DEV_BROADCAST_DEVICEINTERFACE);
    ::ZeroMemory(&notificationFilter, size);

    notificationFilter.dbcc_size = size;
    notificationFilter.dbcc_devicetype = DBT_DEVTYP_DEVICEINTERFACE;

    size = sizeof(guidDevInterfaceList);
    for (int i = 0; i < size; i++) {
        notificationFilter.dbcc_classguid = guidDevInterfaceList[i];
        ::HDEVNOTIFY hDeviceNotify = ::RegisterDeviceNotification(this->internalHwnd, &notificationFilter, DEVICE_NOTIFY_WINDOW_HANDLE);
        if (!hDeviceNotify) {
            // Handle the error...
            qWarning("Notificator: Failed call RegisterDeviceNotification: %d\n", (int)GetLastError());
        }
...

//callbac обработчик сообщений от окна
...
::LRESULT CALLBACK internal_proc(::HWND hwnd, ::UINT message, ::WPARAM wp, ::LPARAM lp)
{
    switch (message) {
    case WM_DEVICECHANGE: {
             //тут "тупо" перебор имеющихся в системе портов с помощью SetupDiGetClassDevs и SetupDiEnumDeviceInfo
        }
        break;
    default:
        return ::DefWindowProc(hwnd, message, wp, lp);
    }
    return 0;
}
...

 if (::WriteFile(this->descriptor, (PCVOID)data, (DWORD)len, &writeBytes, &this->oWrite))
 

...
setBaudRate(230400);
...

01346 void AbstractSerial::setCharIntervalTimeout(int usecs)
01347 {
01348     Q_D(AbstractSerial);
01349     if (this->isOpen())
01350         d->serialEngine->setCharReadTimeout(usecs);
01351     else
01352         this->emitStatusString(ESetCharIntervalTimeout);
01353 }

void AbstractSerial::signalStatus  ( const QString &  status,  
  QDateTime  current  
 )  [signal] 

Этот сигнал автоматически испускается при изменении статуса AbstractSerial. 
Изменение статуса может быть вызвано следующими причинами:

•При ошибках конфигурировании устройства.
•При его открытии/закрытии.
•При ошибках I/O.

INCLUDEPATH += $$(QTPATH)/serportM04/src/qserialdevice \
	$$(QTPATH)/serportM04/src/qserialdeviceenumerator

QMAKE_LIBDIR += $$(QTPATH)/serportM04/src/build/release

LIBS += -lqserialdevice

d:/soft/Qt/serportM04/src/build/release/libqserialdevice.a(serialdeviceenumerator_p_win.o):serialdeviceenumerator_p_win.cpp:(.text+0x89a): undefined reference to `_imp__SetupDiGetDeviceRegistryPropertyW@28'

d:/soft/Qt/serportM04/src/build/release/libqserialdevice.a(serialdeviceenumerator_p_win.o):serialdeviceenumerator_p_win.cpp:(.text+0xfb3): undefined reference to `_imp__SetupDiGetClassDevsW@16'

d:/soft/Qt/serportM04/src/build/release/libqserialdevice.a(serialdeviceenumerator_p_win.o):serialdeviceenumerator_p_win.cpp:(.text+0x100a): undefined reference to `_imp__SetupDiEnumDeviceInfo@12'

d:/soft/Qt/serportM04/src/build/release/libqserialdevice.a(serialdeviceenumerator_p_win.o):serialdeviceenumerator_p_win.cpp:(.text+0x1170): undefined reference to `_imp__SetupDiOpenDevRegKey@24'

d:/soft/Qt/serportM04/src/build/release/libqserialdevice.a(serialdeviceenumerator_p_win.o):serialdeviceenumerator_p_win.cpp:(.text+0x27de): undefined reference to `_imp__SetupDiDestroyDeviceInfoList@4'

collect2: ld returned 1 exit status

mingw32-make[1]: *** [debug/TestProg.exe] Error 1

mingw32-make: *** [debug] Error 2

char command[4];
AbstractSerial *port;
...
port->write(command, 4);
...

include_directories( ${CMAKE_CURRENT_BINARY_DIR}
                     ${QT_INCLUDES} 
)

set(CMAKE_INCLUDE_CURRENT_DIR T)

# qplatformdefs
include_directories(${QT_MKSPECS_DIR}/default)

set( QT_DONT_USE_QTGUI 1 )

include( ${QT_USE_FILE} )

find_package( Qt4 COMPONENTS QtCore REQUIRED )

    set ( LIBRARY_OUTPUT_PATH 
        ${PROJECT_BINARY_DIR}/debug
        CACHE string "Path to output library binaries."
    )

set( QT_DEFINITIONS
    -DUNICODE
    -DQT_NO_DEBUG
    -DQT_THREAD_SUPPORT
)
add_definitions( ${QT_DEFINITIONS})

if(BUILD_SHARED)
    add_library( ${LIB_TARGET} SHARED ${QSERIALDEVICE_SRCS} ${QSERIALDEVICE_MOCS} )
else()
    add_library( ${LIB_TARGET} STATIC ${QSERIALDEVICE_SRCS} ${QSERIALDEVICE_MOCS} )
endif()

set(SERIALDEVICE_BUILD_TYPE "SHARED") # or STATIC
add_library( ${PROJECT_NAME} ${SERIALDEVICE_BUILD_TYPE} ${QSERIALDEVICE_SRCS} ${QSERIALDEVICE_MOCS} )

if( CMAKE_BUILD_TYPE STREQUAL "Debug" )
    set ( LIBRARY_OUTPUT_PATH 
        ${PROJECT_BINARY_DIR}/debug
        CACHE string "Path to output library binaries."
    )
    set( LIB_TARGET "qserialdeviced" CACHE string "Name of the output library binaries." )
else()

set(CMAKE_DEBUG_POSTFIX d)

target_link_libraries(${PROJECT_NAME}  ${QT_LIBRARIES} ${ADDITIONAL_LIBRARY})

set_target_properties(exetarget PROPERTIES DEBUG_POSTFIX "_debug" VERSION ${VERSION})