| /libcore/luni/src/main/java/libcore/io/ |
| D | ForwardingOs.java | 38 …riptor accept(FileDescriptor fd, InetSocketAddress peerAddress) throws ErrnoException, SocketExcep… in accept() argument
40 …public void bind(FileDescriptor fd, InetAddress address, int port) throws ErrnoException, SocketEx… in bind() argument
43 public void close(FileDescriptor fd) throws ErrnoException { os.close(fd); } in close() argument
44 …lic void connect(FileDescriptor fd, InetAddress address, int port) throws ErrnoException, SocketEx… in connect() argument
50 public void fchmod(FileDescriptor fd, int mode) throws ErrnoException { os.fchmod(fd, mode); } in fchmod() argument
51 …public void fchown(FileDescriptor fd, int uid, int gid) throws ErrnoException { os.fchown(fd, uid,… in fchown() argument
52 …public int fcntlVoid(FileDescriptor fd, int cmd) throws ErrnoException { return os.fcntlVoid(fd, c… in fcntlVoid() argument
53 …public int fcntlLong(FileDescriptor fd, int cmd, long arg) throws ErrnoException { return os.fcntl… in fcntlLong() argument
54 …public int fcntlFlock(FileDescriptor fd, int cmd, StructFlock arg) throws ErrnoException { return … in fcntlFlock() argument
55 public void fdatasync(FileDescriptor fd) throws ErrnoException { os.fdatasync(fd); } in fdatasync() argument
[all …]
|
| D | BlockGuardOs.java | 36 private FileDescriptor tagSocket(FileDescriptor fd) throws ErrnoException { in tagSocket() argument
38 SocketTagger.get().tag(fd); in tagSocket()
39 return fd; in tagSocket()
45 private void untagSocket(FileDescriptor fd) throws ErrnoException { in untagSocket() argument
47 SocketTagger.get().untag(fd); in untagSocket()
53 …@Override public FileDescriptor accept(FileDescriptor fd, InetSocketAddress peerAddress) throws Er… in accept() argument
55 return tagSocket(os.accept(fd, peerAddress)); in accept()
58 @Override public void close(FileDescriptor fd) throws ErrnoException { in close() argument
60 if (S_ISSOCK(Libcore.os.fstat(fd).st_mode)) { in close()
61 if (isLingerSocket(fd)) { in close()
[all …]
|
| D | Posix.java | 32 …public native FileDescriptor accept(FileDescriptor fd, InetSocketAddress peerAddress) throws Errno… in accept() argument
34 …public native void bind(FileDescriptor fd, InetAddress address, int port) throws ErrnoException, S… in bind() argument
37 public native void close(FileDescriptor fd) throws ErrnoException; in close() argument
38 …public native void connect(FileDescriptor fd, InetAddress address, int port) throws ErrnoException… in connect() argument
44 public native void fchmod(FileDescriptor fd, int mode) throws ErrnoException; in fchmod() argument
45 public native void fchown(FileDescriptor fd, int uid, int gid) throws ErrnoException; in fchown() argument
46 public native int fcntlVoid(FileDescriptor fd, int cmd) throws ErrnoException; in fcntlVoid() argument
47 public native int fcntlLong(FileDescriptor fd, int cmd, long arg) throws ErrnoException; in fcntlLong() argument
48 public native int fcntlFlock(FileDescriptor fd, int cmd, StructFlock arg) throws ErrnoException; in fcntlFlock() argument
49 public native void fdatasync(FileDescriptor fd) throws ErrnoException; in fdatasync() argument
[all …]
|
| D | IoBridge.java | 49 public static int available(FileDescriptor fd) throws IOException { in available() argument
52 Libcore.os.ioctlInt(fd, FIONREAD, available); in available()
73 … public static void bind(FileDescriptor fd, InetAddress address, int port) throws SocketException { in bind() argument
87 Libcore.os.bind(fd, address, port); in bind()
98 …public static boolean connect(FileDescriptor fd, InetAddress inetAddress, int port) throws SocketE… in connect() argument
100 return IoBridge.connect(fd, inetAddress, port, 0); in connect()
110 …public static boolean connect(FileDescriptor fd, InetAddress inetAddress, int port, int timeoutMs)… in connect() argument
112 return connectErrno(fd, inetAddress, port, timeoutMs); in connect()
124 …private static boolean connectErrno(FileDescriptor fd, InetAddress inetAddress, int port, int time… in connectErrno() argument
127 Libcore.os.connect(fd, inetAddress, port); in connectErrno()
[all …]
|
| D | Os.java | 29 …public FileDescriptor accept(FileDescriptor fd, InetSocketAddress peerAddress) throws ErrnoExcepti… in accept() argument
31 …public void bind(FileDescriptor fd, InetAddress address, int port) throws ErrnoException, SocketEx… in bind() argument
34 public void close(FileDescriptor fd) throws ErrnoException; in close() argument
35 …public void connect(FileDescriptor fd, InetAddress address, int port) throws ErrnoException, Socke… in connect() argument
41 public void fchmod(FileDescriptor fd, int mode) throws ErrnoException; in fchmod() argument
42 public void fchown(FileDescriptor fd, int uid, int gid) throws ErrnoException; in fchown() argument
43 public int fcntlVoid(FileDescriptor fd, int cmd) throws ErrnoException; in fcntlVoid() argument
44 public int fcntlLong(FileDescriptor fd, int cmd, long arg) throws ErrnoException; in fcntlLong() argument
45 public int fcntlFlock(FileDescriptor fd, int cmd, StructFlock arg) throws ErrnoException; in fcntlFlock() argument
46 public void fdatasync(FileDescriptor fd) throws ErrnoException; in fdatasync() argument
[all …]
|
| D | IoUtils.java | 36 public static void close(FileDescriptor fd) throws IOException { in close() argument
38 if (fd != null && fd.valid()) { in close()
39 Libcore.os.close(fd); in close()
63 public static void closeQuietly(FileDescriptor fd) { in closeQuietly() argument
65 IoUtils.close(fd); in closeQuietly()
85 public static void setBlocking(FileDescriptor fd, boolean blocking) throws IOException { in setBlocking() argument
87 int flags = Libcore.os.fcntlVoid(fd, F_GETFL); in setBlocking()
93 Libcore.os.fcntlLong(fd, F_SETFL, flags); in setBlocking()
158 FileDescriptor fd = Libcore.os.open(path, O_RDONLY, 0); in canOpenReadOnly() local
159 Libcore.os.close(fd); in canOpenReadOnly()
|
| D | MemoryMappedFile.java | 51 FileDescriptor fd = Libcore.os.open(path, O_RDONLY, 0); in mmapRO() local
52 long size = Libcore.os.fstat(fd).st_size; in mmapRO()
53 long address = Libcore.os.mmap(0L, size, PROT_READ, MAP_SHARED, fd, 0); in mmapRO()
54 Libcore.os.close(fd); in mmapRO()
|
| D | StructPollfd.java | 27 public FileDescriptor fd; field in StructPollfd
46 return "StructPollfd[fd=" + fd + ",events=" + events + ",revents=" + revents + "]"; in toString()
|
| /libcore/include/ |
| D | ScopedFd.h | 27 explicit ScopedFd(int fd) : fd(fd) { in ScopedFd() argument
31 close(fd); in ~ScopedFd()
35 return fd; in get()
39 int fd;
|
| /libcore/luni/src/main/java/java/io/ |
| D | FileInputStream.java | 58 private FileDescriptor fd; field in FileInputStream
78 this.fd = IoBridge.open(file.getAbsolutePath(), O_RDONLY); in FileInputStream()
91 public FileInputStream(FileDescriptor fd) { in FileInputStream() argument
92 if (fd == null) { in FileInputStream()
95 this.fd = fd; in FileInputStream()
110 return IoBridge.available(fd); in available()
121 IoUtils.close(fd); in close()
125 fd = new FileDescriptor(); in close()
161 channel = NioUtils.newFileChannel(this, fd, O_RDONLY); in getChannel()
171 return fd; in getFD()
[all …]
|
| D | FileOutputStream.java | 55 private FileDescriptor fd; field in FileOutputStream
88 this.fd = IoBridge.open(file.getAbsolutePath(), mode); in FileOutputStream()
98 public FileOutputStream(FileDescriptor fd) { in FileOutputStream() argument
99 if (fd == null) { in FileOutputStream()
102 this.fd = fd; in FileOutputStream()
105 this.channel = NioUtils.newFileChannel(this, fd, mode); in FileOutputStream()
139 IoUtils.close(fd); in close()
143 fd = new FileDescriptor(); in close()
172 channel = NioUtils.newFileChannel(this, fd, mode); in getChannel()
182 return fd; in getFD()
[all …]
|
| D | RandomAccessFile.java | 46 private FileDescriptor fd; field in RandomAccessFile
118 this.fd = IoBridge.open(file.getAbsolutePath(), flags); in RandomAccessFile()
123 fd.sync(); in RandomAccessFile()
166 IoUtils.close(fd); in close()
193 channel = NioUtils.newFileChannel(this, fd, mode); in getChannel()
208 return fd; in getFD()
223 return Libcore.os.lseek(fd, 0L, SEEK_CUR); in getFilePointer()
238 return Libcore.os.fstat(fd).st_size; in length()
290 return IoBridge.read(fd, buffer, byteOffset, byteCount); in read()
604 Libcore.os.lseek(fd, offset, SEEK_SET); in seek()
[all …]
|
| D | FileReader.java | 53 public FileReader(FileDescriptor fd) { in FileReader() argument
54 super(new FileInputStream(fd)); in FileReader()
|
| /libcore/luni/src/main/java/java/nio/ |
| D | PipeImpl.java | 61 private final FileDescriptor fd; field in PipeImpl.PipeSourceChannel
64 …private PipeSourceChannel(SelectorProvider selectorProvider, FileDescriptor fd) throws IOException… in PipeSourceChannel() argument
66 this.fd = fd; in PipeSourceChannel()
67 this.channel = new SocketChannelImpl(selectorProvider, fd); in PipeSourceChannel()
91 return fd; in getFD()
96 private final FileDescriptor fd; field in PipeImpl.PipeSinkChannel
99 … private PipeSinkChannel(SelectorProvider selectorProvider, FileDescriptor fd) throws IOException { in PipeSinkChannel() argument
101 this.fd = fd; in PipeSinkChannel()
102 this.channel = new SocketChannelImpl(selectorProvider, fd); in PipeSinkChannel()
126 return fd; in getFD()
|
| D | FileChannelImpl.java | 54 private final FileDescriptor fd; field in FileChannelImpl
64 public FileChannelImpl(Object stream, FileDescriptor fd, int mode) { in FileChannelImpl() argument
65 this.fd = fd; in FileChannelImpl()
121 success = (Libcore.os.fcntlFlock(fd, wait ? F_SETLKW64 : F_SETLK64, flock) != -1); in basicLock()
193 Libcore.os.fcntlFlock(fd, F_SETLKW64, flock); in release()
206 Libcore.os.fsync(fd); in force()
208 Libcore.os.fdatasync(fd); in force()
236 Libcore.os.ftruncate(fd, position + size); in map()
249 MemoryBlock block = MemoryBlock.mmap(fd, alignment, size + offset, mapMode); in map()
256 return Libcore.os.lseek(fd, 0L, SEEK_CUR); in position()
[all …]
|
| /libcore/luni/src/main/java/libcore/net/ |
| D | RawSocket.java | 45 private static native void create(FileDescriptor fd, short in create() argument
48 private static native int sendPacket(FileDescriptor fd, in sendPacket() argument
51 private static native int recvPacket(FileDescriptor fd, byte[] packet, in recvPacket() argument
54 private final FileDescriptor fd; field in RawSocket
66 fd = new FileDescriptor(); in RawSocket()
67 create(fd, mProtocolType, mInterfaceName); in RawSocket()
93 return recvPacket(fd, packet, offset, byteCount, destPort, in read()
119 return sendPacket(fd, mInterfaceName, mProtocolType, destMac, packet, in write()
129 IoBridge.closeSocket(fd); in close()
|
| /libcore/luni/src/main/java/java/net/ |
| D | PlainSocketImpl.java | 62 public PlainSocketImpl(FileDescriptor fd) { in PlainSocketImpl() argument
63 this.fd = fd; in PlainSocketImpl()
64 if (fd.valid()) { in PlainSocketImpl()
78 public PlainSocketImpl(FileDescriptor fd, int localport, InetAddress addr, int port) { in PlainSocketImpl() argument
79 this.fd = fd; in PlainSocketImpl()
83 if (fd.valid()) { in PlainSocketImpl()
98 FileDescriptor clientFd = Libcore.os.accept(fd, peerAddress); in accept()
102 newImpl.fd.setInt$(clientFd.getInt$()); in accept()
116 newImpl.localport = IoBridge.getSocketLocalPort(newImpl.fd); in accept()
133 if (!fd.valid()) { in checkNotClosed()
[all …]
|
| D | PlainDatagramSocketImpl.java | 55 public PlainDatagramSocketImpl(FileDescriptor fd, int localPort) { in PlainDatagramSocketImpl() argument
56 this.fd = fd; in PlainDatagramSocketImpl()
58 if (fd.valid()) { in PlainDatagramSocketImpl()
64 fd = new FileDescriptor(); in PlainDatagramSocketImpl()
68 IoBridge.bind(fd, address, port); in bind()
72 localPort = IoBridge.getSocketLocalPort(fd); in bind()
84 IoBridge.closeSocket(fd); in close()
91 this.fd = IoBridge.socket(false); in create()
106 return IoBridge.getSocketOption(fd, option); in getOption()
161 …IoBridge.recvfrom(false, fd, pack.getData(), pack.getOffset(), pack.getLength(), flags, pack, isNa… in doRecv()
[all …]
|
| /libcore/luni/src/main/native/ |
| D | libcore_net_RawSocket.cpp | 102 NetFd fd(env, fileDescriptor); in RawSocket_sendPacket() local
104 if (fd.isClosed()) { in RawSocket_sendPacket()
134 int intFd = fd.get(); in RawSocket_sendPacket()
136 err = NET_FAILURE_RETRY(fd, sendto(intFd, byteArray.get() + offset, in RawSocket_sendPacket()
154 NetFd fd(env, fileDescriptor); in RawSocket_recvPacket() local
155 if (fd.isClosed()) { in RawSocket_recvPacket()
168 fds[0].fd = fd.get(); in RawSocket_recvPacket()
178 int intFd = fd.get(); in RawSocket_recvPacket()
180 size = NET_FAILURE_RETRY(fd, read(intFd, packetData, packetSize)); in RawSocket_recvPacket()
|
| D | java_lang_ProcessManager.cpp | 41 for (int fd = 3; fd < max_fd; ++fd) { in closeNonStandardFds() local
42 if (fd != skipFd1 && fd != skipFd2) { in closeNonStandardFds()
43 close(fd); in closeNonStandardFds()
53 int fd = pipes[i]; in closePipes() local
54 if (fd == -1) { in closePipes()
57 if (fd != skipFd) { in closePipes()
|
| D | libcore_io_Posix.cpp | 342 int fd = jniGetFDFromFileDescriptor(env, javaFd); in doGetSockName() local
347 int rc = is_sockname ? TEMP_FAILURE_RETRY(getsockname(fd, sa, &byteCount)) in doGetSockName()
348 : TEMP_FAILURE_RETRY(getpeername(fd, sa, &byteCount)); in doGetSockName()
453 int fd = jniGetFDFromFileDescriptor(env, javaFd); in Posix_close() local
459 throwIfMinusOne(env, "close", close(fd)); in Posix_close()
481 int fd = throwIfMinusOne(env, "dup2", TEMP_FAILURE_RETRY(dup2(oldFd, newFd))); in Posix_dup2() local
482 return (fd != -1) ? jniCreateFileDescriptor(env, fd) : NULL; in Posix_dup2()
519 int fd = jniGetFDFromFileDescriptor(env, javaFd); in Posix_fchmod() local
520 throwIfMinusOne(env, "fchmod", TEMP_FAILURE_RETRY(fchmod(fd, mode))); in Posix_fchmod()
524 int fd = jniGetFDFromFileDescriptor(env, javaFd); in Posix_fchown() local
[all …]
|
| D | AsynchronousSocketCloseMonitor.cpp | 64 void AsynchronousSocketCloseMonitor::signalBlockedThreads(int fd) { in signalBlockedThreads() argument
67 if (it->mFd == fd) { in signalBlockedThreads()
74 AsynchronousSocketCloseMonitor::AsynchronousSocketCloseMonitor(int fd) { in AsynchronousSocketCloseMonitor() argument
78 mFd = fd; in AsynchronousSocketCloseMonitor()
|
| D | AsynchronousSocketCloseMonitor.h | 42 AsynchronousSocketCloseMonitor(int fd);
47 static void signalBlockedThreads(int fd);
|
| /libcore/luni/src/main/java/java/lang/ |
| D | ProcessManager.java | 345 private FileDescriptor fd; field in ProcessManager.ProcessInputStream
347 private ProcessInputStream(FileDescriptor fd) { in ProcessInputStream() argument
348 super(fd); in ProcessInputStream()
349 this.fd = fd; in ProcessInputStream()
359 IoUtils.close(fd); in close()
361 fd = null; in close()
371 private FileDescriptor fd; field in ProcessManager.ProcessOutputStream
373 private ProcessOutputStream(FileDescriptor fd) { in ProcessOutputStream() argument
374 super(fd); in ProcessOutputStream()
375 this.fd = fd; in ProcessOutputStream()
[all …]
|
| /libcore/dalvik/src/main/java/dalvik/system/ |
| D | VMDebug.java | 183 FileDescriptor fd, int bufferSize, int flags) in startMethodTracing() argument
188 if (fd == null) { in startMethodTracing()
192 startMethodTracingNative(traceFileName, fd, bufferSize, flags); in startMethodTracing()
208 FileDescriptor fd, int bufferSize, int flags); in startMethodTracingNative() argument
324 public static native void dumpHprofData(String fileName, FileDescriptor fd) in dumpHprofData() argument
|