coffee/cpp-ipc
1
0
Fork 0
mirror of https://github.com/mutouyun/cpp-ipc.git synced 2025-12-07 01:06:45 +08:00
Code Issues Packages Projects Releases Wiki Activity

for vs2015

Browse Source
This commit is contained in:
mutouyun 2019-01-25 16:49:02 +08:00
parent efe7353e55
commit 7461dc88ed
1 changed files with 10 additions and 9 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

19
src/ipc.cpp
View File

@ -42,7 +42,8 @@ struct msg_t<0, AlignSize> {
}; };
template <std::size_t DataSize, std::size_t AlignSize> template <std::size_t DataSize, std::size_t AlignSize>
struct msg_t : msg_t<0, AlignSize> { struct msg_t {
msg_t<0, AlignSize> head_;
alignas(AlignSize) byte_t data_[DataSize]; alignas(AlignSize) byte_t data_[DataSize];
}; };
@ -172,25 +173,25 @@ static buff_t recv(ipc::handle_t h) {
while (1) { while (1) {
// pop a new message // pop a new message
auto msg = que->pop(); auto msg = que->pop();
if (msg.id_ == 0) return {}; if (msg.head_.id_ == 0) return {};
if (msg.que_ == que) continue; // pop next if (msg.head_.que_ == que) continue; // pop next
// msg.remain_ may minus & abs(msg.remain_) < data_length // msg.head_.remain_ may minus & abs(msg.head_.remain_) < data_length
std::size_t remain = static_cast<std::size_t>( std::size_t remain = static_cast<std::size_t>(
static_cast<int>(data_length) + msg.remain_); static_cast<int>(data_length) + msg.head_.remain_);
// find cache with msg.id_ // find cache with msg.head_.id_
auto cac_it = rc.find(msg.id_); auto cac_it = rc.find(msg.head_.id_);
if (cac_it == rc.end()) { if (cac_it == rc.end()) {
if (remain <= data_length) { if (remain <= data_length) {
return make_cache(msg.data_, remain); return make_cache(msg.data_, remain);
} }
// cache the first message fragment // cache the first message fragment
else rc.emplace(msg.id_, cache_t { data_length, make_cache(msg.data_, remain) }); else rc.emplace(msg.head_.id_, cache_t { data_length, make_cache(msg.data_, remain) });
} }
// has cached before this message // has cached before this message
else { else {
auto& cac = cac_it->second; auto& cac = cac_it->second;
// this is the last message fragment // this is the last message fragment
if (msg.remain_ <= 0) { if (msg.head_.remain_ <= 0) {
cac.append(msg.data_, remain); cac.append(msg.data_, remain);
// finish this message, erase it from cache // finish this message, erase it from cache
auto buff = std::move(cac.buff_); auto buff = std::move(cac.buff_);