Mercurial > hg > ucis.core

comparison Pml/Channels/TCPPmlChannel.cs @ 103:8fe322656807

Find changesets by keywords (author, files, the commit message), revision number or hash, or revset expression.
Cleanup some old PML code
author Ivo Smits <Ivo@UCIS.nl>
date Sat, 11 Oct 2014 14:03:31 +0200
parents 3ab940a0c7a0
children
comparison
equal deleted inserted replaced
102:1474f92cf7e7 103:8fe322656807
13 public TCPPmlChannel(TCPStream socket) { 13 public TCPPmlChannel(TCPStream socket) {
14 if (socket == null) throw new ArgumentNullException("socket"); 14 if (socket == null) throw new ArgumentNullException("socket");
15 _socket = socket; 15 _socket = socket;
16 _rw = new PmlBinaryRW(_socket); 16 _rw = new PmlBinaryRW(_socket);
17 _open = true; 17 _open = true;
18 //ThreadPool.RunTask(worker, null);
19 } 18 }
20 19
21 public override void WriteMessage(PmlElement message) { 20 public override void WriteMessage(PmlElement message) {
22 if (!_open) throw new InvalidOperationException("The channel is not open"); 21 if (!_open) throw new InvalidOperationException("The channel is not open");
23 lock (_rw) _rw.WriteMessage(message); 22 lock (_rw) _rw.WriteMessage(message);
31 } 30 }
32 31
33 public override PmlElement ReadMessage() { 32 public override PmlElement ReadMessage() {
34 return _rw.ReadMessage(); 33 return _rw.ReadMessage();
35 } 34 }
36
37 /*private void worker(Object state) {
38 try {
39 while (_open) {
40 base.PushReceivedMessage(_rw.ReadMessage());
41 }
42 } catch (Exception ex) {
43 Console.WriteLine(ex.ToString());
44 } finally {
45 Close();
46 }
47 }*/
48 } 35 }
49 } 36 }