| OLD | NEW |
| 1 // Copyright (c) 2011 The Chromium Authors. All rights reserved. | 1 // Copyright (c) 2011 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 "base/message_loop.h" | 5 #include "base/message_loop.h" |
| 6 #include "gpu/command_buffer/common/command_buffer_mock.h" | 6 #include "gpu/command_buffer/common/command_buffer_mock.h" |
| 7 #include "gpu/command_buffer/service/gpu_scheduler.h" | 7 #include "gpu/command_buffer/service/gpu_scheduler.h" |
| 8 #include "gpu/command_buffer/service/gles2_cmd_decoder.h" | 8 #include "gpu/command_buffer/service/gles2_cmd_decoder.h" |
| 9 #include "gpu/command_buffer/service/gles2_cmd_decoder_mock.h" | 9 #include "gpu/command_buffer/service/gles2_cmd_decoder_mock.h" |
| 10 #include "gpu/command_buffer/service/mocks.h" | 10 #include "gpu/command_buffer/service/mocks.h" |
| (...skipping 12 matching lines...) Expand all Loading... |
| 23 using testing::SetArgumentPointee; | 23 using testing::SetArgumentPointee; |
| 24 using testing::StrictMock; | 24 using testing::StrictMock; |
| 25 | 25 |
| 26 namespace gpu { | 26 namespace gpu { |
| 27 | 27 |
| 28 const size_t kRingBufferSize = 1024; | 28 const size_t kRingBufferSize = 1024; |
| 29 const size_t kRingBufferEntries = kRingBufferSize / sizeof(CommandBufferEntry); | 29 const size_t kRingBufferEntries = kRingBufferSize / sizeof(CommandBufferEntry); |
| 30 | 30 |
| 31 class GpuSchedulerTest : public testing::Test { | 31 class GpuSchedulerTest : public testing::Test { |
| 32 protected: | 32 protected: |
| 33 static const int32 kTransferBufferId = 123; | |
| 34 | |
| 35 virtual void SetUp() { | 33 virtual void SetUp() { |
| 36 shared_memory_.reset(new ::base::SharedMemory); | 34 shared_memory_.reset(new ::base::SharedMemory); |
| 37 shared_memory_->CreateAndMapAnonymous(kRingBufferSize); | 35 shared_memory_->CreateAndMapAnonymous(kRingBufferSize); |
| 38 buffer_ = static_cast<int32*>(shared_memory_->memory()); | 36 buffer_ = static_cast<int32*>(shared_memory_->memory()); |
| 39 shared_memory_buffer_.ptr = buffer_; | 37 shared_memory_buffer_.ptr = buffer_; |
| 40 shared_memory_buffer_.size = kRingBufferSize; | 38 shared_memory_buffer_.size = kRingBufferSize; |
| 41 memset(buffer_, 0, kRingBufferSize); | 39 memset(buffer_, 0, kRingBufferSize); |
| 42 | 40 |
| 43 command_buffer_.reset(new MockCommandBuffer); | 41 command_buffer_.reset(new MockCommandBuffer); |
| 42 ON_CALL(*command_buffer_.get(), GetRingBuffer()) |
| 43 .WillByDefault(Return(shared_memory_buffer_)); |
| 44 | 44 |
| 45 CommandBuffer::State default_state; | 45 CommandBuffer::State default_state; |
| 46 default_state.num_entries = kRingBufferEntries; | 46 default_state.num_entries = kRingBufferEntries; |
| 47 ON_CALL(*command_buffer_.get(), GetState()) | 47 ON_CALL(*command_buffer_.get(), GetState()) |
| 48 .WillByDefault(Return(default_state)); | 48 .WillByDefault(Return(default_state)); |
| 49 | 49 |
| 50 async_api_.reset(new StrictMock<AsyncAPIMock>); |
| 51 |
| 50 decoder_.reset(new gles2::MockGLES2Decoder()); | 52 decoder_.reset(new gles2::MockGLES2Decoder()); |
| 53 |
| 54 parser_ = new CommandParser(buffer_, |
| 55 kRingBufferEntries, |
| 56 0, |
| 57 kRingBufferEntries, |
| 58 0, |
| 59 async_api_.get()); |
| 60 |
| 51 scheduler_.reset(new gpu::GpuScheduler(command_buffer_.get(), | 61 scheduler_.reset(new gpu::GpuScheduler(command_buffer_.get(), |
| 52 decoder_.get(), | 62 decoder_.get(), |
| 53 NULL)); | 63 parser_)); |
| 54 EXPECT_CALL(*command_buffer_, GetTransferBuffer(kTransferBufferId)) | |
| 55 .WillOnce(Return(shared_memory_buffer_)); | |
| 56 EXPECT_CALL(*command_buffer_, SetGetBuffer(kTransferBufferId)); | |
| 57 EXPECT_CALL(*command_buffer_, SetGetOffset(0)); | |
| 58 EXPECT_TRUE(scheduler_->SetGetBuffer(kTransferBufferId)); | |
| 59 } | 64 } |
| 60 | 65 |
| 61 virtual void TearDown() { | 66 virtual void TearDown() { |
| 62 // Ensure that any unexpected tasks posted by the GPU scheduler are executed | 67 // Ensure that any unexpected tasks posted by the GPU scheduler are executed |
| 63 // in order to fail the test. | 68 // in order to fail the test. |
| 64 MessageLoop::current()->RunAllPending(); | 69 MessageLoop::current()->RunAllPending(); |
| 65 } | 70 } |
| 66 | 71 |
| 67 error::Error GetError() { | 72 error::Error GetError() { |
| 68 return command_buffer_->GetState().error; | 73 return command_buffer_->GetState().error; |
| 69 } | 74 } |
| 70 | 75 |
| 71 #if defined(OS_MACOSX) | 76 #if defined(OS_MACOSX) |
| 72 base::mac::ScopedNSAutoreleasePool autorelease_pool_; | 77 base::mac::ScopedNSAutoreleasePool autorelease_pool_; |
| 73 #endif | 78 #endif |
| 74 MessageLoop message_loop; | 79 MessageLoop message_loop; |
| 75 scoped_ptr<MockCommandBuffer> command_buffer_; | 80 scoped_ptr<MockCommandBuffer> command_buffer_; |
| 76 scoped_ptr<base::SharedMemory> shared_memory_; | 81 scoped_ptr<base::SharedMemory> shared_memory_; |
| 77 Buffer shared_memory_buffer_; | 82 Buffer shared_memory_buffer_; |
| 78 int32* buffer_; | 83 int32* buffer_; |
| 79 scoped_ptr<gles2::MockGLES2Decoder> decoder_; | 84 scoped_ptr<gles2::MockGLES2Decoder> decoder_; |
| 85 CommandParser* parser_; |
| 86 scoped_ptr<AsyncAPIMock> async_api_; |
| 80 scoped_ptr<GpuScheduler> scheduler_; | 87 scoped_ptr<GpuScheduler> scheduler_; |
| 81 }; | 88 }; |
| 82 | 89 |
| 83 TEST_F(GpuSchedulerTest, SchedulerDoesNothingIfRingBufferIsEmpty) { | 90 TEST_F(GpuSchedulerTest, SchedulerDoesNothingIfRingBufferIsEmpty) { |
| 84 CommandBuffer::State state; | 91 CommandBuffer::State state; |
| 85 | 92 |
| 86 state.put_offset = 0; | 93 state.put_offset = 0; |
| 87 EXPECT_CALL(*command_buffer_, GetState()) | 94 EXPECT_CALL(*command_buffer_, GetState()) |
| 88 .WillRepeatedly(Return(state)); | 95 .WillRepeatedly(Return(state)); |
| 89 | 96 |
| 90 EXPECT_CALL(*command_buffer_, SetParseError(_)) | 97 EXPECT_CALL(*command_buffer_, SetParseError(_)) |
| 91 .Times(0); | 98 .Times(0); |
| 92 | 99 |
| 93 scheduler_->PutChanged(); | 100 scheduler_->PutChanged(); |
| 94 } | 101 } |
| 95 | 102 |
| 96 TEST_F(GpuSchedulerTest, GetSetBuffer) { | |
| 97 CommandBuffer::State state; | |
| 98 | |
| 99 // Set the get offset to something not 0. | |
| 100 EXPECT_CALL(*command_buffer_, SetGetOffset(2)); | |
| 101 scheduler_->SetGetOffset(2); | |
| 102 EXPECT_EQ(2, scheduler_->GetGetOffset()); | |
| 103 | |
| 104 // Set the buffer. | |
| 105 EXPECT_CALL(*command_buffer_, GetTransferBuffer(kTransferBufferId)) | |
| 106 .WillOnce(Return(shared_memory_buffer_)); | |
| 107 EXPECT_CALL(*command_buffer_, SetGetBuffer(kTransferBufferId)); | |
| 108 EXPECT_CALL(*command_buffer_, SetGetOffset(0)); | |
| 109 EXPECT_TRUE(scheduler_->SetGetBuffer(kTransferBufferId)); | |
| 110 | |
| 111 // Check the get offset was reset. | |
| 112 EXPECT_EQ(0, scheduler_->GetGetOffset()); | |
| 113 } | |
| 114 | |
| 115 TEST_F(GpuSchedulerTest, ProcessesOneCommand) { | 103 TEST_F(GpuSchedulerTest, ProcessesOneCommand) { |
| 116 CommandHeader* header = reinterpret_cast<CommandHeader*>(&buffer_[0]); | 104 CommandHeader* header = reinterpret_cast<CommandHeader*>(&buffer_[0]); |
| 117 header[0].command = 7; | 105 header[0].command = 7; |
| 118 header[0].size = 2; | 106 header[0].size = 2; |
| 119 buffer_[1] = 123; | 107 buffer_[1] = 123; |
| 120 | 108 |
| 121 CommandBuffer::State state; | 109 CommandBuffer::State state; |
| 122 | 110 |
| 123 state.put_offset = 2; | 111 state.put_offset = 2; |
| 124 EXPECT_CALL(*command_buffer_, GetState()) | 112 EXPECT_CALL(*command_buffer_, GetState()) |
| 125 .WillRepeatedly(Return(state)); | 113 .WillRepeatedly(Return(state)); |
| 126 EXPECT_CALL(*command_buffer_, SetGetOffset(2)); | 114 EXPECT_CALL(*command_buffer_, SetGetOffset(2)); |
| 127 | 115 |
| 128 EXPECT_CALL(*decoder_, DoCommand(7, 1, &buffer_[0])) | 116 EXPECT_CALL(*async_api_, DoCommand(7, 1, &buffer_[0])) |
| 129 .WillOnce(Return(error::kNoError)); | 117 .WillOnce(Return(error::kNoError)); |
| 130 | 118 |
| 131 EXPECT_CALL(*command_buffer_, SetParseError(_)) | 119 EXPECT_CALL(*command_buffer_, SetParseError(_)) |
| 132 .Times(0); | 120 .Times(0); |
| 133 | 121 |
| 134 scheduler_->PutChanged(); | 122 scheduler_->PutChanged(); |
| 135 } | 123 } |
| 136 | 124 |
| 137 TEST_F(GpuSchedulerTest, ProcessesTwoCommands) { | 125 TEST_F(GpuSchedulerTest, ProcessesTwoCommands) { |
| 138 CommandHeader* header = reinterpret_cast<CommandHeader*>(&buffer_[0]); | 126 CommandHeader* header = reinterpret_cast<CommandHeader*>(&buffer_[0]); |
| 139 header[0].command = 7; | 127 header[0].command = 7; |
| 140 header[0].size = 2; | 128 header[0].size = 2; |
| 141 buffer_[1] = 123; | 129 buffer_[1] = 123; |
| 142 header[2].command = 8; | 130 header[2].command = 8; |
| 143 header[2].size = 1; | 131 header[2].size = 1; |
| 144 | 132 |
| 145 CommandBuffer::State state; | 133 CommandBuffer::State state; |
| 146 | 134 |
| 147 state.put_offset = 3; | 135 state.put_offset = 3; |
| 148 EXPECT_CALL(*command_buffer_, GetState()) | 136 EXPECT_CALL(*command_buffer_, GetState()) |
| 149 .WillRepeatedly(Return(state)); | 137 .WillRepeatedly(Return(state)); |
| 150 | 138 |
| 151 EXPECT_CALL(*decoder_, DoCommand(7, 1, &buffer_[0])) | 139 EXPECT_CALL(*async_api_, DoCommand(7, 1, &buffer_[0])) |
| 152 .WillOnce(Return(error::kNoError)); | 140 .WillOnce(Return(error::kNoError)); |
| 153 EXPECT_CALL(*command_buffer_, SetGetOffset(2)); | 141 EXPECT_CALL(*command_buffer_, SetGetOffset(2)); |
| 154 | 142 |
| 155 EXPECT_CALL(*decoder_, DoCommand(8, 0, &buffer_[2])) | 143 EXPECT_CALL(*async_api_, DoCommand(8, 0, &buffer_[2])) |
| 156 .WillOnce(Return(error::kNoError)); | 144 .WillOnce(Return(error::kNoError)); |
| 157 EXPECT_CALL(*command_buffer_, SetGetOffset(3)); | 145 EXPECT_CALL(*command_buffer_, SetGetOffset(3)); |
| 158 | 146 |
| 159 scheduler_->PutChanged(); | 147 scheduler_->PutChanged(); |
| 160 } | 148 } |
| 161 | 149 |
| 162 TEST_F(GpuSchedulerTest, SetsErrorCodeOnCommandBuffer) { | 150 TEST_F(GpuSchedulerTest, SetsErrorCodeOnCommandBuffer) { |
| 163 CommandHeader* header = reinterpret_cast<CommandHeader*>(&buffer_[0]); | 151 CommandHeader* header = reinterpret_cast<CommandHeader*>(&buffer_[0]); |
| 164 header[0].command = 7; | 152 header[0].command = 7; |
| 165 header[0].size = 1; | 153 header[0].size = 1; |
| 166 | 154 |
| 167 CommandBuffer::State state; | 155 CommandBuffer::State state; |
| 168 | 156 |
| 169 state.put_offset = 1; | 157 state.put_offset = 1; |
| 170 EXPECT_CALL(*command_buffer_, GetState()) | 158 EXPECT_CALL(*command_buffer_, GetState()) |
| 171 .WillRepeatedly(Return(state)); | 159 .WillRepeatedly(Return(state)); |
| 172 | 160 |
| 173 EXPECT_CALL(*decoder_, DoCommand(7, 0, &buffer_[0])) | 161 EXPECT_CALL(*async_api_, DoCommand(7, 0, &buffer_[0])) |
| 174 .WillOnce(Return( | 162 .WillOnce(Return( |
| 175 error::kUnknownCommand)); | 163 error::kUnknownCommand)); |
| 176 EXPECT_CALL(*command_buffer_, SetGetOffset(1)); | 164 EXPECT_CALL(*command_buffer_, SetGetOffset(1)); |
| 177 | 165 |
| 178 EXPECT_CALL(*command_buffer_, SetContextLostReason(_)); | |
| 179 EXPECT_CALL(*decoder_, GetContextLostReason()) | 166 EXPECT_CALL(*decoder_, GetContextLostReason()) |
| 180 .WillOnce(Return(error::kUnknown)); | 167 .WillOnce(Return(error::kUnknown)); |
| 181 EXPECT_CALL(*command_buffer_, | 168 EXPECT_CALL(*command_buffer_, |
| 182 SetParseError(error::kUnknownCommand)); | 169 SetParseError(error::kUnknownCommand)); |
| 183 | 170 |
| 184 scheduler_->PutChanged(); | 171 scheduler_->PutChanged(); |
| 185 } | 172 } |
| 186 | 173 |
| 187 TEST_F(GpuSchedulerTest, ProcessCommandsDoesNothingAfterError) { | 174 TEST_F(GpuSchedulerTest, ProcessCommandsDoesNothingAfterError) { |
| 188 CommandBuffer::State state; | 175 CommandBuffer::State state; |
| (...skipping 22 matching lines...) Expand all Loading... |
| 211 | 198 |
| 212 EXPECT_EQ(kRingBufferSize, scheduler_->GetSharedMemoryBuffer(7).size); | 199 EXPECT_EQ(kRingBufferSize, scheduler_->GetSharedMemoryBuffer(7).size); |
| 213 } | 200 } |
| 214 | 201 |
| 215 TEST_F(GpuSchedulerTest, SetTokenForwardsToCommandBuffer) { | 202 TEST_F(GpuSchedulerTest, SetTokenForwardsToCommandBuffer) { |
| 216 EXPECT_CALL(*command_buffer_, SetToken(7)); | 203 EXPECT_CALL(*command_buffer_, SetToken(7)); |
| 217 scheduler_->set_token(7); | 204 scheduler_->set_token(7); |
| 218 } | 205 } |
| 219 | 206 |
| 220 } // namespace gpu | 207 } // namespace gpu |
| OLD | NEW |