Вопрос начинающего

17.12.2010, 00:21. **Показов** 776. **Ответов** 1

Author24 — интернет-сервис помощи студентам

Добрый вечер не не могли бы мне помочь. Я разработал систему терминального доступа на протоколе TCP. Работа параллельна, на каждого пользователя отдельный сокет и отдельная нить. Но если на одну из функций я вешаю Sleep чтобы проверить что они параллельно работают, то получается что второй пользователь тоже висит пока у первого не сойдет Sleep.
Сервер на Linux.

Вот я вешаю в функции fwho после
lsendto(clntinf[MAX_NUMBER_OF_CONNECTIONS].s,tn,0);
//sleep(15);
Работает все абсолютно параллельно, но если в самом начале функции fwho, то не работает.
Не подскажите что такого я неверного делал в сервере. И как бы это можно было бы исправить.

Server.h

C++

#include <stdio.h>
#include <stdlib.h>
#include <string>
#include <iostream>
#include <fstream>
#include <string.h>
#include <time.h>
#include <signal.h>
#include <sstream>
#include <vector>
#include <netdb.h>
#include <netinet/in.h>
#include <arpa/inet.h>
#include <sys/types.h>
#include <errno.h>
#pragma comment(lib, "ws2_32.lib")
using namespace std;
 
// максимальный размер структурированного пакета
#define SIZE 100
// максимальное число подключенных пользователей
#define MAX_NUMBER_OF_CONNECTIONS 100
 
// Перевод строки в число, с выводом ошибки
template <class T>
bool from_string(T& t, 
                 const std::string& s, 
                 std::ios_base& (*f)(std::ios_base&))
{
  std::istringstream iss(s);
  return !(iss >> f >> t).fail();
}
 
// Ошибки посылаемые в пакетах
#define WRONG_LOGIN_PASS_COMBINATION 1
#define YOU_ARE_NOT_LOGGED_IN 2
#define TOO_MANY_CONNECTIONS 3
#define YOU_HAVE_BEEN_DISCONECTED_BY_SUSER 4
#define NO_SUCH_CODE 101
#define CODE_IS_ALREADY_ADDED 102
#define NO_SUCH_USER 201
#define NOT_ENOUGH_PRIVELEDGE 202
 
// векторы с данными о паролях
vector <string> Login;      
vector <string> Pass;       
vector <int> ilvl;          
 
// Сокет
int s;
// Кол-во принятых или отосланных символов
int rc;
// порт для прослушивания
int port = 27015;
 
 
//Структура в которую записываем структуру содержащую информацию о клиенте
sockaddr_in client_sock_info;
 
int SenderAddrSize = sizeof(client_sock_info);
 
// команда пользователя
char command[20];
 
// Данные о подключении клиента
struct ClientInfo
{
    int iId;            // Уникальный номер клиента
    char cIp[16];       // IP адрес клиента
    int _iPort;         // порт используемый клиентом
    char cLogin[20];    // логин клиента
    char cPass[20];     // пароль клиента  
    int cStatus;        // Уровень доступных комманд
    int iError;         // сообщение об ошибке, либо клиент отключился
    int Section;        // текущий раздел
    int Article;        // текущая статья
    pthread_t targetThreadId;   // Указатель на нить для обработки запросов клиента
    int theArg;             // Аргументы для нити
    int hThrd;          // указатель на нить
    int s;              //информация о сокете
}clntinf[MAX_NUMBER_OF_CONNECTIONS]; 
 
// Работа с функиями отдельно
struct FuncExec
{
// функция вывода списка пользователей
void fwho(int tn);
 
// Смена уровня в системе
void fcd(int tn);
 
// переход на верхний уровень системы
void fup(int tn);
 
// функция добавления валюты
void fadd(int tn);
 
// функция принудительного отключения пользователя
void fkill(int tn);
 
// функция вывода списка
void fList (int tn);
}object[MAX_NUMBER_OF_CONNECTIONS];
 
// формат даты(времени)
struct date
{
    int day;    // день
    int month;  // месяц
    int year;   // год
}cdate;
 
// формат данных сервера
struct DB
{
    int nSections;          // кол-во разделов
    vector <string> Sections; // имена разделов
    vector <int> nArticles;         // кол-во статей в разделе
    vector <vector<string> > Articles;  // Статьи
}SDB;
 
// объединения для удобной записи/чтения файла
union inttochar
{
    int number;
    char chars[4];  
}int_char;
union inttofloat
{
    float number;
    char chars[4];  
}float_char;
 
 
// Пакет команды login
struct ReceiveLogin
{
    char cCommand[10];  // текущая комманда клиента   
    char cLogin[20];    // логин клиента
    char cPass[20];     // пароль клиента
};
// Ответ на команду login
struct ResponseLogin
{
    char cCommand[10];  // текущая комманда клиента   
    int iError;         // сообщение об ошибке
    int cStatus;        // Уровень доступных комманд 
};
 
// Структура стандартного пакета
struct stdPacket
{
    char cCommand[10];  // текущая комманда клиента
    int iError;         // сообщение об ошибке
};
 
// Структура пакета list
struct ReceiveLIST
{
    char cCommand[10];  // текущая комманда клиента
};
 
// Структура ответного пакета list
struct ResponseLIST
{
    char cLength[10];   // длина ответного пакета
    int iError;         // сообщение об ошибке
};
 
// Структура пакета up
struct ReceiveUP
{
    char cCommand[10];  // текущая комманда клиента
};
 
// Структура ответного пакета up
struct ResponseUP
{
    char cCommand[10];  // текущая комманда клиента
    int iError;         // сообщение об ошибке
};
 
// Структура пакета add
struct ReceiveADD
{
    char cCommand[10];  // текущая комманда клиента
    int length;         // длина пакета
};
 
// Структура ответного пакета add
struct ResponseADD
{
    char cCommand[10];  // текущая комманда клиента
    int iError;         // сообщение об ошибке
};
 
// Структура пакета del
struct ReceiveDEL
{
    char cCommand[10];  // текущая комманда клиента
    int code;           // код удаляемой валюты
};
 
// Структура пакета cd
struct ReceiveCD
{
    char cCommand[10];  // текущая комманда клиента
    int code;           // код раздела
};
 
// Структура ответного пакета cd
struct ResponseCD
{
    char cCommand[10];  // текущая комманда клиента
    int iError;         // сообщение об ошибке
    int Section;        // раздел
    int Article;        // статья
    char clvl[50];          // текущий уровень в системе в виде текста
};
 
// Структура пакета logout
struct ReceiveLogout
{
    char cCommand[10];  // текущая комманда клиента
};
 
// Структура пакета who
struct ReceiveWho
{
    char cCommand[10];  // текущая комманда клиента
};
 
// Структура ответного пакета who
struct ResponseWho
{
    char cLength[10];   // длина ответного пакета
    int iError;         // сообщение об ошибке
};
 
// Структура ответного пакета kill
struct ReceiveKill
{
    char cCommand[10];  // текущая комманда клиента
    int uID;            // Номер пользователя
};
 
// Структура ответного пакета kill
struct ResponseKill
{
    char cCommand[10];  // текущая комманда клиента
    int iError;         // сообщение об ошибке
};
 
// Посылка пакета производится в виде массива символов, независимо от типа пакета
union PacketFormat
{
    struct ReceiveLogin login_in;
    struct ResponseLogin login_out;
    struct stdPacket std_command;
    struct ReceiveLIST list_in;
    struct ResponseLIST list_out;
    struct ReceiveUP up_in;
    struct ResponseUP up_out;
    struct ReceiveADD add_in;
    struct ResponseADD add_out;
    struct ReceiveCD cd_in;
    struct ResponseCD cd_out;
    struct ReceiveLogout logout_in;
    struct ReceiveWho who_in;
    struct ResponseWho who_out;
    struct ReceiveKill kill_in;
    struct ResponseKill kill_out;
    char un[SIZE];  
}unSnd;
 
// Информация хранящаяся на сервере
struct SrvStatus
{
    // кол-во клиентов
    int numberofclients;
    // наибольший ID
    int lastid;
    // информация о клиентах
    struct ClientInfo InfoForClients[MAX_NUMBER_OF_CONNECTIONS];
    // Принятый пакет для обработки нитью
    union PacketFormat msg[MAX_NUMBER_OF_CONNECTIONS];
    // Буфер сообщения
    string l_buf_send[MAX_NUMBER_OF_CONNECTIONS];
}ServStatus;
 
// Посылка строки
void lsendto(int s, int tn, int flags);
 
// Нить обработки клиентских запросов
void * Handle_Client_Requests(void *n);
 
 
//----
// Функция аутентификации
int fLogin (int tn);
 
// функция отключения пользователя
int flogout(int tn);
 
// Функция вывода cтруктурированного пакета
void print(int tn);
// Чтение файла настроек
int ReadIniFile();
 
// Чтение состояния
int ReadSavedState();
 
// Сохранение состояния
void SaveState(int sig);
 
// Копирование строки даже при появлении символа 0
void strcpy2(char * Dest, const char * Source)
{
    for (int i=0; i<sizeof(Dest); i++)
    {
        Dest[i]=Source[i];
    }
}
 
// Нить обработки ввода команд
void * Server_UI(void *n);

Server.c

C++

#include "tcp_server.h"
 
 
// Главная функция программы
int main(void)
{
    // Кол-во подключенных клиентов
    ServStatus.numberofclients = 0;
    ServStatus.lastid = 0;
    for (int i=0; i<MAX_NUMBER_OF_CONNECTIONS; i++) ServStatus.InfoForClients[i].iError=1;
    SDB.nSections=0;
    
    // Чтение файла паролей
    if (ReadIniFile() < 0)
    {
        return 0;
    }else
    {
        printf("SERVER INFO: Successfully read ini file\n");
    }
 
    // Чтение состояния
    if (ReadSavedState() < 0)
    {
        printf("SERVER INFO: Failed to load previos state\n");
    }
 
    // Обработка выхода с сохранением состояния
    signal(SIGABRT, &SaveState);
    signal(SIGTERM, &SaveState);
    signal(SIGINT, &SaveState);
 
    // Создание соединения
    /*WSADATA wsaData;
    WSAStartup(MAKEWORD(2,2), &wsaData);*/
    sockaddr_in local;
    
    local.sin_family = AF_INET;
    local.sin_port = htons ( port ) ;
    local.sin_addr.s_addr = htonl ( INADDR_ANY );
    
    // Создание сокета
    s = socket ( AF_INET, SOCK_STREAM, 0 );
    if ( s < 0 )
    {
        //printf("SERVER INFO: Error at socket(): %ld\n", WSAGetLastError());
        perror("SERVER INFO: Error at socket()");
        //WSACleanup();
        return 0;
    }
 
    // Прослушивание порта
    if (bind( s, (sockaddr*) &local, sizeof(local)) == -1)
    {
        printf("SERVER INFO: bind() failed.\n");
        close(s);
        return 0;
    }
    else cout<<"SERVER INFO: bind() ok\n";
 
    if ( listen( s, 5 ) )
    {
        perror ( "SERVER INFO: listen failed\n" );
        return  0 ;
    }
    else printf("SERVER INFO: listen() ok\n");
 
    // Создание нити для получения уведомления об отключении
    pthread_t targetThreadId2;
    int theArg2=101;
    if( pthread_create(&targetThreadId2, NULL, Server_UI, (void *) theArg2) != 0 )
    {
        cout<<"INFO: Error CreateThread: "<<endl;
        return -1;
    }
    
    
    // Обработка пришедших пакетов
    while(1)
    {
        // Принятие соединения и передача его на обработку нити
        int tmps = accept( s, NULL, NULL );
        if ( tmps < 0 ){
            //cout<<"SERVER INFO: Error accept connection: "<<WSAGetLastError()<<endl;
            perror("SERVER INFO: Error accept connection");
        }else
        {
            cout << "SERVER INFO: Connection accepted, socket=" << tmps << "\n";
        }
        // уникальный номер клиента
        clntinf[MAX_NUMBER_OF_CONNECTIONS].iId = ServStatus.lastid;
        // Получение номера нити
        // получаем номер свободного слота
        int emptyslot=MAX_NUMBER_OF_CONNECTIONS;
        // Если никто не отключался, то нумерация от 0
        if ( ServStatus.lastid == ServStatus.numberofclients)
        {
            emptyslot=ServStatus.numberofclients; 
        }else
        // если кто-то отключился, то записываем информацию в свободный слот
        {
            for (int j=0; j<MAX_NUMBER_OF_CONNECTIONS; j++)
            {
                if (ServStatus.InfoForClients[j].iError > 0)
                {
                    emptyslot=j;
                    break;
                }
            }
        }
        if (emptyslot==MAX_NUMBER_OF_CONNECTIONS)
        {
            cout<<"SERVER INFO: Thread limit reached, can't handle anymore users\n";
            // Посылка ответа
            rc = shutdown(tmps, SHUT_RDWR);
            if ( rc < 0 ){
                //cout<<"SERVER INFO: Error shuting down socket: "<< WSAGetLastError() << endl;
                perror("SERVER INFO: Error shuting down socket");   
            }else
            {
                cout<<"SERVER INFO: socket shutdowned, RC="<< rc << endl;
            }
            rc = close(tmps);
            if ( rc < 0 ){
                //cout<<"SERVER INFO: Error closing socket: "<< WSAGetLastError() << endl;
                perror("SERVER INFO: Error closing socket");
            }else
            {
                cout<<"SERVER INFO: socket closed, RC="<< rc << endl;
            }
            continue;
        }
 
        // Создаем нить для обработки запросов клиента
        pthread_t targetThreadId;
        int theArg=emptyslot;
        int hThrd=0;
        int *pArg = new int;
        *pArg = theArg;
        hThrd=pthread_create(&targetThreadId, NULL, Handle_Client_Requests, (void *) pArg);
        if( hThrd != 0 )
        {
            cout<<"SERVER INFO: Error CreateThread for client requests: " << endl;//<<GetLastError()<<endl;
            return -1;
        }
        clntinf[MAX_NUMBER_OF_CONNECTIONS].targetThreadId=targetThreadId;
        clntinf[MAX_NUMBER_OF_CONNECTIONS].theArg=theArg;
        clntinf[MAX_NUMBER_OF_CONNECTIONS].hThrd=hThrd;
        clntinf[MAX_NUMBER_OF_CONNECTIONS].s=tmps;
        clntinf[MAX_NUMBER_OF_CONNECTIONS].iError=0;
        clntinf[MAX_NUMBER_OF_CONNECTIONS].Article=0;
        clntinf[MAX_NUMBER_OF_CONNECTIONS].Section=0;
        
        // заполняем базу клиентов
        ServStatus.InfoForClients[emptyslot] = clntinf[MAX_NUMBER_OF_CONNECTIONS];
 
        /// Увеличиваем кол-во подключенных клиентов и идентификатор
        ServStatus.numberofclients++;
        ServStatus.lastid++;
    }
    // Выход
    close(s);
    printf("Exiting.\n");
    //WSACleanup();
    return 0;
}
 
