Алгоритм чтения оглавления РПДП

После того, как поезд приехал в депо, и было произведено соединение между стендом и регистратором параметров движения поезда по Wi-Fi, можно начинать считывание регистраций, находящихся в памяти РПДП.

Рисунок 3.3.1 Начальное окно программы.

Сразу после запуска программы выполняются следующие действия:

Листинг 3.3.1.

__fastcall TForm1: TForm1(TComponent* Owner).

: TForm (Owner).

{.

ProgName = L" Тестирование передачи информации на РПДП" ;

Form1->Caption = ProgName;

rscodec_init (); //Производится подключение динамической библиотеки rscodec.dll.

netlib_init (); //Инициируется использование Winsock DLL функцией WSAStartup ().

dev = new CEthDev ();

dev->open ();

}.

В первую очередь происходит netlib_init () инициирование использования функций библиотеки Winsock, описанных выше. Далее происходит создание элемента класса CEthDev и вызывается функция, обеспечивающая сетевое взаимодействие клиента и сервера open (). Эта функция создает UDP-клиента вызовом функции udp_client (), описанной в начале главы.

Листинг 3.3.2.

int CEthDev: open (int dev_no).

{.

//создается сокет клиента, производится адресация и ассоциирование.

sd = udp_client (&sa, SRC_IP_ADDR, 0);

setRecvBufSize (1024*1024*10);

return sd;

}.

Прежде чем считывать конкретную регистрацию, необходимо вывести на экран список всех существующих на РПДП регистраций. Список выводится на компоненту StrGridRPDP[6] по нажатию кнопки «Оглавление» (BtnReadHeader).

Листинг 3.3.3.

void __fastcall TForm1: BtnReadHeaderClick (TObject *Sender).

{.

bool bResult;

igCountRPDP = 0;

Screen->Cursor = crHourGlass;

bResult = this->ReadHeader (); //Вызывается функция чтения Оглавления.

Screen->Cursor = crDefault;

}.

//—————————————————————————————————————;

bool __fastcall TForm1: ReadHeader ().

{.

int ret_code, count;

reg_info_t *farr;

try {.

// Выделяем память под страницу.

char *sys_page = new char[4096];

// Указатель на оглавление.

ginfo = (reg_info_t *) g_sys_page;

igCountRPDP = 0;

// Цикл чтения списка регистраций.

for (int block = 0; block < 10; block++).

{.

// читаем очередную страницу (4096 байт).

for (int i = 0; i < 5; i++).

{.

ret_code = dev->get_header (sys_page, 1, block);

if (ret_code == 4096).

{.

break;

}.

if (i == 4).

{.

Application->MessageBoxW (L" РПДП не отвечает.", L" Ошибка", MB_OK);

return false;

}.

Sleep (50);

}.

for (int i = 0; i < 4094; i++).

{.

g_sys_page[(block*4094)+i] = sys_page[i]; //заполнение.

}.

// в одной странице умещается 89 регистраций.

for (count=0;count<89;count++).

{.

if (is_free_cell (&ginfo[igCountRPDP+count])).

//if = 0xFF goto end_found.

{.

igCountRPDP = igCountRPDP + count;

// igCountRPDP счетчик регистраций.

goto end_found;

}.

}.

igCountRPDP = igCountRPDP + count;

}.

end_found: //.

if (count > 0).

{.

this->FillStrGridRPDP (count);//Заполнение StrGrid Оглавлением.

return true;

}.

delete [] sys_page;

}.

catch (String str).

{.

}.

return false;

}.

Функция поиска последней регистрации в странице:

Листинг 3.3.4.

int TForm1: is_free_cell (void *faddr).

{.

unsigned int i;

unsigned char *b;

int free;

b = (unsigned char *)faddr;

free = 1;

for (i=0; i < sizeof (reg_info_t); i++).

{.

if (b[i] ≠ 0xFF).

{.

free = 0;

break;

}.

}.

return free;

}.

