<?php
// RRDtool datasource plugin.
//     gauge:filename.rrd:ds_in:ds_out
//     filename.rrd:ds_in:ds_out
//     filename.rrd:ds_in:ds_out
//

include_once(dirname(__FILE__) . "/../ds-common.php");
include_once(dirname(__FILE__) . "/../database.php");

class WeatherMapDataSource_rrd extends WeatherMapDataSource
{

  function Init(&$map)
  {
    global $config;

    /*if ($map->context == 'cacti') {
      wm_debug("RRD DS: path_rra is " . $config["rra_path"] . " - your rrd pathname must be exactly this to use poller_output\n");
      // save away a couple of useful global SET variables
      $map->add_hint("cacti_path_rra", $config["rra_path"]);
      $map->add_hint("cacti_url", $config['url_path']);
    } */

    if (file_exists($map->rrdtool)) {
      if ((function_exists('is_executable')) && (!is_executable($map->rrdtool))) {
        wm_warn("RRD DS: RRDTool exists but is not executable? [WMRRD01]\n");
        return (FALSE);
      }
      $map->rrdtool_check = "FOUND";
      return (TRUE);
    }

    // normally, DS plugins shouldn't really pollute the logs
    // this particular one is important to most users though...
    if ($map->context == 'cli') {
      wm_warn("RRD DS: Can't find RRDTOOL. Check line 29 of the 'weathermap' script.\nRRD-based TARGETs will fail. [WMRRD02]\n");
    }
    if ($map->context == 'cacti') {    // unlikely to ever occur
      wm_warn("RRD DS: Can't find RRDTOOL. Check your Cacti config. [WMRRD03]\n");
    }

    return (FALSE);
  }

  function Recognise($targetstring)
  {
    if (preg_match("/^(.*\.rrd):([\-a-zA-Z0-9_]+):([\-a-zA-Z0-9_]+)$/", $targetstring, $matches)) {
      return TRUE;
    } else if (preg_match("/^(.*\.rrd)$/", $targetstring, $matches)) {
      return TRUE;
    } else {
      return FALSE;
    }
  }

