SHS/pip
4
3
Fork 0
Code Issues 67 Pull Requests 1 Actions Releases Wiki Activity

git-svn-id: svn://db.shs.com.ru/pip@638 12ceb7fc-bf1f-11e4-8940-5bc7170c53b5

Browse Source
This commit is contained in:
Пелипенко Иван
2018-10-03 19:51:47 +00:00
parent e1a495039d
commit 031079d24c
3 changed files with 19 additions and 8 deletions
Download Patch File Download Diff File Expand all files Collapse all files

14
main.cpp
View File

@@ -45,12 +45,14 @@ int main() {
CONNECTU(PICout::Notifier::object(), finished, &a, pcf); CONNECTU(PICout::Notifier::object(), finished, &a, pcf);
PIString buffer = "my buff:"; PIString buffer = "my buff:";
PICout(&buffer, 1) << "int 10 ->" << 10 << ", time ->" << PITime::current();*/ PICout(&buffer, 1) << "int 10 ->" << 10 << ", time ->" << PITime::current();*/
PIString s("str"); PISerial ser(PISerial::availableDevices(false)[0], PISerial::S115200);
piCout << s; piCout << ser.constructFullPath();
piCout << s.quoted(); piCout << ser.open();
piCout << s.quoted(); ser.startThreadedRead();
piCout << s.quote(); FOREVER {
piCout << s; piCout << ser.isOpened();
piMSleep(200);
}
return 0; return 0;
/*} /*}

10
src_main/io_devices/piserial.cpp
View File

@@ -292,7 +292,7 @@ void PISerial::flush() {
bool PISerial::closeDevice() { bool PISerial::closeDevice() {
if (isRunning()) { if (isRunning() && !isStopping()) {
stop(); stop();
PIThread::terminate(); PIThread::terminate();
} }
@@ -627,7 +627,13 @@ int PISerial::readDevice(void * read_to, int max_size) {
//WaitCommEvent(PRIVATE->hCom, 0, 0); //WaitCommEvent(PRIVATE->hCom, 0, 0);
//piCoutObj << "read ..." << PRIVATE->hCom; //piCoutObj << "read ..." << PRIVATE->hCom;
ReadFile(PRIVATE->hCom, read_to, max_size, &PRIVATE->readed, 0); ReadFile(PRIVATE->hCom, read_to, max_size, &PRIVATE->readed, 0);
//piCoutObj << "read ok" << PRIVATE->readed; DWORD err = GetLastError();
if (err == ERROR_BAD_COMMAND) {
PIThread::stop(false);
close();
return 0;
}
//piCoutObj << "read" << (PRIVATE->readed) << errorString();
return PRIVATE->readed; return PRIVATE->readed;
#else #else
if (!canRead()) return -1; if (!canRead()) return -1;

3
src_main/io_utils/pipacketextractor.h
View File

@@ -118,6 +118,9 @@ public:
// //! Returns pointer to \a missedPackets() count. Useful for output to PIConsole // //! Returns pointer to \a missedPackets() count. Useful for output to PIConsole
const ullong * missedPackets_ptr() const {return &missed_packets;} const ullong * missedPackets_ptr() const {return &missed_packets;}
void appendData(const void * d, int s) {threadedRead(const_cast<uchar*>((const uchar *)d), s);}
void appendData(const PIByteArray & data) {appendData(data.data(), data.size_s());}
EVENT2(packetReceived, uchar * , data, int, size) EVENT2(packetReceived, uchar * , data, int, size)
//! \events //! \events