GVariant *parameters,
GDBusMethodInvocation *invocation)
{
- LogInfo("On method call: " << methodName);
+ LogDebug("On method call: " << methodName);
if (g_strcmp0(methodName, "echo") == 0)
{
const gchar* arg = NULL;
g_variant_get(parameters, "(&s)", &arg);
- LogInfo("Client said: " << arg);
+ LogDebug("Client said: " << arg);
gchar* response = g_strdup_printf(arg);
g_dbus_method_invocation_return_value(invocation,
virtual void OnEventReceived(const AsyncCallEvent &event)
{
- LogInfo("CLIENT: AsyncCallEvent received");
+ LogDebug("CLIENT: AsyncCallEvent received");
event.GetArg0().ConsumeArg(m_receivedData);
- LogInfo("CLIENT: Result from server: " << m_receivedData);
+ LogDebug("CLIENT: Result from server: " << m_receivedData);
if (m_receivedData != m_sentData)
LogError("Wrong data Received!");
{
if (dynamic_cast<DPL::FakeRpcConnection *>(event.GetArg1())){
++m_connections;
- LogInfo("CLIENT: Acquiring new fake connection");
+ LogDebug("CLIENT: Acquiring new fake connection");
m_rpcFakeConnection.reset(event.GetArg1());
//this is not used on this side
// m_rpcFakeConnection->DPL::EventSupport<AsyncCallEvent>::AddListener(this);
}
else{
++m_connections;
- LogInfo("CLIENT: Acquiring new unix connection");
+ LogDebug("CLIENT: Acquiring new unix connection");
m_rpcUnixConnection.reset(event.GetArg1());
m_rpcUnixConnection->DPL::EventSupport<AsyncCallEvent>::AddListener(this);
}
// Emit RPC function call
DPL::RPCFunction proc;
proc.AppendArg(m_sentData);
- LogInfo("CLIENT: Calling RPC function");
+ LogDebug("CLIENT: Calling RPC function");
m_rpcFakeConnection->AsyncCall(proc);
}
}
{
m_connections = 0;
// Attach RPC listeners
- LogInfo("CLIENT: Attaching connection established event");
+ LogDebug("CLIENT: Attaching connection established event");
m_rpcUnixClient.DPL::EventSupport<ConnectionEstablishedEvent>::AddListener(this);
m_rpcFakeClient.DPL::EventSupport<ConnectionEstablishedEvent>::AddListener(this);
// Open connection to server
- LogInfo("CLIENT: Opening connection to RPC");
+ LogDebug("CLIENT: Opening connection to RPC");
m_rpcUnixClient.Open(UNIX_RPC_NAME);
m_rpcFakeClient.Open(FAKE_RPC_NAME);
// Start message loop
- LogInfo("CLIENT: Starting thread event loop");
+ LogDebug("CLIENT: Starting thread event loop");
int ret = Exec();
if (m_rpcUnixConnection.get()){
- LogInfo("CLIENT: Removing Unix connection");
+ LogDebug("CLIENT: Removing Unix connection");
m_rpcUnixConnection->DPL::EventSupport<AsyncCallEvent>::RemoveListener(this);
m_rpcUnixConnection.reset();
}
- LogInfo("CLIENT: Closing");
+ LogDebug("CLIENT: Closing");
if (m_rpcFakeConnection.get()){
- LogInfo("CLIENT: Removing Fake connection");
+ LogDebug("CLIENT: Removing Fake connection");
//this is not used on this side
// m_rpcFakeConnection->DPL::EventSupport<AsyncCallEvent>::RemoveListener(this);
m_rpcFakeConnection.reset();
}
// Detach RPC client listener
- LogInfo("CLIENT: Detaching connection established event");
+ LogDebug("CLIENT: Detaching connection established event");
m_rpcUnixClient.DPL::EventSupport<ConnectionEstablishedEvent>::RemoveListener(this);
m_rpcFakeClient.DPL::EventSupport<ConnectionEstablishedEvent>::RemoveListener(this);
// Close RPC
- LogInfo("CLIENT: Closing RPC client");
+ LogDebug("CLIENT: Closing RPC client");
m_rpcUnixClient.CloseAll();
m_rpcFakeClient.Close();//not needed
// Quit application event occurred
virtual void OnEventReceived(const QuitEvent &/*event*/){
// Close RPC now
- LogInfo("SERVER: Closing RPC connection...");
+ LogDebug("SERVER: Closing RPC connection...");
// Detach RPC connection listeners
if (m_rpcUnixConnection.get()) {
m_rpcFakeConnection.reset();
}
- LogInfo("SERVER: Closing Server");
+ LogDebug("SERVER: Closing Server");
m_rpcUnixServer.CloseAll();
m_rpcFakeServer.CloseAll();//not needed
m_rpcUnixServer.DPL::EventSupport<ConnectionEstablishedEvent>::RemoveListener(this);
m_rpcFakeServer.DPL::EventSupport<ConnectionEstablishedEvent>::RemoveListener(this);
- LogInfo("SERVER: Server closed");
+ LogDebug("SERVER: Server closed");
Quit();
}
virtual void OnEventReceived(const AsyncCallEvent &event)
{
- LogInfo("SERVER: AsyncCallEvent received");
+ LogDebug("SERVER: AsyncCallEvent received");
int value;
event.GetArg0().ConsumeArg(value);
- LogInfo("SERVER: Result from client: " << value);
+ LogDebug("SERVER: Result from client: " << value);
// send back data to client (via fake)
// Emit RPC function call
DPL::RPCFunction proc;
proc.AppendArg(value);
- LogInfo("SERVER: Calling RPC function");
+ LogDebug("SERVER: Calling RPC function");
m_rpcUnixConnection->AsyncCall(proc);
}
{
// Save connection pointer
if (dynamic_cast<DPL::FakeRpcConnection *>(event.GetArg1())){
- LogInfo("SERVER: Acquiring Fake RPC connection");
+ LogDebug("SERVER: Acquiring Fake RPC connection");
m_rpcFakeConnection.reset(event.GetArg1());
m_rpcFakeConnection->DPL::EventSupport<AsyncCallEvent>::AddListener(this);
}
else{
- LogInfo("SERVER: Acquiring Unix RPC connection");
+ LogDebug("SERVER: Acquiring Unix RPC connection");
m_rpcUnixConnection.reset(event.GetArg1());
//this is not used on this side
// m_rpcUnixConnection->DPL::EventSupport<AsyncCallEvent>::AddListener(this);
: Application(argc, argv, "rpc")
{
// Attach RPC server listeners
- LogInfo("SERVER: Attaching connection established event");
+ LogDebug("SERVER: Attaching connection established event");
m_rpcUnixServer.DPL::EventSupport<ConnectionEstablishedEvent>::AddListener(this);
m_rpcFakeServer.DPL::EventSupport<ConnectionEstablishedEvent>::AddListener(this);
// Self touch
- LogInfo("SERVER: Touching controller");
+ LogDebug("SERVER: Touching controller");
Touch();
// Open RPC server
- LogInfo("SERVER: Opening server RPC");
+ LogDebug("SERVER: Opening server RPC");
m_rpcUnixServer.Open(UNIX_RPC_NAME);
m_rpcFakeServer.Open(FAKE_RPC_NAME);
// Run RPC client in thread
- LogInfo("SERVER: Starting RPC client thread");
+ LogDebug("SERVER: Starting RPC client thread");
m_thread.Run();
// Quit application automatically in few seconds
- LogInfo("SERVER: Sending control timed events");
+ LogDebug("SERVER: Sending control timed events");
DPL::ControllerEventHandler<CloseThreadEvent>::PostTimedEvent(CloseThreadEvent(), 2);
DPL::ControllerEventHandler<QuitEvent>::PostTimedEvent(QuitEvent(), 3);
}
virtual ~MyApplication()
{
// Quit thread
- LogInfo("SERVER: Quitting thread");
+ LogDebug("SERVER: Quitting thread");
}
};
int main(int argc, char *argv[])
{
- LogInfo("Starting");
+ LogDebug("Starting");
MyApplication app(argc, argv);
return app.Exec();
}
(void)event;
// Heart beat
- LogInfo("* Got metronome signal *");
+ LogDebug("* Got metronome signal *");
}
virtual void OnEventReceived(const DPL::AbstractRPCConnectionEvents::ConnectionClosedEvent &event)
{
(void)event;
- LogInfo("Connection closed");
+ LogDebug("Connection closed");
// Must quit
Quit();
{
(void)event;
- LogInfo("Connection broken");
+ LogDebug("Connection broken");
// Must quit
Quit();
virtual void OnEventReceived(const DPL::AbstractRPCConnectorEvents::ConnectionEstablishedEvent &event)
{
// Save connection pointer
- LogInfo("Connected to metronome server");
+ LogDebug("Connected to metronome server");
m_rpcConnection.reset(event.GetArg1());
// Attach event listeners
m_rpcClient.Open("127.0.0.1", 12345);
// Started
- LogInfo("Metronome client started");
+ LogDebug("Metronome client started");
}
virtual ~MetronomeClientApplication()
{
(void)event;
- LogInfo("Connection closed");
+ LogDebug("Connection closed");
// Remove connection from list
RemoveConnection(static_cast<DPL::AbstractRPCConnection *>(event.GetSender()));
{
(void)event;
- LogInfo("Connection broken");
+ LogDebug("Connection broken");
// Remove connection from list
RemoveConnection(static_cast<DPL::AbstractRPCConnection *>(event.GetSender()));
virtual void OnEventReceived(const DPL::AbstractRPCConnectorEvents::ConnectionEstablishedEvent &event)
{
// Save connection pointer
- LogInfo("New connection");
+ LogDebug("New connection");
// Add nre connection to list
AddConnection(event.GetArg1());
DPL::ControllerEventHandler<SignalEvent>::PostTimedEvent(SignalEvent(), HEART_BEAT_INTERVAL);
// Started
- LogInfo("Metronome server started");
+ LogDebug("Metronome server started");
}
virtual ~MetronomeServerApplication()
{
(void)event;
- LogInfo("CLIENT: AsyncCallEvent received");
+ LogDebug("CLIENT: AsyncCallEvent received");
int value;
event.GetArg0().ConsumeArg(value);
- LogInfo("CLIENT: Result from server: " << value);
+ LogDebug("CLIENT: Result from server: " << value);
}
virtual void OnEventReceived(const DPL::AbstractRPCConnectionEvents::ConnectionClosedEvent &event)
{
(void)event;
- LogInfo("CLIENT: ConnectionClosedEvent received");
+ LogDebug("CLIENT: ConnectionClosedEvent received");
}
virtual void OnEventReceived(const DPL::AbstractRPCConnectionEvents::ConnectionBrokenEvent &event)
{
(void)event;
- LogInfo("CLIENT: ConnectionBrokenEvent received");
+ LogDebug("CLIENT: ConnectionBrokenEvent received");
}
virtual void OnEventReceived(const DPL::AbstractRPCConnectorEvents::ConnectionEstablishedEvent &event)
{
// Save connection pointer
- LogInfo("CLIENT: Acquiring new connection");
+ LogDebug("CLIENT: Acquiring new connection");
m_rpcConnection.reset(event.GetArg1());
// Attach listener to new connection
- LogInfo("CLIENT: Attaching connection event listeners");
+ LogDebug("CLIENT: Attaching connection event listeners");
m_rpcConnection->DPL::EventSupport<DPL::AbstractRPCConnectionEvents::AsyncCallEvent>::AddListener(this);
m_rpcConnection->DPL::EventSupport<DPL::AbstractRPCConnectionEvents::ConnectionClosedEvent>::AddListener(this);
m_rpcConnection->DPL::EventSupport<DPL::AbstractRPCConnectionEvents::ConnectionBrokenEvent>::AddListener(this);
- LogInfo("CLIENT: Connection established");
+ LogDebug("CLIENT: Connection established");
// Emit RPC function call
DPL::RPCFunction proc;
proc.AppendArg((int)1111);
- LogInfo("CLIENT: Calling RPC function");
+ LogDebug("CLIENT: Calling RPC function");
m_rpcConnection->AsyncCall(proc);
}
virtual int ThreadEntry()
{
// Attach RPC listeners
- LogInfo("CLIENT: Attaching connection established event");
+ LogDebug("CLIENT: Attaching connection established event");
m_rpcClient.DPL::EventSupport<DPL::AbstractRPCConnectorEvents::ConnectionEstablishedEvent>::AddListener(this);
// Open connection to server
- LogInfo("CLIENT: Opening connection to RPC");
+ LogDebug("CLIENT: Opening connection to RPC");
m_rpcClient.Open(RPC_NAME);
// Start message loop
- LogInfo("CLIENT: Starting thread event loop");
+ LogDebug("CLIENT: Starting thread event loop");
int ret = Exec();
// Detach RPC listeners
if (m_rpcConnection.get())
{
- LogInfo("CLIENT: Detaching RPC connection events");
+ LogDebug("CLIENT: Detaching RPC connection events");
m_rpcConnection->DPL::EventSupport<DPL::AbstractRPCConnectionEvents::AsyncCallEvent>::RemoveListener(this);
m_rpcConnection->DPL::EventSupport<DPL::AbstractRPCConnectionEvents::ConnectionClosedEvent>::RemoveListener(this);
m_rpcConnection->DPL::EventSupport<DPL::AbstractRPCConnectionEvents::ConnectionBrokenEvent>::RemoveListener(this);
- LogInfo("CLIENT: Resetting connection");
+ LogDebug("CLIENT: Resetting connection");
m_rpcConnection.reset();
}
// Detach RPC client listener
- LogInfo("CLIENT: Detaching connection established event");
+ LogDebug("CLIENT: Detaching connection established event");
m_rpcClient.DPL::EventSupport<DPL::AbstractRPCConnectorEvents::ConnectionEstablishedEvent>::RemoveListener(this);
// Close RPC
- LogInfo("CLIENT: Closing RPC client");
+ LogDebug("CLIENT: Closing RPC client");
m_rpcClient.CloseAll();
// Done
{
(void)event;
- LogInfo("SERVER: AsyncCallEvent received");
+ LogDebug("SERVER: AsyncCallEvent received");
int value;
event.GetArg0().ConsumeArg(value);
- LogInfo("SERVER: Result from client: " << value);
+ LogDebug("SERVER: Result from client: " << value);
}
virtual void OnEventReceived(const DPL::AbstractRPCConnectionEvents::ConnectionClosedEvent &event)
{
(void)event;
- LogInfo("SERVER: ConnectionClosedEvent received");
+ LogDebug("SERVER: ConnectionClosedEvent received");
// Close RPC now
- LogInfo("SERVER: Closing RPC connection on event...");
+ LogDebug("SERVER: Closing RPC connection on event...");
// Detach RPC connection listeners
if (m_rpcConnection.get())
{
- LogInfo("SERVER: Detaching connection events");
+ LogDebug("SERVER: Detaching connection events");
m_rpcConnection->DPL::EventSupport<DPL::AbstractRPCConnectionEvents::AsyncCallEvent>::RemoveListener(this);
m_rpcConnection->DPL::EventSupport<DPL::AbstractRPCConnectionEvents::ConnectionClosedEvent>::RemoveListener(this);
m_rpcConnection->DPL::EventSupport<DPL::AbstractRPCConnectionEvents::ConnectionBrokenEvent>::RemoveListener(this);
}
- LogInfo("SERVER: RPC connection closed");
+ LogDebug("SERVER: RPC connection closed");
- LogInfo("SERVER: Closing RPC on event...");
+ LogDebug("SERVER: Closing RPC on event...");
m_rpcServer.CloseAll();
- LogInfo("SERVER: RPC closed");
+ LogDebug("SERVER: RPC closed");
}
virtual void OnEventReceived(const DPL::AbstractRPCConnectionEvents::ConnectionBrokenEvent &event)
{
(void)event;
- LogInfo("SERVER: ConnectionBrokenEvent received");
+ LogDebug("SERVER: ConnectionBrokenEvent received");
}
virtual void OnEventReceived(const DPL::AbstractRPCConnectorEvents::ConnectionEstablishedEvent &event)
{
// Save connection pointer
- LogInfo("SERVER: Acquiring RPC connection");
+ LogDebug("SERVER: Acquiring RPC connection");
m_rpcConnection.reset(event.GetArg1());
// Attach event listeners
- LogInfo("SERVER: Attaching connection listeners");
+ LogDebug("SERVER: Attaching connection listeners");
m_rpcConnection->DPL::EventSupport<DPL::AbstractRPCConnectionEvents::AsyncCallEvent>::AddListener(this);
m_rpcConnection->DPL::EventSupport<DPL::AbstractRPCConnectionEvents::ConnectionClosedEvent>::AddListener(this);
m_rpcConnection->DPL::EventSupport<DPL::AbstractRPCConnectionEvents::ConnectionBrokenEvent>::AddListener(this);
- LogInfo("SERVER: Connection established");
+ LogDebug("SERVER: Connection established");
// Emit RPC function call
DPL::RPCFunction proc;
proc.AppendArg((int)2222);
- LogInfo("SERVER: Calling RPC function");
+ LogDebug("SERVER: Calling RPC function");
m_rpcConnection->AsyncCall(proc);
}
: Application(argc, argv, "rpc")
{
// Attach RPC server listeners
- LogInfo("SERVER: Attaching connection established event");
+ LogDebug("SERVER: Attaching connection established event");
m_rpcServer.DPL::EventSupport<DPL::AbstractRPCConnectorEvents::ConnectionEstablishedEvent>::AddListener(this);
// Self touch
- LogInfo("SERVER: Touching controller");
+ LogDebug("SERVER: Touching controller");
Touch();
// Open RPC server
- LogInfo("SERVER: Opening server RPC");
+ LogDebug("SERVER: Opening server RPC");
m_rpcServer.Open(RPC_NAME);
// Run RPC client in thread
- LogInfo("SERVER: Starting RPC client thread");
+ LogDebug("SERVER: Starting RPC client thread");
m_thread.Run();
// Quit application automatically in few seconds
- LogInfo("SERVER: Sending control timed events");
+ LogDebug("SERVER: Sending control timed events");
DPL::ControllerEventHandler<CloseThreadEvent>::PostTimedEvent(CloseThreadEvent(), 2);
DPL::ControllerEventHandler<QuitEvent>::PostTimedEvent(QuitEvent(), 3);
}
virtual ~MyApplication()
{
// Quit thread
- LogInfo("SERVER: Quitting thread");
+ LogDebug("SERVER: Quitting thread");
m_thread.Quit();
// Close RPC server
- LogInfo("SERVER: Closing RPC server");
+ LogDebug("SERVER: Closing RPC server");
m_rpcServer.CloseAll();
// Detach RPC server listener
int main(int argc, char *argv[])
{
- LogInfo("Starting");
+ LogDebug("Starting");
MyApplication app(argc, argv);
return app.Exec();
}
{
(void)argc;
(void)argv;
- LogInfo("Hello world!");
+ LogDebug("Hello world!");
return 0;
}
virtual void OnEventReceived(const DPL::AbstractSocketEvents::AcceptEvent &event)
{
(void)event;
- LogInfo("Accept event occurred");
+ LogDebug("Accept event occurred");
DPL::UnixSocket *client = static_cast<DPL::UnixSocket *>(m_socket.Accept());
- LogInfo("Accepted client remote address: " << client->GetRemoteAddress().ToString());
- LogInfo("Accepted client local address: " << client->GetLocalAddress().ToString());
+ LogDebug("Accepted client remote address: " << client->GetRemoteAddress().ToString());
+ LogDebug("Accepted client local address: " << client->GetLocalAddress().ToString());
delete client;
}
m_socket.DPL::EventSupport<DPL::AbstractSocketEvents::AcceptEvent>::AddListener(this);
// Create server
- LogInfo("Starting server...");
+ LogDebug("Starting server...");
m_socket.Bind(DPL::Address(SOCKET_NAME));
m_socket.Listen(5);
- LogInfo("Server started");
+ LogDebug("Server started");
- LogInfo("Server local address: " << m_socket.GetLocalAddress().ToString());
+ LogDebug("Server local address: " << m_socket.GetLocalAddress().ToString());
int result = Exec();
virtual void OnEventReceived(const DPL::AbstractSocketEvents::ConnectedEvent &event)
{
(void)event;
- LogInfo("Connected event occurred");
+ LogDebug("Connected event occurred");
}
public:
Touch();
// Start threaded server
- LogInfo("Running threaded server");
+ LogDebug("Running threaded server");
// Run server in thread
thread.Run();
- LogInfo("Waiting for server to start...");
+ LogDebug("Waiting for server to start...");
sleep(1);
// Connect to server
virtual void OnEventReceived(const DPL::AbstractSocketEvents::ConnectedEvent &event)
{
(void)event;
- LogInfo("Connected!");
+ LogDebug("Connected!");
// Send request
DPL::BinaryQueue data;
virtual void OnEventReceived(const DPL::AbstractSocketEvents::ReadEvent &event)
{
(void)event;
- LogInfo("Read!");
+ LogDebug("Read!");
DPL::BinaryQueueAutoPtr data = m_socket.Read(100); // Bad: DLOG cannot log more than about 450 bytes...
if (data->Empty())
{
- LogInfo("Connection closed!");
+ LogDebug("Connection closed!");
m_socket.Close();
// Done
MyApplication(int argc, char **argv)
: Application(argc, argv, "tcpsock")
{
- LogInfo("CTOR!");
+ LogDebug("CTOR!");
// Add listeners
m_socket.DPL::EventSupport<DPL::AbstractSocketEvents::ConnectedEvent>::AddListener(this);
// Connect
m_socket.Open();
- LogInfo("Connecting...");
+ LogDebug("Connecting...");
m_socket.Connect(DPL::Address("en.wikipedia.org", 80));
}
virtual ~MyApplication()
{
- LogInfo("DTOR!");
+ LogDebug("DTOR!");
// Remove listeners
m_socket.DPL::EventSupport<DPL::AbstractSocketEvents::ConnectedEvent>::RemoveListener(this);
virtual void OnEventReceived(const FirstEvent &event)
{
(void)event;
- LogInfo("First event occurred");
+ LogDebug("First event occurred");
}
virtual void OnEventReceived(const SecondEvent &event)
{
(void)event;
- LogInfo("Second event occurred");
+ LogDebug("Second event occurred");
}
};
struct stat buffer;
if (stat(databasePath.c_str(), &buffer) != 0) {
//Create fresh database
- LogInfo("Creating database " << databasePath);
+ LogDebug("Creating database " << databasePath);
std::fstream file;
file.open(CERTIFICATE_DB_SQL_PATH, std::ios_base::in);
}
// Destroy connection
- LogInfo("Destroying thread database connection: " << m_address);
+ LogDebug("Destroying thread database connection: " << m_address);
delete *Connection();
}
// Initialize SQL connection described in traits
- LogInfo("Attaching thread database connection: " << m_address);
+ LogDebug("Attaching thread database connection: " << m_address);
Connection() = new DPL::DB::SqlConnection(
m_address.c_str(), m_flags, options);
// It must not be in linger state yet
Assert(*Linger() == false);
- LogInfo("Detaching thread database connection: " << m_address);
+ LogDebug("Detaching thread database connection: " << m_address);
// Enter linger state
*Linger() = true;
const gchar* /*interfaceName*/,
const gchar* propertyName)
{
- LogInfo("InterfaceDispatcher onPropertyGet: " << propertyName);
+ LogDebug("InterfaceDispatcher onPropertyGet: " << propertyName);
return NULL;
}
const gchar* propertyName,
GVariant* /*value*/)
{
- LogInfo("InterfaceDispatcher onPropertySet: " << propertyName);
+ LogDebug("InterfaceDispatcher onPropertySet: " << propertyName);
return false;
}
G_CALLBACK(onNewConnection),
this);
- LogInfo("Server started at: "
+ LogDebug("Server started at: "
<< g_dbus_server_get_client_address(m_server));
}
ServerEvents::NewConnectionEvent event(
ConnectionPtr(new Connection(connection)));
- LogInfo("Emitting new connection event");
+ LogDebug("Emitting new connection event");
// TODO Blocking to allow object registration before any DBus messages are
// processed.
self->DPL::Event::EventSupport<ServerEvents::NewConnectionEvent>::
struct stat buffer;
if (stat(databasePath.c_str(), &buffer) != 0) {
//Create fresh database
- LogInfo("Creating database " << databasePath);
+ LogDebug("Creating database " << databasePath);
std::fstream file;
file.open(SECURITY_ORIGIN_DB_SQL_PATH, std::ios_base::in);
//register feature
{
- LogInfo(" |-- Registering feature " << feature.m_name);
+ LogDebug(" |-- Registering feature " << feature.m_name);
FeaturesList::Row row;
row.Set_FeatureName(DPL::FromUTF8String(feature.m_name));
int deviceCapID;
if (FeatureDAOReadOnly::isDeviceCapabilityInstalled(*itdev)) {
- LogInfo(" | |--DeviceCap " << *itdev <<
+ LogDebug(" | |--DeviceCap " << *itdev <<
" already installed!");
WRT_DB_SELECT(select,
deviceCapID =
select->GetSingleValue<DeviceCapabilities::DeviceCapID>();
} else {
- LogInfo(" | |--Register DeviceCap: " << *itdev);
+ LogDebug(" | |--Register DeviceCap: " << *itdev);
DeviceCapabilities::Row row;
row.Set_DeviceCapName(DPL::FromUTF8String(*itdev));
whiteURI.strIRI = i->Get_uri();
whiteURI.bSubDomains = i->Get_subdomain_access();
resultList.push_back(whiteURI);
- LogInfo("[uri] : " << whiteURI.strIRI <<
+ LogDebug("[uri] : " << whiteURI.strIRI <<
", [subdomain] : " << whiteURI.bSubDomains);
}
return resultList;
if (isPluginInstalled(metafile.m_libraryName)) {
handle = PluginDAO(metafile.m_libraryName).getPluginHandle();
- LogInfo(" >> Library " << metafile.m_libraryName <<
+ LogDebug(" >> Library " << metafile.m_libraryName <<
" is already registered. Handle: " << handle);
} else {
LogDebug("Register Plugin: " << metafile.m_libraryName);
&WrtDatabase::interface());
if (!isPluginInstalled(pluginHandle)) {
- LogInfo("PluginHandle is invalid. Handle: " << pluginHandle);
+ LogDebug("PluginHandle is invalid. Handle: " << pluginHandle);
return;
} else {
using namespace DPL::DB::ORM;
g_type_init();
g_thread_init(NULL);
- LogInfo("Starting");
+ LogDebug("Starting");
elm_init(argc, argv);
}
int id;
Foo(int i = 0) : id(i)
{
- LogInfo("Foo: ctor: " << id);
+ LogDebug("Foo: ctor: " << id);
}
~Foo()
{
- LogInfo("Foo: dtor: " << id);
+ LogDebug("Foo: dtor: " << id);
g_wasFooDeleted = true;
}
void Bar()
{
- LogInfo("Foo: bar");
+ LogDebug("Foo: bar");
}
};
protected:
virtual int ThreadEntry()
{
- LogInfo("In thread");
+ LogDebug("In thread");
RUNNER_ASSERT(!g_foo);
RUNNER_ASSERT(g_foo.IsNull());
WrtDB::WrtDatabase::attachToThreadRW();
CustomHandlerDB::Interface::attachDatabaseRW();
- LogInfo("Starting tests");
+ LogDebug("Starting tests");
int status = DPL::Test::TestRunnerSingleton::Instance().ExecTestRunner(argc,
argv);
{
LoopControl::init_loop(argc, argv);
- LogInfo("Running tests");
+ LogDebug("Running tests");
int status = DPL::Test::TestRunnerSingleton::Instance().ExecTestRunner(argc,
argv);
void OnDelegateTest(const int &k)
{
- LogInfo("Got delegate call");
+ LogDebug("Got delegate call");
g_delegateTest = k;
}
{
event.GetArg0() (); //calling intercontext delegate
if (++m_reuseCount < ReuseCount) {
- LogInfo("[Send] Reuse: " << m_reuseCount);
+ LogDebug("[Send] Reuse: " << m_reuseCount);
DPL::Event::ControllerEventHandler<ReuseCountEvent>::PostEvent(
event);
}
RUNNER_TEST(tagsFromSystemLocales)
{
- LogInfo("Generating tags from system locales");
+ LogDebug("Generating tags from system locales");
char* currlocals = vconf_get_str(VCONFKEY_LANGSET);
LogDebug("Locales fetched from system settings: " << currlocals);
RUNNER_TEST(tagsFromGivenLocales)
{
- LogInfo("Generating tags from given locales");
+ LogDebug("Generating tags from given locales");
const char *locales1 = "it_IT.UTF-8", *locales2="en_GB";
RUNNER_TEST(tagsFromNullLocales)
{
- LogInfo("Generating tags when NULL locales given");
+ LogDebug("Generating tags when NULL locales given");
LanguageTagsProviderSingleton::Instance().setLanguageTagsFromLocales(NULL);
LanguageTags ltlist = LanguageTagsProviderSingleton::Instance().getLanguageTags();
RUNNER_TEST(tagsFromGivenTagList)
{
- LogInfo("Copying given tags list");
+ LogDebug("Copying given tags list");
LogDebug("Correct full list (with default values)");
LanguageTags correct;
RUNNER_TEST(tagsFromEmptyList)
{
- LogInfo("Generating tags when empty tag list given");
+ LogDebug("Generating tags when empty tag list given");
LanguageTags input;
LanguageTagsProviderSingleton::Instance().setLanguageTags(input);
RUNNER_TEST(defaultWidgetLocale)
{
- LogInfo("Adding default widget locales to language tags list");
+ LogDebug("Adding default widget locales to language tags list");
LanguageTags input;
input.push_back(L"de-DE");
int main (int argc, char *argv[])
{
- LogInfo("Starting miscellaneous unit tests");
+ LogDebug("Starting miscellaneous unit tests");
int status = DPL::Test::TestRunnerSingleton::Instance().ExecTestRunner(argc, argv);
return status;
m_output(output),
m_dataSize(dataSize)
{
- LogInfo("Thread created");
+ LogDebug("Thread created");
}
protected:
virtual int ThreadEntry()
{
- LogInfo("Entering copy thread");
+ LogDebug("Entering copy thread");
Try
{
return 0;
}
- LogInfo("Copy finished");
+ LogDebug("Copy finished");
return 0;
}
};
// Create and wait for notification. Make sure that the thread/controller 0
// is created first
- LogInfo("Creating controllers");
+ LogDebug("Creating controllers");
for (size_t i = 0; i < MAX_THREADS; ++i) {
controller[i] = new ShmController4(&waitable[i]);
Wait(waitable[i]);
MTSharedObjectPtr singleton = SharedObjectSingleton::Instance();
for (size_t repeats = 0; repeats < SINGLETON_TEST_REPEATS; ++repeats) {
- LogInfo("%%%%%%%%%%%%%%%%%%%%%");
- LogInfo("Iteration " << repeats + 1 << " of " << SINGLETON_TEST_REPEATS);
+ LogDebug("%%%%%%%%%%%%%%%%%%%%%");
+ LogDebug("Iteration " << repeats + 1 << " of " << SINGLETON_TEST_REPEATS);
singleton->Clear();
// add listeners
- LogInfo("Adding listeners");
+ LogDebug("Adding listeners");
for (size_t i = 0; i < MAX_THREADS; ++i) {
controller[i]->PostEvent(ShmController4::ADD_LISTENERS);
}
RUNNER_ASSERT(checkArray[2] == 0);
// change
- LogInfo("Setting property 0");
+ LogDebug("Setting property 0");
sho->SetProperty<0>(1);
// wait for confirmations
MultipleWait(waitable);
// change
- LogInfo("Setting property 1");
+ LogDebug("Setting property 1");
sho->SetProperty<1>(11);
// wait for confirmations
MultipleWait(waitable);
// change
- LogInfo("Setting property 2");
+ LogDebug("Setting property 2");
sho->SetProperty<2>('a');
// wait for confirmations
MultipleWait(waitable);
// change
- LogInfo("Setting property 3");
+ LogDebug("Setting property 3");
sho->SetProperty<3>(array);
// wait for confirmations
MultipleWait(waitable);
// remove listeners
- LogInfo("Removing listeners");
+ LogDebug("Removing listeners");
for (size_t i = 0; i < MAX_THREADS; ++i) {
controller[i]->PostEvent(ShmController4::REMOVE_LISTENERS);
}
MultipleWait(waitable);
// check if listeners array is empty
- LogInfo("Checking listeners");
+ LogDebug("Checking listeners");
for (size_t i = 0; i < MAX_THREADS; ++i) {
LISTENER_ASSERT(0);
LISTENER_ASSERT(1);
// Destroy controllers and wait for confirmation. Make sure that
// thread/controller 0 is destroyed in the end
- LogInfo("Destroying controllers");
+ LogDebug("Destroying controllers");
for (int i = MAX_THREADS - 1; i >= 0; --i) {
controller[i]->PostEvent(DESTROY_EVENT);
Wait(waitable[i]);
* This is to properly close all waitable handles opened by
* SharedObject in thread 0.
*/
- LogInfo("Destroying singleton");
+ LogDebug("Destroying singleton");
controller[i]->PostEvent(ShmController4::DESTROY_SINGLETON);
Wait(waitable[i]);
}
void StepOne()
{
- LogInfo("Step one");
+ LogDebug("Step one");
}
void StepTwo()
{
- LogInfo("Step two");
+ LogDebug("Step two");
}
void StepThree()
{
- LogInfo("Step three");
+ LogDebug("Step three");
}
public: