Именованные каналы

@NSEb22 · Регистрация: 10.09.2021

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

Доброе время суток. Мне нужно написать именованый канал между С++ и МТ5. На просторах интернета я нашел данную программу под VisualStudio, которую хотел бы взять за основу. Но при запуске из под CLion выдается такая ошибка:
"C:\JetBrains CLion 2021.1.3\bin\cmake\win\bin\cmake.exe" --build D:\CLionProject_2\PipeServer\cmake-build-debug --target PipeServer -- -j 3
[ 25%] Building CXX object CMakeFiles/PipeServer.dir/PipeManager.cpp.obj
D:\CLionProject_2\PipeServer\PipeManager .cpp: In member function 'bool CPipeManager::Create(LPCWSTR)':
D:\CLionProject_2\PipeServer\PipeManager .cpp:33:30: error: cannot convert 'LPCWSTR' {aka 'const wchar_t*'} to 'LPCSTR' {aka 'const char*'}
m_handle=CreateNamedPipe(pipename,PIPE_A CCESS_DUPLEX, PIPE_TYPE_BYTE | PIPE_READMODE_BYTE | PIPE_WAIT, PIPE_UNLIMITED_INSTANCES,256*1024,256*10 24,5000,NULL);
^~~~~~~~
In file included from C:/PROGRA~1/MINGW-~1/X86_64~1.0-P/mingw64/x86_64-w64-mingw32/include/windows.h:70,
from D:\CLionProject_2\PipeServer\StdAfx.h:10 ,
from D:\CLionProject_2\PipeServer\PipeManager .cpp:6:
C:/PROGRA~1/MINGW-~1/X86_64~1.0-P/mingw64/x86_64-w64-mingw32/include/winbase.h:2083:53: note: initializing argument 1 of 'void* CreateNamedPipeA(LPCSTR, DWORD, DWORD, DWORD, DWORD, DWORD, DWORD, LPSECURITY_ATTRIBUTES)'
WINBASEAPI HANDLE WINAPI CreateNamedPipeA (LPCSTR lpName, DWORD dwOpenMode, DWORD dwPipeMode, DWORD nMaxInstances, DWORD nOutBufferSize, DWORD nInBufferSize, DWORD nDefaultTimeOut, LPSECURITY_ATTRIBUTES lpSecurityAttributes);
~~~~~~~^~~~~~
mingw32-make.exe[3]: *** [CMakeFiles\PipeServer.dir\build.make:107 : CMakeFiles/PipeServer.dir/PipeManager.cpp.obj] Error 1
mingw32-make.exe[2]: *** [CMakeFiles\Makefile2:94: CMakeFiles/PipeServer.dir/all] Error 2
mingw32-make.exe[1]: *** [CMakeFiles\Makefile2:101: CMakeFiles/PipeServer.dir/rule] Error 2
mingw32-make.exe: *** [Makefile:136: PipeServer] Error 2

Я так понял, что дело в том что создается указатель типа LPCWSTR, а для создания канала нужен LPCSTR. Подскажите как преобразовать указатель. Если это делать так (LPCSTR)pipname, то он имя канала сокращает до одного символа, хотя ошибку уже не выдает.

PipeServer.cpp

C++
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
#include "stdafx.h"
#include "PipeManager.h"
 
