litesoft
Subversion Repository Public Repository

litesoft

URLs

Copy to Clipboard
Explore
Commits

Diff Revisions 949 vs 950 for /trunk/Java/GWT/OldServer/src/org/litesoft/GWT/eventbus/server/ServerEventBus.java

Diff revisions: vs.
  @@ -1,142 +1,141 @@
1 - // This Source Code is in the Public Domain per: http://unlicense.org
2 - package org.litesoft.GWT.eventbus.server;
3 -
4 - import org.litesoft.GWT.eventbus.client.*;
5 - import org.litesoft.GWT.eventbus.client.nonpublic.*;
6 - import org.litesoft.GWT.eventbus.server.nonpublic.*;
7 - import org.litesoft.delayed.*;
8 -
9 - import java.util.*;
10 -
11 - public abstract class ServerEventBus extends AbstractPeerSupportingEventBus implements IServerEventBus {
12 - public static final ServerEventBus[] EMPTY_ARRAY = new ServerEventBus[0];
13 -
14 - public static final String TRANSLATED_PATH = "TranslatedPath";
15 - public static final String REMOTE_ADDR = "RemoteAddr";
16 -
17 - protected ServerEventBus( int pClientIdNumber ) {
18 - super( "Server", pClientIdNumber, TimedRunnableManager.INSTANCE,
19 - LoggingUnexpectedEventPackageHandler.INSTANCE );
20 - }
21 -
22 - protected void sharedInitialization( String pWhy, Integer pParentClientID,
23 - ClientWindowInstanceDataManager pInitialClientWindowInstanceData ) {
24 - addAllClientWindowInstanceDataFrom( pInitialClientWindowInstanceData );
25 -
26 - ServerEventBus zExistingSEB = ServerEventBusManager.BackDoor.updateServerEventBus( this, //
27 - pParentClientID );
28 - if ( zExistingSEB != null ) {
29 - zExistingSEB.dispose( pWhy );
30 - }
31 -
32 - mLogger.debug.log( "*** create! - ", getClientIdNumber(), " - ", pWhy );
33 - }
34 -
35 - protected void LLdisposing( String pWhy ) {
36 - for ( ServerEventBusDisposeListener listener : getServerEventBusDisposeListeners() ) {
37 - try {
38 - listener.disposing( this );
39 - }
40 - catch ( RuntimeException e ) {
41 - mLogger.error.log( e, "disposing SEB: ", getClientIdNumber() );
42 - }
43 - }
44 - super.LLdisposing( pWhy );
45 - }
46 -
47 - protected void LLdispose( String pWhy ) {
48 - synchronized ( this ) {
49 - mRelatedBusCommonObject = null;
50 - }
51 - clrServerEventBusDisposeListeners();
52 - mLogger.debug.log( "*** dispose - ", getClientIdNumber(), " - ", pWhy );
53 - super.LLdispose( pWhy );
54 - }
55 -
56 - public synchronized void setRelatedBusCommonObject( Object pRelatedBusCommonObject ) {
57 - mRelatedBusCommonObject = pRelatedBusCommonObject;
58 - }
59 -
60 - private Object mRelatedBusCommonObject;
61 -
62 - public synchronized Object getRelatedBusCommonObject() {
63 - return mRelatedBusCommonObject;
64 - }
65 -
66 - /**
67 - * @return may return an empty array, but never null
68 - */
69 - public ServerEventBus[] getAllServerEventBuses() {
70 - return ServerEventBusManager.INSTANCE.getAllServerEventBuses();
71 - }
72 -
73 - /**
74 - * @return may return null
75 - */
76 - public ServerEventBus getRootServerEventBus() {
77 - return ServerEventBusManager.INSTANCE.getRootServerEventBus( getClientIdNumber() );
78 - }
79 -
80 - /**
81 - * @return may return null
82 - */
83 - public ServerEventBus getParentServerEventBus() {
84 - return ServerEventBusManager.INSTANCE.getParentServerEventBus( getClientIdNumber() );
85 - }
86 -
87 - /**
88 - * @return may return an empty array, but never null
89 - */
90 - public ServerEventBus[] getChildrenServerEventBuses() {
91 - return ServerEventBusManager.INSTANCE.getChildrenServerEventBuses( getClientIdNumber() );
92 - }
93 -
94 - /**
95 - * @return may return an empty array, but never null
96 - */
97 - public ServerEventBus[] getAllRelatedServerEventBuses() {
98 - return ServerEventBusManager.INSTANCE.getAllRelatedServerEventBuses( getClientIdNumber() );
99 - }
100 -
101 - public AuthenticationData getAuthenticationData() {
102 - return null;
103 - }
104 -
105 - public void apply( ServerEventBusSubscriptionCollector pCollector ) {
106 - if ( pCollector != null ) {
107 - for ( ServerEventBusDisposeListener zListener : pCollector.getListeners() ) {
108 - addListener( zListener );
109 - }
110 - subscribe( pCollector );
111 - }
112 - }
113 -
114 - public void addListener( ServerEventBusDisposeListener pServerEventBusDisposeListener ) {
115 - if ( pServerEventBusDisposeListener != null ) {
116 - synchronized ( this ) {
117 - if ( mListeners.add( pServerEventBusDisposeListener ) ) {
118 - pServerEventBusDisposeListener.init( this );
119 - }
120 - }
121 - }
122 - }
123 -
124 - public void removeListener( ServerEventBusDisposeListener pServerEventBusDisposeListener ) {
125 - if ( pServerEventBusDisposeListener != null ) {
126 - synchronized ( this ) {
127 - mListeners.remove( pServerEventBusDisposeListener );
128 - }
129 - }
130 - }
131 -
132 - public synchronized ServerEventBusDisposeListener[] getServerEventBusDisposeListeners() {
133 - return mListeners.toArray( new ServerEventBusDisposeListener[mListeners.size()] );
134 - }
135 -
136 - private synchronized void clrServerEventBusDisposeListeners() {
137 - mListeners.clear();
138 - }
139 -
140 - private Set<ServerEventBusDisposeListener> mListeners = new HashSet<ServerEventBusDisposeListener>();
141 - }
142 -
1 + // This Source Code is in the Public Domain per: http://unlicense.org
2 + package org.litesoft.GWT.eventbus.server;
3 +
4 + import org.litesoft.GWT.eventbus.client.*;
5 + import org.litesoft.GWT.eventbus.client.nonpublic.*;
6 + import org.litesoft.GWT.eventbus.server.nonpublic.*;
7 + import org.litesoft.delayed.*;
8 +
9 + import java.util.*;
10 +
11 + public abstract class ServerEventBus extends AbstractPeerSupportingEventBus implements IServerEventBus {
12 + public static final ServerEventBus[] EMPTY_ARRAY = new ServerEventBus[0];
13 +
14 + public static final String TRANSLATED_PATH = "TranslatedPath";
15 + public static final String REMOTE_ADDR = "RemoteAddr";
16 +
17 + protected ServerEventBus( int pClientIdNumber ) {
18 + super( "Server", pClientIdNumber, TimedRunnableManager.INSTANCE,
19 + LoggingUnexpectedEventPackageHandler.INSTANCE );
20 + }
21 +
22 + protected void sharedInitialization( String pWhy, Integer pParentClientID,
23 + ClientWindowInstanceDataManager pInitialClientWindowInstanceData ) {
24 + addAllClientWindowInstanceDataFrom( pInitialClientWindowInstanceData );
25 +
26 + ServerEventBus zExistingSEB = ServerEventBusManager.BackDoor.updateServerEventBus( this, //
27 + pParentClientID );
28 + if ( zExistingSEB != null ) {
29 + zExistingSEB.dispose( pWhy );
30 + }
31 +
32 + mLogger.debug.log( "*** create! - ", getClientIdNumber(), " - ", pWhy );
33 + }
34 +
35 + protected void LLdisposing( String pWhy ) {
36 + for ( ServerEventBusDisposeListener listener : getServerEventBusDisposeListeners() ) {
37 + try {
38 + listener.disposing( this );
39 + }
40 + catch ( RuntimeException e ) {
41 + mLogger.error.log( e, "disposing SEB: ", getClientIdNumber() );
42 + }
43 + }
44 + super.LLdisposing( pWhy );
45 + }
46 +
47 + protected void LLdispose( String pWhy ) {
48 + synchronized ( this ) {
49 + mRelatedBusCommonObject = null;
50 + }
51 + clrServerEventBusDisposeListeners();
52 + mLogger.debug.log( "*** dispose - ", getClientIdNumber(), " - ", pWhy );
53 + super.LLdispose( pWhy );
54 + }
55 +
56 + public synchronized void setRelatedBusCommonObject( Object pRelatedBusCommonObject ) {
57 + mRelatedBusCommonObject = pRelatedBusCommonObject;
58 + }
59 +
60 + private Object mRelatedBusCommonObject;
61 +
62 + public synchronized Object getRelatedBusCommonObject() {
63 + return mRelatedBusCommonObject;
64 + }
65 +
66 + /**
67 + * @return may return an empty array, but never null
68 + */
69 + public ServerEventBus[] getAllServerEventBuses() {
70 + return ServerEventBusManager.INSTANCE.getAllServerEventBuses();
71 + }
72 +
73 + /**
74 + * @return may return null
75 + */
76 + public ServerEventBus getRootServerEventBus() {
77 + return ServerEventBusManager.INSTANCE.getRootServerEventBus( getClientIdNumber() );
78 + }
79 +
80 + /**
81 + * @return may return null
82 + */
83 + public ServerEventBus getParentServerEventBus() {
84 + return ServerEventBusManager.INSTANCE.getParentServerEventBus( getClientIdNumber() );
85 + }
86 +
87 + /**
88 + * @return may return an empty array, but never null
89 + */
90 + public ServerEventBus[] getChildrenServerEventBuses() {
91 + return ServerEventBusManager.INSTANCE.getChildrenServerEventBuses( getClientIdNumber() );
92 + }
93 +
94 + /**
95 + * @return may return an empty array, but never null
96 + */
97 + public ServerEventBus[] getAllRelatedServerEventBuses() {
98 + return ServerEventBusManager.INSTANCE.getAllRelatedServerEventBuses( getClientIdNumber() );
99 + }
100 +
101 + public AuthenticationData getAuthenticationData() {
102 + return null;
103 + }
104 +
105 + public void apply( ServerEventBusSubscriptionCollector pCollector ) {
106 + if ( pCollector != null ) {
107 + for ( ServerEventBusDisposeListener zListener : pCollector.getListeners() ) {
108 + addListener( zListener );
109 + }
110 + subscribe( pCollector );
111 + }
112 + }
113 +
114 + public void addListener( ServerEventBusDisposeListener pServerEventBusDisposeListener ) {
115 + if ( pServerEventBusDisposeListener != null ) {
116 + synchronized ( this ) {
117 + if ( mListeners.add( pServerEventBusDisposeListener ) ) {
118 + pServerEventBusDisposeListener.init( this );
119 + }
120 + }
121 + }
122 + }
123 +
124 + public void removeListener( ServerEventBusDisposeListener pServerEventBusDisposeListener ) {
125 + if ( pServerEventBusDisposeListener != null ) {
126 + synchronized ( this ) {
127 + mListeners.remove( pServerEventBusDisposeListener );
128 + }
129 + }
130 + }
131 +
132 + public synchronized ServerEventBusDisposeListener[] getServerEventBusDisposeListeners() {
133 + return mListeners.toArray( new ServerEventBusDisposeListener[mListeners.size()] );
134 + }
135 +
136 + private synchronized void clrServerEventBusDisposeListeners() {
137 + mListeners.clear();
138 + }
139 +
140 + private Set<ServerEventBusDisposeListener> mListeners = new HashSet<ServerEventBusDisposeListener>();
141 + }

View View this file contents

History View the full history

Feeds

Commits for /trunk/Java/GWT/OldServer/src/org/litesoft/GWT/eventbus/server/ServerEventBus.java

Need assistance?   Get in touch, or head to our documentation site.