diff options
Diffstat (limited to 'py/test/Ice/operations/ServerAMD.py')
| -rwxr-xr-x | py/test/Ice/operations/ServerAMD.py | 12 |
1 files changed, 12 insertions, 0 deletions
diff --git a/py/test/Ice/operations/ServerAMD.py b/py/test/Ice/operations/ServerAMD.py index b888f48eea5..b32f7f1acf0 100755 --- a/py/test/Ice/operations/ServerAMD.py +++ b/py/test/Ice/operations/ServerAMD.py @@ -35,6 +35,8 @@ class MyDerivedClassI(Test.MyDerivedClass): def __init__(self): self.opVoidThread = None self.opVoidThreadLock = threading.Lock() + self.lock = threading.Lock() + self.opByteSOnewayCount = 0 def ice_isA(self, id, current=None): test(current.mode == Ice.OperationMode.Nonmutating) @@ -233,8 +235,18 @@ class MyDerivedClassI(Test.MyDerivedClass): cb.ice_response([-x for x in s]) def opByteSOneway_async(self, cb, s, current=None): + self.lock.acquire() + self.opByteSOnewayCount += 1 + self.lock.release() cb.ice_response() + def opByteSOnewayCallCount_async(self, cb, current=None): + self.lock.acquire() + count = self.opByteSOnewayCount + self.opByteSOnewayCount = 0 + self.lock.release() + cb.ice_response(count) + def opDoubleMarshaling_async(self, cb, p1, p2, current=None): d = 1278312346.0 / 13.0; test(p1 == d) |