hotspot/src/os/linux/vm/hpi_linux.hpp
author never
Tue, 24 Jun 2008 16:00:14 -0700
changeset 768 d0bebc7eefc2
parent 1 489c9b5090e2
child 5547 f4b087cbb361
permissions -rw-r--r--
6718676: putback for 6604014 is incomplete Reviewed-by: kvn, jrose
Ignore whitespace changes - Everywhere: Within whitespace: At end of lines:
1
489c9b5090e2 Initial load
duke
parents:
diff changeset
     1
/*
489c9b5090e2 Initial load
duke
parents:
diff changeset
     2
 * Copyright 1999-2005 Sun Microsystems, Inc.  All Rights Reserved.
489c9b5090e2 Initial load
duke
parents:
diff changeset
     3
 * DO NOT ALTER OR REMOVE COPYRIGHT NOTICES OR THIS FILE HEADER.
489c9b5090e2 Initial load
duke
parents:
diff changeset
     4
 *
489c9b5090e2 Initial load
duke
parents:
diff changeset
     5
 * This code is free software; you can redistribute it and/or modify it
489c9b5090e2 Initial load
duke
parents:
diff changeset
     6
 * under the terms of the GNU General Public License version 2 only, as
489c9b5090e2 Initial load
duke
parents:
diff changeset
     7
 * published by the Free Software Foundation.
489c9b5090e2 Initial load
duke
parents:
diff changeset
     8
 *
489c9b5090e2 Initial load
duke
parents:
diff changeset
     9
 * This code is distributed in the hope that it will be useful, but WITHOUT
489c9b5090e2 Initial load
duke
parents:
diff changeset
    10
 * ANY WARRANTY; without even the implied warranty of MERCHANTABILITY or
489c9b5090e2 Initial load
duke
parents:
diff changeset
    11
 * FITNESS FOR A PARTICULAR PURPOSE.  See the GNU General Public License
489c9b5090e2 Initial load
duke
parents:
diff changeset
    12
 * version 2 for more details (a copy is included in the LICENSE file that
489c9b5090e2 Initial load
duke
parents:
diff changeset
    13
 * accompanied this code).
489c9b5090e2 Initial load
duke
parents:
diff changeset
    14
 *
489c9b5090e2 Initial load
duke
parents:
diff changeset
    15
 * You should have received a copy of the GNU General Public License version
489c9b5090e2 Initial load
duke
parents:
diff changeset
    16
 * 2 along with this work; if not, write to the Free Software Foundation,
489c9b5090e2 Initial load
duke
parents:
diff changeset
    17
 * Inc., 51 Franklin St, Fifth Floor, Boston, MA 02110-1301 USA.
489c9b5090e2 Initial load
duke
parents:
diff changeset
    18
 *
489c9b5090e2 Initial load
duke
parents:
diff changeset
    19
 * Please contact Sun Microsystems, Inc., 4150 Network Circle, Santa Clara,
489c9b5090e2 Initial load
duke
parents:
diff changeset
    20
 * CA 95054 USA or visit www.sun.com if you need additional information or
489c9b5090e2 Initial load
duke
parents:
diff changeset
    21
 * have any questions.
489c9b5090e2 Initial load
duke
parents:
diff changeset
    22
 *
489c9b5090e2 Initial load
duke
parents:
diff changeset
    23
 */
489c9b5090e2 Initial load
duke
parents:
diff changeset
    24
489c9b5090e2 Initial load
duke
parents:
diff changeset
    25
//
489c9b5090e2 Initial load
duke
parents:
diff changeset
    26
// Because the interruptible IO has been dropped for HotSpot/Linux,
489c9b5090e2 Initial load
duke
parents:
diff changeset
    27
// the following HPI interface is very different from HotSparc.
489c9b5090e2 Initial load
duke
parents:
diff changeset
    28
//
489c9b5090e2 Initial load
duke
parents:
diff changeset
    29
489c9b5090e2 Initial load
duke
parents:
diff changeset
    30
#include <unistd.h>
489c9b5090e2 Initial load
duke
parents:
diff changeset
    31
#include <sys/socket.h>
489c9b5090e2 Initial load
duke
parents:
diff changeset
    32
#include <sys/poll.h>
489c9b5090e2 Initial load
duke
parents:
diff changeset
    33
