{"id":36,"date":"2005-06-27T18:14:20","date_gmt":"2005-06-28T01:14:20","guid":{"rendered":"http:\/\/kennyw.com\/indigo\/36"},"modified":"2005-06-27T18:14:20","modified_gmt":"2005-06-28T01:14:20","slug":"channels-110b-ilistenerfactory","status":"publish","type":"post","link":"https:\/\/kennyw.com\/?p=36","title":{"rendered":"Channels 110b: IListenerFactory"},"content":{"rendered":"

At the root of a service-side stack lives an IListenerFactory. When you add an Endpoint<\/a> to a Service, its binding constructs an IListenerFactory stack which is responsible for receiving messages associated with that endpoint.<\/p>\n

In our sample code<\/a>, IListenerFactory-related files include UdpListenerFactory.cs<\/em>, UdpInputListener.cs<\/em>, and UdpInputChannel.cs<\/em>.<\/p>\n

UdpListenerFactory <\/a><\/h4>\n

UdpListenerFactory derives from ListenerFactoryBase. For addressing purposes<\/a>, we implement SetUri() and SetUniqueUri().<\/p>\n

Similar to UdpChannelFactory<\/a>, UdpListenerFactory overrides OnOpening() and OnClosed() to setup and tear-down resources (IBufferManager, FilterTable, etc) at the appropriate points of the state machine<\/a>.<\/p>\n

In OnOpen() we create and bind a single Udp socket to receive datagrams.<\/p>\n

In OnOpened(), we begin receiving data on our Udp socket in an asynchronous loop. As we receive data, we convert the data into Messages using the Message Encoding Framework:<\/p>\n

message = UdpConstants<\/code>.MessageEncoder.ReadMessage(new<\/code> ArraySegment<\/code><byte<\/code>>(buffer, 0, count), bufferManager);<\/div>\n

We use a FilterTable<\/code><UdpInputListener<\/code>> in order to match incoming Messages to Listeners that we’ve created. If we get a match, we dispacth the message to the UdpInputListener, which will enqueue it for a pending receive on its singleton channel (see UdpInputListener and UdpInputChannel sections below for details). If we don’t have any matching listeners for the new message, we write a warning entry to the system Event Log, and drop the message.<\/p>\n

UdpInputListener <\/a><\/h4>\n

UdpInputListener is our implementation of IInputListener<\/a>. Since the same datagram channel represents messages that come in from any number of sources, we call UdpInputListener a singleton listener. That is, we have at most one active IChannel<\/a> associated with this listener at a time. We only generate another one if a channel returned from our AcceptChannel() is subsequently disposed.<\/p>\n

UdpInputChannel <\/a><\/h4>\n

UdpInputChannel is our implementation of IInputChannel<\/a>. It consists of a queue of incoming Messages. UdpListenerFactory adds matching incoming messages to this queue, and these messages are dequeued by IInputChannel.Receive() calls.<\/p>\n

You will also notice some complexity in UdpListenerFactory.cs<\/em> around the async read loop to ensure we (a) always have an outstanding read on the receiving UDP socket and (b) maximize synchronicity while not blocking threads or deadlocking. If you want further details on a particular snippet of code, let me know.<\/p>\n

Next up will be tying the IChannelFactory and IListenerFactory to the “ABCs” of ServiceModel by creating a custom Binding Element. I can feel the excitement building…<\/p>\n","protected":false},"excerpt":{"rendered":"

At the root of a service-side stack lives an IListenerFactory. When you add an Endpoint to a Service, its binding constructs an IListenerFactory stack which is responsible for receiving messages associated with that endpoint. In our sample code, IListenerFactory-related files include UdpListenerFactory.cs, UdpInputListener.cs, and UdpInputChannel.cs. UdpListenerFactory  UdpListenerFactory derives from ListenerFactoryBase. For addressing purposes, we implement […]<\/p>\n","protected":false},"author":2,"featured_media":0,"comment_status":"open","ping_status":"open","sticky":false,"template":"","format":"standard","meta":{"footnotes":""},"categories":[11],"tags":[],"class_list":["post-36","post","type-post","status-publish","format-standard","hentry","category-indigo"],"_links":{"self":[{"href":"https:\/\/kennyw.com\/index.php?rest_route=\/wp\/v2\/posts\/36","targetHints":{"allow":["GET"]}}],"collection":[{"href":"https:\/\/kennyw.com\/index.php?rest_route=\/wp\/v2\/posts"}],"about":[{"href":"https:\/\/kennyw.com\/index.php?rest_route=\/wp\/v2\/types\/post"}],"author":[{"embeddable":true,"href":"https:\/\/kennyw.com\/index.php?rest_route=\/wp\/v2\/users\/2"}],"replies":[{"embeddable":true,"href":"https:\/\/kennyw.com\/index.php?rest_route=%2Fwp%2Fv2%2Fcomments&post=36"}],"version-history":[{"count":0,"href":"https:\/\/kennyw.com\/index.php?rest_route=\/wp\/v2\/posts\/36\/revisions"}],"wp:attachment":[{"href":"https:\/\/kennyw.com\/index.php?rest_route=%2Fwp%2Fv2%2Fmedia&parent=36"}],"wp:term":[{"taxonomy":"category","embeddable":true,"href":"https:\/\/kennyw.com\/index.php?rest_route=%2Fwp%2Fv2%2Fcategories&post=36"},{"taxonomy":"post_tag","embeddable":true,"href":"https:\/\/kennyw.com\/index.php?rest_route=%2Fwp%2Fv2%2Ftags&post=36"}],"curies":[{"name":"wp","href":"https:\/\/api.w.org\/{rel}","templated":true}]}}