Делаю рассылку клиентам. Почему-то, если я отправляю массово BeginSend (в цикле), то на клиент приходит мусор. Если делаю синхронный Send, то все нормально. Данные где-то мешаются? Разве TCP не гарантирует последовательность? Я понимаю, что тут не просто TCP, но еще и асинхронные порты, но они они вроде как должны гарантировать порядок? Или я ошибаюсь.

Поток отправки данных один. Берет, что рассылать, из очереди.

Здравствуйте, Аноним, Вы писали:

А>если я отправляю массово BeginSend (в цикле), то на клиент приходит мусор

Синхронизировать BeginSend в callback'е нужно. Была похожая проблема, правда с SerialPort.Write и с потоками, решается элементарно с помощью lock.

Здравствуйте, Sinatr, Вы писали:

S>Синхронизировать BeginSend в callback'е нужно. Была похожая проблема, правда с SerialPort.Write и с потоками, решается элементарно с помощью lock.

Не совсем понять, локировать какую именно область?

Здравствуйте, Аноним, Вы писали:

А>Делаю рассылку клиентам. Почему-то, если я отправляю массово BeginSend (в цикле), то на клиент приходит мусор. Если делаю синхронный Send, то все нормально. Данные где-то мешаются? Разве TCP не гарантирует последовательность? Я понимаю, что тут не просто TCP, но еще и асинхронные порты, но они они вроде как должны гарантировать порядок? Или я ошибаюсь.

Буфер в BeginSend передается каждый раз свой? Код в студию.

Здравствуйте, hardcase, Вы писали:

H>Буфер в BeginSend передается каждый раз свой? Код в студию.

Я немного с ламбдами поигрался, может что там напортачил:

foreach (var message in messages)
    clientStream.SafeWriteBuffer(Extensions.Encoding.GetBytes(message), this.AddErrorLog);


// а это методы-расширения

public static void SafeWriteBuffer(this Stream clientStream, byte[] buffer, Action<Exception> errorHandler)
{
    clientStream.SafeWrite(((ushort)buffer.Length).To<byte[]>(),
        () => clientStream.SafeWrite(buffer, () => { }, errorHandler), errorHandler);
}

public static void SafeWrite(this Stream clientStream, byte[] buffer, Action complete, Action<Exception> errorHandler)
{
    clientStream.BeginWrite(buffer, 0, buffer.Length, ar =>
    {
        try
        {
            clientStream.EndWrite(ar);
            complete();
        }
        catch (Exception ex)
        {
            errorHandler(ex);
        }
    }, null);
}

Здравствуйте, Аноним, Вы писали:

А> clientStream.BeginWrite(buffer, 0, buffer.Length, ar =>
А> clientStream.EndWrite(ar);

Кста, что за ar вы передаёте в EndWrite? Разве туда не суётся IAsyncResult, возвращаемый BeginWrite?

Здравствуйте, matumba, Вы писали:

M>Здравствуйте, Аноним, Вы писали:

А>> clientStream.BeginWrite(buffer, 0, buffer.Length, ar =>
А>> clientStream.EndWrite(ar);

M>Кста, что за ar вы передаёте в EndWrite? Разве туда не суётся IAsyncResult, возвращаемый BeginWrite?

http://msdn.microsoft.com/library/system.asynccallback.aspx Все как в МСДН

Здравствуйте, Аноним, Вы писали:

Нашел причину. Всем спасибо.

Здравствуйте, Аноним, Вы писали:

А>Нашел причину. Всем спасибо.

Ну так назови ее нам.

Здравствуйте, Ночной Смотрящий, Вы писали:

НС>Здравствуйте, Аноним, Вы писали:

А>>Нашел причину. Всем спасибо.

НС>Ну так назови ее нам.

Дрол ее знает.