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 "gpu/command_buffer/service/command_buffer_service.h" | 5 #include "gpu/command_buffer/service/command_buffer_service.h" |
6 | 6 |
7 #include <limits> | 7 #include <limits> |
8 | 8 |
9 #include "base/logging.h" | 9 #include "base/logging.h" |
10 #include "base/debug/trace_event.h" | 10 #include "base/debug/trace_event.h" |
(...skipping 85 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
96 num_entries_ = size / sizeof(CommandBufferEntry); | 96 num_entries_ = size / sizeof(CommandBufferEntry); |
97 put_offset_ = 0; | 97 put_offset_ = 0; |
98 SetGetOffset(0); | 98 SetGetOffset(0); |
99 if (!get_buffer_change_callback_.is_null()) { | 99 if (!get_buffer_change_callback_.is_null()) { |
100 get_buffer_change_callback_.Run(ring_buffer_id_); | 100 get_buffer_change_callback_.Run(ring_buffer_id_); |
101 } | 101 } |
102 | 102 |
103 UpdateState(); | 103 UpdateState(); |
104 } | 104 } |
105 | 105 |
106 bool CommandBufferService::SetSharedStateBuffer( | 106 void CommandBufferService::SetSharedStateBuffer( |
107 scoped_ptr<base::SharedMemory> shared_state_shm) { | 107 scoped_ptr<BufferBacking> shared_state_buffer) { |
108 shared_state_shm_.reset(shared_state_shm.release()); | 108 shared_state_buffer_ = shared_state_buffer.Pass(); |
109 if (!shared_state_shm_->Map(sizeof(*shared_state_))) | 109 DCHECK(shared_state_buffer_->GetSize() >= sizeof(*shared_state_)); |
110 return false; | |
111 | 110 |
112 shared_state_ = | 111 shared_state_ = |
113 static_cast<CommandBufferSharedState*>(shared_state_shm_->memory()); | 112 static_cast<CommandBufferSharedState*>(shared_state_buffer_->GetMemory()); |
114 | 113 |
115 UpdateState(); | 114 UpdateState(); |
116 return true; | |
117 } | 115 } |
118 | 116 |
119 void CommandBufferService::SetGetOffset(int32 get_offset) { | 117 void CommandBufferService::SetGetOffset(int32 get_offset) { |
120 DCHECK(get_offset >= 0 && get_offset < num_entries_); | 118 DCHECK(get_offset >= 0 && get_offset < num_entries_); |
121 get_offset_ = get_offset; | 119 get_offset_ = get_offset; |
122 } | 120 } |
123 | 121 |
124 scoped_refptr<Buffer> CommandBufferService::CreateTransferBuffer(size_t size, | 122 scoped_refptr<Buffer> CommandBufferService::CreateTransferBuffer(size_t size, |
125 int32* id) { | 123 int32* id) { |
126 *id = -1; | 124 *id = -1; |
127 | 125 |
128 scoped_ptr<SharedMemory> shared_memory(new SharedMemory()); | 126 scoped_ptr<SharedMemory> shared_memory(new SharedMemory()); |
129 if (!shared_memory->CreateAndMapAnonymous(size)) | 127 if (!shared_memory->CreateAndMapAnonymous(size)) |
130 return NULL; | 128 return NULL; |
131 | 129 |
132 static int32 next_id = 1; | 130 static int32 next_id = 1; |
133 *id = next_id++; | 131 *id = next_id++; |
134 | 132 |
135 if (!RegisterTransferBuffer(*id, shared_memory.Pass(), size)) { | 133 if (!RegisterTransferBuffer( |
| 134 *id, MakeBackingFromSharedMemory(shared_memory.Pass(), size))) { |
136 *id = -1; | 135 *id = -1; |
137 return NULL; | 136 return NULL; |
138 } | 137 } |
139 | 138 |
140 return GetTransferBuffer(*id); | 139 return GetTransferBuffer(*id); |
141 } | 140 } |
142 | 141 |
143 void CommandBufferService::DestroyTransferBuffer(int32 id) { | 142 void CommandBufferService::DestroyTransferBuffer(int32 id) { |
144 transfer_buffer_manager_->DestroyTransferBuffer(id); | 143 transfer_buffer_manager_->DestroyTransferBuffer(id); |
145 if (id == ring_buffer_id_) { | 144 if (id == ring_buffer_id_) { |
146 ring_buffer_id_ = -1; | 145 ring_buffer_id_ = -1; |
147 ring_buffer_ = NULL; | 146 ring_buffer_ = NULL; |
148 num_entries_ = 0; | 147 num_entries_ = 0; |
149 get_offset_ = 0; | 148 get_offset_ = 0; |
150 put_offset_ = 0; | 149 put_offset_ = 0; |
151 } | 150 } |
152 } | 151 } |
153 | 152 |
154 scoped_refptr<Buffer> CommandBufferService::GetTransferBuffer(int32 id) { | 153 scoped_refptr<Buffer> CommandBufferService::GetTransferBuffer(int32 id) { |
155 return transfer_buffer_manager_->GetTransferBuffer(id); | 154 return transfer_buffer_manager_->GetTransferBuffer(id); |
156 } | 155 } |
157 | 156 |
158 bool CommandBufferService::RegisterTransferBuffer( | 157 bool CommandBufferService::RegisterTransferBuffer( |
159 int32 id, | 158 int32 id, |
160 scoped_ptr<base::SharedMemory> shared_memory, | 159 scoped_ptr<BufferBacking> buffer) { |
161 size_t size) { | 160 return transfer_buffer_manager_->RegisterTransferBuffer(id, buffer.Pass()); |
162 return transfer_buffer_manager_->RegisterTransferBuffer( | |
163 id, shared_memory.Pass(), size); | |
164 } | 161 } |
165 | 162 |
166 void CommandBufferService::SetToken(int32 token) { | 163 void CommandBufferService::SetToken(int32 token) { |
167 token_ = token; | 164 token_ = token; |
168 UpdateState(); | 165 UpdateState(); |
169 } | 166 } |
170 | 167 |
171 void CommandBufferService::SetParseError(error::Error error) { | 168 void CommandBufferService::SetParseError(error::Error error) { |
172 if (error_ == error::kNoError) { | 169 if (error_ == error::kNoError) { |
173 error_ = error; | 170 error_ = error; |
(...skipping 16 matching lines...) Expand all Loading... |
190 const GetBufferChangedCallback& callback) { | 187 const GetBufferChangedCallback& callback) { |
191 get_buffer_change_callback_ = callback; | 188 get_buffer_change_callback_ = callback; |
192 } | 189 } |
193 | 190 |
194 void CommandBufferService::SetParseErrorCallback( | 191 void CommandBufferService::SetParseErrorCallback( |
195 const base::Closure& callback) { | 192 const base::Closure& callback) { |
196 parse_error_callback_ = callback; | 193 parse_error_callback_ = callback; |
197 } | 194 } |
198 | 195 |
199 } // namespace gpu | 196 } // namespace gpu |
OLD | NEW |