172 похожих чатов

Всем доброго времени суток. Есть два сокета. Всё, что пытаюсь

сделать - получить с одного и отправить на другой. И ловлю довольно таки странное поведение. Дело в том, что данные не доходят на конечный сокет. Но как только вырубаешь приложуху sigint'ом - вываливается чанк пакетов. Самое интересное, что socket.send() не лочится и цикл продолжает крутиться. Что я делаю не так ? Я лочу экзекьютор ? Если так, то где и как (токио) ? Пример:

loop {
let data = receive_sock.next().await;
if let Some(Ok((_, data))) = data {
send_sock.send((Instant::now(), data.clone())).await.unwrap();
}
}

5 ответов

6 просмотров

Другая сторона читает пакеты, которые ты отправляешь? Если она не читает, то они просто копятся в буфере отправки, пока не придёт подтверждение предыдущих

Lighty
Читает конечно.

В else ветку(которой нет) точно не попадаешь? Ошибки сокета, например

Как создаётся сокет? Конвертируется из std::net? На сокете из std нужно сделать set_nonblocking(true). tokio не делает это сам.

Попробуй воткнуть "пустой await" между receive и send Чтобы ивентлуп на следующую итерацию скакнул Не помню как это в токио делается

Похожие вопросы

Обсуждают сегодня

Такс, блин, таки кто-то знает, каким образом работают макросы stdin/stdout/stderr? Я влез в stdio.h, там определения нет, отладил через асмокод - вызывается функция со странны...
The Bird of Hermes
18
Всем привет, на линуксе лучше на fasm или nasm учиться писать для начала ?
meszjol
14
я не магистр хаскеля, но разве не может лейзи тип конвертнуться в не-лейзи запросив вычисление содержимого прям при инициализации?
deadgnom32 λ madao
100
Если у меня есть такой класс: Object = {} function Object:new(a_name, a_transform, a_color, a_mesh, a_material, a_shader, a_textures) local private = {} private.n...
Cuarno Vile
4
Гайз, кто-нибудь пробовал запустить probe-rs под камень, которого нет в probe-rs? Мб есть какой-нибудь пример у кого... Через target-gen попробовал сгенерировать chip-descript...
Максим Смирнов
2
было так ;void set_http_ver(RESPD* ptr, char* version, uint32_t length) // example: 'RTSP/1.1 ' set_http_ver: mov eax, [esp + 4] mov ecx, [esp + 8] ...
Mixail Frolov
5
А еще в перле можно уже @arr1 + @arr2?
Sergei Zhmylove
53
зачем же переименовывать ? чтобы кол-во участников возросло или вдруг IBM от этого снова на свифте начнет кодить ? Я не понимаю что страшного в том что свифт гавно, если это т...
Oleh Nerzh
10
@MrMiscipitlick А можешь макрос написать, который будет вычислять смещение относительно переданных меток? Просто .label1-.label2, и вернуть значение.
КТ315
35
здравствуйте. совершаю вот такую вещь: strcpy(line, (char)current_number); где current number — неподписанный шорт, line — массив чаров. ругань следующая: main.c:29:30: error...
Roberto's Ширгозиев
13
Карта сайта