2 // PeerChannelListener.cs
5 // Atsushi Enomoto <atsushi@ximian.com>
7 // Copyright (C) 2009 Novell, Inc. http://www.novell.com
9 // Permission is hereby granted, free of charge, to any person obtaining
10 // a copy of this software and associated documentation files (the
11 // "Software"), to deal in the Software without restriction, including
12 // without limitation the rights to use, copy, modify, merge, publish,
13 // distribute, sublicense, and/or sell copies of the Software, and to
14 // permit persons to whom the Software is furnished to do so, subject to
15 // the following conditions:
17 // The above copyright notice and this permission notice shall be
18 // included in all copies or substantial portions of the Software.
20 // THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND,
21 // EXPRESS OR IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF
22 // MERCHANTABILITY, FITNESS FOR A PARTICULAR PURPOSE AND
23 // NONINFRINGEMENT. IN NO EVENT SHALL THE AUTHORS OR COPYRIGHT HOLDERS BE
24 // LIABLE FOR ANY CLAIM, DAMAGES OR OTHER LIABILITY, WHETHER IN AN ACTION
25 // OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, OUT OF OR IN CONNECTION
26 // WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE SOFTWARE.
29 using System
.Collections
.Generic
;
30 using System
.Collections
.ObjectModel
;
32 using System
.Net
.Security
;
33 using System
.ServiceModel
;
34 using System
.ServiceModel
.Description
;
35 using System
.ServiceModel
.Security
;
37 using System
.Threading
;
39 namespace System
.ServiceModel
.Channels
41 internal class PeerChannelListener
<TChannel
> : InternalChannelListenerBase
<TChannel
>, IPeerChannelManager
42 where TChannel
: class, IChannel
44 PeerTransportBindingElement source
;
45 BindingContext context
;
47 AutoResetEvent accept_handle
= new AutoResetEvent (false);
49 public PeerChannelListener (PeerTransportBindingElement source
,
50 BindingContext context
)
54 foreach (BindingElement be
in context
.Binding
.Elements
) {
55 MessageEncodingBindingElement mbe
= be
as MessageEncodingBindingElement
;
57 MessageEncoder
= CreateEncoder
<TChannel
> (mbe
);
61 if (MessageEncoder
== null)
62 MessageEncoder
= new BinaryMessageEncoder ();
65 public PeerResolver Resolver { get; set; }
67 public PeerTransportBindingElement Source
{
68 get { return source; }
71 protected override TChannel
OnAcceptChannel (TimeSpan timeout
)
73 DateTime start
= DateTime
.Now
;
75 if (!accept_handle
.WaitOne (timeout
))
76 throw new TimeoutException ();
77 channel
= PopulateChannel (timeout
- (DateTime
.Now
- start
));
78 ((CommunicationObject
) (object) channel
).Closed
+= delegate {
85 TChannel
PopulateChannel (TimeSpan timeout
)
87 if (typeof (TChannel
) == typeof (IInputChannel
))
88 return (TChannel
) (object) new PeerDuplexChannel (this);
89 // FIXME: handle timeout somehow.
90 if (typeof (TChannel
) == typeof (IDuplexChannel
))
91 return (TChannel
) (object) new PeerDuplexChannel (this);
93 throw new InvalidOperationException (String
.Format ("Not supported channel '{0}' (mono bug; it is incorrectly allowed at construction time)", typeof (TChannel
)));
96 protected override bool OnWaitForChannel (TimeSpan timeout
)
98 throw new NotImplementedException ();
101 protected override void OnOpen (TimeSpan timeout
)
105 protected override void OnClose (TimeSpan timeout
)
108 channel
.Close (timeout
);
111 protected override void OnAbort ()