2 using System.Collections.Generic;
\r
4 using System.Diagnostics;
\r
5 using System.Runtime.InteropServices;
\r
7 using System.Threading;
\r
8 using System.Runtime.Serialization.Formatters.Binary;
\r
10 using SlimDX.Direct3D9;
\r
12 using SampleFramework;
\r
16 internal class CEnumSongs // #27060 2011.2.7 yyagi 曲リストを取得するクラス
\r
17 { // ファイルキャッシュ(songslist.db)からの取得と、ディスクからの取得を、この一つのクラスに集約。
\r
18 public CSongs管理 Songs管理 // 曲の探索結果はこのSongs管理に読み込まれる
\r
24 public bool IsSongListEnumCompletelyDone // 曲リスト探索と、実際の曲リストへの反映が完了した?
\r
28 return ( this.state == DTXEnumState.CompletelyDone );
\r
31 public bool IsEnumerating
\r
35 if ( thDTXFileEnumerate == null )
\r
39 return thDTXFileEnumerate.IsAlive;
\r
42 public bool IsSongListEnumerated // 曲リスト探索が完了したが、実際の曲リストへの反映はまだ?
\r
46 return ( this.state == DTXEnumState.Enumeratad );
\r
49 public bool IsSongListEnumStarted // 曲リスト探索開始後?(探索完了も含む)
\r
53 return ( this.state != DTXEnumState.None );
\r
56 public void SongListEnumCompletelyDone()
\r
58 this.state = DTXEnumState.CompletelyDone;
\r
59 this.Songs管理 = null; // GCはOSに任せる
\r
61 public bool IsSlowdown // #PREMOVIE再生中は検索負荷を落とす
\r
65 return this.Songs管理.bIsSlowdown;
\r
69 this.Songs管理.bIsSlowdown = value;
\r
73 public void ChangeEnumeratePriority( ThreadPriority tp )
\r
75 if ( this.thDTXFileEnumerate != null && this.thDTXFileEnumerate.IsAlive == true )
\r
77 this.thDTXFileEnumerate.Priority = tp;
\r
80 private readonly string strPathSongsDB = CDTXMania.app.strEXEのあるフォルダ + "songs.db";
\r
81 private readonly string strPathSongList = CDTXMania.app.strEXEのあるフォルダ + "songlist.db";
\r
83 public Thread thDTXFileEnumerate
\r
88 private enum DTXEnumState
\r
93 Enumeratad, // 探索完了、現在の曲リストに未反映
\r
94 CompletelyDone // 探索完了、現在の曲リストに反映完了
\r
96 private DTXEnumState state = DTXEnumState.None;
\r
102 public CEnumSongs()
\r
104 this.Songs管理 = new CSongs管理();
\r
107 public void Init( List<Cスコア> ls, int n )
\r
109 if ( state == DTXEnumState.None )
\r
111 this.Songs管理.listSongsDB = ls;
\r
112 this.Songs管理.nSongsDBから取得できたスコア数 = n;
\r
117 /// 曲リストのキャッシュ(songlist.db)取得スレッドの開始
\r
119 public void StartEnumFromCache()
\r
121 this.thDTXFileEnumerate = new Thread( new ThreadStart( this.t曲リストの構築1 ) );
\r
122 this.thDTXFileEnumerate.Name = "曲リストの構築";
\r
123 this.thDTXFileEnumerate.IsBackground = true;
\r
124 this.thDTXFileEnumerate.Start();
\r
130 public delegate void AsyncDelegate();
\r
135 public void StartEnumFromDisk()
\r
137 if ( state == DTXEnumState.None || state == DTXEnumState.CompletelyDone )
\r
139 Trace.TraceInformation( "★曲データ検索スレッドを起動しました。" );
\r
142 state = DTXEnumState.Ongoing;
\r
144 // this.autoReset = new AutoResetEvent( true );
\r
146 if ( this.Songs管理 == null ) // Enumerating Songs完了後、CONFIG画面から再スキャンしたときにこうなる
\r
148 this.Songs管理 = new CSongs管理();
\r
150 this.thDTXFileEnumerate = new Thread( new ThreadStart( this.t曲リストの構築2 ) );
\r
151 this.thDTXFileEnumerate.Name = "曲リストの構築";
\r
152 this.thDTXFileEnumerate.IsBackground = true;
\r
153 this.thDTXFileEnumerate.Priority = System.Threading.ThreadPriority.Lowest;
\r
154 this.thDTXFileEnumerate.Start();
\r
162 public void Suspend()
\r
164 if ( this.state != DTXEnumState.CompletelyDone &&
\r
165 ( ( thDTXFileEnumerate.ThreadState & ( System.Threading.ThreadState.Background ) ) != 0 ) )
\r
167 // this.thDTXFileEnumerate.Suspend(); // obsoleteにつき使用中止
\r
168 this.Songs管理.bIsSuspending = true;
\r
169 this.state = DTXEnumState.Suspended;
\r
170 Trace.TraceInformation( "★曲データ検索スレッドを中断しました。" );
\r
177 public void Resume()
\r
179 if ( this.state == DTXEnumState.Suspended )
\r
181 if ( ( this.thDTXFileEnumerate.ThreadState & ( System.Threading.ThreadState.WaitSleepJoin | System.Threading.ThreadState.StopRequested ) ) != 0 ) //
\r
183 // this.thDTXFileEnumerate.Resume(); // obsoleteにつき使用中止
\r
184 this.Songs管理.bIsSuspending = false;
\r
185 this.Songs管理.AutoReset.Set();
\r
186 this.state = DTXEnumState.Ongoing;
\r
187 Trace.TraceInformation( "★曲データ検索スレッドを再開しました。" );
\r
193 /// 曲探索スレッドにサスペンド指示を出してから、本当にサスペンド状態に遷移するまでの間、ブロックする
\r
194 /// 500ms * 10回=5秒でタイムアウトし、サスペンド完了して無くてもブロック解除する
\r
196 public void WaitUntilSuspended()
\r
199 for ( int i = 0; i < 10; i++ )
\r
201 if ( this.state == DTXEnumState.CompletelyDone ||
\r
202 ( thDTXFileEnumerate.ThreadState & ( System.Threading.ThreadState.WaitSleepJoin | System.Threading.ThreadState.Background | System.Threading.ThreadState.Stopped ) ) != 0 )
\r
206 Trace.TraceInformation( "★曲データ検索スレッドの中断待ちです: {0}", this.thDTXFileEnumerate.ThreadState.ToString() );
\r
207 Thread.Sleep( 500 );
\r
215 public void Abort()
\r
217 if ( thDTXFileEnumerate != null )
\r
219 thDTXFileEnumerate.Abort();
\r
220 thDTXFileEnumerate = null;
\r
221 this.state = DTXEnumState.None;
\r
223 this.Songs管理 = null; // Songs管理を再初期化する (途中まで作った曲リストの最後に、一から重複して追記することにならないようにする。)
\r
224 this.Songs管理 = new CSongs管理();
\r
231 /// songlist.dbからの曲リスト構築
\r
233 public void t曲リストの構築1()
\r
236 // 本メソッドは別スレッドで動作するが、プラグイン側でカレントディレクトリを変更しても大丈夫なように、
\r
237 // すべてのファイルアクセスは「絶対パス」で行うこと。(2010.9.16)
\r
238 // 構築が完了したら、DTXEnumerateState state を DTXEnumerateState.Done にすること。(2012.2.9)
\r
239 DateTime now = DateTime.Now;
\r
243 #region [ 0) システムサウンドの構築 ]
\r
244 //-----------------------------
\r
245 CDTXMania.app.stage起動.eフェーズID = CStage.Eフェーズ.起動0_システムサウンドを構築;
\r
247 Trace.TraceInformation( "0) システムサウンドを構築します。" );
\r
252 CDTXMania.app.Skin.bgm起動画面.t再生する();
\r
253 for ( int i = 0; i < CDTXMania.app.Skin.nシステムサウンド数; i++ )
\r
255 if ( !CDTXMania.app.Skin[ i ].b排他 ) // BGM系以外のみ読み込む。(BGM系は必要になったときに読み込む)
\r
257 CSkin.Cシステムサウンド cシステムサウンド = CDTXMania.app.Skin[ i ];
\r
258 if ( !CDTXMania.app.bコンパクトモード || cシステムサウンド.bCompact対象 )
\r
263 Trace.TraceInformation( "システムサウンドを読み込みました。({0})", cシステムサウンド.strファイル名 );
\r
264 //if ( ( cシステムサウンド == CDTXMania.app.Skin.bgm起動画面 ) && cシステムサウンド.b読み込み成功 )
\r
266 // cシステムサウンド.t再生する();
\r
269 catch ( FileNotFoundException )
\r
271 Trace.TraceWarning( "システムサウンドが存在しません。({0})", cシステムサウンド.strファイル名 );
\r
273 catch ( Exception e )
\r
275 Trace.TraceError( e.Message );
\r
276 Trace.TraceWarning( "システムサウンドの読み込みに失敗しました。({0})", cシステムサウンド.strファイル名 );
\r
281 lock (CDTXMania.app.stage起動.list進行文字列)
\r
283 CDTXMania.app.stage起動.list進行文字列.Add("Loading system sounds ... OK ");
\r
290 //-----------------------------
\r
293 if ( CDTXMania.app.bコンパクトモード )
\r
295 Trace.TraceInformation( "コンパクトモードなので残りの起動処理は省略します。" );
\r
299 #region [ 00) songlist.dbの読み込みによる曲リストの構築 ]
\r
300 //-----------------------------
\r
301 CDTXMania.app.stage起動.eフェーズID = CStage.Eフェーズ.起動00_songlistから曲リストを作成する;
\r
303 Trace.TraceInformation( "1) songlist.dbを読み込みます。" );
\r
308 if ( !CDTXMania.app.ConfigIni.bConfigIniがないかDTXManiaのバージョンが異なる )
\r
310 CSongs管理 s = new CSongs管理();
\r
311 s = Deserialize( strPathSongList ); // 直接this.Songs管理にdeserialize()結果を代入するのは避ける。nullにされてしまうことがあるため。
\r
317 int scores = this.Songs管理.n検索されたスコア数;
\r
318 Trace.TraceInformation( "songlist.db の読み込みを完了しました。[{0}スコア]", scores );
\r
319 lock (CDTXMania.app.stage起動.list進行文字列)
\r
321 CDTXMania.app.stage起動.list進行文字列.Add("Loading songlist.db ... OK");
\r
326 Trace.TraceInformation( "初回の起動であるかまたはDTXManiaのバージョンが上がったため、songlist.db の読み込みをスキップします。" );
\r
327 lock (CDTXMania.app.stage起動.list進行文字列)
\r
329 CDTXMania.app.stage起動.list進行文字列.Add("Loading songlist.db ... Skip");
\r
340 #region [ 1) songs.db の読み込み ]
\r
341 //-----------------------------
\r
342 CDTXMania.app.stage起動.eフェーズID = CStage.Eフェーズ.起動1_SongsDBからスコアキャッシュを構築;
\r
344 Trace.TraceInformation( "2) songs.db を読み込みます。" );
\r
349 if ( !CDTXMania.app.ConfigIni.bConfigIniがないかDTXManiaのバージョンが異なる )
\r
353 this.Songs管理.tSongsDBを読み込む( strPathSongsDB );
\r
357 Trace.TraceError( "songs.db の読み込みに失敗しました。" );
\r
360 int scores = ( this.Songs管理 == null ) ? 0 : this.Songs管理.nSongsDBから取得できたスコア数; // 読み込み途中でアプリ終了した場合など、CDTXMania.app.Songs管理 がnullの場合があるので注意
\r
361 Trace.TraceInformation( "songs.db の読み込みを完了しました。[{0}スコア]", scores );
\r
362 lock (CDTXMania.app.stage起動.list進行文字列)
\r
364 CDTXMania.app.stage起動.list進行文字列.Add("Loading songs.db ... OK");
\r
369 Trace.TraceInformation( "初回の起動であるかまたはDTXManiaのバージョンが上がったため、songs.db の読み込みをスキップします。" );
\r
370 lock (CDTXMania.app.stage起動.list進行文字列)
\r
372 CDTXMania.app.stage起動.list進行文字列.Add("Loading songs.db ... Skip");
\r
380 //-----------------------------
\r
386 CDTXMania.app.stage起動.eフェーズID = CStage.Eフェーズ.起動7_完了;
\r
387 TimeSpan span = (TimeSpan) ( DateTime.Now - now );
\r
388 Trace.TraceInformation( "起動所要時間: {0}", span.ToString() );
\r
389 lock ( this ) // #28700 2012.6.12 yyagi; state change must be in finally{} for exiting as of compact mode.
\r
391 state = DTXEnumState.CompletelyDone;
\r
398 /// 起動してタイトル画面に遷移した後にバックグラウンドで発生させる曲検索
\r
399 /// #27060 2012.2.6 yyagi
\r
401 private void t曲リストの構築2()
\r
404 // 本メソッドは別スレッドで動作するが、プラグイン側でカレントディレクトリを変更しても大丈夫なように、
\r
405 // すべてのファイルアクセスは「絶対パス」で行うこと。(2010.9.16)
\r
406 // 構築が完了したら、DTXEnumerateState state を DTXEnumerateState.Done にすること。(2012.2.9)
\r
408 DateTime now = DateTime.Now;
\r
409 bool bIsAvailableSongList = false;
\r
410 bool bIsAvailableSongsDB = false;
\r
411 bool bSucceededFastBoot = false;
\r
416 #region [ 2) 曲データの検索 ]
\r
417 //-----------------------------
\r
418 // base.eフェーズID = CStage.Eフェーズ.起動2_曲を検索してリストを作成する;
\r
420 Trace.TraceInformation( "enum2) 曲データを検索します。" );
\r
425 if ( !string.IsNullOrEmpty( CDTXMania.app.ConfigIni.str曲データ検索パス ) )
\r
427 string[] strArray = CDTXMania.app.ConfigIni.str曲データ検索パス.Split( new char[] { ';' } );
\r
428 if ( strArray.Length > 0 )
\r
431 foreach ( string str in strArray )
\r
434 if ( !Path.IsPathRooted( path ) )
\r
436 path = CDTXMania.app.strEXEのあるフォルダ + str; // 相対パスの場合、絶対パスに直す(2010.9.16)
\r
439 if ( !string.IsNullOrEmpty( path ) )
\r
441 Trace.TraceInformation( "検索パス: " + path );
\r
446 this.Songs管理.t曲を検索してリストを作成する( path, true );
\r
448 catch ( Exception e )
\r
450 Trace.TraceError( e.Message );
\r
451 Trace.TraceError( e.StackTrace );
\r
452 Trace.TraceError( "例外が発生しましたが処理を継続します。" );
\r
464 Trace.TraceWarning( "曲データの検索パス(DTXPath)の指定がありません。" );
\r
469 Trace.TraceInformation( "曲データの検索を完了しました。[{0}曲{1}スコア]", this.Songs管理.n検索された曲ノード数, this.Songs管理.n検索されたスコア数 );
\r
472 // lock ( this.list進行文字列 )
\r
474 // this.list進行文字列.Add( string.Format( "{0} ... {1} scores ({2} songs)", "Enumerating songs", this..Songs管理_裏読.n検索されたスコア数, this.Songs管理_裏読.n検索された曲ノード数 ) );
\r
476 //-----------------------------
\r
478 #region [ 3) songs.db 情報の曲リストへの反映 ]
\r
479 //-----------------------------
\r
480 // base.eフェーズID = CStage.Eフェーズ.起動3_スコアキャッシュをリストに反映する;
\r
481 Trace.TraceInformation( "enum3) songs.db の情報を曲リストへ反映します。" );
\r
486 if ( this.Songs管理.listSongsDB != null )
\r
488 this.Songs管理.tスコアキャッシュを曲リストに反映する();
\r
491 catch ( Exception e )
\r
493 Trace.TraceError( e.Message );
\r
494 Trace.TraceError( e.StackTrace );
\r
495 Trace.TraceError( "例外が発生しましたが処理を継続します。" );
\r
499 Trace.TraceInformation( "曲リストへの反映を完了しました。[{0}/{1}スコア]", this.Songs管理.nスコアキャッシュから反映できたスコア数, this.Songs管理.n検索されたスコア数 );
\r
502 // lock ( this.list進行文字列 )
\r
504 // this.list進行文字列.Add( string.Format( "{0} ... {1}/{2}", "Loading score properties from songs.db", CDTXMania.app.Songs管理_裏読.nスコアキャッシュから反映できたスコア数, cs.n検索されたスコア数 ) );
\r
506 //-----------------------------
\r
508 #region [ 4) songs.db になかった曲データをファイルから読み込んで反映 ]
\r
509 //-----------------------------
\r
510 // base.eフェーズID = CStage.Eフェーズ.起動4_スコアキャッシュになかった曲をファイルから読み込んで反映する;
\r
512 int num2 = this.Songs管理.n検索されたスコア数 - this.Songs管理.nスコアキャッシュから反映できたスコア数;
\r
514 Trace.TraceInformation( "{0}, {1}", this.Songs管理.n検索されたスコア数, this.Songs管理.nスコアキャッシュから反映できたスコア数 );
\r
515 Trace.TraceInformation( "enum4) songs.db になかった曲データ[{0}スコア]の情報をファイルから読み込んで反映します。", num2 );
\r
520 this.Songs管理.tSongsDBになかった曲をファイルから読み込んで反映する();
\r
522 catch ( Exception e )
\r
524 Trace.TraceError( e.Message );
\r
525 Trace.TraceError( e.StackTrace );
\r
526 Trace.TraceError( "例外が発生しましたが処理を継続します。" );
\r
530 Trace.TraceInformation( "曲データへの反映を完了しました。[{0}/{1}スコア]", this.Songs管理.nファイルから反映できたスコア数, num2 );
\r
533 // lock ( this.list進行文字列 )
\r
535 // this.list進行文字列.Add( string.Format( "{0} ... {1}/{2}", "Loading score properties from files", CDTXMania.app.Songs管理_裏読.nファイルから反映できたスコア数, CDTXMania.app.Songs管理_裏読.n検索されたスコア数 - cs.nスコアキャッシュから反映できたスコア数 ) );
\r
537 //-----------------------------
\r
539 #region [ 5) 曲リストへの後処理の適用 ]
\r
540 //-----------------------------
\r
541 // base.eフェーズID = CStage.Eフェーズ.起動5_曲リストへ後処理を適用する;
\r
543 Trace.TraceInformation( "enum5) 曲リストへの後処理を適用します。" );
\r
548 this.Songs管理.t曲リストへ後処理を適用する();
\r
550 catch ( Exception e )
\r
552 Trace.TraceError( e.Message );
\r
553 Trace.TraceError( e.StackTrace );
\r
554 Trace.TraceError( "例外が発生しましたが処理を継続します。" );
\r
558 Trace.TraceInformation( "曲リストへの後処理を完了しました。" );
\r
561 // lock ( this.list進行文字列 )
\r
563 // this.list進行文字列.Add( string.Format( "{0} ... OK", "Building songlists" ) );
\r
565 //-----------------------------
\r
567 #region [ 6) songs.db への保存 ]
\r
568 //-----------------------------
\r
569 // base.eフェーズID = CStage.Eフェーズ.起動6_スコアキャッシュをSongsDBに出力する;
\r
571 Trace.TraceInformation( "enum6) 曲データの情報を songs.db へ出力します。" );
\r
576 this.Songs管理.tスコアキャッシュをSongsDBに出力する( strPathSongsDB );
\r
578 catch ( Exception e )
\r
580 Trace.TraceError( e.Message );
\r
581 Trace.TraceError( e.StackTrace );
\r
582 Trace.TraceError( "例外が発生しましたが処理を継続します。" );
\r
586 Trace.TraceInformation( "songs.db への出力を完了しました。[{0}スコア]", this.Songs管理.nSongsDBへ出力できたスコア数 );
\r
589 // lock ( this.list進行文字列 )
\r
591 // this.list進行文字列.Add( string.Format( "{0} ... OK", "Saving songs.db" ) );
\r
595 // if ( !bSucceededFastBoot ) // songs2.db読み込みに成功したなら、songs2.dbを新たに作らない
\r
596 #region [ 7) songs2.db への保存 ] // #27060 2012.1.26 yyagi
\r
597 Trace.TraceInformation( "enum7) 曲データの情報を songlist.db へ出力します。" );
\r
600 SerializeSongList( this.Songs管理, strPathSongList );
\r
601 Trace.TraceInformation( "songlist.db への出力を完了しました。[{0}スコア]", this.Songs管理.nSongsDBへ出力できたスコア数 );
\r
603 //-----------------------------
\r
610 // base.eフェーズID = CStage.Eフェーズ.起動7_完了;
\r
611 TimeSpan span = (TimeSpan) ( DateTime.Now - now );
\r
612 Trace.TraceInformation( "曲探索所要時間: {0}", span.ToString() );
\r
616 // state = DTXEnumState.Done; // DoneにするのはCDTXMania.app.cs側にて。
\r
617 state = DTXEnumState.Enumeratad;
\r
626 private static void SerializeSongList( CSongs管理 cs, string strPathSongList )
\r
628 bool bSucceededSerialize = true;
\r
629 Stream output = null;
\r
632 output = File.Create( strPathSongList );
\r
633 BinaryFormatter formatter = new BinaryFormatter();
\r
634 formatter.Serialize( output, cs );
\r
636 catch ( Exception e )
\r
638 bSucceededSerialize = false;
\r
639 Trace.TraceError( e.Message );
\r
640 Trace.TraceError( e.StackTrace );
\r
641 Trace.TraceError( "例外が発生しましたが処理を継続します。" );
\r
646 if ( !bSucceededSerialize )
\r
650 File.Delete( strPathSongList ); // serializeに失敗したら、songs2.dbファイルを消しておく
\r
652 catch ( Exception )
\r
661 /// 曲リストのdeserialize
\r
663 /// <param name="songs管理"></param>
\r
664 /// <param name="strPathSongList"></param>
\r
665 private CSongs管理 Deserialize( string strPathSongList )
\r
667 CSongs管理 songs管理 = null;
\r
670 #region [ SongListDB(songlist.db)を読み込む ]
\r
671 // byte[] buf = File.ReadAllBytes( SongListDBファイル名 ); // 一旦メモリにまとめ読みしてからdeserializeした方が高速かと思ったら全く変わらなかったので削除
\r
672 // using ( MemoryStream input = new MemoryStream(buf, false) )
\r
673 using ( Stream input = File.OpenRead( strPathSongList ) )
\r
677 BinaryFormatter formatter = new BinaryFormatter();
\r
678 songs管理 = (CSongs管理) formatter.Deserialize( input );
\r
680 catch ( Exception )
\r
689 Trace.TraceError( "songlist.db の読み込みに失敗しました。" );
\r