summaryrefslogtreecommitdiff
path: root/java/src/Ice/ImplicitContextI.java
diff options
context:
space:
mode:
authorBernard Normier <bernard@zeroc.com>2007-02-01 17:09:49 +0000
committerBernard Normier <bernard@zeroc.com>2007-02-01 17:09:49 +0000
commitabada90e3f84dc703b8ddc9efcbed8a946fadead (patch)
tree2c6f9dccd510ea97cb927a7bd635422efaae547a /java/src/Ice/ImplicitContextI.java
parentremoving trace message (diff)
downloadice-abada90e3f84dc703b8ddc9efcbed8a946fadead.tar.bz2
ice-abada90e3f84dc703b8ddc9efcbed8a946fadead.tar.xz
ice-abada90e3f84dc703b8ddc9efcbed8a946fadead.zip
Expanded tabs into spaces
Diffstat (limited to 'java/src/Ice/ImplicitContextI.java')
-rw-r--r--java/src/Ice/ImplicitContextI.java646
1 files changed, 323 insertions, 323 deletions
diff --git a/java/src/Ice/ImplicitContextI.java b/java/src/Ice/ImplicitContextI.java
index 865c8eed725..e595d2d5a1f 100644
--- a/java/src/Ice/ImplicitContextI.java
+++ b/java/src/Ice/ImplicitContextI.java
@@ -16,27 +16,27 @@ public abstract class ImplicitContextI extends LocalObjectImpl implements Implic
{
public static ImplicitContextI create(String kind)
{
- if(kind.equals("None") || kind.equals(""))
- {
- return null;
- }
- else if(kind.equals("Shared"))
- {
- return new Shared();
- }
- else if(kind.equals("SharedWithoutLocking"))
- {
- return new SharedWithoutLocking();
- }
- else if(kind.equals("PerThread"))
- {
- return new PerThread();
- }
- else
- {
- throw new Ice.InitializationException(
- "'" + kind + "' is not a valid value for Ice.ImplicitContext");
- }
+ if(kind.equals("None") || kind.equals(""))
+ {
+ return null;
+ }
+ else if(kind.equals("Shared"))
+ {
+ return new Shared();
+ }
+ else if(kind.equals("SharedWithoutLocking"))
+ {
+ return new SharedWithoutLocking();
+ }
+ else if(kind.equals("PerThread"))
+ {
+ return new PerThread();
+ }
+ else
+ {
+ throw new Ice.InitializationException(
+ "'" + kind + "' is not a valid value for Ice.ImplicitContext");
+ }
}
abstract public void write(java.util.Map prxContext, IceInternal.BasicStream os);
@@ -45,317 +45,317 @@ public abstract class ImplicitContextI extends LocalObjectImpl implements Implic
static class SharedWithoutLocking extends ImplicitContextI
{
- public java.util.Map getContext()
- {
- return (java.util.Map)_context.clone();
- }
-
- public void setContext(java.util.Map context)
- {
- _context.clear();
- if(context != null && !context.isEmpty())
- {
- _context.putAll(context);
- }
- }
-
- public String get(String key)
- {
- if(key == null)
- {
- key = "";
- }
-
-
- String val = (String)_context.get(key);
- if(val == null)
- {
- throw new Ice.NotSetException(key);
- }
- else
- {
- return val;
- }
- }
-
- public String getWithDefault(String key, String dflt)
- {
- if(key == null)
- {
- key = "";
- }
- if(dflt == null)
- {
- dflt = "";
- }
-
- String val = (String)_context.get(key);
- return val == null ? dflt : val;
- }
-
- public void set(String key, String value)
- {
- if(key == null)
- {
- key = "";
- }
- if(value == null)
- {
- value = "";
- }
-
- _context.put(key, value);
- }
-
- public void remove(String key)
- {
- if(key == null)
- {
- key = "";
- }
-
- if(_context.remove(key) == null)
- {
- throw new Ice.NotSetException(key);
- }
- }
-
- public void write(java.util.Map prxContext, IceInternal.BasicStream os)
- {
- if(prxContext.isEmpty())
- {
- ContextHelper.write(os, _context);
- }
- else if(_context.isEmpty())
- {
- ContextHelper.write(os, prxContext);
- }
- else
- {
- ContextHelper.write(os, combine(prxContext));
- }
- }
-
- java.util.Map combine(java.util.Map prxContext)
- {
- java.util.Map combined = (java.util.Map)_context.clone();
- combined.putAll(prxContext);
- return combined;
- }
-
- protected java.util.HashMap _context = new java.util.HashMap();
+ public java.util.Map getContext()
+ {
+ return (java.util.Map)_context.clone();
+ }
+
+ public void setContext(java.util.Map context)
+ {
+ _context.clear();
+ if(context != null && !context.isEmpty())
+ {
+ _context.putAll(context);
+ }
+ }
+
+ public String get(String key)
+ {
+ if(key == null)
+ {
+ key = "";
+ }
+
+
+ String val = (String)_context.get(key);
+ if(val == null)
+ {
+ throw new Ice.NotSetException(key);
+ }
+ else
+ {
+ return val;
+ }
+ }
+
+ public String getWithDefault(String key, String dflt)
+ {
+ if(key == null)
+ {
+ key = "";
+ }
+ if(dflt == null)
+ {
+ dflt = "";
+ }
+
+ String val = (String)_context.get(key);
+ return val == null ? dflt : val;
+ }
+
+ public void set(String key, String value)
+ {
+ if(key == null)
+ {
+ key = "";
+ }
+ if(value == null)
+ {
+ value = "";
+ }
+
+ _context.put(key, value);
+ }
+
+ public void remove(String key)
+ {
+ if(key == null)
+ {
+ key = "";
+ }
+
+ if(_context.remove(key) == null)
+ {
+ throw new Ice.NotSetException(key);
+ }
+ }
+
+ public void write(java.util.Map prxContext, IceInternal.BasicStream os)
+ {
+ if(prxContext.isEmpty())
+ {
+ ContextHelper.write(os, _context);
+ }
+ else if(_context.isEmpty())
+ {
+ ContextHelper.write(os, prxContext);
+ }
+ else
+ {
+ ContextHelper.write(os, combine(prxContext));
+ }
+ }
+
+ java.util.Map combine(java.util.Map prxContext)
+ {
+ java.util.Map combined = (java.util.Map)_context.clone();
+ combined.putAll(prxContext);
+ return combined;
+ }
+
+ protected java.util.HashMap _context = new java.util.HashMap();
}
static class Shared extends SharedWithoutLocking
{
- public synchronized java.util.Map getContext()
- {
- return super.getContext();
- }
-
- public synchronized void setContext(java.util.Map context)
- {
- super.setContext(context);
- }
-
- public synchronized String get(String key)
- {
- return super.get(key);
- }
-
- public synchronized String getWithDefault(String key, String dflt)
- {
- return super.getWithDefault(key, dflt);
- }
-
- public synchronized void set(String key, String value)
- {
- super.set(key, value);
- }
-
- public synchronized void remove(String key)
- {
- super.remove(key);
- }
-
- public void write(java.util.Map prxContext, IceInternal.BasicStream os)
- {
- if(prxContext.isEmpty())
- {
- synchronized(this)
- {
- ContextHelper.write(os, _context);
- }
- }
- else
- {
- java.util.Map ctx = null;
- synchronized(this)
- {
- ctx = _context.isEmpty() ? prxContext : super.combine(prxContext);
- }
- ContextHelper.write(os, ctx);
- }
- }
-
- synchronized java.util.Map combine(java.util.Map prxContext)
- {
- return super.combine(prxContext);
- }
+ public synchronized java.util.Map getContext()
+ {
+ return super.getContext();
+ }
+
+ public synchronized void setContext(java.util.Map context)
+ {
+ super.setContext(context);
+ }
+
+ public synchronized String get(String key)
+ {
+ return super.get(key);
+ }
+
+ public synchronized String getWithDefault(String key, String dflt)
+ {
+ return super.getWithDefault(key, dflt);
+ }
+
+ public synchronized void set(String key, String value)
+ {
+ super.set(key, value);
+ }
+
+ public synchronized void remove(String key)
+ {
+ super.remove(key);
+ }
+
+ public void write(java.util.Map prxContext, IceInternal.BasicStream os)
+ {
+ if(prxContext.isEmpty())
+ {
+ synchronized(this)
+ {
+ ContextHelper.write(os, _context);
+ }
+ }
+ else
+ {
+ java.util.Map ctx = null;
+ synchronized(this)
+ {
+ ctx = _context.isEmpty() ? prxContext : super.combine(prxContext);
+ }
+ ContextHelper.write(os, ctx);
+ }
+ }
+
+ synchronized java.util.Map combine(java.util.Map prxContext)
+ {
+ return super.combine(prxContext);
+ }
}
static class PerThread extends ImplicitContextI
{
-
- public java.util.Map getContext()
- {
- //
- // Note that _map is a *synchronized* map
- //
- java.util.HashMap threadContext = (java.util.HashMap)_map.get(Thread.currentThread());
-
- if(threadContext == null)
- {
- threadContext = new java.util.HashMap();
- }
- return threadContext;
- }
-
- public void setContext(java.util.Map context)
- {
- if(context == null || context.isEmpty())
- {
- _map.remove(Thread.currentThread());
- }
- else
- {
- java.util.HashMap threadContext = new java.util.HashMap(context);
- _map.put(Thread.currentThread(), threadContext);
- }
- }
-
- public String get(String key)
- {
- if(key == null)
- {
- key = "";
- }
-
- java.util.HashMap threadContext = (java.util.HashMap)_map.get(Thread.currentThread());
-
- if(threadContext == null)
- {
- throw new Ice.NotSetException(key);
- }
- String val = (String)threadContext.get(key);
- if(val == null)
- {
- throw new Ice.NotSetException(key);
- }
- return val;
- }
-
- public String getWithDefault(String key, String dflt)
- {
- if(key == null)
- {
- key = "";
- }
- if(dflt == null)
- {
- dflt = "";
- }
+
+ public java.util.Map getContext()
+ {
+ //
+ // Note that _map is a *synchronized* map
+ //
+ java.util.HashMap threadContext = (java.util.HashMap)_map.get(Thread.currentThread());
+
+ if(threadContext == null)
+ {
+ threadContext = new java.util.HashMap();
+ }
+ return threadContext;
+ }
+
+ public void setContext(java.util.Map context)
+ {
+ if(context == null || context.isEmpty())
+ {
+ _map.remove(Thread.currentThread());
+ }
+ else
+ {
+ java.util.HashMap threadContext = new java.util.HashMap(context);
+ _map.put(Thread.currentThread(), threadContext);
+ }
+ }
+
+ public String get(String key)
+ {
+ if(key == null)
+ {
+ key = "";
+ }
+
+ java.util.HashMap threadContext = (java.util.HashMap)_map.get(Thread.currentThread());
+
+ if(threadContext == null)
+ {
+ throw new Ice.NotSetException(key);
+ }
+ String val = (String)threadContext.get(key);
+ if(val == null)
+ {
+ throw new Ice.NotSetException(key);
+ }
+ return val;
+ }
+
+ public String getWithDefault(String key, String dflt)
+ {
+ if(key == null)
+ {
+ key = "";
+ }
+ if(dflt == null)
+ {
+ dflt = "";
+ }
- java.util.HashMap threadContext = (java.util.HashMap)_map.get(Thread.currentThread());
-
- if(threadContext == null)
- {
- return dflt;
- }
- String val = (String)threadContext.get(key);
- if(val == null)
- {
- return dflt;
- }
- return val;
- }
-
- public void set(String key, String value)
- {
- if(key == null)
- {
- key = "";
- }
- if(value == null)
- {
- value = "";
- }
-
- Thread currentThread = Thread.currentThread();
- java.util.HashMap threadContext = (java.util.HashMap)_map.get(currentThread);
-
- if(threadContext == null)
- {
- threadContext = new java.util.HashMap();
- _map.put(currentThread, threadContext);
- }
-
- threadContext.put(key, value);
- }
-
- public void remove(String key)
- {
- if(key == null)
- {
- key = "";
- }
-
- java.util.HashMap threadContext = (java.util.HashMap)_map.get(Thread.currentThread());
-
- if(threadContext == null)
- {
- throw new Ice.NotSetException(key);
- }
-
- if(threadContext.remove(key) == null)
- {
- throw new Ice.NotSetException(key);
- }
- }
-
- public void write(java.util.Map prxContext, IceInternal.BasicStream os)
- {
- java.util.HashMap threadContext = (java.util.HashMap)_map.get(Thread.currentThread());
-
- if(threadContext == null || threadContext.isEmpty())
- {
- ContextHelper.write(os, prxContext);
- }
- else if(prxContext.isEmpty())
- {
- ContextHelper.write(os, threadContext);
- }
- else
- {
- java.util.Map combined = (java.util.Map)threadContext.clone();
- combined.putAll(prxContext);
- ContextHelper.write(os, combined);
- }
- }
-
- java.util.Map combine(java.util.Map prxContext)
- {
- java.util.HashMap threadContext = (java.util.HashMap)_map.get(Thread.currentThread());
-
- java.util.Map combined = (java.util.Map)threadContext.clone();
- combined.putAll(prxContext);
- return combined;
- }
-
- //
- // Synchronized map Thread -> Context
- //
- private java.util.Map _map = java.util.Collections.synchronizedMap(new java.util.HashMap());
+ java.util.HashMap threadContext = (java.util.HashMap)_map.get(Thread.currentThread());
+
+ if(threadContext == null)
+ {
+ return dflt;
+ }
+ String val = (String)threadContext.get(key);
+ if(val == null)
+ {
+ return dflt;
+ }
+ return val;
+ }
+
+ public void set(String key, String value)
+ {
+ if(key == null)
+ {
+ key = "";
+ }
+ if(value == null)
+ {
+ value = "";
+ }
+
+ Thread currentThread = Thread.currentThread();
+ java.util.HashMap threadContext = (java.util.HashMap)_map.get(currentThread);
+
+ if(threadContext == null)
+ {
+ threadContext = new java.util.HashMap();
+ _map.put(currentThread, threadContext);
+ }
+
+ threadContext.put(key, value);
+ }
+
+ public void remove(String key)
+ {
+ if(key == null)
+ {
+ key = "";
+ }
+
+ java.util.HashMap threadContext = (java.util.HashMap)_map.get(Thread.currentThread());
+
+ if(threadContext == null)
+ {
+ throw new Ice.NotSetException(key);
+ }
+
+ if(threadContext.remove(key) == null)
+ {
+ throw new Ice.NotSetException(key);
+ }
+ }
+
+ public void write(java.util.Map prxContext, IceInternal.BasicStream os)
+ {
+ java.util.HashMap threadContext = (java.util.HashMap)_map.get(Thread.currentThread());
+
+ if(threadContext == null || threadContext.isEmpty())
+ {
+ ContextHelper.write(os, prxContext);
+ }
+ else if(prxContext.isEmpty())
+ {
+ ContextHelper.write(os, threadContext);
+ }
+ else
+ {
+ java.util.Map combined = (java.util.Map)threadContext.clone();
+ combined.putAll(prxContext);
+ ContextHelper.write(os, combined);
+ }
+ }
+
+ java.util.Map combine(java.util.Map prxContext)
+ {
+ java.util.HashMap threadContext = (java.util.HashMap)_map.get(Thread.currentThread());
+
+ java.util.Map combined = (java.util.Map)threadContext.clone();
+ combined.putAll(prxContext);
+ return combined;
+ }
+
+ //
+ // Synchronized map Thread -> Context
+ //
+ private java.util.Map _map = java.util.Collections.synchronizedMap(new java.util.HashMap());
}
}