• file
• revisions
• annotate
• diff
• comparison
• raw

src/os/bsd/vm/os_bsd.inline.hpp@f8c8cace25ad (annotated)

src/os/bsd/vm/os_bsd.inline.hpp

Thu, 06 Jun 2013 05:56:33 -0700

author

dcubed

date

Thu, 06 Jun 2013 05:56:33 -0700

changeset 5219

f8c8cace25ad

parent 4675

63e54c37ac64

child 5237

f2110083203d

permissions

-rw-r--r--

Merge

never@3156	1	/*
hseigel@4465	2	* Copyright (c) 1999, 2013, Oracle and/or its affiliates. All rights reserved.
never@3156	3	* DO NOT ALTER OR REMOVE COPYRIGHT NOTICES OR THIS FILE HEADER.
never@3156	4	*
never@3156	5	* This code is free software; you can redistribute it and/or modify it
never@3156	6	* under the terms of the GNU General Public License version 2 only, as
never@3156	7	* published by the Free Software Foundation.
never@3156	8	*
never@3156	9	* This code is distributed in the hope that it will be useful, but WITHOUT
never@3156	10	* ANY WARRANTY; without even the implied warranty of MERCHANTABILITY or
never@3156	11	* FITNESS FOR A PARTICULAR PURPOSE. See the GNU General Public License
never@3156	12	* version 2 for more details (a copy is included in the LICENSE file that
never@3156	13	* accompanied this code).
never@3156	14	*
never@3156	15	* You should have received a copy of the GNU General Public License version
never@3156	16	* 2 along with this work; if not, write to the Free Software Foundation,
never@3156	17	* Inc., 51 Franklin St, Fifth Floor, Boston, MA 02110-1301 USA.
never@3156	18	*
never@3156	19	* Please contact Oracle, 500 Oracle Parkway, Redwood Shores, CA 94065 USA
never@3156	20	* or visit www.oracle.com if you need additional information or have any
never@3156	21	* questions.
never@3156	22	*
never@3156	23	*/
never@3156	24
never@3156	25	#ifndef OS_BSD_VM_OS_BSD_INLINE_HPP
never@3156	26	#define OS_BSD_VM_OS_BSD_INLINE_HPP
never@3156	27
twisti@4318	28	#include "runtime/atomic.inline.hpp"
never@3156	29	#include "runtime/os.hpp"
twisti@4318	30
never@3156	31	#ifdef TARGET_OS_ARCH_bsd_x86
never@3156	32	# include "orderAccess_bsd_x86.inline.hpp"
never@3156	33	#endif
never@3156	34	#ifdef TARGET_OS_ARCH_bsd_zero
never@3156	35	# include "orderAccess_bsd_zero.inline.hpp"
never@3156	36	#endif
never@3156	37
never@3156	38	// System includes
never@3156	39
never@3156	40	#include <unistd.h>
never@3156	41	#include <sys/socket.h>
never@3156	42	#include <sys/poll.h>
never@3156	43	#include <netdb.h>
never@3156	44
never@3156	45	inline void* os::thread_local_storage_at(int index) {
never@3156	46	return pthread_getspecific((pthread_key_t)index);
never@3156	47	}
never@3156	48
never@3156	49	inline const char* os::file_separator() {
never@3156	50	return "/";
never@3156	51	}
never@3156	52
never@3156	53	inline const char* os::line_separator() {
never@3156	54	return "\n";
never@3156	55	}
never@3156	56
never@3156	57	inline const char* os::path_separator() {
never@3156	58	return ":";
never@3156	59	}
never@3156	60
never@3156	61	// File names are case-sensitive on windows only
never@3156	62	inline int os::file_name_strcmp(const char* s1, const char* s2) {
never@3156	63	return strcmp(s1, s2);
never@3156	64	}
never@3156	65
never@3156	66	inline bool os::obsolete_option(const JavaVMOption *option) {
never@3156	67	return false;
never@3156	68	}
never@3156	69
never@3156	70	inline bool os::uses_stack_guard_pages() {
never@3156	71	return true;
never@3156	72	}
never@3156	73
never@3156	74	inline bool os::allocate_stack_guard_pages() {
never@3156	75	assert(uses_stack_guard_pages(), "sanity check");
never@3156	76	#if !defined(__FreeBSD__) || __FreeBSD__ < 5
never@3156	77	// Since FreeBSD 4 uses malloc() for allocating the thread stack
never@3156	78	// there is no need to do anything extra to allocate the guard pages
never@3156	79	return false;
never@3156	80	#else
never@3156	81	// FreeBSD 5+ uses mmap MAP_STACK for allocating the thread stacks.
never@3156	82	// Must 'allocate' them or guard pages are ignored.
never@3156	83	return true;
never@3156	84	#endif
never@3156	85	}
never@3156	86
never@3156	87
never@3156	88	// On Bsd, reservations are made on a page by page basis, nothing to do.
zgu@3900	89	inline void os::pd_split_reserved_memory(char *base, size_t size,
never@3156	90	size_t split, bool realloc) {
never@3156	91	}
never@3156	92
never@3156	93
never@3156	94	// Bang the shadow pages if they need to be touched to be mapped.
never@3156	95	inline void os::bang_stack_shadow_pages() {
never@3156	96	}
never@3156	97
never@3156	98	inline void os::dll_unload(void *lib) {
never@3156	99	::dlclose(lib);
never@3156	100	}
never@3156	101
never@3156	102	inline const int os::default_file_open_flags() { return 0;}
never@3156	103
never@3156	104	inline DIR* os::opendir(const char* dirname)
never@3156	105	{
never@3156	106	assert(dirname != NULL, "just checking");
never@3156	107	return ::opendir(dirname);
never@3156	108	}
never@3156	109
never@3156	110	inline int os::readdir_buf_size(const char *path)
never@3156	111	{
never@3156	112	return NAME_MAX + sizeof(dirent) + 1;
never@3156	113	}
never@3156	114
never@3156	115	inline jlong os::lseek(int fd, jlong offset, int whence) {
never@3156	116	return (jlong) ::lseek(fd, offset, whence);
never@3156	117	}
never@3156	118
never@3156	119	inline int os::fsync(int fd) {
never@3156	120	return ::fsync(fd);
never@3156	121	}
never@3156	122
never@3156	123	inline char* os::native_path(char *path) {
never@3156	124	return path;
never@3156	125	}
never@3156	126
never@3156	127	inline int os::ftruncate(int fd, jlong length) {
never@3156	128	return ::ftruncate(fd, length);
never@3156	129	}
never@3156	130
never@3156	131	inline struct dirent* os::readdir(DIR* dirp, dirent *dbuf)
never@3156	132	{
never@3156	133	dirent* p;
never@3156	134	int status;
never@3156	135	assert(dirp != NULL, "just checking");
never@3156	136
never@3156	137	// NOTE: Bsd readdir_r (on RH 6.2 and 7.2 at least) is NOT like the POSIX
never@3156	138	// version. Here is the doc for this function:
never@3156	139	// http://www.gnu.org/manual/glibc-2.2.3/html_node/libc_262.html
never@3156	140
never@3156	141	if((status = ::readdir_r(dirp, dbuf, &p)) != 0) {
never@3156	142	errno = status;
never@3156	143	return NULL;
never@3156	144	} else
never@3156	145	return p;
never@3156	146	}
never@3156	147
never@3156	148	inline int os::closedir(DIR *dirp) {
never@3156	149	assert(dirp != NULL, "argument is NULL");
never@3156	150	return ::closedir(dirp);
never@3156	151	}
never@3156	152
never@3156	153	// macros for restartable system calls
never@3156	154
never@3156	155	#define RESTARTABLE(_cmd, _result) do { \
never@3156	156	_result = _cmd; \
never@3156	157	} while(((int)_result == OS_ERR) && (errno == EINTR))
never@3156	158
never@3156	159	#define RESTARTABLE_RETURN_INT(_cmd) do { \
never@3156	160	int _result; \
never@3156	161	RESTARTABLE(_cmd, _result); \
never@3156	162	return _result; \
never@3156	163	} while(false)
never@3156	164
never@3156	165	inline bool os::numa_has_static_binding() { return true; }
never@3156	166	inline bool os::numa_has_group_homing() { return false; }
never@3156	167
never@3156	168	inline size_t os::restartable_read(int fd, void *buf, unsigned int nBytes) {
never@3156	169	size_t res;
never@3156	170	RESTARTABLE( (size_t) ::read(fd, buf, (size_t) nBytes), res);
never@3156	171	return res;
never@3156	172	}
never@3156	173
never@3156	174	inline size_t os::write(int fd, const void *buf, unsigned int nBytes) {
never@3156	175	size_t res;
never@3156	176	RESTARTABLE((size_t) ::write(fd, buf, (size_t) nBytes), res);
never@3156	177	return res;
never@3156	178	}
never@3156	179
never@3156	180	inline int os::close(int fd) {
never@3156	181	RESTARTABLE_RETURN_INT(::close(fd));
never@3156	182	}
never@3156	183
never@3156	184	inline int os::socket_close(int fd) {
never@3156	185	RESTARTABLE_RETURN_INT(::close(fd));
never@3156	186	}
never@3156	187
never@3156	188	inline int os::socket(int domain, int type, int protocol) {
never@3156	189	return ::socket(domain, type, protocol);
never@3156	190	}
never@3156	191
phh@3344	192	inline int os::recv(int fd, char* buf, size_t nBytes, uint flags) {
phh@3344	193	RESTARTABLE_RETURN_INT(::recv(fd, buf, nBytes, flags));
never@3156	194	}
never@3156	195
phh@3344	196	inline int os::send(int fd, char* buf, size_t nBytes, uint flags) {
phh@3344	197	RESTARTABLE_RETURN_INT(::send(fd, buf, nBytes, flags));
never@3156	198	}
never@3156	199
phh@3344	200	inline int os::raw_send(int fd, char* buf, size_t nBytes, uint flags) {
never@3156	201	return os::send(fd, buf, nBytes, flags);
never@3156	202	}
never@3156	203
never@3156	204	inline int os::timeout(int fd, long timeout) {
never@3156	205	julong prevtime,newtime;
never@3156	206	struct timeval t;
never@3156	207
never@3156	208	gettimeofday(&t, NULL);
never@3156	209	prevtime = ((julong)t.tv_sec * 1000) + t.tv_usec / 1000;
never@3156	210
never@3156	211	for(;;) {
never@3156	212	struct pollfd pfd;
never@3156	213
never@3156	214	pfd.fd = fd;
never@3156	215	pfd.events = POLLIN | POLLERR;
never@3156	216
never@3156	217	int res = ::poll(&pfd, 1, timeout);
never@3156	218
never@3156	219	if (res == OS_ERR && errno == EINTR) {
never@3156	220
never@3156	221	// On Bsd any value < 0 means "forever"
never@3156	222
never@3156	223	if(timeout >= 0) {
never@3156	224	gettimeofday(&t, NULL);
never@3156	225	newtime = ((julong)t.tv_sec * 1000) + t.tv_usec / 1000;
never@3156	226	timeout -= newtime - prevtime;
never@3156	227	if(timeout <= 0)
never@3156	228	return OS_OK;
never@3156	229	prevtime = newtime;
never@3156	230	}
never@3156	231	} else
never@3156	232	return res;
never@3156	233	}
never@3156	234	}
never@3156	235
never@3156	236	inline int os::listen(int fd, int count) {
never@3156	237	return ::listen(fd, count);
never@3156	238	}
never@3156	239
phh@3344	240	inline int os::connect(int fd, struct sockaddr* him, socklen_t len) {
never@3156	241	RESTARTABLE_RETURN_INT(::connect(fd, him, len));
never@3156	242	}
never@3156	243
phh@3344	244	inline int os::accept(int fd, struct sockaddr* him, socklen_t* len) {
never@3156	245	// At least OpenBSD and FreeBSD can return EINTR from accept.
phh@3344	246	RESTARTABLE_RETURN_INT(::accept(fd, him, len));
never@3156	247	}
never@3156	248
phh@3344	249	inline int os::recvfrom(int fd, char* buf, size_t nBytes, uint flags,
phh@3344	250	sockaddr* from, socklen_t* fromlen) {
phh@3344	251	RESTARTABLE_RETURN_INT((int)::recvfrom(fd, buf, nBytes, flags, from, fromlen));
never@3156	252	}
never@3156	253
phh@3344	254	inline int os::sendto(int fd, char* buf, size_t len, uint flags,
phh@3344	255	struct sockaddr *to, socklen_t tolen) {
phh@3344	256	RESTARTABLE_RETURN_INT((int)::sendto(fd, buf, len, flags, to, tolen));
never@3156	257	}
never@3156	258
phh@3344	259	inline int os::socket_shutdown(int fd, int howto) {
never@3156	260	return ::shutdown(fd, howto);
never@3156	261	}
never@3156	262
phh@3344	263	inline int os::bind(int fd, struct sockaddr* him, socklen_t len) {
never@3156	264	return ::bind(fd, him, len);
never@3156	265	}
never@3156	266
phh@3344	267	inline int os::get_sock_name(int fd, struct sockaddr* him, socklen_t* len) {
phh@3344	268	return ::getsockname(fd, him, len);
never@3156	269	}
never@3156	270
phh@3344	271	inline int os::get_host_name(char* name, int namelen) {
never@3156	272	return ::gethostname(name, namelen);
never@3156	273	}
never@3156	274
phh@3344	275	inline struct hostent* os::get_host_by_name(char* name) {
never@3156	276	return ::gethostbyname(name);
never@3156	277	}
phh@3344	278
never@3156	279	inline int os::get_sock_opt(int fd, int level, int optname,
phh@3344	280	char *optval, socklen_t* optlen) {
phh@3344	281	return ::getsockopt(fd, level, optname, optval, optlen);
never@3156	282	}
never@3156	283
never@3156	284	inline int os::set_sock_opt(int fd, int level, int optname,
phh@3344	285	const char* optval, socklen_t optlen) {
never@3156	286	return ::setsockopt(fd, level, optname, optval, optlen);
never@3156	287	}
simonis@4675	288
simonis@4675	289	inline void os::Bsd::SuspendResume::set_suspended() {
simonis@4675	290	jint temp, temp2;
simonis@4675	291	do {
simonis@4675	292	temp = _state;
simonis@4675	293	temp2 = Atomic::cmpxchg(temp | SR_SUSPENDED, &_state, temp);
simonis@4675	294	} while (temp2 != temp);
simonis@4675	295	}
simonis@4675	296
simonis@4675	297	inline void os::Bsd::SuspendResume::clear_suspended() {
simonis@4675	298	jint temp, temp2;
simonis@4675	299	do {
simonis@4675	300	temp = _state;
simonis@4675	301	temp2 = Atomic::cmpxchg(temp & ~SR_SUSPENDED, &_state, temp);
simonis@4675	302	} while (temp2 != temp);
simonis@4675	303	}
simonis@4675	304
never@3156	305	#endif // OS_BSD_VM_OS_BSD_INLINE_HPP