Передать звук на несколько хостов

[Programmer0]

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

[Programmer0]

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

И еще 2 программки с жатием GSM, нагрузка на сеть уменьшилась, качество вроде не потерянно, но есть небольшая задержка.

За GSM отдельно большое спасибо! Ещё не смотрел. Но как раз при увеличении хостов будет в тему. Спасибо!

[Aliens_wolfs]

)) Зачем дублировать функцию потока вы можете все в одной функции создавать. Сейчас напишу как

type
  TForm1 = class(TForm)
    Button1: TButton;
    procedure Button1Click(Sender: TObject);
    procedure FormCreate(Sender: TObject);
    procedure FormDestroy(Sender: TObject);
  private
  procedure OnWaveMessage(var msg:TMessage); message MM_WIM_DATA;
  public
    { Public declarations }
  end;

//Задаем тип структуре передающих UDP
  type
    PParamUDP = ^TParamUDP;
    TParamUDP = record
    hWorkUDPThead: Dword; // Хендел потока
    Host: String; // Хост для передачи
    Port: Integer; // Порт для передачи
    SendMemoryStream: TMemoryStream; // Задаем для каждого UDP свой передающий буфер иначе если общий то у некоторых будет глотание звука так как очищается после передачи
    end;

var
  Form1: TForm1;
  ParamUDPArray: array[0..99] of TParamUDP; // Структура UDP передатчиков но это статически созданные, можно конечно создавать отдельно каждого

   waveformat: TWAVEFORMATEX;
  Wavein: HWAVEIN;
  WaveHdr:array [0..buff_count-1] of TWaveHdr;
  bufsize:Cardinal;
  bytes:integer;
  n:integer;
  fstop:boolean;


implementation

{$R *.dfm}


function WorkUDPThead(Param: Pointer): Integer;
var
  IdUDPClient: TIdUDPClient;
begin
try
  IdUDPClient:= TIdUDPClient.Create(nil);
  PParamUDP(Param).SendMemoryStream:= TMemoryStream.Create;

    IdUDPClient.BufferSize:= Bufsize;
    IdUDPClient.Host:=PParamUDP(Param).Host;
    IdUDPClient.Port:= PParamUDP(Param).Port;

  IdUDPClient.Active:= true;
  PParamUDP(Param).Started:= true;

while PParamUDP(Param).Started do
begin
if PParamUDP(Param)^.SendMemoryStream.Size > 0 then
begin
PParamUDP(Param).SendMemoryStream.Position:= 0;
idUDPClient.Sendbuffer(PParamUDP(Param).SendMemoryStream.Memory^, PParamUDP(Param).SendMemoryStream.Size);
PParamUDP(Param).SendMemoryStream.Clear;
end
else
sleep(1);
end;
     finally
 IdUDPClient.Free;
 PParamUDP(Param).SendMemoryStream.Destroy;
 PParamUDP(Param).SendMemoryStream:= nil;
 CloseHandle(PParamUDP(Param).hWorkUDPThead);
 fillChar(PParamUDP(Param)^, SizeOf(TParamUDP), 0);
  endthread(0);
  end;
end;

//Останавливаем все потоки
procedure StopUDP;
var
  i: Integer;
begin
  for i:= 0 to Length(ParamUDPArray) -1 do
   ParamUDPArray[i].Started:= false;
  end;

procedure TForm1.OnWaveMessage(var msg:TMessage);
var
  i: integer;
begin
    if not fstop then begin
        if n=buff_count then
          n:=0;
        for i:= 0 to Length(ParamUDPArray) -1 do
        if ParamUDPArray[i].SendMemoryStream <> nil then
        ParamUDPArray[i].SendMemoryStream.Write(WaveHdr[n].lpData^,WaveHdr[n].dwBufferLength);
        waveInPrepareHeader(waveIn,@WaveHdr[n],sizeof(Twavehdr));
        waveInAddBuffer(wavein,@WaveHdr[n],sizeof(TwaveHdr));
        UpDate;
        inc(n);
        end;
end;

procedure TForm1.Button1Click(Sender: TObject);
var
i: integer;
    ThId: Dword;