// Нить обработки клиентских запросов
void * Handle_Client_Requests(void *n)
{ 
     int *parg = (int*) n;
     
     int arg = *parg;
     printf("arg %i",arg);
     delete parg;
    
    sleep(1);
    // Номер нити
    int TNumber = arg;
    //FuncExec object;
    // Вывод сообщения о запуске нити
    cout<<"SERVER INFO: Thread Number " << TNumber << " started to handle requests for socket '" << ServStatus.InfoForClients[TNumber].s << "'" <<endl;
    // Ждем сообщение
    while ( 1 )
    {
        // Обработка входящих пакетов
        int trc = recv( ServStatus.InfoForClients[TNumber].s, ServStatus.msg[TNumber].un, SIZE, 0 );
        if ( trc < 0 ){
            // Обработка ECONRESET
            int err=errno;
            if (err==ECONNRESET)//ECONNRESET=54
            {
                // завершение работы нити
                cout<<"SERVER INFO: ECONNRESET: Connection reset by peer" <<endl;
                cout << "SERVER INFO: Thread Number " << TNumber << " exiting..." << endl;
                trc = shutdown(ServStatus.InfoForClients[TNumber].s, SHUT_RDWR);
                if ( trc < 0 ){
                    cout<<"SERVER INFO: Error shuting down socket: "<< errno << endl;   
                }else
                {
                    cout<<"SERVER INFO: socket shutdowned" << endl;
                }
                trc = close(ServStatus.InfoForClients[TNumber].s);
                if ( trc < 0 ){
                    cout<<"SERVER INFO: Error closing socket: "<< errno << endl;    
                }else
                {
                    cout<<"SERVER INFO: socket closed" << endl;
                }
                ServStatus.numberofclients--;
                ServStatus.InfoForClients[TNumber].iError=1;
                return 0;
            }else if (err==ENOTSOCK)//ENOTSOCK=38
            {
                // завершение работы нити при дисконекте другой нитью
                cout << "SERVER INFO: Thread Number " << TNumber << " exiting..." << endl;
                return 0;
            }else
            {
                cout<<"SERVER INFO: Error receiving packet: "<<errno<<endl;
                cout << "SERVER INFO: Thread Number " << TNumber << " exiting..." << endl;
                return 0;
            }
        }else if (trc == 0)
        {
            cout << "SERVER INFO: Thread Number " << TNumber << " exiting..." << endl;
            return 0;
        }else
        {
            cout << "SERVER INFO: Packet received, RC=" << trc << "\n";
        }
        cout<<"SERVER INFO: Thread Number " << TNumber << " processing '"<< ServStatus.msg[TNumber].std_command.cCommand << "' command for socket '" << ServStatus.InfoForClients[TNumber].s << "', UserID=" << ServStatus.InfoForClients[TNumber].iId <<endl;
        //print(TNumber);
        if(!strcmp(ServStatus.msg[TNumber].std_command.cCommand,"list"))        object[TNumber].fList(TNumber);
        else if(!strcmp(ServStatus.msg[TNumber].std_command.cCommand,"login"))  
        {
            if (fLogin(TNumber) != 0)
            {
                // завершение работы нити при неудачной аутенфикации
                cout << "SERVER INFO: Thread Number " << TNumber << " exiting..." << endl;
                ServStatus.numberofclients--;
                ServStatus.InfoForClients[TNumber].iError=1;
                return 0;
            }
        }
        else if(!strcmp(ServStatus.msg[TNumber].std_command.cCommand,"logout")) 
        {
            flogout(TNumber);
            // завершение работы нити
            cout << "SERVER INFO: Thread Number " << TNumber << " exiting..." << endl;
            return 0;
        }
        else if(!strcmp(ServStatus.msg[TNumber].std_command.cCommand,"who"))        object[TNumber].fwho(TNumber);
        else if(!strcmp(ServStatus.msg[TNumber].std_command.cCommand,"cd"))         object[TNumber].fcd(TNumber);
        else if(!strcmp(ServStatus.msg[TNumber].std_command.cCommand,"up"))         object[TNumber].fup(TNumber);
        else if(!strcmp(ServStatus.msg[TNumber].std_command.cCommand,"add"))        object[TNumber].fadd(TNumber);
        else if(!strcmp(ServStatus.msg[TNumber].std_command.cCommand,"kill"))       object[TNumber].fkill(TNumber);
        else {cout << "SERVER INFO: received unknown command '" << ServStatus.msg[TNumber].std_command.cCommand << "'" << endl;}
    }
    
    return(0);
}
 
// функция вывода списка
void FuncExec :: fList (int tn)
{
    cout << "SERVER INFO: processing list command"<< endl;
 
    // Буфер для сообщения
    char  buf_send[400];
    ServStatus.l_buf_send[tn]="";
    
    if (ServStatus.InfoForClients[tn].Section==0)
    {
        // Вывод разделов
        if (SDB.nSections==0)
        {
            sprintf(buf_send, "There is no sections on the server\n");
            ServStatus.l_buf_send[tn]+=buf_send;
        }else
        {
            sprintf(buf_send, "Sections:\n");
            ServStatus.l_buf_send[tn]+=buf_send;
            for (int i=0; i<SDB.nSections; i++)
            {
                sprintf(buf_send, "%d\t%s\n", i+1, SDB.Sections[i].c_str());
                ServStatus.l_buf_send[tn]+=buf_send;
            }
        }
    }else
    {
        if (ServStatus.InfoForClients[tn].Section>SDB.nSections)
        {
            sprintf(buf_send, "Current section no longer exists on the server\n");
            ServStatus.l_buf_send[tn]+=buf_send;
        }else
        {
            if (ServStatus.InfoForClients[tn].Article==0)
            {
                sprintf(buf_send, "%s Section:\n", SDB.Sections[ServStatus.InfoForClients[tn].Section-1].c_str());
                ServStatus.l_buf_send[tn]+=buf_send;
                if (SDB.nArticles[ServStatus.InfoForClients[tn].Section-1]==0)
                {
                    sprintf(buf_send, "There are no section\n");
                    ServStatus.l_buf_send[tn]+=buf_send;
                }
                for (int i=0; i<SDB.nArticles[ServStatus.InfoForClients[tn].Section-1]; i++)
                {
                    string tmp1="", tmp2="";
                    int sep1=-1,sep2=-1;
                    for (int j=0; j<SDB.Articles[ServStatus.InfoForClients[tn].Section-1][i].length(); j++)
                    {
                        if ( SDB.Articles[ServStatus.InfoForClients[tn].Section-1][i][j] == 30 )
                        {
                            sep1=j;
                            break;
                        }
                        tmp1+=SDB.Articles[ServStatus.InfoForClients[tn].Section-1][i][j];
                    }
                    for (int j=sep1+1; j<SDB.Articles[ServStatus.InfoForClients[tn].Section-1][i].length(); j++)
                    {
                        if ( SDB.Articles[ServStatus.InfoForClients[tn].Section-1][i][j] == 30 )
                        {
                            sep2=j;
                            break;
                        }
                        tmp2+=SDB.Articles[ServStatus.InfoForClients[tn].Section-1][i][j];
                    }
                    sprintf(buf_send, "%d\t%s\n",i+1, tmp1.c_str());
                    ServStatus.l_buf_send[tn]+=buf_send;
                }
            }else
            {
                if (ServStatus.InfoForClients[tn].Article>SDB.nArticles[ServStatus.InfoForClients[tn].Section-1])
                {
                    sprintf(buf_send, "Current article no longer exists on the server\n");
                    ServStatus.l_buf_send[tn]+=buf_send;
                }else
                {
                    string tmp1="", tmp2="", tmp3="";
                    int sep1=-1,sep2=-1;
                    for (int j=0; j<SDB.Articles[ServStatus.InfoForClients[tn].Section-1][ServStatus.InfoForClients[tn].Article-1].length(); j++)
                    {                       
                        if ( SDB.Articles[ServStatus.InfoForClients[tn].Section-1][ServStatus.InfoForClients[tn].Article-1][j] == 30 )
                        {
                            sep1=j;                         
                            break;
                        }
                        tmp1+=SDB.Articles[ServStatus.InfoForClients[tn].Section-1][ServStatus.InfoForClients[tn].Article-1][j];
                    }
                    for (int j=sep1+1; j<SDB.Articles[ServStatus.InfoForClients[tn].Section-1][ServStatus.InfoForClients[tn].Article-1].length(); j++)
                    {
                        if ( SDB.Articles[ServStatus.InfoForClients[tn].Section-1][ServStatus.InfoForClients[tn].Article-1][j] == 30 )
                        {
                            sep2=j;
                            break;
                        }
                        tmp2+=SDB.Articles[ServStatus.InfoForClients[tn].Section-1][ServStatus.InfoForClients[tn].Article-1][j];
                    }
                    for (int j=sep2+1; j<SDB.Articles[ServStatus.InfoForClients[tn].Section-1][ServStatus.InfoForClients[tn].Article-1].length(); j++)
                    {
                        tmp3+=SDB.Articles[ServStatus.InfoForClients[tn].Section-1][ServStatus.InfoForClients[tn].Article-1][j];
                    }
                    int i=0;
                    sprintf(buf_send, "%d\t%s\n",i+1, tmp1.c_str());
                    ServStatus.l_buf_send[tn]+=buf_send;
                }
 
            }
        }
    }
    printf ("List 1 = %d",ServStatus.InfoForClients[tn].s);
    // Посылаем строку
     lsendto(ServStatus.InfoForClients[tn].s,tn,0); 
    printf ("List 2 = %d",ServStatus.InfoForClients[tn].s);
}
 
// функция добавления
void FuncExec :: fadd(int tn)
{
    // Проверка статуса клиента
    if (ServStatus.InfoForClients[tn].cStatus < 4)
    {
        int length=ServStatus.msg[tn].add_in.length;
        char *buf_recv;
        buf_recv=new char[length];
        // Обработка входящих пакетов
        int trc = recv( ServStatus.InfoForClients[tn].s, buf_recv, length, 0 );
        if ( trc < 0 ){
            cout << "SERVER INFO: Add command had't receive text: " <<errno<<endl;
        }
        if (ServStatus.InfoForClients[tn].Section==0)
        {           
            string finalstring="";
            for (int i=0; i<length; i++) finalstring+=buf_recv[i];
            cout << "SERVER INFO: adding Section with name='" << finalstring <<"', length='" << length << "'\n";
            // добавление раздела
            SDB.Sections.push_back(finalstring);
            SDB.nSections++;
            vector<string> tmp;
            SDB.Articles.push_back(tmp);
            SDB.nArticles.push_back(0);
            // формирование пакета с ответом
            // очистка пакета от мусора
            for (int i=0; i<SIZE; i++) ServStatus.msg[tn].un[i]=0;
            strcpy(ServStatus.msg[tn].kill_out.cCommand,"add");
            ServStatus.msg[tn].kill_out.iError=0;
            // Посылка ответа на команду add
            rc = send(ServStatus.InfoForClients[tn].s,ServStatus.msg[tn].un,SIZE,0);
            if ( rc < 0 ){
                cout<<"SERVER INFO: Error sending add response: "<<errno<<endl;
            }
            else
            {
                cout << "SERVER INFO: Sent add response, RC=" << rc << endl;
            }       
        }else
        {
            string finalstring="";
            for (int i=0; i<length; i++) finalstring+=buf_recv[i];
            cout << "SERVER INFO: adding Article='" << finalstring <<"', length='" << length << "'\n";
            // добавление подраздела
            SDB.Articles[ServStatus.InfoForClients[tn].Section-1].push_back(finalstring);
            SDB.nArticles[ServStatus.InfoForClients[tn].Section-1]++;
            // формирование пакета с ответом
            // очистка пакета от мусора
            for (int i=0; i<SIZE; i++) ServStatus.msg[tn].un[i]=0;
            strcpy(ServStatus.msg[tn].kill_out.cCommand,"add");
            ServStatus.msg[tn].kill_out.iError=0;
            // Посылка ответа на команду add
            rc = send(ServStatus.InfoForClients[tn].s,ServStatus.msg[tn].un,SIZE,0);
            if ( rc < 0 ){
                cout<<"SERVER INFO: Error sending add response: "<<errno<<endl;
            }
            else
            {
                cout << "SERVER INFO: Sent add response, RC=" << rc << endl;
            }
        }
    }else
    {
        // формирование пакета с ошибкой
        // очистка пакета от мусора
        for (int i=0; i<SIZE; i++) ServStatus.msg[tn].un[i]=0;
        strcpy(ServStatus.msg[tn].kill_out.cCommand,"add");
        ServStatus.msg[tn].kill_out.iError=NOT_ENOUGH_PRIVELEDGE;
        // Посылка ответа на команду add
        rc = send(ServStatus.InfoForClients[tn].s,ServStatus.msg[tn].un,SIZE,0);
        if ( rc < 0 ){
            cout<<"SERVER INFO: Error sending NOT_ENOUGH_PRIVELEDGE Notification: "<<errno<<endl;
        }
        else
        {
            cout << "SERVER INFO: Sent NOT_ENOUGH_PRIVELEDGE Notification, RC=" << rc << endl;
        }
    }
}
 
