/// </summary>
public void Listen()
{
- lock(s_lock)
+ lock (s_lock)
{
if (s_portMap.Contains(_portName))
{
throw new InvalidOperationException(_portName + " is already used");
}
- _messageCallBack = (int localPortId, string remoteAppId, string remotePortName, bool trusted, IntPtr message, IntPtr userData) => {
- MessageReceivedEventArgs args = new MessageReceivedEventArgs() {
+ _messageCallBack = (int localPortId, string remoteAppId, string remotePortName, bool trusted, IntPtr message, IntPtr userData) =>
+ {
+ MessageReceivedEventArgs args = new MessageReceivedEventArgs()
+ {
Message = new Bundle(message)
};
if (!String.IsNullOrEmpty(remotePortName) && !String.IsNullOrEmpty(remoteAppId))
{
- args.Remote = new RemoteValues() {
+ args.Remote = new RemoteValues()
+ {
AppId = remoteAppId,
PortName = remotePortName,
Trusted = trusted
MessagePortErrorFactory.ThrowException(ret);
}
- lock(s_lock)
+ lock (s_lock)
{
s_portMap.Remove(_portName);
}
if (ret != (int)MessagePortError.None)
{
- if (ret== (int)MessagePortError.MaxExceeded)
+ if (ret == (int)MessagePortError.MaxExceeded)
{
MessagePortErrorFactory.ThrowException(ret, "Message has exceeded the maximum limit(4KB)", "Message");
}
Dispose(true);
GC.SuppressFinalize(this);
}
-
}
}
\ No newline at end of file
}
internal static class MessagePortErrorFactory
{
- internal static void ThrowException(int errorCode, string errorMessage=null, string paramName=null)
+ internal static void ThrowException(int errorCode, string errorMessage = null, string paramName = null)
{
MessagePortError err = (MessagePortError)errorCode;
if (String.IsNullOrEmpty(errorMessage))