]> pilppa.org Git - libplpbus.git/blobdiff - src/plpbus/BusMessage.cc
projects / libplpbus.git / blobdiff
? search:
summary | shortlog | log | commit | commitdiff | tree
raw | inline | side by side
cleanups
[libplpbus.git] / src / plpbus / BusMessage.cc
diff --git a/src/plpbus/BusMessage.cc b/src/plpbus/BusMessage.cc
index 16eaec47fd48faec3b964296d0183e0533e02541..99d32a0f9ac9d958dd52a1f25bd317619b3a7abe 100644 (file)
--- a/src/plpbus/BusMessage.cc
+++ b/src/plpbus/BusMessage.cc
@@ -40,24 +40,64 @@ BusMessage::BusMessage(long type_param,
 }
 
 BusMessage::~BusMessage() {
+       long                    cnt;
+       DataItemSequence        *seq;
+
+       log_debug("\n");
+       seq     = (DataItemSequence *)_dataItemSeq;
+       if (seq != NULL) {
+               cnt     = seq->length();
+/*
+               DataItem                *item;
+
+               for (long ii = 0; ii < cnt; ii++) {
+                       item    = seq[ii];
+                       log_debug("deleting BusMessage item:\n");
+                       printout_dataitem(ii, item);
+                       delete(item);
+               }
+*/
+               delete(seq);
+       }
+}
+
+int BusMessage::add_cstring_parameter(const char *arg_name_param, const char *value_param) {
+       long                    ln;
+       int                     ret_val;
+       DataItemSequence        *seq;
+       DataItem                *item;
+
+       ret_val = 0;
+       seq     = (DataItemSequence *)_dataItemSeq;
+       if (arg_name_param != NULL) {
+               ln                      = seq->length();
+               seq->length(ln + 1);
+               item                    = &((*seq)[ln]);
+               item->name              = arg_name_param;
+               item->str_value         = value_param;
+       }
+       else {
+               ret_val = -1;
+       }
+       return ret_val;
 }
 
 int BusMessage::add_string_parameter(string arg_name_param, string value_param)
 {
-       long                    length;
+       long                    ln;
        int                     ret_val;
-       DataItem                *item;
        DataItemSequence        *seq;
+       DataItem                *item;
 
+       //str   = (const char)"hooo";
        ret_val = 0;
        seq     = (DataItemSequence *)_dataItemSeq;
        if (arg_name_param.empty() == false) {
-               length          = seq->length();
-               item            = new DataItem();
-               item->name      = strdup(arg_name_param.c_str());
-               item->value     <<= strdup(value_param.c_str());
-               seq->length(length + 1);
-               (*seq)[length]  = *item;
+               ln              = seq->length();
+               seq->length(ln + 1);
+               item            = &((*seq)[ln]);
+               item->name      = arg_name_param.c_str();
+               item->str_value = value_param.c_str();
        }
        else {
                ret_val = -1;
@@ -65,23 +105,20 @@ int BusMessage::add_string_parameter(string arg_name_param, string value_param)
        return ret_val;
 }
 
-int BusMessage::add_long_parameter(const char *arg_name_param, long value_param)
+int BusMessage::add_long_parameter(string arg_name_param, long value_param)
 {
        long                    length;
        int                     ret_val;
-       DataItem                *item;
        DataItemSequence        *seq;
 
        ret_val = 0;
        seq     = (DataItemSequence *)_dataItemSeq;
-       if (arg_name_param != NULL) {
+       if (arg_name_param.empty() == false) {
                length          = seq->length();
-               item            = new DataItem();
-               item->name      = strdup(arg_name_param);
-               item->value     <<= value_param;
-
                seq->length(length + 1);
-               (*seq)[length]  = *item;
+               (*seq)[length].name     = arg_name_param.c_str();
+               (*seq)[length].value    <<= value_param;
+               (*seq)[length].str_value = "";
        }
        else {
                ret_val = -1;
@@ -93,19 +130,16 @@ int BusMessage::add_int_parameter(string arg_name_param, int value_param)
 {
        long                    length;
        int                     ret_val;
-       DataItem                *item;
        DataItemSequence        *seq;
 
        ret_val = 0;
        seq     = (DataItemSequence *)_dataItemSeq;
        if (arg_name_param.empty() == false) {
                length          = seq->length();
-               item            = new DataItem();
-               item->name      = strdup(arg_name_param.c_str());
-               item->value     <<= (long)value_param;
-
                seq->length(length + 1);
-               (*seq)[length]  = *item;
+               (*seq)[length].name     = arg_name_param.c_str();
+               (*seq)[length].value    <<= (long)value_param;
+               (*seq)[length].str_value = "";
        }
        else {
                ret_val = -1;
@@ -113,24 +147,21 @@ int BusMessage::add_int_parameter(string arg_name_param, int value_param)
        return ret_val;
 }
 
-int BusMessage::add_double_parameter(const char *arg_name_param, double value_param)
+int BusMessage::add_double_parameter(string arg_name_param, double value_param)
 {
        long                    length;
        int                     ret_val;
-       DataItem                *item;
        DataItemSequence        *seq;
 
        ret_val = 0;
        log_debug("add_double_parameter() started\n");
        seq     = (DataItemSequence *)_dataItemSeq;
-       if (arg_name_param != NULL) {
+       if (arg_name_param.empty() == false) {
                length          = seq->length();
-               item            = new DataItem();
-               item->name      = strdup(arg_name_param);
-               item->value     <<= (long)value_param;
-
                seq->length(length + 1);
-               (*seq)[length]  = *item;
+               (*seq)[length].name     = arg_name_param.c_str();
+               (*seq)[length].value    <<= (double)value_param;
+               (*seq)[length].str_value = "";
        }
        else {
                ret_val = -1;
@@ -139,23 +170,20 @@ int BusMessage::add_double_parameter(const char *arg_name_param, double value_pa
        return ret_val;
 }
 
-int BusMessage::add_float_parameter(const char *arg_name_param, float value_param)
+int BusMessage::add_float_parameter(string arg_name_param, float value_param)
 {
        long                    length;
        int                     ret_val;
-       DataItem                *item;
        DataItemSequence        *seq;
 
        ret_val = 0;
        seq     = (DataItemSequence *)_dataItemSeq;
-       if (arg_name_param != NULL) {
+       if (arg_name_param.empty() == false) {
                length          = seq->length();
-               item            = new DataItem();
-               item->name      = strdup(arg_name_param);
-               item->value     <<= (long)value_param;
-
                seq->length(length + 1);
-               (*seq)[length]  = *item;
+               (*seq)[length].name     = arg_name_param.c_str();
+               (*seq)[length].value    <<= (float)value_param;
+               (*seq)[length].str_value = "";
        }
        else {
                ret_val = -1;
@@ -186,6 +214,7 @@ long BusMessage::get_type(int *err_flg) {
        long    ret_val;
        long    res;
 
+       ret_val = -1;
        res     = get_long_parameter(CONST_MSG_ID_KEY_NAME, err_flg);
        if (*err_flg == PLP_OK) {
                ret_val = res;
@@ -203,7 +232,8 @@ string BusMessage::get_string_parameter(string arg_name_param, int *err_flg) {
        seq             = (DataItemSequence *)_dataItemSeq;
        item            = get_dataitem_by_param_name(seq, arg_name_param);
        if (item != NULL) {
-               item->value >>= CORBA::Any::to_string(ch, 0);
+               //item->value >>= CORBA::Any::to_string(ch, 0);
+               ch              = item->str_value;
                ret_val         = ch;
                *err_flg        = PLP_OK;
        }
@@ -215,6 +245,7 @@ long BusMessage::get_long_parameter(string arg_name_param, int *err_flg) {
        DataItem                *item;
        DataItemSequence        *seq;
 
+       ret_val         = 0;
        *err_flg        = PLP_ERR_DATA_NOT_FOUND;
        seq             = (DataItemSequence *)_dataItemSeq;
        item            = get_dataitem_by_param_name(seq, arg_name_param);
@@ -231,6 +262,7 @@ int BusMessage::get_int_parameter(string arg_name_param, int *err_flg) {
        DataItemSequence        *seq;
        long                    tmp;
 
+       ret_val         = 0;
        *err_flg        = PLP_ERR_DATA_NOT_FOUND;
        seq             = (DataItemSequence *)_dataItemSeq;
        item            = get_dataitem_by_param_name(seq, arg_name_param);
@@ -247,6 +279,7 @@ double BusMessage::get_double_parameter(string arg_name_param, int *err_flg) {
        DataItem        *item;
        DataItemSequence *seq;
 
+       ret_val         = 0;
        *err_flg        = PLP_ERR_DATA_NOT_FOUND;
        seq             = (DataItemSequence *)_dataItemSeq;
        item            = get_dataitem_by_param_name(seq, arg_name_param);
@@ -262,6 +295,7 @@ float BusMessage::get_float_parameter(string arg_name_param, int *err_flg) {
        DataItem        *item;
        DataItemSequence *seq;
 
+       ret_val         = 0;
        *err_flg        = PLP_ERR_DATA_NOT_FOUND;
        seq             = (DataItemSequence *)_dataItemSeq;
        item            = get_dataitem_by_param_name(seq, arg_name_param);
@@ -283,14 +317,6 @@ void BusMessage::printout_dataitem(long index, void *item) {
                        name    = dataitem->name;
                        kind    = dataitem->value.type()->kind();
                        switch(kind) {
-                               case tk_string:
-                                       {
-                                               const char *val;
-
-                                               dataitem->value >>= val;
-                                               log_debug("\t[%ld] %s: %s\n", index, name, val);
-                                       }
-                                       break;
                                case tk_long:
                                        {
                                                long    val;
@@ -316,6 +342,12 @@ void BusMessage::printout_dataitem(long index, void *item) {
                                        }
                                        break;
                                default:
+                                       {
+                                               const char *val;
+                                               val     = dataitem->str_value;
+                                               log_debug("\t[%ld] %s: %s\n", index, name, val);
+                                       }
+                                       break;
                                        log_error("\t[%ld], name: %s, value unknown\n", index, name);
                        }
                }
@@ -337,6 +369,7 @@ void BusMessage::printout() {
        count   = seq->length();
        log_debug("BusMessage.printout(): parameter count: %ld\n", count);
        for (long ii = 0; ii < count; ii++) {
+               printf("item[%ld]\n", ii);
                item    = (*seq)[ii];
                printout_dataitem(ii, &item);
        }
Unnamed repository; edit this file 'description' to name the repository.