Сохранение данных COM-порта в несколько файлов

[bedouin]

Добрый день всем!
Возник вот какой вопрос:
У меня есть входной поток с СОМ-порта. Данные записываются в файл.
Но так как считывание происходит непрерывно, в течение длительного времени (до нескольких дней), то приемный файл сильно "разбухает".
Все, что встречал в нете, связано с сохранением в один и тот же файл.
А кому-нибудь приходилось сохранять данные в различные файлы?

P.S.: Мне подобную циклическую запись удалось реализовать только для синхронного режима чтения СОМ-порта (по достижении заданного объема текущий файл закрывался и запись начинала вестись в новый файл).
Но это тупиковый путь, т.к. "поедается" много системных ресурсов и программа работает нестабильно.
Может кто-то делал подобное для асинхронного режима?

[raxp]

...решается очень просто формированием имени файла из даты-года текущего, к примеру 10-08-2012.txt, 11-08-2012.txt, ... . К тому же, так удобнее просматривать потом логи.

[waleri]

В чем проблема с асинхронным чтением? Все равно данные приходят сначала к вам, потом идут в файл, не зависимо синхронно или нет. Что мешает проверить не нужно ли менять файл?

А с чего вы взяли, что при синхронном режиме поедаются много ресурсов? Ничего подобного.

[bedouin]

to waleri
Проблема в том, что наиболее часто асинхронный режим чтения рекомендуют организовывать при помощи потоков, как, например, здесь:
http://www.piclist.ru/S-COM-THREAD-R...HREAD-RUS.html
Я открываю порт

void CReadDataDlg::COMOpen(void)
{
 char sPortName[10];    	 //имя порта (например, "COM1", "COM2" и т.д.)
 DCB dcb;                //структура для общей инициализации порта DCB
 COMMTIMEOUTS timeouts;  //структура для установки таймаутов
 
  cbPorts.GetWindowText(sPortName, 10); cbPorts.GetWindowText(sPortName, 10);	//получить имя выбранного порта

 //открыть порт, для асинхронных операций обязательно нужно указать флаг FILE_FLAG_OVERLAPPED
 COMport = CreateFile(sPortName, GENERIC_READ | GENERIC_WRITE, 0, NULL, OPEN_EXISTING, FILE_FLAG_OVERLAPPED, NULL);


	if (COMport == INVALID_HANDLE_VALUE) 
	{	
		lLogList.AddString("Ошибка при открытии СОМ-порта");
	}
	else  
	{
		lLogList.AddString("СОМ-порт успешно открыт");

		DCB dcb;
		GetCommState(COMport, &dcb);
		dcb.BaudRate = CBR_19200;
		dcb.ByteSize = 8;
		dcb.Parity = NOPARITY;
		dcb.StopBits = ONESTOPBIT; 
		if (SetCommState(COMport, &dcb))
		{
		lLogList.AddString("Настройка СОМ-порта выполнена успешно");
		
		}
		else
			lLogList.AddString("Ошибка в настройке СОМ-порта");
	}

Создаю поток

DWORD WINAPI ReadThread(LPVOID)
{
 COMSTAT comstat;		//структура текущего состояния порта, в данной программе используется для определения количества принятых в порт байтов
 DWORD btr, mask, temp, signal;	//переменная temp используется в качестве заглушки

 overlapped.hEvent = CreateEvent(NULL, true, true, NULL);	//создать сигнальный объект-событие для асинхронных операций
 SetCommMask(COMport, EV_RXCHAR);                   	        //установить маску на срабатывание по событию приёма байта в порт
 while(1)						//пока поток не будет прерван, выполняем цикл
  {
   WaitCommEvent(COMport, &mask, &overlapped);               	//ожидать события приёма байта (это и есть перекрываемая операция)
   signal = WaitForSingleObject(overlapped.hEvent, INFINITE);	//приостановить поток до прихода байта
   if(signal == WAIT_OBJECT_0)				        //если событие прихода байта произошло
    {
     if(GetOverlappedResult(COMport, &overlapped, &temp, true)) //проверяем, успешно ли завершилась перекрываемая операция WaitCommEvent
      if((mask & EV_RXCHAR)!=0)					//если произошло именно событие прихода байта
       {
        ClearCommError(COMport, &temp, &comstat);		//нужно заполнить структуру COMSTAT
        btr = comstat.cbInQue;                          	//и получить из неё количество принятых байтов
        if(btr)                         			//если действительно есть байты для чтения
        {
         ReadFile(COMport, bufrd, btr, &temp, &overlapped);     //прочитать байты из порта в буфер программы
         counter+=btr;                                          //увеличиваем счётчик байтов
         ReadPrinting();                      		//вызываем функцию для вывода данных на экран и в файл
        }
       }
    }
  }
}

Создаю имя файла в зависимости от времени

CString CReadDataDlg::GetFileName(void)
{
SYSTEMTIME lt;
GetLocalTime(&lt);

CString stroke;
stroke = "";
char temp[5];
// Преобразуем целое в строку в десятичном формате
itoa(lt.wYear, temp, 10);
stroke += temp;
stroke += "-";
itoa(lt.wMonth, temp, 10);
stroke += temp;
stroke += "-";
itoa(lt.wDay, temp, 10);
stroke += temp;
stroke += "-";
itoa(lt.wHour, temp, 10);
stroke += temp;
stroke += "-";
itoa(lt.wMinute, temp, 10);
stroke += temp;
stroke += "-";
itoa(lt.wSecond, temp, 10);
stroke += temp;
stroke += ",";
itoa(lt.wMilliseconds, temp, 10);
stroke += temp;
stroke += ".dat";

return stroke;
}

Организую асинхронное чтение в файл

void ReadPrinting()
{
  myFile.Write(bufrd, strlen(bufrd));  //записать в файл данные из приёмного буфера
  memset(bufrd, 0, BUFSIZE);	        //очистить буфер (чтобы данные не накладывались друг на друга)
}

И оно все работает.
Но только для одного файла!
А организовать цикл не получается

[bedouin]

Для синхронного режима с этим проблем нет:

	for (k=0; k<5; k++)
{
	
	//ПРОЦЕДУРА ФОРМИРОВАНИЯ ИМЕНИ ФАЙЛА
curTime = CTime::GetCurrentTime(); 
m_fileName = GetFileName();

UpdateData(TRUE);
char data[23];
strcpy(data,m_fileName);
szFileName = data;

    // Создаём файл и открываем его
   myFile.Open( szFileName, CFile::modeCreate | CFile::modeWrite );

    for (i=0; i<101; i++) 
{
ReadFile(hCom,&szBuffer, 4096,&LenBuf, NULL);
//	ReadFile("data.dat",&szBuffer, 4096,&LenBuf, NULL);

myFile.Write(szBuffer, sizeof(szBuffer));
}
myFile.Close();
}

Но данный код нерационален.
"Кушает" много ресурсов и часто зависает

[waleri]

Не вижу, где синхронный код кушает ресурсы. Зависает - это да. Точнее не зависает а просто ждет 4К данных. Посмотрите на SetCommTimeouts(). И потом, почему в асинхронном варианте вы ожидаете информации о событии а в синхронном варианте нет? Что мешает узнать точное число байт в очереди и считать только их - тогда ничего зависать не будет.

Почему вы решили что асинхронный вариант можно только для одного файла? Что вам мешает а) запустить несколько потоков или б) воспользоваться услугами WaitForMultipleObjects()?