// функция Смены уровня в системе
void FuncExec :: fcd(int tn)
{
 
    if (ServStatus.InfoForClients[tn].Section==0)
    {
        // если раздела/подоаздела нет - посылаем ошибку
        if (ServStatus.msg[tn].cd_in.code>SDB.nSections || ServStatus.msg[tn].cd_in.code == 0)
        {
            // формирование пакета с ошибкой
            // очистка пакета от мусора
            for (int i=0; i<SIZE; i++) ServStatus.msg[tn].un[i]=0;
            strcpy(ServStatus.msg[tn].kill_out.cCommand,"del");
            ServStatus.msg[tn].kill_out.iError=NO_SUCH_CODE;
            // Посылка ответа на команду del
            rc = send(ServStatus.InfoForClients[tn].s,ServStatus.msg[tn].un,SIZE,0);
            if ( rc < 0 ){
                cout<<"SERVER INFO: Error sending NO_SUCH_CODE Notification: "<<errno<<endl;
            }
            else
            {
                cout << "SERVER INFO: Sent NO_SUCH_CODE Notification, RC=" << rc << endl;
            }
        }
        // раздел найден
        else
        {
            // переходим в раздел
            ServStatus.InfoForClients[tn].Section=ServStatus.msg[tn].cd_in.code;
            // формирование пакета с ответом
            // очистка пакета от мусора
            for (int i=0; i<SIZE; i++) ServStatus.msg[tn].un[i]=0;
            strcpy(ServStatus.msg[tn].kill_out.cCommand,"пїЅпїЅ");
            ServStatus.msg[tn].kill_out.iError=0;
            ServStatus.msg[tn].cd_out.Section=ServStatus.InfoForClients[tn].Section;
            ServStatus.msg[tn].cd_out.Article=0;
            char tmp[50];
            strcpy(tmp,"root-");
            strcat(tmp,SDB.Sections[ServStatus.InfoForClients[tn].Section-1].c_str());
            strcpy(ServStatus.msg[tn].cd_out.clvl,tmp);
            // Посылка ответа на команду cd
            rc = send(ServStatus.InfoForClients[tn].s,ServStatus.msg[tn].un,SIZE,0);
            if ( rc < 0 ){
                cout<<"SERVER INFO: Error sending add response: "<<errno<<endl;
            }
            else
            {
                cout << "SERVER INFO: Sent add response, RC=" << rc << endl;
            }       
        }
    }else
    {
        // если раздела/подоаздела нет - посылаем ошибку
        if (ServStatus.msg[tn].cd_in.code>SDB.nArticles[ServStatus.InfoForClients[tn].Section-1] || ServStatus.msg[tn].cd_in.code == 0)
        {
            // формирование пакета с ошибкой
            // очистка пакета от мусора
            for (int i=0; i<SIZE; i++) ServStatus.msg[tn].un[i]=0;
            strcpy(ServStatus.msg[tn].kill_out.cCommand,"del");
            ServStatus.msg[tn].kill_out.iError=NO_SUCH_CODE;
            // Посылка ответа на команду del
            rc = send(ServStatus.InfoForClients[tn].s,ServStatus.msg[tn].un,SIZE,0);
            if ( rc < 0 ){
                cout<<"SERVER INFO: Error sending NO_SUCH_CODE Notification: "<<errno<<endl;
            }
            else
            {
                cout << "SERVER INFO: Sent NO_SUCH_CODE Notification, RC=" << rc << endl;
            }
        }
        // раздел найден
        else
        {
            // переходим в раздел
            ServStatus.InfoForClients[tn].Article=ServStatus.msg[tn].cd_in.code;
            // формирование пакета с ответом
            // очистка пакета от мусора
            for (int i=0; i<SIZE; i++) ServStatus.msg[tn].un[i]=0;
            strcpy(ServStatus.msg[tn].kill_out.cCommand,"пїЅпїЅ");
            ServStatus.msg[tn].kill_out.iError=0;
            ServStatus.msg[tn].cd_out.Section=ServStatus.InfoForClients[tn].Section;
            ServStatus.msg[tn].cd_out.Article=ServStatus.InfoForClients[tn].Article;
            char tmp[50];
            strcpy(tmp,"root-");
            strcat(tmp,SDB.Sections[ServStatus.InfoForClients[tn].Section-1].c_str());
            strcat(tmp,"-");
            string tmp2;
            string tmp1="";
            int sep1=-1;
            for (int j=0; j<SDB.Articles[ServStatus.InfoForClients[tn].Section-1][ServStatus.InfoForClients[tn].Article-1].length(); j++)
            {                       
                if ( SDB.Articles[ServStatus.InfoForClients[tn].Section-1][ServStatus.InfoForClients[tn].Article-1][j] == 30 )
                {
                    sep1=j;                         
                    break;
                }
                tmp1+=SDB.Articles[ServStatus.InfoForClients[tn].Section-1][ServStatus.InfoForClients[tn].Article-1][j];
            }
            strcat(tmp,tmp1.c_str());
            strcpy(ServStatus.msg[tn].cd_out.clvl,tmp);
            // Посылка ответа на команду cd
            rc = send(ServStatus.InfoForClients[tn].s,ServStatus.msg[tn].un,SIZE,0);
            if ( rc < 0 ){
                cout<<"SERVER INFO: Error sending add response: "<<errno<<endl;
            }
            else
            {
                cout << "SERVER INFO: Sent add response, RC=" << rc << endl;
            }       
        }
    }
}
 
// функция Смены уровня в системе
void FuncExec ::  fup(int tn)
{
sleep(15);
    // переходим в корневой раздел
    ServStatus.InfoForClients[tn].Section=0;
    ServStatus.InfoForClients[tn].Article=0;
 
    // формирование пакета с ответом
    // очистка пакета от мусора
    for (int i=0; i<SIZE; i++) ServStatus.msg[tn].un[i]=0;
    strcpy(ServStatus.msg[tn].kill_out.cCommand,"up");
    ServStatus.msg[tn].kill_out.iError=0;
    // Посылка ответа на команду up
    rc = send(ServStatus.InfoForClients[tn].s,ServStatus.msg[tn].un,SIZE,0);
    if ( rc < 0 ){
        cout<<"SERVER INFO: Error sending add response: "<<errno<<endl;
    }
    else
    {
        cout << "SERVER INFO: Sent add response, RC=" << rc << endl;
    }
}
 
// функция отключения пользователя
int flogout(int tn)
{
    // Запись информации о том, что ячейка памяти более не используется
    ServStatus.InfoForClients[tn].iError=1;
    ServStatus.numberofclients--;
    // закрытие сокета
    int trc = shutdown(ServStatus.InfoForClients[tn].s, SHUT_RDWR);
    if ( trc < 0 ){
        cout<<"SERVER INFO: Error shuting down socket: "<< errno << endl;   
    }else
    {
        cout<<"SERVER INFO: socket shutdowned" << endl;
    }
    trc = close(ServStatus.InfoForClients[tn].s);
    if ( trc < 0 ){
        cout<<"SERVER INFO: Error closing socket: "<< errno << endl;    
    }else
    {
        cout<<"SERVER INFO: socket closed" << endl;
    }
    // завершение работы нити
    return 1;
}
 
// функция принудительного отключения пользователя
void FuncExec :: fkill(int tn)
{
    // Проверка статуса клиента
    if (ServStatus.InfoForClients[tn].cStatus < 3)
    {
        int ID=MAX_NUMBER_OF_CONNECTIONS;
        // Поиск указанного клиента
        for (int i=0; i<MAX_NUMBER_OF_CONNECTIONS; i++)
        {
            if (ServStatus.InfoForClients[i].iError==0 && ServStatus.msg[tn].kill_in.uID==ServStatus.InfoForClients[i].iId)
            {
                ID=i;
                break;
            }
        }
        // клиент не найден
        if (ID==MAX_NUMBER_OF_CONNECTIONS)
        {
            // формирование пакета с ошибкой
            // очистка пакета от мусора
            for (int i=0; i<SIZE; i++) ServStatus.msg[tn].un[i]=0;
            strcpy(ServStatus.msg[tn].kill_out.cCommand,"kill");
            ServStatus.msg[tn].kill_out.iError=NO_SUCH_USER;
            // Посылка ответа на команду kill
            rc = send(ServStatus.InfoForClients[tn].s,ServStatus.msg[tn].un,SIZE,0);
            if ( rc < 0 ){
                cout<<"SERVER INFO: Error sending NO_SUCH_USER Notification: "<<errno<<endl;
            }
            else
            {
                cout << "SERVER INFO: Sent NO_SUCH_USER Notification, RC=" << rc << endl;
            }
 
        }
        //клиент найден
        else
        {
                        // Адрес отключенного клиента
            /*sockaddr_in client_sock_info3;
            client_sock_info3.sin_addr.s_addr = inet_addr(ServStatus.InfoForClients[ID].cIp);
            client_sock_info3.sin_port = ServStatus.InfoForClients[ID]._iPort;*/
 
            // Запись информации о том, что ячейка памяти более не используется
            ServStatus.InfoForClients[ID].iError=1;
            ServStatus.numberofclients--;           
            // формирование пакета с ответом
            // очистка пакета от мусора
            for (int i=0; i<SIZE; i++) ServStatus.msg[tn].un[i]=0;
            strcpy(ServStatus.msg[tn].kill_out.cCommand,"kill");
            ServStatus.msg[tn].kill_out.iError=0;
            // Посылка ответа на команду kill
            rc = send(ServStatus.InfoForClients[tn].s,ServStatus.msg[tn].un,SIZE,0);
            if ( rc < 0 ){
                cout<<"SERVER INFO: Error sending kill response: "<<errno<<endl;
            }
            else
            {
                cout << "SERVER INFO: Sent kill response, RC=" << rc << endl;
            }
            // формирование пакета с уведомлением об отключении
            // очистка пакета от мусора
            for (int i=0; i<SIZE; i++) ServStatus.msg[tn].un[i]=0;
            strcpy(ServStatus.msg[tn].kill_out.cCommand,"kill");
            ServStatus.msg[tn].kill_out.iError=YOU_HAVE_BEEN_DISCONECTED_BY_SUSER;
            // Посылка уведомления отключенному клиенту
            rc = send(ServStatus.InfoForClients[ID].s,ServStatus.msg[tn].un,SIZE,0);
            if ( rc < 0 ){
                cout<<"SERVER INFO: Error sending YOU_HAVE_BEEN_DISCONECTED_BY_SUSER Notification: "<<errno<<endl;
            }
            else
            {
                cout << "SERVER INFO: Sent YOU_HAVE_BEEN_DISCONECTED_BY_SUSER Notification, RC=" << rc << endl;
            }
            // закрытие сокета
            int trc = shutdown(ServStatus.InfoForClients[ID].s, SHUT_RDWR);
            if ( trc < 0 ){
                cout<<"SERVER INFO: Error shuting down socket: "<< errno << endl;   
            }else
            {
                cout<<"SERVER INFO: socket shutdowned" << endl;
            }
            trc = close(ServStatus.InfoForClients[ID].s);
            if ( trc < 0 ){
                cout<<"SERVER INFO: Error closing socket: "<< errno << endl;    
            }else
            {
                cout<<"SERVER INFO: socket closed" << endl;
            }
 
 
        }       
    }else
    {
        // формирование пакета с ошибкой
        // очистка пакета от мусора
        for (int i=0; i<SIZE; i++) ServStatus.msg[tn].un[i]=0;
        strcpy(ServStatus.msg[tn].kill_out.cCommand,"kill");
        ServStatus.msg[tn].kill_out.iError=NOT_ENOUGH_PRIVELEDGE;
        // Посылка ответа на команду kill
        rc = send(ServStatus.InfoForClients[tn].s,ServStatus.msg[tn].un,SIZE,0);
        if ( rc < 0 ){
            cout<<"SERVER INFO: Error sending NOT_ENOUGH_PRIVELEDGE Notification: "<<errno<<endl;
        }
        else
        {
            cout << "SERVER INFO: Sent NOT_ENOUGH_PRIVELEDGE Notification, RC=" << rc << endl;
        }
    }
}
 
// функция вывода списка пользователей
void FuncExec :: fwho(int tn)
{
    cout << "SERVER INFO: processing who command"<< endl;
    // Буфер для сообщения
    char  buf_send[400];
    ServStatus.l_buf_send[tn]="";
    //sleep(15);
    sprintf(buf_send, "UserID\tUserName\n");
    ServStatus.l_buf_send[tn]+=buf_send;
    for (int i=0; i<MAX_NUMBER_OF_CONNECTIONS; i++)
    {
        if (ServStatus.InfoForClients[i].iError==0)
        {
            sprintf(buf_send,"%6d\t%-8s\n",ServStatus.InfoForClients[i].iId, ServStatus.InfoForClients[i].cLogin);
            ServStatus.l_buf_send[tn]+=buf_send;
        }
    }
 
    // Посылаем строку
    printf ("Who 1 = %d",ServStatus.InfoForClients[tn].s); 
    lsendto(clntinf[MAX_NUMBER_OF_CONNECTIONS].s,tn,0);
    //sleep(15);
    printf ("who 2 = %d",ServStatus.InfoForClients[tn].s);
}
 
// Посылка строки
void lsendto(int s, int tn, int flags)
{
    // Получение длины получившейся строки
    int messagelength=ServStatus.l_buf_send[tn].length();
    // Запись длины в буфер
    char str_messagelength[10];
    sprintf(str_messagelength,"%d",messagelength);
    // формирование пакета с длиной
    // очистка пакета от мусора
    for (int i=0; i<SIZE; i++) ServStatus.msg[tn].un[i]=0;
    strcpy(ServStatus.msg[tn].list_out.cLength,str_messagelength);
    // ошибок нету
    ServStatus.msg[tn].list_out.iError=0;   
    // Посылка длины нашего сообщения клиентскому приложению
    rc = send(ServStatus.InfoForClients[tn].s,ServStatus.msg[tn].un,SIZE,flags);
    if ( rc < 0 ){
        cout<<"SERVER INFO: Error sending packet length: "<<errno<<endl;
    }
    else
    {
        cout << "SERVER INFO: Sent packet length(" << str_messagelength << "), RC=" << rc << endl;
    }
    // Посылка сообщения
    rc = send(ServStatus.InfoForClients[tn].s,ServStatus.l_buf_send[tn].c_str(),messagelength,flags);
    if ( rc < 0 ){
        cout<<"SERVER INFO: Error sending long packet: "<<errno<<endl;
    }
    else
    {
        cout << "SERVER INFO: Sent long packet, RC=" << rc << endl;
    }
    return rc;  
}
 
