Skip to content

Commit

Permalink
HEAD:(zeroc-ice/ice@ce4245eb3b) Add MaxDispatches connection property (
Browse files Browse the repository at this point in the history
  • Loading branch information
bernardnormier authored and temp committed Aug 2, 2024
1 parent bbbb308 commit 053ede2
Show file tree
Hide file tree
Showing 1,473 changed files with 1,909 additions and 1,909 deletions.
12 changes: 6 additions & 6 deletions slice2cpp/cpp/src/IceGrid/Internal.cpp
Original file line number Diff line number Diff line change
Expand Up @@ -1585,11 +1585,11 @@ IceGrid::ReplicaSessionPrx::_iceI_setAdapterDirectProxy(const ::std::shared_ptr<
{
ex.ice_throw();
}
catch(const AdapterNotExistException&)
catch(const AdapterExistsException&)
{
throw;
}
catch(const AdapterExistsException&)
catch(const AdapterNotExistException&)
{
throw;
}
Expand Down Expand Up @@ -1700,11 +1700,11 @@ IceGrid::InternalRegistryPrx::_iceI_registerNode(const ::std::shared_ptr<::IceIn
{
ex.ice_throw();
}
catch(const PermissionDeniedException&)
catch(const NodeActiveException&)
{
throw;
}
catch(const NodeActiveException&)
catch(const PermissionDeniedException&)
{
throw;
}
Expand Down Expand Up @@ -1750,11 +1750,11 @@ IceGrid::InternalRegistryPrx::_iceI_registerReplica(const ::std::shared_ptr<::Ic
{
ex.ice_throw();
}
catch(const PermissionDeniedException&)
catch(const ReplicaActiveException&)
{
throw;
}
catch(const ReplicaActiveException&)
catch(const PermissionDeniedException&)
{
throw;
}
Expand Down
4 changes: 2 additions & 2 deletions slice2cpp/python/test/Ice/exceptions/Test.cpp
Original file line number Diff line number Diff line change
Expand Up @@ -218,11 +218,11 @@ Test::ThrowerPrx::_iceI_throwAorDasAorD(const ::std::shared_ptr<::IceInternal::O
{
ex.ice_throw();
}
catch(const D&)
catch(const A&)
{
throw;
}
catch(const A&)
catch(const D&)
{
throw;
}
Expand Down
4 changes: 2 additions & 2 deletions slice2cs/cpp/src/IceGrid/Internal.cs
Original file line number Diff line number Diff line change
Expand Up @@ -5792,11 +5792,11 @@ private void _iceI_setDatabaseObserver(DatabaseObserverPrx? iceP_dbObs, global::
{
throw ex;
}
catch(DeploymentException)
catch(ObserverAlreadyRegisteredException)
{
throw;
}
catch(ObserverAlreadyRegisteredException)
catch(DeploymentException)
{
throw;
}
Expand Down
14 changes: 7 additions & 7 deletions slice2cs/cpp/src/IceStorm/IceStormInternal.cs
Original file line number Diff line number Diff line change
Expand Up @@ -729,15 +729,15 @@ private void _iceI_subscribeAndGetPublisher(global::System.Collections.Generic.D
{
throw ex;
}
catch(InvalidSubscriber)
catch(AlreadySubscribed)
{
throw;
}
catch(BadQoS)
catch(InvalidSubscriber)
{
throw;
}
catch(AlreadySubscribed)
catch(BadQoS)
{
throw;
}
Expand Down Expand Up @@ -1391,6 +1391,10 @@ public abstract class TopicInternalDisp_ : Ice.ObjectImpl, TopicInternal

public abstract global::Ice.ObjectPrx? subscribeAndGetPublisher(global::System.Collections.Generic.Dictionary<string, string> theQoS, global::Ice.ObjectPrx? subscriber, Ice.Current current);

public abstract void unsubscribe(global::Ice.ObjectPrx? subscriber, Ice.Current current);

public abstract void link(TopicPrx? linkTo, int cost, Ice.Current current);

public abstract void unlink(TopicPrx? linkTo, Ice.Current current);

public abstract LinkInfo[] getLinkInfoSeq(Ice.Current current);
Expand All @@ -1399,10 +1403,6 @@ public abstract class TopicInternalDisp_ : Ice.ObjectImpl, TopicInternal

public abstract void destroy(Ice.Current current);

public abstract void unsubscribe(global::Ice.ObjectPrx? subscriber, Ice.Current current);

public abstract void link(TopicPrx? linkTo, int cost, Ice.Current current);

public override string ice_id(Ice.Current current) => ice_staticId();

public static new string ice_staticId() => "::IceStorm::TopicInternal";
Expand Down
140 changes: 70 additions & 70 deletions slice2cs/cpp/test/Ice/operations/TestAMD.cs

Large diffs are not rendered by default.

84 changes: 42 additions & 42 deletions slice2cs/csharp/test/Ice/operations/TestAMD.cs
Original file line number Diff line number Diff line change
Expand Up @@ -10145,34 +10145,6 @@ public abstract class MyDerivedClassDisp_ : Ice.ObjectImpl, MyDerivedClass

public abstract global::System.Threading.Tasks.Task<MyStruct1> opMyStruct1Async(MyStruct1 opMyStruct1, Ice.Current current);

public abstract global::System.Threading.Tasks.Task shutdownAsync(Ice.Current current);

public abstract global::System.Threading.Tasks.Task<bool> supportsCompressAsync(Ice.Current current);

public abstract global::System.Threading.Tasks.Task opVoidAsync(Ice.Current current);

public abstract global::System.Threading.Tasks.Task<MyClass_OpByteResult> opByteAsync(byte p1, byte p2, Ice.Current current);

public abstract global::System.Threading.Tasks.Task<MyClass_OpBoolResult> opBoolAsync(bool p1, bool p2, Ice.Current current);

public abstract global::System.Threading.Tasks.Task<MyClass_OpShortIntLongResult> opShortIntLongAsync(short p1, int p2, long p3, Ice.Current current);

public abstract global::System.Threading.Tasks.Task<MyClass_OpFloatDoubleResult> opFloatDoubleAsync(float p1, double p2, Ice.Current current);

public abstract global::System.Threading.Tasks.Task<MyClass_OpStringResult> opStringAsync(string p1, string p2, Ice.Current current);

public abstract global::System.Threading.Tasks.Task<MyClass_OpMyEnumResult> opMyEnumAsync(MyEnum p1, Ice.Current current);

public abstract global::System.Threading.Tasks.Task<MyClass_OpMyClassResult> opMyClassAsync(MyClassPrx? p1, Ice.Current current);

public abstract global::System.Threading.Tasks.Task<MyClass_OpStructResult> opStructAsync(Structure p1, Structure p2, Ice.Current current);

public abstract global::System.Threading.Tasks.Task<MyClass_OpByteSResult> opByteSAsync(byte[] p1, byte[] p2, Ice.Current current);

public abstract global::System.Threading.Tasks.Task<MyClass_OpBoolSResult> opBoolSAsync(bool[] p1, bool[] p2, Ice.Current current);

public abstract global::System.Threading.Tasks.Task<MyClass_OpShortIntLongSResult> opShortIntLongSAsync(short[] p1, int[] p2, long[] p3, Ice.Current current);

public abstract global::System.Threading.Tasks.Task<MyClass_OpFloatDoubleSResult> opFloatDoubleSAsync(float[] p1, double[] p2, Ice.Current current);

public abstract global::System.Threading.Tasks.Task<MyClass_OpStringSResult> opStringSAsync(string[] p1, string[] p2, Ice.Current current);
Expand Down Expand Up @@ -10213,6 +10185,20 @@ public abstract class MyDerivedClassDisp_ : Ice.ObjectImpl, MyDerivedClass

public abstract global::System.Threading.Tasks.Task<MyClass_OpStringMyEnumDSResult> opStringMyEnumDSAsync(global::System.Collections.Generic.Dictionary<string, MyEnum>[] p1, global::System.Collections.Generic.Dictionary<string, MyEnum>[] p2, Ice.Current current);

public abstract global::System.Threading.Tasks.Task<MyClass_OpMyEnumMyEnumSDResult> opMyEnumMyEnumSDAsync(global::System.Collections.Generic.Dictionary<MyEnum, MyEnum[]> p1, global::System.Collections.Generic.Dictionary<MyEnum, MyEnum[]> p2, Ice.Current current);

public abstract global::System.Threading.Tasks.Task<int[]> opIntSAsync(int[] s, Ice.Current current);

public abstract global::System.Threading.Tasks.Task opByteSOnewayAsync(byte[] s, Ice.Current current);

public abstract global::System.Threading.Tasks.Task<int> opByteSOnewayCallCountAsync(Ice.Current current);

public abstract global::System.Threading.Tasks.Task<global::System.Collections.Generic.Dictionary<string, string>> opContextAsync(Ice.Current current);

public abstract global::System.Threading.Tasks.Task opDoubleMarshalingAsync(double p1, double[] p2, Ice.Current current);

public abstract global::System.Threading.Tasks.Task opIdempotentAsync(Ice.Current current);

public abstract global::System.Threading.Tasks.Task<MyClass_OpMyEnumStringDSResult> opMyEnumStringDSAsync(global::System.Collections.Generic.Dictionary<MyEnum, string>[] p1, global::System.Collections.Generic.Dictionary<MyEnum, string>[] p2, Ice.Current current);

public abstract global::System.Threading.Tasks.Task<MyClass_OpMyStructMyEnumDSResult> opMyStructMyEnumDSAsync(global::System.Collections.Generic.Dictionary<MyStruct, MyEnum>[] p1, global::System.Collections.Generic.Dictionary<MyStruct, MyEnum>[] p2, Ice.Current current);
Expand All @@ -10233,20 +10219,6 @@ public abstract class MyDerivedClassDisp_ : Ice.ObjectImpl, MyDerivedClass

public abstract global::System.Threading.Tasks.Task<MyClass_OpStringStringSDResult> opStringStringSDAsync(global::System.Collections.Generic.Dictionary<string, string[]> p1, global::System.Collections.Generic.Dictionary<string, string[]> p2, Ice.Current current);

public abstract global::System.Threading.Tasks.Task<MyClass_OpMyEnumMyEnumSDResult> opMyEnumMyEnumSDAsync(global::System.Collections.Generic.Dictionary<MyEnum, MyEnum[]> p1, global::System.Collections.Generic.Dictionary<MyEnum, MyEnum[]> p2, Ice.Current current);

public abstract global::System.Threading.Tasks.Task<int[]> opIntSAsync(int[] s, Ice.Current current);

public abstract global::System.Threading.Tasks.Task opByteSOnewayAsync(byte[] s, Ice.Current current);

public abstract global::System.Threading.Tasks.Task<int> opByteSOnewayCallCountAsync(Ice.Current current);

public abstract global::System.Threading.Tasks.Task<global::System.Collections.Generic.Dictionary<string, string>> opContextAsync(Ice.Current current);

public abstract global::System.Threading.Tasks.Task opDoubleMarshalingAsync(double p1, double[] p2, Ice.Current current);

public abstract global::System.Threading.Tasks.Task opIdempotentAsync(Ice.Current current);

public abstract global::System.Threading.Tasks.Task<byte> opByte1Async(byte opByte1, Ice.Current current);

public abstract global::System.Threading.Tasks.Task<short> opShort1Async(short opShort1, Ice.Current current);
Expand Down Expand Up @@ -10285,6 +10257,34 @@ public abstract class MyDerivedClassDisp_ : Ice.ObjectImpl, MyDerivedClass

public abstract global::System.Threading.Tasks.Task<MyClass_OpMDict2MarshaledResult> opMDict2Async(global::System.Collections.Generic.Dictionary<string, string> p1, Ice.Current current);

public abstract global::System.Threading.Tasks.Task shutdownAsync(Ice.Current current);

public abstract global::System.Threading.Tasks.Task<bool> supportsCompressAsync(Ice.Current current);

public abstract global::System.Threading.Tasks.Task opVoidAsync(Ice.Current current);

public abstract global::System.Threading.Tasks.Task<MyClass_OpByteResult> opByteAsync(byte p1, byte p2, Ice.Current current);

public abstract global::System.Threading.Tasks.Task<MyClass_OpBoolResult> opBoolAsync(bool p1, bool p2, Ice.Current current);

public abstract global::System.Threading.Tasks.Task<MyClass_OpShortIntLongResult> opShortIntLongAsync(short p1, int p2, long p3, Ice.Current current);

public abstract global::System.Threading.Tasks.Task<MyClass_OpFloatDoubleResult> opFloatDoubleAsync(float p1, double p2, Ice.Current current);

public abstract global::System.Threading.Tasks.Task<MyClass_OpStringResult> opStringAsync(string p1, string p2, Ice.Current current);

public abstract global::System.Threading.Tasks.Task<MyClass_OpMyEnumResult> opMyEnumAsync(MyEnum p1, Ice.Current current);

public abstract global::System.Threading.Tasks.Task<MyClass_OpMyClassResult> opMyClassAsync(MyClassPrx? p1, Ice.Current current);

public abstract global::System.Threading.Tasks.Task<MyClass_OpStructResult> opStructAsync(Structure p1, Structure p2, Ice.Current current);

public abstract global::System.Threading.Tasks.Task<MyClass_OpByteSResult> opByteSAsync(byte[] p1, byte[] p2, Ice.Current current);

public abstract global::System.Threading.Tasks.Task<MyClass_OpBoolSResult> opBoolSAsync(bool[] p1, bool[] p2, Ice.Current current);

public abstract global::System.Threading.Tasks.Task<MyClass_OpShortIntLongSResult> opShortIntLongSAsync(short[] p1, int[] p2, long[] p3, Ice.Current current);

public override string ice_id(Ice.Current current) => ice_staticId();

public static new string ice_staticId() => "::Test::MyDerivedClass";
Expand Down
Loading

0 comments on commit 053ede2

Please sign in to comment.