#37271 サウンドのミキシングをマルチスレッド化するライブラリを使おうとしたが、うまく動かなかった実装を、注釈でなく#ifdefに入れ込んだ。後日じっくり対応し直す。

diff --git a/FDK/FDK.csproj b/FDK/FDK.csproj
index 12d621d..d228ac2 100644 (file)
--- a/FDK/FDK.csproj
+++ b/FDK/FDK.csproj
@@ -47,7 +47,7 @@
     </DocumentationFile>
     <UseVSHostingProcess>false</UseVSHostingProcess>
     <NoWarn>0219</NoWarn>
-    <DefineConstants>TRACE;DEBUG;TEST_CancelEnterCodeInAltEnter2 TEST_Direct3D9Ex_ TEST_MulthThreadedMixer_</DefineConstants>
+    <DefineConstants>TRACE;DEBUG;TEST_CancelEnterCodeInAltEnter2 TEST_Direct3D9Ex_ TEST_MultiThreadedMixer_</DefineConstants>
     <Optimize>false</Optimize>
     <Prefer32Bit>false</Prefer32Bit>
   </PropertyGroup>

diff --git a/FDK/コード/03.サウンド/CSound.cs b/FDK/コード/03.サウンド/CSound.cs
index a1620f5..387cb02 100644 (file)
--- a/FDK/コード/03.サウンド/CSound.cs
+++ b/FDK/コード/03.サウンド/CSound.cs
@@ -1769,7 +1769,7 @@ Debug.WriteLine("更に再生に失敗: " + Path.GetFileName(this.strファイ
                        _hTempoStream = 0;
                        if ( CSound管理.bIsTimeStretch )      // TimeStretchのON/OFFに関わりなく、テンポ変更のストリームを生成する。後からON/OFF切り替え可能とするため。
                                                                                                // ... と思ったが、1サウンド辺り1つのテンポ変更ストリームが存在することになり、
-                                                                                               // ミキシング負荷が非常に高くなるため、結局TimeStretch=ONの時のみ店舗変更ストリームを提供することにした。
+                                                                                               // ミキシング負荷が非常に高くなるため、結局TimeStretch=ONの時のみテンポ変更ストリームを提供することにした。
                        {
                                this._hTempoStream = BassFx.BASS_FX_TempoCreate(this._hBassStream, BASSFlag.BASS_STREAM_DECODE | BASSFlag.BASS_FX_FREESOURCE);
                                if (this._hTempoStream == 0)
@@ -1852,9 +1852,12 @@ Debug.WriteLine("更に再生に失敗: " + Path.GetFileName(this.strファイ
                }
                public bool tBASSサウンドをミキサーから削除する( int channel )
                {
-//bool b = BASSThreadedMixerLibraryWrapper.BASS_ThreadedMixer_RemoveSource((IntPtr)this.hMixer, channel );
-//mixingChannel.Remove((IntPtr)this.hMixer);
+#if TEST_MultiThreadedMixer
+                       bool b = BASSThreadedMixerLibraryWrapper.BASS_ThreadedMixer_RemoveSource((IntPtr)this.hMixer, channel );
+                       mixingChannel.Remove((IntPtr)this.hMixer);
+#else
                        bool b = BassMix.BASS_Mixer_ChannelRemove(channel);
+#endif
                        if ( b )
                        {
                                Interlocked.Decrement( ref CSound管理.nMixing );
@@ -1865,13 +1868,17 @@ Debug.WriteLine("更に再生に失敗: " + Path.GetFileName(this.strファイ
 
 
                // mixer への追加
-
-//private List<IntPtr> mixingChannel = new List<IntPtr>();
+#if TEST_MultiThreadedMixer
+               private List<IntPtr> mixingChannel = new List<IntPtr>();
+#endif
 
                public bool tBASSサウンドをミキサーに追加する()
                {
-//if (!mixingChannel.Contains((IntPtr)this.hMixer))
+#if TEST_MultiThreadedMixer
+                       if (!mixingChannel.Contains((IntPtr)this.hMixer))
+#else
                        if ( BassMix.BASS_Mixer_ChannelGetMixer( hBassStream ) == 0 )
+#endif
                        {
                                BASSFlag bf = BASSFlag.BASS_SPEAKER_FRONT | BASSFlag.BASS_MIXER_NORAMPIN | BASSFlag.BASS_MIXER_PAUSE;
                                Interlocked.Increment( ref CSound管理.nMixing );
@@ -1879,9 +1886,12 @@ Debug.WriteLine("更に再生に失敗: " + Path.GetFileName(this.strファイ
                                // preloadされることを期待して、敢えてflagからはBASS_MIXER_PAUSEを外してAddChannelした上で、すぐにPAUSEする
                                // -> ChannelUpdateでprebufferできることが分かったため、BASS_MIXER_PAUSEを使用することにした
 
-//bool b1 = BASSThreadedMixerLibraryWrapper.BASS_ThreadedMixer_AddSource( (IntPtr)this.hMixer, this.hBassStream, IntPtr.Zero );
-//mixingChannel.Add((IntPtr)this.hMixer);
+#if TEST_MultiThreadedMixer
+                               bool b1 = BASSThreadedMixerLibraryWrapper.BASS_ThreadedMixer_AddSource( (IntPtr)this.hMixer, this.hBassStream, IntPtr.Zero );
+                               mixingChannel.Add((IntPtr)this.hMixer);
+#else
                                bool b1 = BassMix.BASS_Mixer_StreamAddChannel(this.hMixer, this.hBassStream, bf);
+#endif
                                //bool b2 = BassMix.BASS_Mixer_ChannelPause( this.hBassStream );
                                t再生位置を先頭に戻す();      // StreamAddChannelの後で再生位置を戻さないとダメ。逆だと再生位置が変わらない。
 //Trace.TraceInformation( "Add Mixer: " + Path.GetFileName( this.strファイル名 ) + " (" + hBassStream + ")" + " MixedStreams=" + CSound管理.nMixing );
@@ -1891,7 +1901,7 @@ Debug.WriteLine("更に再生に失敗: " + Path.GetFileName(this.strファイ
                        return true;
                }
 
-               #region [ tオンメモリ方式でデコードする() ]
+#region [ tオンメモリ方式でデコードする() ]
                public void tオンメモリ方式でデコードする( string strファイル名, out byte[] buffer,
                        out int nPCMデータの先頭インデックス, out int totalPCMSize, out CWin32.WAVEFORMATEX wfx,
                        bool bIntegrateWaveHeader )
@@ -2004,7 +2014,7 @@ Debug.WriteLine("更に再生に失敗: " + Path.GetFileName(this.strファイ
                                sounddecoder = null;
                        }
                }
-               #endregion
-               #endregion
+#endregion
+#endregion
        }
 }

diff --git a/FDK/コード/03.サウンド/CSoundDeviceWASAPI.cs b/FDK/コード/03.サウンド/CSoundDeviceWASAPI.cs
index 7402846..3d08561 100644 (file)
--- a/FDK/コード/03.サウンド/CSoundDeviceWASAPI.cs
+++ b/FDK/コード/03.サウンド/CSoundDeviceWASAPI.cs
@@ -435,10 +435,10 @@ Trace.TraceInformation("WASAPI Device #{0}: {1}: IsDefault={2}, defPeriod={3}s,
                                //-----------------
                                #endregion
                        }
-
-//LoadLibraryに失敗する・・・
-//BASSThreadedMixerLibraryWrapper.InitBASSThreadedMixerLibrary();
-
+#if TEST_MultiThreadedMixer
+                       //LoadLibraryに失敗する・・・
+                       //BASSThreadedMixerLibraryWrapper.InitBASSThreadedMixerLibrary();
+#endif
 
 
                        // WASAPI出力と同じフォーマットを持つ BASS ミキサーを作成。
@@ -448,18 +448,20 @@ Trace.TraceInformation("WASAPI Device #{0}: {1}: IsDefault={2}, defPeriod={3}s,
                        //      string.Format( "BASS_SetConfig(CONFIG_MIXER_BUFFER) に失敗しました。[{0}", Bass.BASS_ErrorGetCode() ) );
 
                        var info = BassWasapi.BASS_WASAPI_GetInfo();
-//this.hMixer = BASSThreadedMixerLibraryWrapper.BASS_ThreadedMixer_Create(
-//                             info.freq,
-//                             info.chans,
-//                             (int)(BASSFlag.BASS_MIXER_NONSTOP | BASSFlag.BASS_SAMPLE_FLOAT | BASSFlag.BASS_STREAM_DECODE | BASSFlag.BASS_MIXER_POSEX),
-//                             out hMixerThreaded
-//                     );
-
+#if TEST_MultiThreadedMixer
+                       this.hMixer = BASSThreadedMixerLibraryWrapper.BASS_ThreadedMixer_Create(
+                               info.freq,
+                               info.chans,
+                               (int)(BASSFlag.BASS_MIXER_NONSTOP | BASSFlag.BASS_SAMPLE_FLOAT | BASSFlag.BASS_STREAM_DECODE | BASSFlag.BASS_MIXER_POSEX),
+                               out hMixerThreaded
+                       );
+#else
                        this.hMixer = BassMix.BASS_Mixer_StreamCreate(
                                info.freq,
                                info.chans,
                                BASSFlag.BASS_MIXER_NONSTOP | BASSFlag.BASS_SAMPLE_FLOAT | BASSFlag.BASS_STREAM_DECODE | BASSFlag.BASS_MIXER_POSEX);    // デコードのみ＝発声しない。WASAPIに出力されるだけ。
-                       if ( this.hMixer == 0 )
+#endif
+                       if (this.hMixer == 0 )
                        {
                                BASSError errcode = Bass.BASS_ErrorGetCode();
                                BassWasapi.BASS_WASAPI_Free();
@@ -471,16 +473,19 @@ Trace.TraceInformation("WASAPI Device #{0}: {1}: IsDefault={2}, defPeriod={3}s,
 
                        for (int i = 0; i <= (int)CSound.EInstType.Unknown; i++)
                        {
-//this.hMixer_Chips[i] = BASSThreadedMixerLibraryWrapper.BASS_ThreadedMixer_Create(
-//     info.freq,
-//     info.chans,
-//     (int)(BASSFlag.BASS_MIXER_NONSTOP | BASSFlag.BASS_SAMPLE_FLOAT | BASSFlag.BASS_STREAM_DECODE | BASSFlag.BASS_MIXER_POSEX),
-//     out this.hMixerThreaded_Chips[i]
-//);    // デコードのみ＝発声しない。WASAPIに出力されるだけ。
+#if TEST_MultiThreadedMixer
+                               this.hMixer_Chips[i] = BASSThreadedMixerLibraryWrapper.BASS_ThreadedMixer_Create(
+                                       info.freq,
+                                       info.chans,
+                                       (int)(BASSFlag.BASS_MIXER_NONSTOP | BASSFlag.BASS_SAMPLE_FLOAT | BASSFlag.BASS_STREAM_DECODE | BASSFlag.BASS_MIXER_POSEX),
+                                       out this.hMixerThreaded_Chips[i]
+                               );    // デコードのみ＝発声しない。WASAPIに出力されるだけ。
+#else
                                this.hMixer_Chips[ i ] = BassMix.BASS_Mixer_StreamCreate(
                                        info.freq,
                                        info.chans,
                                        BASSFlag.BASS_MIXER_NONSTOP | BASSFlag.BASS_SAMPLE_FLOAT | BASSFlag.BASS_STREAM_DECODE | BASSFlag.BASS_MIXER_POSEX);    // デコードのみ＝発声しない。WASAPIに出力されるだけ。
+#endif
                                if (this.hMixer_Chips[ i ] == 0)
                                {
                                        BASSError errcode = Bass.BASS_ErrorGetCode();
@@ -494,8 +499,11 @@ Trace.TraceInformation("WASAPI Device #{0}: {1}: IsDefault={2}, defPeriod={3}s,
                                Bass.BASS_ChannelSetAttribute(this.hMixer_Chips[i], BASSAttribute.BASS_ATTRIB_VOL, CSound管理.nMixerVolume[i] / 100.0f);
                                //Trace.TraceInformation("Vol{0}: {1}", i, CSound管理.nMixerVolume[i]);
 
-//bool b1 = BASSThreadedMixerLibraryWrapper.BASS_ThreadedMixer_AddSource(this.hMixerThreaded, this.hMixer_Chips[i], IntPtr.Zero);
+#if TEST_MultiThreadedMixer
+                               bool b1 = BASSThreadedMixerLibraryWrapper.BASS_ThreadedMixer_AddSource(this.hMixerThreaded, this.hMixer_Chips[i], IntPtr.Zero);
+#else
                                bool b1 = BassMix.BASS_Mixer_StreamAddChannel(this.hMixer, this.hMixer_Chips[i], BASSFlag.BASS_DEFAULT);
+#endif
                                if (!b1)
                                {
                                        BASSError errcode = Bass.BASS_ErrorGetCode();
@@ -596,20 +604,20 @@ Trace.TraceInformation("WASAPI Device #{0}: {1}: IsDefault={2}, defPeriod={3}s,
                        BassWasapi.BASS_WASAPI_Start();
                }
 
-               #region [録音開始]
+#region [録音開始]
                public bool tStartRecording()
                {
                        return encoder.Pause(false);
                }
-               #endregion
-               #region [録音終了]
+#endregion
+#region [録音終了]
                public bool tStopRecording()
                {
                        return encoder.Stop(true);
                }
-               #endregion
+#endregion
 
-               #region [ tサウンドを作成する() ]
+#region [ tサウンドを作成する() ]
                public CSound tサウンドを作成する(string strファイル名)
                {
                        return tサウンドを作成する( strファイル名, CSound.EInstType.Unknown );
@@ -617,8 +625,11 @@ Trace.TraceInformation("WASAPI Device #{0}: {1}: IsDefault={2}, defPeriod={3}s,
                public CSound tサウンドを作成する( string strファイル名, CSound.EInstType eInstType )
                {
                        var sound = new CSound();
-//int hmixer = (int)hMixerThreaded_Chips[ (int)eInstType ];
+#if TEST_MultiThreadedMixer
+                       int hmixer = (int)hMixerThreaded_Chips[ (int)eInstType ];
+#else
                        int hmixer = hMixer_Chips[(int)eInstType];
+#endif
                        sound.tWASAPIサウンドを作成する( strファイル名, hmixer, this.e出力デバイス, eInstType );
                        return sound;
                }
@@ -629,26 +640,35 @@ Trace.TraceInformation("WASAPI Device #{0}: {1}: IsDefault={2}, defPeriod={3}s,
                public CSound tサウンドを作成する( byte[] byArrWAVファイルイメージ, CSound.EInstType eInstType )
                {
                        var sound = new CSound();
-//int hmixer = (int)hMixerThreaded_Chips[(int)eInstType];
+#if TEST_MultiThreadedMixer
+                       int hmixer = (int)hMixerThreaded_Chips[(int)eInstType];
+#else
                        int hmixer = hMixer_Chips[(int)eInstType];
+#endif
                        sound.tWASAPIサウンドを作成する( byArrWAVファイルイメージ, hmixer, this.e出力デバイス, eInstType );
                        return sound;
                }
                public void tサウンドを作成する( string strファイル名, ref CSound sound, CSound.EInstType eInstType )
                {
-//int hmixer = (int)hMixerThreaded_Chips[(int)eInstType];
+#if TEST_MultiThreadedMixer
+                       int hmixer = (int)hMixerThreaded_Chips[(int)eInstType];
+#else
                        int hmixer = hMixer_Chips[(int)eInstType];
+#endif
                        sound.tWASAPIサウンドを作成する( strファイル名, hmixer, this.e出力デバイス, eInstType );
                }
                public void tサウンドを作成する( byte[] byArrWAVファイルイメージ, ref CSound sound, CSound.EInstType eInstType)
                {
-//int hmixer = (int)hMixerThreaded_Chips[(int)eInstType];
+#if TEST_MultiThreadedMixer
+                       int hmixer = (int)hMixerThreaded_Chips[(int)eInstType];
+#else
                        int hmixer = hMixer_Chips[(int)eInstType];
+#endif
                        sound.tWASAPIサウンドを作成する( byArrWAVファイルイメージ, hmixer, this.e出力デバイス, eInstType );
                }
-               #endregion
+#endregion
 
-               #region [ Dispose-Finallizeパターン実装 ]
+#region [ Dispose-Finallizeパターン実装 ]
                //-----------------
                public void Dispose()
                {
@@ -697,7 +717,9 @@ Trace.TraceInformation("WASAPI Device #{0}: {1}: IsDefault={2}, defPeriod={3}s,
                                        }
                                }
                        }
-//BASSThreadedMixerLibraryWrapper.FreeBASSThreadedMixerLibrary();
+#if TEST_MultiThreadedMixer
+                       //BASSThreadedMixerLibraryWrapper.FreeBASSThreadedMixerLibrary();               
+#endif
 
                        if ( !this.bIsBASSFree )
                        {
@@ -715,16 +737,17 @@ Trace.TraceInformation("WASAPI Device #{0}: {1}: IsDefault={2}, defPeriod={3}s,
                        this.Dispose( false );
                }
                //-----------------
-               #endregion
+#endregion
 
                protected int hMixer = 0;
                protected int hMixer_DeviceOut = 0;
                protected int hMixer_Record = 0;
                protected int[] hMixer_Chips = new int[(int)CSound.EInstType.Unknown + 1];  //DTX2WAV対応 BGM, SE, Drums...を別々のmixerに入れて、個別に音量変更できるようにする
 
-//protected IntPtr hMixerThreaded = IntPtr.Zero;
-//protected IntPtr[] hMixerThreaded_Chips = new IntPtr[(int)CSound.EInstType.Unknown + 1];
-
+#if TEST_MultiThreadedMixer
+               protected IntPtr hMixerThreaded = IntPtr.Zero;
+               protected IntPtr[] hMixerThreaded_Chips = new IntPtr[(int)CSound.EInstType.Unknown + 1];
+#endif
                protected BaseEncoder encoder;
                protected int stream;
                protected WASAPIPROC tWasapiProc = null;