litesoft
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
|
package org.litesoft.GWT.eventbus.server.nonpublic;
import java.util.*;
import javax.servlet.http.*;
import org.litesoft.GWT.eventbus.server.*;
import org.litesoft.logger.*;
public class SEBSessionTracker implements HttpSessionBindingListener,
ServerEventBusDisposeListener
{
private static final Logger LOGGER = LoggerFactory.getLogger( SEBSessionTracker.class );
private Set<Integer> mClientIdNumbers = new HashSet<Integer>();
private ThreadLocalContextFactory mThreadLocalContextFactory;
public SEBSessionTracker( ThreadLocalContextFactory pThreadLocalContextFactory )
{
if ( pThreadLocalContextFactory == null )
{
throw new NoThreadLocalContextFactoryException();
}
mThreadLocalContextFactory = pThreadLocalContextFactory;
}
public synchronized boolean anyServerEventBuses()
{
return !mClientIdNumbers.isEmpty();
}
public synchronized void addServerEventBus( ServerEventBus pServerEventBus )
{
Integer zClientIdNumber = pServerEventBus.getClientIdNumber();
mClientIdNumbers.add( zClientIdNumber );
pServerEventBus.addListener( this );
}
public void init( IServerEventBus pServerEventBus )
{
}
public synchronized void disposing( IServerEventBus pServerEventBus )
{
Integer zClientIdNumber = pServerEventBus.getClientIdNumber();
mClientIdNumbers.remove( zClientIdNumber );
}
public void dropAllServerEventBuses( String pWhy )
{
for ( Integer clientIdNumber : getClientIdNumbers() )
{
try
{
ServerEventBus zSEB = ServerEventBusManager.INSTANCE.getServerEventBus( clientIdNumber );
if ( (zSEB != null) && zSEB.isAliveAndWell() )
{
mThreadLocalContextFactory.setThreadLocalContextFrom( zSEB );
try
{
zSEB.dispose( pWhy );
}
finally
{
mThreadLocalContextFactory.clrThreadLocalContext();
}
}
}
catch ( RuntimeException e )
{
LOGGER.error.log( e );
}
}
synchronized ( this )
{
mClientIdNumbers.clear();
}
}
// todo: switch back to private when the AbstractStoredImageRetrievalServlet is corrected
public synchronized Integer[] getClientIdNumbers()
{
return mClientIdNumbers.toArray( new Integer[mClientIdNumbers.size()] );
}
protected synchronized void finalize()
throws Throwable
{
dropAllServerEventBuses( "ServerEventBusSessionMapper.finalize" );
super.finalize();
}
public void valueBound( HttpSessionBindingEvent pEvent )
{
HttpSession session = pEvent.getSession();
mSessionID = session.getId();
LOGGER.debug.log( pEvent.getName(), " bound to ", (session.isNew() ? "NEW" : "OLD"), //
" Session Id ", mSessionID, //
" last access time ", session.getLastAccessedTime() );
}
private String mSessionID = null;
public void valueUnbound( HttpSessionBindingEvent pEvent )
{
LOGGER.debug.log( pEvent.getName(), " unbound from Session Id ", mSessionID );
dropAllServerEventBuses( "ServerEventBusSessionMapper.valueUnbound" );
}
private String mLogoutMessage = null;
public String getLogoutMessage()
{
return mLogoutMessage;
}
public void setLogoutMessage( String pLogoutMessage )
{
mLogoutMessage = pLogoutMessage;
}
}
|
Revision |
Author |
Commited |
Message |
2
|
GeorgeS
|
Sun 07 Feb, 2010 12:50:58 +0000 |
|