Wwise サウンドエンジンは、ストリームマネージャを使用してサウンドバンクをロードし、ストリーミングされたオーディオファイルを読み込みます。I/Oマネージャをお持ちでない場合は、これをあらゆるゲーム I/O にご使用いただくことが可能です。高レベルストリームマネージャをクライアントとして直接使用せず、低レベル I/O フックの実装により Wwise I/O をゲームに統合する場合には、この章を読み飛ばしていただいても結構です。
ストリームマネージャのメインインターフェイスは、AKIAkStreamMgr により定義されますが、これは基本的にストリーミングオブジェクトのファクトリです。
ストリームマネージャを使用する前に、これをインスタンス化する必要があります。
Default Streaming Manager Information ストリームマネージャのインスタンス化は、実装固有のものです。従って、ストリームマネージャの Audiokinetic デフォルト実装ファクトリ関数は、AkStreamMgrModule.h: AK::StreamMgr::Create()で定義されています。これに実装固有の設定を渡す必要があります(初期設定に関する詳細は、Audiokinetic ストリームマネージャ初期化設定 を参照してください)。 |
Default Streaming Manager Information ストリームオブジェクト作成と使用の前に、高レベルストリーミングデバイスを作る必要があります。この概念はAudiokineticストリームマネージャのデフォルト実装に固有のものです。高レベルストリーミングデバイスは、基本的に独自のスレッドで実行されるI/Oスケジューラ実装で、これに関連付けられているストリームオブジェクトを一元化し、データ転送要求を低レベル I/Oにポストします。一般に高レベルデバイスは、単にデバイスと呼ばれます。特定にフラグおよび設定を持つ1つ以上のデバイスが、好ましくは初期化時にゲームによって作成されます。初期設定に関する詳細は、Audiokinetic ストリームマネージャ初期化設定 のセクションをご覧ください。AKStreamMgr::CreateDevice() は、デバイスIDを返しますが、これはファイルロケーションおよびデバイス割り当てのために低レベルI/Oによって保持される必要があります。(更なる詳細は、ファイルロケーションの解決 のセクションをご覧ください。)正しい終了のためには、このデバイスIDが AK::StreamMgr::DestroyDevice() に渡されなければなりません。実装固有の全ての関数については、AKStreamMgr::CreateDevice() と AK::StreamMgr::DestroyDevice() は、ヘッダ AkStreamMgrModule.h で定義されています。 |
ストリームマネージャ メインAPIの多くはストリームファクトリメソッドのセットです。ファイル識別子と設定を与えられ、これらはストリームオブジェクトを作成し、そのストリームにインターフェイスを戻します。すべてのストリーム操作は、このインターフェイスを介して実行されます。 ストリーム作成メソッドの両セットはオーバーロードを2つ持ちますが、これらは使用するファイル識別方式に応じて異なります。1つ目のオーバーロードは、ファイルの識別に文字列を使用しますが、2つ目のオーバーロードは、整数IDを使用します。
Default Streaming Manager Information
|
ストリーム作成メソッドは、ファイル識別子に加えて、ファイルロケーション用フラグを含む AkFileSystemFlags 構造体へのポインタを受け付けます。
Default Streaming Manager Information このポインタはそのまま低レベルI/Oへ渡されます。AkFileSystemFlags に関する詳細およびサウンドエンジンがどのようにこれらを使用するかについては、サウンドバンク 、ストリーミングオーディオファイル と 基本的なファイルロケーション のセクションをご覧ください。 |
ストリーム作成メソッドには、追加引数があります:in_bSyncOpen。ユーザーは(サウンドエンジンと同じように)、ストリームオブジェクトでラップされたファイルハンドルがこのコール中にオープンされる必要がある場合には、trueを渡します。falseを渡すと、Stream Managerによるファイルオープン延期を許可することになります。延期は発生する可能性も発生しない可能性もあります。延期が発生して、ファイルオープンに失敗した場合、AKIAkStdStream::Read() または AK::IAkAutoStream::GetBuffer() への次のコールはAK_Failを返します。
|
Note: これは、致命的なエラーとみなされるべきではありません。サウンドエンジンはストリームされたオーディオファイルに対して false を渡します。GetBuffer() が false を返すと、これは I/O エラーとみなされ、ストリームが正常に破棄されます。 |
Default Streaming Manager Information 引数 in_bSyncOpenは、低レベルI/Oに直接渡されます。低レベルI/Oのこのフラグの影響についての詳細は 遅延オープン を参照してください。 |
AK::IAkStreamMgr::CreateStd() は、標準ストリームを作成し、AKIAkStreamMgr::CreateAuto() は自動ストリームを作成します。これらの2タイプのストリームについて、以下のセクションで解説しています。
どちらのタイプのストリームオブジェクトも Destroy() メソッドを定義します。ストリームにより使用されているリソースを解放するためには、このメソッドを呼び出す必要があります。これを実行した後には、オブジェクトを再び使用することはできません。
Default Streaming Manager Information 破棄が予定されているストリームオブジェクトは、低レベルI/O で保留されている所有I/O転送がなくなったらすぐに解放されるよう、I/Oスレッドに信号を送ります。 ストリームプロファイリングが発生している場合、I/Oスレッドは、監視スレッドによる承認を待ってからストリームオブジェクトを破棄します。監視スレッドは、200ミリ秒ごとにプロファイリングパスを実行します。 |
AK::IAkStreamMgr::CreateStd() への呼び出しにより、返される AK::IAkStdStream インターフェースを介して制御可能である標準ストリームオブジェクトが作成されます。
標準ストリームは、基本的なリード/ライト方式を使用してI/O動作を制御します。AKIAkStdStream::Read() または AK::IAkStdStream::Write() が呼び出されると、I/O要求がスケジューラにキューイングされ、ストリームはそのステータスを AK_StmStatusPending に設定します。ユーザーは、要求転送サイズとバッファのアドレスを渡します。完了すると、ストリームはそのステータスをAK_StmStatusCompleted または AK_StmStatusError に設定します。その位置は、実際に転送されるサイズによってインクリメントされるので、次の操作は新しい位置で発生します。別の位置を強制するには、新しい転送を開始する前に、ユーザーが AK::IAkStdStream::SetPosition() メソッドを使用する必要があります。
同時に発生可能なI/O操作は1つのみです。後続の操作は、AKIAkStdStream::Read() または AK::IAkStdStream::Write()を呼び出すことによって、明示的に開始される必要があります。ユーザーがストリームの使用を終えた時は、AKIAkStdStream::Destroy() を呼び出す必要があります。これにより、インターフェースが無効になります。
Default Streaming Manager Information リードまたはライトのコールは、低レベルI/OのI/O転送につながります。クライアントレベルで要求されるサイズがストリーミングデバイスの粒度(AkDeviceSettingsuGranularity)より大きい場合、転送が分割されます。ストリームは、全転送が完了するまで、または、エラーまたはエンドオブファイル状況が発生するまで、AK_StmStatusPending または AK_StmStatusIdle 状態のままになります。 |
インターフェースは、クエリ設定、現在のステータスまたは位置へのアクセス、および以前の操作に供給されるバッファへのアクセスなど、他のメソッドを公開します。
標準ストリーム操作を起動する方法は2つあります:
標準ストリームを作成する時には、オープンモード(AkOpenMode)を指定する必要があります。オープンモードは、ストリームがリードまたはライトのどちらに使用されるのか、または、リードとライトの両方に使用されるのかを指定します。リードのみのためにオープンされたストリームへの AK::IAkStdStream::Write() の呼び出しは、明らかに失敗してしまいます。
ストリームの名前を AK::IAkStdStream::SetStreamName() を使用して指定することができます。文字列がストリームオブジェクトにコピーされ、 AK::IAkStdStream::GetInfo() でクエリすることが可能です。
Default Streaming Manager Information ストリーム名は、Wwise の Advanced Profiler ストリーミングタブに表示されるものです。 |
標準ストリームのヒューリスティックは、操作ごとに指定されています。
AK::IAkStdStream::Read() と AK::IAkStdStream::Write() には、操作の優先度と(ミリ秒単位での)期限が必要です。一般的には、Stream Manager は、期限の短い操作を好みます。ストレージデバイスが提供できるより大きなI/O帯域幅をアプリケーションが必要とする場合、優先度の高いストリームが好まれます。期限をゼロに指定すると、データが今必要とされていることを意味し、I/O は既に遅れています。このような場合には、優先度の低い他のストリームより前に処理されます。
|
Note: サウンドエンジンのBank Manager(バンクマネージャ)は、標準ストリームを使用します。SoundBank データを独自のバッファに読み込んで解析します。バンクローディングの平均スループットと優先度を指定するためのメソッドが1つサウンドエンジンAPIで公開されています:AKSoundEngine::SetBankLoadIOSettings()。(詳細は、Wwise Sound Engine の Banks を参照してください。)バンクマネージャは、AKIAkStdStream::Read() を呼び出し、これが完了するとデータを解析して読み取ります。これには、このメソッドの引数として与えられた優先度が使用されます。操作の期限が、ユーザーにより指定されたスループットから計算されます: fDeadline = uBufferSize / fUserSpecifiedThroughput; 標準ストリーム操作の期限と自動ストリームの平均スループットのデッドラインは、Stream Manager のI/Oスケジューラと等価です。サウンドエンジンの使用により、I/O上でのバンクロードの負荷を、オーディオストリームやゲーム内の他のストリームの負荷と調整することができます。 |
リードおよびシークの粒度やバッファアラインメントへの低レベルでの制約は、Stream Manager レベルでは“ブロックサイズ”と呼ばれます。ストリームのインターフェース上のAKIAkStdStream::GetBlockSize() メソッドは、低レベルI/Oをクエリし、これにストリームに関連付けられたファイル記述子を渡して、呼び出し元にその値を返します。ファイル記述子に関する詳細は、低レベルI/OのセクションとAKStreamMgr::IAkLowLevelIOHook::GetBlockSize() メソッドを参照してください。ストレージデバイスの中には、データ転送サイズへの制約があるものもあります。例えば、Win32プラットフォームでは、FILE_FLAG_UNBUFFERED フラグで開かれるファイルは、物理デバイスのセクタサイズのみの倍数の転送サイズを可能にします。リードまたはライトの操作がブロックサイズの倍数ではない転送サイズを要求した場合には、これらの操作は失敗します。高レベルインターフェースのユーザーは、AKIAkStdStream::GetBlockSize() に返される値の倍数であるリードサイズを要求しなければなりません。AKIAkStdStream::SetPosition() は、同様の制約を受けます。しかしながら、これは自動的に下位のブロック境界にスナップし、実際のファイル位置オフセットを返します。
一般的に、ゲームタイトルでは、Stream Manager が使用されます。ゲームタイトルは、低レベルI/Oサブモジュールも実装するので、使用可能な転送サイズを認識しています。サウンドエンジンは、ストレージデバイスの制約を認識しないので、常に標準ストリームのリードサイズをブロックサイズの境界までスナップします。
AK::IAkStdStream::Read() と AK::IAkStdStream::Write() は、ストリームが AK_StmStatusPending ステートにある間に呼び出された場合には失敗します。AKIAkStdStream::GetPosition() と AK::IAkStdStream::SetPosition() は、I/O転送が完了する前または後で発生する可能性があるので、不定な結果をもたらします。しかし、これらがI/Oでブロックすることはありません。
AK::IAkStdStream::Cancel() は、転送の保留中に使用することが可能ですが、パフォーマンスが低下するので、これの使用はお薦めできません。このメソッドは、保留されているI/Oがないことを呼び出し元に確認します。低レベルI/Oに要求が送信される前に呼び出しが実行されると、タスクがキューから除去されます。しかしながら、既に低レベルI/Oへ要求が送信されている場合には、I/Oが完了するまで呼び出し元がブロックされます。
|
Tip: ユーザーは、ストリームを破棄(AKIAkStdStream::Destroy())する前に AK::IAkStdStream::Cancel() を明示的に呼び出す必要はありません。しかし、最良のパフォーマンスを得るためにも、ストリームが AK_StmStatusPending ステートにない場合にのみ、ユーザーは Destroy() を呼び出すべきです。 |
AK::IAkStreamMgr::CreateAuto() を呼び出すと、返される AK::IAkAutoStream インターフェースを介して制御可能である自動ストリームオブジェクトが作成されます。
自動ストリームは、入力のみに使用されるストリームです。I/O要求が、ユーザーによる明示的な関数呼び出しなしで、低レベルI/Oへ “フードの下で” 送信されるため自動ストリームと呼ばれています。ストリーミングメモリは Stream Manager に所有されており、ストリーミングされたデータには、ストリーミングメモリアドレスを求めることによりアクセス可能です。ストリーミングメモリの一領域がユーザーに許可されると、これが明示的に解放されるまでロックされたままになります。一方、内部スケジューラは、ロックされていないメモリ内でデータ転送を実行します。ストリームは、作成時にはアイドル状態です。I/O要求の自動スケジューリングは、ユーザーが AK::IAkAutoStream::Start() を呼び出すと開始します。これは、AKIAkAutoStream::Stop() の呼び出しにより停止または一時停止、AKIAkAutoStream::Start() の再度呼び出しにより再開することが可能です。
|
Caution: ストリームが停止している間は、GetBuffer() を呼び出さないでください。ストリームからバッファを取得する前に必ず Start() を呼び出す必要があります。 |
データは、AKIAkAutoStream::GetBuffer() への呼び出しによりアクセス可能です。低レベルI/Oから既にデータが読み出されている場合、このメソッドは AK_DataReady、このデータを含むバッファのアドレス、およびそのサイズを返します。バッファがもはや必要とされない場合は、これをAKIAkAutoStream::ReleaseBuffer() への呼び出しにより解放することができます。続いて、ストリームの位置は、解放されたバッファのサイズだけインクリメントされます。ユーザーは、AKIAkAutoStream::SetPosition() への呼び出しにより新しい位置を強制することができます。AKIAkAutoStream::GetBuffer() への次の呼び出しは、この位置と一致します。
|
Caution: ストリームの位置を変更すると、一部データのフラッシュが発生する場合があります。自動ストリームはシーケンシャルアクセス用に最適化されています。ループを指定するヒューリスティックがあり、これにより Stream Manager は、ストリーミングメモリを効率的に管理することができます。詳細は、一般的な注意点とその他の考慮事項 section セクションをご覧ください。 |
|
Caution: 低レベル I/O がエラーを報告すると、ストリームがエラーモードになります。自動ストリームはエラー状態から回復することができないため、AKIAkAutoStream::GetBuffer() は常に AK_Fail を返します。 |
自動ストリーム内のデータへは次の2つの方法でアクセス可能です:
AK::IAkAutoStream::GetBuffer() には、4つのリターンコードがあります:
ユーザーが、データで満たされたバッファを付与されている場合、メソッドは AK_DataReady または AK_NoMoreData を返します。ストリームバッファが空の場合、AKIAkAutoStream::GetBuffer() は、サイズがゼロおよびバッファアドレスが null で AK_NoDataReady を返します。低レベルI/Oがエラーを報告した場合、または、無効なパラメータでメソッドが呼び出された場合には、AK_Fail が返されます。
ファイルの最後のバッファが付与されると AK_DataReady の代わりに AK_NoMoreData が返されます。Stream Manager は、(ユーザーから見た)現在の位置を、ファイル記述子構造体のメンバとして低レベルI/Oにより提供されるファイルサイズと比較することにより、これが最後のバッファであると判断します。AKIAkAutoStream::GetBuffer() への後続の呼び出しは、サイズゼロで AK_NoMoreData を返します。
AK::IAkAutoStream::GetBuffer() を呼び出すたびに、新しいバッファが提供されます。バッファは、AKIAkAutoStream::ReleaseBuffer() への呼び出しにより明示的に解放される必要があります。これらのバッファは、GetBuffer() によって付与された順番に解放されます。バッファが解放されると、そのアドレスは無効になります。ReleaseBuffer() は、クライアントがバッファを保持していない場合には、AK_Fail を返します。しかし、これは致命的エラーとみなされるべきではありません。
|
Tip: 可能であれば、一度に一つのバッファのみを取得するようにしてください。これにより、Stream Manager はI/Oを実行するためのスペースをより多く得ることができます。複数のバッファの同時使用は、主にリング/ダブルバッファへのアクセスを必要とするハードウェアまたはその他のインターフェース向けです。特定のストリームに対して複数のバッファを使用する場合は、適切なヒューリスティック(AkAutoStmHeuristicsuMinNumBuffers)を渡すことにより通知する必要があります。 |
|
Caution: 自動ストリーム使用時によくあるミスは、ReleaseBuffer() の呼び出しを忘れることです。 |
GetBuffer() への呼び出しに成功し付与されたバッファサイズは、Stream Manager により決定されます。下層ファイルの末尾に到達した場合以外は、ブロックサイズの倍数でなければなりません。また、作成時に渡されたバッファ制約(AkAutoStmBufSettings 参照)を使用して、GetBuffer() により返されるサイズを強制することも可能です。
|
Caution: バッファサイズを強制すると、ストリーミングメモリと/または帯域幅が浪費される可能性があるので、パフォーマンスが最適以下になる場合があります。また、ユーザー指定の制約はサポートされない場合があります。IAkStreamMgrCreateAuto() は、AK_Fail を返します。 |
Default Streaming Manager Information 通常、ストリームが終わりに達した場合を除き、このサイズは高レベルデバイスの作成設定で指定された粒度に対応します。 |
in_bWait フラグを True に設定した状態での AK::IAkAutoStream::GetBuffer() への呼び出しは、データの準備ができるまでユーザーをブロックします。従って、メソッドは AK_NoDataReady を返すことができません。最終バッファが既に付与・解放されている場合には、メソッドはサイズゼロで AK_NoMoreData を直ちに返します。
ユーザーは、 in_bWait フラグを False に設定して呼び出された AK::IAkAutoStream::GetBuffer() によって返されるコードを評価することで、データを取得することができます。AK_NoDataReady が返された場合、他のタスクを行い、しばらくしてから再度試してみてください。
自動ストリームは、標準ストリームより多くの設定でインスタンス化されますが、特にバッファサイズ制約とヒューリスティックが重要です。これらの設定により、Stream Manager は最適メモリ量を割り当て、データ転送要求に優先順位をつけることができます。
一部の設定は、ユーザーにより指定されるメモリ関連の制約です。バッファサイズは直接指定することが可能です。Stream Manager にバッファサイズを選択させたいけれども制限内にとどめたい場合は、最小限のバッファサイズまたはブロックサイズ、あるいは両方を指定することができます。バッファサイズはブロックサイズの倍数になります。
|
Tip: バッファ制約はオプションであり、通常 Stream Manager がストリーミングメモリを最適に管理できるようにすることを目的で使用するべきではありません。サウンドエンジンは、一部プラットフォーム上でのデコードハードウェアを使用する時に、バッファ制約を使用します。これらのデコーダは、特定のバイトアラインメント(ブロックサイズ)と最小バッファサイズで、一度に2つのバッファにアクセスする必要があります。 |
Default Streaming Manager Information |
Stream Manager によるスケジューリングとメモリ割り当て実行を支援するためにヒューリスティックが提供される必要があります。自動ストリームヒューリスティックは、作成時にストリームごとに指定されますが、最適な動作のために非常に重要です。AKIAkAutoStream::GetHeuristics() や AK::IAkAutoStream::SetHeuristics() を介して、いつでもクエリや変更が可能です。
Stream Manager は、バッファサイズがブロックサイズの倍数であることを確認するために、バッファサイズの選択に先立って特定ファイルのブロックサイズを低レベル I/O にクエリします。従って、自動ストリームのユーザーは、ストリームを別の位置へ強制しない限り、低レベルのブロックサイズを意識する必要はありません。この場合、AKIAkAutoStream::GetBlockSize() から取得したブロックサイズ、または、 AK::IAkAutoStream::SetPosition() が返す実際の絶対オフセットを考慮する必要があります。
ストリーム位置は、ユーザーの観点から評価され、Get/SetPosition() メソッドによりクエリおよび設定されます。Stream Manager のバッファへ低レベル I/O から転送されるデータは、位置の計算では考慮されません。このデータは、バッファがユーザーにより解放される時に更新されます。AKIAkAutoStream::SetPosition() が呼び出された時に、低レベル I/O から既に転送されてしまったデータは、通常フラッシュされます。
|
Note: ユーザーは、可能な限り AK::IAkAutoStream::SetPosition() の呼び出しを避けてください。これを使用する必要がある場合は、できるだけ早期に呼び出す必要があります。例えば、サウンドエンジンで、ループ中のサウンドソース(音源)は、Stream Manager からバッファを取得する時に、ループエンドがこのバッファに含まれているかどうかを確認します。そうであれば、AKIAkAutoStream::SetPosition() が直ちに(つまり、ReleaseBuffer() のかなり前に)呼び出され、無用なデータをストリーミングするリスクを最小限に抑えようとします。また、ループヒューリスティックを指定すると、内部スケジューラが低レベル I/O への要求に関してより優れた意思決定をできるよう支援することができます。 |
|
Tip: AK::IAkAutoStream::SetPosition() は、バッファがロックされた状態でもロックされていない状態でも呼び出し可能ですが、無用にデータをストリーミングするリスクを最小限に抑えるため、できるだけ早期の位置変更をお勧めします。ストリームを適切に停止することで、帯域幅の浪費を最小限に抑えることができます。 AK::IAkAutoStream::SetPosition() は、クライアントに保持されているバッファを解放しません。クライアントは、ReleaseBuffer() を明示的に呼び出すことにより、バッファがいつ解放されるかを決定します。AKIAkAutoStream::SetPosition() は、実際に GetBuffer() への次の呼び出しに対してクライアントが期待する位置を示します。 AK::IAkAutoStream::GetPosition() は、現在クライアントが保持している最初のバッファの位置を返します。クライアントがバッファを保持していない場合、GetBuffer() への次の呼び出しで付与されるバッファの位置を返します。 |
AK::IAkAutoStream::GetBuffer() のAK_NoMoreData リターンコードは、ストリームの位置から決定されます。AKIAkAutoStream::GetPosition() に返される out_bEndOfStream オプションフラグも、ストリーム位置にバインドされています。これは、以下のような場合のみ True を返します:
自動ストリームAPIは、AKIAkAutoStream::GetBuffer() 呼び出しをブロックするのを除き、ユーザーが低レベル I/Oとの保留中のトランザクションを決してブロックしないようにデザインされています。AKIAkAutoStream::Destroy() さえもブロックされません。通常、ストリームが破棄されたにも関わらず、低レベルI/Oと相互作用をしている場合、低レベルI/Oとの現在の転送が終了するまでこのストリームは内部で行き続けます。
Stream Manager 全体をオーバーライドするには、ゲームタイトルは IAkStreamMgr.h で定義されているすべてのインターフェースを実装している必要があります。実装は、このセクションの他の部分で説明されている各規則に従わなければなりません。
スタティックライブラリ AkStreamMgr.lib をゲーム独自のスタティックライブラリと置き換えることができます。作成関数やその他の実装に固有な設定や定義、例えば低レベルI/O APIなどは、AkStreamMgrModule.h にあるので、Stream Manager の一部ではありません。
サウンドエンジンは、インラインスタティック AK::IAkStreamMgr::Get() メソッドを呼び出すことで Stream Manager にアクセスします。これは、AKIAkStreamMgr のプロテクトメンバとして定義されている、AKIAkStreamMgr インターフェースへのポインタを返します。カスタム実装が宣言する必要があるのは変数1つのみで(AKIAkStreamMgr::m_pStreamMgr)、リンケージは自動的に行われます。Stream Manager とサウンドエンジンが、同一の実行可能ファイルまたはDLL内でリンクされていない場合は、AKIAkStreamMgr::m_pStreamMgr が __dllexport 属性を持っている必要があります。AKSTREAMMGR_API マクロは、カスタム Stream Manager ライブラリのコンパイラ設定で定義されている AKSTREAMMGR_EXPORTS と一緒に使用可能です。
プロファイリングインターフェースも、サウンドエンジンの非 AK_OPTIMIZED バージョンとのリンクを可能にするために実装される必要があります。このインターフェースはかなり自己説明的です。これを実装することで、Wwiseでのプロファイリングが可能になります。プロファイリングが必要でない場合は、AKIAkStreamMgr::GetStreamMgrProfile() がNULLを返し、インターフェースは空のコードで実装されます。この場合、Wwise では、プロファイリング情報は Wwise に表示されません。
以下のコードは、文章で説明するよりもコードでの方がより良く説明可能ないくつかの考慮事項を示すためのもので。Stream Manager の実装をオーバーライドまたは変更する場合に特に便利です。このコードは、特に注意する必要のある事項を指摘できるよう、故意にボリュームのあるものになっています。
// Note: For the sake of simplicity, we assume that the test file is smaller than 4Gb (its position fits on 32 bits). // 標準ストリームの使用法と考慮事項。 // この関数は、テストが成功した場合(Stream Manager が正しく動作する場合)、trueを返します。 bool BasicStdStreamTest( const AkOSChar * in_pszFilename ) { // 基本的な標準ストリームテスト。 bool bSuccess = true; AkUInt64 iCurPosition; const AkInt64 POSITION_BEGIN = 0; // 読み込み用のストリームオブジェクトを作成します。 AK::IAkStdStream * pStream; AKRESULT eResult = AK::IAkStreamMgr::Get()->CreateStd( in_pszFilename, // アプリケーションストリーム識別子(ファイル名)。 NULL, // No file system flags: we provide the full path and do not need any file location resolving logic. AK_OpenModeRead, // Creation setting: Open Mode. pStream, // Returned stream interface. true ); // Require synchronous file open. // リターンコードを確認してください。 if ( eResult != AK_Success ) { printf( "Failed creating stream.\n" ); bSuccess = false; goto stdstmbasictest_cleanup; } // メモリーを提供します。 const int BUFFER_SIZE = 8192; unsigned char pBuffer[BUFFER_SIZE]; // Before attempting any read, users who are unaware of the implementation of the Low-Level I/O module // should ensure their read sizes are consistent with the block size constraint. このテストは、 // that BUFFER_SIZE はブロックサイズの倍数であることを前提としています。そうでなければ、続行しません。 if ( BUFFER_SIZE % pStream->GetBlockSize() != 0 ) { printf( "Low-Level storage device requirements are not compatible with this test.\n"); bSuccess = false; goto stdstmbasictest_cleanup; } // // バッファのRead BUFFER_SIZE バイトを読み込みます。読み取りをブロックしています。 // AkUInt32 uSizeTransferred; eResult = pStream->Read( pBuffer, BUFFER_SIZE, true, // Blocking AK_DEFAULT_PRIORITY, // Default priority. 0, // 締め切りは0です:データは今すぐ要求されます(もちろん、遅くなります)。 uSizeTransferred ); // リターンコードを確認してください。 if ( eResult != AK_Success ) { printf( "Read failed.\n" ); bSuccess = false; goto stdstmbasictest_cleanup; } // テスト:ファイルの最後に達していない場合、読み込まれるサイズは要求されたサイズと同じでなければなりません。// これを確認します。 bool bReachedEOF; pStream->GetPosition( &bReachedEOF ); if ( !bReachedEOF && uSizeTransferred != BUFFER_SIZE ) { // これは起こりえません。 printf( "Inconsistent transfer size.\n" ); bSuccess = false; goto stdstmbasictest_cleanup; } // 注:現在のストリームの位置はBUFFER_SIZEでなければなりません。 In order for this test to properly // compare data, the input file should be big enough. If we already reached the end of file, leave now. if ( bReachedEOF ) { printf( "Input file not big enough. Could not complete test.\n" ); bSuccess = false; goto stdstmbasictest_cleanup; } // // バッファのRead BUFFER_SIZE バイトを読み込みます。Non-blocking read. // eResult = pStream->Read( pBuffer, BUFFER_SIZE, true, // Non-blocking AK_DEFAULT_PRIORITY, // Default priority. 0, // 締め切りは0です:データは今すぐ要求されます(もちろん、遅くなります)。 uSizeTransferred ); // Check code. if ( eResult != AK_Success ) { printf( "Read failed.\n" ); bSuccess = false; goto stdstmbasictest_cleanup; } // Poll until data is ready. AkStmStatus eStatus = pStream->GetStatus(); while ( eStatus != AK_StmStatusCompleted && eStatus != AK_StmStatusError ) { // Do something else... AKPLATFORM::AkSleep(0); } // Check status. if ( pStream->GetStatus() != AK_StmStatusCompleted ) { printf( "Read failed.\n" ); bSuccess = false; goto stdstmbasictest_cleanup; } // データ比較が失敗するため、EOFに達していないことを再度確認します。 pStream->GetPosition( &bReachedEOF ); if ( bReachedEOF ) { printf( "Input file not big enough. Could not complete test.\n" ); bSuccess = false; goto stdstmbasictest_cleanup; } // // SetPositionをABS_POSITION(ファイルの先頭から絶対)に設定し、バッファ内のBUFFER_SIZEバイトを読み込みます。 // AkInt64 ABS_POSITION = 12000; AkInt64 iRealOffset; eResult = pStream->SetPosition( ABS_POSITION, AK_MoveBegin, &iRealOffset ); // Check return code. if ( eResult != AK_Success ) { printf( "SetPosition failed.\n" ); bSuccess = false; goto stdstmbasictest_cleanup; } // NOTE: Use the returned Real Offset. If the Low-Level I/O specifies a block size greater than 1, // the Stream Manager will snap the seek to the lowest boundary (for example, if seek was 9001 and block // size was 2000, the position would be set to 8000, and so would be iRealOffset). printf( "Set position to %u, low-level block size is %u, actual position set to %u\n", ABS_POSITION, pStream->GetBlockSize(), iRealOffset ); // Read. eResult = pStream->Read( pBuffer, BUFFER_SIZE, true, // Blocking AK_DEFAULT_PRIORITY, // Default priority. 0, // 締め切りは0です:データは今すぐ要求されます(もちろん、遅くなります)。 uSizeTransferred ); // リターンコードを確認してください。 if ( eResult != AK_Success ) { printf( "Read failed.\n" ); bSuccess = false; goto stdstmbasictest_cleanup; } // データ比較が失敗するため、EOFに達していないことを再度確認します。 pStream->GetPosition( &bReachedEOF ); if ( bReachedEOF ) { printf( "Input file not big enough. Could not complete test.\n" ); bSuccess = false; goto stdstmbasictest_cleanup; } // 現在の絶対位置を保持します。 iCurPosition = pStream->GetPosition( NULL ); // // SetPosition を逆方向に、 -REL_POSITION を現在の位置に相対的に、 // AkInt64 REL_POSITION = -8000; eResult = pStream->SetPosition( REL_POSITION, AK_MoveCurrent, &iRealOffset ); // リターンコードをチェックします。 if ( eResult != AK_Success ) { printf( "SetPosition failed.\n" ); bSuccess = false; goto stdstmbasictest_cleanup; } // NOTE: If the block size is greater than 1, the real absolute move offset could be greater than REL_POSITION // (iRealOffset <= REL_POSITION). // NOTE: The new position should be about ABS_POSITION+BUFFER_SIZE+REL_POSITION bytes relative to the beginning // of the file. // iCurPosition contains the "real" ABS_POSITION, and iRealOffset now contains the "real" REL_POSITION, // that is, the real move offset. Therefore, GetPosition(), which always returns the absolute position, // should equal iCurPosition+iRealOffset. if ( pStream->GetPosition( NULL ) != iCurPosition+iRealOffset ) { printf( "Wrong stream position." ); bSuccess = false; goto stdstmbasictest_cleanup; } iCurPosition = pStream->GetPosition( NULL ); printf( "Reading from offset %u.\n", iCurPosition ); // そこから読み込みます。 eResult = pStream->Read( pBuffer, BUFFER_SIZE, true, // Blocking AK_DEFAULT_PRIORITY, // Default priority. 0, // 締め切りは0です:データは今すぐ要求されます(もちろん、遅くなります)。 uSizeTransferred ); // リターンコードを確認してください。 if ( eResult != AK_Success ) { printf( "Read failed.\n" ); bSuccess = false; goto stdstmbasictest_cleanup; } // // Cancelling an operation // // Read. eResult = pStream->Read( pBuffer, BUFFER_SIZE, true, // Blocking AK_DEFAULT_PRIORITY, // Default priority. 0, // 締め切りは0です:データは今すぐ要求されます(もちろん、遅くなります)。 uSizeTransferred ); // リターンコードを確認してください。 if ( eResult != AK_Success ) { printf( "Read failed.\n" ); bSuccess = false; goto stdstmbasictest_cleanup; } // Cancel. pStream->Cancel(); // Here, either the Stream Manager had time to send and complete the request to low-level // (status would be AK_StmStatusCompleted), or it removed it from the queue of pending operations // (status would be AK_StmStatusCancelled). // In either case, we can be sure that no operation is pending for our stream. if ( pStream->GetStatus() != AK_StmStatusCompleted && pStream->GetStatus() != AK_StmStatusCancelled ) { printf( "Inconsistent status after operation cancellation.\n" ); bSuccess = false; goto stdstmbasictest_cleanup; } // // Writing. // // Read. eResult = pStream->Read( pBuffer, BUFFER_SIZE, true, // Blocking AK_DEFAULT_PRIORITY, // Default priority. 0, // 締め切りは0です:データは今すぐ要求されます(もちろん、遅くなります)。 uSizeTransferred ); // リターンコードを確認してください。 if ( eResult != AK_Success ) { printf( "Read failed.\n" ); bSuccess = false; goto stdstmbasictest_cleanup; } // Write back to another file (blocking). // Create stream. AK::IAkStdStream * pWrStream; eResult = AK::IAkStreamMgr::Get()->CreateStd( "out.dat", NULL, // We could use this argument to tell the Low-Level I/O that this file needs to // be created in another storage device (one that supports writing). AK_OpenModeReadWrite, pWrStream, true ); // Require synchronous file open. // リターンコードを確認してください。 if ( eResult != AK_Success ) { printf( "Failed creating stream for writing.\n" ); bSuccess = false; goto stdstmbasictest_cleanup; } eResult = pWrStream->Write( pBuffer, BUFFER_SIZE, true, // Blocking AK_DEFAULT_PRIORITY, // Default priority. 0, // 締め切りは0です:データは今すぐ要求されます(もちろん、遅くなります)。 uSizeTransferred ); // リターンコードを確認してください。 if ( eResult != AK_Success || uSizeTransferred != BUFFER_SIZE ) { printf( "Write failed.\n" ); bSuccess = false; goto stdstmbasictest_cleanup; } // Set position to beginning, and read back file in another buffer to compare data. eResult = pWrStream->SetPosition( POSITION_BEGIN, AK_MoveBegin, NULL ); if ( eResult != AK_Success ) { printf( "SetPosition failed.\n" ); bSuccess = false; goto stdstmbasictest_cleanup; } unsigned char pBufferCheck[BUFFER_SIZE]; eResult = pWrStream->Read( pBufferCheck, BUFFER_SIZE, true, // Blocking AK_DEFAULT_PRIORITY, // Default priority. 0, // 締め切りは0です:データは今すぐ要求されます(もちろん、遅くなります)。 uSizeTransferred ); // リターンコードを確認してください。 if ( eResult != AK_Success || uSizeTransferred != BUFFER_SIZE ) { printf( "Read failed.\n" ); bSuccess = false; goto stdstmbasictest_cleanup; } // データを比較します。 if ( memcmp( pBuffer, pBufferCheck, uSizeTransferred ) != 0 ) { printf( "Data read and written do not match.\n" ); bSuccess = false; goto stdstmbasictest_cleanup; } stdstmbasictest_cleanup: // ストリームを閉じます。 if ( pStream ) pStream->Destroy(); if ( pWrStream ) pWrStream->Destroy(); return bSuccess; } // Automatic streams usage and considerations. // この関数は、テストが成功した場合(Stream Manager が正しく動作する場合)、trueを返します。 bool BasicAutoStreamTest( const AkOSChar * in_pszFilename ) { // 基本的な標準ストリームテスト。 bool bSuccess = true; AK::IAkAutoStream * pStream; // ヒューリスティックを設定します。 AkAutoStmHeuristics heuristics; heuristics.fThroughput = 1048576; // 1 Mb/s // Note: Since this will be the only stream created in the Stream Manager, throughput has no effect. // スケジューラーは常にこのストリームをI / O用に選択します。 heuristics.uLoopStart = 0; heuristics.uLoopEnd = 0; // Not looping. // 注:アプリケーション全体にストリームが1つしかない場合でも、ヒューリスティックのルーピングは重要です。 // なぜなら、ストリームメモリが管理される方法を変更する可能性があるからです。 heuristics.priority = AK_DEFAULT_PRIORITY; // Note: Priority is also irrelevant. However, you must specify a value between AK_MIN_PRIORITY // and AK_MAX_PRIORITY (inclusive), otherwise the Stream Manager will consider its creation settings to be invalid. // Create stream. AKRESULT eResult = AK::IAkStreamMgr::Get()->CreateAuto( in_pszFilename, // File name. NULL, // No file system flags: we provide the full path and do not need any file location resolving logic. heuristics, // Our heuristics. NULL, // Buffer constraints: none. Users should not specify user constraints if they don't need to. pStream, // Returned stream interface. true ); // Require synchronous file open. // リターンコードを確認してください。 if ( eResult != AK_Success ) { printf( "Failed creating stream.\n" ); bSuccess = false; goto autostmbasictest_cleanup; } // ストリームをスタートします。I / Oスケジューラはこのストリームの考慮し始めます。 pStream->Start(); // (GetInfoを介して)ストリームサイズを取得します。 AkStreamInfo streamInfo; pStream->GetInfo( streamInfo ); // 最初のバッファーを取得します。このアクセスはブロックされます。 AkUInt32 uBufferSize; void * pBuffer; eResult = pStream->GetBuffer( pBuffer, // Address of granted data space. uBufferSize, // 与えられたデータスペースのサイズ。 true // データが準備できるまでブロックします。 ); // Check return code. if ( eResult != AK_DataReady && eResult != AK_NoMoreData ) { printf( "GetBuffer failed.\n" ); bSuccess = false; goto autostmbasictest_cleanup; } // ファイルに情報を与えたバッファに格納されているデータを解析したとしましょう。 // たとえば、ファイルが位置10000〜150000(バイト)の間でループしている必要があります。 AkUInt32 uLoopStart = 10000; AkUInt32 uLoopEnd = 150000; // 注:このテストがデータを適切に比較するためには、入力ファイルはuLoopEndより大きくなければなりません。 if ( (AkUInt32)streamInfo.uSize < uLoopEnd ) { printf( "Input file not big enough. Could not complete test.\n" ); bSuccess = false; goto autostmbasictest_cleanup; } // 最適なStream Manager の動作のために、ヒューリスティックを適切に設定する必要があります。 pStream->GetHeuristics( heuristics ); // Note: In the present case, it is not necessary to get the heuristics first. heuristics.uLoopStart = uLoopStart; heuristics.uLoopEnd = uLoopEnd; pStream->SetHeuristics( heuristics ); // 注:現在のストリームの位置は、クライアントが認識する位置です。It is therefore 0, because // we did not release the buffer yet. if ( pStream->GetPosition( NULL ) != 0 ) { printf( "Invalid stream position.\n" ); bSuccess = false; goto autostmbasictest_cleanup; } // バッファをリリースします。 eResult = pStream->ReleaseBuffer(); if ( eResult != AK_Success ) { printf( "ReleaseBuffer failed.\n" ); bSuccess = false; goto autostmbasictest_cleanup; } // 注:バッファを解放したので、現在のストリームの位置はuBufferSizeにする必要があります。 if ( pStream->GetPosition( NULL ) != uBufferSize ) { printf( "Invalid stream position.\n" ); bSuccess = false; goto autostmbasictest_cleanup; } // // 次のシーケンスでは、ストリームマネージャのユーザーは、 "ループ終了"位置が交差するまでバッファを取得し、解放します。 // 位置はGetBuffer()の後に照会されるので、バッファの先頭を参照します。 // ストリーム位置と所有されている // バッファのサイズを加算することで、ループポイントが交差するときにユーザーは「予知します」。この時点で、位置はループの先頭に戻され、 //ヒューリスティックを変更し、最後まで(GetBuffer()がAK_NoMoreDataを返すまで)ファイルを読み込みます。 // バッファを解放した後に位置を取得する方が簡単ですが、 //可能な限り早く位置を変更することをお勧めします。Stream Manager にはヒューリスティックがループしていますが、その使用は //実装固有です。 // bool bEOF = false; bool bDoLoop = true; while ( !bEOF ) { // ポーリングは、uLoopEnd の位置を交差するまで読み取ります。 eResult = pStream->GetBuffer( pBuffer, uBufferSize, false ); // リターンコードをチェックします。 if ( eResult == AK_Fail ) { assert( !"I/O error" ); return false; } else if ( eResult == AK_NoDataReady ) { printf( "Starving...\n" ); } else { // End of file condition. bEOF = ( eResult == AK_NoMoreData ) && !bDoLoop; // ルーピングを処理します。After first call to SetPosition, set bDoLoop to false // so that we stop looping. if ( bDoLoop ) { // Get the current position to see if we crossed the boundary. // ストリームマネージャのユーザーはバッファを所有しているので、GetPosition()は // バッファの先頭の位置を返します。// その値にバッファサイズを加えて、バッファの終わりの位置を取得するために、バッファサイズをその値に加えます。 // 注:GetPosition()を呼び出さずに位置を追跡する方が //より効率的です。 AkUInt32 uCurPosition = pStream->GetPosition( NULL ); if ( ( uCurPosition + uBufferSize ) > uLoopEnd ) { // We crossed the loop end. // ループの開始に位置を設定します。 AkInt64 iLoopStart; iLoopStart.HighPart = 0; iLoopStart.LowPart = uLoopStart; AkInt64 iRealOffset; eResult = pStream->SetPosition( iLoopStart, AK_MoveBegin, &iRealOffset ); if ( eResult != AK_Success ) { printf( "SetPosition failed.\n" ); bSuccess = false; goto autostmbasictest_cleanup; } // Note: Since we did not release the buffer yet, GetPosition() should still return the // position of the start of the buffer. // Verify this. if ( pStream->GetPosition( NULL ) != uCurPosition ) { printf( "Invalid position returned.\n" ); bSuccess = false; goto autostmbasictest_cleanup; } // Note: Our uLoopStart position might not fall directly on the Low-LevelIO block size // for that stream. Users of the Stream Manager are responsible for handling this constraint. // ここで、iRealOffsetが0でない場合、要求された位置よりも小さくなります。 // ストリームマネージャのユーザーは、修正された値をローカル変数に格納することができます。 // Now that position is set, the next buffer access will be at the beginning of the loop // (minus the correction value). // 最高のパフォーマンスを得るには、ルーピング ヒューリスティック値をすぐに変更することができます。 // ルーピングがもうありませんので。 heuristics.uLoopStart = 0; heuristics.uLoopEnd = 0; // 0: Not looping. pStream->SetHeuristics( heuristics ); // ルーピングを停止します。 bDoLoop = false; } } eResult = pStream->ReleaseBuffer(); if ( eResult != AK_Success ) { printf( "ReleaseBuffer failed.\n" ); bSuccess = false; goto autostmbasictest_cleanup; } } // ユーザースループットをシミュレートします。待機時間は、バッファサイズをスループットで割ったものです。 //AKPLATFORM::AkSleep( DWORD( 1000*uBufferSize / heuristics.fThroughput ) ); AKPLATFORM::AkSleep( 0 ); } autostmbasictest_cleanup: if ( pStream ) pStream->Destroy(); return bSuccess; }