/** 

  * 

  * Copyright 2004 Hiram Chirino

  * 

  * Licensed under the Apache License, Version 2.0 (the "License"); 

  * you may not use this file except in compliance with the License. 

  * You may obtain a copy of the License at 

  * 

  * http://www.apache.org/licenses/LICENSE-2.0

  * 

  * Unless required by applicable law or agreed to in writing, software

  * distributed under the License is distributed on an "AS IS" BASIS, 

  * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. 

  * See the License for the specific language governing permissions and 

  * limitations under the License. 

  * 

  **/

 package org.activeio.oneport;

 import java.io.IOException;

 import java.net.URI;

 import java.util.Iterator;

 import org.activeio.AcceptListener;

 import org.activeio.AsynchChannel;

 import org.activeio.AsynchChannelListener;

 import org.activeio.AsynchChannelServer;

 import org.activeio.Channel;

 import org.activeio.FilterAsynchChannel;

 import org.activeio.FilterAsynchChannelServer;

 import org.activeio.Packet;

 import org.activeio.SynchChannel;

 import org.activeio.adapter.AsynchToSynchChannelAdapter;

 import org.activeio.adapter.SynchToAsynchChannelAdapter;

 import org.activeio.filter.PushbackSynchChannel;

 import org.activeio.packet.AppendedPacket;

 import EDU.oswego.cs.dl.util.concurrent.ConcurrentHashMap;

 /**

  * Allows multiple protocols share a single ChannelServer.  All protocols sharing the server 

  * must have a distinct magic number at the beging of the client's request.

  * 

  * TODO: handle the case where a client opens a connection but sends no data down the stream.  We need

  * to timeout that client.

  * 

  * @version $Revision$

  */

     /**

      * The OnePortAsynchChannelServer listens for incoming connection

      * from a normal AsynchChannelServer.  This s the listner used 

      * to receive the accepted channels.

      */

             } catch (IOException e) {

             }                

         }

         }

     }

     /**

      * This channel filter sniffs the first few bytes of the byte stream 

      * to see if a ProtocolRecognizer recognizes the protocol.  If it does not

      * it just closes the channel, otherwise the associated SubPortAsynchChannelServer

      * is notified that it accepted a channel.

      *

      */

         private Packet buffer;

                     } else {

                     }

                 }

                 }

             });

         }

                         // Dispose the channel.. don't know what to do with it.

                     }

                         // Dispose the channel.. don't know what to do with it.

                     }

                     // Once the magic number is found:

                     // Stop the channel so that a decision can be taken on what to

                     // do with the

                     // channel. When the channel is restarted, the buffered up

                     // packets wiil get

                     // delivered.

                     } catch (IOException e) {                        

                     }

                 }

             }

         }

     }    

     /**

      * Clients bind against the OnePortAsynchChannelServer and get 

      * SubPortAsynchChannelServer which can be used to accept connections.

      */

         private final ProtocolRecognizer recognizer;

         private AcceptListener acceptListener;

         private boolean started;

         /**

          * @param recognizer

          */

         }

         }

         }

         }

         }

         }

         }

             } else {

                 // Dispose the channel.. don't know what to do with it.

             }

         }

             }

         }    

     }

     private final ConcurrentHashMap recognizerMap = new ConcurrentHashMap();

     }

     }    

     }

 }