| 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 82 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 93 | 93 |
| 94 #endif // _MSC_VER | 94 #endif // _MSC_VER |
| 95 | 95 |
| 96 #ifndef __CYGWIN__ | 96 #ifndef __CYGWIN__ |
| 97 // Random is missing on both Visual Studio and MinGW. | 97 // Random is missing on both Visual Studio and MinGW. |
| 98 int random(); | 98 int random(); |
| 99 #endif | 99 #endif |
| 100 | 100 |
| 101 #endif // WIN32 | 101 #endif // WIN32 |
| 102 | 102 |
| 103 #include "lazy-instance.h" | 103 #include "mutex.h" |
| 104 #include "utils.h" | 104 #include "utils.h" |
| 105 #include "v8globals.h" | 105 #include "v8globals.h" |
| 106 | 106 |
| 107 namespace v8 { | 107 namespace v8 { |
| 108 namespace internal { | 108 namespace internal { |
| 109 | 109 |
| 110 class Semaphore; | 110 class Semaphore; |
| 111 class Mutex; | 111 class Mutex; |
| 112 | 112 |
| 113 double ceiling(double x); | 113 double ceiling(double x); |
| (...skipping 188 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 302 static const int kStackWalkError = -1; | 302 static const int kStackWalkError = -1; |
| 303 static const int kStackWalkMaxNameLen = 256; | 303 static const int kStackWalkMaxNameLen = 256; |
| 304 static const int kStackWalkMaxTextLen = 256; | 304 static const int kStackWalkMaxTextLen = 256; |
| 305 struct StackFrame { | 305 struct StackFrame { |
| 306 void* address; | 306 void* address; |
| 307 char text[kStackWalkMaxTextLen]; | 307 char text[kStackWalkMaxTextLen]; |
| 308 }; | 308 }; |
| 309 | 309 |
| 310 static int StackWalk(Vector<StackFrame> frames); | 310 static int StackWalk(Vector<StackFrame> frames); |
| 311 | 311 |
| 312 // Factory method for creating platform dependent Mutex. | |
| 313 // Please use delete to reclaim the storage for the returned Mutex. | |
| 314 static Mutex* CreateMutex(); | |
| 315 | |
| 316 // Factory method for creating platform dependent Semaphore. | 312 // Factory method for creating platform dependent Semaphore. |
| 317 // Please use delete to reclaim the storage for the returned Semaphore. | 313 // Please use delete to reclaim the storage for the returned Semaphore. |
| 318 static Semaphore* CreateSemaphore(int count); | 314 static Semaphore* CreateSemaphore(int count); |
| 319 | 315 |
| 320 // Factory method for creating platform dependent Socket. | 316 // Factory method for creating platform dependent Socket. |
| 321 // Please use delete to reclaim the storage for the returned Socket. | 317 // Please use delete to reclaim the storage for the returned Socket. |
| 322 static Socket* CreateSocket(); | 318 static Socket* CreateSocket(); |
| 323 | 319 |
| 324 class MemoryMappedFile { | 320 class MemoryMappedFile { |
| 325 public: | 321 public: |
| (...skipping 383 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 709 | 705 |
| 710 char name_[kMaxThreadNameLength]; | 706 char name_[kMaxThreadNameLength]; |
| 711 int stack_size_; | 707 int stack_size_; |
| 712 Semaphore* start_semaphore_; | 708 Semaphore* start_semaphore_; |
| 713 | 709 |
| 714 DISALLOW_COPY_AND_ASSIGN(Thread); | 710 DISALLOW_COPY_AND_ASSIGN(Thread); |
| 715 }; | 711 }; |
| 716 | 712 |
| 717 | 713 |
| 718 // ---------------------------------------------------------------------------- | 714 // ---------------------------------------------------------------------------- |
| 719 // Mutex | |
| 720 // | |
| 721 // Mutexes are used for serializing access to non-reentrant sections of code. | |
| 722 // The implementations of mutex should allow for nested/recursive locking. | |
| 723 | |
| 724 class Mutex { | |
| 725 public: | |
| 726 virtual ~Mutex() {} | |
| 727 | |
| 728 // Locks the given mutex. If the mutex is currently unlocked, it becomes | |
| 729 // locked and owned by the calling thread, and immediately. If the mutex | |
| 730 // is already locked by another thread, suspends the calling thread until | |
| 731 // the mutex is unlocked. | |
| 732 virtual int Lock() = 0; | |
| 733 | |
| 734 // Unlocks the given mutex. The mutex is assumed to be locked and owned by | |
| 735 // the calling thread on entrance. | |
| 736 virtual int Unlock() = 0; | |
| 737 | |
| 738 // Tries to lock the given mutex. Returns whether the mutex was | |
| 739 // successfully locked. | |
| 740 virtual bool TryLock() = 0; | |
| 741 }; | |
| 742 | |
| 743 struct CreateMutexTrait { | |
| 744 static Mutex* Create() { | |
| 745 return OS::CreateMutex(); | |
| 746 } | |
| 747 }; | |
| 748 | |
| 749 // POD Mutex initialized lazily (i.e. the first time Pointer() is called). | |
| 750 // Usage: | |
| 751 // static LazyMutex my_mutex = LAZY_MUTEX_INITIALIZER; | |
| 752 // | |
| 753 // void my_function() { | |
| 754 // ScopedLock my_lock(my_mutex.Pointer()); | |
| 755 // // Do something. | |
| 756 // } | |
| 757 // | |
| 758 typedef LazyDynamicInstance< | |
| 759 Mutex, CreateMutexTrait, ThreadSafeInitOnceTrait>::type LazyMutex; | |
| 760 | |
| 761 #define LAZY_MUTEX_INITIALIZER LAZY_DYNAMIC_INSTANCE_INITIALIZER | |
| 762 | |
| 763 // ---------------------------------------------------------------------------- | |
| 764 // ScopedLock | |
| 765 // | |
| 766 // Stack-allocated ScopedLocks provide block-scoped locking and | |
| 767 // unlocking of a mutex. | |
| 768 class ScopedLock { | |
| 769 public: | |
| 770 explicit ScopedLock(Mutex* mutex): mutex_(mutex) { | |
| 771 ASSERT(mutex_ != NULL); | |
| 772 mutex_->Lock(); | |
| 773 } | |
| 774 ~ScopedLock() { | |
| 775 mutex_->Unlock(); | |
| 776 } | |
| 777 | |
| 778 private: | |
| 779 Mutex* mutex_; | |
| 780 DISALLOW_COPY_AND_ASSIGN(ScopedLock); | |
| 781 }; | |
| 782 | |
| 783 | |
| 784 // ---------------------------------------------------------------------------- | |
| 785 // Socket | 715 // Socket |
| 786 // | 716 // |
| 787 | 717 |
| 788 class Socket { | 718 class Socket { |
| 789 public: | 719 public: |
| 790 virtual ~Socket() {} | 720 virtual ~Socket() {} |
| 791 | 721 |
| 792 // Server initialization. | 722 // Server initialization. |
| 793 virtual bool Bind(const int port) = 0; | 723 virtual bool Bind(const int port) = 0; |
| 794 virtual bool Listen(int backlog) const = 0; | 724 virtual bool Listen(int backlog) const = 0; |
| (...skipping 22 matching lines...) Expand all Loading... |
| 817 static uint16_t HToN(uint16_t value); | 747 static uint16_t HToN(uint16_t value); |
| 818 static uint16_t NToH(uint16_t value); | 748 static uint16_t NToH(uint16_t value); |
| 819 static uint32_t HToN(uint32_t value); | 749 static uint32_t HToN(uint32_t value); |
| 820 static uint32_t NToH(uint32_t value); | 750 static uint32_t NToH(uint32_t value); |
| 821 }; | 751 }; |
| 822 | 752 |
| 823 | 753 |
| 824 } } // namespace v8::internal | 754 } } // namespace v8::internal |
| 825 | 755 |
| 826 #endif // V8_PLATFORM_H_ | 756 #endif // V8_PLATFORM_H_ |
| OLD | NEW |