Информация от РПДП приходит в виде дейтаграмм фиксированного размера. Размер дейтаграммы равен 4096 байт. Дейтаграмма далее будет называться страницей или блоком. В функции ReadHeader () создается указатель sys_page на динамически выделенную область памяти размером 4096 байт для хранения одной дейтаграммы, а также происходит инициализация созданного глобально указателя ginfo на тип reg_info_t, описывающий регистрацию.

Листинг 3.3.5.

struct reg_info_t.

{.

rtc_time_t rtc_time; // дополнительная временная информация.

rpdp_addr_tfaddr; // адрес первой страницы регистрации.

unsigned int pages; // количество страниц регисирации.

};

Типreg_info_t определен в хидерном файле rpdr.h. Это созданный разработчиком составной тип данных, который характеризует одну конкретную регистрацию. Он содержит адрес первой страницы регистрации в памяти РПДП faddr, количество страниц pages, а также дополнительную информацию о регистрации, хранящуюся в rtc_time типа rtc_time_t.

Листинг 3.3.6.

//структура, описывающая время создания регистрации.

struct rtc_time_t.

{.

int sec; // секунды.

int min; // минуты.

int hour;// часы.

int mday;// день месяца.

int mon; // месяц.

int year;// год.

int wday;// день недели.

int yday;// день года.

int days_ago;// прошло дней с момента запуска.

};

После инициализации производится цикл чтения 10 страниц (блоков). Функция get_header (), определенная в классе CEthDev, производит чтение и запись страницы в предварительно выделенную область памяти sys_page и возвращает её размер. На чтение страницы программе дается пять попыток с интервалом в 50 миллисекунд. Если чтение произведено успешно и функция get_header () возвращает значение 4096, попытки прекращаются, в противном случае программа выдает сообщение «РПДП не отвечает». Функция get_header () будет более подробно рассмотрена далее.

Принятая страница записывается в глобально определенный массив всех страниц оглавления g_sys_page[40 960] типа unsigned char.

В одной принятой странице оглавления умещается информация о 89 регистрациях (адрес первой страницы, количество страниц, временная информация), но их может быть и меньше. Для подсчета количества регистраций в страницеоглавления вводится глобальный параметр igCountRPDP типа int. Подсчет производится в цикле for () по всем возможным 89 регистрациям. Проверяется существование очередной регистрации с помощью функции is_free_cell (). is_free_cell () получает указатель на область памяти, где хранится информация об очередной регистрации, сравнивает байты памяти со значением 0xFF и если находит совпадения, то делает вывод о том, что память пуста и регистрации закончились. Функция возвращает значение true, если регистрация в памяти существует и false в противном случае.

После того, как определено, что регистрации в памяти закончились и произведен их подсчет с помощью параметра igCountRPDP, список регистраций выводится вStrGridRPDP с помощью функции FillStrGridRPDP (). Функция FillStrGridRPDP () заполняет столбцы таблицы, записывая туда данные о регистрации (количество страниц, размер в байтах), а также время, когда эта регистрация была записана на РПДП.

После общего описания процесса считывания оглавления РПДП, можно вернуться к функции get_header () и более подробно показать, каким же образом происходит считывание страницы регистрации в буфер sys_page.

Взаимодействие программы с РПДП происходит в режиме интерпретатора команд. Для того чтобы получить от РПДП страницу оглавления, необходимо отправить ему соответствующую команду на отправку этой страницы. Соответствие команд их идентификаторам описано в хидерном файле rpdp.h. Пример команд:

Листинг 3.3.7.

// команды cmd для РПДП.

#define RPDP_GET_PAGE0 // получение страницы РПДП.

#define RPDP_ERASE_BLOCK 4 // стирание блока РПДП.

#define RPDP_GET_TIME5 // получение времени РПДП.

#define RPDP_SET_TIME6 // установка времени РПДП.

#define RPDP_PUT_PAGE9// запись без ожидания.

#define RPDP_GET_RAW_PAGE10 // получение страниц РПДП.

#define RPDP_GET_VERSION 14 // получение версии РПДП Перед отправлением команды на РПДП, необходимо заполнить структуру команды rpdp_cmd_t, где нужно задать тип команды (некоторые из них перечислены выше), адрес верхнего и нижнего слова, длину сдвига и некоторую дополнительную информацию.

Листинг 3.3.8.

