Межпроцессное взаимодествие (анонимный канал и WM_COPYDATA)

@Кротяка · Регистрация: 20.12.2010

Студворк — интернет-сервис помощи студентам

Здравствуйте. Есть матрица типа int**, с которой необходимо произвести следующие действия:
1) Отправить другому приложению (серверу) для обработки, используя анонимный канал
2) Вернуть преобразованную матрицу исходному приложению (клиенту), используя сообщение WM_COPYDATA

Что, собственно, пытаюсь делать:
1)
Создание анонимного канала и отправка матрицы на сервер:

C++

DWORD dwWritten;
HANDLE hRead, hWrite;
SECURITY_ATTRIBUTES saAttr;
    
saAttr.bInheritHandle = TRUE;
saAttr.lpSecurityDescriptor = NULL;
saAttr.nLength = sizeof (SECURITY_ATTRIBUTES);  
 
CreatePipe(&hRead, &hWrite, &saAttr, 0));
hPipe = CreateFile(L"Client", GENERIC_READ | GENERIC_WRITE, 0, &saAttr, CREATE_ALWAYS, FILE_ATTRIBUTE_NORMAL, NULL);
WriteFile(hPipe, initial_matrix, sizeof(int) * N * N, &dwWritten, NULL); //initial_matrix - "готовая" матрица, N - размерность
CloseHandle(hWrite);
 
SendMessage(FindWindow(L"Server", NULL), WM_RECV_FROM_KLIENT, NULL, NULL);
 
CloseHandle(hPipe);

Попытка "приёма" матрицы на сервере:

C++

case WM_RECV_FROM_KLIENT:
    CreatePipe(&hRead, &hWrite, &saAttr, 0);
    hPipe = CreateFile(L"Client", GENERIC_READ, 0, NULL, OPEN_EXISTING, FILE_ATTRIBUTE_NORMAL, NULL);
 
    if (!ReadFile(hPipe, initial_matrix, sizeof(int) * N * N, &dwRead, NULL)) 
    {
        MessageBox(NULL, L"Ошибка чтения файла!", L"Ошибка", MB_OK | MB_ICONERROR);
        return;
    }
    ...

Собственно, "Ошибка чтения файла!"...Хочу понять, в чём проблема и как её можно было бы решить

2)
Пытаюсь "вернуть" клиенту новую матрицу, заполненную единицами(раз уж исходную принять не получается):

C++

typedef struct Matrix
{
    int size;
    int **result_matrix;
} New_Matrix;
...
COPYDATASTRUCT MyCDS;
MyCDS.dwData = 1;
New_Matrix new_matrix;
new_matrix.result_matrix = initial_matrix;//забегая вперёд отмечу, что матрица проинициализирована правильно
new_matrix.size = N;//размерность
MyCDS.cbData = sizeof(new_matrix);
MyCDS.lpData = &new_matrix;
SendMessage(FindWindow(L"Client", NULL), WM_COPYDATA, (WPARAM)(HWND) hWnd, (LPARAM)(LPVOID) &MyCDS);

В итоге обрабатываю полученную матрицу на клиенте:

C++

