| /libcore/luni/src/main/java/java/net/ |
| PlainDatagramSocketImpl.java | 25 import libcore.io.IoBridge;
60 IoBridge.bind(fd, address, port);
64 localPort = IoBridge.getSocketLocalPort(fd);
81 IoBridge.closeAndSignalBlockedThreads(fd);
93 this.fd = IoBridge.socket(false);
108 return IoBridge.getSocketOption(fd, option);
113 return (Integer) getOption(IoBridge.JAVA_IP_MULTICAST_TTL);
128 setOption(IoBridge.JAVA_MCAST_JOIN_GROUP, makeGroupReq(addr, null));
135 setOption(IoBridge.JAVA_MCAST_JOIN_GROUP, makeGroupReq(groupAddr, netInterface));
141 setOption(IoBridge.JAVA_MCAST_LEAVE_GROUP, makeGroupReq(addr, null))
[all...] |
| PlainSocketImpl.java | 28 import libcore.io.IoBridge;
107 newImpl.localport = IoBridge.getSocketLocalPort(newImpl.fd);
128 return IoBridge.available(fd);
132 IoBridge.bind(fd, address, port);
136 this.localport = IoBridge.getSocketLocalPort(fd);
148 IoBridge.closeAndSignalBlockedThreads(fd);
183 IoBridge.connect(fd, normalAddr, aPort, timeout);
198 this.fd = IoBridge.socket(streaming);
242 return IoBridge.getSocketOption(fd, option);
286 IoBridge.setSocketOption(fd, option, value)
[all...] |
| InetAddress.java | 37 import libcore.io.IoBridge;
755 FileDescriptor fd = IoBridge.socket(true);
759 IoBridge.bind(fd, source, 0);
761 IoBridge.connect(fd, destination, 7, timeout);
770 IoBridge.closeAndSignalBlockedThreads(fd);
[all...] |
| /libcore/luni/src/main/java/java/io/ |
| FileOutputStream.java | 23 import libcore.io.IoBridge;
87 this.fd = IoBridge.open(file.getPath(), mode);
138 IoBridge.closeAndSignalBlockedThreads(fd);
186 IoBridge.write(fd, buffer, byteOffset, byteCount);
|
| RandomAccessFile.java | 27 import libcore.io.IoBridge;
117 this.fd = IoBridge.open(file.getPath(), flags);
165 IoBridge.closeAndSignalBlockedThreads(fd);
286 return IoBridge.read(fd, buffer, byteOffset, byteCount);
688 IoBridge.write(fd, buffer, byteOffset, byteCount);
|
| /frameworks/base/core/java/android/os/ |
| FileBridge.java | 26 import libcore.io.IoBridge;
97 while (IoBridge.read(mServer, temp, 0, MSG_LENGTH) == MSG_LENGTH) {
103 int n = IoBridge.read(mServer, temp, 0, Math.min(temp.length, len));
108 IoBridge.write(mTarget, temp, 0, n);
115 IoBridge.write(mServer, temp, 0, MSG_LENGTH);
122 IoBridge.write(mServer, temp, 0, MSG_LENGTH);
154 IoBridge.closeAndSignalBlockedThreads(mClient);
165 IoBridge.write(mClient, mTemp, 0, MSG_LENGTH);
168 if (IoBridge.read(mClient, mTemp, 0, MSG_LENGTH) == MSG_LENGTH) {
182 IoBridge.write(mClient, mTemp, 0, MSG_LENGTH)
[all...] |
| /frameworks/base/drm/java/android/drm/ |
| DrmOutputStream.java | 28 import libcore.io.IoBridge;
76 IoBridge.write(mFd, status.convertedData, 0, status.convertedData.length);
106 IoBridge.write(mFd, status.convertedData, 0, status.convertedData.length);
|
| /libcore/luni/src/main/java/libcore/io/ |
| IoBridge.java | 50 public final class IoBridge {
52 private IoBridge() {
110 IoBridge.connect(fd, inetAddress, port, 0);
171 } while (!IoBridge.isConnected(fd, inetAddress, port, timeoutMs, remainingTimeoutMs));
274 case IoBridge.JAVA_IP_MULTICAST_TTL:
343 case IoBridge.JAVA_IP_MULTICAST_TTL:
389 case IoBridge.JAVA_MCAST_JOIN_GROUP:
390 case IoBridge.JAVA_MCAST_LEAVE_GROUP:
398 case IoBridge.JAVA_MCAST_JOIN_SOURCE_GROUP:
399 case IoBridge.JAVA_MCAST_LEAVE_SOURCE_GROUP
[all...] |
| /libcore/luni/src/main/java/java/nio/ |
| DatagramChannelImpl.java | 45 import libcore.io.IoBridge;
83 fd = IoBridge.socket(false);
153 IoBridge.connect(fd, remoteAddress, remotePort);
257 received = IoBridge.recvfrom(false, fd, receivePacket.getData(), receivePacket.getOffset(), receivePacket.getLength(), 0, receivePacket, isConnected());
280 received = IoBridge.recvfrom(false, fd, target, 0, receivePacket, isConnected());
313 sendCount = IoBridge.sendto(fd, source, 0, isa.getAddress(), isa.getPort());
391 readCount = IoBridge.recvfrom(false, fd, dst, 0, null, isConnected());
456 result = IoBridge.sendto(fd, buf, 0, null, 0);
467 IoBridge.closeAndSignalBlockedThreads(fd);
|
| SocketChannelImpl.java | 48 import libcore.io.IoBridge;
105 fd = (connect ? IoBridge.socket(true) : new FileDescriptor());
196 // When in blocking mode, IoBridge.connect() will return without an exception when the
199 IoBridge.connect(fd, normalAddr, port);
277 finished = IoBridge.isConnected(fd, inetAddress, port, 0, 0); // Return immediately.
342 readCount = IoBridge.recvfrom(true, fd, dst, 0, null, false);
406 writeCount = IoBridge.sendto(fd, src, 0, null, 0);
471 // IoBridge.closeAndSignalBlockedThreads(fd) is idempotent: It is safe to call on an
473 IoBridge.closeAndSignalBlockedThreads(fd);
|