// Функция аутентификации
int fLogin (int tn) 
{
    // Тип нашей команды
    char tmpcommand[10]="login";
    // проверяем наличие комбинации пользователь-пароль
    for(int i=0;i<int(Login.size());i++)
    {
        if ((!strcmp(ServStatus.msg[tn].login_in.cLogin,Login[i].c_str()))&&(!strcmp(ServStatus.msg[tn].login_in.cPass,Pass[i].c_str())))
        {
            // Заполняем данные о клиенте, IP и порт уже записаны
            // Записываем статус клиента
            ServStatus.InfoForClients[tn].cStatus=ilvl[i];
            // Логин клиента
            strcpy(ServStatus.InfoForClients[tn].cLogin,ServStatus.msg[tn].login_in.cLogin);
            // Пароль клиента
            strcpy(ServStatus.InfoForClients[tn].cPass,ServStatus.msg[tn].login_in.cPass);
            // Клиент подключен
            ServStatus.InfoForClients[tn].iError=0;
                        
            // Посылка ответа
            // Очистка структуры пакета
            for (int j=0; j<SIZE; j++) ServStatus.msg[tn].un[j]=0;
            // запись команды
            strcpy(ServStatus.msg[tn].login_out.cCommand,tmpcommand);
            // запись ошибки
            ServStatus.msg[tn].login_out.iError=0;
            // запись уровня привелегий
            ServStatus.msg[tn].login_out.cStatus=ilvl[i];
            // посылка пакета
            rc = send(ServStatus.InfoForClients[tn].s,ServStatus.msg[tn].un,SIZE,0);
            if ( rc < 0 ){
                cout<<"SERVER INFO: Error sending ResponseLogin: "<< errno << endl; 
            }else
            {
                cout<<"SERVER INFO: Sent ResponseLogin, RC="<< rc << endl;
            }
            // аутентификация прошла успешно
            return 0; 
            break;
        }       
    }
    cout << "SERVER INFO: unsuccessfull autentification, login='" << ServStatus.msg[tn].login_in.cLogin << "', pass='" << ServStatus.msg[tn].login_in.cPass << "'\n";
    // Посылка ответа
    // Очистка структуры пакета
    for (int j=0; j<SIZE; j++) ServStatus.msg[tn].un[j]=0;
    // запись команды
    strcpy(ServStatus.msg[tn].login_out.cCommand,tmpcommand);
    // запись ошибки
    ServStatus.msg[tn].login_out.iError=WRONG_LOGIN_PASS_COMBINATION;
    // запись уровня привелегий
    ServStatus.msg[tn].login_out.cStatus=0;
    rc = send(ServStatus.InfoForClients[tn].s,ServStatus.msg[tn].un,SIZE,0);
    if ( rc < 0 ){
        cout<<"SERVER INFO: Error sending ResponseLogin: "<< errno << endl; 
    }else
    {
        cout<<"SERVER INFO: Sent ResponseLogin, RC="<< rc << endl;
    }
 
    rc = shutdown(ServStatus.InfoForClients[tn].s, SHUT_RDWR);
    if ( rc < 0 ){
        cout<<"SERVER INFO: Error shuting down socket: "<< errno << endl;   
    }else
    {
        cout<<"SERVER INFO: socket shutdowned" << endl;
    }
 
    rc = close(ServStatus.InfoForClients[tn].s);
    if ( rc < 0 ){
        cout<<"SERVER INFO: Error closing socket: "<< errno << endl;    
    }else
    {
        cout<<"SERVER INFO: socket closed" << endl;
    }
    // неудачная аутентификация
    return 1; 
}
 
// Чтение файла настроек
int ReadIniFile()
{
    // файловый поток
    fstream FileStream; 
    // имя файла
    string F_Name="Server.ini"; 
    // открытие файла
    FileStream.open(F_Name.c_str(), ios::in);
    // проверка открытия файла
    if (!FileStream)
    {
        cout << "SERVER INFO: Error opening ini file '" << F_Name.c_str() << "'" << endl;
        return -1;
    }else
    {
        cout << "SERVER INFO: Opened ini file '" << F_Name.c_str() << "'" << endl;
    }
    // текущая строка файла
    string line;
    // начало блока паролей
    bool readlogininfo=false;
    // номера символов с инфой
    int tmp,tmp2,tmp3,tmp4,tmp5,tmp6;
    // Переменная для перевода данных из строки в число
    int inttmp1;
    // чтение файла
    while(FileStream)
    {
        // чтение строки
        getline(FileStream,line, '\n');
        // Обработка коментариев
        if (line.find(";") != string::npos && int(line.find(";"))==0 )
        {
            cout << "SERVER INFO: Found comment in file '" << F_Name.c_str() << "':" << endl;
            cout << line.c_str() << endl;
        }
        // Строка пустая
        else if (line.empty())
        {
            cout << "SERVER INFO: Found empty line in file '" << F_Name.c_str() << "'" << endl;
        }
        // Блок с информацией о паролях
        else if (line.find("[Login info]") != string::npos )
        {
            readlogininfo=true;
        }
        else if (readlogininfo==true && line.find("Login=") != string::npos )
        {
            // Поиск логина
            tmp=line.find("Login=");
            tmp2=line.find(";",tmp);
            if (tmp2 != string::npos )
            {
                Login.push_back(line.substr(tmp+6,tmp2-6-tmp));
            }else
            {
                cout << "SERVER INFO: Wrong ini file '" << F_Name.c_str() << "'" << endl;
                return -1;
            }
            // Поиск пароля
            tmp3=line.find("Pass=",tmp2);
            if (tmp3 != string::npos )
            {
                tmp4=line.find(";",tmp3);
                if (tmp4 != string::npos )
                {
                    Pass.push_back(line.substr(tmp3+5,tmp4-tmp3-5));
                }else
                {
                    cout << "SERVER INFO: Wrong ini file '" << F_Name.c_str() << "'" << endl;
                    return -1;
                }
            }else
            {
                cout << "SERVER INFO: Wrong ini file '" << F_Name.c_str() << "'" << endl;
                return -1;
            }
            // Поиск уровня привелегий
            tmp5=line.find("ilvl=",tmp4);
            if (tmp3 != string::npos )
            {
                tmp6=line.find(";",tmp5);
                if (tmp6 != string::npos )
                {
                    if(!from_string<int>(inttmp1, line.substr(tmp5+5,tmp6-5-tmp5), std::dec))
                    {
                        cout << "SERVER INFO: ilvl is not integer, file '" << F_Name.c_str() << "'" << endl;
                        return -1;
                    }
                    ilvl.push_back(inttmp1);
                }else
                {
                    cout << "SERVER INFO: Wrong ini file '" << F_Name.c_str() << "'" << endl;
                    return -1;
                }
            }else
            {
                cout << "SERVER INFO: Wrong ini file '" << F_Name.c_str() << "'" << endl;
                return -1;
            }
 
 
        }else
        {
            cout << "SERVER INFO: Wrong ini file '" << F_Name.c_str() << "'" << endl;
            return -1;
        }
    }
    // закрытие файла
    FileStream.close();
    return 0;
}
 
// Чтение состояния
int ReadSavedState()
{
    
    // файловый поток
    fstream FileStream; 
    // имя файла
    string F_Name="Saved.state";    
    // открытие файла
    FileStream.open(F_Name.c_str(), ios::in);//, ios::binary );
    // проверка открытия файла
    if (!FileStream)
    {
        cout << "SERVER INFO: Error opening state file '" << F_Name.c_str() << "'" << endl;
        return -1;
    }else
    {
        cout << "SERVER INFO: state file '" << F_Name.c_str() << "' opened" << endl;
    }
    // текущая строка файла
    string line="";
    char linetmp;
    // чтение файла
    linetmp = FileStream.peek();
    //line+=linetmp;
    while(FileStream)
    {
        // чтение файла
        linetmp = FileStream.get();
        line+=linetmp;
        //FileStream >> linetmp;
        
    }
    //debug
    //for (int k=0; k<line.length(); k++) cout << int(line[k]) << " ";
    //cout << endl;
    int tmpint;
    float tmpfloat;
    int cpos=0,cposto=0;
    // запись кол-ва кодов и котировок
    strcpy2(int_char.chars,line.substr(cpos,4).c_str());
    // debug
    //cout << "nSections: " << int_char.number << endl;
    SDB.nSections=int_char.number;
    cpos+=4;
    for (int i=0; i<SDB.nSections; i++)
    {
        // запись длины названий
        strcpy2(int_char.chars,line.substr(cpos,4).c_str());
        cpos+=4;
        cposto=int_char.number;
        // debug
        //cout << "Section["<< i << "]: " << line.substr(cpos,cposto).c_str() << endl;
        SDB.Sections.push_back(line.substr(cpos,cposto).c_str());
        vector<string> tmp;
        SDB.Articles.push_back(tmp);
        cpos+=cposto;
        // запись кол-ва статей
        strcpy2(int_char.chars,line.substr(cpos,4).c_str());
        // debug
        //cout << "nArticles["<< i << "]: " << int_char.number << endl;
        SDB.nArticles.push_back(int_char.number);
        cpos+=4;
        for (int j=0; j<SDB.nArticles[i]; j++)
        {
            // запись длины названий
            strcpy2(int_char.chars,line.substr(cpos,4).c_str());
            cpos+=4;
            cposto=int_char.number;
            // debug
            //cout << "Article["<< i << "][" << j <<"]: " << line.substr(cpos,cposto).c_str() << endl;
            SDB.Articles[i].push_back(line.substr(cpos,cposto).c_str());
            cpos+=cposto;
        }           
    }
    // закрытие файла
    FileStream.close();
    return 0;
}
 
// Сохранение состояния
void SaveState(int sig)
{
    // файловый поток
    fstream FileStream; 
    // имя файла
    string F_Name="Saved.state";    
    // открытие файла
    FileStream.open(F_Name.c_str(), ios::out);
    // проверка открытия файла
    if (!FileStream)
    {
        cout << "SERVER INFO: Error creating state file '" << F_Name.c_str() << "'" << endl;
        exit(0);
    }else
    {
        cout << "SERVER INFO: state file '" << F_Name.c_str() << "' created" << endl;
    }
    // вывод кол-ва разделов
    int_char.number=SDB.nSections;
    for (int k=0; k<4; k++) FileStream << int_char.chars[k];
    for (int i=0; i<SDB.nSections; i++)
    {
        // вывод длины названий
        int_char.number=SDB.Sections[i].length();
        for (int k=0; k<4; k++) FileStream << int_char.chars[k];
        cout << "\nSaving Section["<<i<<"]\n";
        // вывод названий
        for (int j=0; j<SDB.Sections[i].length(); j++)
        {
            cout << SDB.Sections[i][j];
            FileStream << SDB.Sections[i][j];   
        }
        // вывод кол-ва статей
        int_char.number=SDB.nArticles[i];
        for (int k=0; k<4; k++) FileStream << int_char.chars[k];
        for (int j=0; j<SDB.nArticles[i]; j++)
        {
            // вывод длины названий
            int_char.number=SDB.Articles[i][j].length();
            for (int k=0; k<4; k++) FileStream << int_char.chars[k];
            cout << "\nSaving Aricle["<<i<<"][" << j << "]\n";
            // вывод названий
            for (int l=0; l<SDB.Articles[i][j].length(); l++)
            {
                cout << SDB.Articles[i][j][l];
                FileStream << SDB.Articles[i][j][l];    
            }
        }
    }
    // закрытие файла
    FileStream.close();
    exit(0);
}
 
// Нить обработки ввода команд
void * Server_UI(void *n)
{
    // переменная для хранения комманды
    string scommand;
    while(1)
    {
        // Получение введеной команды
        getline(cin,scommand, '\n');
        // Перевод команды из string в char
        for (int i=0; i<20; i++) command[i]=0;
        for (int i=0; i<scommand.length(); i++)
        {
            if (i==20) break;
            command[i]=scommand[i];
        }
        // Обработка команды
        if(scommand=="who") {fwho2();}
        else if(scommand=="kill") {cout << "This command requres argument\n";}
        else if(scommand.find("kill ")!=string::npos && int(scommand.find("kill "))==0) {fkill2();}
        else 
        {
            printf("'%s' is not recognized as internal command\n", command);
            cout << "\nList of avaible commands:" << endl
            << "who - list connected users" << endl
            << "kill - kill user thread" << endl;
        }
    }
}
        
}

17.12.2010, 03:02

Извините не ту версию кода выложил

Server.h

C++

#include <stdio.h>
#include <stdlib.h>
#include <string>
#include <iostream>
#include <fstream>
#include <string.h>
#include <time.h>
#include <signal.h>
#include <sstream>
#include <vector>
#include <netdb.h>
#include <netinet/in.h>
#include <arpa/inet.h>
#include <sys/types.h>
#include <errno.h>
#pragma comment(lib, "ws2_32.lib")
using namespace std;
 
// максимальный размер структурированного пакета
#define SIZE 100
// максимальное число подключенных пользователей
#define MAX_NUMBER_OF_CONNECTIONS 100
 
// Перевод строки в число, с выводом ошибки
template <class T>
bool from_string(T& t, 
                 const std::string& s, 
                 std::ios_base& (*f)(std::ios_base&))
{
  std::istringstream iss(s);
  return !(iss >> f >> t).fail();
}
 
// Ошибки посылаемые в пакетах
#define WRONG_LOGIN_PASS_COMBINATION 1
#define YOU_ARE_NOT_LOGGED_IN 2
#define TOO_MANY_CONNECTIONS 3
#define YOU_HAVE_BEEN_DISCONECTED_BY_SUSER 4
#define NO_SUCH_CODE 101
#define CODE_IS_ALREADY_ADDED 102
#define NO_SUCH_USER 201
#define NOT_ENOUGH_PRIVELEDGE 202
 
// векторы с данными о паролях
vector <string> Login;      
vector <string> Pass;       
vector <int> ilvl;          
 