  function wmrrd_read_from_poller_output($rrdfile, $cf, $start, $end, $dsnames, &$data, &$map, &$data_time, &$item)
  {
    global $config;

    wm_debug("RRD ReadData: poller_output style\n");

    if (isset($config)) {
      $pdo = weathermap_get_pdo();

      // take away the cacti bit, to get the appropriate path for the table
      // $db_rrdname = realpath($rrdfile);
      $path_rra   = $config["rra_path"];
      $db_rrdname = $rrdfile;
      $db_rrdname = str_replace($path_rra, "<path_rra>", $db_rrdname);
      wm_debug("******************************************************************\nChecking weathermap_data\n");
      foreach (array(IN, OUT) as $dir) {
        wm_debug("RRD ReadData: poller_output - looking for $dir value\n");
        if ($dsnames[$dir] != '-') {
          wm_debug("RRD ReadData: poller_output - DS name is " . $dsnames[$dir] . "\n");

          //					$SQL = "select * from weathermap_data where rrdfile='".mysql_real_escape_string($db_rrdname)."' and data_source_name='".mysql_real_escape_string($dsnames[$dir])."'";

          //					$SQLcheck = "select data_template_data.local_data_id from data_template_data,data_template_rrd where data_template_data.local_data_id=data_template_rrd.local_data_id and data_template_data.data_source_path='".mysql_real_escape_string($db_rrdname)."' and data_template_rrd.data_source_name='".mysql_real_escape_string($dsnames[$dir])."'";
          //					$SQLvalid = "select data_template_rrd.data_source_name from data_template_data,data_template_rrd where data_template_data.local_data_id=data_template_rrd.local_data_id and data_template_data.data_source_path='".mysql_real_escape_string($db_rrdname)."'";

          $statement_check  = $pdo->prepare("select data_template_data.local_data_id from data_template_data,data_template_rrd where data_template_data.local_data_id=data_template_rrd.local_data_id and data_template_data.data_source_path=? and data_template_rrd.data_source_name=?");
          $statement_valid  = $pdo->prepare("select data_template_rrd.data_source_name from data_template_data,data_template_rrd where data_template_data.local_data_id=data_template_rrd.local_data_id and data_template_data.data_source_path=?");
          $statement_search = $pdo->prepare("select * from weathermap_data where rrdfile=? and data_source_name=?");

          $statement_search->execute(array($db_rrdname, $dsnames[$dir]));
          $result = $statement_search->fetch(PDO::FETCH_ASSOC);

          $worst_time = time() - 8 * 60;
          //					$result = db_fetch_row($SQL);

          // OK, the straightforward query for data failed, let's work out why, and add the new data source if necessary
          if (!isset($result['id'])) {
            wm_debug("RRD ReadData: poller_output - Adding new weathermap_data row for $db_rrdname:" . $dsnames[$dir] . "\n");

            $statement_check->execute(array($db_rrdname, $dsnames[$dir]));
            $result = $statement_check->fetch(PDO::FETCH_ASSOC);
            //						$result = db_fetch_row($SQLcheck);
            if (!isset($result['local_data_id'])) {
              $fields = array();

              $statement_valid->execute(array($db_rrdname));
              $results = $statement_valid->fetchAll(PDO::FETCH_ASSOC);
              //                            $results = db_fetch_assoc($SQLvalid);
              foreach ($results as $result) {
                $fields[] = $result['data_source_name'];
              }
              if (count($fields) > 0) {
                wm_warn("RRD ReadData: poller_output: " . $dsnames[$dir] . " is not a valid DS name for $db_rrdname - valid names are: " . join(", ", $fields) . " [WMRRD07]\n");
              } else {
                wm_warn("RRD ReadData: poller_output: $db_rrdname is not a valid RRD filename within this Cacti install. <path_rra> is $path_rra [WMRRD08]\n");
              }
            } else {
              // add the new data source (which we just checked exists) to the table.
              // Include the local_data_id as well, to make life easier in poller_output
              // (and to allow the cacti: DS plugin to use the same table, too)
              wm_debug("RRD ReadData: poller_output - Adding new weathermap_data row for data source ID " . $result['local_data_id'] . "\n");
              $statement_insert = $pdo->prepare("INSERT INTO weathermap_data (rrdfile, data_source_name, sequence, local_data_id) VALUES (?,?, 0,?)");
              $statement_insert->execute(array($db_rrdname, $dsnames[$dir], $result['local_data_id']));

              //							$SQLins = "insert into weathermap_data (rrdfile, data_source_name, sequence, local_data_id) values ('".mysql_real_escape_string($db_rrdname)."','".mysql_real_escape_string($dsnames[$dir])."', 0,".$result['local_data_id'].")";
              //							db_execute($SQLins);
            }
          } else {  // the data table line already exists
            wm_debug("RRD ReadData: poller_output - found weathermap_data row\n");
            // if the result is valid, then use it
            if (($result['sequence'] > 2) && ($result['last_time'] > $worst_time)) {
              $data[$dir] = $result['last_calc'];
              $data_time  = $result['last_time'];
              wm_debug("RRD ReadData: poller_output - data looks valid\n");
            } else {
              $data[$dir] = 0;
              wm_debug("RRD ReadData: poller_output - data is either too old, or too new\n");
            }
            // now, we can use the local_data_id to get some other useful info
            // first, see if the weathermap_data entry *has* a local_data_id. If not, we need to update this entry.
            $ldi = 0;
            if (!isset($result['local_data_id']) || $result['local_data_id'] == 0) {
              $statement_check->execute(array($db_rrdname, $dsnames[$dir]));
              $r2 = $statement_check->fetch(PDO::FETCH_ASSOC);
              //							$r2 = db_fetch_row($SQLcheck);
              if (isset($r2['local_data_id'])) {
                $ldi = $r2['local_data_id'];
                wm_debug("RRD ReadData: updated  local_data_id for wmdata.id=" . $result['id'] . "to $ldi\n");
                // put that in now, so that we can skip this step next time
                $statement_update = $pdo->prepare("update weathermap_data set local_data_id=? where id=?");
                $statement_update->execute(array($r2['local_data_id'], $result['id']));

                //								db_execute("update weathermap_data set local_data_id=".$r2['local_data_id']." where id=".$result['id']);

              }
            } else {
              $ldi = $result['local_data_id'];
            }

            if ($ldi > 0) UpdateCactiData($item, $ldi);
          }
        } else {
          wm_debug("RRD ReadData: poller_output - DS name is '-'\n");
        }
      }
    } else {
      wm_warn("RRD ReadData: poller_output - Cacti environment is not right [WMRRD12]\n");
    }

    wm_debug("RRD ReadData: poller_output - result is " . ($data[IN] === NULL ? 'NULL' : $data[IN]) . "," . ($data[OUT] === NULL ? 'NULL' : $data[OUT]) . "\n");
    wm_debug("RRD ReadData: poller_output - ended\n");
  }

