RepoMirrors/ceph
1
0
Fork 0
mirror of https://github.com/ceph/ceph synced 2025-03-11 02:39:05 +00:00
Code Issues Packages Projects Releases Wiki Activity

fixed use of PAGE_MASK in simplemessenger

Browse Source
This commit is contained in:
Sage Weil 2008-01-04 15:32:19 -08:00
parent 95efa1fe0a
commit b613593d6d
1 changed files with 3 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
src/msg/SimpleMessenger.cc
View File

@ -1302,9 +1302,9 @@ Message *Rank::Pipe::read_message()
bufferlist data;
if (env.data_len) {
int left = env.data_len;
if (env.data_off & PAGE_MASK) {
if (env.data_off & ~PAGE_MASK) {
// head
int head = MIN(PAGE_SIZE - (env.data_off & PAGE_MASK),
int head = MIN(PAGE_SIZE - (env.data_off & ~PAGE_MASK),
(unsigned)left);
bp = buffer::create(head);
if (tcp_read( sd, bp.c_str(), head ) < 0)
@ -1315,7 +1315,7 @@ Message *Rank::Pipe::read_message()
}
// middle
int middle = left & ~PAGE_MASK;
int middle = left & PAGE_MASK;
if (middle > 0) {
bp = buffer::create_page_aligned(middle);
if (tcp_read( sd, bp.c_str(), middle ) < 0)