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 }