lib: remove clock class priority map, use default clock value
[babeltrace.git] / plugins / utils / counter / counter.c
index bbcb82769590b4dd7f4bdecf676970c417f8d8e7..e782a7b7b58bdc760de8b84816eb2f32b881659c 100644 (file)
@@ -48,8 +48,6 @@ uint64_t get_total_count(struct counter *counter)
                counter->count.packet_begin +
                counter->count.packet_end +
                counter->count.inactivity +
-               counter->count.discarded_events +
-               counter->count.discarded_packets +
                counter->count.other;
 }
 
@@ -64,14 +62,6 @@ void print_count(struct counter *counter)
        PRINTF_COUNT("packet beginning", "packet beginnings", packet_begin);
        PRINTF_COUNT("packet end", "packet ends", packet_end);
        PRINTF_COUNT("inactivity", "inactivities", inactivity);
-       PRINTF_COUNT("discarded events notification",
-               "discarded events notifications", discarded_events_notifs);
-       PRINTF_COUNT("  known discarded event", "  known discarded events",
-               discarded_events);
-       PRINTF_COUNT("discarded packets notification",
-               "discarded packets notifications", discarded_packets_notifs);
-       PRINTF_COUNT("  known discarded packet", "  known discarded packets",
-               discarded_packets);
 
        if (counter->count.other > 0) {
                PRINTF_COUNT("  other (unknown) notification",
@@ -183,11 +173,12 @@ end:
        return ret;
 }
 
-void counter_port_connected(
+enum bt_component_status counter_port_connected(
                struct bt_private_component *component,
                struct bt_private_port *self_port,
                struct bt_port *other_port)
 {
+       enum bt_component_status status = BT_COMPONENT_STATUS_OK;
        struct counter *counter;
        struct bt_notification_iterator *iterator;
        struct bt_private_connection *connection;
@@ -200,7 +191,7 @@ void counter_port_connected(
        conn_status = bt_private_connection_create_notification_iterator(
                connection, &iterator);
        if (conn_status != BT_CONNECTION_STATUS_OK) {
-               counter->error = true;
+               status = BT_COMPONENT_STATUS_ERROR;
                goto end;
        }
 
@@ -208,6 +199,7 @@ void counter_port_connected(
 
 end:
        bt_put(connection);
+       return status;
 }
 
 enum bt_component_status counter_consume(struct bt_private_component *component)
@@ -215,18 +207,12 @@ enum bt_component_status counter_consume(struct bt_private_component *component)
        enum bt_component_status ret = BT_COMPONENT_STATUS_OK;
        struct counter *counter;
        enum bt_notification_iterator_status it_ret;
-       int64_t count;
        uint64_t notif_count;
        bt_notification_array notifs;
 
        counter = bt_private_component_get_user_data(component);
        BT_ASSERT(counter);
 
-       if (unlikely(counter->error)) {
-               ret = BT_COMPONENT_STATUS_ERROR;
-               goto end;
-       }
-
        if (unlikely(!counter->notif_iter)) {
                try_print_last(counter);
                ret = BT_COMPONENT_STATUS_END;
@@ -276,22 +262,6 @@ enum bt_component_status counter_consume(struct bt_private_component *component)
                        case BT_NOTIFICATION_TYPE_PACKET_END:
                                counter->count.packet_end++;
                                break;
-                       case BT_NOTIFICATION_TYPE_DISCARDED_EVENTS:
-                               counter->count.discarded_events_notifs++;
-                               count = bt_notification_discarded_events_get_count(
-                                       notif);
-                               if (count >= 0) {
-                                       counter->count.discarded_events += count;
-                               }
-                               break;
-                       case BT_NOTIFICATION_TYPE_DISCARDED_PACKETS:
-                               counter->count.discarded_packets_notifs++;
-                               count = bt_notification_discarded_packets_get_count(
-                                       notif);
-                               if (count >= 0) {
-                                       counter->count.discarded_packets += count;
-                               }
-                               break;
                        default:
                                counter->count.other++;
                        }
This page took 0.024475 seconds and 4 git commands to generate.