Отправка UDP в потоке (winsock)

[NewHorek]

Добрый день. Кто подсказать может. Имеется код по отправке пакетов UDP. Без потока все работает нормально. Как только этот же код начинает работать в отдельном потоке, так пакеты больше 150 байт не уходят. Кто знает, в чем может быть проблемма.
Отрывок кода:

function UDP(p : pointer) : DWORD; stdcall;
var
SocketHwnd : TSocket;
SocketAddr : TSockAddr;
sUDPPacket : string;
iSleepTime : integer;
begin
SocketHwnd := Socket(AF_INET,SOCK_DGRAM,IPPROTO_U DP);
SocketAddr.sin_family := AF_INET;
SocketAddr.sin_addr.S_addr := '192.168.1.100';
SocketAddr.sin_port := htons(5000);

.
.
// sUDPPacket < 150 bytes - отправляется
// > нет
.
.

while bGo do
begin
SendTo(SocketHwnd,sUDPPacket,Length (sUDPPacket),0,SocketAddr,SizeOf(So cketAddr));
sleep(iSleepTime);
end;
end;


// основной поток

Windows.CreateThread(nil,0,@UDP,@UD PMessage,0,UDPID);
SetThreadPriority(UDPID,THREAD_PRIO RITY_NORMAL);

Кто знает, помогите...

[raxp]

...вызывайте внешний метод отправки из потока через Synchronize().

[NewHorek]

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

[raxp]

...покажите как пробовали?

[NewHorek]

Уже перетер все. Через потомок от TThread (обычный поток в делфи)
Сейчас соорудил фун-ю
procedure M(SocketHwnd : integer; sUDPPacket : string; SocketAddr : TSockAddr);
var
i : integer;
begin
i := SendTo(SocketHwnd,sUDPPacket,Length (sUDPPacket),0,SocketAddr,SizeOf(So cketAddr));
MessageBox(0,PChar(IntToStr(i)),'', 0);
//sleep(10);
end;

Если есть sleep - пакеты уходят. Но это ведь не правильно!
Может как узнать свободность сокета?


Вопрос решил заменой sUDPPacket на динамический массив. Все заработало. Проблемму с предыдущим типом данных так и не понял....

[raxp]

...пакет не может быть неограниченной длины, да и для UDP пакеты лучше делать фиксированными и поменьше.

Насчет того, как синхронизировали, вы не показали, да и уже неактуально . Удачи.

[Aliens_wolfs]

Сейчас попробуем помочь из твоего примера

[Aliens_wolfs]

Вот накидал простенький поток из твоего примера должен работать

var
  Form1: TForm1;
  FhEvent: THandle;
  sUDPPacket: string;
  UDPID: dword;

implementation

{$R *.dfm}

function UDP(p : pointer) : DWORD; stdcall;
var
SocketHwnd : TSocket;
SocketAddr : TSockAddr;
Size : integer;
begin
//Заполняем структуру
SocketHwnd := Socket(AF_INET,SOCK_DGRAM,IPPROTO_UDP);
SocketAddr.sin_family := AF_INET;
SocketAddr.sin_addr.S_addr := inet_addr(PCHAR('192.168.1.100'));
SocketAddr.sin_port := htons(5000);

// Создаем Объект события - это что-то вpоде пеpеключателя: 
// у него есть только два состояния: вкл и выкл.
FhEvent := CreateEvent(nil, True, False, nil);

//крутим поток
while true do
begin
//ждем когда включать Объект события
WaitForSingleObject(FhEvent, INFINITE);
ResetEvent(FhEvent);
//отправляем данные
Size:= SendTo(SocketHwnd, sUDPPacket, Length(sUDPPacket), 0 , SocketAddr, SizeOf(SocketAddr));
if (Size = SOCKET_ERROR)then
break;
end;
UDPID:=0;

end;

procedure TForm1.Button1Click(Sender: TObject);
begin
//Запускаем поток если значение его ID 0
if UDPID = 0 then
begin
CreateThread(nil,0,@UDP,nil,0,UDPID);
SetThreadPriority(UDPID,THREAD_PRIORITY_NORMAL);
end;
end;

procedure TForm1.Button2Click(Sender: TObject);
begin
 //Заполняем данные для отправки
 sUDPPacket:='fff';
 // включаем объект события чтобы данные отправились
 SetEvent(FhEvent);
end;

procedure TForm1.FormCreate(Sender: TObject);
begin
UDPID:=0;
end;

// следим за потоком и делаем кнопку его запуска недоступной если он уже запущен
procedure TForm1.Timer1Timer(Sender: TObject);
begin
if UDPID = 0 then
Button1.Enabled:=true
else
Button1.Enabled:=false;
//Контроль кнопки отправления данных если поток работает то кнопка доступна
Button2.Enabled:= not Button1.Enabled;
end;

Для отправки больших данных нужно их отправлять частями и следить все ли отпавились, могу и с этим помочь
Еще можно сделать из класса TThread создать его тело и через него можно реализовать и передачу и прием данных

[NewHorek]

Спасибо за пример. Учту. Правда вопрос решил применением динамических массивов. Причем:
massiv: array of byte;
SetLength(masssiv, len);

1. SendTo(handle, masssiv[0],... -работает,

Пакеты приходят (использовал commview) , причем, длина не имеет значения (ну логично < 65535 bytes). CommView показывает один пакет = MTU, остальные как defragment ( в сумме = len ).

Не понял проблемму с типом string? Почему поток отказывается работать.
Вот этого я не вкурил

Еще 1 фишка - данные при типе string (delphi 7, без unicode) в пакете не соответстуют исходным. При динамическом массиве все ОК...
Ладно бы я понял там смещение на пару байт в string с учетом организации строк паскаля. Но ведь нет. Бред какой-то. приходит.

Предположение: Поток, организованный CreateThread и BeginThread - отличаются в работе со строками (изменения в диспетчере пямяти не в счет)

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

[raxp]

Не понял проблемму с типом string? Почему поток отказывается работать.
Вот этого я не вкурил

еще раз про длины . Cколько тип string вмещает? Если бы вы определили как string[1000], 5000, 6000, ..., скажем, еще куда не шло.