//+------------------------------------------------------------------+
//|                                                                  |
//+------------------------------------------------------------------+
int PipeServer(void)
  {
   wprintf(L"MQL5 Pipe Server\n");
   wprintf(L"Copyright 2012, MetaQuotes Software Corp.\n");
//--- create named pipe
   CPipeManager manager;
 
    if(!manager.Create(L"\\\\.\\\\pipe\\MQL5.Pipe.Server"))
      return(-1);
//   std::cout<<pipename<<std::endl;
//--- wait for client
   char          answer[256];
   int           value=1234567890;
 
   wprintf(L"Client: waiting for connection...\n");
   while(!manager.IsConnected())
     {
      if(!manager.ReadString(answer,_countof(answer)-1))
        {
         Sleep(250);
         continue;
        }
      wprintf(L"Client: connected as '%S'\n",answer);
     }
//--- send data to client
   wprintf(L"Server: send string\n");
   if(!manager.SendString("Hello from pipe server"))
     {
      wprintf(L"Server: sending string failed\n");
      return(-1);
     }
 
   wprintf(L"Server: sending integer\n");
   if(!manager.Send(&value,sizeof(value)))
     {
      wprintf(L"Server: sending integer failed\n");
      return(-1);
     }
//--- read data from client
   wprintf(L"Server: reading string\n");
   if(!manager.ReadString(answer,_countof(answer)-1))
     {
      wprintf(L"Server: reading string failed\n");
      return(-1);
     }
   wprintf(L"Server: '%S' received\n",answer);
 
   wprintf(L"Server: reading integer\n");
   if(!manager.Read(&value,sizeof(value)))
     {
      wprintf(L"Server: reading integer failed\n");
      return(-1);
     }
   wprintf(L"Server: %d received\n",value);
//--- benchmark
   double  volume=0.0;
   double *buffer=new double[1024*1024];   // 8 Mb
 
   wprintf(L"Server: start benchmark\n");
   if(buffer)
     {
      //--- fill the buffer
      for(size_t j=0;j<1024*1024;j++)
         buffer[j]=j;
      //--- send 8 Mb * 128 = 1024 Mb to client
      DWORD   ticks=GetTickCount();
 
      for(size_t i=0;i<128;i++)
        {
         //--- setup guard signatures
         buffer[0]=i;
         buffer[1024*1024-1]=i+1024*1024-1;
         //--- 
         if(!manager.Send(buffer,sizeof(double)*1024*1024))
           {
            wprintf(L"Server: benchmark failed, %d\n",GetLastError());
            break;
           }
         volume+=sizeof(double)*1024*1024;
         wprintf(L".");
        }
      wprintf(L"\n");
      //--- read confirmation
      if(!manager.Read(&value,sizeof(value)) || value!=12345)
         wprintf(L"Server: benchmark confirmation failed\n");
      //--- show statistics
      ticks=GetTickCount()-ticks;
      if(ticks>0)
         wprintf(L"Server: %.0lf Mb sent at %.0lf Mb per second\n",volume/1024/1024,volume/1024/ticks);
      //---
      delete[] buffer;
     }
//---
   return(0);
  }
//+------------------------------------------------------------------+
//|                                                                  |
//+------------------------------------------------------------------+
int _tmain(int argc, _TCHAR* argv[])
  {
   wprintf(L"MQL5 Pipe Server\n");
   wprintf(L"Copyright 2012, MetaQuotes Software Corp.\n");
//--- create named pipe
   while(true)
     {
      PipeServer();
     }
//---
   return(0);
  }
//+------------------------------------------------------------------+

PipeManager.cpp

C++
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
182
183
184
#include "StdAfx.h"
#include "PipeManager.h"
 
//+------------------------------------------------------------------+
//| Constructor                                                      |
//+------------------------------------------------------------------+
CPipeManager::CPipeManager(void):m_handle(INVALID_HANDLE_VALUE),m_connected(false)
  {
  }
//+------------------------------------------------------------------+
//| Destructor                                                       |
//+------------------------------------------------------------------+
CPipeManager::~CPipeManager(void)
  {
   Close();
  }
