| OLD | NEW |
| 1 // Copyright (c) 2012 The Chromium Authors. All rights reserved. | 1 // Copyright (c) 2012 The Chromium Authors. All rights reserved. |
| 2 // Use of this source code is governed by a BSD-style license that can be | 2 // Use of this source code is governed by a BSD-style license that can be |
| 3 // found in the LICENSE file. | 3 // found in the LICENSE file. |
| 4 | 4 |
| 5 #include "ipc/ipc_message.h" | 5 #include "ipc/ipc_message.h" |
| 6 | 6 |
| 7 #include "base/atomic_sequence_num.h" | 7 #include "base/atomic_sequence_num.h" |
| 8 #include "base/logging.h" | 8 #include "base/logging.h" |
| 9 #include "build/build_config.h" | 9 #include "build/build_config.h" |
| 10 #include "ipc/ipc_message_attachment.h" | 10 #include "ipc/ipc_message_attachment.h" |
| (...skipping 28 matching lines...) Expand all Loading... |
| 39 namespace IPC { | 39 namespace IPC { |
| 40 | 40 |
| 41 //------------------------------------------------------------------------------ | 41 //------------------------------------------------------------------------------ |
| 42 | 42 |
| 43 Message::~Message() { | 43 Message::~Message() { |
| 44 } | 44 } |
| 45 | 45 |
| 46 Message::Message() : base::Pickle(sizeof(Header)) { | 46 Message::Message() : base::Pickle(sizeof(Header)) { |
| 47 header()->routing = header()->type = 0; | 47 header()->routing = header()->type = 0; |
| 48 header()->flags = GetRefNumUpper24(); | 48 header()->flags = GetRefNumUpper24(); |
| 49 #if USE_ATTACHMENT_BROKER | |
| 50 header()->num_brokered_attachments = 0; | |
| 51 #endif | |
| 52 #if defined(OS_POSIX) | 49 #if defined(OS_POSIX) |
| 53 header()->num_fds = 0; | 50 header()->num_fds = 0; |
| 54 header()->pad = 0; | 51 header()->pad = 0; |
| 55 #endif | 52 #endif |
| 56 Init(); | 53 Init(); |
| 57 } | 54 } |
| 58 | 55 |
| 59 Message::Message(int32 routing_id, uint32 type, PriorityValue priority) | 56 Message::Message(int32 routing_id, uint32 type, PriorityValue priority) |
| 60 : base::Pickle(sizeof(Header)) { | 57 : base::Pickle(sizeof(Header)) { |
| 61 header()->routing = routing_id; | 58 header()->routing = routing_id; |
| 62 header()->type = type; | 59 header()->type = type; |
| 63 DCHECK((priority & 0xffffff00) == 0); | 60 DCHECK((priority & 0xffffff00) == 0); |
| 64 header()->flags = priority | GetRefNumUpper24(); | 61 header()->flags = priority | GetRefNumUpper24(); |
| 65 #if USE_ATTACHMENT_BROKER | |
| 66 header()->num_brokered_attachments = 0; | |
| 67 #endif | |
| 68 #if defined(OS_POSIX) | 62 #if defined(OS_POSIX) |
| 69 header()->num_fds = 0; | 63 header()->num_fds = 0; |
| 70 header()->pad = 0; | 64 header()->pad = 0; |
| 71 #endif | 65 #endif |
| 72 Init(); | 66 Init(); |
| 73 } | 67 } |
| 74 | 68 |
| 75 Message::Message(const char* data, int data_len) | 69 Message::Message(const char* data, int data_len) |
| 76 : base::Pickle(data, data_len) { | 70 : base::Pickle(data, data_len) { |
| 77 Init(); | 71 Init(); |
| (...skipping 52 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 130 | 124 |
| 131 void Message::set_received_time(int64 time) const { | 125 void Message::set_received_time(int64 time) const { |
| 132 received_time_ = time; | 126 received_time_ = time; |
| 133 } | 127 } |
| 134 #endif | 128 #endif |
| 135 | 129 |
| 136 bool Message::WriteAttachment(scoped_refptr<MessageAttachment> attachment) { | 130 bool Message::WriteAttachment(scoped_refptr<MessageAttachment> attachment) { |
| 137 // We write the index of the descriptor so that we don't have to | 131 // We write the index of the descriptor so that we don't have to |
| 138 // keep the current descriptor as extra decoding state when deserialising. | 132 // keep the current descriptor as extra decoding state when deserialising. |
| 139 WriteInt(attachment_set()->size()); | 133 WriteInt(attachment_set()->size()); |
| 140 | |
| 141 #if USE_ATTACHMENT_BROKER | |
| 142 if (attachment->GetType() == MessageAttachment::TYPE_BROKERABLE_ATTACHMENT) | |
| 143 header()->num_brokered_attachments += 1; | |
| 144 #endif | |
| 145 | |
| 146 return attachment_set()->AddAttachment(attachment); | 134 return attachment_set()->AddAttachment(attachment); |
| 147 } | 135 } |
| 148 | 136 |
| 149 bool Message::ReadAttachment( | 137 bool Message::ReadAttachment( |
| 150 base::PickleIterator* iter, | 138 base::PickleIterator* iter, |
| 151 scoped_refptr<MessageAttachment>* attachment) const { | 139 scoped_refptr<MessageAttachment>* attachment) const { |
| 152 int descriptor_index; | 140 int descriptor_index; |
| 153 if (!iter->ReadInt(&descriptor_index)) | 141 if (!iter->ReadInt(&descriptor_index)) |
| 154 return false; | 142 return false; |
| 155 | 143 |
| (...skipping 12 matching lines...) Expand all Loading... |
| 168 bool Message::HasMojoHandles() const { | 156 bool Message::HasMojoHandles() const { |
| 169 return attachment_set_.get() && attachment_set_->num_mojo_handles() > 0; | 157 return attachment_set_.get() && attachment_set_->num_mojo_handles() > 0; |
| 170 } | 158 } |
| 171 | 159 |
| 172 bool Message::HasBrokerableAttachments() const { | 160 bool Message::HasBrokerableAttachments() const { |
| 173 return attachment_set_.get() && | 161 return attachment_set_.get() && |
| 174 attachment_set_->num_brokerable_attachments() > 0; | 162 attachment_set_->num_brokerable_attachments() > 0; |
| 175 } | 163 } |
| 176 | 164 |
| 177 } // namespace IPC | 165 } // namespace IPC |
| OLD | NEW |