// Сокет
int s;
// Кол-во принятых или отосланных символов
int rc;
// порт для прослушивания
int port = 27015;
 
 
//Структура в которую записываем структуру содержащую информацию о клиенте
sockaddr_in client_sock_info;
 
int SenderAddrSize = sizeof(client_sock_info);
 
// команда пользователя
char command[20];
 
// Данные о подключении клиента
struct ClientInfo
{
    int iId;            // Уникальный номер клиента
    char cIp[16];       // IP адрес клиента
    int _iPort;         // порт используемый клиентом
    char cLogin[20];    // логин клиента
    char cPass[20];     // пароль клиента  
    int cStatus;        // Уровень доступных комманд
    int iError;         // сообщение об ошибке, либо клиент отключился
    int Section;        // текущий раздел
    int Article;        // текущая статья
    pthread_t targetThreadId;   // Указатель на нить для обработки запросов клиента
    int theArg;             // Аргументы для нити
    int hThrd;          // указатель на нить
    int s;              //информация о сокете
}clntinf[MAX_NUMBER_OF_CONNECTIONS]; 
 
// Работа с функиями отдельно
struct FuncExec
{
// функция вывода списка пользователей
void fwho(int tn);
 
// Смена уровня в системе
void fcd(int tn);
 
// переход на верхний уровень системы
void fup(int tn);
 
// функция добавления
void fadd(int tn);
 
// функция принудительного отключения пользователя
void fkill(int tn);
 
// функция вывода списка 
void fList (int tn);
}object[MAX_NUMBER_OF_CONNECTIONS];
 
// формат даты(времени)
struct date
{
    int day;    // день
    int month;  // месяц
    int year;   // год
}cdate;
 
// формат данных сервера
struct DB
{
    int nSections;          // кол-во разделов
    vector <string> Sections; // имена разделов
    vector <int> nArticles;         // кол-во статей в разделе
    vector <vector<string> > Articles;  // Статьи
}SDB;
 
// объединения для удобной записи/чтения файла
union inttochar
{
    int number;
    char chars[4];  
}int_char;
union inttofloat
{
    float number;
    char chars[4];  
}float_char;
 
 
// Пакет команды login
struct ReceiveLogin
{
    char cCommand[10];  // текущая комманда клиента   
    char cLogin[20];    // логин клиента
    char cPass[20];     // пароль клиента
};
// Ответ на команду login
struct ResponseLogin
{
    char cCommand[10];  // текущая комманда клиента   
    int iError;         // сообщение об ошибке
    int cStatus;        // Уровень доступных комманд 
};
 
// Структура стандартного пакета
struct stdPacket
{
    char cCommand[10];  // текущая комманда клиента
    int iError;         // сообщение об ошибке
};
 
// Структура пакета list
struct ReceiveLIST
{
    char cCommand[10];  // текущая комманда клиента
};
 
// Структура ответного пакета list
struct ResponseLIST
{
    char cLength[10];   // длина ответного пакета
    int iError;         // сообщение об ошибке
};
 
// Структура пакета up
struct ReceiveUP
{
    char cCommand[10];  // текущая комманда клиента
};
 
// Структура ответного пакета up
struct ResponseUP
{
    char cCommand[10];  // текущая комманда клиента
    int iError;         // сообщение об ошибке
};
 
// Структура пакета add
struct ReceiveADD
{
    char cCommand[10];  // текущая комманда клиента
    int length;         // длина пакета
};
 
// Структура ответного пакета add
struct ResponseADD
{
    char cCommand[10];  // текущая комманда клиента
    int iError;         // сообщение об ошибке
};
 
// Структура пакета del
struct ReceiveDEL
{
    char cCommand[10];  // текущая комманда клиента
    int code;           // код удаляемой 
};
 
// Структура пакета cd
struct ReceiveCD
{
    char cCommand[10];  // текущая комманда клиента
    int code;           // код раздела
};
 
// Структура ответного пакета cd
struct ResponseCD
{
    char cCommand[10];  // текущая комманда клиента
    int iError;         // сообщение об ошибке
    int Section;        // раздел
    int Article;        // статья
    char clvl[50];          // текущий уровень в системе в виде текста
};
 
// Структура пакета logout
struct ReceiveLogout
{
    char cCommand[10];  // текущая комманда клиента
};
 
// Структура пакета who
struct ReceiveWho
{
    char cCommand[10];  // текущая комманда клиента
};
 
// Структура ответного пакета who
struct ResponseWho
{
    char cLength[10];   // длина ответного пакета
    int iError;         // сообщение об ошибке
};
 
// Структура ответного пакета kill
struct ReceiveKill
{
    char cCommand[10];  // текущая комманда клиента
    int uID;            // Номер пользователя
};
 
// Структура ответного пакета kill
struct ResponseKill
{
    char cCommand[10];  // текущая комманда клиента
    int iError;         // сообщение об ошибке
};
 
// Посылка пакета производится в виде массива символов, независимо от типа пакета
union PacketFormat
{
    struct ReceiveLogin login_in;
    struct ResponseLogin login_out;
    struct stdPacket std_command;
    struct ReceiveLIST list_in;
    struct ResponseLIST list_out;
    struct ReceiveUP up_in;
    struct ResponseUP up_out;
    struct ReceiveADD add_in;
    struct ResponseADD add_out;
    struct ReceiveCD cd_in;
    struct ResponseCD cd_out;
    struct ReceiveLogout logout_in;
    struct ReceiveWho who_in;
    struct ResponseWho who_out;
    struct ReceiveKill kill_in;
    struct ResponseKill kill_out;
    char un[SIZE];  
}unSnd;
 
// Информация хранящаяся на сервере
struct SrvStatus
{
    // кол-во клиентов
    int numberofclients;
    // наибольший ID
    int lastid;
    // информация о клиентах
    struct ClientInfo InfoForClients[MAX_NUMBER_OF_CONNECTIONS];
    // Принятый пакет для обработки нитью
    union PacketFormat msg[MAX_NUMBER_OF_CONNECTIONS];
    // Буфер сообщения
    string l_buf_send[MAX_NUMBER_OF_CONNECTIONS];
}ServStatus;
 
// Посылка строки
int lsendto(int s, int tn, int flags);
 
// Нить обработки клиентских запросов
void * Handle_Client_Requests(void *n);
 
 
 
//----
// Функция аутентификации
int fLogin (int tn);
 
// функция отключения пользователя
int flogout(int tn);
 
// Функция вывода cтруктурированного пакета
void print(int tn);
// Чтение файла настроек
int ReadIniFile();
 
// Чтение состояния
int ReadSavedState();
 
// Сохранение состояния
void SaveState(int sig);
 
// Копирование строки даже при появлении символа 0
void strcpy2(char * Dest, const char * Source)
{
    for (int i=0; i<sizeof(Dest); i++)
    {
        Dest[i]=Source[i];
    }
}
 
// Нить обработки ввода команд
void * Server_UI(void *n);
 
// функция вывода списка пользователей для сервера
void fwho2();
 
// функция принудительного отключения пользователя для сервера
int fkill2();

Server.c

C++

#include "tcp_server.h"
 
 
// Главная функция программы
int main(void)
{
    // Кол-во подключенных клиентов
    ServStatus.numberofclients = 0;
    ServStatus.lastid = 0;
    for (int i=0; i<MAX_NUMBER_OF_CONNECTIONS; i++) ServStatus.InfoForClients[i].iError=1;
    SDB.nSections=0;
    
    // Чтение файла паролей
    if (ReadIniFile() < 0)
    {
        return 0;
    }else
    {
        printf("SERVER INFO: Successfully read ini file\n");
    }
 
    // Чтение состояния
    if (ReadSavedState() < 0)
    {
        printf("SERVER INFO: Failed to load previos state\n");
    }
 
    // Обработка выхода с сохранением состояния
    signal(SIGABRT, &SaveState);
    signal(SIGTERM, &SaveState);
    signal(SIGINT, &SaveState);
 
    // Создание соединения
    /*WSADATA wsaData;
    WSAStartup(MAKEWORD(2,2), &wsaData);*/
    sockaddr_in local;
    
    local.sin_family = AF_INET;
    local.sin_port = htons ( port ) ;
    local.sin_addr.s_addr = htonl ( INADDR_ANY );
    
    // Создание сокета
    s = socket ( AF_INET, SOCK_STREAM, 0 );
    if ( s < 0 )
    {
        //printf("SERVER INFO: Error at socket(): %ld\n", WSAGetLastError());
        perror("SERVER INFO: Error at socket()");
        //WSACleanup();
        return 0;
    }
 
    // Прослушивание порта
    if (bind( s, (sockaddr*) &local, sizeof(local)) == -1)
    {
        printf("SERVER INFO: bind() failed.\n");
        close(s);
        return 0;
    }
    else cout<<"SERVER INFO: bind() ok\n";
 
    if ( listen( s, 5 ) )
    {
        perror ( "SERVER INFO: listen failed\n" );
        return  0 ;
    }
    else printf("SERVER INFO: listen() ok\n");
 
    // Создание нити для получения уведомления об отключении
    pthread_t targetThreadId2;
    int theArg2=101;
    if( pthread_create(&targetThreadId2, NULL, Server_UI, (void *) theArg2) != 0 )
    {
        cout<<"INFO: Error CreateThread: "<<endl;
        return -1;
    }
    
    
    // Обработка пришедших пакетов
    while(1)
    {
        // Принятие соединения и передача его на обработку нити
        int tmps = accept( s, NULL, NULL );
        if ( tmps < 0 ){
            //cout<<"SERVER INFO: Error accept connection: "<<WSAGetLastError()<<endl;
            perror("SERVER INFO: Error accept connection");
        }else
        {
            cout << "SERVER INFO: Connection accepted, socket=" << tmps << "\n";
        }
        // уникальный номер клиента
        clntinf[MAX_NUMBER_OF_CONNECTIONS].iId = ServStatus.lastid;
        // Получение номера нити
        // получаем номер свободного слота
        int emptyslot=MAX_NUMBER_OF_CONNECTIONS;
        // Если никто не отключался, то нумерация от 0
        if ( ServStatus.lastid == ServStatus.numberofclients)
        {
            emptyslot=ServStatus.numberofclients; 
        }else
        // если кто-то отключился, то записываем информацию в свободный слот
        {
            for (int j=0; j<MAX_NUMBER_OF_CONNECTIONS; j++)
            {
                if (ServStatus.InfoForClients[j].iError > 0)
                {
                    emptyslot=j;
                    break;
                }
            }
        }
        if (emptyslot==MAX_NUMBER_OF_CONNECTIONS)
        {
            cout<<"SERVER INFO: Thread limit reached, can't handle anymore users\n";
            // Посылка ответа
            rc = shutdown(tmps, SHUT_RDWR);
            if ( rc < 0 ){
                //cout<<"SERVER INFO: Error shuting down socket: "<< WSAGetLastError() << endl;
                perror("SERVER INFO: Error shuting down socket");   
            }else
            {
                cout<<"SERVER INFO: socket shutdowned, RC="<< rc << endl;
            }
            rc = close(tmps);
            if ( rc < 0 ){
                //cout<<"SERVER INFO: Error closing socket: "<< WSAGetLastError() << endl;
                perror("SERVER INFO: Error closing socket");
            }else
            {
                cout<<"SERVER INFO: socket closed, RC="<< rc << endl;
            }
            continue;
        }
 
        // Создаем нить для обработки запросов клиента
        pthread_t targetThreadId;
        int theArg=emptyslot;
        int hThrd=0;
        int *pArg = new int;
        *pArg = theArg;
        hThrd=pthread_create(&targetThreadId, NULL, Handle_Client_Requests, (void *) pArg);
        if( hThrd != 0 )
        {
            cout<<"SERVER INFO: Error CreateThread for client requests: " << endl;//<<GetLastError()<<endl;
            return -1;
        }
        clntinf[MAX_NUMBER_OF_CONNECTIONS].targetThreadId=targetThreadId;
        clntinf[MAX_NUMBER_OF_CONNECTIONS].theArg=theArg;
        clntinf[MAX_NUMBER_OF_CONNECTIONS].hThrd=hThrd;
        clntinf[MAX_NUMBER_OF_CONNECTIONS].s=tmps;
        clntinf[MAX_NUMBER_OF_CONNECTIONS].iError=0;
        clntinf[MAX_NUMBER_OF_CONNECTIONS].Article=0;
        clntinf[MAX_NUMBER_OF_CONNECTIONS].Section=0;
        
        // заполняем базу клиентов
        ServStatus.InfoForClients[emptyslot] = clntinf[MAX_NUMBER_OF_CONNECTIONS];
 
        /// Увеличиваем кол-во подключенных клиентов и идентификатор
        ServStatus.numberofclients++;
        ServStatus.lastid++;
    }
    // Выход
    close(s);
    printf("Exiting.\n");
    //WSACleanup();
    return 0;
}
 
