View Javadoc

1   // ========================================================================
2   // Copyright 2006 Mort Bay Consulting Pty. Ltd.
3   // ------------------------------------------------------------------------
4   // Licensed under the Apache License, Version 2.0 (the "License");
5   // you may not use this file except in compliance with the License.
6   // You may obtain a copy of the License at 
7   // http://www.apache.org/licenses/LICENSE-2.0
8   // Unless required by applicable law or agreed to in writing, software
9   // distributed under the License is distributed on an "AS IS" BASIS,
10  // WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
11  // See the License for the specific language governing permissions and
12  // limitations under the License.
13  //========================================================================
14  
15  package org.mortbay.cometd.continuation;
16  
17  import java.util.Timer;
18  import java.util.TimerTask;
19  
20  import javax.servlet.ServletContext;
21  
22  import org.mortbay.cometd.AbstractBayeux;
23  import org.mortbay.cometd.ClientImpl;
24  import org.mortbay.thread.Timeout;
25  import org.mortbay.thread.Timeout.Task;
26  
27  /* ------------------------------------------------------------ */
28  /**
29   * Extension of Bayeux that uses {@link ContinuationClient}s.
30   * 
31   * @author gregw
32   * 
33   */
34  public class ContinuationBayeux extends AbstractBayeux
35  {
36      private static int __id;
37      private transient Timer _tick;
38      private transient Timeout _timeout;
39      private long _now;
40  
41      /* ------------------------------------------------------------ */
42      /*
43       * (non-Javadoc)
44       * 
45       * @see org.mortbay.cometd.AbstractBayeux#newClient(java.lang.String,
46       * dojox.io.cometd.Destination)
47       */
48      @Override
49      public ClientImpl newRemoteClient()
50      {
51          return new ContinuationClient(this);
52      }
53  
54      /* ------------------------------------------------------------ */
55      /*
56       * (non-Javadoc)
57       * 
58       * @see
59       * org.mortbay.cometd.AbstractBayeux#initialize(javax.servlet.ServletContext
60       * )
61       */
62      @Override
63      protected void initialize(ServletContext context)
64      {
65          super.initialize(context);
66  
67          _tick=new Timer("ContinuationBayeux-" + __id++,true);
68          _timeout=new Timeout();
69          _timeout.setDuration(getMaxInterval());
70  
71          _tick.schedule(new TimerTask()
72          {
73              @Override
74              public void run()
75              {
76                  _now=System.currentTimeMillis();
77                  _timeout.tick(_now);
78              }
79          },100L,100L);
80      }
81  
82      /* ------------------------------------------------------------ */
83      long getNow()
84      {
85          return _now;
86      }
87  
88      /* ------------------------------------------------------------ */
89      @Override
90      public void setMaxInterval(long ms)
91      {
92          _timeout.setDuration(ms);
93          super.setMaxInterval(ms);
94      }
95  
96      /* ------------------------------------------------------------ */
97      /*
98       * (non-Javadoc)
99       * 
100      * @see
101      * org.mortbay.cometd.AbstractBayeux#initialize(javax.servlet.ServletContext
102      * )
103      */
104     public void destroy()
105     {
106         _tick.cancel();
107     }
108 
109     /* ------------------------------------------------------------ */
110     void startIntervalTimeout(Timeout.Task timeout,long interval)
111     {
112         synchronized(_timeout)
113         {
114             if (interval == 0 || interval==_maxInterval)
115                 _timeout.schedule(timeout);
116             else
117             {
118                 long delay = interval-getMaxInterval();
119                 _timeout.schedule(timeout,delay);
120             }
121         }
122     }
123 
124     /* ------------------------------------------------------------ */
125     void cancelIntervalTimeout(Timeout.Task timeout)
126     {
127         synchronized(_timeout)
128         {
129             if (timeout != null)
130                 timeout.cancel();
131         }
132     }
133 
134 }