//+------------------------------------------------------------------+
//| Create named pipe                                                |
//+------------------------------------------------------------------+
bool CPipeManager::Create(LPCWSTR pipename)
  {
//--- check parameters
   if(!pipename || *pipename==0) return(false);
//--- close old
   Close();
//--- create named pipe
//   m_handle=CreateNamedPipe(pipename,PIPE_ACCESS_DUPLEX, PIPE_TYPE_BYTE | PIPE_READMODE_BYTE | PIPE_WAIT, PIPE_UNLIMITED_INSTANCES,256*1024,256*1024,5000,NULL);
    m_handle=CreateNamedPipe(pipename,PIPE_ACCESS_DUPLEX, PIPE_TYPE_BYTE | PIPE_READMODE_BYTE | PIPE_WAIT, PIPE_UNLIMITED_INSTANCES,256*1024,256*1024,5000,NULL);
   if(m_handle==INVALID_HANDLE_VALUE)
     {
      wprintf(L"Creating pipe '%s' failed\n",pipename);
      return(false);
     }
//--- ok
   wprintf(L"Pipe '%s' created\n",pipename);
   return(true);
  }
//+------------------------------------------------------------------+
//| Close pipe                                                       |
//+------------------------------------------------------------------+
void CPipeManager::Close(void)
  {
//--- pipe exists?
   if(m_handle!=INVALID_HANDLE_VALUE)
     {
      DisconnectNamedPipe(m_handle);     // disconnect
      CloseHandle(m_handle);             // close
      m_handle=INVALID_HANDLE_VALUE;
     }
//---
  }
//+------------------------------------------------------------------+
//| Client connected?                                                |
//+------------------------------------------------------------------+
bool CPipeManager::IsConnected(void)
  {
   return(m_connected);
  }
//+------------------------------------------------------------------+
//| Connect client                                                   |
//+------------------------------------------------------------------+
bool CPipeManager::ConnectClient(void)
  {
//--- pipe exists?
   if(m_handle==INVALID_HANDLE_VALUE) return(false);
//--- connected?
   if(!m_connected)
     {
      //--- connect
      if(ConnectNamedPipe(m_handle,NULL)==0)
        {
         //--- client already connected before ConnectNamedPipe?
         if(GetLastError()!=ERROR_PIPE_CONNECTED)
            return(false);
         //--- ok
        }
      m_connected=true;
     }
//---
   return(true);
  }
//+------------------------------------------------------------------+
//| Disconnect                                                       |
//+------------------------------------------------------------------+
void CPipeManager::DisconnectClient(void)
  {
//--- pipe exists?
   if(m_handle!=INVALID_HANDLE_VALUE)
     {
      FlushFileBuffers(m_handle);
      DisconnectNamedPipe(m_handle);
     }
//--- drop flag
   m_connected=false;
  }
//+------------------------------------------------------------------+
//| Send any data                                                    |
//+------------------------------------------------------------------+
bool CPipeManager::Send(void *data,size_t data_size)
  {
//--- check parameters
   if(!data || data_size<1) return(false);
//--- connected?
   if(!m_connected)
      if(!ConnectClient())
         return(false);
//--- send data
   DWORD written=0;
   if(!WriteFile(m_handle,data,data_size,&written,NULL) || written!=data_size)
      return(false);
//--- ok
   return(true);
  }
//+------------------------------------------------------------------+
//| Read any data                                                    |
//+------------------------------------------------------------------+
bool CPipeManager::Read(void *data,size_t data_size)
  {
//--- check parameters
   if(!data || data_size<1) return(false);
//--- connected?
   if(!m_connected)
      if(!ConnectClient())
         return(false);
//--- read data
   DWORD received=0;
 
   if(!ReadFile(m_handle,data,data_size,&received,NULL) || received!=data_size)
      return(false);
//--- ok
   return(true);
  }
//+------------------------------------------------------------------+
//| Send string                                                      |
//+------------------------------------------------------------------+
bool CPipeManager::SendString(LPCSTR command)
  {
//--- check parameters
   if(!command || *command==0) return(false);
//--- connected?
   if(!m_connected)
      if(!ConnectClient())
         return(false);
//--- send string (size+data)
   DWORD size=strlen(command);
   DWORD written=0;
 
   if(!WriteFile(m_handle,&size,sizeof(size),&written,NULL) || written!=sizeof(size))
      return(false);
 
   if(!WriteFile(m_handle,command,size,&written,NULL) || written!=size)
      return(false);
//--- ok
   return(true);
  }
