プロセス間通信でC++の画像データをC#へ渡したいです。

Question

C++dllのOpenCVによって得た画像データを、プロセス間通信をおこないC#へ渡したいです。
共有メモリは動いているようですが、C#側のStreamReadにデータが入っておらず、
全ての要素に0が入っている状態です。

C#側へデータを配列で渡す方法、または
配列以外でデータを渡すよい方法など、ご教授いただきたく思います。

コード
		//--- レンズ歪み補正 ---//
		cv::undistort(dst, dst2, Mtx, Dist);	//L
		DWORD size = dst.dataend - dst.datastart;
		//--- 動画保存 ---//
		writer << dst2;
		cv::imshow("window-cam" + std::to_string(camNo) + "", dst2);//画像を表示．

		//--- dataを配列に格納する ---//
		byte *imgarray = new byte[dst2.rows * dst2.cols * dst2.channels()];	//

		for (int y = 0; y < dst2.rows; y++) {
			// ポインタの取得
			cv::Vec3b* ptr = dst2.ptr<cv::Vec3b>(y);
			for (int x = 0; x < dst2.cols; x++) {
				// 値の取得
				// 対象のピクセルが赤だった場合、BGRの順に"0,0,255"と出力される。
				cv::Vec3b bgr = ptr[x];
				//printf("%d,%d,%d\n", bgr[0], bgr[1], bgr[2]);

				//--- 配列へデータを格納 ---//
				imgarray[(y * dst2.rows) + (3 * x) + 0] = bgr[0];
				imgarray[(y * dst2.rows) + (3 * x) + 1] = bgr[1];
				imgarray[(y * dst2.rows) + (3 * x) + 2] = bgr[2];
			}
		}
		//--- MemoryMappedFile記述 ---//
		//HANDLE hShareMemory = ::OpenFileMapping(FILE_MAP_ALL_ACCESS, false, "ImageAccess");
		HANDLE hShareMemory = ::CreateFileMapping(INVALID_HANDLE_VALUE, NULL, PAGE_READWRITE, 0, size, "ImageAccess");
		if (NULL != hShareMemory) {
			printf("共有メモリオープン成功\n");
			//--- 共有メモリマッピング ---//
			void* cpSharedMemory = ::MapViewOfFile(hShareMemory, FILE_MAP_WRITE, 0, 0, size);	//戻り値 開始アドレス
			if (NULL != cpSharedMemory) {
				printf("共有メモリマッピング成功 %x", (DWORD)cpSharedMemory);		//ハンドル表示

				//--- データコピー ---//
				//memcpy(imgarray, &dst.data, size);
				memcpy(cpSharedMemory, imgarray, sizeof(unsigned char) * size);
				//--- 共有マッピング解除 ---//
				::UnmapViewOfFile(cpSharedMemory);
			}
			else {
				printf("共有マッピング失敗\n");
			}

		}
		else {
			printf("共有メモリオープン失敗\n");
		}
		//--- ファイルマッピングオブジェクトハンドルの開放 ---//
		if (NULL != hShareMemory) {
			printf("共有メモリクローズ\n");
			::CloseHandle(hShareMemory);

		}

コード
            string mappedName = "ImageAccess";
            MemoryMappedFile mmf;
            try
            {
                //--- メモリマップドファイルを開く ---//
                using (mmf = MemoryMappedFile.CreateNew(mappedName, width * height * 5, MemoryMappedFileAccess.ReadWrite))
                {

                    //C++側 マップ書き込み ※FilePathを可変的な記述へ変更のこと
                    
                    string filePath = "C:\images";

                    int check = RecVideoL(camNo, width, height, fps, filePath, mappedName);
                    //}
                    //--- マップドストリーム作成 マップ操作 ---//
                    using (MemoryMappedViewStream stream = mmf.CreateViewStream())
                    {

                        //C#側 マップデータ読み込み
                        stream.Read(imageArr, 0, sizeof(byte) * width * height * 4);

                        //C#側 BMP変換

                        ImageConverter imgConv = new ImageConverter();
                        if (imgConv != null)
                        {
                            Image img = (Image)imgConv.ConvertFrom(imageArr);
                            Bitmap bmp = new Bitmap(img);
                            //PictureBoxへの表示
                            CameraImg.Image = bmp;
                        }
                    }
                }

            }
            catch (Exception ex)
            {
                MessageBox.Show(ex.Message);
                this.Close();
            }

Comments

[takabosoft]

C#側の「mmf」の初期化コードも載せてください。

[mypace]

mmfの初期化コードを追加いたしました。

Answer 1

こういう課題の場合、シンプルなプロジェクトを作ってプロセス間通信部分のみの技術調査を行う事が大事です。

自分でもやってみましたが、

1. C++側がhShareMemoryを::CloseHandle(hShareMemory);した時点でマップファイルは消去され、C#側では読めなくなりました。つまりhShareMemoryはクラスのメンバで管理するなどして、なるべく開きっぱなしの方がよいです。
2. C#側でMemoryMappedFile.CreateNewを使っていますが、これはすでに作成したマップファイルを開くものではなく新規に作成する関数です。作成済みのものを開くのであればMemoryMappedFile.OpenExistingを使えば良さそうです。

...ということが判りましたので、その辺を考慮して修正を行ってください。

以下、検証用コードです。

送信側(c++, MFC)：

void CMappedFileSendDlg::OnBnClickedButton1()
{
    DWORD dwSharedMemorySize = 1024;
	HANDLE hFileMapping = CreateFileMapping(INVALID_HANDLE_VALUE, NULL, PAGE_READWRITE, 0, dwSharedMemorySize, _T("HOGEHOGE"));
	if (hFileMapping) {
		BYTE* pBytes = (BYTE*)::MapViewOfFile(hFileMapping, FILE_MAP_WRITE, 0, 0, dwSharedMemorySize);
		if (pBytes) {
			for (DWORD i = 0; i < 1024; i++) {
				pBytes[i] = (BYTE)i;
			}
			UnmapViewOfFile(pBytes);
		}
		AfxMessageBox(_T("作成済み"));
		CloseHandle(hFileMapping);
	}
}

受信側（C#, WinForms）：

        private void button1_Click(object sender, EventArgs e)
        {
            using (var mmf = MemoryMappedFile.OpenExisting("HOGEHOGE"))
            using (var stream = mmf.CreateViewStream())
            {
                byte[] bytes = new byte[1024];
                if (stream.Read(bytes, 0, 1024) == 1024)
                {
                    foreach (var b in bytes)
                    {
                        Debug.WriteLine(b);
                    }
                }
            }
        }

出力結果：

0
1
2
3
4
5
6
7
8
9
...
（略）

Comments

[mypace]

アドバイスいただきありがとうございます。
検証してプロセス間通信ができました。