?  search:
summary | log | graphiclog1 | graphiclog2 | commit | commitdiff | tree | refs | edit | fork
blame | history | raw | HEAD
(DISTFILES): Comment out a few missing files.
[mono-project.git] / mcs / class / corlib / System.Runtime.Remoting.Contexts / Context.cs
blob0d72a0fc379af4c8ba6dd7dedc7b7e2f09b4e945
1 //
2 // System.Runtime.Remoting.Contexts.Context..cs
3 //
4 // Author:
5 // Miguel de Icaza (miguel@ximian.com)
6 // Lluis Sanchez Gual (lluis@ideary.com)
7 // Patrik Torstensson
8 //
9 // (C) Ximian, Inc. http://www.ximian.com
10 //
11
12 //
13 // Copyright (C) 2004 Novell, Inc (http://www.novell.com)
14 //
15 // Permission is hereby granted, free of charge, to any person obtaining
16 // a copy of this software and associated documentation files (the
17 // "Software"), to deal in the Software without restriction, including
18 // without limitation the rights to use, copy, modify, merge, publish,
19 // distribute, sublicense, and/or sell copies of the Software, and to
20 // permit persons to whom the Software is furnished to do so, subject to
21 // the following conditions:
22 //
23 // The above copyright notice and this permission notice shall be
24 // included in all copies or substantial portions of the Software.
25 //
26 // THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND,
27 // EXPRESS OR IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF
28 // MERCHANTABILITY, FITNESS FOR A PARTICULAR PURPOSE AND
29 // NONINFRINGEMENT. IN NO EVENT SHALL THE AUTHORS OR COPYRIGHT HOLDERS BE
30 // LIABLE FOR ANY CLAIM, DAMAGES OR OTHER LIABILITY, WHETHER IN AN ACTION
31 // OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, OUT OF OR IN CONNECTION
32 // WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE SOFTWARE.
33 //
34
35 using System.Collections;
36 using System.Threading;
37 using System.Runtime.Remoting;
38 using System.Runtime.Remoting.Proxies;
39 using System.Runtime.Remoting.Activation;
40 using System.Runtime.Remoting.Messaging;
41 using System.Runtime.Remoting.Lifetime;
42
43 namespace System.Runtime.Remoting.Contexts {
44
45 public class Context
46 {
47 int domain_id;
48 int context_id;
49 int process_id;
50 IntPtr static_data;
51
52 // Default server context sink chain
53 static IMessageSink default_server_context_sink;
54
55 // The sink chain that has to be used by all calls entering the context
56 IMessageSink server_context_sink_chain = null;
57
58 // The sink chain that has to be used by all calls exiting the context
59 IMessageSink client_context_sink_chain = null;
60
61 Hashtable datastore;
62 ArrayList context_properties;
63 bool frozen;
64
65 static int global_count;
66 static Hashtable namedSlots;
67
68 static DynamicPropertyCollection global_dynamic_properties;
69 DynamicPropertyCollection context_dynamic_properties;
70 ContextCollbackObject callback_object = null;
71
72 public Context ()
73 {
74 domain_id = Thread.GetDomainID();
75 context_id = 1 + global_count++;
76 }
77
78 ~Context ()
79 {
80 }
81
82 public static Context DefaultContext {
83 get {
84 return AppDomain.InternalGetDefaultContext ();
85 }
86 }
87
88 public virtual int ContextID {
89 get {
90 return context_id;
91 }
92 }
93
94 public IContextProperty[] ContextProperties
95 {
96 get
97 {
98 if (context_properties == null) return new IContextProperty[0];
99 else return (IContextProperty[]) context_properties.ToArray (typeof(IContextProperty[]));
100 }
101 }
102
103 internal bool IsDefaultContext
104 {
105 get { return context_id == 0; }
106 }
107
108 public static bool RegisterDynamicProperty(IDynamicProperty prop, ContextBoundObject obj, Context ctx)
109 {
110 DynamicPropertyCollection col = GetDynamicPropertyCollection (obj, ctx);
111 return col.RegisterDynamicProperty (prop);
112 }
113
114 public static bool UnregisterDynamicProperty(string name, ContextBoundObject obj, Context ctx)
115 {
116 DynamicPropertyCollection col = GetDynamicPropertyCollection (obj, ctx);
117 return col.UnregisterDynamicProperty (name);
118 }
119
120 static DynamicPropertyCollection GetDynamicPropertyCollection(ContextBoundObject obj, Context ctx)
121 {
122 if (ctx == null && obj != null)
123 {
124 if (RemotingServices.IsTransparentProxy(obj))
125 {
126 RealProxy rp = RemotingServices.GetRealProxy (obj);
127 return rp.ObjectIdentity.ClientDynamicProperties;
128 }
129 else
130 return obj.ObjectIdentity.ServerDynamicProperties;
131 }
132 else if (ctx != null && obj == null)
133 {
134 if (ctx.context_dynamic_properties == null) ctx.context_dynamic_properties = new DynamicPropertyCollection ();
135 return ctx.context_dynamic_properties;
136 }
137 else if (ctx == null && obj == null)
138 {
139 if (global_dynamic_properties == null) global_dynamic_properties = new DynamicPropertyCollection ();
140 return global_dynamic_properties;
141 }
142 else
143 throw new ArgumentException ("Either obj or ctx must be null");
144 }
145
146 internal static void NotifyGlobalDynamicSinks (bool start, IMessage req_msg, bool client_site, bool async)
147 {
148 if (global_dynamic_properties != null && global_dynamic_properties.HasProperties)
149 global_dynamic_properties.NotifyMessage (start, req_msg, client_site, async);
150 }
151
152 internal static bool HasGlobalDynamicSinks
153 {
154 get { return (global_dynamic_properties != null && global_dynamic_properties.HasProperties); }
155 }
156
157 internal void NotifyDynamicSinks (bool start, IMessage req_msg, bool client_site, bool async)
158 {
159 if (context_dynamic_properties != null && context_dynamic_properties.HasProperties)
160 context_dynamic_properties.NotifyMessage (start, req_msg, client_site, async);
161 }
162
163 internal bool HasDynamicSinks
164 {
165 get { return (context_dynamic_properties != null && context_dynamic_properties.HasProperties); }
166 }
167
168 internal bool HasExitSinks
169 {
170 get
171 {
172 // Needs to go through the client context sink if there are custom
173 // client context or dynamic sinks.
174
175 return ( !(GetClientContextSinkChain() is ClientContextTerminatorSink) || HasDynamicSinks || HasGlobalDynamicSinks);
176 }
177 }
178
179 public virtual IContextProperty GetProperty (string name)
180 {
181 if (context_properties == null)
182 return null;
183
184 foreach (IContextProperty p in context_properties)
185 if (p.Name == name)
186 return p;
187
188 return null;
189 }
190
191 public virtual void SetProperty (IContextProperty prop)
192 {
193 if (prop == null)
194 throw new ArgumentNullException ("IContextProperty");
195 if (this == DefaultContext)
196 throw new InvalidOperationException ("Can not add properties to " +
197 "default context");
198 if (frozen)
199 throw new InvalidOperationException ("Context is Frozen");
200
201 if (context_properties == null)
202 context_properties = new ArrayList ();
203
204 context_properties.Add (prop);
205 }
206
207 public virtual void Freeze ()
208 {
209 if (context_properties != null)
210 {
211 foreach (IContextProperty prop in context_properties)
212 prop.Freeze (this);
213 }
214 }
215
216 public override string ToString()
217 {
218 return "ContextID: " + context_id;
219 }
220
221 internal IMessageSink GetServerContextSinkChain()
222 {
223 if (server_context_sink_chain == null)
224 {
225 if (default_server_context_sink == null)
226 default_server_context_sink = new ServerContextTerminatorSink();
227
228 server_context_sink_chain = default_server_context_sink;
229
230 if (context_properties != null) {
231 // Enumerate in reverse order
232 for (int n = context_properties.Count-1; n>=0; n--) {
233 IContributeServerContextSink contributor = context_properties[n] as IContributeServerContextSink;
234 if (contributor != null)
235 server_context_sink_chain = contributor.GetServerContextSink (server_context_sink_chain);
236 }
237 }
238 }
239 return server_context_sink_chain;
240 }
241
242 internal IMessageSink GetClientContextSinkChain()
243 {
244 if (client_context_sink_chain == null)
245 {
246 client_context_sink_chain = new ClientContextTerminatorSink (this);
247
248 if (context_properties != null) {
249 foreach (IContextProperty prop in context_properties) {
250 IContributeClientContextSink contributor = prop as IContributeClientContextSink;
251 if (contributor != null)
252 client_context_sink_chain = contributor.GetClientContextSink (client_context_sink_chain);
253 }
254 }
255 }
256 return client_context_sink_chain;
257 }
258
259 internal IMessageSink CreateServerObjectSinkChain (MarshalByRefObject obj, bool forceInternalExecute)
260 {
261 IMessageSink objectSink = new StackBuilderSink (obj, forceInternalExecute);
262 objectSink = new ServerObjectTerminatorSink (objectSink);
263 objectSink = new Lifetime.LeaseSink (objectSink);
264
265 if (context_properties != null)
266 {
267 // Contribute object sinks in reverse order
268 for (int n = context_properties.Count-1; n >= 0; n--)
269 {
270 IContextProperty prop = (IContextProperty) context_properties[n];
271 IContributeObjectSink contributor = prop as IContributeObjectSink;
272 if (contributor != null)
273 objectSink = contributor.GetObjectSink (obj, objectSink);
274 }
275 }
276 return objectSink;
277 }
278
279 internal IMessageSink CreateEnvoySink (MarshalByRefObject serverObject)
280 {
281 IMessageSink sink = EnvoyTerminatorSink.Instance;
282 if (context_properties != null)
283 {
284 foreach (IContextProperty prop in context_properties)
285 {
286 IContributeEnvoySink contributor = prop as IContributeEnvoySink;
287 if (contributor != null)
288 sink = contributor.GetEnvoySink (serverObject, sink);
289 }
290 }
291 return sink;
292 }
293
294 internal static Context SwitchToContext (Context newContext)
295 {
296 return AppDomain.InternalSetContext (newContext);
297 }
298
299 internal static Context CreateNewContext (IConstructionCallMessage msg)
300 {
301 // Create the new context
302
303 Context newContext = new Context();
304
305 foreach (IContextProperty prop in msg.ContextProperties)
306 {
307 if (newContext.GetProperty (prop.Name) == null)
308 newContext.SetProperty (prop);
309 }
310 newContext.Freeze();
311
312
313 // Ask each context property whether the new context is OK
314
315 foreach (IContextProperty prop in msg.ContextProperties)
316 if (!prop.IsNewContextOK (newContext))
317 throw new RemotingException("A context property did not approve the candidate context for activating the object");
318
319 return newContext;
320 }
321
322 public void DoCallBack (CrossContextDelegate deleg)
323 {
324 if (callback_object == null)
325 {
326 lock (this)
327 {
328 if (callback_object == null) {
329 Context oldContext = Context.SwitchToContext (this);
330 callback_object = new ContextCollbackObject ();
331 Context.SwitchToContext (oldContext);
332 }
333 }
334 }
335
336 callback_object.DoCallBack (deleg);
337 }
338
339 public static LocalDataStoreSlot AllocateDataSlot ()
340 {
341 return new LocalDataStoreSlot ();
342 }
343
344 public static LocalDataStoreSlot AllocateNamedDataSlot (string name)
345 {
346 if (namedSlots == null)
347 {
348 lock (typeof(Context))
349 {
350 if (namedSlots == null)
351 namedSlots = new Hashtable ();
352 }
353 }
354
355 lock (namedSlots.SyncRoot)
356 {
357 LocalDataStoreSlot slot = new LocalDataStoreSlot ();
358 namedSlots.Add (name, slot);
359 return slot;
360 }
361 }
362
363 public static void FreeNamedDataSlot (string name)
364 {
365 if (namedSlots == null) return;
366
367 lock (namedSlots.SyncRoot)
368 {
369 namedSlots.Remove (name);
370 }
371 }
372
373 public static object GetData (LocalDataStoreSlot slot)
374 {
375 Context ctx = Thread.CurrentContext;
376 if (ctx.datastore == null) return null;
377
378 lock (ctx.datastore.SyncRoot)
379 {
380 return ctx.datastore [slot];
381 }
382 }
383
384 public static LocalDataStoreSlot GetNamedDataSlot (string name)
385 {
386 if (namedSlots == null)
387 return AllocateNamedDataSlot (name);
388
389 lock (namedSlots)
390 {
391 LocalDataStoreSlot slot = namedSlots [name] as LocalDataStoreSlot;
392 if (slot == null) return AllocateNamedDataSlot (name);
393 else return slot;
394 }
395 }
396
397 public static void SetData (LocalDataStoreSlot slot, object data)
398 {
399 Context ctx = Thread.CurrentContext;
400 if (ctx.datastore == null)
401 {
402 lock (ctx)
403 {
404 if (ctx.datastore == null)
405 ctx.datastore = new Hashtable ();
406 }
407 }
408
409 lock (ctx.datastore.SyncRoot)
410 {
411 ctx.datastore [slot] = data;
412 }
413 }
414 }
415
416 class DynamicPropertyCollection
417 {
418 ArrayList _properties = new ArrayList();
419
420 class DynamicPropertyReg
421 {
422 public IDynamicProperty Property;
423 public IDynamicMessageSink Sink;
424 }
425
426 public bool HasProperties
427 {
428 get { return _properties.Count > 0; }
429 }
430
431 public bool RegisterDynamicProperty(IDynamicProperty prop)
432 {
433 lock (this)
434 {
435 if (FindProperty (prop.Name) != -1)
436 throw new InvalidOperationException ("Another property by this name already exists");
437
438 // Make a copy, do not interfere with threads running dynamic sinks
439 ArrayList newProps = new ArrayList (_properties);
440
441 DynamicPropertyReg reg = new DynamicPropertyReg();
442 reg.Property = prop;
443 IContributeDynamicSink contributor = prop as IContributeDynamicSink;
444 if (contributor != null) reg.Sink = contributor.GetDynamicSink ();
445 newProps.Add (reg);
446
447 _properties = newProps;
448
449 return true; // When should be false?
450 }
451 }
452
453 public bool UnregisterDynamicProperty(string name)
454 {
455 lock (this)
456 {
457 int i = FindProperty (name);
458 if (i == -1) throw new RemotingException ("A property with the name " + name + " was not found");
459
460 _properties.RemoveAt (i);
461 return true; // When should be false?
462 }
463 }
464
465 public void NotifyMessage (bool start, IMessage msg, bool client_site, bool async)
466 {
467 ArrayList props = _properties;
468 if (start)
469 {
470 foreach (DynamicPropertyReg reg in props)
471 if (reg.Sink != null) reg.Sink.ProcessMessageStart (msg, client_site, async);
472 }
473 else
474 {
475 foreach (DynamicPropertyReg reg in props)
476 if (reg.Sink != null) reg.Sink.ProcessMessageFinish (msg, client_site, async);
477 }
478 }
479
480 int FindProperty (string name)
481 {
482 for (int n=0; n<_properties.Count; n++)
483 if (((DynamicPropertyReg)_properties[n]).Property.Name == name)
484 return n;
485 return -1;
486 }
487 }
488
489 class ContextCollbackObject: ContextBoundObject
490 {
491 public void DoCallBack (CrossContextDelegate deleg)
492 {
493 }
494 }
495 }
Mirror of the official Mono project git repository