OLD | NEW |
1 // Copyright 2015 The Chromium Authors. All rights reserved. | 1 // Copyright 2015 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 "content/child/shared_memory_received_data_factory.h" | 5 #include "content/child/shared_memory_received_data_factory.h" |
6 | 6 |
7 #include <algorithm> | 7 #include <algorithm> |
8 | 8 |
9 #include "base/macros.h" | 9 #include "base/macros.h" |
10 #include "base/memory/ptr_util.h" | 10 #include "base/memory/ptr_util.h" |
11 #include "content/common/resource_messages.h" | 11 #include "content/common/resource_messages.h" |
12 #include "ipc/ipc_sender.h" | 12 #include "ipc/ipc_sender.h" |
13 | 13 |
14 namespace content { | 14 namespace content { |
15 | 15 |
16 class SharedMemoryReceivedDataFactory::SharedMemoryReceivedData final | 16 class SharedMemoryReceivedDataFactory::SharedMemoryReceivedData final |
17 : public RequestPeer::ReceivedData { | 17 : public RequestPeer::ReceivedData { |
18 public: | 18 public: |
19 SharedMemoryReceivedData( | 19 SharedMemoryReceivedData( |
20 const char* payload, | 20 const char* payload, |
21 int length, | 21 int length, |
22 int encoded_data_length, | |
23 scoped_refptr<SharedMemoryReceivedDataFactory> factory, | 22 scoped_refptr<SharedMemoryReceivedDataFactory> factory, |
24 SharedMemoryReceivedDataFactory::TicketId id) | 23 SharedMemoryReceivedDataFactory::TicketId id) |
25 : payload_(payload), | 24 : payload_(payload), |
26 length_(length), | 25 length_(length), |
27 encoded_data_length_(encoded_data_length), | |
28 factory_(factory), | 26 factory_(factory), |
29 id_(id) {} | 27 id_(id) {} |
30 | 28 |
31 ~SharedMemoryReceivedData() override { factory_->Reclaim(id_); } | 29 ~SharedMemoryReceivedData() override { factory_->Reclaim(id_); } |
32 | 30 |
33 const char* payload() const override { return payload_; } | 31 const char* payload() const override { return payload_; } |
34 int length() const override { return length_; } | 32 int length() const override { return length_; } |
35 int encoded_data_length() const override { return encoded_data_length_; } | |
36 | 33 |
37 private: | 34 private: |
38 const char* const payload_; | 35 const char* const payload_; |
39 const int length_; | 36 const int length_; |
40 const int encoded_data_length_; | |
41 | 37 |
42 scoped_refptr<SharedMemoryReceivedDataFactory> factory_; | 38 scoped_refptr<SharedMemoryReceivedDataFactory> factory_; |
43 SharedMemoryReceivedDataFactory::TicketId id_; | 39 SharedMemoryReceivedDataFactory::TicketId id_; |
44 | 40 |
45 DISALLOW_COPY_AND_ASSIGN(SharedMemoryReceivedData); | 41 DISALLOW_COPY_AND_ASSIGN(SharedMemoryReceivedData); |
46 }; | 42 }; |
47 | 43 |
48 SharedMemoryReceivedDataFactory::SharedMemoryReceivedDataFactory( | 44 SharedMemoryReceivedDataFactory::SharedMemoryReceivedDataFactory( |
49 IPC::Sender* message_sender, | 45 IPC::Sender* message_sender, |
50 int request_id, | 46 int request_id, |
51 linked_ptr<base::SharedMemory> memory) | 47 linked_ptr<base::SharedMemory> memory) |
52 : id_(0), | 48 : id_(0), |
53 oldest_(0), | 49 oldest_(0), |
54 message_sender_(message_sender), | 50 message_sender_(message_sender), |
55 request_id_(request_id), | 51 request_id_(request_id), |
56 is_stopped_(false), | 52 is_stopped_(false), |
57 memory_(memory) { | 53 memory_(memory) { |
58 } | 54 } |
59 | 55 |
60 SharedMemoryReceivedDataFactory::~SharedMemoryReceivedDataFactory() { | 56 SharedMemoryReceivedDataFactory::~SharedMemoryReceivedDataFactory() { |
61 if (!is_stopped_) | 57 if (!is_stopped_) |
62 SendAck(released_tickets_.size()); | 58 SendAck(released_tickets_.size()); |
63 } | 59 } |
64 | 60 |
65 std::unique_ptr<RequestPeer::ReceivedData> | 61 std::unique_ptr<RequestPeer::ReceivedData> |
66 SharedMemoryReceivedDataFactory::Create(int offset, | 62 SharedMemoryReceivedDataFactory::Create(int offset, int length) { |
67 int length, | |
68 int encoded_data_length) { | |
69 const char* start = static_cast<char*>(memory_->memory()); | 63 const char* start = static_cast<char*>(memory_->memory()); |
70 const char* payload = start + offset; | 64 const char* payload = start + offset; |
71 TicketId id = id_++; | 65 TicketId id = id_++; |
72 | 66 |
73 return base::MakeUnique<SharedMemoryReceivedData>( | 67 return base::MakeUnique<SharedMemoryReceivedData>(payload, length, this, id); |
74 payload, length, encoded_data_length, this, id); | |
75 } | 68 } |
76 | 69 |
77 void SharedMemoryReceivedDataFactory::Stop() { | 70 void SharedMemoryReceivedDataFactory::Stop() { |
78 is_stopped_ = true; | 71 is_stopped_ = true; |
79 released_tickets_.clear(); | 72 released_tickets_.clear(); |
80 message_sender_ = nullptr; | 73 message_sender_ = nullptr; |
81 } | 74 } |
82 | 75 |
83 class SharedMemoryReceivedDataFactory::TicketComparator final { | 76 class SharedMemoryReceivedDataFactory::TicketComparator final { |
84 public: | 77 public: |
(...skipping 39 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
124 SendAck(count); | 117 SendAck(count); |
125 } | 118 } |
126 | 119 |
127 void SharedMemoryReceivedDataFactory::SendAck(size_t count) { | 120 void SharedMemoryReceivedDataFactory::SendAck(size_t count) { |
128 for (size_t i = 0; i < count; ++i) { | 121 for (size_t i = 0; i < count; ++i) { |
129 message_sender_->Send(new ResourceHostMsg_DataReceived_ACK(request_id_)); | 122 message_sender_->Send(new ResourceHostMsg_DataReceived_ACK(request_id_)); |
130 } | 123 } |
131 } | 124 } |
132 | 125 |
133 } // namespace content | 126 } // namespace content |
OLD | NEW |