  function wmrrd_read_from_php_rrd($rrdfile, $cf, $start, $end, $dsnames, &$data, &$map, &$data_time, &$item)
  {
    // not yet implemented - use php-rrdtool to read rrd data. Should be quicker
    if ((1 == 0) && extension_loaded('RRDTool')) // fetch the values via the RRDtool Extension
    {
      // for the php-rrdtool module, we use an array instead...
      $rrdparams = array("AVERAGE", "--start", $start, "--end", $end);
      $rrdreturn = rrd_fetch($rrdfile, $rrdparams, count($rrdparams));
      print_r($rrdreturn);
      // XXX - figure out what to do with the results here
      $now = $rrdreturn['start'];
      $n   = 0;
      do {
        $now += $rrdreturn['step'];
        print "$now - ";
        for ($i = 0; $i < $rrdreturn['ds_cnt']; $i++) {
          print $rrdreturn['ds_namv'][$i] . ' = ' . $rrdreturn['data'][$n++] . " ";
        }
        print "\n";
      } while ($now <= $rrdreturn['end']);
    }
  }

  # rrdtool graph /dev/null -f "" -s now-30d -e now DEF:in=../rra/atm-sl_traffic_in_5498.rrd:traffic_in:AVERAGE DEF:out=../rra/atm-sl_traffic_in_5498.rrd:traffic_out:AVERAGE VDEF:avg_in=in,AVERAGE VDEF:avg_out=out,AVERAGE PRINT:avg_in:%lf PRINT:avg_out:%lf

  function wmrrd_read_from_real_rrdtool_aggregate($rrdfile, $cf, $aggregatefn, $start, $end, $dsnames, &$data, &$map, &$data_time, &$item)
  {

    wm_debug("RRD ReadData: VDEF style, for " . $item->my_type() . " " . $item->name . "\n");

    $extra_options = $map->get_hint("rrd_options");

    // Assemble an array of command args.
    // In a real programming language, we'd be able to pass this directly to exec()
    // However, this will at least allow us to put quotes around args that need them
    $args   = array();
    $args[] = "graph";
    $args[] = "/dev/null";
    $args[] = "-f";
    $args[] = "''";
    $args[] = "--start";
    $args[] = $start;
    $args[] = "--end";
    $args[] = $end;

    if ($map->daemon) {
      $args[] = "--daemon";
      $args[] = $map->daemon_args;
    }

    # assemble an appropriate RRDtool command line, skipping any '-' DS names.
    # $command = $map->rrdtool . " graph /dev/null -f ''  --start $start --end $end ";

    if ($dsnames[IN] != '-') {
      # $command .= "DEF:in=$rrdfile:".$dsnames[IN].":$cf ";
      # $command .= "VDEF:agg_in=in,$aggregatefn ";
      # $command .= "PRINT:agg_in:'IN %lf' ";

      $args[] = "DEF:in=$rrdfile:" . $dsnames[IN] . ":$cf";
      $args[] = "VDEF:agg_in=in,$aggregatefn";
      $args[] = "PRINT:agg_in:'IN %lf'";
    }

    if ($dsnames[OUT] != '-') {
      # $command .= "DEF:out=$rrdfile:".$dsnames[OUT].":$cf ";
      # $command .= "VDEF:agg_out=out,$aggregatefn ";
      # $command .= "PRINT:agg_out:'OUT %lf' ";

      $args[] = "DEF:out=$rrdfile:" . $dsnames[OUT] . ":$cf";
      $args[] = "VDEF:agg_out=out,$aggregatefn";
      $args[] = "PRINT:agg_out:'OUT %lf'";
    }

    $command = $map->rrdtool;
    foreach ($args as $arg) {
      if (strchr($arg, " ") != FALSE) {
        $command .= ' "' . $arg . '"';
      } else {
        $command .= ' ' . $arg;
      }
    }
    $command .= " " . $extra_options;

    wm_debug("RRD ReadData: Running: $command\n");
    $pipe = popen($command, "r");

    $lines     = array();
    $count     = 0;
    $linecount = 0;

    if (isset($pipe)) {
      // fgets($pipe, 4096); // skip the blank line
      $buffer  = '';
      $data_ok = FALSE;

      while (!feof($pipe)) {
        $line = fgets($pipe, 4096);
        // there might (pre-1.5) or might not (1.5+) be a leading blank line
        // we don't want to count it if there is
        if (trim($line) != "") {

          wm_debug("> " . $line);
          $buffer  .= $line;
          $lines[] = $line;
          $linecount++;
        }
      }
      pclose($pipe);

      if ($linecount > 1) {
        foreach ($lines as $line) {
          if (preg_match('/^\'(IN|OUT)\s(\-?\d+[\.,]?\d*e?[+-]?\d*:?)\'$/i', $line, $matches)) {
            wm_debug("MATCHED: " . $matches[1] . " " . $matches[2] . "\n");
            if ($matches[1] == 'IN') $data[IN] = floatval($matches[2]);
            if ($matches[1] == 'OUT') $data[OUT] = floatval($matches[2]);
            $data_ok = TRUE;
          }
        }
        if ($data_ok) {
          if ($data[IN] === NULL) $data[IN] = 0;
          if ($data[OUT] === NULL) $data[OUT] = 0;
        }
      } else {
        wm_warn("Not enough output from RRDTool. [WMRRD09]\n");
      }
    } else {
      $error = error_get_last();
      wm_warn("RRD ReadData: failed to open pipe to RRDTool: " . $error['message'] . " [WMRRD04]\n");
    }
    wm_debug("RRD ReadDataFromRealRRDAggregate: Returning (" . ($data[IN] === NULL ? 'NULL' : $data[IN]) . "," . ($data[OUT] === NULL ? 'NULL' : $data[OUT]) . ",$data_time)\n");

  }