begin
    If button1.Caption='Начать отправку' then
    begin
        n:=0;
        fstop:=false;
       //Задаем первый хост
        ParamUDPArray[0].Host:= '169.254.233.61';
        ParamUDPArray[0].Port:= 10090 ;
        ParamUDPArray[0].hWorkUDPThead:= BeginThread(nil, 0, @WorkUDPThead, @ParamUDPArray[0], 0, ThId);
     //Задаем второй хост
        ParamUDPArray[1].Host:= '169.254.124.227';
        ParamUDPArray[1].Port:= 10090 ;
        ParamUDPArray[1].hWorkUDPThead:= BeginThread(nil, 0, @WorkUDPThead, @ParamUDPArray[1], 0, ThId);
// и так далее но можно и с внешнего файла хосты грузить

        button1.Caption:='Остановить отправку';
        for i:=0 to buff_count-1 do begin
            waveInPrepareHeader(waveIn,@WaveHdr[i],sizeof(Twavehdr));
            waveInAddBuffer(wavein,@WaveHdr[i],sizeof(TwaveHdr));
            end;
        waveInStart(waveIn);
        end
    else
        begin
        fstop:=true;
        button1.Caption:='Начать отправку';
        StopUDP;
        for i:=0 to buff_count-1 do
        waveInUnprepareHeader(Wavein,@WaveHdr[i],sizeof(TwaveHdr));
        waveInStop(Wavein);
        end;
end;


procedure TForm1.FormCreate(Sender: TObject);
var
    i:integer;
begin
    with waveformat do begin
        nChannels:=1;
        wFormatTag:=WAVE_FORMAT_PCM;
        nSamplesPerSec:=sampleRate;
        wBitsPerSample:=16;
        nBlockAlign:=nChannels * wBitsPerSample div 8;
        nAvgBytesPerSec:=sampleRate * nChannels * wBitsPerSample div 8;
        cbSize:=0;
        end;
    bufsize:=waveformat.nAvgBytesPerSec*2 div 16;

    waveInOpen(@Wavein,WAVE_MAPPER,addr(waveformat),self.Handle,0,CALLBACK_WINDOW);
    for i:=0 to buff_count-1 do begin
        WaveHdr[i].lpData:=Pchar(GlobalAlloc(GMEM_FIXED, bufsize));
        WaveHdr[i].dwBufferLength:=bufsize;
        WaveHdr[i].dwFlags:=0;
        end;
end;

procedure TForm1.FormDestroy(Sender: TObject);
begin
  StopUDP;
    Sleep(1000); //небольшая пауза для завершения потоков
    waveInClose(Wavein);
end;

[Aliens_wolfs]

до 100 потоков но можно и увеличить в глобальном параметре то что выше ParamUDPArray: array[0..99] of TParamUDP
Либо можно с внешнего текстового файла список хостов грузить если хотите могу показать

[Programmer0]

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

)) Зачем дублировать функцию потока вы можете все в одной функции создавать. Сейчас напишу как

Да, так гораздо красивее. Спасибо.

[Programmer0]

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

до 100 потоков но можно и увеличить в глобальном параметре то что выше ParamUDPArray: array[0..99] of TParamUDP
Либо можно с внешнего текстового файла список хостов грузить если хотите могу показать

Хочу Если не трудно.

[Aliens_wolfs]

Работа с файлом хостов, вот та часть кода в Button1Click где нужно сделать изменения, остальной код остается преждним, предварительно создайте текстовый файл в папке с проектом HostSend.txt
и впишите в него строки примерно такие:
127.0.0.1:10090
169.254.233.61:10090
169.254.124.227:10090
и т.д. в том же виде

// Новая функция разбора ip и порта из строки хоста
function ExtractHostPort(const S: string; out Host: String; out Port: DWord): Boolean;
var
  i, e: Integer;
begin
 Result := False;
  i := Pos(':', S);
  if (i > 0) then
  begin
    Host := Copy(S, 1, i - 1);
    if pos('.', Host)<>0 then
    begin
    val(Copy(S, i + 1, Length(S)), Port, e);
    Result := True;
   end;
  end;
end;

