Работа с Сокетами

#include "SDK\amx\amx.h"
#include "SDK\plugincommon.h"
 
#pragma comment (lib, "ws2_32.lib")
 
#include <winsock2.h>
 
using namespace std;
 
typedef void(*logprintf_t)(char* format, ...);
logprintf_t logprintf;
extern void *pAMXFunctions;
 
//Создаем сокет socket ( int af, int type, int protocol ).
//Первый слева аргумент указывает на семейство использу-
//емых протоколов, AF_INET - используеться при создании интернет приложений. SOCK_STREAM - тип
//создаваемого сокета, SOCK_STREAM (потоковый) или SOCK_DGRAM (дейтаграммный) или SOCK_RAW
//(сырой).Последний аргумент задает тип создаваемого сокета, нулевое значение соответствует выбору по
//умолчанию, ТСР - для потоковых, и UDP - дейтограммных.
//Если функция завершилась успешно то она возвращает дескриптор сокета.
 
SOCKET* Connections;
int ClientCount = 0;
 
cell AMX_NATIVE_CALL Addon_IsClientConnected(AMX* amx, cell* params)
{
    //char* IP = NULL;
    //int pID = params[1];
    //amx_StrParam(amx, params[2], IP);
    //logprintf("ID: %i IP: %s", ID, IP);
 
    int pID = params[1];
    if(Connections[pID] != INVALID_SOCKET) return 1;
    return 0;
}
 
PLUGIN_EXPORT unsigned int PLUGIN_CALL Supports()
{
    return SUPPORTS_VERSION | SUPPORTS_AMX_NATIVES | SUPPORTS_PROCESS_TICK;
}
 
PLUGIN_EXPORT bool PLUGIN_CALL Load(void **ppData)
{
    pAMXFunctions = ppData[PLUGIN_DATA_AMX_EXPORTS];
    logprintf = (logprintf_t)ppData[PLUGIN_DATA_LOGPRINTF];
 
    
 
    logprintf("Addon loaded");
    
    return true;
}
 
PLUGIN_EXPORT void PLUGIN_CALL Unload()
{
    logprintf("Addon unloaded");
}
 
AMX_NATIVE_INFO PluginNatives[] =
{
    { "Addon_IsClientConnected", Addon_IsClientConnected },
    { 0, 0 }
};
 
PLUGIN_EXPORT int PLUGIN_CALL AmxLoad(AMX *amx)
{
    return amx_Register(amx, PluginNatives, -1);
}
 
PLUGIN_EXPORT int PLUGIN_CALL AmxUnload(AMX *amx)
{
    return AMX_ERR_NONE;
}
 
PLUGIN_EXPORT void PLUGIN_CALL ProcessTick()
{
    //Перед началом использования библиотеки ее необходимо подготовить к работе с помощью вызова функции
    //WSAStartup(Ver, lpWSAData), передав ей в старшем байте номер требуемой версии, а в младшем подверсии.
    //Аргумент lpWSAData должен указывать на структуру WSADATA, в которую при успешной инициализации
    //будет занесена информация о производителе библиотеки. Если инициализация не удалась, то функция
    //возвращает не нулевое значение.
    WSAData WSData;
    //WSAStartup позволяет указать версию winsock или получить информацию об ее конкретной реализации
    WSAStartup(0x101, &WSData);
    SOCKET S = socket(AF_INET, SOCK_STREAM, 0);
 
    //Connections = (SOCKET*)calloc(64, sizeof(SOCKET)); //Calloc - этим методом мы инициализируем. Далее выделяем под него память
    //Далее расмотрим установку соединения. Заполнение структуры sockaddr_in:
    sockaddr_in SA;
    SA.sin_family = AF_INET;  //AF_INET характеризует набор протоколов, соответствующий данному соединителю
    SA.sin_port = htons(3135); // htons переводит число из обычного в сетевой порядок бит.
    SA.sin_addr.S_un.S_addr = INADDR_ANY;
    //bind присваивает определенный адрес заданному соединителю
    //bind(SOCKET S, const struct sockaddr far*name, int namelen)
    //s - целочисленный код дескриптора
    //параметр name (идентификатор локального адреса) обычно содержит три величины:
    //IP-адрес ЭВМ, код протокольного набора, номер порта, который определяет характер приложения.
    //Параметр namlen определяет длину второго параметра
    bind(S, (sockaddr*)&SA, sizeof(SA));
    //Установка в режим ожидания осуществляется командой listen, которая организует очередь запросов:
    //R=listen(SOCKET S, int backlog)
    //где backlog - задает максимальный размер очереди для приходящих запросов соединения
    listen(S, SOMAXCONN);
    //Запросы из очереди извлекаются оператором accept:
    //accept(s, struct sockaddr FAR*addr, int FAR*addrlen),
    //где s - дескриптор соединителя, который прослушивает соединение (тот же, что и в listen),
    //addr - опционный указатель на структуру, которая содержит адрес, addrlen - код длины адреса.
    //*************************************************************************************
    //Оператор accept позволяет серверу принять запрос от клиента. Когда входная очередь сформирована,
    //программа реализует процедуру accept и переходит в режим ожидания запросов.
    //Программа извлекает первый элемент очереди, создает новый соединитель со свойствами, идентичными s,
    //и при успешном выполнении возвращает дескриптор нового соединителя.
    //При возникновении ошибки возвращается код INVALID_SOCKET.
    //По окончании обработки запроса сервер вновь вызывает accept, который возвращает ему дескриптор
    //соединителя очередного запроса, если таковой имеется.
    //Если очередь пуста, accept блокирует программу до получения связи.
    SOCKET NS;
    NS = accept(S, 0, 0);
    if(NS != INVALID_SOCKET)
    {
        logprintf(" \n");
        //char n = 0;
        logprintf("[Addon]: Client connected.\n");
 
        //Connections[ClientCount] = NS;
        //ClientCount++;
 
        /*recv(NS, &n, 1, 0);
        logprintf("Received Length = %i\n", int(n));
        char* a = new char[100];
        recv(NS, a, n, 0);
        cout << "Received: "";
        for (int i = 0;i<n;i++) { cout << a[i]; }
        cout << ""\n";*/
        closesocket(NS);
    }
    //closesocket(S); //Закрываем чтобы при следующем соединении выводилось сообщение, что клиент соединен
}

if(NS != INVALID_SOCKET)
    {
        logprintf(" \n");
        //char n = 0;
        logprintf("[Addon]: Client connected.\n");
 
        //Connections[ClientCount] = NS;
        //ClientCount++;
 
        /*recv(NS, &n, 1, 0);
        logprintf("Received Length = %i\n", int(n));
        char* a = new char[100];
        recv(NS, a, n, 0);
        cout << "Received: "";
        for (int i = 0;i<n;i++) { cout << a[i]; }
        cout << ""\n";*/
        closesocket(NS);
    }