Client/Client.cs
author sl
Mon, 15 Dec 2014 18:52:42 +0100
changeset 73 926cdf23b485
parent 72 fd0bb39a7818
child 74 60d584bad780
permissions -rw-r--r--
Client now recovers from faulty states and timeout.
sl@20
     1
using System;
sl@20
     2
using System.Collections.Generic;
sl@20
     3
using System.Linq;
sl@20
     4
using System.Text;
sl@20
     5
using System.Threading.Tasks;
sl@20
     6
using System.Windows.Forms;
sl@55
     7
using SharpDisplay;
sl@20
     8
using System.ServiceModel;
sl@20
     9
using System.ServiceModel.Channels;
sl@20
    10
sl@20
    11
sl@20
    12
namespace SharpDisplayClient
sl@20
    13
{
sl@25
    14
    /// <summary>
sl@25
    15
    ///
sl@25
    16
    /// </summary>
sl@31
    17
    [ServiceBehavior(ConcurrencyMode = ConcurrencyMode.Multiple)]
sl@55
    18
    public class Callback : ICallback, IDisposable
sl@20
    19
    {
sl@31
    20
        private MainForm MainForm { get; set; }
sl@31
    21
sl@31
    22
        public Callback(MainForm aMainForm)
sl@31
    23
        {
sl@31
    24
            MainForm = aMainForm;
sl@31
    25
        }
sl@31
    26
sl@20
    27
        public void OnConnected()
sl@20
    28
        {
sl@20
    29
            //Debug.Assert(Thread.CurrentThread.IsThreadPoolThread);
sl@20
    30
            //Trace.WriteLine("Callback thread = " + Thread.CurrentThread.ManagedThreadId);
sl@20
    31
sl@20
    32
            MessageBox.Show("OnConnected()", "Client");
sl@20
    33
        }
sl@20
    34
sl@20
    35
sl@32
    36
        public void OnCloseOrder()
sl@20
    37
        {
sl@20
    38
            //Debug.Assert(Thread.CurrentThread.IsThreadPoolThread);
sl@20
    39
            //Trace.WriteLine("Callback thread = " + Thread.CurrentThread.ManagedThreadId);
sl@20
    40
sl@21
    41
            //MessageBox.Show("OnServerClosing()", "Client");
sl@31
    42
            MainForm.CloseConnectionThreadSafe();
sl@31
    43
            MainForm.CloseThreadSafe();
sl@20
    44
        }
sl@25
    45
sl@25
    46
        //From IDisposable
sl@25
    47
        public void Dispose()
sl@25
    48
        {
sl@25
    49
sl@25
    50
        }
sl@20
    51
    }
sl@20
    52
sl@20
    53
sl@25
    54
    /// <summary>
sl@25
    55
    ///
sl@25
    56
    /// </summary>
sl@31
    57
    [ServiceBehavior(ConcurrencyMode = ConcurrencyMode.Multiple)]
sl@55
    58
    public class Client : DuplexClientBase<IService>
sl@20
    59
    {
sl@30
    60
        public string Name { get; set; }
sl@30
    61
        public string SessionId { get { return InnerChannel.SessionId; } }
sl@26
    62
sl@57
    63
        public Client(ICallback aCallback)
sl@57
    64
            : base(new InstanceContext(aCallback), new NetTcpBinding(SecurityMode.None, true), new EndpointAddress("net.tcp://localhost:8001/DisplayService"))
sl@20
    65
        { }
sl@20
    66
sl@32
    67
        public void SetName(string aClientName)
sl@20
    68
        {
sl@26
    69
            Name = aClientName;
sl@32
    70
            Channel.SetName(aClientName);
sl@26
    71
        }
sl@26
    72
sl@62
    73
sl@62
    74
        public void SetLayout(TableLayout aLayout)
sl@62
    75
        {
sl@62
    76
            Channel.SetLayout(aLayout);
sl@62
    77
        }
sl@62
    78
sl@72
    79
        public void SetText(DataField aField)
sl@20
    80
        {
sl@72
    81
            Channel.SetText(aField);
sl@20
    82
        }
sl@20
    83
sl@72
    84
        public void SetTexts(System.Collections.Generic.IList<DataField> aFields)
sl@20
    85
        {
sl@72
    86
            Channel.SetTexts(aFields);
sl@20
    87
        }
sl@20
    88
sl@72
    89
        public void SetBitmap(DataField aField)
sl@67
    90
        {
sl@72
    91
            Channel.SetBitmap(aField);
sl@67
    92
        }
sl@67
    93
sl@32
    94
        public int ClientCount()
sl@32
    95
        {
sl@32
    96
            return Channel.ClientCount();
sl@32
    97
        }
sl@57
    98
sl@57
    99
        public bool IsReady()
sl@57
   100
        {
sl@57
   101
            return State == CommunicationState.Opened;
sl@57
   102
        }
sl@20
   103
    }
sl@73
   104
sl@73
   105
sl@73
   106
    /// <summary>
sl@73
   107
    ///
sl@73
   108
    /// </summary>
sl@73
   109
    public class DisplayClient
sl@73
   110
    {
sl@73
   111
        Client iClient;
sl@73
   112
        Callback iCallback;
sl@73
   113
        private MainForm MainForm { get; set; }
sl@73
   114
sl@73
   115
        public string Name { get; set; }
sl@73
   116
        public string SessionId { get { return iClient.SessionId; } }
sl@73
   117
sl@73
   118
        public DisplayClient(MainForm aMainForm)
sl@73
   119
        {
sl@73
   120
            MainForm = aMainForm;
sl@73
   121
            Name = "";
sl@73
   122
        }
sl@73
   123
sl@73
   124
        public void Open()
sl@73
   125
        {
sl@73
   126
            iCallback = new Callback(MainForm);
sl@73
   127
            iClient = new Client(iCallback);
sl@73
   128
            if (Name != "")
sl@73
   129
            {
sl@73
   130
                iClient.SetName(Name);
sl@73
   131
            }
sl@73
   132
        }
sl@73
   133
sl@73
   134
        public void Close()
sl@73
   135
        {
sl@73
   136
            iClient.Close();
sl@73
   137
            iClient = null;
sl@73
   138
            iCallback.Dispose();
sl@73
   139
            iCallback = null;
sl@73
   140
        }
sl@73
   141
sl@73
   142
        public bool IsReady()
sl@73
   143
        {
sl@73
   144
            return (iClient != null && iCallback != null && iClient.IsReady());
sl@73
   145
        }
sl@73
   146
sl@73
   147
        public void CheckConnection()
sl@73
   148
        {
sl@73
   149
            if (!IsReady())
sl@73
   150
            {
sl@73
   151
                Open();
sl@73
   152
            }
sl@73
   153
        }
sl@73
   154
sl@73
   155
        public void SetName(string aClientName)
sl@73
   156
        {
sl@73
   157
            Name = aClientName;
sl@73
   158
            CheckConnection();
sl@73
   159
            iClient.SetName(aClientName);
sl@73
   160
        }
sl@73
   161
sl@73
   162
sl@73
   163
        public void SetLayout(TableLayout aLayout)
sl@73
   164
        {
sl@73
   165
            CheckConnection();
sl@73
   166
            iClient.SetLayout(aLayout);
sl@73
   167
        }
sl@73
   168
sl@73
   169
        public void SetText(DataField aField)
sl@73
   170
        {
sl@73
   171
            CheckConnection();
sl@73
   172
            iClient.SetText(aField);
sl@73
   173
        }
sl@73
   174
sl@73
   175
        public void SetTexts(System.Collections.Generic.IList<DataField> aFields)
sl@73
   176
        {
sl@73
   177
            CheckConnection();
sl@73
   178
            iClient.SetTexts(aFields);
sl@73
   179
        }
sl@73
   180
sl@73
   181
        public void SetBitmap(DataField aField)
sl@73
   182
        {
sl@73
   183
            CheckConnection();
sl@73
   184
            iClient.SetBitmap(aField);
sl@73
   185
        }
sl@73
   186
sl@73
   187
        public int ClientCount()
sl@73
   188
        {
sl@73
   189
            CheckConnection();
sl@73
   190
            return iClient.ClientCount();
sl@73
   191
        }
sl@73
   192
sl@73
   193
sl@73
   194
sl@73
   195
    }
sl@73
   196
sl@73
   197
sl@20
   198
}