/libcore/ojluni/src/main/java/sun/nio/ch/ |
D | FileDispatcherImpl.java | 50 int read(FileDescriptor fd, long address, int len) throws IOException { in read() argument 53 return read0(fd, address, len); in read() 56 int pread(FileDescriptor fd, long address, int len, long position) in pread() argument 61 return pread0(fd, address, len, position); in pread() 64 long readv(FileDescriptor fd, long address, int len) throws IOException { in readv() argument 67 return readv0(fd, address, len); in readv() 70 int write(FileDescriptor fd, long address, int len) throws IOException { in write() argument 73 return write0(fd, address, len); in write() 76 int pwrite(FileDescriptor fd, long address, int len, long position) in pwrite() argument 81 return pwrite0(fd, address, len, position); in pwrite() [all …]
|
D | DatagramDispatcher.java | 40 int read(FileDescriptor fd, long address, int len) throws IOException { in read() argument 42 return read0(fd, address, len); in read() 45 long readv(FileDescriptor fd, long address, int len) throws IOException { in readv() argument 47 return readv0(fd, address, len); in readv() 50 int write(FileDescriptor fd, long address, int len) throws IOException { in write() argument 52 return write0(fd, address, len); in write() 55 long writev(FileDescriptor fd, long address, int len) throws IOException { in writev() argument 57 return writev0(fd, address, len); in writev() 60 void close(FileDescriptor fd) throws IOException { in close() argument 61 FileDispatcherImpl.close0(fd); in close() [all …]
|
D | Net.java | 280 static void setSocketOption(FileDescriptor fd, ProtocolFamily family, 295 ExtendedOptionsImpl.setFlowOption(fd, (SocketFlow)value); 343 setIntOption0(fd, mayNeedConversion, key.level(), key.name(), arg, isIPv6); 346 static Object getSocketOption(FileDescriptor fd, ProtocolFamily family, 358 ExtendedOptionsImpl.getFlowOption(fd, flow); 372 int value = getIntOption0(fd, mayNeedConversion, key.level(), key.name()); 431 public static void bind(FileDescriptor fd, InetAddress addr, int port) 434 bind(UNSPEC, fd, addr, port); 437 static void bind(ProtocolFamily family, FileDescriptor fd, 442 bind0(fd, preferIPv6, exclusiveBind, addr, port); [all …]
|
D | SocketDispatcher.java | 40 int read(FileDescriptor fd, long address, int len) throws IOException { in read() argument 43 return FileDispatcherImpl.read0(fd, address, len); in read() 46 long readv(FileDescriptor fd, long address, int len) throws IOException { in readv() argument 49 return FileDispatcherImpl.readv0(fd, address, len); in readv() 52 int write(FileDescriptor fd, long address, int len) throws IOException { in write() argument 55 return FileDispatcherImpl.write0(fd, address, len); in write() 58 long writev(FileDescriptor fd, long address, int len) throws IOException { in writev() argument 61 return FileDispatcherImpl.writev0(fd, address, len); in writev() 64 void close(FileDescriptor fd) throws IOException { in close() argument 65 FileDispatcherImpl.close0(fd); in close() [all …]
|
D | NativeDispatcher.java | 38 abstract int read(FileDescriptor fd, long address, int len) in read() argument 49 int pread(FileDescriptor fd, long address, int len, long position) in pread() argument 55 abstract long readv(FileDescriptor fd, long address, int len) in readv() argument 58 abstract int write(FileDescriptor fd, long address, int len) in write() argument 61 int pwrite(FileDescriptor fd, long address, int len, long position) in pwrite() argument 67 abstract long writev(FileDescriptor fd, long address, int len) in writev() argument 70 abstract void close(FileDescriptor fd) throws IOException; in close() argument 76 void preClose(FileDescriptor fd) throws IOException { in preClose() argument
|
D | IOUtil.java | 46 static int write(FileDescriptor fd, ByteBuffer src, long position, in write() argument 51 return writeFromNativeBuffer(fd, src, position, nd); in write() 65 int n = writeFromNativeBuffer(fd, bb, position, nd); in write() 76 private static int writeFromNativeBuffer(FileDescriptor fd, ByteBuffer bb, in writeFromNativeBuffer() argument 89 written = nd.pwrite(fd, in writeFromNativeBuffer() 93 written = nd.write(fd, ((DirectBuffer)bb).address() + pos, rem); in writeFromNativeBuffer() 100 static long write(FileDescriptor fd, ByteBuffer[] bufs, NativeDispatcher nd) in write() argument 103 return write(fd, bufs, 0, bufs.length, nd); in write() 106 static long write(FileDescriptor fd, ByteBuffer[] bufs, int offset, int length, in write() argument 148 long bytesWritten = nd.writev(fd, vec.address, iov_len); in write() [all …]
|
D | SocketChannelImpl.java | 74 private final FileDescriptor fd; field in SocketChannelImpl 130 this.fd = Net.socket(true); in SocketChannelImpl() 131 this.fdVal = IOUtil.fdVal(fd); in SocketChannelImpl() 136 if (fd != null && fd.valid()) { in SocketChannelImpl() 142 FileDescriptor fd, in SocketChannelImpl() argument 147 this.fd = fd; in SocketChannelImpl() 148 this.fdVal = IOUtil.fdVal(fd); in SocketChannelImpl() 152 if (fd != null && fd.valid()) { in SocketChannelImpl() 157 this.localAddress = Net.localAddress(fd); in SocketChannelImpl() 163 FileDescriptor fd, InetSocketAddress remote) in SocketChannelImpl() argument [all …]
|
D | Port.java | 64 final void register(int fd, PollableChannel ch) { in register() argument 69 fdToChannel.put(Integer.valueOf(fd), ch); in register() 79 protected void preUnregister(int fd) { in preUnregister() argument 86 final void unregister(int fd) { in unregister() argument 89 preUnregister(fd); in unregister() 93 fdToChannel.remove(Integer.valueOf(fd)); in unregister() 114 abstract void startPoll(int fd, int events); in startPoll() argument 127 final Object attachForeignChannel(final Channel channel, FileDescriptor fd) { in attachForeignChannel() argument 128 int fdVal = IOUtil.fdVal(fd); in attachForeignChannel() 157 for (Integer fd: fdToChannel.keySet()) { in closeAllChannels() [all …]
|
D | DatagramChannelImpl.java | 78 final FileDescriptor fd; field in DatagramChannelImpl 145 this.fd = Net.socket(family, false); in DatagramChannelImpl() 146 this.fdVal = IOUtil.fdVal(fd); in DatagramChannelImpl() 150 if (fd != null && fd.valid()) { in DatagramChannelImpl() 177 this.fd = Net.socket(family, false); in DatagramChannelImpl() 178 this.fdVal = IOUtil.fdVal(fd); in DatagramChannelImpl() 182 if (fd != null && fd.valid()) { in DatagramChannelImpl() 187 public DatagramChannelImpl(SelectorProvider sp, FileDescriptor fd) in DatagramChannelImpl() argument 193 this.fd = fd; in DatagramChannelImpl() 194 this.fdVal = IOUtil.fdVal(fd); in DatagramChannelImpl() [all …]
|
/libcore/luni/src/main/java/libcore/io/ |
D | ForwardingOs.java | 57 …scriptor accept(FileDescriptor fd, SocketAddress peerAddress) throws ErrnoException, SocketExcepti… in accept() argument 60 …public void bind(FileDescriptor fd, InetAddress address, int port) throws ErrnoException, SocketEx… in bind() argument 61 …public void bind(FileDescriptor fd, SocketAddress address) throws ErrnoException, SocketException … in bind() argument 72 public void close(FileDescriptor fd) throws ErrnoException { os.close(fd); } in close() argument 73 …lic void connect(FileDescriptor fd, InetAddress address, int port) throws ErrnoException, SocketEx… in connect() argument 74 …public void connect(FileDescriptor fd, SocketAddress address) throws ErrnoException, SocketExcepti… in connect() argument 80 public void fchmod(FileDescriptor fd, int mode) throws ErrnoException { os.fchmod(fd, mode); } in fchmod() argument 81 …public void fchown(FileDescriptor fd, int uid, int gid) throws ErrnoException { os.fchown(fd, uid,… in fchown() argument 82 …fcntlFlock(FileDescriptor fd, int cmd, StructFlock arg) throws ErrnoException, InterruptedIOExcept… in fcntlFlock() argument 83 …public int fcntlInt(FileDescriptor fd, int cmd, int arg) throws ErrnoException { return os.fcntlIn… in fcntlInt() argument [all …]
|
D | Linux.java | 51 …public native FileDescriptor accept(FileDescriptor fd, SocketAddress peerAddress) throws ErrnoExce… in accept() argument 54 …public native void bind(FileDescriptor fd, InetAddress address, int port) throws ErrnoException, S… in bind() argument 55 …public native void bind(FileDescriptor fd, SocketAddress address) throws ErrnoException, SocketExc… in bind() argument 63 public native void close(FileDescriptor fd) throws ErrnoException; in close() argument 64 …public native void connect(FileDescriptor fd, InetAddress address, int port) throws ErrnoException… in connect() argument 65 …public native void connect(FileDescriptor fd, SocketAddress address) throws ErrnoException, Socket… in connect() argument 71 public native void fchmod(FileDescriptor fd, int mode) throws ErrnoException; in fchmod() argument 72 public native void fchown(FileDescriptor fd, int uid, int gid) throws ErrnoException; in fchown() argument 73 …public native int fcntlFlock(FileDescriptor fd, int cmd, StructFlock arg) throws ErrnoException, I… in fcntlFlock() argument 74 public native int fcntlInt(FileDescriptor fd, int cmd, int arg) throws ErrnoException; in fcntlInt() argument [all …]
|
D | IoBridge.java | 57 public static int available(FileDescriptor fd) throws IOException { in available() argument 60 Libcore.os.ioctlInt(fd, FIONREAD, available); in available() 81 … public static void bind(FileDescriptor fd, InetAddress address, int port) throws SocketException { in bind() argument 99 Libcore.os.bind(fd, address, port); in bind() 115 …public static void connect(FileDescriptor fd, InetAddress inetAddress, int port) throws SocketExce… in connect() argument 117 IoBridge.connect(fd, inetAddress, port, 0); in connect() 127 …public static void connect(FileDescriptor fd, InetAddress inetAddress, int port, int timeoutMs) th… in connect() argument 129 connectErrno(fd, inetAddress, port, timeoutMs); in connect() 137 throw new ConnectException(createMessageForException(fd, inetAddress, port, timeoutMs, in connect() 148 …private static void connectErrno(FileDescriptor fd, InetAddress inetAddress, int port, int timeout… in connectErrno() argument [all …]
|
D | Os.java | 48 …public FileDescriptor accept(FileDescriptor fd, SocketAddress peerAddress) throws ErrnoException, … in accept() argument 51 …public void bind(FileDescriptor fd, InetAddress address, int port) throws ErrnoException, SocketEx… in bind() argument 52 … public void bind(FileDescriptor fd, SocketAddress address) throws ErrnoException, SocketException; in bind() argument 57 public void close(FileDescriptor fd) throws ErrnoException; in close() argument 58 …public void connect(FileDescriptor fd, InetAddress address, int port) throws ErrnoException, Socke… in connect() argument 59 …public void connect(FileDescriptor fd, SocketAddress address) throws ErrnoException, SocketExcepti… in connect() argument 65 public void fchmod(FileDescriptor fd, int mode) throws ErrnoException; in fchmod() argument 66 public void fchown(FileDescriptor fd, int uid, int gid) throws ErrnoException; in fchown() argument 67 …public int fcntlFlock(FileDescriptor fd, int cmd, StructFlock arg) throws ErrnoException, Interrup… in fcntlFlock() argument 68 public int fcntlInt(FileDescriptor fd, int cmd, int arg) throws ErrnoException; in fcntlInt() argument [all …]
|
D | BlockGuardOs.java | 48 private FileDescriptor tagSocket(FileDescriptor fd) throws ErrnoException { in tagSocket() argument 50 SocketTagger.get().tag(fd); in tagSocket() 51 return fd; in tagSocket() 57 …@Override public FileDescriptor accept(FileDescriptor fd, SocketAddress peerAddress) throws ErrnoE… in accept() argument 59 final FileDescriptor acceptFd = os.accept(fd, peerAddress); in accept() 81 @Override public void close(FileDescriptor fd) throws ErrnoException { in close() argument 86 if (fd.isSocket$()) { in close() 87 if (isLingerSocket(fd)) { in close() 100 os.close(fd); in close() 103 private static boolean isInetSocket(FileDescriptor fd) throws ErrnoException{ in isInetSocket() argument [all …]
|
D | IoUtils.java | 40 public static void close(FileDescriptor fd) throws IOException { in close() argument 42 if (fd != null && fd.valid()) { in close() 43 Libcore.os.close(fd); in close() 67 public static void closeQuietly(FileDescriptor fd) { in closeQuietly() argument 69 IoUtils.close(fd); in closeQuietly() 89 public static void setBlocking(FileDescriptor fd, boolean blocking) throws IOException { in setBlocking() argument 91 int flags = Libcore.os.fcntlVoid(fd, F_GETFL); in setBlocking() 97 Libcore.os.fcntlInt(fd, F_SETFL, flags); in setBlocking() 163 FileDescriptor fd = Libcore.os.open(path, O_RDONLY, 0); in canOpenReadOnly() local 164 Libcore.os.close(fd); in canOpenReadOnly() [all …]
|
/libcore/luni/src/main/java/android/system/ |
D | Os.java | 41 …or accept(FileDescriptor fd, InetSocketAddress peerAddress) throws ErrnoException, SocketException… in accept() argument 47 …ptor accept(FileDescriptor fd, SocketAddress peerAddress) throws ErrnoException, SocketException {… in accept() argument 59 …tic void bind(FileDescriptor fd, InetAddress address, int port) throws ErrnoException, SocketExcep… in bind() argument 61 … static void bind(FileDescriptor fd, SocketAddress address) throws ErrnoException, SocketException… in bind() argument 95 public static void close(FileDescriptor fd) throws ErrnoException { Libcore.os.close(fd); } in close() argument 100 …void connect(FileDescriptor fd, InetAddress address, int port) throws ErrnoException, SocketExcept… in connect() argument 102 …tic void connect(FileDescriptor fd, SocketAddress address) throws ErrnoException, SocketException … in connect() argument 132 …public static void fchmod(FileDescriptor fd, int mode) throws ErrnoException { Libcore.os.fchmod(f… in fchmod() argument 137 …public static void fchown(FileDescriptor fd, int uid, int gid) throws ErrnoException { Libcore.os.… in fchown() argument 139 …lFlock(FileDescriptor fd, int cmd, StructFlock arg) throws ErrnoException, InterruptedIOException … in fcntlFlock() argument [all …]
|
/libcore/ojluni/src/main/java/java/net/ |
D | PlainSocketImpl.java | 81 PlainSocketImpl(FileDescriptor fd) { in PlainSocketImpl() argument 82 this.fd = fd; in PlainSocketImpl() 124 fd.setInt$(IoBridge.socket(AF_INET6, isStream ? SOCK_STREAM : SOCK_DGRAM, 0).getInt$()); in socketCreate() 127 IoUtils.setBlocking(fd, false); in socketCreate() 128 IoBridge.setSocketOption(fd, SO_REUSEADDR, true); in socketCreate() 133 if (fd == null || !fd.valid()) { in socketConnect() 137 IoBridge.connect(fd, address, port, timeout); in socketConnect() 147 localport = IoBridge.getLocalInetSocketAddress(fd).getPort(); in socketConnect() 153 if (fd == null || !fd.valid()) { in socketBind() 157 IoBridge.bind(fd, address, port); in socketBind() [all …]
|
D | PlainDatagramSocketImpl.java | 104 IoBridge.bind(fd, laddr, lport); in bind0() 109 localPort = IoBridge.getLocalInetSocketAddress(fd).getPort(); in bind0() 125 IoBridge.sendto(fd, p.getData(), p.getOffset(), p.getLength(), 0, address, port); in send() 150 IoBridge.poll(fd, POLLIN | POLLERR, timeout); in doRecv() 153 IoBridge.recvfrom(false, fd, p.getData(), p.getOffset(), p.bufLength, flags, p, in doRecv() 158 IoBridge.setSocketOption(fd, JAVA_IP_MULTICAST_TTL, ttl); in setTimeToLive() 162 return (Integer) IoBridge.getSocketOption(fd, JAVA_IP_MULTICAST_TTL); in getTimeToLive() 184 IoBridge.setSocketOption(fd, JAVA_MCAST_JOIN_GROUP, makeGroupReq(inetaddr, netIf)); in join() 193 IoBridge.setSocketOption(fd, JAVA_MCAST_LEAVE_GROUP, makeGroupReq(inetaddr, netIf)); in leave() 197 fd = IoBridge.socket(AF_INET6, SOCK_DGRAM, 0); in datagramSocketCreate() [all …]
|
D | AbstractPlainSocketImpl.java | 136 if (fd != null && fd.valid()) { in create() 382 NetHooks.beforeTcpConnect(fd, address, port); in doConnect() 424 NetHooks.beforeTcpBind(fd, address, lport); in bind() 491 void setFileDescriptor(FileDescriptor fd) { in setFileDescriptor() argument 492 this.fd = fd; in setFileDescriptor() 554 if (fd != null && fd.valid()) { in close() 602 if (fd != null && fd.valid()) { in reset() 618 if (fd != null && fd.valid()) { in shutdownInput() 632 if (fd != null && fd.valid()) { in shutdownOutput() 644 if (fd == null || !fd.valid()) { in sendUrgentData() [all …]
|
/libcore/ojluni/src/main/native/ |
D | io_util_md.c | 67 FD fd; in handleOpen() local 68 RESTARTABLE(open64(path, oflag, mode), fd); in handleOpen() 69 if (fd != -1) { in handleOpen() 72 RESTARTABLE(fstat64(fd, &buf64), result); in handleOpen() 75 close(fd); in handleOpen() 77 fd = -1; in handleOpen() 80 close(fd); in handleOpen() 81 fd = -1; in handleOpen() 84 return fd; in handleOpen() 92 FD fd; in fileOpen() local [all …]
|
D | FileDispatcherImpl.c | 67 jint fd = fdval(env, fdo); in FileDispatcherImpl_read0() local 70 return convertReturnVal(env, read(fd, buf, len), JNI_TRUE); in FileDispatcherImpl_read0() 77 jint fd = fdval(env, fdo); in FileDispatcherImpl_pread0() local 80 return convertReturnVal(env, pread64(fd, buf, len, offset), JNI_TRUE); in FileDispatcherImpl_pread0() 87 jint fd = fdval(env, fdo); in FileDispatcherImpl_readv0() local 89 return convertLongReturnVal(env, readv(fd, iov, len), JNI_TRUE); in FileDispatcherImpl_readv0() 96 jint fd = fdval(env, fdo); in FileDispatcherImpl_write0() local 99 return convertReturnVal(env, write(fd, buf, len), JNI_FALSE); in FileDispatcherImpl_write0() 106 jint fd = fdval(env, fdo); in FileDispatcherImpl_pwrite0() local 109 return convertReturnVal(env, pwrite64(fd, buf, len, offset), JNI_FALSE); in FileDispatcherImpl_pwrite0() [all …]
|
D | FileSystemPreferences.c | 70 int fd, rc; in Java_java_util_prefs_FileSystemPreferences_lockFile0() local 86 fd = open(fname, O_RDONLY, 0); in Java_java_util_prefs_FileSystemPreferences_lockFile0() 89 fd = open(fname, O_WRONLY|O_CREAT, permission); in Java_java_util_prefs_FileSystemPreferences_lockFile0() 94 if (fd < 0) { in Java_java_util_prefs_FileSystemPreferences_lockFile0() 98 rc = fcntl(fd, F_SETLK, &fl); in Java_java_util_prefs_FileSystemPreferences_lockFile0() 100 rc = fcntl(fd, F_SETLK64, &fl); in Java_java_util_prefs_FileSystemPreferences_lockFile0() 105 close(fd); in Java_java_util_prefs_FileSystemPreferences_lockFile0() 107 result[0] = fd; in Java_java_util_prefs_FileSystemPreferences_lockFile0() 122 jclass thisclass, jint fd) { in Java_java_util_prefs_FileSystemPreferences_unlockFile0() argument 132 rc = fcntl(fd, F_SETLK, &fl); in Java_java_util_prefs_FileSystemPreferences_unlockFile0() [all …]
|
D | io_util.c | 43 FD fd = GET_FD(this, fid); in readSingle() local 44 if (fd == -1) { in readSingle() 48 nread = (jint)IO_Read(fd, &ret, 1); in readSingle() 83 FD fd; in readBytes() local 107 fd = GET_FD(this, fid); in readBytes() 108 if (fd == -1) { in readBytes() 112 nread = (jint)IO_Read(fd, buf, len); in readBytes() 135 FD fd = GET_FD(this, fid); in writeSingle() local 136 if (fd == -1) { in writeSingle() 141 n = (jint)IO_Append(fd, &c, 1); in writeSingle() [all …]
|
/libcore/luni/src/test/java/libcore/java/util/zip/ |
D | ZipFileTest.java | 48 FileDescriptor fd = new FileDescriptor(); in testZipFileOffsetNeverChangesAfterInit() local 49 fd.setInt$(zipFile.getFileDescriptor()); in testZipFileOffsetNeverChangesAfterInit() 51 long initialOffset = android.system.Os.lseek(fd, 0, OsConstants.SEEK_CUR); in testZipFileOffsetNeverChangesAfterInit() 54 assertOffset(initialOffset, fd); in testZipFileOffsetNeverChangesAfterInit() 60 assertOffset(initialOffset, fd); in testZipFileOffsetNeverChangesAfterInit() 63 assertOffset(initialOffset, fd); in testZipFileOffsetNeverChangesAfterInit() 65 assertOffset(initialOffset, fd); in testZipFileOffsetNeverChangesAfterInit() 69 assertOffset(initialOffset, fd); in testZipFileOffsetNeverChangesAfterInit() 74 private static void assertOffset(long initialOffset, FileDescriptor fd) throws Exception { in assertOffset() argument 75 long currentOffset = android.system.Os.lseek(fd, 0, OsConstants.SEEK_CUR); in assertOffset()
|
/libcore/harmony-tests/src/test/java/org/apache/harmony/tests/java/io/ |
D | FileDescriptorTest.java | 43 FileDescriptor fd = fos.getFD(); in test_sync() local 44 fd.sync(); in test_sync() 50 fd = fis.getFD(); in test_sync() 51 fd.sync(); in test_sync() 55 fd = raf.getFD(); in test_sync() 56 fd.sync(); in test_sync() 79 FileDescriptor fd = fos.getFD(); in test_valid() local 80 assertTrue(fd.valid()); in test_valid() 82 assertFalse(fd.valid()); in test_valid()
|