VPF::waveInOpen & сообщение к потоку - Форум программистов

Aeore

Дата 14.5.2010, 10:58 (ссылка)

(нет голосов)

Загрузка ...

Новичок

Профиль
Группа: Участник
Сообщений: 25
Регистрация: 21.4.2007

Репутация: нет
Всего: нет

Пишу библиотеку DLL для звуковой связи по tcp/ip сети. Для передачи звука принял решение использовать поток, на ThreadID которого будут приходить сообщения с данными от ОС. Проблема в следующем: у меня происходит запуск потока в Suspended (т.е. остановленном режиме), потом вызов waveInOpen, затем идет подготовка буферов и, собственно, запуск потока. В потоке в цикле стоит GetMessage(), который принимает сообщение и работает с ним дальше. Проблема в том, что после запуска потока сообщение не принимается (GetMessage() уходит в вечное ожидание), но если поток сразу делать запущеным, то сообщения приходят. Отсюда вопрос -- возможен ли прием (в очередь) сообщений suspended-потоком и если нет, то как такого добиться? И правильно ли я понял источник проблемы ? Я понимаю, что открытие аудио-устройства можно делать прямо в потоке, но пока хотелось бы написать именно так как я описал выше.

функция инициализации (вызывается один раз при запуске программы)

Код


function SAS_InitTransmitter(DeviceID: Integer): Integer;
var
  WaveFormat: TWaveFormatEx;
  I: Integer;
begin
  ...
  AudioOutputDevice := DeviceID;

  TransmitterThread := TAudioTransmitter.Create; // Создаем поток

  with WaveFormat do begin
    wFormatTag := WAVE_FORMAT_PCM;
    nChannels := 1;
    wBitsPerSample := 16;
    nBlockAlign := nChannels * wBitsPerSample div 8;
    nSamplesPerSec := 8000;
    nAvgBytesPerSec := nSamplesPerSec * nBlockAlign;
    cbSize := 0;
  end;

  InDevHandle := 0;
  Result := ifx(waveInOpen(@InDevHandle, AudioOutputDevice, @WaveFormat, TransmitterThread.ThreadID, 0, CALLBACK_THREAD) = MMSYSERR_NOERROR, SAS_E_FAIL, SAS_E_SUCCESS);
  if Result = SAS_E_FAIL then Exit;

  // Готовим CWAVEBUFFERSCOUNT буферов передатчика, размером с фрейм кодирования (20 мс)
  for I := 0 to High(TXBuffers) do begin
    SetLength(inBuffs[I], encframe);
    with TXBuffers[I] do begin
      lpData := @inBuffs[I, 0];
      dwBufferLength := Length(inBuffs[I]) * SizeOf(inBuffs[I, 0]);
      dwBytesRecorded := 0;
      dwUser := I;  // Порядковый номер буфера
      dwLoops := 0;
      Result := ifx(waveInPrepareHeader(InDevHandle, @TXBuffers[I], SizeOf(TWAVEHDR)) = MMSYSERR_NOERROR, SAS_E_FAIL, SAS_E_SUCCESS);
      if Result = SAS_E_FAIL then Exit;
    end;
  end;

  if Result = SAS_E_SUCCESS then begin
    TransmitterThread.Resume; // Запускаем поток!!
    TXInit := True;
  end else
    TransmitterThread.Free;
end;

поток:

Код


constructor TAudioTransmitter.Create;
begin
  inherited Create(True); // Если False, то сообщение принимается
  Priority := tpNormal;
  FreeOnTerminate := False;
  GetMem(payload, 8000);
  PeekMessage(Msg, 0, 0, 0, PM_REMOVE);
end;

destructor TAudioTransmitter.Destroy;
begin
  PostThreadMessage(ThreadID, WM_QUIT, 0, 0);
  FreeMem(payload);
  inherited;
end;

procedure TAudioTransmitter.Execute;
var
  I, enc_size, BuffNo, total_pl, frames: Integer;
  AudioData: TSAS_MSG_AUDIODATA;
begin
  ..
  while not Terminated do begin
    ..

    if GetMessage(Msg, 0, 0, 0) then begin
      case Msg.message of
        MM_WIM_OPEN:
          begin
            ...
          end;

        MM_WIM_DATA:
          begin
            ...

            waveInAddBuffer(InDevHandle, PWAVEHDR(Msg.lParam), SizeOf(TWAVEHDR));
          end;
      end;
    end;

  end;
end;

0 Пользователей читают эту тему (0 Гостей и 0 Скрытых Пользователей)
0 Пользователей:
« Предыдущая тема \| Delphi: Звук, графика и видео \| Следующая тема »