// Нить обработки клиентских запросов
void * Handle_Client_Requests(void *n)
{ 
     int *parg = (int*) n;
     
     int arg = *parg;
     printf("arg %i",arg);
     delete parg;
    
    sleep(1);
    // Номер нити
    int TNumber = arg;
    //FuncExec object;
    // Вывод сообщения о запуске нити
    cout<<"SERVER INFO: Thread Number " << TNumber << " started to handle requests for socket '" << ServStatus.InfoForClients[TNumber].s << "'" <<endl;
    // Ждем сообщение
    while ( 1 )
    {
        // Обработка входящих пакетов
        int trc = recv( ServStatus.InfoForClients[TNumber].s, ServStatus.msg[TNumber].un, SIZE, 0 );
        if ( trc < 0 ){
            // Обработка ECONRESET
            int err=errno;
            if (err==ECONNRESET)//ECONNRESET=54
            {
                // завершение работы нити
                cout<<"SERVER INFO: ECONNRESET: Connection reset by peer" <<endl;
                cout << "SERVER INFO: Thread Number " << TNumber << " exiting..." << endl;
                trc = shutdown(ServStatus.InfoForClients[TNumber].s, SHUT_RDWR);
                if ( trc < 0 ){
                    cout<<"SERVER INFO: Error shuting down socket: "<< errno << endl;   
                }else
                {
                    cout<<"SERVER INFO: socket shutdowned" << endl;
                }
                trc = close(ServStatus.InfoForClients[TNumber].s);
                if ( trc < 0 ){
                    cout<<"SERVER INFO: Error closing socket: "<< errno << endl;    
                }else
                {
                    cout<<"SERVER INFO: socket closed" << endl;
                }
                ServStatus.numberofclients--;
                ServStatus.InfoForClients[TNumber].iError=1;
                return 0;
            }else if (err==ENOTSOCK)//ENOTSOCK=38
            {
                // завершение работы нити при дисконекте другой нитью
                cout << "SERVER INFO: Thread Number " << TNumber << " exiting..." << endl;
                return 0;
            }else
            {
                cout<<"SERVER INFO: Error receiving packet: "<<errno<<endl;
                cout << "SERVER INFO: Thread Number " << TNumber << " exiting..." << endl;
                return 0;
            }
        }else if (trc == 0)
        {
            cout << "SERVER INFO: Thread Number " << TNumber << " exiting..." << endl;
            return 0;
        }else
        {
            cout << "SERVER INFO: Packet received, RC=" << trc << "\n";
        }
        cout<<"SERVER INFO: Thread Number " << TNumber << " processing '"<< ServStatus.msg[TNumber].std_command.cCommand << "' command for socket '" << ServStatus.InfoForClients[TNumber].s << "', UserID=" << ServStatus.InfoForClients[TNumber].iId <<endl;
        //print(TNumber);
        if(!strcmp(ServStatus.msg[TNumber].std_command.cCommand,"list"))        object[TNumber].fList(TNumber);
        else if(!strcmp(ServStatus.msg[TNumber].std_command.cCommand,"login"))  
        {
            if (fLogin(TNumber) != 0)
            {
                // завершение работы нити при неудачной аутенфикации
                cout << "SERVER INFO: Thread Number " << TNumber << " exiting..." << endl;
                ServStatus.numberofclients--;
                ServStatus.InfoForClients[TNumber].iError=1;
                return 0;
            }
        }
        else if(!strcmp(ServStatus.msg[TNumber].std_command.cCommand,"logout")) 
        {
            flogout(TNumber);
            // завершение работы нити
            cout << "SERVER INFO: Thread Number " << TNumber << " exiting..." << endl;
            return 0;
        }
        else if(!strcmp(ServStatus.msg[TNumber].std_command.cCommand,"who"))        object[TNumber].fwho(TNumber);
        else if(!strcmp(ServStatus.msg[TNumber].std_command.cCommand,"cd"))         object[TNumber].fcd(TNumber);
        else if(!strcmp(ServStatus.msg[TNumber].std_command.cCommand,"up"))         object[TNumber].fup(TNumber);
        else if(!strcmp(ServStatus.msg[TNumber].std_command.cCommand,"add"))        object[TNumber].fadd(TNumber);
        else if(!strcmp(ServStatus.msg[TNumber].std_command.cCommand,"kill"))       object[TNumber].fkill(TNumber);
        else {cout << "SERVER INFO: received unknown command '" << ServStatus.msg[TNumber].std_command.cCommand << "'" << endl;}
    }
    
    return(0);
}
 
// функция вывода списка
void FuncExec :: fList (int tn)
{
    cout << "SERVER INFO: processing list command"<< endl;
 
    // Буфер для сообщения
    char  buf_send[400];
    ServStatus.l_buf_send[tn]="";
    
    if (ServStatus.InfoForClients[tn].Section==0)
    {
        // Вывод разделов
        if (SDB.nSections==0)
        {
            sprintf(buf_send, "There is no sections on the server\n");
            ServStatus.l_buf_send[tn]+=buf_send;
        }else
        {
            sprintf(buf_send, "Sections:\n");
            ServStatus.l_buf_send[tn]+=buf_send;
            for (int i=0; i<SDB.nSections; i++)
            {
                sprintf(buf_send, "%d\t%s\n", i+1, SDB.Sections[i].c_str());
                ServStatus.l_buf_send[tn]+=buf_send;
            }
        }
    }else
    {
        if (ServStatus.InfoForClients[tn].Section>SDB.nSections)
        {
            sprintf(buf_send, "Current section no longer exists on the server\n");
            ServStatus.l_buf_send[tn]+=buf_send;
        }else
        {
            if (ServStatus.InfoForClients[tn].Article==0)
            {
                sprintf(buf_send, "%s Section:\n", SDB.Sections[ServStatus.InfoForClients[tn].Section-1].c_str());
                ServStatus.l_buf_send[tn]+=buf_send;
                if (SDB.nArticles[ServStatus.InfoForClients[tn].Section-1]==0)
                {
                    sprintf(buf_send, "There are no section\n");
                    ServStatus.l_buf_send[tn]+=buf_send;
                }
                for (int i=0; i<SDB.nArticles[ServStatus.InfoForClients[tn].Section-1]; i++)
                {
                    string tmp1="", tmp2="";
                    int sep1=-1,sep2=-1;
                    for (int j=0; j<SDB.Articles[ServStatus.InfoForClients[tn].Section-1][i].length(); j++)
                    {
                        if ( SDB.Articles[ServStatus.InfoForClients[tn].Section-1][i][j] == 30 )
                        {
                            sep1=j;
                            break;
                        }
                        tmp1+=SDB.Articles[ServStatus.InfoForClients[tn].Section-1][i][j];
                    }
                    for (int j=sep1+1; j<SDB.Articles[ServStatus.InfoForClients[tn].Section-1][i].length(); j++)
                    {
                        if ( SDB.Articles[ServStatus.InfoForClients[tn].Section-1][i][j] == 30 )
                        {
                            sep2=j;
                            break;
                        }
                        tmp2+=SDB.Articles[ServStatus.InfoForClients[tn].Section-1][i][j];
                    }
                    sprintf(buf_send, "%d\t%s\n",i+1, tmp1.c_str());
                    ServStatus.l_buf_send[tn]+=buf_send;
                }
            }else
            {
                if (ServStatus.InfoForClients[tn].Article>SDB.nArticles[ServStatus.InfoForClients[tn].Section-1])
                {
                    sprintf(buf_send, "Current article no longer exists on the server\n");
                    ServStatus.l_buf_send[tn]+=buf_send;
                }else
                {
                    string tmp1="", tmp2="", tmp3="";
                    int sep1=-1,sep2=-1;
                    for (int j=0; j<SDB.Articles[ServStatus.InfoForClients[tn].Section-1][ServStatus.InfoForClients[tn].Article-1].length(); j++)
                    {                       
                        if ( SDB.Articles[ServStatus.InfoForClients[tn].Section-1][ServStatus.InfoForClients[tn].Article-1][j] == 30 )
                        {
                            sep1=j;                         
                            break;
                        }
                        tmp1+=SDB.Articles[ServStatus.InfoForClients[tn].Section-1][ServStatus.InfoForClients[tn].Article-1][j];
                    }
                    for (int j=sep1+1; j<SDB.Articles[ServStatus.InfoForClients[tn].Section-1][ServStatus.InfoForClients[tn].Article-1].length(); j++)
                    {
                        if ( SDB.Articles[ServStatus.InfoForClients[tn].Section-1][ServStatus.InfoForClients[tn].Article-1][j] == 30 )
                        {
                            sep2=j;
                            break;
                        }
                        tmp2+=SDB.Articles[ServStatus.InfoForClients[tn].Section-1][ServStatus.InfoForClients[tn].Article-1][j];
                    }
                    for (int j=sep2+1; j<SDB.Articles[ServStatus.InfoForClients[tn].Section-1][ServStatus.InfoForClients[tn].Article-1].length(); j++)
                    {
                        tmp3+=SDB.Articles[ServStatus.InfoForClients[tn].Section-1][ServStatus.InfoForClients[tn].Article-1][j];
                    }
                    int i=0;
                    sprintf(buf_send, "%d\t%s\n",i+1, tmp1.c_str());
                    ServStatus.l_buf_send[tn]+=buf_send;
                }
 
            }
        }
    }
    printf ("List 1 = %d",ServStatus.InfoForClients[tn].s);
    // Посылаем строку
     lsendto(ServStatus.InfoForClients[tn].s,tn,0); 
    printf ("List 2 = %d",ServStatus.InfoForClients[tn].s);
}
 
// функция добавления
void FuncExec :: fadd(int tn)
{
    // Проверка статуса клиента
    if (ServStatus.InfoForClients[tn].cStatus < 4)
    {
        int length=ServStatus.msg[tn].add_in.length;
        char *buf_recv;
        buf_recv=new char[length];
        // Обработка входящих пакетов
        int trc = recv( ServStatus.InfoForClients[tn].s, buf_recv, length, 0 );
        if ( trc < 0 ){
            cout << "SERVER INFO: Add command had't receive text: " <<errno<<endl;
        }
        if (ServStatus.InfoForClients[tn].Section==0)
        {           
            string finalstring="";
            for (int i=0; i<length; i++) finalstring+=buf_recv[i];
            cout << "SERVER INFO: adding Section with name='" << finalstring <<"', length='" << length << "'\n";
            // добавление раздела
            SDB.Sections.push_back(finalstring);
            SDB.nSections++;
            vector<string> tmp;
            SDB.Articles.push_back(tmp);
            SDB.nArticles.push_back(0);
            // формирование пакета с ответом
            // очистка пакета от мусора
            for (int i=0; i<SIZE; i++) ServStatus.msg[tn].un[i]=0;
            strcpy(ServStatus.msg[tn].kill_out.cCommand,"add");
            ServStatus.msg[tn].kill_out.iError=0;
            // Посылка ответа на команду add
            rc = send(ServStatus.InfoForClients[tn].s,ServStatus.msg[tn].un,SIZE,0);
            if ( rc < 0 ){
                cout<<"SERVER INFO: Error sending add response: "<<errno<<endl;
            }
            else
            {
                cout << "SERVER INFO: Sent add response, RC=" << rc << endl;
            }       
        }else
        {
            string finalstring="";
            for (int i=0; i<length; i++) finalstring+=buf_recv[i];
            cout << "SERVER INFO: adding Article='" << finalstring <<"', length='" << length << "'\n";
            // добавление подраздела
            SDB.Articles[ServStatus.InfoForClients[tn].Section-1].push_back(finalstring);
            SDB.nArticles[ServStatus.InfoForClients[tn].Section-1]++;
            // формирование пакета с ответом
            // очистка пакета от мусора
            for (int i=0; i<SIZE; i++) ServStatus.msg[tn].un[i]=0;
            strcpy(ServStatus.msg[tn].kill_out.cCommand,"add");
            ServStatus.msg[tn].kill_out.iError=0;
            // Посылка ответа на команду add
            rc = send(ServStatus.InfoForClients[tn].s,ServStatus.msg[tn].un,SIZE,0);
            if ( rc < 0 ){
                cout<<"SERVER INFO: Error sending add response: "<<errno<<endl;
            }
            else
            {
                cout << "SERVER INFO: Sent add response, RC=" << rc << endl;
            }
        }
    }else
    {
        // формирование пакета с ошибкой
        // очистка пакета от мусора
        for (int i=0; i<SIZE; i++) ServStatus.msg[tn].un[i]=0;
        strcpy(ServStatus.msg[tn].kill_out.cCommand,"add");
        ServStatus.msg[tn].kill_out.iError=NOT_ENOUGH_PRIVELEDGE;
        // Посылка ответа на команду add
        rc = send(ServStatus.InfoForClients[tn].s,ServStatus.msg[tn].un,SIZE,0);
        if ( rc < 0 ){
            cout<<"SERVER INFO: Error sending NOT_ENOUGH_PRIVELEDGE Notification: "<<errno<<endl;
        }
        else
        {
            cout << "SERVER INFO: Sent NOT_ENOUGH_PRIVELEDGE Notification, RC=" << rc << endl;
        }
    }
}
 
