| 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 "chrome/nacl/nacl_ipc_adapter.h" | 5 #include "chrome/nacl/nacl_ipc_adapter.h" |
| 6 | 6 |
| 7 #include <string.h> | 7 #include <string.h> |
| 8 | 8 |
| 9 #include "base/memory/scoped_ptr.h" | 9 #include "base/memory/scoped_ptr.h" |
| 10 #include "base/message_loop.h" | 10 #include "base/message_loop.h" |
| (...skipping 268 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 279 explicit MyThread(NaClIPCAdapter* adapter) | 279 explicit MyThread(NaClIPCAdapter* adapter) |
| 280 : SimpleThread("NaClIPCAdapterThread"), | 280 : SimpleThread("NaClIPCAdapterThread"), |
| 281 adapter_(adapter) {} | 281 adapter_(adapter) {} |
| 282 virtual void Run() OVERRIDE { | 282 virtual void Run() OVERRIDE { |
| 283 base::PlatformThread::Sleep(base::TimeDelta::FromSeconds(1)); | 283 base::PlatformThread::Sleep(base::TimeDelta::FromSeconds(1)); |
| 284 adapter_->OnChannelError(); | 284 adapter_->OnChannelError(); |
| 285 } | 285 } |
| 286 private: | 286 private: |
| 287 scoped_refptr<NaClIPCAdapter> adapter_; | 287 scoped_refptr<NaClIPCAdapter> adapter_; |
| 288 }; | 288 }; |
| 289 MyThread thread(adapter_); | 289 MyThread thread(adapter_.get()); |
| 290 | 290 |
| 291 // IMPORTANT: do not return early from here down (including ASSERT_*) because | 291 // IMPORTANT: do not return early from here down (including ASSERT_*) because |
| 292 // the thread needs to joined or it will assert. | 292 // the thread needs to joined or it will assert. |
| 293 thread.Start(); | 293 thread.Start(); |
| 294 | 294 |
| 295 // Request data. This will normally (modulo races) block until data is | 295 // Request data. This will normally (modulo races) block until data is |
| 296 // received or there is an error, and the thread above will wake us up | 296 // received or there is an error, and the thread above will wake us up |
| 297 // after 1s. | 297 // after 1s. |
| 298 const int kBufSize = 64; | 298 const int kBufSize = 64; |
| 299 char buf[kBufSize]; | 299 char buf[kBufSize]; |
| (...skipping 35 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 335 // back NACL_ABI_O_READONLY | 335 // back NACL_ABI_O_READONLY |
| 336 EXPECT_EQ(NACL_ABI_O_RDONLY, | 336 EXPECT_EQ(NACL_ABI_O_RDONLY, |
| 337 TranslatePepperFileReadWriteOpenFlagsForTesting(PP_FILEOPENFLAG_CREATE)); | 337 TranslatePepperFileReadWriteOpenFlagsForTesting(PP_FILEOPENFLAG_CREATE)); |
| 338 EXPECT_EQ(NACL_ABI_O_RDONLY, | 338 EXPECT_EQ(NACL_ABI_O_RDONLY, |
| 339 TranslatePepperFileReadWriteOpenFlagsForTesting( | 339 TranslatePepperFileReadWriteOpenFlagsForTesting( |
| 340 PP_FILEOPENFLAG_TRUNCATE)); | 340 PP_FILEOPENFLAG_TRUNCATE)); |
| 341 EXPECT_EQ(NACL_ABI_O_RDONLY, | 341 EXPECT_EQ(NACL_ABI_O_RDONLY, |
| 342 TranslatePepperFileReadWriteOpenFlagsForTesting( | 342 TranslatePepperFileReadWriteOpenFlagsForTesting( |
| 343 PP_FILEOPENFLAG_EXCLUSIVE)); | 343 PP_FILEOPENFLAG_EXCLUSIVE)); |
| 344 } | 344 } |
| OLD | NEW |