[asterisk-scf-commits] asterisk-scf/integration/ice-util-cpp.git branch "route_replica" updated.

[Commits to the Asterisk SCF project code repositories]

branch "route_replica" has been updated
       via  ac6533138755e6ed1962dc1639705ccd9153fb2a (commit)
      from  e161fcc8523025bd0a9b9d027a4601ee26fd773d (commit)

Summary of changes:
 .../include/AsteriskSCF/StateReplicator.h          |   12 ++++++++----
 1 files changed, 8 insertions(+), 4 deletions(-)


- Log -----------------------------------------------------------------
commit ac6533138755e6ed1962dc1639705ccd9153fb2a
Author: Ken Hunt <ken.hunt at digium.com>
Date:   Mon Apr 25 10:32:59 2011 -0500

    Make one-way calls to listeners.

diff --git a/StateReplicator/include/AsteriskSCF/StateReplicator.h b/StateReplicator/include/AsteriskSCF/StateReplicator.h
index 19e0d94..158e282 100644
--- a/StateReplicator/include/AsteriskSCF/StateReplicator.h
+++ b/StateReplicator/include/AsteriskSCF/StateReplicator.h
@@ -72,7 +72,8 @@ public:
         {
             try
             {
-                x->stateSet(mStateSeq);
+                T listenerOneWay = T::uncheckedCast(x->ice_oneway());
+                listenerOneWay->stateSet(mStateSeq);
             }
             catch(const Ice::Exception&)
             {
@@ -97,7 +98,8 @@ public:
         {
             try
             {
-                x->stateRemoved(mKeys);
+                T listenerOneWay = T::uncheckedCast(x->ice_oneway());
+                listenerOneWay->stateRemoved(mKeys);
             }
             catch(const Ice::Exception&)
             {
@@ -122,7 +124,8 @@ public:
         {
             try
             {
-                x->stateRemovedForItems(mStateSeq);
+                T listenerOneWay = T::uncheckedCast(x->ice_oneway());
+                listenerOneWay->stateRemovedForItems(mStateSeq);
             }
             catch(const Ice::Exception&)
             {
@@ -174,7 +177,8 @@ public:
         boost::shared_lock<boost::shared_mutex> lock(mStateLock);
         try
         {
-            listener->stateSet(mStateItems);
+            L listenerOneWay = L::uncheckedCast(listener->ice_oneway());
+            listenerOneWay->stateSet(mStateItems);
         }
         catch(const Ice::Exception&)
         {

-----------------------------------------------------------------------


-- 
asterisk-scf/integration/ice-util-cpp.git