bool TServer::OnCommand(void * AInfo, char * ABuffer, int ABufferSize)
    {
        int TmpCommand;
        // Если это старт команды - считаем размер
        if (FCommandSize == 0)
        {
            // Заберем размер            
            FCommandSize = *ABuffer;
            if (FCommandSize <= 0)
            {
                Log("Empty command size");
                return false;
            }
            FBuffer = new Transport::TBuffer(AInfo, FCommandSize);
        }
        // Сдвинем позицию чтения буфера
        int TmpCopyCount = std::min(ABufferSize, FCommandSize);
        ABuffer += sizeof(FCommandSize);
        ABufferSize -= TmpCopyCount;
        FCommandSize -= TmpCopyCount;
        // Запишем буфер
        if (!FBuffer->WriteBuffer(*ABuffer, TmpCopyCount))
        {
            Log("Error copy command");
            return false;
        }
        // Сдвинем буфер на прочитанный размер
        ABuffer += TmpCopyCount;
        // Если вся команда записана, убираем задачу в очередь
        if (FCommandSize > 0)
            return OnCommand(AInfo, ABuffer, ABufferSize);
        else
            FBuffer->Commit();
        // Попробуем считать команду с буфера
        if (!FBuffer->PeekCommand(TmpCommand))
        {
            Log("Broken command");
            return false;
        }
        // Иначе добавим в обработчики
        switch (TmpCommand / 1000)
        {
        case 0:
            FAuth.Command(FBuffer);
            break;
        /*case  1:
            FPlanetar.Subscribe(TmpInfo);
            break;
        case 2:
            FPlanetar.Connect(TmpInfo);
            break;
        default:
            TmpInfo->Reader->Buffer->Rollback();
            TmpInfo->Reader->Commit();
            break;*/
        }
        // Успешно
        return true;
    }

    void TBufferTransport::Push(TBuffer * ABuffer)
    {
        TLockGuard lock(FMutexAccess);
        FQueue.push(ABuffer);
        FSignal.notify_one();
    }

    TBuffer * TBufferTransport::Pop()
    {
        // Заблокируем мьютекс сигнала
        std::unique_lock<std::mutex> locker(FMutexSignal);
        // Подождем появления сигнала
        FSignal.wait(locker);
        // Заблокируем от изменения
        TLockGuard lock(FMutexAccess);
        // Выделим элемент
        if (FQueue.empty())
            return nullptr;
        else
        {
            TBuffer * tmpResult = FQueue.front();
            FQueue.pop();
            return tmpResult;
        }
    }