  function wmrrd_read_from_real_rrdtool($rrdfile, $cf, $start, $end, $dsnames, &$data, &$map, &$data_time, &$item)
  {
    wm_debug("RRD ReadData: traditional style\n");

    // we get the last 800 seconds of data - this might be 1 or 2 lines, depending on when in the
    // cacti polling cycle we get run. This ought to stop the 'some lines are grey' problem that some
    // people were seeing

    // NEW PLAN - READ LINES (LIKE NOW), *THEN* CHECK IF REQUIRED DS NAMES EXIST (AND FAIL IF NOT),
    //     *THEN* GET THE LAST LINE WHERE THOSE TWO DS ARE VALID, *THEN* DO ANY PROCESSING.
    //  - this allows for early failure, and also tolerance of empty data in other parts of an rrd (like smokeping uptime)

    $extra_options = $map->get_hint("rrd_options");

    $values = array();
    $args   = array();

    #### $command = '"'.$map->rrdtool . '" fetch "'.$rrdfile.'" AVERAGE --start '.$start.' --end '.$end;
    #$command=$map->rrdtool . " fetch $rrdfile $cf --start $start --end $end $extra_options";
    $args[] = "fetch";
    $args[] = $rrdfile;
    $args[] = $cf;
    $args[] = "--start";
    $args[] = $start;
    $args[] = "--end";
    $args[] = $end;

    if ($map->daemon) {
      $args[] = "--daemon";
      $args[] = $map->daemon_args;
    }

    $command = $map->rrdtool;
    foreach ($args as $arg) {
      if (strchr($arg, " ") != FALSE) {
        $command .= ' "' . $arg . '"';
      } else {
        $command .= ' ' . $arg;
      }
    }
    $command .= " " . $extra_options;

    wm_debug("RRD ReadData: Running: $command\n");
    $pipe = popen($command, "r");

    $lines     = array();
    $count     = 0;
    $linecount = 0;

    if (isset($pipe)) {
      $headings = fgets($pipe, 4096);
      // this replace fudges 1.2.x output to look like 1.0.x
      // then we can treat them both the same.
      $heads = preg_split("/\s+/", preg_replace("/^\s+/", "timestamp ", $headings));

      //fgets($pipe, 4096); // skip the blank line
      $buffer = '';

      while (!feof($pipe)) {
        $line = fgets($pipe, 4096);
        // there might (pre-1.5) or might not (1.5+) be a leading blank line
        // we don't want to count it if there is
        if (trim($line) != "") {
          wm_debug("> " . $line);
          $buffer  .= $line;
          $lines[] = $line;
          $linecount++;
        }

      }
      pclose($pipe);

      wm_debug("RRD ReadData: Read $linecount lines from rrdtool\n");
      wm_debug("RRD ReadData: Headings are: $headings\n");

      if ((in_array($dsnames[IN], $heads) || $dsnames[IN] == '-') && (in_array($dsnames[OUT], $heads) || $dsnames[OUT] == '-')) {
        // deal with the data, starting with the last line of output
        $rlines = array_reverse($lines);

        foreach ($rlines as $line) {
          wm_debug("--" . $line . "\n");
          $cols = preg_split("/\s+/", $line);
          for ($i = 0, $cnt = count($cols) - 1; $i < $cnt; $i++) {
            $h = $heads[$i];
            $v = $cols[$i];
            # print "|$h|,|$v|\n";
            $values[$h] = trim($v);
          }

          $data_ok = FALSE;

          foreach (array(IN, OUT) as $dir) {
            $n = $dsnames[$dir];
            # print "|$n|\n";
            if (array_key_exists($n, $values)) {
              $candidate = $values[$n];
              if (preg_match('/^\-?\d+[\.,]?\d*e?[+-]?\d*:?$/i', $candidate)) {
                $data[$dir] = $candidate;
                wm_debug("$candidate is OK value for $n\n");
                $data_ok = TRUE;
              }
            }
          }

          if ($data_ok) {
            // at least one of the named DS had good data
            $data_time = intval($values['timestamp']);

            // 'fix' a -1 value to 0, so the whole thing is valid
            // (this needs a proper fix!)
            if ($data[IN] === NULL) $data[IN] = 0;
            if ($data[OUT] === NULL) $data[OUT] = 0;

            // break out of the loop here
            break;
          }
        }
      } else {
        // report DS name error
        $names = join(",", $heads);
        $names = str_replace("timestamp,", "", $names);
        wm_warn("RRD ReadData: At least one of your DS names (" . $dsnames[IN] . " and " . $dsnames[OUT] . ") were not found, even though there was a valid data line. Maybe they are wrong? Valid DS names in this file are: $names [WMRRD06]\n");
      }

    } else {
      $error = error_get_last();
      wm_warn("RRD ReadData: failed to open pipe to RRDTool: " . $error['message'] . " [WMRRD04]\n");
    }
    wm_debug("RRD ReadDataFromRealRRD: Returning (" . ($data[IN] === NULL ? 'NULL' : $data[IN]) . "," . ($data[OUT] === NULL ? 'NULL' : $data[OUT]) . ",$data_time)\n");
  }