struct rpdp_cmd_t.

{.

unsigned char pack_type;

unsigned int cmd;

unsigned int addr_lo;

unsigned int addr_hi;

unsigned int len;

unsigned charreserv[100];

};

В функции get_header () производится заполнение данной структуры. cmd. pack_type задается по умолчанию, тип команды cmd. cmd задается как RPDP_GET_PAGE, адрес заполняется исходя из протокола, а длина устанавливается в 1. Далее открывается цикл по количеству страниц, где сначала производится отправка команды на получение информации, а потом вызывается функция read_pages (), которой в качестве параметра передается указатель на область памяти под страницу sys_page. Далее в цикле производится увеличение адреса команды на единицу, смещение указателя и чтение следующей страницы. Функция возвращает количество прочитанных байт.

Листинг 3.3.9.

intCEthDev:get_header (void *buf, unsigned int pages_count, int start_block).

{.

rpdp_cmd_t cmd;

int ret_code;

reg_info_t *farr;

rpdp_addr_tfaddr;

cmd.pack_type = PKT_CMD;

cmd.cmd = RPDP_GET_PAGE; // команда на получение страницы РПДП.

cmd.addr_lo = 0;

cmd.addr_hi = (7 << 20) + (start_block << 8); // адрес.

cmd.len = 1;

char *tmp_buf = (char *)buf;

for (int i = 0; i< pages_count; i++).

{.

send_cmd (&cmd);

ret_code = read_pages (tmp_buf, 1,5000);

cmd.addr_hi++;

tmp_buf += 4096;

}.

return ret_code;

}.

Отправка команды на получение информации от РПДП производится с помощью функции send_cmd ().Сначала происходит инициализация структурыdest, в которой указывается IP-адрес пункта назначенияDST_IP_ADDR ="192.168.1.10″ и порт. Далее производится отправка команды cmd с помощью функции sendto () в пункт назначения dest.

Листинг 3.3.10.

//следующая функция отправляет информацию (cmd).

int CEthDev: send_cmd (rpdp_cmd_t *cmd).

{.

struct sockaddr_in dest;

int ret_code;

set_address (&dest, DST_IP_ADDR, DST_UDP_PORT);

ret_code = sendto (sd,(const char*)cmd, sizeof (rpdp_cmd_t), 0, (sockaddr*)&dest, sizeof (dest));

return ret_code;

}.

Функция read_pages () вызывает функцию чтения байт read_bytes ().

Листинг 3.3.11.

//Функция читает страницу из РПДП, 1 страница — 4096.

int CEthDev: read_pages (void *data, int pages_count, int tout).

{.

unsigned char *b;

int ret_code;

b = (unsigned char *)data;

for (int i=0;i.

{.

ret_code = read_bytes (&b[i*4096], 4096, tout); //читает по 4096 байт за раз.

}.

return ret_code;

}.

//—————————————————————————————————————;

В функции read_bytes () создается дескриптор события recv_event, который с помощью функции WSAEventSelect () ассоциируется с определенным набором сетевых событий, в нашем случае с событием чтения FD_READ.Таким образом, после отправки команды cmd на считывание регистрации, клиент в течение определенного времени ожидает сетевого события FD_READ. Если событие происходит до момента истечения таймера ожидания WAIT_TIMEOUT, вызывается функция recvfrom (). Функция recvfrom () получает дейтаграмму, записывает ее в буфер sys_page и возвращает количество принятых байт. Подробное описание функции recvfrom () дано в начале главы.

Листинг 3.3.12.

int CEthDev: read_bytes (void *data, int len, int tout).

{.

int fromlen;

struct sockaddr_in saddr;

int count;

count = -1;

//create an event object.

HANDLE recv_event = CreateEvent (0,0,0,0);

BOOL bSend = TRUE;

int iCnt;

WSAEventSelect (sd, recv_event, FD_READ);

DWORD dwRet = WaitForSingleObject (recv_event, tout);

if (dwRet ≠ WAIT_TIMEOUT).

{.

count = recvfrom (sd, (char*)data, len, 0, 0, 0);

}.

CloseHandle (recv_event);

return count;

}.