// функция Смены уровня в системе
void FuncExec :: fcd(int tn)
{
 
    if (ServStatus.InfoForClients[tn].Section==0)
    {
        // если раздела/подоаздела нет - посылаем ошибку
        if (ServStatus.msg[tn].cd_in.code>SDB.nSections || ServStatus.msg[tn].cd_in.code == 0)
        {
            // формирование пакета с ошибкой
            // очистка пакета от мусора
            for (int i=0; i<SIZE; i++) ServStatus.msg[tn].un[i]=0;
            strcpy(ServStatus.msg[tn].kill_out.cCommand,"del");
            ServStatus.msg[tn].kill_out.iError=NO_SUCH_CODE;
            // Посылка ответа на команду del
            rc = send(ServStatus.InfoForClients[tn].s,ServStatus.msg[tn].un,SIZE,0);
            if ( rc < 0 ){
                cout<<"SERVER INFO: Error sending NO_SUCH_CODE Notification: "<<errno<<endl;
            }
            else
            {
                cout << "SERVER INFO: Sent NO_SUCH_CODE Notification, RC=" << rc << endl;
            }
        }
        // раздел найден
        else
        {
            // переходим в раздел
            ServStatus.InfoForClients[tn].Section=ServStatus.msg[tn].cd_in.code;
            // формирование пакета с ответом
            // очистка пакета от мусора
            for (int i=0; i<SIZE; i++) ServStatus.msg[tn].un[i]=0;
            strcpy(ServStatus.msg[tn].kill_out.cCommand,"пїЅпїЅ");
            ServStatus.msg[tn].kill_out.iError=0;
            ServStatus.msg[tn].cd_out.Section=ServStatus.InfoForClients[tn].Section;
            ServStatus.msg[tn].cd_out.Article=0;
            char tmp[50];
            strcpy(tmp,"root-");
            strcat(tmp,SDB.Sections[ServStatus.InfoForClients[tn].Section-1].c_str());
            strcpy(ServStatus.msg[tn].cd_out.clvl,tmp);
            // Посылка ответа на команду cd
            rc = send(ServStatus.InfoForClients[tn].s,ServStatus.msg[tn].un,SIZE,0);
            if ( rc < 0 ){
                cout<<"SERVER INFO: Error sending add response: "<<errno<<endl;
            }
            else
            {
                cout << "SERVER INFO: Sent add response, RC=" << rc << endl;
            }       
        }
    }else
    {
        // если раздела/подоаздела нет - посылаем ошибку
        if (ServStatus.msg[tn].cd_in.code>SDB.nArticles[ServStatus.InfoForClients[tn].Section-1] || ServStatus.msg[tn].cd_in.code == 0)
        {
            // формирование пакета с ошибкой
            // очистка пакета от мусора
            for (int i=0; i<SIZE; i++) ServStatus.msg[tn].un[i]=0;
            strcpy(ServStatus.msg[tn].kill_out.cCommand,"del");
            ServStatus.msg[tn].kill_out.iError=NO_SUCH_CODE;
            // Посылка ответа на команду del
            rc = send(ServStatus.InfoForClients[tn].s,ServStatus.msg[tn].un,SIZE,0);
            if ( rc < 0 ){
                cout<<"SERVER INFO: Error sending NO_SUCH_CODE Notification: "<<errno<<endl;
            }
            else
            {
                cout << "SERVER INFO: Sent NO_SUCH_CODE Notification, RC=" << rc << endl;
            }
        }
        // раздел найден
        else
        {
            // переходим в раздел
            ServStatus.InfoForClients[tn].Article=ServStatus.msg[tn].cd_in.code;
            // формирование пакета с ответом
            // очистка пакета от мусора
            for (int i=0; i<SIZE; i++) ServStatus.msg[tn].un[i]=0;
            strcpy(ServStatus.msg[tn].kill_out.cCommand,"пїЅпїЅ");
            ServStatus.msg[tn].kill_out.iError=0;
            ServStatus.msg[tn].cd_out.Section=ServStatus.InfoForClients[tn].Section;
            ServStatus.msg[tn].cd_out.Article=ServStatus.InfoForClients[tn].Article;
            char tmp[50];
            strcpy(tmp,"root-");
            strcat(tmp,SDB.Sections[ServStatus.InfoForClients[tn].Section-1].c_str());
            strcat(tmp,"-");
            string tmp2;
            string tmp1="";
            int sep1=-1;
            for (int j=0; j<SDB.Articles[ServStatus.InfoForClients[tn].Section-1][ServStatus.InfoForClients[tn].Article-1].length(); j++)
            {                       
                if ( SDB.Articles[ServStatus.InfoForClients[tn].Section-1][ServStatus.InfoForClients[tn].Article-1][j] == 30 )
                {
                    sep1=j;                         
                    break;
                }
                tmp1+=SDB.Articles[ServStatus.InfoForClients[tn].Section-1][ServStatus.InfoForClients[tn].Article-1][j];
            }
            strcat(tmp,tmp1.c_str());
            strcpy(ServStatus.msg[tn].cd_out.clvl,tmp);
            // Посылка ответа на команду cd
            rc = send(ServStatus.InfoForClients[tn].s,ServStatus.msg[tn].un,SIZE,0);
            if ( rc < 0 ){
                cout<<"SERVER INFO: Error sending add response: "<<errno<<endl;
            }
            else
            {
                cout << "SERVER INFO: Sent add response, RC=" << rc << endl;
            }       
        }
    }
}
 
// функция Смены уровня в системе
void FuncExec ::  fup(int tn)
{
sleep(15);
    // переходим в корневой раздел
    ServStatus.InfoForClients[tn].Section=0;
    ServStatus.InfoForClients[tn].Article=0;
 
    // формирование пакета с ответом
    // очистка пакета от мусора
    for (int i=0; i<SIZE; i++) ServStatus.msg[tn].un[i]=0;
    strcpy(ServStatus.msg[tn].kill_out.cCommand,"up");
    ServStatus.msg[tn].kill_out.iError=0;
    // Посылка ответа на команду up
    rc = send(ServStatus.InfoForClients[tn].s,ServStatus.msg[tn].un,SIZE,0);
    if ( rc < 0 ){
        cout<<"SERVER INFO: Error sending add response: "<<errno<<endl;
    }
    else
    {
        cout << "SERVER INFO: Sent add response, RC=" << rc << endl;
    }
}
 
// функция отключения пользователя
int flogout(int tn)
{
    // Запись информации о том, что ячейка памяти более не используется
    ServStatus.InfoForClients[tn].iError=1;
    ServStatus.numberofclients--;
    // закрытие сокета
    int trc = shutdown(ServStatus.InfoForClients[tn].s, SHUT_RDWR);
    if ( trc < 0 ){
        cout<<"SERVER INFO: Error shuting down socket: "<< errno << endl;   
    }else
    {
        cout<<"SERVER INFO: socket shutdowned" << endl;
    }
    trc = close(ServStatus.InfoForClients[tn].s);
    if ( trc < 0 ){
        cout<<"SERVER INFO: Error closing socket: "<< errno << endl;    
    }else
    {
        cout<<"SERVER INFO: socket closed" << endl;
    }
    // завершение работы нити
    return 1;
}
 
// функция принудительного отключения пользователя
void FuncExec :: fkill(int tn)
{
    // Проверка статуса клиента
    if (ServStatus.InfoForClients[tn].cStatus < 3)
    {
        int ID=MAX_NUMBER_OF_CONNECTIONS;
        // Поиск указанного клиента
        for (int i=0; i<MAX_NUMBER_OF_CONNECTIONS; i++)
        {
            if (ServStatus.InfoForClients[i].iError==0 && ServStatus.msg[tn].kill_in.uID==ServStatus.InfoForClients[i].iId)
            {
                ID=i;
                break;
            }
        }
        // клиент не найден
        if (ID==MAX_NUMBER_OF_CONNECTIONS)
        {
            // формирование пакета с ошибкой
            // очистка пакета от мусора
            for (int i=0; i<SIZE; i++) ServStatus.msg[tn].un[i]=0;
            strcpy(ServStatus.msg[tn].kill_out.cCommand,"kill");
            ServStatus.msg[tn].kill_out.iError=NO_SUCH_USER;
            // Посылка ответа на команду kill
            rc = send(ServStatus.InfoForClients[tn].s,ServStatus.msg[tn].un,SIZE,0);
            if ( rc < 0 ){
                cout<<"SERVER INFO: Error sending NO_SUCH_USER Notification: "<<errno<<endl;
            }
            else
            {
                cout << "SERVER INFO: Sent NO_SUCH_USER Notification, RC=" << rc << endl;
            }
 
        }
        //клиент найден
        else
        {
                        // Адрес отключенного клиента
            /*sockaddr_in client_sock_info3;
            client_sock_info3.sin_addr.s_addr = inet_addr(ServStatus.InfoForClients[ID].cIp);
            client_sock_info3.sin_port = ServStatus.InfoForClients[ID]._iPort;*/
 
            // Запись информации о том, что ячейка памяти более не используется
            ServStatus.InfoForClients[ID].iError=1;
            ServStatus.numberofclients--;           
            // формирование пакета с ответом
            // очистка пакета от мусора
            for (int i=0; i<SIZE; i++) ServStatus.msg[tn].un[i]=0;
            strcpy(ServStatus.msg[tn].kill_out.cCommand,"kill");
            ServStatus.msg[tn].kill_out.iError=0;
            // Посылка ответа на команду kill
            rc = send(ServStatus.InfoForClients[tn].s,ServStatus.msg[tn].un,SIZE,0);
            if ( rc < 0 ){
                cout<<"SERVER INFO: Error sending kill response: "<<errno<<endl;
            }
            else
            {
                cout << "SERVER INFO: Sent kill response, RC=" << rc << endl;
            }
            // формирование пакета с уведомлением об отключении
            // очистка пакета от мусора
            for (int i=0; i<SIZE; i++) ServStatus.msg[tn].un[i]=0;
            strcpy(ServStatus.msg[tn].kill_out.cCommand,"kill");
            ServStatus.msg[tn].kill_out.iError=YOU_HAVE_BEEN_DISCONECTED_BY_SUSER;
            // Посылка уведомления отключенному клиенту
            rc = send(ServStatus.InfoForClients[ID].s,ServStatus.msg[tn].un,SIZE,0);
            if ( rc < 0 ){
                cout<<"SERVER INFO: Error sending YOU_HAVE_BEEN_DISCONECTED_BY_SUSER Notification: "<<errno<<endl;
            }
            else
            {
                cout << "SERVER INFO: Sent YOU_HAVE_BEEN_DISCONECTED_BY_SUSER Notification, RC=" << rc << endl;
            }
            // закрытие сокета
            int trc = shutdown(ServStatus.InfoForClients[ID].s, SHUT_RDWR);
            if ( trc < 0 ){
                cout<<"SERVER INFO: Error shuting down socket: "<< errno << endl;   
            }else
            {
                cout<<"SERVER INFO: socket shutdowned" << endl;
            }
            trc = close(ServStatus.InfoForClients[ID].s);
            if ( trc < 0 ){
                cout<<"SERVER INFO: Error closing socket: "<< errno << endl;    
            }else
            {
                cout<<"SERVER INFO: socket closed" << endl;
            }
 
 
        }       
    }else
    {
        // формирование пакета с ошибкой
        // очистка пакета от мусора
        for (int i=0; i<SIZE; i++) ServStatus.msg[tn].un[i]=0;
        strcpy(ServStatus.msg[tn].kill_out.cCommand,"kill");
        ServStatus.msg[tn].kill_out.iError=NOT_ENOUGH_PRIVELEDGE;
        // Посылка ответа на команду kill
        rc = send(ServStatus.InfoForClients[tn].s,ServStatus.msg[tn].un,SIZE,0);
        if ( rc < 0 ){
            cout<<"SERVER INFO: Error sending NOT_ENOUGH_PRIVELEDGE Notification: "<<errno<<endl;
        }
        else
        {
            cout << "SERVER INFO: Sent NOT_ENOUGH_PRIVELEDGE Notification, RC=" << rc << endl;
        }
    }
}
 
// функция вывода списка пользователей
void FuncExec :: fwho(int tn)
{
    cout << "SERVER INFO: processing who command"<< endl;
    // Буфер для сообщения
    char  buf_send[400];
    ServStatus.l_buf_send[tn]="";
    //sleep(15);
    sprintf(buf_send, "UserID\tUserName\n");
    ServStatus.l_buf_send[tn]+=buf_send;
    for (int i=0; i<MAX_NUMBER_OF_CONNECTIONS; i++)
    {
        if (ServStatus.InfoForClients[i].iError==0)
        {
            sprintf(buf_send,"%6d\t%-8s\n",ServStatus.InfoForClients[i].iId, ServStatus.InfoForClients[i].cLogin);
            ServStatus.l_buf_send[tn]+=buf_send;
        }
    }
 
    // Посылаем строку
    printf ("Who 1 = %d",ServStatus.InfoForClients[tn].s); 
    lsendto(clntinf[MAX_NUMBER_OF_CONNECTIONS].s,tn,0);
    //sleep(15);
    printf ("who 2 = %d",ServStatus.InfoForClients[tn].s);
}
 
// Посылка строки
int lsendto(int s, int tn, int flags)
{
    // Получение длины получившейся строки
    int messagelength=ServStatus.l_buf_send[tn].length();
    // Запись длины в буфер
    char str_messagelength[10];
    sprintf(str_messagelength,"%d",messagelength);
    // формирование пакета с длиной
    // очистка пакета от мусора
    for (int i=0; i<SIZE; i++) ServStatus.msg[tn].un[i]=0;
    strcpy(ServStatus.msg[tn].list_out.cLength,str_messagelength);
    // ошибок нету
    ServStatus.msg[tn].list_out.iError=0;   
    // Посылка длины нашего сообщения клиентскому приложению
    rc = send(ServStatus.InfoForClients[tn].s,ServStatus.msg[tn].un,SIZE,flags);
    if ( rc < 0 ){
        cout<<"SERVER INFO: Error sending packet length: "<<errno<<endl;
    }
    else
    {
        cout << "SERVER INFO: Sent packet length(" << str_messagelength << "), RC=" << rc << endl;
    }
    // Посылка сообщения
    rc = send(ServStatus.InfoForClients[tn].s,ServStatus.l_buf_send[tn].c_str(),messagelength,flags);
    if ( rc < 0 ){
        cout<<"SERVER INFO: Error sending long packet: "<<errno<<endl;
    }
    else
    {
        cout << "SERVER INFO: Sent long packet, RC=" << rc << endl;
    }
    return rc;  
}
 
// Функция аутентификации
int fLogin (int tn) 
{
    // Тип нашей команды
    char tmpcommand[10]="login";
    // проверяем наличие комбинации пользователь-пароль
    for(int i=0;i<int(Login.size());i++)
    {
        if ((!strcmp(ServStatus.msg[tn].login_in.cLogin,Login[i].c_str()))&&(!strcmp(ServStatus.msg[tn].login_in.cPass,Pass[i].c_str())))
        {
            // Заполняем данные о клиенте, IP и порт уже записаны
            // Записываем статус клиента
            ServStatus.InfoForClients[tn].cStatus=ilvl[i];
            // Логин клиента
            strcpy(ServStatus.InfoForClients[tn].cLogin,ServStatus.msg[tn].login_in.cLogin);
            // Пароль клиента
            strcpy(ServStatus.InfoForClients[tn].cPass,ServStatus.msg[tn].login_in.cPass);
            // Клиент подключен
            ServStatus.InfoForClients[tn].iError=0;
                        
            // Посылка ответа
            // Очистка структуры пакета
            for (int j=0; j<SIZE; j++) ServStatus.msg[tn].un[j]=0;
            // запись команды
            strcpy(ServStatus.msg[tn].login_out.cCommand,tmpcommand);
            // запись ошибки
            ServStatus.msg[tn].login_out.iError=0;
            // запись уровня привелегий
            ServStatus.msg[tn].login_out.cStatus=ilvl[i];
            // посылка пакета
            rc = send(ServStatus.InfoForClients[tn].s,ServStatus.msg[tn].un,SIZE,0);
            if ( rc < 0 ){
                cout<<"SERVER INFO: Error sending ResponseLogin: "<< errno << endl; 
            }else
            {
                cout<<"SERVER INFO: Sent ResponseLogin, RC="<< rc << endl;
            }
            // аутентификация прошла успешно
            return 0; 
            break;
        }       
    }
    cout << "SERVER INFO: unsuccessfull autentification, login='" << ServStatus.msg[tn].login_in.cLogin << "', pass='" << ServStatus.msg[tn].login_in.cPass << "'\n";
    // Посылка ответа
    // Очистка структуры пакета
    for (int j=0; j<SIZE; j++) ServStatus.msg[tn].un[j]=0;
    // запись команды
    strcpy(ServStatus.msg[tn].login_out.cCommand,tmpcommand);
    // запись ошибки
    ServStatus.msg[tn].login_out.iError=WRONG_LOGIN_PASS_COMBINATION;
    // запись уровня привелегий
    ServStatus.msg[tn].login_out.cStatus=0;
    rc = send(ServStatus.InfoForClients[tn].s,ServStatus.msg[tn].un,SIZE,0);
    if ( rc < 0 ){
        cout<<"SERVER INFO: Error sending ResponseLogin: "<< errno << endl; 
    }else
    {
        cout<<"SERVER INFO: Sent ResponseLogin, RC="<< rc << endl;
    }
 
    rc = shutdown(ServStatus.InfoForClients[tn].s, SHUT_RDWR);
    if ( rc < 0 ){
        cout<<"SERVER INFO: Error shuting down socket: "<< errno << endl;   
    }else
    {
        cout<<"SERVER INFO: socket shutdowned" << endl;
    }
 
    rc = close(ServStatus.InfoForClients[tn].s);
    if ( rc < 0 ){
        cout<<"SERVER INFO: Error closing socket: "<< errno << endl;    
    }else
    {
        cout<<"SERVER INFO: socket closed" << endl;
    }
    // неудачная аутентификация
    return 1; 
}
 
