jdk-sandbox: comparison hotspot/src/os/linux/vm/os

equal deleted inserted replaced

-:8f17e084029b
+:a02753d5a0b2
 //
 // This interface should be declared in os_linux_i486.hpp, but
 // that file provides extensions to the os class and not the
 // Linux class.
 static ExtendedPC fetch_frame_from_ucontext(Thread* thread, ucontext_t* uc,
 intptr_t** ret_sp, intptr_t** ret_fp);
 // This boolean allows users to forward their own non-matching signals
 // to JVM_handle_linux_signal, harmlessly.
 static bool signal_handlers_are_installed;
 }
 static jlong fast_thread_cpu_time(clockid_t clockid);
 // pthread_cond clock suppport
 private:
 static pthread_condattr_t _condattr[1];
 public:
 static pthread_condattr_t* condAttr() { return _condattr; }
 // Stack repair handling
 // none present
 // LinuxThreads work-around for 6292965
 static int safe_cond_timedwait(pthread_cond_t *_cond, pthread_mutex_t *_mutex, const struct timespec *_abstime);
 private:
 typedef int (*sched_getcpu_func_t)(void);
 typedef int (*numa_node_to_cpus_func_t)(int node, unsigned long *buffer, int bufferlen);
 typedef int (*numa_max_node_func_t)(void);
 typedef int (*numa_available_func_t)(void);
 typedef int (*numa_tonode_memory_func_t)(void *start, size_t size, int node);
 static void set_numa_tonode_memory(numa_tonode_memory_func_t func) { _numa_tonode_memory = func; }
 static void set_numa_interleave_memory(numa_interleave_memory_func_t func) { _numa_interleave_memory = func; }
 static void set_numa_set_bind_policy(numa_set_bind_policy_func_t func) { _numa_set_bind_policy = func; }
 static void set_numa_all_nodes(unsigned long* ptr) { _numa_all_nodes = ptr; }
 static int sched_getcpu_syscall(void);
 public:
 static int sched_getcpu()  { return _sched_getcpu != NULL ? _sched_getcpu() : -1; }
 static int numa_node_to_cpus(int node, unsigned long *buffer, int bufferlen) {
 return _numa_node_to_cpus != NULL ? _numa_node_to_cpus(node, buffer, bufferlen) : -1;
 }
 static int numa_max_node() { return _numa_max_node != NULL ? _numa_max_node() : -1; }
 static int get_node_by_cpu(int cpu_id);
 };
 class PlatformEvent : public CHeapObj<mtInternal> {
 private:
 double CachePad[4];   // increase odds that _mutex is sole occupant of cache line
 volatile int _Event;
 volatile int _nParked;
 pthread_mutex_t _mutex[1];
 pthread_cond_t  _cond[1];
 double PostPad[2];
 Thread * _Assoc;
 public:       // TODO-FIXME: make dtor private
 ~PlatformEvent() { guarantee(0, "invariant"); }
 public:
 PlatformEvent() {
 int status;
 status = pthread_cond_init (_cond, os::Linux::condAttr());
 assert_status(status == 0, status, "cond_init");
 status = pthread_mutex_init (_mutex, NULL);
 assert_status(status == 0, status, "mutex_init");
 _Event   = 0;
 _nParked = 0;
 _Assoc   = NULL;
 }
 // Use caution with reset() and fired() -- they may require MEMBARs
 void reset() { _Event = 0; }
 int  fired() { return _Event; }
 void park();
 void unpark();
 int  park(jlong millis); // relative timed-wait only
 void SetAssociation(Thread * a) { _Assoc = a; }
 };
 class PlatformParker : public CHeapObj<mtInternal> {
 protected:
 enum {
 REL_INDEX = 0,
 ABS_INDEX = 1
 };
 int _cur_index;  // which cond is in use: -1, 0, 1
 pthread_mutex_t _mutex[1];
 pthread_cond_t  _cond[2]; // one for relative times and one for abs.
 public:       // TODO-FIXME: make dtor private
 ~PlatformParker() { guarantee(0, "invariant"); }
 public:
 PlatformParker() {
 int status;
 status = pthread_cond_init (&_cond[REL_INDEX], os::Linux::condAttr());
 assert_status(status == 0, status, "cond_init rel");
 status = pthread_cond_init (&_cond[ABS_INDEX], NULL);
 assert_status(status == 0, status, "cond_init abs");
 status = pthread_mutex_init (_mutex, NULL);
 assert_status(status == 0, status, "mutex_init");
 _cur_index = -1; // mark as unused
 }
 };
 #endif // OS_LINUX_VM_OS_LINUX_HPP

changeset 26683	a02753d5a0b2
parent 25946	1572c9f03fb9
child 26684	d1221849ea3d