Запись буфера в boost asio

@admsasha · Регистрация: 11.06.2011

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

Изучаю данный пример
http://www.boost.org/doc/libs/... server.cpp

Появились некоторые вопросы, которые на localhost проблемно проверить, а знать о ньансах хочется.

Есть вот такой код.

C++
1
2
   boost::asio::async_write(socket_, boost::asio::buffer(data_, length),
        [this, self](boost::system::error_code ec, std::size_t /*length*/)

1. Тут шлется буфер data_ в сокет. Что будет если он не успеет записаться весь, а сокет примет большую пачку данных и будет указание еще одной записи ? Две асинхронные записи ? Что будет с буфером ? Ведь он глобален для всего класса.

2. Пока идет запись/чтение из одной сессии (async_write) все прочие сессии будут его ждать ?

Убежденный · 04.02.2014, 10:57

Сообщение от admsasha

1. Тут шлется буфер data_ в сокет. Что будет если он не успеет записаться весь, а сокет примет большую пачку данных и будет указание еще одной записи ? Две асинхронные записи ?

Если Вы переформулируете свой вопрос, постараюсь ответить.
Сейчас непонятно, что именно имеется в виду. Сокет может принимать данные
только тогда, когда он находится в состоянии обработки команды recv.
"примет большую пачку данных и будет указание еще одной записи" - непонятно.

Что будет с буфером ? Ведь он глобален для всего класса.

Не глобален. Один буфер на один объект session.

Сообщение от admsasha

2. Пока идет запись/чтение из одной сессии (async_write) все прочие сессии будут его ждать ?

Нет. Можно запустить несколько операций ввода-вывода и все они будут
выполняться параллельно. А вот обработка завершения уже зависит от того,
сколько потоков выполняют io_service::run - если там только один поток,
как в данном примере, то в один момент времени может выполняться только
один обработчик завершения I/O.

@admsasha · 04.02.2014, 11:51 **[ТС]**

Попробую перефразировать.
Допустим данные передаются в течении часа. На boost::asio::async_write не повиснет на весь час ? Как я понял, нет. В течении этого часа шлем еще раз boost::asio::async_write это возможно ? Или в каком то месте кода будет ожидание, того пока не завершит отправку первая порция ? Или всё что я кину в async_write , будет в порядке очереди отправляться ?

Убежденный · 04.02.2014, 12:13

Сообщение от admsasha

Допустим данные передаются в течении часа. На boost::asio::async_write не повиснет на весь час ?

Async-операции не виснут по определению, они запускают I/O и сразу же
возвращают управление. А вот обработчик завершения I/O может быть вызван
через некоторое время, это зависит от многих факторов. К примеру, если на том
конце упорно не хотят звать recv, передача данных может надолго застопориться.

Сообщение от admsasha

В течении этого часа шлем еще раз boost::asio::async_write это возможно ?

Да.

Сообщение от admsasha

Или в каком то месте кода будет ожидание, того пока не завершит отправку первая порция ?

Сначала отработает первая операция, затем вторая.
Точно также, как если бы сначала запустить первую операцию,
дождаться ее завершения, а затем запустить вторую.

Сообщение от admsasha

Или всё что я кину в async_write , будет в порядке очереди отправляться ?

Здесь речь про TCP, это протокол, который гарантирует порядок данных.
Если пишется А, затем Б, потом В, то они в таком порядке и отправляются в сокет.

@admsasha · 04.02.2014, 14:23 **[ТС]**

Большое спасибо за ответы! Стало действительно понятнее...

И, надеюсь, последний момент.

Например, я создаю свою переменную

C++
1
char mystr[max_length];

В неё копирую значение какое либо. И передаю в async_write

C++
1
2
boost::asio::async_write(socket_, boost::asio::buffer(mystr, str(mystr)),   //  \0 пока не учитываем, это я для упращения.
        [this, self](boost::system::error_code ec, std::size_t /*length*/)

т.к. произойдет выход из функции do_write, то и значение mystr уничтожится. На сколько я понял async_write не копирует значение, а использует ссылку. Это так ? Если да, то в простом случае, данные будут не дозаписываться, т.к. будут не успевать. Прошу подсказать, как грамотно в данном случае поступить?

@ForEveR · 04.02.2014, 14:35

admsasha, Если переменная mystr выйдет из области видимости, тогда не будет ровным счетом ничего хорошего. Нужно гарантировать, что память будет доступна. Если нет возможности это сделать - стоит использовать динамическую память, в частности можно использовать boost::shared_array.

Убежденный · 04.02.2014, 14:45

Сообщение от admsasha

На сколько я понял async_write не копирует значение, а использует ссылку. Это так ?

Ответы на такие вопросы всегда лучше искать в официальной документации.
Да, буфер не копируется. Для высоконагруженных сетевых приложений это критично,
поэтому везде, где только возможно, принято обходиться без копирования.

Сообщение от admsasha

Если да, то в простом случае, данные будут не дозаписываться, т.к. будут не успевать. Прошу подсказать, как грамотно в данном случае поступить?

Простейший способ - создавать буфер в динамической памяти и передавать
его указатель в обработчик, где обрабатывать результат и вызывать delete.
Лучше обернуть все это в смарт-поинтеры (shared_array, например).
Если производительность не устроит (а она устроит в 95% случаев), можно
подумать про какой-нибудь пул буферов разного размера.

Новые блоги и статьи Все статьи Все блоги /
SDL3 для Web (WebAssembly): Обработчик клика мыши в браузере ПК и касания экрана в браузере на мобильном устройстве 8Observer8 02.02.2026 Содержание блога Для начала пошагово создадим рабочий пример для подготовки к экспериментам в браузере ПК и в браузере мобильного устройства. Потом напишем обработчик клика мыши и обработчик. . .	Философия технологии iceja 01.02.2026 На мой взгляд у человека в технических проектах остается роль генерального директора. Все остальное нейронки делают уже лучше человека. Они не могут нести предпринимательские риски, не могут. . .	SDL3 для Web (WebAssembly): Вывод текста со шрифтом TTF с помощью SDL3_ttf 8Observer8 01.02.2026 Содержание блога В этой пошаговой инструкции создадим с нуля веб-приложение, которое выводит текст в окне браузера. Запустим на Android на локальном сервере. Загрузим Release на бесплатный. . .	SDL3 для Web (WebAssembly): Сборка C/C++ проекта из консоли 8Observer8 30.01.2026 Содержание блога Если вы откроете примеры для начинающих на официальном репозитории SDL3 в папке: examples, то вы увидите, что все примеры используют следующие четыре обязательные функции, а. . .
SDL3 для Web (WebAssembly): Установка Emscripten SDK (emsdk) и CMake для сборки C и C++ приложений в Wasm 8Observer8 30.01.2026 Содержание блога Для того чтобы скачать Emscripten SDK (emsdk) необходимо сначало скачать и уставить Git: Install for Windows. Следуйте стандартной процедуре установки Git через установщик. . . .	SDL3 для Android: Подключение Box2D v3, физика и отрисовка коллайдеров 8Observer8 29.01.2026 Содержание блога Box2D - это библиотека для 2D физики для анимаций и игр. С её помощью можно определять были ли коллизии между конкретными объектами. Версия v3 была полностью переписана на Си, в. . .	Инструменты COM: Сохранение данный из VARIANT в файл и загрузка из файла в VARIANT bedvit 28.01.2026 Сохранение базовых типов COM и массивов (одномерных или двухмерных) любой вложенности (деревья) в файл, с возможностью выбора алгоритмов сжатия и шифрования. Часть библиотеки BedvitCOM Использованы. . .	SDL3 для Android: Загрузка PNG с альфа-каналом с помощью SDL_LoadPNG (без SDL3_image) 8Observer8 28.01.2026 Содержание блога SDL3 имеет собственные средства для загрузки и отображения PNG-файлов с альфа-каналом и базовой работы с ними. В этой инструкции используется функция SDL_LoadPNG(), которая. . .

@admsasha 28 / 27 / 7 Регистрация: 11.06.2011 Сообщений: 387
	04.02.2014, 11:51 [ТС]
	Попробую перефразировать. Допустим данные передаются в течении часа. На boost::asio::async_write не повиснет на весь час ? Как я понял, нет. В течении этого часа шлем еще раз boost::asio::async_write это возможно ? Или в каком то месте кода будет ожидание, того пока не завершит отправку первая порция ? Или всё что я кину в async_write , будет в порядке очереди отправляться ? 0

@ForEveR В астрале 8049 / 4806 / 655 Регистрация: 24.06.2010 Сообщений: 10,562
	04.02.2014, 14:35
	admsasha, Если переменная mystr выйдет из области видимости, тогда не будет ровным счетом ничего хорошего. Нужно гарантировать, что память будет доступна. Если нет возможности это сделать - стоит использовать динамическую память, в частности можно использовать boost::shared_array. 0

Запись буфера в boost asio

Решение