//+------------------------------------------------------------------+
//| Read string from client                                          |
//+------------------------------------------------------------------+
bool CPipeManager::ReadString(LPSTR answer,size_t answer_maxlen)
  {
//--- check parameters
   if(!answer || answer_maxlen<2) return(false);
   *answer=0;
//--- connected?
   if(!m_connected)
      if(!ConnectClient())
         return(false);
//--- read ANSI string (size+data)
   DWORD size=0;
   DWORD received=0;
 
   if(!ReadFile(m_handle,&size,sizeof(size),&received,NULL) || received!=sizeof(size))
      return(false);
 
   if(size<2 || size>answer_maxlen)
      return(false);
 
   if(!ReadFile(m_handle,answer,size,&received,NULL) || received!=size)
      return(false);
   answer[size]=0;
//--- ok
   return(true);
  }
//+------------------------------------------------------------------+

@hoggy · 21.01.2022, 21:33

Сообщение от NSEb22

bool CPipeManager::Create(LPCWSTR pipename)

CreateNamedPipeW

Новые блоги и статьи Все статьи Все блоги /
Новый ноутбук volvo 07.12.2025 Всем привет. По скидке в "черную пятницу" взял себе новый ноутбук Lenovo ThinkBook 16 G7 на Амазоне: Ryzen 5 7533HS 64 Gb DDR5 1Tb NVMe 16" Full HD Display Win11 Pro	Музыка, написанная Искусственным Интеллектом volvo 04.12.2025 Всем привет. Некоторое время назад меня заинтересовало, что уже умеет ИИ в плане написания музыки для песен, и, собственно, исполнения этих самых песен. Стихов у нас много, уже вышли 4 книги, еще 3. . .	От async/await к виртуальным потокам в Python IndentationError 23.11.2025 Армин Ронахер поставил под сомнение async/ await. Создатель Flask заявляет: цветные функции - провал, виртуальные потоки - решение. Не threading-динозавры, а новое поколение лёгких потоков. Откат?. . .	Поиск "дружественных имён" СОМ портов Argus19 22.11.2025 Поиск "дружественных имён" СОМ портов На странице: https:/ / norseev. ru/ 2018/ 01/ 04/ comportlist_windows/ нашёл схожую тему. Там приведён код на С++, который показывает только имена СОМ портов, типа,. . .	Сколько Государство потратило денег на меня, обеспечивая инсулином. Programma_Boinc 20.11.2025 Сколько Государство потратило денег на меня, обеспечивая инсулином. Вот решила сделать интересный приблизительный подсчет, сколько государство потратило на меня денег на покупку инсулинов. . . .
Ломающие изменения в C#.NStar Alpha Etyuhibosecyu 20.11.2025 Уже можно не только тестировать, но и пользоваться C#. NStar - писать оконные приложения, содержащие надписи, кнопки, текстовые поля и даже изображения, например, моя игра "Три в ряд" написана на этом. . .	Мысли в слух kumehtar 18.11.2025 Кстати, совсем недавно имел разговор на тему медитаций с людьми. И обнаружил, что они вообще не понимают что такое медитация и зачем она нужна. Самые базовые вещи. Для них это - когда просто люди. . .	Создание Single Page Application на фреймах krapotkin 16.11.2025 Статья исключительно для начинающих. Подходы оригинальностью не блещут. В век Веб все очень привыкли к дизайну Single-Page-Application . Быстренько разберем подход "на фреймах". Мы делаем одну. . .	Фото: Daniel Greenwood kumehtar 13.11.2025	Расскажи мне о Мире, бродяга kumehtar 12.11.2025 — Расскажи мне о Мире, бродяга, Ты же видел моря и метели. Как сменялись короны и стяги, Как эпохи стрелою летели. - Этот мир — это крылья и горы, Снег и пламя, любовь и тревоги, И бескрайние. . .