#include <sys/ioctl.h>
489c9b5090e2 Initial load
duke
parents:
diff changeset
    34
#include <netdb.h>
489c9b5090e2 Initial load
duke
parents:
diff changeset
    35
489c9b5090e2 Initial load
duke
parents:
diff changeset
    36
// HPI_FileInterface
489c9b5090e2 Initial load
duke
parents:
diff changeset
    37
489c9b5090e2 Initial load
duke
parents:
diff changeset
    38
inline int hpi::close(int fd) {
489c9b5090e2 Initial load
duke
parents:
diff changeset
    39
  return ::close(fd);
489c9b5090e2 Initial load
duke
parents:
diff changeset
    40
}
489c9b5090e2 Initial load
duke
parents:
diff changeset
    41
489c9b5090e2 Initial load
duke
parents:
diff changeset
    42
inline size_t hpi::read(int fd, void *buf, unsigned int nBytes) {
489c9b5090e2 Initial load
duke
parents:
diff changeset
    43
  size_t res;
489c9b5090e2 Initial load
duke
parents:
diff changeset
    44
  RESTARTABLE( (size_t) ::read(fd, buf, (size_t) nBytes), res);
489c9b5090e2 Initial load
duke
parents:
diff changeset
    45
  return res;
489c9b5090e2 Initial load
duke
parents:
diff changeset
    46
}
489c9b5090e2 Initial load
duke
parents:
diff changeset
    47
489c9b5090e2 Initial load
duke
parents:
diff changeset
    48
inline size_t hpi::write(int fd, const void *buf, unsigned int nBytes) {
489c9b5090e2 Initial load
duke
parents:
diff changeset
    49
  size_t res;
489c9b5090e2 Initial load
duke
parents:
diff changeset
    50
  RESTARTABLE((size_t) ::write(fd, buf, (size_t) nBytes), res);
489c9b5090e2 Initial load
duke
parents:
diff changeset
    51
  return res;
489c9b5090e2 Initial load
duke
parents:
diff changeset
    52
}
489c9b5090e2 Initial load
duke
parents:
diff changeset
    53
489c9b5090e2 Initial load
duke
parents:
diff changeset
    54
489c9b5090e2 Initial load
duke
parents:
diff changeset
    55
// HPI_SocketInterface
489c9b5090e2 Initial load
duke
parents:
diff changeset
    56
489c9b5090e2 Initial load
duke
parents:
diff changeset
    57
inline int hpi::socket_close(int fd) {
489c9b5090e2 Initial load
duke
parents:
diff changeset
    58
  return ::close(fd);
489c9b5090e2 Initial load
duke
parents:
diff changeset
    59
}
489c9b5090e2 Initial load
duke
parents:
diff changeset
    60
489c9b5090e2 Initial load
duke
parents:
diff changeset
    61
inline int hpi::socket(int domain, int type, int protocol) {
489c9b5090e2 Initial load
duke
parents:
diff changeset
    62
  return ::socket(domain, type, protocol);
489c9b5090e2 Initial load
duke
parents:
diff changeset
    63
}
489c9b5090e2 Initial load
duke
parents:
diff changeset
    64
489c9b5090e2 Initial load
duke
parents:
diff changeset
    65
inline int hpi::recv(int fd, char *buf, int nBytes, int flags) {
489c9b5090e2 Initial load
duke
parents:
diff changeset
    66
  RESTARTABLE_RETURN_INT(::recv(fd, buf, nBytes, (unsigned int) flags));
489c9b5090e2 Initial load
duke
parents:
diff changeset
    67
}
489c9b5090e2 Initial load
duke
parents:
diff changeset
    68
489c9b5090e2 Initial load
duke
parents:
diff changeset
    69
inline int hpi::send(int fd, char *buf, int nBytes, int flags) {
489c9b5090e2 Initial load
duke
parents:
diff changeset
    70
  RESTARTABLE_RETURN_INT(::send(fd, buf, nBytes, (unsigned int) flags));
489c9b5090e2 Initial load
duke
parents:
diff changeset
    71
}
489c9b5090e2 Initial load
duke
parents:
diff changeset
    72
768
d0bebc7eefc2 6718676: putback for 6604014 is incomplete
never
parents: 1
diff changeset
    73
inline int hpi::raw_send(int fd, char *buf, int nBytes, int flags) {
d0bebc7eefc2 6718676: putback for 6604014 is incomplete
never
parents: 1
diff changeset
    74
  return send(fd, buf, nBytes, flags);
d0bebc7eefc2 6718676: putback for 6604014 is incomplete
never
parents: 1
diff changeset
    75
}
d0bebc7eefc2 6718676: putback for 6604014 is incomplete
never
parents: 1
diff changeset
    76
1
489c9b5090e2 Initial load
duke
parents:
diff changeset
    77
inline int hpi::timeout(int fd, long timeout) {
489c9b5090e2 Initial load
duke
parents:
diff changeset
    78
  julong prevtime,newtime;
489c9b5090e2 Initial load
duke
parents:
diff changeset
    79
  struct timeval t;
489c9b5090e2 Initial load
duke
parents:
diff changeset
    80
489c9b5090e2 Initial load
duke
parents:
diff changeset
    81
  gettimeofday(&t, NULL);
489c9b5090e2 Initial load
duke
parents:
diff changeset
    82
  prevtime = ((julong)t.tv_sec * 1000)  +  t.tv_usec / 1000;
489c9b5090e2 Initial load
duke
parents:
diff changeset
    83
489c9b5090e2 Initial load
duke
parents:
diff changeset
    84
  for(;;) {
489c9b5090e2 Initial load
duke
parents:
diff changeset
    85
    struct pollfd pfd;
489c9b5090e2 Initial load
duke
parents:
diff changeset
    86
489c9b5090e2 Initial load
duke
parents:
diff changeset
    87
    pfd.fd = fd;
489c9b5090e2 Initial load
duke
parents:
diff changeset
    88
    pfd.events = POLLIN | POLLERR;
489c9b5090e2 Initial load
duke
parents:
diff changeset
    89
489c9b5090e2 Initial load
duke
parents:
diff changeset
    90
    int res = ::poll(&pfd, 1, timeout);
489c9b5090e2 Initial load
duke
parents:
diff changeset
    91
489c9b5090e2 Initial load
duke
parents:
diff changeset
    92
    if (res == OS_ERR && errno == EINTR) {
489c9b5090e2 Initial load
duke
parents:
diff changeset
    93
489c9b5090e2 Initial load
duke
parents:
diff changeset
    94
      // On Linux any value < 0 means "forever"
489c9b5090e2 Initial load
duke
parents:
diff changeset
    95
489c9b5090e2 Initial load
duke
parents:
diff changeset
    96
      if(timeout >= 0) {
489c9b5090e2 Initial load
duke
parents:
diff changeset
    97
        gettimeofday(&t, NULL);
489c9b5090e2 Initial load
duke
parents:
diff changeset
    98
        newtime = ((julong)t.tv_sec * 1000)  +  t.tv_usec / 1000;
489c9b5090e2 Initial load
duke
parents:
diff changeset
    99
        timeout -= newtime - prevtime;
489c9b5090e2 Initial load
duke
parents:
diff changeset
   100
        if(timeout <= 0)
489c9b5090e2 Initial load
duke
parents:
diff changeset
   101
          return OS_OK;
489c9b5090e2 Initial load
duke
parents:
diff changeset
   102
        prevtime = newtime;
489c9b5090e2 Initial load
duke
parents:
diff changeset
   103
      }
489c9b5090e2 Initial load
duke
parents:
diff changeset
   104
    } else
489c9b5090e2 Initial load
duke
parents:
diff changeset
   105
      return res;
489c9b5090e2 Initial load
duke
parents:
diff changeset
   106
  }
489c9b5090e2 Initial load
duke
parents:
diff changeset
   107
}
489c9b5090e2 Initial load
duke
parents:
diff changeset
   108
489c9b5090e2 Initial load
duke
parents:
diff changeset
   109
inline int hpi::listen(int fd, int count) {
489c9b5090e2 Initial load
duke
parents:
diff changeset
   110
  return ::listen(fd, count);
489c9b5090e2 Initial load
duke
parents:
diff changeset
   111
}
489c9b5090e2 Initial load
duke
parents:
diff changeset
   112
489c9b5090e2 Initial load
duke
parents:
diff changeset
   113
inline int hpi::connect(int fd, struct sockaddr *him, int len) {
489c9b5090e2 Initial load
duke
parents:
diff changeset
   114
  RESTARTABLE_RETURN_INT(::connect(fd, him, len));
489c9b5090e2 Initial load
duke
parents:
diff changeset
   115
}
489c9b5090e2 Initial load
duke
parents:
diff changeset
   116
489c9b5090e2 Initial load
duke
parents:
diff changeset
   117
inline int hpi::accept(int fd, struct sockaddr *him, int *len) {
489c9b5090e2 Initial load
duke
parents:
diff changeset
   118
  // This cast is from int to unsigned int on linux.  Since we
489c9b5090e2 Initial load
duke
parents:
diff changeset
   119
  // only pass the parameter "len" around the vm and don't try to
489c9b5090e2 Initial load
duke
parents:
diff changeset
   120
  // fetch it's value, this cast is safe for now. The java.net group
489c9b5090e2 Initial load
duke
parents:
diff changeset
   121
  // may need and want to change this interface someday if socklen_t goes
489c9b5090e2 Initial load
duke
parents:
diff changeset
   122
  // to 64 bits on some platform that we support.
489c9b5090e2 Initial load
duke
parents:
diff changeset
   123
  // Linux doc says this can't return EINTR, unlike accept() on Solaris
489c9b5090e2 Initial load
duke
parents:
diff changeset
   124
489c9b5090e2 Initial load
duke
parents:
diff changeset
   125
  return ::accept(fd, him, (socklen_t *)len);
489c9b5090e2 Initial load
duke
parents:
diff changeset
   126
}
489c9b5090e2 Initial load
duke
parents:
diff changeset
   127
489c9b5090e2 Initial load
duke
parents:
diff changeset
   128
inline int hpi::recvfrom(int fd, char *buf, int nBytes, int flags,
489c9b5090e2 Initial load
duke
parents:
diff changeset
   129
                         sockaddr *from, int *fromlen) {
489c9b5090e2 Initial load
duke
parents:
diff changeset
   130
  RESTARTABLE_RETURN_INT(::recvfrom(fd, buf, nBytes, (unsigned int) flags, from, (socklen_t *)fromlen));
489c9b5090e2 Initial load
duke
parents:
diff changeset
   131
}
489c9b5090e2 Initial load
duke
parents:
diff changeset
   132
489c9b5090e2 Initial load
duke
parents:
diff changeset
   133
inline int hpi::sendto(int fd, char *buf, int len, int flags,
489c9b5090e2 Initial load
duke
parents:
diff changeset
   134
                        struct sockaddr *to, int tolen) {
489c9b5090e2 Initial load
duke
parents:
diff changeset
   135
  RESTARTABLE_RETURN_INT(::sendto(fd, buf, len, (unsigned int) flags, to, tolen));
489c9b5090e2 Initial load
duke
parents:
diff changeset
   136
}
489c9b5090e2 Initial load
duke
parents:
diff changeset
   137
489c9b5090e2 Initial load
duke
parents:
diff changeset
   138
inline int hpi::socket_available(int fd, jint *pbytes) {
489c9b5090e2 Initial load
duke
parents:
diff changeset
   139
  // Linux doc says EINTR not returned, unlike Solaris
489c9b5090e2 Initial load
duke
parents:
diff changeset
   140
  int ret = ::ioctl(fd, FIONREAD, pbytes);
489c9b5090e2 Initial load
duke
parents:
diff changeset
   141
489c9b5090e2 Initial load
duke
parents:
diff changeset
   142
  //%% note ioctl can return 0 when successful, JVM_SocketAvailable
489c9b5090e2 Initial load
duke
parents:
diff changeset
   143
  // is expected to return 0 on failure and 1 on success to the jdk.
489c9b5090e2 Initial load
duke
parents:
diff changeset
   144
  return (ret < 0) ? 0 : 1;
489c9b5090e2 Initial load
duke
parents:
diff changeset
   145
}
489c9b5090e2 Initial load
duke
parents:
diff changeset
   146
489c9b5090e2 Initial load
duke
parents:
diff changeset
   147
489c9b5090e2 Initial load
duke
parents:
diff changeset
   148
// following methods have been updated to avoid problems in
489c9b5090e2 Initial load
duke
parents:
diff changeset
   149
// hpi's sockets calls based on sys_api_td.c (JDK1.3)
489c9b5090e2 Initial load
duke
parents:
diff changeset
   150
489c9b5090e2 Initial load
duke
parents:
diff changeset
   151
/*
489c9b5090e2 Initial load
duke
parents:
diff changeset
   152
HPIDECL(socket_shutdown, "socket_shutdown", _socket, SocketShutdown,
489c9b5090e2 Initial load
duke
parents:
diff changeset
   153
        int, "%d",
489c9b5090e2 Initial load
duke
parents:
diff changeset
   154
        (int fd, int howto),
489c9b5090e2 Initial load
duke
parents:
diff changeset
   155
        ("fd = %d, howto = %d", fd, howto),
489c9b5090e2 Initial load
duke
parents:
diff changeset
   156
        (fd, howto));
489c9b5090e2 Initial load
duke
parents:
diff changeset
   157
        */
489c9b5090e2 Initial load
duke
parents:
diff changeset
   158
inline int hpi::socket_shutdown(int fd, int howto){
489c9b5090e2 Initial load
duke
parents:
diff changeset
   159
  return ::shutdown(fd, howto);
489c9b5090e2 Initial load
duke
parents:
diff changeset
   160
}
489c9b5090e2 Initial load
duke
parents:
diff changeset
   161
489c9b5090e2 Initial load
duke
parents:
diff changeset
   162
/*
489c9b5090e2 Initial load
duke
parents:
diff changeset
   163
HPIDECL(bind, "bind", _socket, Bind,
489c9b5090e2 Initial load
duke
parents:
diff changeset
   164
        int, "%d",
489c9b5090e2 Initial load
duke
parents:
diff changeset
   165
        (int fd, struct sockaddr *him, int len),
489c9b5090e2 Initial load
duke
parents:
diff changeset
   166
        ("fd = %d, him = %p, len = %d",
489c9b5090e2 Initial load
duke
parents:
diff changeset
   167
         fd, him, len),
489c9b5090e2 Initial load
duke
parents:
diff changeset
   168
        (fd, him, len));
489c9b5090e2 Initial load
duke
parents:
diff changeset
   169
*/
489c9b5090e2 Initial load
duke
parents:
diff changeset
   170
inline int hpi::bind(int fd, struct sockaddr *him, int len){
489c9b5090e2 Initial load
duke
parents:
diff changeset
   171
  return ::bind(fd, him, len);
489c9b5090e2 Initial load
duke
parents:
diff changeset
   172
}
489c9b5090e2 Initial load
duke
parents:
diff changeset
   173
489c9b5090e2 Initial load
duke
parents:
diff changeset
   174
/*
489c9b5090e2 Initial load
duke
parents:
diff changeset
   175
HPIDECL(get_sock_name, "get_sock_name", _socket, GetSocketName,
489c9b5090e2 Initial load
duke
parents:
diff changeset
   176
        int, "%d",
489c9b5090e2 Initial load
duke
parents:
diff changeset
   177
        (int fd, struct sockaddr *him, int *len),
489c9b5090e2 Initial load
duke
parents:
diff changeset
   178
        ("fd = %d, him = %p, len = %p",
489c9b5090e2 Initial load
duke
parents:
diff changeset
   179
         fd, him, len),
489c9b5090e2 Initial load
duke
parents:
diff changeset
   180
        (fd, him, len));
489c9b5090e2 Initial load
duke
parents:
diff changeset
   181
        */
489c9b5090e2 Initial load
duke
parents:
diff changeset
   182
inline int hpi::get_sock_name(int fd, struct sockaddr *him, int *len){
489c9b5090e2 Initial load
duke
parents:
diff changeset
   183
  return ::getsockname(fd, him, (socklen_t *)len);
489c9b5090e2 Initial load
duke
parents:
diff changeset
   184
}
489c9b5090e2 Initial load
duke
parents:
diff changeset
   185
489c9b5090e2 Initial load
duke
parents:
diff changeset
   186
