Merge "Prevent LocalSocket from creating an fd if fd is already there"
am: 616910fd53
Change-Id: I90192dd7e656b9bec62815ad628fc4e67f806240
This commit is contained in:
@@ -73,6 +73,7 @@ public class LocalSocket implements Closeable {
|
||||
this(new LocalSocketImpl(fd), SOCKET_UNKNOWN);
|
||||
isBound = true;
|
||||
isConnected = true;
|
||||
implCreated = true;
|
||||
}
|
||||
|
||||
private LocalSocket(LocalSocketImpl impl, int sockType) {
|
||||
@@ -223,11 +224,11 @@ public class LocalSocket implements Closeable {
|
||||
implCreateIfNeeded();
|
||||
impl.shutdownOutput();
|
||||
}
|
||||
|
||||
|
||||
public void setReceiveBufferSize(int size) throws IOException {
|
||||
impl.setOption(SocketOptions.SO_RCVBUF, Integer.valueOf(size));
|
||||
}
|
||||
|
||||
|
||||
public int getReceiveBufferSize() throws IOException {
|
||||
return ((Integer) impl.getOption(SocketOptions.SO_RCVBUF)).intValue();
|
||||
}
|
||||
@@ -235,7 +236,7 @@ public class LocalSocket implements Closeable {
|
||||
public void setSoTimeout(int n) throws IOException {
|
||||
impl.setOption(SocketOptions.SO_TIMEOUT, Integer.valueOf(n));
|
||||
}
|
||||
|
||||
|
||||
public int getSoTimeout() throws IOException {
|
||||
return ((Integer) impl.getOption(SocketOptions.SO_TIMEOUT)).intValue();
|
||||
}
|
||||
@@ -243,7 +244,7 @@ public class LocalSocket implements Closeable {
|
||||
public void setSendBufferSize(int n) throws IOException {
|
||||
impl.setOption(SocketOptions.SO_SNDBUF, Integer.valueOf(n));
|
||||
}
|
||||
|
||||
|
||||
public int getSendBufferSize() throws IOException {
|
||||
return ((Integer) impl.getOption(SocketOptions.SO_SNDBUF)).intValue();
|
||||
}
|
||||
@@ -328,5 +329,5 @@ public class LocalSocket implements Closeable {
|
||||
*/
|
||||
public FileDescriptor getFileDescriptor() {
|
||||
return impl.getFileDescriptor();
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
Reference in New Issue
Block a user