typedef struct Matrix
{
    int size;
    int **result_matrix;
} New_Matrix;
...
PCOPYDATASTRUCT pMyCDS;
...
case WM_COPYDATA:
    pMyCDS = (PCOPYDATASTRUCT) lParam;
 
    switch(pMyCDS->dwData)
    {
        case 1:
        New_Matrix new_matrix;
            new_matrix.result_matrix = ((New_Matrix *) (pMyCDS->lpData))->result_matrix;
        new_matrix.size = ((New_Matrix *) (pMyCDS->lpData))->size;
            //и теперь самое интересное
            sprintf_s(tmp, "%d  ", new_matrix.size);//РАБОТАЕТ
        MessageBoxA(hWnd, tmp, "Размер", MB_OK | MB_ICONINFORMATION);
            sprintf_s(tmp, "%d  ", new_matrix.result_matrix[0][0]);//НЕ РАБОТАЕТ
        MessageBoxA(hWnd, tmp, "Элемент", MB_OK | MB_ICONINFORMATION);
            ...

По всей видимости, я просто неправильно пытаюсь считать двумерный массив, ведь попытки просмотреть его контрольные значения при отладке говорят о том, что "Чтение памяти невозможно", при том, что размерность(new_matrix.size) считывается нормально

Буду рад любой помощи по этим двум вопросам.

@schdub · 24.01.2017, 21:03

Сообщение от Кротяка

Собственно, "Ошибка чтения файла!"...Хочу понять, в чём проблема и как её можно было бы решить

После ошибки в ReadFile() вызовите GetLastError() чтобы узнать причины.

Сообщение от Кротяка

C

MyCDS.dwData = 1;
New_Matrix new_matrix;
new_matrix.result_matrix = initial_matrix;//забегая вперёд отмечу, что матрица проинициализирована правильно
new_matrix.size = N;//размерность
MyCDS.cbData = sizeof(new_matrix);
MyCDS.lpData = &new_matrix;

Так вы передаете sizeof(new_matrix) байт с указателями на int внутри процесса сервара, для процесса клинта эти укзатели будут указывать на мусор. Нужно собрать все int числа, чтобы они последовательно шли друг за другом, для чего потребуется N * M * sizeof(int) байт. В cbData должно быть это число, а в lpData указатель на N*M целых чисел идущих в памяти последовательно, друг за другом.

@Кротяка · 25.01.2017, 00:25 **[ТС]**

schdub, спасибо за отклик.

После ошибки в ReadFile() вызовите GetLastError() чтобы узнать причины.

Дело в том, что я не совсем понимаю, как правильно использовать анонимные каналы, потому как материала по этой теме в сети немного, и его исследование мало что дало. Собственно, за этим вопросом я и обратился сюда, попутно указав, чего удалось достичь. GetLastError() возвращает ошибку с кодом 6(ERROR_INVALID_HANDLE), указывающую на неверный дескриптор.

Что касается второго пункта - можете изобразить наглядно?(если не тяжело)

@Alex5 · 25.01.2017, 13:36

Сообщение от Кротяка

Дело в том, что я не совсем понимаю, как ...

Кротяка, зачем сразу вместе собирать все непонятные вопросы? Можно разобраться отдельно.

C++

1 2	int mesg[5]={ 10, 20, 30, 40, 50 }; // попробуем отправить mesg по анонимному каналу.

Добавлено через 35 минут

Сообщение от Кротяка

C++

1 2	hPipe = CreateFile(L"Client", ... WriteFile(hPipe, ...

Кротяка, здесь вы записываете что-то в файл Client.

@Кротяка · 25.01.2017, 13:40 **[ТС]**

Alex5, ну вопроса то всего 2 (как правильно передать данные через анонимный канал и как вернуть эти данные при помощи WM_COPYDATA), и т.к. они взаимосвязаны, то потому и спрашиваю в одной теме

@Alex5 · 25.01.2017, 15:18

Не по теме:

Сообщение от Кротяка

ну вопроса то всего 2

Кротяка, судя по коду, есть еще вопросы, с которыми стоит разобраться. Что такое указатель. Чем отличаются int**, int[N][N].
Если непонятно, чем int** отличается от массива, не нужно его использовать в этом примере.

Добавлено через 36 минут

Сообщение от Кротяка

C++

typedef struct Matrix
{
 int size;
 int **result_matrix;
} New_Matrix;
...
 
COPYDATASTRUCT MyCDS;
MyCDS.dwData = 1;
New_Matrix new_matrix;
new_matrix.result_matrix = initial_matrix;//забегая вперёд отмечу, что матрица проинициализирована правильно

Как проинициализирована initial_matrix?

C++

1 2	new_matrix.size = N;//размерность MyCDS.cbData = sizeof(new_matrix);

Кротяка, пусть N=100. Сколько байт данных в этом случае нужно передать клиенту ? Чему равняется sizeof(new_matrix) ?

@Кротяка · 25.01.2017, 16:07 **[ТС]**

Alex5,

Как проинициализирована initial_matrix?

C++

double Q, x;
int N;
 
N = 8;
Q = 0.5;
 
initial_matrix = new int*[N];
 
for (int i = 0; i < N; i++)
    initial_matrix[i] = new int[N];
 
srand((unsigned)time(0));
 
for (int i = 0; i < N; i++)
    for (int j = 0; j < N; j++)
    {
        x = (double)(rand()) / RAND_MAX;
 
        if (x >= Q)
            initial_matrix[i][j] = 1;
        else
            if (x < Q)
                initial_matrix[i][j] = 0;
    }

@Кротяка 7 / 7 / 1 Регистрация: 20.12.2010 Сообщений: 392
	25.01.2017, 00:25 [ТС]	3
	schdub, спасибо за отклик. После ошибки в ReadFile() вызовите GetLastError() чтобы узнать причины. Дело в том, что я не совсем понимаю, как правильно использовать анонимные каналы, потому как материала по этой теме в сети немного, и его исследование мало что дало. Собственно, за этим вопросом я и обратился сюда, попутно указав, чего удалось достичь. GetLastError() возвращает ошибку с кодом 6(ERROR_INVALID_HANDLE), указывающую на неверный дескриптор. Что касается второго пункта - можете изобразить наглядно?(если не тяжело) 0

@Кротяка 7 / 7 / 1 Регистрация: 20.12.2010 Сообщений: 392
	25.01.2017, 13:40 [ТС]	5
	Alex5, ну вопроса то всего 2 (как правильно передать данные через анонимный канал и как вернуть эти данные при помощи WM_COPYDATA), и т.к. они взаимосвязаны, то потому и спрашиваю в одной теме 0

	25.01.2017, 16:07