1 /*

     2 * Copyright (c) 2010 Nokia Corporation and/or its subsidiary(-ies).

     3 * All rights reserved.

     4 * This component and the accompanying materials are made available

     5 * under the terms of "Eclipse Public License v1.0"

     6 * which accompanies this distribution, and is available

     7 * at the URL "http://www.eclipse.org/legal/epl-v10.html".

     8 *

     9 * Initial Contributors:

    10 * Nokia Corporation - initial contribution.

    11 *

    12 * Contributors:

    13 *

    14 * Description: RmsExtensionPlugin unit tests

    15 *

    16 */

    17 

    18 #include <string>

    19 #include "TestHarness.h"

    20 #include "javacommonutils.h"

    21 #include "commsmessage.h"

    22 #include "comms.h"

    23 

    24 #include "rmsextensionplugin.h"

    25 

    26 using namespace java::rms;

    27 using namespace java::util;

    28 

    29 class TestRmsExtensionPlugin : public RmsExtensionPlugin

    30 {

    31 public:

    32     TestRmsExtensionPlugin() : mRecordChangeMsgs(0), mListenerCountMsgs(0) {};

    33     virtual ~TestRmsExtensionPlugin() {};

    34 

    35     using RmsExtensionPlugin::addListener;

    36     using RmsExtensionPlugin::removeListener;

    37     using RmsExtensionPlugin::notifyListeners;

    38     using RmsExtensionPlugin::sendListenerCount;

    39     using RmsExtensionPlugin::createListenerCountMsg;

    40     virtual int send(CommsMessage& aMessage)

    41     {

    42         int msgId = aMessage.getMessageId();

    43         int rc = 0;

    44         switch (msgId)

    45         {

    46         case MSG_ID_RECORD_CHANGE:

    47             mRecordChangeMsgs++;

    48             break;

    49         case MSG_ID_LISTENER_COUNT:

    50             mListenerCountMsgs++;

    51             break;

    52         default:

    53             rc = aMessage.getMessageId();

    54         }

    55         return rc;

    56     };

    57 

    58     using RmsExtensionPlugin::mListeners;

    59     using RmsExtensionPlugin::listenersIterator;

    60     int mRecordChangeMsgs;

    61     int mListenerCountMsgs;

    62 };

    63 

    64 TEST_GROUP(TestMethods)

    65 {

    66     TEST_SETUP()

    67     {

    68     }

    69 

    70     TEST_TEARDOWN()

    71     {

    72     }

    73 };

    74 

    75 TEST(TestMethods, addRemoveListener)

    76 {

    77     TestRmsExtensionPlugin rms;

    78     CHECK(rms.mListeners.size() == 0);

    79 

    80     rms.addListener("aaa", 1);

    81     CHECK(rms.mListeners.size() == 1);

    82 

    83     TestRmsExtensionPlugin::listenersIterator iter = rms.mListeners.find("aaa");

    84     CHECK(iter->second.size() == 1);

    85 

    86     rms.removeListener("aaa", 1);

    87     CHECK(rms.mListeners.size() == 0);

    88 }

    89 

    90 TEST(TestMethods, addSameListener)

    91 {

    92     TestRmsExtensionPlugin rms;

    93     CHECK(rms.mListeners.size() == 0);

    94 

    95     rms.addListener("aaa", 1);

    96     rms.addListener("aaa", 1);

    97     rms.addListener("aaa", 1);

    98     CHECK(rms.mListeners.size() == 1);

    99 

   100     TestRmsExtensionPlugin::listenersIterator iter = rms.mListeners.find("aaa");

   101     CHECK(iter->second.size() == 3);

   102 

   103     rms.removeListener("aaa", 1);

   104     iter = rms.mListeners.find("aaa");

   105     CHECK(iter->second.size() == 2);

   106 

   107     rms.removeListener("aaa", 1);

   108     rms.removeListener("aaa", 1);

   109     CHECK(iter->second.size() == 0);

   110 }

   111 

   112 TEST(TestMethods, manyListenersOneName)

   113 {

   114     TestRmsExtensionPlugin rms;

   115     CHECK(rms.mListeners.size() == 0);

   116 

   117     // multiple listeners for one name

   118     for (int i = 0; i < 10; i++)

   119     {

   120         rms.addListener("aaa", i);

   121     }

   122     CHECK(rms.mListeners.size() == 1);

   123     TestRmsExtensionPlugin::listenersIterator iter = rms.mListeners.find("aaa");

   124     CHECK(iter->second.size() == 10);

   125 

   126     for (int i = 0; i < 10; i++)

   127     {

   128         CHECK(iter->second.at(i) == i);

   129     }

   130 

   131     for (int i = 0; i < 10; i++)

   132     {

   133         rms.removeListener("aaa", i);

   134     }

   135     CHECK(rms.mListeners.size() == 0);

   136 }

   137 

   138 TEST(TestMethods, manyListenersManyNames)

   139 {

   140     TestRmsExtensionPlugin rms;

   141     CHECK(rms.mListeners.size() == 0);

   142 

   143     // multiple listeners for many names

   144     for (int i = 0; i < 10; i++)

   145     {

   146         for (int j = 0; j < 10; j++)

   147         {

   148             rms.addListener(JavaCommonUtils::intToString(i), j);

   149         }

   150     }

   151     CHECK(rms.mListeners.size() == 10);

   152 

   153 

   154     for (int i = 0; i < 10; i++)

   155     {

   156         TestRmsExtensionPlugin::listenersIterator iter = rms.mListeners.find(JavaCommonUtils::intToString(i));

   157         CHECK(iter->second.size() == 10);

   158         for (int j = 0; j < 10; j++)

   159         {

   160             CHECK(iter->second.at(j) == j);

   161         }

   162     }

   163 

   164     for (int i = 0; i < 10; i++)

   165     {

   166         for (int j = 0; j < 10; j++)

   167         {

   168             rms.removeListener(JavaCommonUtils::intToString(i), j);

   169         }

   170     }

   171     CHECK(rms.mListeners.size() == 0);

   172 }

   173 

   174 TEST(TestMethods, removeNonExistingListener)

   175 {

   176     TestRmsExtensionPlugin rms;

   177     CHECK(rms.mListeners.size() == 0);

   178 

   179     // no such name

   180     rms.removeListener("aaa", 1);

   181     CHECK(rms.mListeners.size() == 0);

   182 

   183     // no listener

   184     rms.addListener("aaa", 1);

   185     rms.removeListener("aaa", 2);

   186     CHECK(rms.mListeners.size() == 1);

   187     TestRmsExtensionPlugin::listenersIterator iter = rms.mListeners.find("aaa");

   188     CHECK(iter->second.size() == 1);

   189     rms.removeListener("aaa", 1);

   190     CHECK(rms.mListeners.size() == 0);

   191 }

   192 

   193 TEST(TestMethods, notifyListeners)

   194 {

   195     TestRmsExtensionPlugin rms;

   196     CHECK(rms.mRecordChangeMsgs == 0);

   197 

   198     CommsMessage msg;

   199     msg.setSender(0);

   200     msg.setMessageId(MSG_ID_RECORD_CHANGE);

   201 

   202     rms.addListener("aaa", 1);

   203     rms.addListener("aaa", 2);

   204 

   205     rms.notifyListeners("aaa", msg);

   206     CHECK(rms.mRecordChangeMsgs == 2);

   207 }

   208 

   209 TEST(TestMethods, noListeners)

   210 {

   211     TestRmsExtensionPlugin rms;

   212 

   213     CommsMessage msg;

   214     msg.setSender(0);

   215     msg.setMessageId(MSG_ID_RECORD_CHANGE);

   216 

   217     rms.notifyListeners("aaa", msg);

   218     CHECK(rms.mRecordChangeMsgs == 0);

   219 

   220     rms.addListener("aaa", 1);

   221     rms.addListener("aaa", 2);

   222     rms.addListener("bbb", 1);

   223 

   224     rms.notifyListeners("ccc", msg);

   225     CHECK(rms.mRecordChangeMsgs == 0);

   226 

   227     msg.setSender(1);

   228     rms.notifyListeners("bbb", msg);

   229     CHECK(rms.mRecordChangeMsgs == 0);

   230 

   231     TestRmsExtensionPlugin::listenersIterator iter = rms.mListeners.find("aaa");

   232     CHECK(iter->second.size() == 2);

   233 

   234     iter = rms.mListeners.find("bbb");

   235     CHECK(iter->second.size() == 1);

   236 }

   237 

   238 TEST(TestMethods, sendFails)

   239 {

   240     TestRmsExtensionPlugin rms;

   241 

   242     CommsMessage msg;

   243     msg.setSender(0);

   244     msg.setMessageId(-1);

   245 

   246     rms.addListener("aaa", 1);

   247     rms.addListener("aaa", 2);

   248 

   249     TestRmsExtensionPlugin::listenersIterator iter = rms.mListeners.find("aaa");

   250     CHECK(iter->second.size() == 2);

   251 

   252     rms.notifyListeners("aaa", msg);

   253     CHECK(rms.mListeners.size() == 0);

   254 }

   255 

   256 TEST(TestMethods, processMessage)

   257 {

   258     CommsMessage addMsg;

   259     addMsg.setSender(1);

   260     addMsg.setMessageId(MSG_ID_LISTENER_CHANGE);

   261     addMsg << "aaa" << ADD_LISTENER;

   262 

   263     CommsMessage removeMsg;

   264     removeMsg.setSender(1);

   265     removeMsg.setMessageId(MSG_ID_LISTENER_CHANGE);

   266     removeMsg << "aaa" << REMOVE_LISTENER;

   267 

   268     CommsMessage recordMsg;

   269     recordMsg.setSender(0);

   270     recordMsg.setMessageId(MSG_ID_RECORD_CHANGE);

   271     recordMsg << "aaa";

   272 

   273     TestRmsExtensionPlugin rms;

   274     // add listener

   275     rms.processMessage(addMsg);

   276     TestRmsExtensionPlugin::listenersIterator iter = rms.mListeners.find("aaa");

   277     CHECK(iter->second.size() == 1);

   278     CHECK(rms.mListenerCountMsgs == 1);

   279 

   280     // record modified

   281     rms.processMessage(recordMsg);

   282     CHECK(rms.mRecordChangeMsgs == 1);

   283 

   284     // remove listener

   285     rms.processMessage(removeMsg);

   286     CHECK(rms.mListeners.size() == 0);

   287 }

   288 

   289 TEST(TestMethods, unknownMessage)

   290 {

   291     CommsMessage dummy;

   292     dummy.setMessageId(666);

   293 

   294     TestRmsExtensionPlugin rms;

   295     rms.processMessage(dummy);

   296     CHECK(rms.mRecordChangeMsgs == 0);

   297     CHECK(rms.mListeners.size() == 0);

   298 }

   299 

   300 TEST(TestMethods, createListenerCountMsg)

   301 {

   302 

   303     TestRmsExtensionPlugin rms;

   304     CommsMessage msg = rms.createListenerCountMsg("aaa", 3);

   305 

   306     std::string name;

   307     int count;

   308     msg >> name >> count;

   309 

   310     CHECK(msg.getMessageId() == MSG_ID_LISTENER_COUNT);

   311     CHECK(msg.getModuleId() == PLUGIN_ID_RMS_C);

   312     CHECK(name == "aaa");

   313     CHECK(count == 3);

   314 }

   315 

   316 TEST(TestMethods, sendListenerCount)

   317 {

   318     TestRmsExtensionPlugin rms;

   319     rms.addListener("aaa", 1);

   320     rms.addListener("aaa", 2);

   321     CHECK(rms.mListenerCountMsgs == 0);

   322 

   323     CommsMessage dummy;

   324     // invalid name

   325     rms.sendListenerCount("bbb", dummy);

   326     CHECK(rms.mListenerCountMsgs == 0);

   327 

   328     // valid name

   329     rms.sendListenerCount("aaa", dummy);

   330     CHECK(rms.mListenerCountMsgs == 2);

   331 }

   332 

   333 

   334