// Чтение файла настроек
int ReadIniFile()
{
    // файловый поток
    fstream FileStream; 
    // имя файла
    string F_Name="Server.ini"; 
    // открытие файла
    FileStream.open(F_Name.c_str(), ios::in);
    // проверка открытия файла
    if (!FileStream)
    {
        cout << "SERVER INFO: Error opening ini file '" << F_Name.c_str() << "'" << endl;
        return -1;
    }else
    {
        cout << "SERVER INFO: Opened ini file '" << F_Name.c_str() << "'" << endl;
    }
    // текущая строка файла
    string line;
    // начало блока паролей
    bool readlogininfo=false;
    // номера символов с инфой
    int tmp,tmp2,tmp3,tmp4,tmp5,tmp6;
    // Переменная для перевода данных из строки в число
    int inttmp1;
    // чтение файла
    while(FileStream)
    {
        // чтение строки
        getline(FileStream,line, '\n');
        // Обработка коментариев
        if (line.find(";") != string::npos && int(line.find(";"))==0 )
        {
            cout << "SERVER INFO: Found comment in file '" << F_Name.c_str() << "':" << endl;
            cout << line.c_str() << endl;
        }
        // Строка пустая
        else if (line.empty())
        {
            cout << "SERVER INFO: Found empty line in file '" << F_Name.c_str() << "'" << endl;
        }
        // Блок с информацией о паролях
        else if (line.find("[Login info]") != string::npos )
        {
            readlogininfo=true;
        }
        else if (readlogininfo==true && line.find("Login=") != string::npos )
        {
            // Поиск логина
            tmp=line.find("Login=");
            tmp2=line.find(";",tmp);
            if (tmp2 != string::npos )
            {
                Login.push_back(line.substr(tmp+6,tmp2-6-tmp));
            }else
            {
                cout << "SERVER INFO: Wrong ini file '" << F_Name.c_str() << "'" << endl;
                return -1;
            }
            // Поиск пароля
            tmp3=line.find("Pass=",tmp2);
            if (tmp3 != string::npos )
            {
                tmp4=line.find(";",tmp3);
                if (tmp4 != string::npos )
                {
                    Pass.push_back(line.substr(tmp3+5,tmp4-tmp3-5));
                }else
                {
                    cout << "SERVER INFO: Wrong ini file '" << F_Name.c_str() << "'" << endl;
                    return -1;
                }
            }else
            {
                cout << "SERVER INFO: Wrong ini file '" << F_Name.c_str() << "'" << endl;
                return -1;
            }
            // Поиск уровня привелегий
            tmp5=line.find("ilvl=",tmp4);
            if (tmp3 != string::npos )
            {
                tmp6=line.find(";",tmp5);
                if (tmp6 != string::npos )
                {
                    if(!from_string<int>(inttmp1, line.substr(tmp5+5,tmp6-5-tmp5), std::dec))
                    {
                        cout << "SERVER INFO: ilvl is not integer, file '" << F_Name.c_str() << "'" << endl;
                        return -1;
                    }
                    ilvl.push_back(inttmp1);
                }else
                {
                    cout << "SERVER INFO: Wrong ini file '" << F_Name.c_str() << "'" << endl;
                    return -1;
                }
            }else
            {
                cout << "SERVER INFO: Wrong ini file '" << F_Name.c_str() << "'" << endl;
                return -1;
            }
 
 
        }else
        {
            cout << "SERVER INFO: Wrong ini file '" << F_Name.c_str() << "'" << endl;
            return -1;
        }
    }
    // закрытие файла
    FileStream.close();
    return 0;
}
 
// Чтение состояния
int ReadSavedState()
{
    
    // файловый поток
    fstream FileStream; 
    // имя файла
    string F_Name="Saved.state";    
    // открытие файла
    FileStream.open(F_Name.c_str(), ios::in);//, ios::binary );
    // проверка открытия файла
    if (!FileStream)
    {
        cout << "SERVER INFO: Error opening state file '" << F_Name.c_str() << "'" << endl;
        return -1;
    }else
    {
        cout << "SERVER INFO: state file '" << F_Name.c_str() << "' opened" << endl;
    }
    // текущая строка файла
    string line="";
    char linetmp;
    // чтение файла
    linetmp = FileStream.peek();
    //line+=linetmp;
    while(FileStream)
    {
        // чтение файла
        linetmp = FileStream.get();
        line+=linetmp;
        //FileStream >> linetmp;
        
    }
    //debug
    //for (int k=0; k<line.length(); k++) cout << int(line[k]) << " ";
    //cout << endl;
    int tmpint;
    float tmpfloat;
    int cpos=0,cposto=0;
    // запись кол-ва кодов и котировок
    strcpy2(int_char.chars,line.substr(cpos,4).c_str());
    // debug
    //cout << "nSections: " << int_char.number << endl;
    SDB.nSections=int_char.number;
    cpos+=4;
    for (int i=0; i<SDB.nSections; i++)
    {
        // запись длины названий
        strcpy2(int_char.chars,line.substr(cpos,4).c_str());
        cpos+=4;
        cposto=int_char.number;
        // debug
        //cout << "Section["<< i << "]: " << line.substr(cpos,cposto).c_str() << endl;
        SDB.Sections.push_back(line.substr(cpos,cposto).c_str());
        vector<string> tmp;
        SDB.Articles.push_back(tmp);
        cpos+=cposto;
        // запись кол-ва статей
        strcpy2(int_char.chars,line.substr(cpos,4).c_str());
        // debug
        //cout << "nArticles["<< i << "]: " << int_char.number << endl;
        SDB.nArticles.push_back(int_char.number);
        cpos+=4;
        for (int j=0; j<SDB.nArticles[i]; j++)
        {
            // запись длины названий
            strcpy2(int_char.chars,line.substr(cpos,4).c_str());
            cpos+=4;
            cposto=int_char.number;
            // debug
            //cout << "Article["<< i << "][" << j <<"]: " << line.substr(cpos,cposto).c_str() << endl;
            SDB.Articles[i].push_back(line.substr(cpos,cposto).c_str());
            cpos+=cposto;
        }           
    }
    // закрытие файла
    FileStream.close();
    return 0;
}
 
// Сохранение состояния
void SaveState(int sig)
{
    // файловый поток
    fstream FileStream; 
    // имя файла
    string F_Name="Saved.state";    
    // открытие файла
    FileStream.open(F_Name.c_str(), ios::out);
    // проверка открытия файла
    if (!FileStream)
    {
        cout << "SERVER INFO: Error creating state file '" << F_Name.c_str() << "'" << endl;
        exit(0);
    }else
    {
        cout << "SERVER INFO: state file '" << F_Name.c_str() << "' created" << endl;
    }
    // вывод кол-ва разделов
    int_char.number=SDB.nSections;
    for (int k=0; k<4; k++) FileStream << int_char.chars[k];
    for (int i=0; i<SDB.nSections; i++)
    {
        // вывод длины названий
        int_char.number=SDB.Sections[i].length();
        for (int k=0; k<4; k++) FileStream << int_char.chars[k];
        cout << "\nSaving Section["<<i<<"]\n";
        // вывод названий
        for (int j=0; j<SDB.Sections[i].length(); j++)
        {
            cout << SDB.Sections[i][j];
            FileStream << SDB.Sections[i][j];   
        }
        // вывод кол-ва статей
        int_char.number=SDB.nArticles[i];
        for (int k=0; k<4; k++) FileStream << int_char.chars[k];
        for (int j=0; j<SDB.nArticles[i]; j++)
        {
            // вывод длины названий
            int_char.number=SDB.Articles[i][j].length();
            for (int k=0; k<4; k++) FileStream << int_char.chars[k];
            cout << "\nSaving Aricle["<<i<<"][" << j << "]\n";
            // вывод названий
            for (int l=0; l<SDB.Articles[i][j].length(); l++)
            {
                cout << SDB.Articles[i][j][l];
                FileStream << SDB.Articles[i][j][l];    
            }
        }
    }
    // закрытие файла
    FileStream.close();
    exit(0);
}
 
    
 
// Нить обработки ввода команд
void * Server_UI(void *n)
{
    // переменная для хранения комманды
    string scommand;
    while(1)
    {
        // Получение введеной команды
        getline(cin,scommand, '\n');
        // Перевод команды из string в char
        for (int i=0; i<20; i++) command[i]=0;
        for (int i=0; i<scommand.length(); i++)
        {
            if (i==20) break;
            command[i]=scommand[i];
        }
        // Обработка команды
        if(scommand=="who") {fwho2();}
        else if(scommand=="kill") {cout << "This command requres argument\n";}
        else if(scommand.find("kill ")!=string::npos && int(scommand.find("kill "))==0) {fkill2();}
        else 
        {
            printf("'%s' is not recognized as internal command\n", command);
            cout << "\nList of avaible commands:" << endl
            << "who - list connected users" << endl
            << "kill - kill user thread" << endl;
        }
    }
}
 
// функция вывода списка пользователей для сервера
void fwho2()
{
    cout << "SERVER INFO: processing who command"<< endl;
 
    printf("UserID\tUserName\n");
    for (int i=0; i<MAX_NUMBER_OF_CONNECTIONS; i++)
    {
        if (ServStatus.InfoForClients[i].iError==0)
        {
            printf("%6d\t%-8s\n",ServStatus.InfoForClients[i].iId, ServStatus.InfoForClients[i].cLogin);
        }
    }
}
 
// функция принудительного отключения пользователя для сервера
int fkill2()
{
    // Переменная под аргумент
    char arg[20]="";
    // Удаление пробелов в аргументе
    int k=5;
    for (int j=5; j<20; j++)
    {
        // начало не пустого аргумента
        if (command[j]>32)
        {
            k=j;
            break;
        }
    }
    // Получения аргумента из строки команды
    for (int i=0; i<20; i++)
    {
        arg[i]=command[i+k];
    }
    // Строка из чаров для получения числа
    char carg[11];
    // число
    int userID;
    for (int i=0; i<11; i++) carg[i]=arg[i];
    if(!from_string<int>(userID, carg, std::dec))
    {
        //debug
            //wcout << arg << endl;
            //cout << carg << endl;
        cout << "INFO: Argument must be an integer value" << endl;
        return -1;
    }
    // Запись аргумента в пакет
    unSnd.kill_in.uID=userID;
 
    int ID=MAX_NUMBER_OF_CONNECTIONS;
    // Поиск указанного клиента
    for (int i=0; i<MAX_NUMBER_OF_CONNECTIONS; i++)
    {
        if (ServStatus.InfoForClients[i].iError==0 && unSnd.kill_in.uID==ServStatus.InfoForClients[i].iId)
        {
            ID=i;
            break;
        }
    }
    // клиент не найден
    if (ID==MAX_NUMBER_OF_CONNECTIONS)
    {
        cout<<"SERVER INFO: NO_SUCH_USER on server"<<endl;
    }
    //клиент найден
    else
    {
        // Запись информации о том, что ячейка памяти более не используется
        ServStatus.InfoForClients[ID].iError=1;
        ServStatus.numberofclients--;           
        cout<<"SERVER INFO: user thread killed"<<endl;
        //Sleep(100);
        // формирование пакета с уведомлением об отключении
        // очистка пакета от мусора
        for (int i=0; i<SIZE; i++) unSnd.un[i]=0;
        strcpy(unSnd.kill_out.cCommand,"kill");
        unSnd.kill_out.iError=YOU_HAVE_BEEN_DISCONECTED_BY_SUSER;
        // Посылка уведомления отключенному клиенту
        rc = send(ServStatus.InfoForClients[ID].s,unSnd.un,SIZE,0);
        if ( rc < 0 ){
            cout<<"SERVER INFO: Error sending YOU_HAVE_BEEN_DISCONECTED_BY_SUSER Notification: "<<errno<<endl;
        }
        else
        {
            cout << "SERVER INFO: Sent YOU_HAVE_BEEN_DISCONECTED_BY_SUSER Notification, RC=" << rc << endl;
        }
        // закрытие сокета
        int trc = shutdown(ServStatus.InfoForClients[ID].s, SHUT_RDWR);
        if ( trc < 0 ){
            cout<<"SERVER INFO: Error shuting down socket: "<< errno << endl;   
        }else
        {
            cout<<"SERVER INFO: socket shutdowned" << endl;
        }
        trc = close(ServStatus.InfoForClients[ID].s);
        if ( trc < 0 ){
            cout<<"SERVER INFO: Error closing socket: "<< errno << endl;    
        }else
        {
            cout<<"SERVER INFO: socket closed" << endl;
        }
 
 
    }       
}

Добавлено через 2 часа 32 минуты
Тему можно закрыть. Все было очень просто а я пол года убил чтобы понять такую банальность)

	17.12.2010, 03:02