yyc12345/BasaltMeter
1
0
Fork 0
Code Activity

finish buggy dx11 code

Browse Source
This commit is contained in:
yyc12345
2026-01-04 23:11:58 +08:00
parent a66d3dee8b
commit 7b234ec405
12 changed files with 432 additions and 219 deletions
Download Patch File Download Diff File Expand all files Collapse all files

40
BasaltPresenter/Shared/pipe_operator.cpp
View File

@@ -16,13 +16,13 @@ namespace Basalt::Shared {
// Create Windows pipe name from given name
auto fullname = std::format(BSTEXT("\\\\.\\pipe\\{}"), name);
m_Handle = CreateFileW(fullname.c_str(), // 管道名称
GENERIC_READ | GENERIC_WRITE, // 读写权限
0, // 不共享
NULL, // 默认安全属性
OPEN_EXISTING, // 打开已存在的管道
0, // 默认属性
NULL // 无模板文件
m_Handle = CreateFileW(fullname.c_str(), // 管道名称
GENERIC_READ | GENERIC_WRITE, // 读写权限
0, // 不共享
NULL, // 默认安全属性
OPEN_EXISTING, // 打开已存在的管道
0, // 默认属性
NULL // 无模板文件
);
if (m_Handle == BAD_PIPE_HANDLE) {
@@ -80,16 +80,16 @@ namespace Basalt::Shared {
void PipeOperator::Read(void *buffer, size_t size) {
if (size == 0) {
return; // 读取0字节直接返回
return; // 读取0字节直接返回
}
#if defined(BASALT_OS_WINDOWS)
DWORD bytesRead = 0;
BOOL success = ReadFile(m_Handle, // 管道句柄
buffer, // 缓冲区
static_cast<DWORD>(size), // 缓冲区大小
&bytesRead, // 实际读取的字节数
NULL // 不使用重叠I/O
BOOL success = ReadFile(m_Handle, // 管道句柄
buffer, // 缓冲区
static_cast<DWORD>(size), // 缓冲区大小
&bytesRead, // 实际读取的字节数
NULL // 不使用重叠I/O
);
if (!success) {
@@ -111,7 +111,7 @@ namespace Basalt::Shared {
}
if (bytesRead == 0) {
// 管道已关闭或到达末尾
// 管道已关闭或到达末尾
throw std::runtime_error("Named pipe closed during read.");
}
@@ -126,16 +126,16 @@ namespace Basalt::Shared {
void PipeOperator::Write(const void *buffer, size_t size) {
if (size == 0) {
return; // 写入0字节直接返回
return; // 写入0字节直接返回
}
#if defined(BASALT_OS_WINDOWS)
DWORD bytesWritten = 0;
BOOL success = WriteFile(m_Handle, // 管道句柄
buffer, // 数据缓冲区
static_cast<DWORD>(size), // 数据大小
&bytesWritten, // 实际写入的字节数
NULL // 不使用重叠I/O
BOOL success = WriteFile(m_Handle, // 管道句柄
buffer, // 数据缓冲区
static_cast<DWORD>(size), // 数据大小
&bytesWritten, // 实际写入的字节数
NULL // 不使用重叠I/O
);
if (!success) {