// Ну и наша кнопка запуска передачи
procedure TForm1.Button1Click(Sender: TObject);
var
ThId: Dword;
i: integer;
Host: String;
Port: DWord;
begin
    If button1.Caption='Начать отправку' then
    begin
        n:=0;
        fstop:=false;

// Работаем с файлом хостов
    With TStringList.Create do
    begin
       LoadFromFile(ExtractFilePath(Application.ExeName) + '\HostSend.txt');
       For i:= 0 to Count -1 do
// применяем нашу новую функцию по разбору строки хоста
       if  ExtractHostPort(Strings[i], Host, Port) then
       begin
       ParamUDPArray[i].Host:= Host;
       ParamUDPArray[i].Port:= Port;
       ParamUDPArray[i].hWorkUDPThead:= BeginThread(nil, 0, @WorkUDPThead, @ParamUDPArray[i], 0, ThId);
        end;
    free;
end;
        button1.Caption:='Остановить отправку';
        for i:=0 to buff_count-1 do begin
            waveInPrepareHeader(waveIn,@WaveHdr[i],sizeof(Twavehdr));
            waveInAddBuffer(wavein,@WaveHdr[i],sizeof(TwaveHdr));
            end;
        waveInStart(waveIn);
        end
    else
        begin
        fstop:=true;
        button1.Caption:='Начать отправку';
        StopUDP;
        for i:=0 to buff_count-1 do
        waveInUnprepareHeader(Wavein,@WaveHdr[i],sizeof(TwaveHdr));
        waveInStop(Wavein);
        end;
end;

[Programmer0]

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

Работа с файлом хостов

Спасибо большое! В строке

ParamUDPArray[i].hWorkUDPThead:= BeginThread(nil, 0, @WorkUDPThead, @ParamUDPArray[1], 0, ThId);

надо i вместо 1

ParamUDPArray[i].hWorkUDPThead:= BeginThread(nil, 0, @WorkUDPThead, @ParamUDPArray[i], 0, ThId);

и все отлично.

[Aliens_wolfs]

А да поторопился не заметил, все исправил)

[Programmer0]

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

А да поторопился не заметил, исправил)

А вы не подскажите в следующем вопросе. Нужно звук с левого канала линейного входа передавать на одну группу хостов, а с правого - на другую. Пытаюсь делать так(пока для двух хостов):

procedure TForm1.OnWaveMessage(var msg:TMessage);
var
  buffer_L:      Pointer;
  buffer_R:      Pointer;
  psample:      PChar;
  psample_L:    PChar;
  psample_R:    PChar;
  len: cardinal;
  i:integer;
begin
    if not fstop then begin
        if n=buff_count then
          n:=0;
        len:=WaveHdr[n].dwBufferLength div 2;
        buffer_L:=allocmem(len);
        buffer_R:=allocmem(len);
        psample:=WaveHdr[n].lpData;
        psample_L:=buffer_L;
        psample_R:=buffer_R;
        for i:=0 to len div 2-1 do
            Begin
            psample_L^:=psample^;
            inc(psample);
            inc(psample_L);
            psample_R^:=psample^;
            inc(psample);
            inc(psample_R);
            end;

        ParamUDPArray[0].SendMemoryStream.Write(buffer_L^, len);
        ParamUDPArray[1].SendMemoryStream.Write(buffer_R^, len);
        freemem(buffer_L);
        freemem(buffer_R);

        waveInPrepareHeader(waveIn,@WaveHdr[n],sizeof(Twavehdr));
        waveInAddBuffer(wavein,@WaveHdr[n],sizeof(TwaveHdr));
        inc(n);
        end;
end;

В настройках записи ставлю 2 канала:

with waveformat do begin
        nChannels:=2;
        wFormatTag:=WAVE_FORMAT_PCM;
        nSamplesPerSec:=sampleRate;
        wBitsPerSample:=8;
        nBlockAlign:=nChannels * wBitsPerSample div 8;
        nAvgBytesPerSec:=sampleRate * nBlockAlign;
        cbSize:=0;
        end;
    bufsize:=waveformat.nAvgBytesPerSec*2 div 8;

В принимающей проге - один канал, остальные настройки те же.

В результате звук воспроизводиться с прерываниями. Что не так?