[asterisk-scf-commits] asterisk-scf/integration/test_channel.git branch "retry_deux" created.
Commits to the Asterisk SCF project code repositories
asterisk-scf-commits at lists.digium.com
Mon Feb 20 11:39:48 CST 2012
branch "retry_deux" has been created
at 76fe971c354aaee7c878b5c45f4494a695a94a73 (commit)
- Log -----------------------------------------------------------------
commit 76fe971c354aaee7c878b5c45f4494a695a94a73
Author: Brent Eagles <beagles at digium.com>
Date: Mon Feb 20 14:09:07 2012 -0330
Signature catchup for recent slice changes.
diff --git a/src/CMakeLists.txt b/src/CMakeLists.txt
old mode 100644
new mode 100755
index d0b4800..a40f59b
--- a/src/CMakeLists.txt
+++ b/src/CMakeLists.txt
@@ -18,7 +18,7 @@ astscf_component_add_ice_libraries(test_channel IceStorm)
astscf_component_add_boost_libraries(test_channel thread date_time)
astscf_component_add_slice_collection_libraries(test_channel ASTSCF TEST_CHANNEL)
astscf_component_build_icebox(test_channel)
-target_link_libraries(test_channel logging-client)
+target_link_libraries(test_channel LoggingClient ASTSCFIceUtilCpp)
astscf_component_install(test_channel)
astscf_component_init(console_driver)
diff --git a/src/MediaSession.cpp b/src/MediaSession.cpp
index a245f68..18ed603 100644
--- a/src/MediaSession.cpp
+++ b/src/MediaSession.cpp
@@ -81,8 +81,10 @@ void MediaSessionI::echo()
/**
* Implementation of the corresponding API call.
*/
-void MediaSessionI::setCookies(const AsteriskSCF::Media::V1::SessionCookies& cookies,
- const Ice::Current&)
+void MediaSessionI::setCookies(
+ const AsteriskSCF::System::V1::OperationContextPtr&,
+ const AsteriskSCF::Media::V1::SessionCookies& cookies,
+ const Ice::Current&)
{
for (AsteriskSCF::Media::V1::SessionCookies::const_iterator i = cookies.begin();
i != cookies.end(); ++i)
@@ -121,8 +123,10 @@ void MediaSessionI::getCookies_async(
/**
* Implementation of the corresponding API call.
*/
-void MediaSessionI::removeCookies(const AsteriskSCF::Media::V1::SessionCookies& cookies,
- const Ice::Current&)
+void MediaSessionI::removeCookies(
+ const AsteriskSCF::System::V1::OperationContextPtr&,
+ const AsteriskSCF::Media::V1::SessionCookies& cookies,
+ const Ice::Current&)
{
for (AsteriskSCF::Media::V1::SessionCookies::const_iterator i = cookies.begin();
i != cookies.end(); ++i)
diff --git a/src/MediaSession.h b/src/MediaSession.h
index d33a65b..5e1ada1 100644
--- a/src/MediaSession.h
+++ b/src/MediaSession.h
@@ -44,7 +44,8 @@ public:
mThread->pushFrames(frames);
}
- void setSource(const AsteriskSCF::Media::V1::StreamSourcePrx& source, const Ice::Current&)
+ void setSource(const AsteriskSCF::System::V1::OperationContextPtr&,
+ const AsteriskSCF::Media::V1::StreamSourcePrx& source, const Ice::Current&)
{
mSource = source;
}
@@ -64,7 +65,8 @@ public:
return mId;
}
- void requestFormat(const AsteriskSCF::Media::V1::FormatPtr&, const Ice::Current&)
+ void requestFormat(const AsteriskSCF::System::V1::OperationContextPtr&,
+ const AsteriskSCF::Media::V1::FormatPtr&, const Ice::Current&)
{
// XXX
}
@@ -110,13 +112,15 @@ public:
{
}
- void addSink(const AsteriskSCF::Media::V1::StreamSinkPrx& sink, const Ice::Current&)
+ void addSink(const AsteriskSCF::System::V1::OperationContextPtr&,
+ const AsteriskSCF::Media::V1::StreamSinkPrx& sink, const Ice::Current&)
{
mSinks.push_back(sink);
mSinkServant->setRelaySinks(mSinks);
}
- void removeSink(const AsteriskSCF::Media::V1::StreamSinkPrx& sink, const Ice::Current&)
+ void removeSink(const AsteriskSCF::System::V1::OperationContextPtr&,
+ const AsteriskSCF::Media::V1::StreamSinkPrx& sink, const Ice::Current&)
{
mSinks.erase(std::remove(mSinks.begin(), mSinks.end(),
sink), mSinks.end());
@@ -138,7 +142,8 @@ public:
return mId;
}
- void requestFormat(const AsteriskSCF::Media::V1::FormatPtr&, const Ice::Current&)
+ void requestFormat(const AsteriskSCF::System::V1::OperationContextPtr&,
+ const AsteriskSCF::Media::V1::FormatPtr&, const Ice::Current&)
{
// XXX
}
@@ -161,14 +166,18 @@ public:
AsteriskSCF::Media::V1::StreamSourceSeq getSources(const Ice::Current&);
AsteriskSCF::Media::V1::StreamSinkSeq getSinks(const Ice::Current&);
std::string getId(const Ice::Current&);
- void setCookies(const AsteriskSCF::Media::V1::SessionCookies& cookies,
- const Ice::Current&);
+ void setCookies(
+ const AsteriskSCF::System::V1::OperationContextPtr&,
+ const AsteriskSCF::Media::V1::SessionCookies& cookies,
+ const Ice::Current&);
void getCookies_async(
const AsteriskSCF::Media::V1::AMD_Session_getCookiesPtr& cb,
const AsteriskSCF::Media::V1::SessionCookies& cookiesToGet,
const Ice::Current&);
- void removeCookies(const AsteriskSCF::Media::V1::SessionCookies& cookies,
- const Ice::Current&);
+ void removeCookies(
+ const AsteriskSCF::System::V1::OperationContextPtr&,
+ const AsteriskSCF::Media::V1::SessionCookies& cookies,
+ const Ice::Current&);
//
// internal test methods.
diff --git a/src/Service.cpp b/src/Service.cpp
index fccaa1f..824a530 100644
--- a/src/Service.cpp
+++ b/src/Service.cpp
@@ -20,6 +20,7 @@
#include <AsteriskSCF/Core/Routing/RoutingIf.h>
#include "Logger.h"
#include "TestEndpoint.h"
+#include <AsteriskSCF/Operations/OperationContext.h>
namespace
{
@@ -92,15 +93,17 @@ void TestChannelDriver::start(const std::string& name, const Ice::CommunicatorPt
AsteriskSCF::Core::Discovery::V1::ServiceLocatorManagementPrx management =
AsteriskSCF::Core::Discovery::V1::ServiceLocatorManagementPrx::checkedCast(communicator->propertyToProxy("LocatorServiceManagement.Proxy"));
- mServiceManagement = AsteriskSCF::Core::Discovery::V1::ServiceManagementPrx::uncheckedCast(management->addService(endpointLocatorPrx, "TestChannel"));
+ mServiceManagement =
+ AsteriskSCF::Core::Discovery::V1::ServiceManagementPrx::uncheckedCast(
+ management->addService(AsteriskSCF::Operations::createContext(), endpointLocatorPrx, "TestChannel"));
AsteriskSCF::Core::Discovery::V1::ServiceLocatorParamsPtr params = new AsteriskSCF::Core::Discovery::V1::ServiceLocatorParams();
params->category = "TestChannel";
- mServiceManagement->addLocatorParams(params, "");
+ mServiceManagement->addLocatorParams(AsteriskSCF::Operations::createContext(), params, "");
}
void TestChannelDriver::stop()
{
- mServiceManagement->unregister();
+ mServiceManagement->unregister(AsteriskSCF::Operations::createContext());
try
{
mAdapter->deactivate();
diff --git a/src/TestEndpoint.cpp b/src/TestEndpoint.cpp
index 0b0315c..33d9a47 100644
--- a/src/TestEndpoint.cpp
+++ b/src/TestEndpoint.cpp
@@ -32,6 +32,7 @@
#include "Logger.h"
#include "MediaSession.h"
#include <AsteriskSCF/TestChannel/CommandsIf.h>
+#include <AsteriskSCF/Operations/OperationContext.h>
using namespace AsteriskSCF::TestUtil;
@@ -78,46 +79,61 @@ public:
//
void connected()
{
- mPublisher->indicated(mSession, new AsteriskSCF::SessionCommunications::V1::ConnectedIndication(),
- AsteriskSCF::SessionCommunications::V1::SessionCookies());
+ mPublisher->indicated(
+ AsteriskSCF::Operations::createContext(), mSession,
+ new AsteriskSCF::SessionCommunications::V1::ConnectedIndication(),
+ AsteriskSCF::SessionCommunications::V1::SessionCookies());
}
void flashed()
{
- mPublisher->indicated(mSession, new AsteriskSCF::SessionCommunications::V1::FlashedIndication(),
- AsteriskSCF::SessionCommunications::V1::SessionCookies());
+ mPublisher->indicated(
+ AsteriskSCF::Operations::createContext(),
+ mSession, new AsteriskSCF::SessionCommunications::V1::FlashedIndication(),
+ AsteriskSCF::SessionCommunications::V1::SessionCookies());
}
void held()
{
- mPublisher->indicated(mSession, new AsteriskSCF::SessionCommunications::V1::HeldIndication(),
- AsteriskSCF::SessionCommunications::V1::SessionCookies());
+ mPublisher->indicated(
+ AsteriskSCF::Operations::createContext(),
+ mSession, new AsteriskSCF::SessionCommunications::V1::HeldIndication(),
+ AsteriskSCF::SessionCommunications::V1::SessionCookies());
}
void progressing(const AsteriskSCF::SessionCommunications::V1::ResponseCodePtr& response)
{
- AsteriskSCF::SessionCommunications::V1::ProgressingIndicationPtr indication(new AsteriskSCF::SessionCommunications::V1::ProgressingIndication());
+ AsteriskSCF::SessionCommunications::V1::ProgressingIndicationPtr indication(
+ new AsteriskSCF::SessionCommunications::V1::ProgressingIndication());
indication->response = response;
- mPublisher->indicated(mSession, indication, AsteriskSCF::SessionCommunications::V1::SessionCookies());
+ mPublisher->indicated(AsteriskSCF::Operations::createContext(),
+ mSession, indication, AsteriskSCF::SessionCommunications::V1::SessionCookies());
}
void ringing()
{
- mPublisher->indicated(mSession, new AsteriskSCF::SessionCommunications::V1::RingingIndication(),
- AsteriskSCF::SessionCommunications::V1::SessionCookies());
+ mPublisher->indicated(
+ AsteriskSCF::Operations::createContext(),
+ mSession, new AsteriskSCF::SessionCommunications::V1::RingingIndication(),
+ AsteriskSCF::SessionCommunications::V1::SessionCookies());
}
void stopped(const AsteriskSCF::SessionCommunications::V1::ResponseCodePtr& response)
{
- AsteriskSCF::SessionCommunications::V1::StoppedIndicationPtr indication(new AsteriskSCF::SessionCommunications::V1::StoppedIndication());
+ AsteriskSCF::SessionCommunications::V1::StoppedIndicationPtr indication(
+ new AsteriskSCF::SessionCommunications::V1::StoppedIndication());
indication->response = response;
- mPublisher->indicated(mSession, indication, AsteriskSCF::SessionCommunications::V1::SessionCookies());
+ mPublisher->indicated(
+ AsteriskSCF::Operations::createContext(),
+ mSession, indication, AsteriskSCF::SessionCommunications::V1::SessionCookies());
}
void unheld()
{
- mPublisher->indicated(mSession, new AsteriskSCF::SessionCommunications::V1::UnheldIndication(),
- AsteriskSCF::SessionCommunications::V1::SessionCookies());
+ mPublisher->indicated(
+ AsteriskSCF::Operations::createContext(),
+ mSession, new AsteriskSCF::SessionCommunications::V1::UnheldIndication(),
+ AsteriskSCF::SessionCommunications::V1::SessionCookies());
}
void setProxy(const AsteriskSCF::SessionCommunications::V1::SessionPrx& prx)
@@ -139,6 +155,7 @@ public:
void write_async(
const AsteriskSCF::SessionCommunications::V1::AMD_TelephonyEventSink_writePtr& cb,
+ const AsteriskSCF::System::V1::OperationContextPtr&,
const AsteriskSCF::SessionCommunications::V1::TelephonyEventPtr& telephonyEvent,
const Ice::Current&)
{
@@ -148,6 +165,7 @@ public:
void setSource_async(
const AsteriskSCF::SessionCommunications::V1::AMD_TelephonyEventSink_setSourcePtr& cb,
+ const AsteriskSCF::System::V1::OperationContextPtr&,
const AsteriskSCF::SessionCommunications::V1::TelephonyEventSourcePrx& source,
const Ice::Current&)
{
@@ -180,6 +198,7 @@ public:
void addSinks_async(
const AsteriskSCF::SessionCommunications::V1::AMD_TelephonyEventSource_addSinksPtr& cb,
+ const AsteriskSCF::System::V1::OperationContextPtr&,
const AsteriskSCF::SessionCommunications::V1::TelephonyEventSinkSeq& sinks,
const Ice::Current&)
{
@@ -189,6 +208,7 @@ public:
void removeSinks_async(
const AsteriskSCF::SessionCommunications::V1::AMD_TelephonyEventSource_removeSinksPtr& cb,
+ const AsteriskSCF::System::V1::OperationContextPtr&,
const AsteriskSCF::SessionCommunications::V1::TelephonyEventSinkSeq& sinks,
const Ice::Current&)
{
@@ -231,7 +251,7 @@ public:
NamePtr name = new Name("bar");
NumberPtr number = new Number("100");
- IdPtr testId = new Id(name, number);
+ IdPtr testId = new Id(name, number, new Privacy(false));
IdSeq idSeq;
idSeq.push_back(testId);
mCaller = new Caller(idSeq);
@@ -240,20 +260,21 @@ public:
NamePtr dialedName = new Name("foo");
NumberPtr dialedNumber = new Number("104");
- IdPtr dialedId = new Id(dialedName, dialedNumber);
+ IdPtr dialedId = new Id(dialedName, dialedNumber, new Privacy(false));
IdSeq dialedSeq;
dialedSeq.push_back(dialedId);
mDialed = new Dialed(dialedNumber);
NamePtr redirName = new Name("scud");
NumberPtr redirNumber = new Number("666");
- IdPtr connectedId = new Id(redirName, redirNumber);
+ IdPtr connectedId = new Id(redirName, redirNumber, new Privacy(false));
IdSeq idSeq2;
idSeq2.push_back(connectedId);
mConnectedLine = new ConnectedLine(idSeq2);
RedirectionSeq redirects;
- RedirectionPtr redirect = new Redirection(dialedId, connectedId);
+ RedirectionPtr redirect = new Redirection(dialedId, connectedId,
+ new RedirectionReason(Unavailable));
redirects.push_back(redirect);
mRedirections = new Redirections(redirects);
@@ -269,6 +290,7 @@ public:
void addListener_async(
const AsteriskSCF::SessionCommunications::V1::AMD_Session_addListenerPtr& cb,
+ const AsteriskSCF::System::V1::OperationContextPtr&,
const AsteriskSCF::SessionCommunications::V1::SessionListenerPrx& listener,
const Ice::Current&)
{
@@ -279,6 +301,7 @@ public:
void indicate_async(
const AsteriskSCF::SessionCommunications::V1::AMD_Session_indicatePtr& cb,
+ const AsteriskSCF::System::V1::OperationContextPtr&,
const AsteriskSCF::SessionCommunications::V1::IndicationPtr& value,
const Ice::Current&)
{
@@ -348,8 +371,9 @@ public:
}
void removeListener(
- const AsteriskSCF::SessionCommunications::V1::SessionListenerPrx& listener,
- const Ice::Current&)
+ const AsteriskSCF::System::V1::OperationContextPtr&,
+ const AsteriskSCF::SessionCommunications::V1::SessionListenerPrx& listener,
+ const Ice::Current&)
{
mListeners->removeListener(listener);
mEndpointManager->log(mId, __FUNCTION__);
@@ -360,13 +384,15 @@ public:
mEndpointManager->log(mId, __FUNCTION__);
}
- void start(const Ice::Current&)
+ void start(const AsteriskSCF::System::V1::OperationContextPtr&, const Ice::Current&)
{
mEndpointManager->log(mId, __FUNCTION__);
mListeners->connected();
}
- void stop(const AsteriskSCF::SessionCommunications::V1::ResponseCodePtr&, const Ice::Current&)
+ void stop(
+ const AsteriskSCF::System::V1::OperationContextPtr&,
+ const AsteriskSCF::SessionCommunications::V1::ResponseCodePtr&, const Ice::Current&)
{
mEndpointManager->log(mId, __FUNCTION__);
}
@@ -390,6 +416,7 @@ public:
*/
void setBridge_async(
const AsteriskSCF::SessionCommunications::V1::AMD_Session_setBridgePtr& cb,
+ const AsteriskSCF::System::V1::OperationContextPtr&,
const AsteriskSCF::SessionCommunications::V1::BridgePrx& newBridge,
const AsteriskSCF::SessionCommunications::V1::SessionListenerPrx& listener,
const Ice::Current&)
@@ -403,6 +430,7 @@ public:
void removeBridge_async(
const AsteriskSCF::SessionCommunications::V1::AMD_Session_removeBridgePtr& cb,
+ const AsteriskSCF::System::V1::OperationContextPtr&,
const AsteriskSCF::SessionCommunications::V1::SessionListenerPrx& listener,
const Ice::Current&)
{
@@ -425,14 +453,18 @@ public:
cb->ice_response(AsteriskSCF::Media::V1::StreamInformationDict());
}
- void setAndGetSessionController_async(const AsteriskSCF::SessionCommunications::V1::AMD_Session_setAndGetSessionControllerPtr& cb,
+ void setAndGetSessionController_async(
+ const AsteriskSCF::SessionCommunications::V1::AMD_Session_setAndGetSessionControllerPtr& cb,
+ const AsteriskSCF::System::V1::OperationContextPtr&,
const AsteriskSCF::SessionCommunications::V1::SessionControllerPrx&, const Ice::Current&)
{
cb->ice_response(0);
}
- void removeSessionController_async(const AsteriskSCF::SessionCommunications::V1::AMD_Session_removeSessionControllerPtr& cb,
- const AsteriskSCF::SessionCommunications::V1::SessionControllerPrx&, const Ice::Current&)
+ void removeSessionController_async(
+ const AsteriskSCF::SessionCommunications::V1::AMD_Session_removeSessionControllerPtr& cb,
+ const AsteriskSCF::System::V1::OperationContextPtr&,
+ const AsteriskSCF::SessionCommunications::V1::SessionControllerPrx&, const Ice::Current&)
{
cb->ice_response();
}
@@ -462,11 +494,15 @@ public:
mListeners->stopped(new AsteriskSCF::SessionCommunications::V1::ResponseCode);
}
- void setCookies(const AsteriskSCF::SessionCommunications::V1::SessionCookies&, const Ice::Current&)
+ void setCookies(
+ const AsteriskSCF::System::V1::OperationContextPtr&,
+ const AsteriskSCF::SessionCommunications::V1::SessionCookies&, const Ice::Current&)
{
}
- void removeCookies(const AsteriskSCF::SessionCommunications::V1::SessionCookies&, const Ice::Current&)
+ void removeCookies(
+ const AsteriskSCF::System::V1::OperationContextPtr&,
+ const AsteriskSCF::SessionCommunications::V1::SessionCookies&, const Ice::Current&)
{
}
@@ -577,10 +613,11 @@ public:
}
AsteriskSCF::SessionCommunications::V1::SessionPrx createSession(
- const std::string& destination,
- const AsteriskSCF::SessionCommunications::V1::SessionListenerPrx&,
- const AsteriskSCF::SessionCommunications::ExtensionPoints::V1::SessionCreationHookPrx&,
- const Ice::Current& current)
+ const AsteriskSCF::System::V1::OperationContextPtr&,
+ const std::string& destination,
+ const AsteriskSCF::SessionCommunications::V1::SessionListenerPrx&,
+ const AsteriskSCF::SessionCommunications::ExtensionPoints::V1::SessionCreationHookPrx&,
+ const Ice::Current& current)
{
InternalSessionInfo info;
info.id = mId + "." + destination + "." + IceUtil::generateUUID();
@@ -717,23 +754,31 @@ public:
std::cerr << "Unknown id" << std::endl;
}
- void addDefaultSessionListener(const SessionListenerPrx& listener, const Ice::Current& )
+ void addDefaultSessionListener(
+ const AsteriskSCF::System::V1::OperationContextPtr&,
+ const SessionListenerPrx& listener, const Ice::Current& )
{
mDefaultListeners.add(listener);
}
- void removeDefaultSessionListener(const SessionListenerPrx& listener, const Ice::Current&)
+ void removeDefaultSessionListener(
+ const AsteriskSCF::System::V1::OperationContextPtr&,
+ const SessionListenerPrx& listener, const Ice::Current&)
{
mDefaultListeners.remove(listener);
}
- void addDefaultSessionCookies(const SessionCookies&,
- const Ice::Current&)
+ void addDefaultSessionCookies(
+ const AsteriskSCF::System::V1::OperationContextPtr&,
+ const SessionCookies&,
+ const Ice::Current&)
{
}
- void removeDefaultSessionCookies(const SessionCookies&,
- const Ice::Current&)
+ void removeDefaultSessionCookies(
+ const AsteriskSCF::System::V1::OperationContextPtr&,
+ const SessionCookies&,
+ const Ice::Current&)
{
}
-----------------------------------------------------------------------
--
asterisk-scf/integration/test_channel.git
More information about the asterisk-scf-commits
mailing list