  // Actually read data from a data source, and return it
  // returns a 3-part array (invalue, outvalue and datavalid time_t)
  // invalue and outvalue should be -1,-1 if there is no valid data
  // data_time is intended to allow more informed graphing in the future
  function ReadData($targetstring, &$map, &$item)
  {
    global $config;

    $dsnames[IN]  = "traffic_in";
    $dsnames[OUT] = "traffic_out";
    $data[IN]     = NULL;
    $data[OUT]    = NULL;
    $SQL[IN]      = 'select null';
    $SQL[OUT]     = 'select null';
    $rrdfile      = $targetstring;

    if ($map->get_hint("rrd_default_in_ds") != '') {
      $dsnames[IN] = $map->get_hint("rrd_default_in_ds");
      wm_debug("Default 'in' DS name changed to " . $dsnames[IN] . ".\n");
    }
    if ($map->get_hint("rrd_default_out_ds") != '') {
      $dsnames[OUT] = $map->get_hint("rrd_default_out_ds");
      wm_debug("Default 'out' DS name changed to " . $dsnames[OUT] . ".\n");
    }

    $multiplier = 8; // default bytes-to-bits

    $inbw      = NULL;
    $outbw     = NULL;
    $data_time = 0;

    if (preg_match("/^(.*\.rrd):([\-a-zA-Z0-9_]+):([\-a-zA-Z0-9_]+)$/", $targetstring, $matches)) {
      $rrdfile = $matches[1];

      $dsnames[IN]  = $matches[2];
      $dsnames[OUT] = $matches[3];

      wm_debug("Special DS names seen (" . $dsnames[IN] . " and " . $dsnames[OUT] . ").\n");
    }

    if (preg_match("/^rrd:(.*)/", $rrdfile, $matches)) {
      $rrdfile = $matches[1];
    }

    if (preg_match("/^gauge:(.*)/", $rrdfile, $matches)) {
      $rrdfile    = $matches[1];
      $multiplier = 1;
    }

    if (preg_match("/^scale:([+-]?\d*\.?\d*):(.*)/", $rrdfile, $matches)) {
      $rrdfile    = $matches[2];
      $multiplier = $matches[1];
    }

    wm_debug("SCALING result by $multiplier\n");

    // try and make a complete path, if we've been given a clue
    // (if the path starts with a . or a / then assume the user knows what they are doing)
    if (!preg_match("/^(\/|\.)/", $rrdfile)) {
      $rrdbase = $map->get_hint('rrd_default_path');
      if ($rrdbase != '') {
        $rrdfile = $rrdbase . "/" . $rrdfile;
      }
    }

    $cfname = $map->get_hint('rrd_cf');
    if ($cfname == '') $cfname = 'AVERAGE';

    $period = intval($map->get_hint('rrd_period'));
    if ($period == 0) $period = 800;
    $start = $map->get_hint('rrd_start');
    if ($start == '') {
      $start = "now-$period";
      $end   = "now";
    } else {
      $end = "start+" . $period;
    }

    $use_poller_output = intval($map->get_hint('rrd_use_poller_output'));
    $nowarn_po_agg     = intval($map->get_hint("nowarn_rrd_poller_output_aggregation"));
    $aggregatefunction = $map->get_hint('rrd_aggregate_function');

    if ($aggregatefunction != '' && $use_poller_output == 1) {
      $use_poller_output = 0;
      if ($nowarn_po_agg == 0) {
        wm_warn("Can't use poller_output for rrd-aggregated data - disabling rrd_use_poller_output [WMRRD10]\n");
      }
    }

    if ($use_poller_output == 1) {
      wm_debug("Going to try poller_output, as requested.\n");
      WeatherMapDataSource_rrd::wmrrd_read_from_poller_output($rrdfile, "AVERAGE", $start, $end, $dsnames, $data, $map, $data_time, $item);
    }

    // if poller_output didn't get anything, or if it couldn't/didn't run, do it the old-fashioned way
    // - this will still be the case for the first couple of runs after enabling poller_output support
    //   because there won't be valid data in the weathermap_data table yet.
    if (($dsnames[IN] != '-' && $data[IN] === NULL) || ($dsnames[OUT] != '-' && $data[OUT] === NULL)) {
      if ($use_poller_output == 1) {
        wm_debug("poller_output didn't get anything useful. Kicking it old skool.\n");
      }
      if (file_exists($rrdfile)) {
        wm_debug("RRD ReadData: Target DS names are " . $dsnames[IN] . " and " . $dsnames[OUT] . "\n");

        $values = array();


          if ($aggregatefunction != '') {
            WeatherMapDataSource_rrd::wmrrd_read_from_real_rrdtool_aggregate($rrdfile, $cfname, $aggregatefunction, $start, $end, $dsnames, $data, $map, $data_time, $item);
          } else {
            // do this the tried and trusted old-fashioned way
            WeatherMapDataSource_rrd::wmrrd_read_from_real_rrdtool($rrdfile, $cfname, $start, $end, $dsnames, $data, $map, $data_time, $item);
          }

      } else {
        wm_warn("Target $rrdfile doesn't exist. Is it a file? [WMRRD06]\n");
      }
    }

    // if the Locale says that , is the decimal point, then rrdtool
    // will honour it. However, floatval() doesn't, so let's replace
    // any , with . (there are never thousands separators, luckily)
    //
    if ($data[IN] !== NULL) {
      $data[IN] = floatval(str_replace(",", ".", $data[IN]));
      $data[IN] = $data[IN] * $multiplier;
    }
    if ($data[OUT] !== NULL) {
      $data[OUT] = floatval(str_replace(",", ".", $data[OUT]));
      $data[OUT] = $data[OUT] * $multiplier;
    }

    wm_debug("RRD ReadData: Returning (" . ($data[IN] === NULL ? 'NULL' : $data[IN]) . "," . ($data[OUT] === NULL ? 'NULL' : $data[OUT]) . ",$data_time)\n");

    return (array($data[IN], $data[OUT], $data_time));
  }
}

// vim:ts=4:sw=4: