/openjdk7/jdk/src/share/transport/socket/ |
H A D | socketTransport.c | 118 setOptions(int fd) argument 125 err = dbgsysSetSocketOption(fd, SO_REUSEADDR, JNI_TRUE, dontcare); 130 err = dbgsysSetSocketOption(fd, TCP_NODELAY, JNI_TRUE, dontcare); 139 handshake(int fd, jlong timeout) { argument 145 dbgsysConfigureBlocking(fd, JNI_FALSE); 153 rv = dbgsysPoll(fd, JNI_TRUE, JNI_FALSE, (long)timeout); 161 n = recv_fully(fd, buf, helloLen-received); 172 dbgsysConfigureBlocking(fd, JNI_TRUE); 186 if (send_fully(fd, (char*)hello, helloLen) != helloLen) { 503 int fd local [all...] |
/openjdk7/jdk/src/solaris/classes/sun/nio/ch/ |
H A D | DevPollArrayWrapper.java | 38 * int fd; 80 // Initial size of arrays for fd registration changes 92 // The fd of the devpoll driver 95 // The fd of the interrupt line going out 98 // The fd of the interrupt line coming in 107 // object to synchronize fd registration changes 162 private void setUpdateEvents(int fd, byte events) { argument 163 if (fd < MAX_UPDATE_ARRAY_SIZE) { 164 eventsLow[fd] = events; 166 eventsHigh.put(Integer.valueOf(fd), Byt 170 getUpdateEvents(int fd) argument 180 setInterest(int fd, int mask) argument 200 release(int fd) argument 285 putPollFD(AllocatedNativeObject array, int index, int fd, short event) argument 313 register(int wfd, int fd, int mask) argument 318 interrupt(int fd) argument [all...] |
H A D | UnixAsynchronousSocketChannelImpl.java | 100 IOUtil.configureBlocking(fd, false); 102 nd.close(fd); 107 this.fdVal = IOUtil.fdVal(fd); 115 FileDescriptor fd, 119 super(port, fd, remote); 121 this.fdVal = IOUtil.fdVal(fd); 122 IOUtil.configureBlocking(fd, false); 222 nd.close(fd); 243 localAddress = Net.localAddress(fd); 325 NetHooks.beforeTcpConnect(fd, is 114 UnixAsynchronousSocketChannelImpl(Port port, FileDescriptor fd, InetSocketAddress remote) argument [all...] |
/openjdk7/jdk/src/solaris/classes/sun/nio/fs/ |
H A D | LinuxWatchService.java | 443 private static native int inotifyAddWatch(int fd, long pathAddress, int mask) argument 446 private static native void inotifyRmWatch(int fd, int wd) argument 449 private static native void configureBlocking(int fd, boolean blocking) argument
|
/openjdk7/jdk/src/solaris/demo/jni/Poller/ |
H A D | Poller.c | 347 if (ioeh->pfd[i].fd == -1) 365 * an fd already added (no problem for /dev/poll...just 369 (JNIEnv *env, jobject obj, jint handle, jint fd, jshort events) 390 pollelt.fd = fd; 400 retval = fd; 406 retval = addfd(env, ioeh, fd, events); 414 jint addfd(JNIEnv *env, ioevent_t *ioeh, jint fd, jshort events) 425 if (ioeh->pfd[idx].fd == -1) 439 * and fill extras with fd 363 Java_Poller_nativeAddFd(JNIEnv *env, jobject obj, jint handle, jint fd, jshort events) argument 409 addfd(JNIEnv *env, ioevent_t *ioeh, jint fd, jshort events) argument 467 Java_Poller_nativeRemoveFd(JNIEnv *env, jobject obj, jint handle, jint fd) argument 502 removefd(JNIEnv *env, ioevent_t *ioeh, jint fd) argument 572 Java_Poller_nativeIsMember(JNIEnv *env, jobject obj, jint handle, jint fd) argument [all...] |
/openjdk7/jdk/src/solaris/demo/jvmti/hprof/ |
H A D | hprof_md.c | 118 int fd; local 121 fd = socket(AF_INET, SOCK_STREAM, 0); 136 if (-1 == connect(fd, (struct sockaddr*)&s, sizeof(s))) { 139 return fd;
|
/openjdk7/jdk/src/share/classes/java/net/ |
H A D | AbstractPlainSocketImpl.java | 92 // only create the fd after we know we will be able to create the socket 93 fd = new FileDescriptor(); 98 fd = null; 102 fd = new FileDescriptor(); 333 NetHooks.beforeTcpConnect(fd, address, port); 373 NetHooks.beforeTcpBind(fd, address, lport); 437 void setFileDescriptor(FileDescriptor fd) { argument 438 this.fd = fd; 500 if (fd ! [all...] |
/openjdk7/jdk/src/share/classes/java/util/ |
H A D | GregorianCalendar.java | 1026 long fd = getCurrentFixedDate(); 1035 fd++; 1038 fd--; 1042 fd += delta; // fd is the expected fixed date after the calculation 1044 setTimeInMillis((fd - EPOCH_OFFSET) * ONE_DAY + timeOfDay - zoneOffset); 1052 if (fd2 != fd) { 1249 long fd = getCurrentFixedDate(); 1251 long day1 = fd - (7 * (woy - min)); 1257 fd 3026 getCalendarDate(long fd) argument [all...] |
H A D | JapaneseImperialCalendar.java | 248 long fd = sinceFixedDates[i]; 252 dayOfYear = Math.min((int)(fdd - fd), dayOfYear); 255 dayOfYear = Math.min((int)(fd - fdd), dayOfYear); 257 LocalGregorianCalendar.Date lgd = getCalendarDate(fd - 1); 452 long fd = cachedFixedDate; 461 fd++; 464 fd--; 468 fd += delta; // fd is the expected fixed date after the calculation 470 setTimeInMillis((fd 2190 getCalendarDate(long fd) argument [all...] |
/openjdk7/hotspot/src/share/vm/ci/ |
H A D | ciObjectFactory.cpp | 455 FieldArrayInfo fd; local 457 fd, THREAD); 463 int dimension = fd.dimension(); 468 ciSymbol* ci_name = env->get_symbol(fd.object_key());
|
/openjdk7/hotspot/src/os/bsd/vm/ |
H A D | os_bsd.inline.hpp | 124 inline jlong os::lseek(int fd, jlong offset, int whence) { argument 125 return (jlong) ::lseek(fd, offset, whence); 128 inline int os::fsync(int fd) { argument 129 return ::fsync(fd); 136 inline int os::ftruncate(int fd, jlong length) { argument 137 return ::ftruncate(fd, length); 177 inline size_t os::restartable_read(int fd, void *buf, unsigned int nBytes) { argument 179 RESTARTABLE( (size_t) ::read(fd, buf, (size_t) nBytes), res); 183 inline size_t os::write(int fd, const void *buf, unsigned int nBytes) { argument 185 RESTARTABLE((size_t) ::write(fd, bu 189 close(int fd) argument 193 socket_close(int fd) argument 201 recv(int fd, char* buf, size_t nBytes, uint flags) argument 205 send(int fd, char* buf, size_t nBytes, uint flags) argument 209 raw_send(int fd, char* buf, size_t nBytes, uint flags) argument 213 timeout(int fd, long timeout) argument 245 listen(int fd, int count) argument 249 connect(int fd, struct sockaddr* him, socklen_t len) argument 253 accept(int fd, struct sockaddr* him, socklen_t* len) argument 258 recvfrom(int fd, char* buf, size_t nBytes, uint flags, sockaddr* from, socklen_t* fromlen) argument 263 sendto(int fd, char* buf, size_t len, uint flags, struct sockaddr *to, socklen_t tolen) argument 268 socket_shutdown(int fd, int howto) argument 272 bind(int fd, struct sockaddr* him, socklen_t len) argument 276 get_sock_name(int fd, struct sockaddr* him, socklen_t* len) argument 288 get_sock_opt(int fd, int level, int optname, char *optval, socklen_t* optlen) argument 293 set_sock_opt(int fd, int level, int optname, const char* optval, socklen_t optlen) argument [all...] |
/openjdk7/hotspot/src/os/linux/vm/ |
H A D | os_linux.inline.hpp | 128 inline jlong os::lseek(int fd, jlong offset, int whence) { argument 129 return (jlong) ::lseek64(fd, offset, whence); 132 inline int os::fsync(int fd) { argument 133 return ::fsync(fd); 140 inline int os::ftruncate(int fd, jlong length) { argument 141 return ::ftruncate64(fd, length); 181 inline size_t os::restartable_read(int fd, void *buf, unsigned int nBytes) { argument 183 RESTARTABLE( (size_t) ::read(fd, buf, (size_t) nBytes), res); 187 inline size_t os::write(int fd, const void *buf, unsigned int nBytes) { argument 189 RESTARTABLE((size_t) ::write(fd, bu 193 close(int fd) argument 197 socket_close(int fd) argument 205 recv(int fd, char* buf, size_t nBytes, uint flags) argument 209 send(int fd, char* buf, size_t nBytes, uint flags) argument 213 raw_send(int fd, char* buf, size_t nBytes, uint flags) argument 217 timeout(int fd, long timeout) argument 249 listen(int fd, int count) argument 253 connect(int fd, struct sockaddr* him, socklen_t len) argument 257 accept(int fd, struct sockaddr* him, socklen_t* len) argument 263 recvfrom(int fd, char* buf, size_t nBytes, uint flags, sockaddr* from, socklen_t* fromlen) argument 268 sendto(int fd, char* buf, size_t len, uint flags, struct sockaddr* to, socklen_t tolen) argument 273 socket_shutdown(int fd, int howto) argument 277 bind(int fd, struct sockaddr* him, socklen_t len) argument 281 get_sock_name(int fd, struct sockaddr* him, socklen_t* len) argument 293 get_sock_opt(int fd, int level, int optname, char* optval, socklen_t* optlen) argument 298 set_sock_opt(int fd, int level, int optname, const char* optval, socklen_t optlen) argument [all...] |
/openjdk7/hotspot/src/os/solaris/vm/ |
H A D | attachListener_solaris.cpp | 339 // DOOR_RELEASE flag makes sure fd is closed after passing it to 373 int fd, res; local 388 RESTARTABLE(::creat(initial_path, S_IRUSR | S_IWUSR), fd); local 389 if (fd == -1) { 394 assert(fd >= 0, "bad file descriptor"); 395 RESTARTABLE(::close(fd), res);
|
/openjdk7/jdk/make/tools/reorder/tools/ |
H A D | mcount.c | 94 int fd; member in struct:ElfInfo 202 elfInfo->fd = open(fullName, O_RDONLY); 203 if (elfInfo->fd < 0) 205 elf = elf_begin(elfInfo->fd, ELF_C_READ, (Elf *)0);
|
/openjdk7/hotspot/src/share/vm/prims/ |
H A D | jniCheck.cpp | 210 fieldDescriptor fd; local 227 if (!id->find_local_field(&fd)) 229 if ((fd.field_type() != ftype) && 230 !(fd.field_type() == T_ARRAY && ftype == T_OBJECT)) { 238 fieldDescriptor fd; local 263 false, &fd)) 266 if ((fd.field_type() != ftype) && 267 !(fd.field_type() == T_ARRAY && ftype == T_OBJECT)) {
|
/openjdk7/hotspot/src/share/vm/utilities/ |
H A D | ostream.hpp | 222 fdStream(int fd = -1) { _fd = fd; _need_close = false; } 225 void set_fd(int fd) { _fd = fd; _need_close = false; } argument 226 int fd() const { return _fd; } function in class:fdStream
|
/openjdk7/jdk/src/solaris/native/sun/nio/ch/ |
H A D | Net.c | 156 int fd; local 164 fd = socket(domain, type, 0); 165 if (fd < 0) { 173 if (setsockopt(fd, IPPROTO_IPV6, IPV6_V6ONLY, (char*)&arg, 178 close(fd); 186 if (setsockopt(fd, SOL_SOCKET, SO_REUSEADDR, (char*)&arg, 191 close(fd); 199 if (setsockopt(fd, IPPROTO_IPV6, IPV6_MULTICAST_HOPS, &arg, 204 close(fd); 209 return fd; [all...] |
H A D | SctpChannelImpl.c | 195 (JNIEnv* env, int fd, jobject resultContainerObj, struct sctp_send_failed *ssf, 247 if ((rv = recvmsg(fd, msg, 0)) < 0) { 360 (JNIEnv* env, int fd, jobject resultContainerObj, union sctp_notification* snp, 364 handleSendFailed(env, fd, resultContainerObj, &snp->sn_send_failed, 414 (JNIEnv *env, jclass klass, jint fd, jobject resultContainerObj, 438 if ((rv = recvmsg(fd, msg, flags)) < 0) { 468 if ((rv = recvmsg(fd, msg, flags)) < 0) { 476 if (handleNotification(env, fd, resultContainerObj, snp, rv, 504 (JNIEnv *env, jclass klass, jint fd, jlong address, jint length, 554 if ((rv = sendmsg(fd, ms 194 handleSendFailed(JNIEnv* env, int fd, jobject resultContainerObj, struct sctp_send_failed *ssf, int read, jboolean isEOR, struct sockaddr* sap) argument 359 handleNotification(JNIEnv* env, int fd, jobject resultContainerObj, union sctp_notification* snp, int read, jboolean isEOR, struct sockaddr* sap) argument 413 Java_sun_nio_ch_SctpChannelImpl_receive0(JNIEnv *env, jclass klass, jint fd, jobject resultContainerObj, jlong address, jint length, jboolean peek) argument 503 Java_sun_nio_ch_SctpChannelImpl_send0(JNIEnv *env, jclass klass, jint fd, jlong address, jint length, jobject targetAddress, jint targetPort, jint assocId, jint streamNumber, jboolean unordered, jint ppid) argument [all...] |
H A D | SctpNet.c | 51 static int preCloseFD = -1; /* File descriptor to which we dup other fd's 169 int fd; local 182 fd = socket(domain, (oneToOne ? SOCK_STREAM : SOCK_SEQPACKET), IPPROTO_SCTP); 184 if (fd < 0) { 198 if (setsockopt(fd, IPPROTO_SCTP, SCTP_EVENTS, &event, sizeof(event)) != 0) { 201 return fd; 210 (JNIEnv *env, jclass klass, jint fd, jobjectArray addrs, jint port, 235 if (nio_sctp_bindx(fd, (void*)sap, addrsLength, add ? SCTP_BINDX_ADD_ADDR : 250 (JNIEnv *env, jclass cl, jint fd, jint backlog) { 251 if (listen(fd, backlo 209 Java_sun_nio_ch_SctpNet_bindx(JNIEnv *env, jclass klass, jint fd, jobjectArray addrs, jint port, jint addrsLength, jboolean add, jboolean preferIPv6) argument 249 Java_sun_nio_ch_SctpNet_listen0(JNIEnv *env, jclass cl, jint fd, jint backlog) argument 261 Java_sun_nio_ch_SctpNet_connect0(JNIEnv *env, jclass clazz, int fd, jobject iao, jint port) argument 290 Java_sun_nio_ch_SctpNet_close0(JNIEnv *env, jclass clazz, jint fd) argument 305 Java_sun_nio_ch_SctpNet_preClose0(JNIEnv *env, jclass clazz, jint fd) argument 347 Java_sun_nio_ch_SctpNet_getLocalAddresses0(JNIEnv *env, jclass klass, jint fd) argument 398 getRemoteAddresses(JNIEnv *env, jint fd, sctp_assoc_t id) argument 455 Java_sun_nio_ch_SctpNet_getRemoteAddresses0(JNIEnv *env, jclass klass, jint fd, jint assocId) argument 494 Java_sun_nio_ch_SctpNet_setIntOption0(JNIEnv *env, jclass klass, jint fd, jint opt, int arg) argument 534 Java_sun_nio_ch_SctpNet_getIntOption0(JNIEnv *env, jclass klass, jint fd, jint opt) argument 573 Java_sun_nio_ch_SctpNet_getPrimAddrOption0(JNIEnv *env, jclass klass, jint fd, jint assocId) argument 595 Java_sun_nio_ch_SctpNet_setPrimAddrOption0(JNIEnv *env, jclass klass, jint fd, jint assocId, jobject iaObj, jint port) argument 619 Java_sun_nio_ch_SctpNet_setPeerPrimAddrOption0(JNIEnv *env, jclass klass, jint fd, jint assocId, jobject iaObj, jint port, jboolean preferIPv6) argument 645 Java_sun_nio_ch_SctpNet_getInitMsgOption0(JNIEnv *env, jclass klass, jint fd, jintArray retVal) argument 668 Java_sun_nio_ch_SctpNet_setInitMsgOption0(JNIEnv *env, jclass klass, jint fd, jint inArg, jint outArg) argument 689 Java_sun_nio_ch_SctpNet_shutdown0(JNIEnv *env, jclass klass, jint fd, jint assocId) argument 745 Java_sun_nio_ch_SctpNet_branch0(JNIEnv *env, jclass klass, jint fd, jint assocId) argument [all...] |
/openjdk7/jdk/src/windows/classes/sun/nio/ch/ |
H A D | WindowsSelectorImpl.java | 96 Integer fd = new Integer(ski.channel.getFDVal()); 97 MapEntry x = get(fd); 99 return remove(fd); 480 private native boolean discardUrgentData(int fd); argument
|
/openjdk7/jdk/src/windows/demo/jvmti/hprof/ |
H A D | hprof_md.c | 83 int fd; local 86 fd = (int)socket(AF_INET, SOCK_STREAM, 0); 101 if (-1 == connect(fd, (struct sockaddr*)&s, sizeof(s))) { 104 return fd;
|
/openjdk7/jdk/src/windows/native/java/io/ |
H A D | io_util_md.c | 293 /* These are functions that use a handle fd instead of the 294 old C style int fd as is used in HPI layer */ 302 handleAvailable(jlong fd, jlong *pbytes) { argument 303 HANDLE h = (HANDLE)fd; 313 ret = handleStdinAvailable(fd, &lpbytes); /* keyboard */ 315 ret = handleNonSeekAvailable(fd, &lpbytes); /* pipe */ 325 current = handleLseek(fd, 0, SEEK_CUR); 340 handleNonSeekAvailable(jlong fd, long *pbytes) { argument 349 if ((han = (HANDLE) fd) == INVALID_HANDLE_VALUE) { 356 * behavior we get on Solaris when an fd i 369 handleStdinAvailable(jlong fd, long *pbytes) argument 436 handleSync(jlong fd) argument 466 handleSetLength(jlong fd, jlong length) argument 482 handleRead(jlong fd, void *buf, jint len) argument 505 writeInternal(jlong fd, const void *buf, jint len, jboolean append) argument 534 handleWrite(jlong fd, const void *buf, jint len) argument 539 handleAppend(jlong fd, const void *buf, jint len) argument 546 FD fd = GET_FD(this, fid); local 568 handleLseek(jlong fd, jlong offset, jint whence) argument [all...] |
/openjdk7/jdk/src/windows/native/java/net/ |
H A D | TwoStacksPlainSocketImpl.c | 103 psi_fdID = (*env)->GetFieldID(env, cls , "fd", "Ljava/io/FileDescriptor;"); 136 int fd, fd1; local 142 "null fd object"); 145 fd = socket(AF_INET, (stream ? SOCK_STREAM: SOCK_DGRAM), 0); 146 if (fd == -1) { 151 SetHandleInformation((HANDLE)(UINT_PTR)fd, HANDLE_FLAG_INHERIT, FALSE); 152 (*env)->SetIntField(env, fdObj, IO_fd_fdID, (int)fd); 161 NET_SocketClose(fd); 168 NET_SocketClose(fd); 197 jint fd, fd local 404 int fd, fd1, len; local 519 int fd, fd1; local 594 jint fd=-1, fd1=-1; local 779 jint fd; local 806 jint fd=-1, fd1=-1; local 842 int fd, fd1; local 1008 int fd, fd1; local 1123 jint fd; local 1149 int n, fd; local [all...] |
/openjdk7/jdk/src/windows/transport/socket/ |
H A D | socket_md.c | 123 dbgsysListen(int fd, int backlog) { argument 124 return listen(fd, backlog); 128 dbgsysConnect(int fd, struct sockaddr *name, int namelen) { argument 129 int rv = connect(fd, name, namelen); 138 int dbgsysFinishConnect(int fd, long timeout) { argument 148 FD_SET((unsigned int)fd, &wr); 149 FD_SET((unsigned int)fd, &ex); 151 rv = select(fd+1, 0, &wr, &ex, &t); 161 if (!FD_ISSET(fd, &ex)) { 174 dbgsysAccept(int fd, struc argument 179 dbgsysRecvFrom(int fd, char *buf, int nBytes, int flags, struct sockaddr *from, int *fromlen) argument 185 dbgsysSendTo(int fd, char *buf, int len, int flags, struct sockaddr *to, int tolen) argument 191 dbgsysRecv(int fd, char *buf, int nBytes, int flags) argument 196 dbgsysSend(int fd, char *buf, int nBytes, int flags) argument 212 int fd = (int)socket(domain, type, protocol); local 220 dbgsysSocketClose(int fd) argument 235 dbgsysBind(int fd, struct sockaddr *name, int namelen) argument 256 dbgsysGetSocketName(int fd, struct sockaddr *name, int *namelen) argument 273 dbgsysSetSocketOption(int fd, jint cmd, jboolean on, jvalue value) argument 332 dbgsysConfigureBlocking(int fd, jboolean blocking) argument 350 dbgsysPoll(int fd, jboolean rd, jboolean wr, long timeout) argument [all...] |
/openjdk7/jdk/test/java/net/URI/ |
H A D | Test.java | 219 // fd Fragment, decoded 338 Test fd(String s) { method in class:Test 1286 .f("f%04").fd("f\4") 1300 .f("f%25%20\uA004%04%E2%80%80").fd("f% \uA004\4\u2000").z(); 1308 .f("f%25%20\uA004%04%E2%80%80").fd("f% \uA004\4\u2000").z(); 1311 .f("f%25%20\uA004%04%E2%80%80").fd("f% \uA004\4\u2000").z(); 1315 .f("f%25%20\uA004%04%E2%80%80").fd("f% \uA004\4\u2000").z();
|