Create a gist now

Instantly share code, notes, and snippets.

@rvernica /acme.c
Created Feb 9, 2016

What would you like to do?
Download ZIP
Unified Split

Revisions

  1. rvernica revised this gist Feb 9, 2016. 1 changed file with 4 additions and 4 deletions.
    View
    8 acme.c
    @@ -35,9 +35,9 @@ static mmv_indom_t indoms[] = {
    static mmv_metric_t metrics[] = {
    { .name = "products.count",
    .item = 7,
    - .type = MMV_TYPE_U64,
    - .semantics = MMV_SEM_COUNTER,
    - .dimension = MMV_UNITS(0,0,1,0,0,PM_COUNT_ONE),
    + .type = MMV_TYPE_FLOAT,
    + .semantics = MMV_SEM_INSTANT,
    + .dimension = MMV_UNITS(1,0,0,PM_SPACE_BYTE,0,0),
    .indom = ACME_PRODUCTS_INDOM,
    .shorttext = "Acme factory product throughput",
    .helptext =
    @@ -112,7 +112,7 @@ main(int argc, char * argv[])
    /* update the memory mapped values for this one: */
    /* one more product produced and work time spent */
    mmv_inc_value(base, machine[product], working); /* API */
    - count[product]->ull += 1; /* or direct mmap update */
    + count[product]->ull = rand() - RAND_MAX / 2; /* or direct mmap update */
    /* all other products are "queued" for this time */
    for (i = 0; i < ACME_PRODUCTS_COUNT; i++)
  2. rvernica created this gist Feb 9, 2016.
    View
    125 acme.c
    @@ -0,0 +1,125 @@
    +/*
    + * Copyright (c) 2013 Red Hat.
    + *
    + * This program is free software; you can redistribute it and/or modify it
    + * under the terms of the GNU General Public License as published by the
    + * Free Software Foundation; either version 2 of the License, or (at your
    + * option) any later version.
    + *
    + * This program is distributed in the hope that it will be useful, but
    + * WITHOUT ANY WARRANTY; without even the implied warranty of MERCHANTABILITY
    + * or FITNESS FOR A PARTICULAR PURPOSE. See the GNU General Public License
    + * for more details.
    + */
    +
    +#include <pcp/pmapi.h>
    +#include <pcp/mmv_stats.h>
    +
    +static mmv_instances_t products[] = {
    + { .internal = 0, .external = "Anvils" },
    + { .internal = 1, .external = "Rockets" },
    + { .internal = 2, .external = "Giant_Rubber_Bands" },
    +};
    +#define ACME_PRODUCTS_INDOM 61
    +#define ACME_PRODUCTS_COUNT (sizeof(products)/sizeof(products[0]))
    +
    +static mmv_indom_t indoms[] = {
    + { .serial = ACME_PRODUCTS_INDOM,
    + .count = ACME_PRODUCTS_COUNT,
    + .instances = products,
    + .shorttext = "Acme products",
    + .helptext = "Most popular products produced by the Acme Corporation",
    + },
    +};
    +
    +static mmv_metric_t metrics[] = {
    + { .name = "products.count",
    + .item = 7,
    + .type = MMV_TYPE_U64,
    + .semantics = MMV_SEM_COUNTER,
    + .dimension = MMV_UNITS(0,0,1,0,0,PM_COUNT_ONE),
    + .indom = ACME_PRODUCTS_INDOM,
    + .shorttext = "Acme factory product throughput",
    + .helptext =
    +"Monotonic increasing counter of products produced in the Acme Corporation\n"
    +"factory since starting the Acme production application. Quality guaranteed.",
    + },
    + { .name = "products.time",
    + .item = 8,
    + .type = MMV_TYPE_U64,
    + .semantics = MMV_SEM_COUNTER,
    + .dimension = MMV_UNITS(0,1,0,0,PM_TIME_USEC,0),
    + .indom = ACME_PRODUCTS_INDOM,
    + .shorttext = "Machine time spent producing Acme products",
    + .helptext =
    +"Machine time spent producing Acme Corporation products. Does not include\n"
    +"time in queues waiting for production machinery.",
    + },
    + { .name = "products.queuetime",
    + .item = 10,
    + .type = MMV_TYPE_U64,
    + .semantics = MMV_SEM_COUNTER,
    + .dimension = MMV_UNITS(0,1,0,0,PM_TIME_USEC,0),
    + .indom = ACME_PRODUCTS_INDOM,
    + .shorttext = "Queued time while producing Acme products",
    + .helptext =
    +"Time spent in the queue waiting to build Acme Corporation products,\n"
    +"while some other Acme product was being built instead of this one.",
    + },
    +};
    +
    +#define INDOM_COUNT (sizeof(indoms)/sizeof(indoms[0]))
    +#define METRIC_COUNT (sizeof(metrics)/sizeof(metrics[0]))
    +#define ACME_CLUSTER 321 /* PMID cluster identifier */
    +
    +int
    +main(int argc, char * argv[])
    +{
    + void *base;
    + pmAtomValue *count[ACME_PRODUCTS_COUNT];
    + pmAtomValue *machine[ACME_PRODUCTS_COUNT];
    + pmAtomValue *inqueue[ACME_PRODUCTS_COUNT];
    + unsigned int working;
    + unsigned int product;
    + unsigned int i;
    +
    + base = mmv_stats_init("acme", ACME_CLUSTER, 0,
    + metrics, METRIC_COUNT, indoms, INDOM_COUNT);
    + if (!base) {
    + perror("mmv_stats_init");
    + return 1;
    + }
    +
    + for (i = 0; i < ACME_PRODUCTS_COUNT; i++) {
    + count[i] = mmv_lookup_value_desc(base,
    + "products.count", products[i].external);
    + machine[i] = mmv_lookup_value_desc(base,
    + "products.time", products[i].external);
    + inqueue[i] = mmv_lookup_value_desc(base,
    + "products.queuetime", products[i].external);
    + }
    +
    + while (1) {
    + /* choose a random number between 0-N -> product */
    + product = rand() % ACME_PRODUCTS_COUNT;
    +
    + /* assign a time spent "working" on this product */
    + working = rand() % 50000;
    +
    + /* pretend to "work" so process doesn't burn CPU */
    + usleep(working);
    +
    + /* update the memory mapped values for this one: */
    + /* one more product produced and work time spent */
    + mmv_inc_value(base, machine[product], working); /* API */
    + count[product]->ull += 1; /* or direct mmap update */
    +
    + /* all other products are "queued" for this time */
    + for (i = 0; i < ACME_PRODUCTS_COUNT; i++)
    + if (i != product)
    + mmv_inc_value(base, inqueue[i], working);
    + }
    +
    + mmv_stats_stop("acme", base);
    + return 0;
    +}