| OLD | NEW |
| 1 // Copyright 2012 the V8 project authors. All rights reserved. | 1 // Copyright 2012 the V8 project authors. All rights reserved. |
| 2 // Redistribution and use in source and binary forms, with or without | 2 // Redistribution and use in source and binary forms, with or without |
| 3 // modification, are permitted provided that the following conditions are | 3 // modification, are permitted provided that the following conditions are |
| 4 // met: | 4 // met: |
| 5 // | 5 // |
| 6 // * Redistributions of source code must retain the above copyright | 6 // * Redistributions of source code must retain the above copyright |
| 7 // notice, this list of conditions and the following disclaimer. | 7 // notice, this list of conditions and the following disclaimer. |
| 8 // * Redistributions in binary form must reproduce the above | 8 // * Redistributions in binary form must reproduce the above |
| 9 // copyright notice, this list of conditions and the following | 9 // copyright notice, this list of conditions and the following |
| 10 // disclaimer in the documentation and/or other materials provided | 10 // disclaimer in the documentation and/or other materials provided |
| (...skipping 33 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 44 #include "platform-posix.h" | 44 #include "platform-posix.h" |
| 45 #include "platform.h" | 45 #include "platform.h" |
| 46 #include "simulator.h" | 46 #include "simulator.h" |
| 47 #include "v8threads.h" | 47 #include "v8threads.h" |
| 48 #include "vm-state-inl.h" | 48 #include "vm-state-inl.h" |
| 49 #include "win32-headers.h" | 49 #include "win32-headers.h" |
| 50 | 50 |
| 51 namespace v8 { | 51 namespace v8 { |
| 52 namespace internal { | 52 namespace internal { |
| 53 | 53 |
| 54 // 0 is never a valid thread id | |
| 55 static const pthread_t kNoThread = (pthread_t) 0; | |
| 56 | |
| 57 | |
| 58 double ceiling(double x) { | |
| 59 return ceil(x); | |
| 60 } | |
| 61 | |
| 62 | 54 |
| 63 static Mutex* limit_mutex = NULL; | 55 static Mutex* limit_mutex = NULL; |
| 64 | 56 |
| 65 | 57 |
| 66 void OS::PostSetUp() { | |
| 67 POSIXPostSetUp(); | |
| 68 } | |
| 69 | |
| 70 | |
| 71 uint64_t OS::CpuFeaturesImpliedByPlatform() { | |
| 72 return 0; // Nothing special about Cygwin. | |
| 73 } | |
| 74 | |
| 75 | |
| 76 int OS::ActivationFrameAlignment() { | |
| 77 // With gcc 4.4 the tree vectorization optimizer can generate code | |
| 78 // that requires 16 byte alignment such as movdqa on x86. | |
| 79 return 16; | |
| 80 } | |
| 81 | |
| 82 | |
| 83 const char* OS::LocalTimezone(double time) { | 58 const char* OS::LocalTimezone(double time) { |
| 84 if (std::isnan(time)) return ""; | 59 if (std::isnan(time)) return ""; |
| 85 time_t tv = static_cast<time_t>(floor(time/msPerSecond)); | 60 time_t tv = static_cast<time_t>(floor(time/msPerSecond)); |
| 86 struct tm* t = localtime(&tv); | 61 struct tm* t = localtime(&tv); |
| 87 if (NULL == t) return ""; | 62 if (NULL == t) return ""; |
| 88 return tzname[0]; // The location of the timezone string on Cygwin. | 63 return tzname[0]; // The location of the timezone string on Cygwin. |
| 89 } | 64 } |
| 90 | 65 |
| 91 | 66 |
| 92 double OS::LocalTimeOffset() { | 67 double OS::LocalTimeOffset() { |
| (...skipping 26 matching lines...) Expand all Loading... |
| 119 Max(highest_ever_allocated, | 94 Max(highest_ever_allocated, |
| 120 reinterpret_cast<void*>(reinterpret_cast<char*>(address) + size)); | 95 reinterpret_cast<void*>(reinterpret_cast<char*>(address) + size)); |
| 121 } | 96 } |
| 122 | 97 |
| 123 | 98 |
| 124 bool OS::IsOutsideAllocatedSpace(void* address) { | 99 bool OS::IsOutsideAllocatedSpace(void* address) { |
| 125 return address < lowest_ever_allocated || address >= highest_ever_allocated; | 100 return address < lowest_ever_allocated || address >= highest_ever_allocated; |
| 126 } | 101 } |
| 127 | 102 |
| 128 | 103 |
| 129 size_t OS::AllocateAlignment() { | |
| 130 return sysconf(_SC_PAGESIZE); | |
| 131 } | |
| 132 | |
| 133 | |
| 134 void* OS::Allocate(const size_t requested, | 104 void* OS::Allocate(const size_t requested, |
| 135 size_t* allocated, | 105 size_t* allocated, |
| 136 bool is_executable) { | 106 bool is_executable) { |
| 137 const size_t msize = RoundUp(requested, sysconf(_SC_PAGESIZE)); | 107 const size_t msize = RoundUp(requested, sysconf(_SC_PAGESIZE)); |
| 138 int prot = PROT_READ | PROT_WRITE | (is_executable ? PROT_EXEC : 0); | 108 int prot = PROT_READ | PROT_WRITE | (is_executable ? PROT_EXEC : 0); |
| 139 void* mbase = mmap(NULL, msize, prot, MAP_PRIVATE | MAP_ANONYMOUS, -1, 0); | 109 void* mbase = mmap(NULL, msize, prot, MAP_PRIVATE | MAP_ANONYMOUS, -1, 0); |
| 140 if (mbase == MAP_FAILED) { | 110 if (mbase == MAP_FAILED) { |
| 141 LOG(ISOLATE, StringEvent("OS::Allocate", "mmap failed")); | 111 LOG(ISOLATE, StringEvent("OS::Allocate", "mmap failed")); |
| 142 return NULL; | 112 return NULL; |
| 143 } | 113 } |
| 144 *allocated = msize; | 114 *allocated = msize; |
| 145 UpdateAllocatedSpaceLimits(mbase, msize); | 115 UpdateAllocatedSpaceLimits(mbase, msize); |
| 146 return mbase; | 116 return mbase; |
| 147 } | 117 } |
| 148 | 118 |
| 149 | 119 |
| 150 void OS::Free(void* address, const size_t size) { | |
| 151 // TODO(1240712): munmap has a return value which is ignored here. | |
| 152 int result = munmap(address, size); | |
| 153 USE(result); | |
| 154 ASSERT(result == 0); | |
| 155 } | |
| 156 | |
| 157 | |
| 158 void OS::ProtectCode(void* address, const size_t size) { | |
| 159 DWORD old_protect; | |
| 160 VirtualProtect(address, size, PAGE_EXECUTE_READ, &old_protect); | |
| 161 } | |
| 162 | |
| 163 | |
| 164 void OS::Guard(void* address, const size_t size) { | |
| 165 DWORD oldprotect; | |
| 166 VirtualProtect(address, size, PAGE_READONLY | PAGE_GUARD, &oldprotect); | |
| 167 } | |
| 168 | |
| 169 | |
| 170 void OS::Sleep(int milliseconds) { | |
| 171 unsigned int ms = static_cast<unsigned int>(milliseconds); | |
| 172 usleep(1000 * ms); | |
| 173 } | |
| 174 | |
| 175 | |
| 176 int OS::NumberOfCores() { | |
| 177 return sysconf(_SC_NPROCESSORS_ONLN); | |
| 178 } | |
| 179 | |
| 180 | |
| 181 void OS::Abort() { | |
| 182 // Redirect to std abort to signal abnormal program termination. | |
| 183 abort(); | |
| 184 } | |
| 185 | |
| 186 | |
| 187 void OS::DebugBreak() { | |
| 188 asm("int $3"); | |
| 189 } | |
| 190 | |
| 191 | |
| 192 void OS::DumpBacktrace() { | 120 void OS::DumpBacktrace() { |
| 193 // Currently unsupported. | 121 // Currently unsupported. |
| 194 } | 122 } |
| 195 | 123 |
| 196 | 124 |
| 197 class PosixMemoryMappedFile : public OS::MemoryMappedFile { | 125 class PosixMemoryMappedFile : public OS::MemoryMappedFile { |
| 198 public: | 126 public: |
| 199 PosixMemoryMappedFile(FILE* file, void* memory, int size) | 127 PosixMemoryMappedFile(FILE* file, void* memory, int size) |
| 200 : file_(file), memory_(memory), size_(size) { } | 128 : file_(file), memory_(memory), size_(size) { } |
| 201 virtual ~PosixMemoryMappedFile(); | 129 virtual ~PosixMemoryMappedFile(); |
| (...skipping 261 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 463 return VirtualFree(base, 0, MEM_RELEASE) != 0; | 391 return VirtualFree(base, 0, MEM_RELEASE) != 0; |
| 464 } | 392 } |
| 465 | 393 |
| 466 | 394 |
| 467 bool VirtualMemory::HasLazyCommits() { | 395 bool VirtualMemory::HasLazyCommits() { |
| 468 // TODO(alph): implement for the platform. | 396 // TODO(alph): implement for the platform. |
| 469 return false; | 397 return false; |
| 470 } | 398 } |
| 471 | 399 |
| 472 | 400 |
| 473 class Thread::PlatformData : public Malloced { | |
| 474 public: | |
| 475 PlatformData() : thread_(kNoThread) {} | |
| 476 pthread_t thread_; // Thread handle for pthread. | |
| 477 }; | |
| 478 | |
| 479 | |
| 480 Thread::Thread(const Options& options) | |
| 481 : data_(new PlatformData()), | |
| 482 stack_size_(options.stack_size()), | |
| 483 start_semaphore_(NULL) { | |
| 484 set_name(options.name()); | |
| 485 } | |
| 486 | |
| 487 | |
| 488 Thread::~Thread() { | |
| 489 delete data_; | |
| 490 } | |
| 491 | |
| 492 | |
| 493 static void* ThreadEntry(void* arg) { | |
| 494 Thread* thread = reinterpret_cast<Thread*>(arg); | |
| 495 // This is also initialized by the first argument to pthread_create() but we | |
| 496 // don't know which thread will run first (the original thread or the new | |
| 497 // one) so we initialize it here too. | |
| 498 thread->data()->thread_ = pthread_self(); | |
| 499 ASSERT(thread->data()->thread_ != kNoThread); | |
| 500 thread->NotifyStartedAndRun(); | |
| 501 return NULL; | |
| 502 } | |
| 503 | |
| 504 | |
| 505 void Thread::set_name(const char* name) { | |
| 506 strncpy(name_, name, sizeof(name_)); | |
| 507 name_[sizeof(name_) - 1] = '\0'; | |
| 508 } | |
| 509 | |
| 510 | |
| 511 void Thread::Start() { | |
| 512 pthread_attr_t* attr_ptr = NULL; | |
| 513 pthread_attr_t attr; | |
| 514 if (stack_size_ > 0) { | |
| 515 pthread_attr_init(&attr); | |
| 516 pthread_attr_setstacksize(&attr, static_cast<size_t>(stack_size_)); | |
| 517 attr_ptr = &attr; | |
| 518 } | |
| 519 pthread_create(&data_->thread_, attr_ptr, ThreadEntry, this); | |
| 520 ASSERT(data_->thread_ != kNoThread); | |
| 521 } | |
| 522 | |
| 523 | |
| 524 void Thread::Join() { | |
| 525 pthread_join(data_->thread_, NULL); | |
| 526 } | |
| 527 | |
| 528 | |
| 529 static inline Thread::LocalStorageKey PthreadKeyToLocalKey( | |
| 530 pthread_key_t pthread_key) { | |
| 531 // We need to cast pthread_key_t to Thread::LocalStorageKey in two steps | |
| 532 // because pthread_key_t is a pointer type on Cygwin. This will probably not | |
| 533 // work on 64-bit platforms, but Cygwin doesn't support 64-bit anyway. | |
| 534 STATIC_ASSERT(sizeof(Thread::LocalStorageKey) == sizeof(pthread_key_t)); | |
| 535 intptr_t ptr_key = reinterpret_cast<intptr_t>(pthread_key); | |
| 536 return static_cast<Thread::LocalStorageKey>(ptr_key); | |
| 537 } | |
| 538 | |
| 539 | |
| 540 static inline pthread_key_t LocalKeyToPthreadKey( | |
| 541 Thread::LocalStorageKey local_key) { | |
| 542 STATIC_ASSERT(sizeof(Thread::LocalStorageKey) == sizeof(pthread_key_t)); | |
| 543 intptr_t ptr_key = static_cast<intptr_t>(local_key); | |
| 544 return reinterpret_cast<pthread_key_t>(ptr_key); | |
| 545 } | |
| 546 | |
| 547 | |
| 548 Thread::LocalStorageKey Thread::CreateThreadLocalKey() { | |
| 549 pthread_key_t key; | |
| 550 int result = pthread_key_create(&key, NULL); | |
| 551 USE(result); | |
| 552 ASSERT(result == 0); | |
| 553 return PthreadKeyToLocalKey(key); | |
| 554 } | |
| 555 | |
| 556 | |
| 557 void Thread::DeleteThreadLocalKey(LocalStorageKey key) { | |
| 558 pthread_key_t pthread_key = LocalKeyToPthreadKey(key); | |
| 559 int result = pthread_key_delete(pthread_key); | |
| 560 USE(result); | |
| 561 ASSERT(result == 0); | |
| 562 } | |
| 563 | |
| 564 | |
| 565 void* Thread::GetThreadLocal(LocalStorageKey key) { | |
| 566 pthread_key_t pthread_key = LocalKeyToPthreadKey(key); | |
| 567 return pthread_getspecific(pthread_key); | |
| 568 } | |
| 569 | |
| 570 | |
| 571 void Thread::SetThreadLocal(LocalStorageKey key, void* value) { | |
| 572 pthread_key_t pthread_key = LocalKeyToPthreadKey(key); | |
| 573 pthread_setspecific(pthread_key, value); | |
| 574 } | |
| 575 | |
| 576 | |
| 577 class CygwinSemaphore : public Semaphore { | 401 class CygwinSemaphore : public Semaphore { |
| 578 public: | 402 public: |
| 579 explicit CygwinSemaphore(int count) { sem_init(&sem_, 0, count); } | 403 explicit CygwinSemaphore(int count) { sem_init(&sem_, 0, count); } |
| 580 virtual ~CygwinSemaphore() { sem_destroy(&sem_); } | 404 virtual ~CygwinSemaphore() { sem_destroy(&sem_); } |
| 581 | 405 |
| 582 virtual void Wait(); | 406 virtual void Wait(); |
| 583 virtual bool Wait(int timeout); | 407 virtual bool Wait(int timeout); |
| 584 virtual void Signal() { sem_post(&sem_); } | 408 virtual void Signal() { sem_post(&sem_); } |
| 585 private: | 409 private: |
| 586 sem_t sem_; | 410 sem_t sem_; |
| (...skipping 63 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 650 limit_mutex = CreateMutex(); | 474 limit_mutex = CreateMutex(); |
| 651 } | 475 } |
| 652 | 476 |
| 653 | 477 |
| 654 void OS::TearDown() { | 478 void OS::TearDown() { |
| 655 delete limit_mutex; | 479 delete limit_mutex; |
| 656 } | 480 } |
| 657 | 481 |
| 658 | 482 |
| 659 } } // namespace v8::internal | 483 } } // namespace v8::internal |
| OLD | NEW |