Непонятки с QTcpSocket

[ploop]

Имеется такой код, вызывается по таймеру раз в секунду:

Код

C++ (Qt)
void send_to_client()
{
  char buf[5] = {'1','2','3','4','5'};
  socket->write(buf,5);
  socket->flush();
}
 
// На другой стороне
 
void slotReadyRead()
{
  qDebug() << QTime::currentTime() << socket->readAll();
}

Вот что получаю:

Код:

QTime("10:42:44") "12345" 
QTime("10:42:45") "1234512345" 
QTime("10:42:46") "1234512345" 
QTime("10:42:47") "1234512345" 
QTime("10:42:48") "12345" 
QTime("10:42:48") "12345" 
QTime("10:42:49") "1234512345" 
QTime("10:42:50") "1234512345" 
QTime("10:42:51") "1234512345" 

Дебаг (и лог) явно показывает, что send_to_client вызывается один раз. При этом на клиенте ловим повторяющиеся данные.
Если размер посылки небольшой (помещается в один сетевой пакет), то алгоритм нормально её декодирует (повтор отбросит). Но если надо сбросить посылку пожирнее, то внутри её получается каша, что логично.

Собственно, почему так происходит?

[Old]

Потому что данные от отправителя склеиваются сетевым стеком в один пакет, все согласно протокола.

[ploop]

Я всё понимаю, но тут другая ситуация. Отправляю данные один раз (вручную например), а получаю несколько копий.

Код

C++ (Qt)
void send_to_client()
{
  char buf[5] = {'1','2','3','4','5'};
 
  xxx++; 
  qDebug() << xxx;
 
  socket->write(buf,5);
  socket->flush();
}

Лог отправляющей стороны:

Код:

debug:    [28.01.2014 11:09:29.256]: 1 
debug:    [28.01.2014 11:09:30.256]: 2 
debug:    [28.01.2014 11:09:31.256]: 3 
debug:    [28.01.2014 11:09:32.256]: 4 
debug:    [28.01.2014 11:09:33.256]: 5 
debug:    [28.01.2014 11:09:34.256]: 6 
debug:    [28.01.2014 11:09:35.256]: 7 
debug:    [28.01.2014 11:09:36.256]: 8 

Принимающая сторона:

Код:

QTime("11:09:29") "12345" 
QTime("11:09:30") "12345" 
QTime("11:09:31") "12345" 
QTime("11:09:32") "12345" 
QTime("11:09:33") "12345" 
QTime("11:09:34") "12345" 
QTime("11:09:35") "1234512345" 
QTime("11:09:36") "1234512345" 

Откуда 10 строк вместо восьми?

ЗЫ: Лог сделал только что, коннект - дисконнект, всё как есть.

[Old]

Странная ситуация.
А точно отсылка через этот сокет происходит только в send_to_client? Может еще кто-то может это писать в слот?

[ploop]

Сокет сидит в отдельном потоке, сколько клиентов - столько потоков. Конструктор тоже проверял, создаётся один поток, один сокет. Вот код:

Код

C++ (Qt)
void serv::slot_new_connection()
{
  // QTcpServer* tcpserv если что
  QThread* thread = new QThread;
  ServerClient* serv_client = new ServerClient(
        tcpserv->nextPendingConnection(),
        &dbl,thread);
 
  serv_client->moveToThread(thread);
 
  connect(serv_client,SIGNAL(sig_stop(ServerClient*)),this,SLOT(slot_disconnected(ServerClient*))); // Тут поток уничтожается. Тоже корректно
  connect(thread,SIGNAL(finished()),thread,SLOT(deleteLater()));
  connect(thread,SIGNAL(finished()),serv_client,SLOT(deleteLater()));
 
  thread->start();
 
  qDebug() << "Client connected: id=" << (int)serv_client;
}
 

Внутри конструктора объекта:

Код

C++ (Qt)
  connect(socket,SIGNAL(readyRead()),this,SLOT(slot_read_client()));

Все тесты с одним клиентом. Если их несколько - ситуация аналогична, только с разными указателями на сокеты/потоки/объекты. То есть всё ровно.

Самое интересное - взял проект вчера домой, дабы спокойно поковыряться, и не смог воспроизвести ошибку, как ни старался! Всё работает чётко. Может что-нибудь связанное с системой быть? Порты разные пробовал...

[ploop]

Да тут просто по логике: если send_to_client вызовет кто-то ещё, увидим запись в логе.

[Old]

Да тут просто по логике: если send_to_client вызовет кто-то ещё, увидим запись в логе.

Ну кто-то может писать в сокет и не в этой функции имея на него указатель.

Похоже, что у вас действительно проблемы не с программой, а с сетью.
Какая у вас платформа и как тестируете, через localhost или разные машины?

[ploop]

Да, через localhost
Ubuntu 12.04 (в системе чего только не понаставлено, но что может быть причиной не могу сообразить). Сборки будут и под Win32.
Наверное попробую собрать тестовый проект на другой машине...

Ну кто-то может писать в сокет и не в этой функции имея на него указатель

Прошерстил проект по ключевому слову "Write", ничего криминального

[ploop]

Кажется победил проблему.
Скомпилив на Windows и запустив, увидел ошибки в логе во время send_to_client:

Код:

QSocketNotifier: socket notifiers cannot be enabled from another thread
QSocketNotifier: socket notifiers cannot be disabled from another thread

И до меня дошло: сам объект находится в новом потоке, а сокет - в старом! Так как указатель на сокет я в конструктор передаю, просто добавил в конструктор это:

Код

C++ (Qt)
  socket->setParent(NULL);
  socket->moveToThread(thread_ptr()); // thread_ptr() просто возвращает указатель на поток.
 
// Ну и проверка в send_to_client
  if ((int)this->thread != (int)this->thread_ptr()) qDebug()<<"Self thread is bad";
  if ((int)this->thread != (int)socket->thread()) qDebug()<<"Socket thread is bad";
 
 

Вот этот тестовый код стал чётко работать. С реальными данными не знаю - весь код разворошил, буду в кучу собирать и пробовать

----

Ну да, всё собрал. Мегабайтные куски друг за другом летают только в путь, и разбираются без ошибок.
Аккуратнее с потоками, господа

[OKTA]

Не уж то наследовался от QThread??))

[ploop]

Нет, зачем?
Весь код я привёл выше. Собственно, это всё.
Сегодня проверили сервер с несколькими десятками клиентов и большой нагрузкой на сеть (при чём некоторые клиенты на плохом соединении) - нормально всё, падений нет, утечек, по мнению Valgrind, - тоже.

[vulko]

У меня похожая непонятка. Отправляю через сокет 128 байт, получаю, закрываю, запрашиваю снова, получаю и т.д.

Однако иногда приходит пакет 4224 байт, хз откуда берущийся...

[OKTA]

а что в пакете-то?))

[vulko]

а что в пакете-то?))

у меня? сериализованный данные. массив из 8 элементов структуры, состоящей из 1 инта и 3х флоутов. 8 элементов по 16 байт, итого 128 байт.

откуда 4224 байта вообще хз...

[LisandreL]

Как вариант - 33 ваших пакета.