[bedouin]

В асинхронном режиме не могу организовать запись в несколько файлов, потому что за входящий поток отвечает функция

DWORD WINAPI ReadThread(LPVOID)

А за запись - функция

void ReadPrinting()

В синхронном режиме все просто и понятно: загнал цикл для одной и той же функции и пишешь.
А как работать с двумя - ума не приложу.
Где ограничить объем файла и как проводить отсечку потока, если условие цикла :

 while(1)						//пока поток не будет прерван, выполняем цикл
  {
 ...
}

не позволяет ограничить объем файла?

[bedouin]

Распараллелить входной поток (он один единственный) на несколько я не могу, потому что в нем каждый байт что-то значит. При чем важно не только за каким и перед каким байтом он идет, но и какой он по счету.
А на счет очереди вопрос - поток непрерывный (с постоянной скоростью). Получается, число байт в очереди будет постоянно обновляться (накапливаться).
Разве я смогу узнавать, сколько их там в какой момент времени?

[waleri]

А зачем вам цикл в ReadPrinting() вообще?
Все гораздо проще (на псевдокоде):

void ReadPrinting()
{
  if (GetFileSize() > FILE_SIZE_LIMIT)
  {
    CloseFile();
    CreateFile(new_file_name,...);
  }

  WriteFile(...);
}

Кстати, ReadPrinting не самое лучшее имя - не глядя на код ни за что не догадатся что эта функция делает. Далее, strlen() не лучший способ - у вас нет гарантии, что буфер, который вы прочитали закончится нулем. Даже если девайс и посылает 0, нет гарантии что данные будут прочитаны в один прием. Лучше передавайте размер буфера как аргумент, ну коли так, лучше и сам буфер передавать.

[bedouin]

Спасибо, попробую