/*
489c9b5090e2 Initial load
duke
parents:
diff changeset
   187
HPIDECL(get_host_name, "get_host_name", _socket, GetHostName, int, "%d",
489c9b5090e2 Initial load
duke
parents:
diff changeset
   188
        (char *hostname, int namelen),
489c9b5090e2 Initial load
duke
parents:
diff changeset
   189
        ("hostname = %p, namelen = %d",
489c9b5090e2 Initial load
duke
parents:
diff changeset
   190
         hostname, namelen),
489c9b5090e2 Initial load
duke
parents:
diff changeset
   191
        (hostname, namelen));
489c9b5090e2 Initial load
duke
parents:
diff changeset
   192
        */
489c9b5090e2 Initial load
duke
parents:
diff changeset
   193
inline int hpi::get_host_name(char* name, int namelen){
489c9b5090e2 Initial load
duke
parents:
diff changeset
   194
  return ::gethostname(name, namelen);
489c9b5090e2 Initial load
duke
parents:
diff changeset
   195
}
489c9b5090e2 Initial load
duke
parents:
diff changeset
   196
489c9b5090e2 Initial load
duke
parents:
diff changeset
   197
/*
489c9b5090e2 Initial load
duke
parents:
diff changeset
   198
HPIDECL(get_sock_opt, "get_sock_opt", _socket, SocketGetOption, int, "%d",
489c9b5090e2 Initial load
duke
parents:
diff changeset
   199
        (int fd, int level, int optname, char *optval, int* optlen),
489c9b5090e2 Initial load
duke
parents:
diff changeset
   200
        ("fd = %d, level = %d, optname = %d, optval = %p, optlen = %p",
489c9b5090e2 Initial load
duke
parents:
diff changeset
   201
         fd, level, optname, optval, optlen),
489c9b5090e2 Initial load
duke
parents:
diff changeset
   202
        (fd, level, optname, optval, optlen));
489c9b5090e2 Initial load
duke
parents:
diff changeset
   203
        */
489c9b5090e2 Initial load
duke
parents:
diff changeset
   204
inline int hpi::get_sock_opt(int fd, int level, int optname,
489c9b5090e2 Initial load
duke
parents:
diff changeset
   205
                             char *optval, int* optlen){
489c9b5090e2 Initial load
duke
parents:
diff changeset
   206
  return ::getsockopt(fd, level, optname, optval, (socklen_t *)optlen);
489c9b5090e2 Initial load
duke
parents:
diff changeset
   207
}
489c9b5090e2 Initial load
duke
parents:
diff changeset
   208
489c9b5090e2 Initial load
duke
parents:
diff changeset
   209
/*
489c9b5090e2 Initial load
duke
parents:
diff changeset
   210
HPIDECL(set_sock_opt, "set_sock_opt", _socket, SocketSetOption, int, "%d",
489c9b5090e2 Initial load
duke
parents:
diff changeset
   211
        (int fd, int level, int optname, const char *optval, int optlen),
489c9b5090e2 Initial load
duke
parents:
diff changeset
   212
        ("fd = %d, level = %d, optname = %d, optval = %p, optlen = %d",
489c9b5090e2 Initial load
duke
parents:
diff changeset
   213
         fd, level, optname, optval, optlen),
489c9b5090e2 Initial load
duke
parents:
diff changeset
   214
        (fd, level, optname, optval, optlen));
489c9b5090e2 Initial load
duke
parents:
diff changeset
   215
        */
489c9b5090e2 Initial load
duke
parents:
diff changeset
   216
inline int hpi::set_sock_opt(int fd, int level, int optname,
489c9b5090e2 Initial load
duke
parents:
diff changeset
   217
                             const char *optval, int optlen){
489c9b5090e2 Initial load
duke
parents:
diff changeset
   218
  return ::setsockopt(fd, level, optname, optval, optlen);
489c9b5090e2 Initial load
duke
parents:
diff changeset
   219
}
489c9b5090e2 Initial load
duke
parents:
diff changeset
   220
489c9b5090e2 Initial load
duke
parents:
diff changeset
   221
489c9b5090e2 Initial load
duke
parents:
diff changeset
   222
// Reconciliation History
489c9b5090e2 Initial load
duke
parents:
diff changeset
   223
// hpi_solaris.hpp      1.9 99/08/30 16:31:23
489c9b5090e2 Initial load
duke
parents:
diff changeset
   224
// End