48888 (Розробка програмного забезпечення системи збору даних про хід та параметри технологічного процесу), страница 4

2016-07-30СтудИзба

Описание файла

Документ из архива "Розробка програмного забезпечення системи збору даних про хід та параметри технологічного процесу", который расположен в категории "". Всё это находится в предмете "информатика" из 1 семестр, которые можно найти в файловом архиве . Не смотря на прямую связь этого архива с , его также можно найти и в других разделах. Архив можно найти в разделе "курсовые/домашние работы", в предмете "информатика, программирование" в общих файлах.

Онлайн просмотр документа "48888"

Текст 4 страницы из документа "48888"

{

ret = recv(sockInfo[nClient].sClient, ((char *)&reqRange)+idx, nLeft, 0);

if ((ret == SOCKET_ERROR)||(ret == 0))

{

bError = 1;

break;

}

nLeft -= ret;

idx += ret;

}//while

//поиск кол-ва файлов удовлетворяющих диапазону времени

packServ.typeRequest = 3; //данные от сервера

packServ.typeSender = 6; //сервер

packServ.lengthPack = sizeof (packageServer);

packServ.AmountPacks = 0;

EnterCriticalSection (&csFile);

if (reqRange.iTypeUVM == 1)

{

curPos = ftell(f1);

fseek(f1, 0, SEEK_END);

endPos = ftell(f1);

fseek(f1, 0, SEEK_SET);

nStructs = endPos / (sizeof(package1));

iFound = 0;

for (i = 0; i

{

fread((void *)&pack1, sizeof(package1), 1, f1);

if ((pack1.time >=reqRange.tBegin) && ( pack1.time <= reqRange.tEnd))

{

packServ.AmountPacks++;

if (iFound == 0)

{

iFound = 1;

startPos = ftell(f1) - sizeof(package1);

}

}

}//for

fseek(f1, curPos, SEEK_SET);

}

else

{

curPos = ftell(f2);

fseek(f2, 0, SEEK_END);

endPos = ftell(f2);

fseek(f2, 0, SEEK_SET);

nStructs = endPos / (sizeof(package2));

iFound = 0;

for (i = 0; i

{

fread((void *)&pack2, sizeof(package2), 1, f2);

if ((pack2.time >=reqRange.tBegin) && ( pack2.time <= reqRange.tEnd))

{

packServ.AmountPacks++;

if (iFound == 0)

{

iFound = 1;

startPos = ftell(f2) - sizeof(package2);

}

}

}//for

fseek(f2, curPos, SEEK_SET);

}

LeaveCriticalSection (&csFile);

//отсылка количества найденных структур

nLeft = packServ.lengthPack;

idx = 0;

while(nLeft > 0)

{

ret = send(sockInfo[nClient].sClient, ((char *) &packServ)+idx, nLeft, 0);

if (ret == SOCKET_ERROR)

{

bError = 1;

break;

}

nLeft -= ret;

idx += ret;

}

//считывание структур из файлов

if ((iFound != 0)&&(!bError))

{

EnterCriticalSection (&csFile);

if (reqRange.iTypeUVM == 1)

{

pack1Array = new package1[packServ.AmountPacks];

curPos = ftell(f1);

fseek(f1, startPos, SEEK_SET);

for (i = 0; i

fread((void *)&pack1Array[i], sizeof(package1), 1, f1);

fseek(f1, curPos, SEEK_SET);

}

else

{

pack2Array = new package2[packServ.AmountPacks];

curPos = ftell(f2);

fseek(f2, startPos, SEEK_SET);

for (i = 0; i

fread((void *)&pack2Array[i], sizeof(package2), 1, f2);

fseek(f2, curPos, SEEK_SET);

}

LeaveCriticalSection (&csFile);

//отсылка структур

for (i = 0; i

{

if (reqRange.iTypeUVM == 1)

nLeft = sizeof(package1);

else

nLeft = sizeof(package2);

idx = 0;

while(nLeft > 0)

{

if (reqRange.iTypeUVM == 1)

ret = send(sockInfo[nClient].sClient, ((char *) &pack1Array[i])+idx, nLeft, 0);

else

ret = send(sockInfo[nClient].sClient, ((char *) &pack2Array[i])+idx, nLeft, 0);

if (ret == SOCKET_ERROR)

{

bError = 1;

break;

}

nLeft -= ret;

idx += ret;

}//while

if (bError == 1)

{

idx = 5;

break;

}

}//for

if (reqRange.iTypeUVM == 1)

delete[] pack1Array;

else

delete[] pack2Array;

}//if iFound

}//if PC

}//while (!bError)

//удаление записи о скруктуре текущего сокете

if (!bAlowCloseClient[nClient])

{

EnterCriticalSection (&cs);

DeleteSockInfo (nClient, 0);

LeaveCriticalSection (&cs);

}

return 0;

}//ClientThread

//---------------------------------------------------------------------------

unsigned __stdcall AcceptThread(LPVOID lpParam)

{

SOCKET sockAccept;

UINT iThreadId;

while (1)

{

sockAccept = accept(sListen, NULL, NULL);

if ((sockAccept == INVALID_SOCKET) && (WSAGetLastError() == WSAENOTSOCK))

break;

EnterCriticalSection (&cs);

if ((sockAccept != INVALID_SOCKET) && (iNumClients < MAX_CLIENT ))

{

sockInfo[iNumClients].sClient = sockAccept;

sockInfo[iNumClients].typeSender = 0;

sockInfo[iNumClients].time = time(NULL);

sockInfo[iNumClients].hClientThread =(HANDLE) _beginthreadex(NULL, 0,

ClientThread, (LPVOID)iNumClients, 0, &iThreadId);

sockInfo[iNumClients].time = time(NULL);

iNumClients ++ ;

LeaveCriticalSection (&cs);

}

else

{

LeaveCriticalSection (&cs);

shutdown(sockAccept, SD_BOTH);

closesocket(sockAccept);

}

}

return 0;

} // AcceptThread()

//---------------------------------------------------------------------------

unsigned __stdcall ControlThread(LPVOID lpParam)

{

int i;

DWORD dwWaitState;

while (1)

{

dwWaitState = WaitForSingleObject(hEvent, timeToSleep);

if (dwWaitState == WAIT_OBJECT_0)

break;

EnterCriticalSection (&cs);

for (i = 0; i< iNumClients; i++)

{

if ((sockInfo[i].typeSender == 5) || (sockInfo[i].typeSender == 0))

{

if ((time(NULL) - sockInfo[i].time)>600)

{

DeleteSockInfo(i , 1);

}

}

else

{

if ((time(NULL) - sockInfo[i].time)>60)

{

DeleteSockInfo(i , 1);

}

}

}//for

LeaveCriticalSection (&cs);

}//while

return 0;

} // ControlThread()

//---------------------------------------------------------------------------

__fastcall TForm1::TForm1(TComponent* Owner)

: TForm(Owner)

{

}

//---------------------------------------------------------------------------

void __fastcall TForm1::Button1Click(TObject *Sender)

{

struct sockaddr_in server;

UINT iThreadId;

AnsiString sAddress, sPort;

char * cAddress, * cPort;

unsigned int lenAdr, lenPort, iPort;

Form1->Button1->Enabled = FALSE;

//создание или открытие файлов

hEvent = CreateEvent( NULL, FALSE, FALSE, NULL);

if ((f1=fopen("group1.txt","a+b"))==NULL)

{

Form1->Button1->Enabled = TRUE;

return;

}

fseek (f1, 0, SEEK_END);

if ((f2=fopen("group2.txt","a+b"))==NULL)

{

fclose(f1);

Form1->Button1->Enabled = TRUE;

return;

}

fseek (f2, 0, SEEK_END);

if (WSAStartup(MAKEWORD(2,2), &wsd) != 0)

{

fclose(f1);

fclose(f2);

Form1->Button1->Enabled = TRUE;

return;

}

//создание необходимых событий, секций

hEvent = CreateEvent( NULL, FALSE, FALSE, NULL);

InitializeCriticalSection (&cs);

InitializeCriticalSection (&csFile);

//создание сокета

sListen = socket(AF_INET, SOCK_STREAM, IPPROTO_TCP);

if (sListen == INVALID_SOCKET)

{

CloseHandle (hEvent);

fclose(f1);

fclose(f2);

DeleteCriticalSection (&cs);

DeleteCriticalSection (&csFile);

Form1->Button1->Enabled = TRUE;

return;

}

// преобразование адреса

sAddress = Form1->Edit2->Text;

cAddress = sAddress.c_str();

lenAdr = sAddress.Length();

cAddress[lenAdr] = '\0';

//преобразование порта

sPort = Form1->Edit3->Text;

cPort = sPort.c_str();

lenPort = sPort.Length();

cPort[lenPort] = '\0';

iPort = atoi(cPort);

server.sin_family = AF_INET;

server.sin_port = htons(iPort);

server.sin_addr.s_addr = inet_addr(cAddress);

if (server.sin_addr.s_addr == INADDR_NONE)

{

CloseHandle (hEvent);

shutdown(sListen, SD_BOTH);

closesocket(sListen);

fclose(f1);

fclose(f2);

DeleteCriticalSection (&cs);

DeleteCriticalSection (&csFile);

Form1->Button1->Enabled = TRUE;

return;

}

if (bind(sListen, (SOCKADDR*) &server, sizeof(server)) == SOCKET_ERROR)

{

CloseHandle (hEvent);

shutdown(sListen, SD_BOTH);

closesocket(sListen);

fclose(f1);

fclose(f2);

DeleteCriticalSection (&cs);

DeleteCriticalSection (&csFile);

Form1->Button1->Enabled = TRUE;

return;

}

if (listen(sListen, 8) == SOCKET_ERROR)

{

CloseHandle (hEvent);

shutdown(sListen, SD_BOTH);

closesocket(sListen);

fclose(f1);

fclose(f2);

DeleteCriticalSection (&cs);

DeleteCriticalSection (&csFile);

Form1->Button1->Enabled = TRUE;

return;

}

//создание потока accept

hThreadAccept = (HANDLE)_beginthreadex(NULL, 0, AcceptThread, (LPVOID)sListen, 0,

&iThreadId);

if (hThreadAccept == NULL)

{

CloseHandle (hEvent);

shutdown(sListen, SD_BOTH);

closesocket(sListen);

fclose(f1);

fclose(f2);

DeleteCriticalSection (&cs);

DeleteCriticalSection (&csFile);

Form1->Button1->Enabled = TRUE;

return;

}

//создание потока отслеживания времени последнего обращени клиентов

hThreadControl = (HANDLE)_beginthreadex(NULL, 0, ControlThread, (LPVOID)sListen, 0,

&iThreadId);

if (hThreadControl == NULL)

{

return;

}

bServWorking = TRUE;

return;

}

//---------------------------------------------------------------------------

void DeleteSockInfo(int num, uc bWaitThread)

{

int i;

bAlowCloseClient[num] = 1;

shutdown(sockInfo[num].sClient, SD_BOTH);

closesocket(sockInfo[num].sClient);

if (bWaitThread)

WaitForSingleObject(sockInfo[num].hClientThread, INFINITE);

CloseHandle (sockInfo[num].hClientThread);

bAlowCloseClient[num] = 0;

for (i = num; i<(iNumClients-1); i++)

sockInfo[i] = sockInfo[i+1];

iNumClients--;

}

//---------------------------------------------------------------------------

void __fastcall TForm1::FormClose(TObject *Sender, TCloseAction &Action)

{

int i;

if (!bServWorking)

return;

// Закрытие потока Control и события ожидания

SetEvent (hEvent);

WaitForSingleObject(hThreadControl, INFINITE);

CloseHandle (hThreadControl);

CloseHandle (hEvent);

//закрытие сокета сервера и потока Accept

shutdown(sListen, SD_BOTH);

closesocket(sListen);

WaitForSingleObject(hThreadAccept, INFINITE);

CloseHandle (hThreadAccept);

//закрытие сокетов клиентов -> закрытие потоков

EnterCriticalSection (&cs);

for (i = 0; i

{

bAlowCloseClient[i] = 1;

shutdown(sockInfo[i].sClient, SD_BOTH);

closesocket(sockInfo[i].sClient);

WaitForSingleObject(sockInfo[i].hClientThread, INFINITE);

CloseHandle (sockInfo[i].hClientThread);

}

LeaveCriticalSection (&cs);

fclose(f1);

fclose(f2);

DeleteCriticalSection (&cs);

DeleteCriticalSection (&csFile);

WSACleanup();

}

Додаток В. Вихідний текст робочої станції

//---------------------------------------------------------------------------

#include

#pragma hdrstop

#include "Client.h"

#include

#include

//---------------------------------------------------------------------------

#pragma package(smart_init)

#pragma resource "*.dfm"

TForm1 *Form1;

typedef unsigned char uc;

typedef unsigned short int ui;

#pragma pack (push)

#pragma pack (1)

typedef struct

{

time_t time;

uc speed1;

uc speed2;

ui temperature1;

ui temperature2;

ui temperature3;

ui weight1;

ui weight2;

ui weight3;

uc length1;

uc length2;

} package1;

typedef struct

{

time_t time;

uc speed1;

uc speed2;

uc speed3;

ui temperature1;

ui temperature2;

ui weight1;

ui weight2;

ui weight3;

ui weight4;

uc length;

} package2;

typedef struct

{

uc typeRequest; //0 - запрос на синхронизацию

//1 - данные от УВМ

//2 - запрос от клиента

//3 - данные от севера

uc typeSender; //1..4 номер УВМ

//5 клиент

//6 сервер

uc lengthPack;

} request;

typedef struct

{

uc typeRequest;

uc typeSender;

uc lengthPack;

ui iTypeUVM;

time_t tBegin;

time_t tEnd;

} requestRange;

typedef struct

{

uc typeRequest;

uc typeSender;

uc lengthPack;

unsigned long AmountPacks;

} packageServer;

#pragma pack (pop)

SOCKET sClient;

WSADATA wsd;

//---------------------------------------------------------------------------

void CloseClientSocket()

{

Form1->Button2->Enabled = FALSE;

Form1->Button3->Enabled = FALSE;

shutdown(sClient, SD_BOTH);

closesocket(sClient);

Form1->Button1->Enabled = TRUE;

}

//---------------------------------------------------------------------------

__fastcall TForm1::TForm1(TComponent* Owner)

: TForm(Owner)

{

StringGrid1->RowCount = 2;

StringGrid1->Rows[1]->Clear();

StringGrid1->Cells[0][0] = "№";

StringGrid1->Cells[1][0] = "Год";

StringGrid1->Cells[2][0] = "Месяц";

StringGrid1->Cells[3][0] = "День месяца";

StringGrid1->Cells[4][0] = "Часы";

StringGrid1->Cells[5][0] = "Минуты";

StringGrid1->Cells[6][0] = "Секунды";

}

//---------------------------------------------------------------------------

void __fastcall TForm1::Button1Click(TObject *Sender)

{

struct sockaddr_in server;

AnsiString sAddress, sPort;

char * cAddress, * cPort;

unsigned int lenAdr, lenPort, iPort;

int nLeft, idx, ret;

request req;

time_t UpdateTime;

Form1->Button1->Enabled = FALSE;

// преобразование адреса

sAddress = Form1->Edit1->Text;

cAddress = sAddress.c_str();

lenAdr = sAddress.Length();

cAddress[lenAdr] = '\0';

//преобразование порта

sPort = Form1->Edit2->Text;

cPort = sPort.c_str();

lenPort = sPort.Length();

cPort[lenPort] = '\0';

iPort = atoi(cPort);

if (WSAStartup(MAKEWORD(2,2), &wsd) != 0)

{

Application->MessageBoxA("Ошибка WSAStartup!", "Error!", MB_OK);

Form1->Button1->Enabled = TRUE;

return;

}

//создание сокета

sClient = socket(AF_INET, SOCK_STREAM, IPPROTO_TCP);

if (sClient == INVALID_SOCKET)

{

Application->MessageBoxA("Невозможно создать сокет", "Error!", MB_OK);

Form1->Button1->Enabled = TRUE;

return;

}

server.sin_family = AF_INET;

server.sin_port = htons(iPort);

server.sin_addr.s_addr = inet_addr(cAddress);

if (server.sin_addr.s_addr == INADDR_NONE)

{

// Если не указан IP-адрес

Application->MessageBoxA("Напрвальный IP адрес", "Error!", MB_OK);

Form1->Button1->Enabled = TRUE;

return;

}

if (connect(sClient, (struct sockaddr *)&server,

sizeof(server)) == SOCKET_ERROR)

{

Application->MessageBoxA("Неудалось подключится к серверу", "Error!", MB_OK);

Form1->Button1->Enabled = TRUE;

return;

}

req.typeRequest = 0; //запрос на синхронизацию

req.typeSender = 5; //идентификатор рабочей станции

req.lengthPack = sizeof(request);

//отправка запроса на синхронизацию времени

nLeft = req.lengthPack;

idx = 0;

while(nLeft > 0)

{

ret = send(sClient, ((char *)&req) + idx, nLeft, 0);

if (ret == SOCKET_ERROR)

{

Application->MessageBoxA("Ошибка отправки запроса на синхронизацию", "Error!", MB_OK);

CloseClientSocket();

return;

}

nLeft -= ret;

idx += ret;

}

//приём времени сервера и установка его в системе

nLeft = sizeof(time_t);

idx = 0;

while(nLeft > 0)

{

ret = recv(sClient, ((char *)&UpdateTime)+idx, nLeft, 0);

if ((ret == SOCKET_ERROR)||(ret == 0))

{

Application->MessageBoxA("Ошибка приёма времени", "Error!", MB_OK);

CloseClientSocket();

return;

}

nLeft -= ret;

idx += ret;

}

// установка времени в системе

//stime(&UpdateTime);

Form1->Button2->Enabled = TRUE;

Form1->Button3->Enabled = TRUE;

}

//---------------------------------------------------------------------------

void __fastcall TForm1::Button2Click(TObject *Sender)

{

CloseClientSocket();

}

//---------------------------------------------------------------------------

void __fastcall TForm1::Button3Click(TObject *Sender)

{

int iTypeUVM, nLeft, idx, ret;

package1 pack1;

package2 pack2;

packageServer packServ;

requestRange reqRange;

tm tmBegin, tmEnd, *tmTime;

time_t time_tBegin, time_tEnd;

unsigned long i;

Form1->Button3->Enabled = FALSE;

StringGrid1->RowCount = 2;

StringGrid1->Rows[1]->Clear();

//формирование структур времени

tmBegin.tm_sec = Form1->ComboBox3->ItemIndex;

tmBegin.tm_min = Form1->ComboBox2->ItemIndex;

tmBegin.tm_hour = Form1->ComboBox6->ItemIndex;

tmBegin.tm_mday = Form1->ComboBox8->ItemIndex+1;

tmBegin.tm_mon = Form1->ComboBox10->ItemIndex;

tmBegin.tm_year = Form1->ComboBox12->ItemIndex+70;

tmBegin.tm_isdst = 0;

time_tBegin = mktime(&tmBegin);

if (time_tBegin == -1)

{

Application->MessageBoxA("Ошибка преобразования начального времени", "Error!", MB_OK);

Form1->Button3->Enabled = TRUE;

return;

}

tmEnd.tm_sec = Form1->ComboBox5->ItemIndex;

tmEnd.tm_min = Form1->ComboBox4->ItemIndex;

tmEnd.tm_hour = Form1->ComboBox7->ItemIndex;

tmEnd.tm_mday = Form1->ComboBox9->ItemIndex+1;

tmEnd.tm_mon = Form1->ComboBox11->ItemIndex;

tmEnd.tm_year = Form1->ComboBox13->ItemIndex+70;

tmEnd.tm_isdst = 0;

time_tEnd = mktime(&tmEnd);

if (time_tBegin == -1)

{

Application->MessageBoxA("Ошибка преобразования конечного времени", "Error!", MB_OK);

Form1->Button3->Enabled = TRUE;

Свежие статьи
Популярно сейчас
Как Вы думаете, сколько людей до Вас делали точно такое же задание? 99% студентов выполняют точно такие же задания, как и их предшественники год назад. Найдите нужный учебный материал на СтудИзбе!
Ответы на популярные вопросы
Да! Наши авторы собирают и выкладывают те работы, которые сдаются в Вашем учебном заведении ежегодно и уже проверены преподавателями.
Да! У нас любой человек может выложить любую учебную работу и зарабатывать на её продажах! Но каждый учебный материал публикуется только после тщательной проверки администрацией.
Вернём деньги! А если быть более точными, то автору даётся немного времени на исправление, а если не исправит или выйдет время, то вернём деньги в полном объёме!
Да! На равне с готовыми студенческими работами у нас продаются услуги. Цены на услуги видны сразу, то есть Вам нужно только указать параметры и сразу можно оплачивать.
Отзывы студентов
Ставлю 10/10
Все нравится, очень удобный сайт, помогает в учебе. Кроме этого, можно заработать самому, выставляя готовые учебные материалы на продажу здесь. Рейтинги и отзывы на преподавателей очень помогают сориентироваться в начале нового семестра. Спасибо за такую функцию. Ставлю максимальную оценку.
Лучшая платформа для успешной сдачи сессии
Познакомился со СтудИзбой благодаря своему другу, очень нравится интерфейс, количество доступных файлов, цена, в общем, все прекрасно. Даже сам продаю какие-то свои работы.
Студизба ван лав ❤
Очень офигенный сайт для студентов. Много полезных учебных материалов. Пользуюсь студизбой с октября 2021 года. Серьёзных нареканий нет. Хотелось бы, что бы ввели подписочную модель и сделали материалы дешевле 300 рублей в рамках подписки бесплатными.
Отличный сайт
Лично меня всё устраивает - и покупка, и продажа; и цены, и возможность предпросмотра куска файла, и обилие бесплатных файлов (в подборках по авторам, читай, ВУЗам и факультетам). Есть определённые баги, но всё решаемо, да и администраторы реагируют в течение суток.
Маленький отзыв о большом помощнике!
Студизба спасает в те моменты, когда сроки горят, а работ накопилось достаточно. Довольно удобный сайт с простой навигацией и огромным количеством материалов.
Студ. Изба как крупнейший сборник работ для студентов
Тут дофига бывает всего полезного. Печально, что бывают предметы по которым даже одного бесплатного решения нет, но это скорее вопрос к студентам. В остальном всё здорово.
Спасательный островок
Если уже не успеваешь разобраться или застрял на каком-то задание поможет тебе быстро и недорого решить твою проблему.
Всё и так отлично
Всё очень удобно. Особенно круто, что есть система бонусов и можно выводить остатки денег. Очень много качественных бесплатных файлов.
Отзыв о системе "Студизба"
Отличная платформа для распространения работ, востребованных студентами. Хорошо налаженная и качественная работа сайта, огромная база заданий и аудитория.
Отличный помощник
Отличный сайт с кучей полезных файлов, позволяющий найти много методичек / учебников / отзывов о вузах и преподователях.
Отлично помогает студентам в любой момент для решения трудных и незамедлительных задач
Хотелось бы больше конкретной информации о преподавателях. А так в принципе хороший сайт, всегда им пользуюсь и ни разу не было желания прекратить. Хороший сайт для помощи студентам, удобный и приятный интерфейс. Из недостатков можно выделить только отсутствия небольшого количества файлов.
Спасибо за шикарный сайт
Великолепный сайт на котором студент за не большие деньги может найти помощь с дз, проектами курсовыми, лабораторными, а также узнать отзывы на преподавателей и бесплатно скачать пособия.
Популярные преподаватели
Нашёл ошибку?
Или хочешь предложить что-то улучшить на этой странице? Напиши об этом и получи бонус!
Бонус рассчитывается индивидуально в каждом случае и может быть в виде баллов или бесплатной услуги от студизбы.
Предложить исправление
Добавляйте материалы
и зарабатывайте!
Продажи идут автоматически
5075
Авторов
на СтудИзбе
455
Средний доход
с одного платного файла
Обучение Подробнее