diff options
author | Benoit Foucher <benoit@zeroc.com> | 2014-11-05 15:33:01 +0100 |
---|---|---|
committer | Benoit Foucher <benoit@zeroc.com> | 2014-11-05 15:33:01 +0100 |
commit | cb4d5772e9a7a9228577df83027e45ec7de022ea (patch) | |
tree | bd6489fe77ed5fba43adff613293d580fda8e0f3 /py/test/Ice/operations/ServerAMD.py | |
parent | Fixed src tree build of IceJS (diff) | |
download | ice-cb4d5772e9a7a9228577df83027e45ec7de022ea.tar.bz2 ice-cb4d5772e9a7a9228577df83027e45ec7de022ea.tar.xz ice-cb4d5772e9a7a9228577df83027e45ec7de022ea.zip |
Fixed ICE-5607: relaxed Ice.MessageSizeMax
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) |