public class LocalDatagramSocket
extends java.lang.Object
Modifier and Type | Field and Description |
---|---|
protected LocalSocketService |
socketService |
protected java.util.concurrent.atomic.AtomicLong |
streamReceiveOffset |
protected java.util.concurrent.atomic.AtomicLong |
streamSendOffset |
Modifier and Type | Method and Description |
---|---|
AcceptReply |
accept(AcceptRequest request) |
protected byte[] |
addrAsBytes(java.net.InetAddress address) |
BindReply |
bind(BindRequest request) |
java.io.IOException |
close()
Closes a socket but returns thrown exceptions.
|
CloseReply |
close(CloseRequest request) |
ConnectReply |
connect(ConnectRequest request) |
CreateSocketReply |
createSocket(CreateSocketRequest request) |
GetPeerNameReply |
getPeerName(GetPeerNameRequest request) |
java.lang.String |
getSocketDescriptor()
Returns the socket descriptor.
|
GetSocketNameReply |
getSocketName(GetSocketNameRequest request) |
GetSocketOptionsReply |
getSocketOptions(GetSocketOptionsRequest request) |
ListenReply |
listen(ListenRequest request) |
protected com.google.apphosting.api.ApiProxy.ApplicationException |
newAppException(ErrorCode code,
java.lang.String message) |
protected com.google.apphosting.api.ApiProxy.ApplicationException |
newAppExceptionAndClose(ErrorCode code,
java.lang.String message) |
protected com.google.apphosting.api.ApiProxy.ApplicationException |
newNotImplementedException(java.lang.String method) |
ReceiveReply |
receive(ReceiveRequest request) |
SendReply |
send(SendRequest request) |
SetSocketOptionsReply |
setSocketOptions(SetSocketOptionsRequest request) |
ShutDownReply |
shutDown(ShutDownRequest request) |
protected final java.util.concurrent.atomic.AtomicLong streamReceiveOffset
protected final java.util.concurrent.atomic.AtomicLong streamSendOffset
protected final LocalSocketService socketService
public java.io.IOException close()
public BindReply bind(BindRequest request)
public GetSocketNameReply getSocketName(GetSocketNameRequest request)
public GetPeerNameReply getPeerName(GetPeerNameRequest request)
public ConnectReply connect(ConnectRequest request)
public ListenReply listen(ListenRequest request)
public AcceptReply accept(AcceptRequest request)
public ShutDownReply shutDown(ShutDownRequest request)
public CloseReply close(CloseRequest request)
public SendReply send(SendRequest request)
public ReceiveReply receive(ReceiveRequest request)
public CreateSocketReply createSocket(CreateSocketRequest request)
public java.lang.String getSocketDescriptor()
public SetSocketOptionsReply setSocketOptions(SetSocketOptionsRequest request)
public GetSocketOptionsReply getSocketOptions(GetSocketOptionsRequest request)
protected byte[] addrAsBytes(java.net.InetAddress address)
protected com.google.apphosting.api.ApiProxy.ApplicationException newAppException(ErrorCode code, java.lang.String message)
protected com.google.apphosting.api.ApiProxy.ApplicationException newAppExceptionAndClose(ErrorCode code, java.lang.String message)
protected com.google.apphosting.api.ApiProxy.ApplicationException newNotImplementedException(java.lang.String method)