t_file_transfer.cpp

Go to the documentation of this file.

/*****************************************************************************\
*                                                                             *
*  Name   : test_file_transfer_tentacle                                       *
*  Author : Chris Koeritz                                                     *
*                                                                             *
*  Purpose:                                                                   *
*                                                                             *
*    Tests the file_transfer_tentacle without any networking involved.        *
*                                                                             *
*******************************************************************************
* Copyright (c) 2005-$now By Author.  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 is online at:      *
*     http://www.fsf.org/copyleft/gpl.html                                    *
* Please send any updates to: fred@gruntose.com                               *
\*****************************************************************************/

#include <basis/function.h>
#include <basis/string_array.h>
#include <opsystem/application_shell.h>
#include <loggers/console_logger.h>
#include <data_struct/static_memory_gremlin.h>
#include <tentacles/recursive_file_copy.h>

#define LOG(s) CLASS_EMERGENCY_LOG(program_wide_logger(), s)

class test_file_transfer_tentacle : public application_shell
{
public:
  test_file_transfer_tentacle() : application_shell(static_class_name()) {}
  IMPLEMENT_CLASS_NAME("test_dirtree_fcopy");
  int execute();
};

int test_file_transfer_tentacle::execute()
{
  FUNCDEF("execute");

  if (__argc < 3) {
    log("\
This program needs two parameters:\n\
a directory for the source root and one for the target root.\n\
Optionally, a third parameter may specify a starting point within the\n\
source root.\n\
Further, if fourth or more parameters are found, they are taken to be\n\
files to include; only they will be transferred.\n");
    return 23;
  }

  istring source_dir = __argv[1];
  istring target_dir = __argv[2];

  istring source_start = "";
  if (__argc >= 4) {
    source_start = __argv[3];
  }

  string_array includes;
  if (__argc >= 5) {
    for (int i = 4; i < __argc; i++) {
      includes += __argv[i];
    }
  }

  outcome returned = recursive_file_copy::copy_hierarchy(source_dir,
      target_dir, includes, source_start);

/*
  istring source_root = "snootums";
  if (source_start.t()) {
    source_root += filename::default_separator() + source_start;
  }

  tcpip_stack stack;
  octopus ring_leader(stack.hostname(), 10 * MEGABYTE);
  file_transfer_tentacle *tran = new file_transfer_tentacle(MAX_CHUNK, false);
  ring_leader.add_tentacle(tran);

  outcome add_ret = tran->add_correspondence("snootums", source_dir,
      10 * MINUTE_ms);
  if (add_ret != tentacle::OKAY)
    deadly_error(class_name(), func, "failed to add the correspondence");

  file_transfer_infoton *initiate = new file_transfer_infoton;
  initiate->_request = true;
  initiate->_command = file_transfer_infoton::TREE_COMPARISON;
  initiate->_src_root = source_root;
  initiate->_dest_root = target_dir;
  directory_tree target_area(target_dir);
  target_area.calculate();
  initiate->package_tree_info(target_area, includes);

  octopus_entity ent = ring_leader.issue_identity();
  octopus_request_id req_id(ent, 1);
  outcome start_ret = ring_leader.evaluate(initiate, req_id);
  if (start_ret != tentacle::OKAY)
    deadly_error(class_name(), func, "failed to start the comparison");

  file_transfer_infoton *reply_from_init
      = (file_transfer_infoton *)ring_leader.acquire_specific_result(req_id);
  if (!reply_from_init)
    deadly_error(class_name(), func, "no response to tree compare start");

  filename_list diffs;
  byte_array pack_copy = reply_from_init->_packed_data;
  if (!diffs.unpack(pack_copy))
    deadly_error(class_name(), func, "could not unpack filename list!");
//  LOG(istring("got list of diffs:\n") + diffs.text_form());

  octopus client_spider(stack.hostname(), 10 * MEGABYTE);
  file_transfer_tentacle *tran2 = new file_transfer_tentacle(MAX_CHUNK, false);
  tran2->register_file_transfer(ent, source_root, target_dir, includes);
  client_spider.add_tentacle(tran2);

  octopus_request_id resp_id(ent, 2);
  outcome ini_resp_ret = client_spider.evaluate(reply_from_init, resp_id);
  if (ini_resp_ret != tentacle::OKAY)
    deadly_error(class_name(), func, "failed to process the start response!");

  infoton *junk = client_spider.acquire_specific_result(resp_id);
  if (junk)
    deadly_error(class_name(), func, "got a response we shouldn't have!");

  int iter = 0;
  while (true) {
LOG(isprintf("ongoing chunk %d", ++iter));

    // keep going until we find a broken reply.
    file_transfer_infoton *ongoing = new file_transfer_infoton;
    ongoing->_request = true;
    ongoing->_command = file_transfer_infoton::PLACE_FILE_CHUNKS;
    ongoing->_src_root = source_root;
    ongoing->_dest_root = target_dir;

    octopus_request_id chunk_id(ent, iter + 10);
    outcome place_ret = ring_leader.evaluate(ongoing, chunk_id);
    if (place_ret != tentacle::OKAY)
      deadly_error(class_name(), func, "failed to run ongoing transfer");
  
    file_transfer_infoton *reply = (file_transfer_infoton *)ring_leader
         .acquire_specific_result(chunk_id);
    if (!reply)
      deadly_error(class_name(), func, "failed to get ongoing transfer reply");

    if (!reply->_packed_data.length()) {
      LOG("hit termination condition: no data packed in for file chunks.");
      break;
    }

    byte_array copy = reply->_packed_data;
    while (copy.length()) {
      file_transfer_header head;
      if (!head.unpack(copy)) 
        deadly_error(class_name(), func, "failed to unpack header");
LOG(istring("header: ") + head.text_form());
LOG(isprintf("size in array: %d", copy.length()));
      if (copy.length() < head._length)
        deadly_error(class_name(), func, "not enough length in array");
      copy.zap(0, head._length - 1);
LOG(isprintf("size in array now: %d", copy.length()));
    }
    if (copy.length())
      deadly_error(class_name(), func, "still had data in array");

    octopus_request_id resp_id(ent, iter + 11);
    outcome resp_ret = client_spider.evaluate(reply, resp_id);
    if (resp_ret != tentacle::OKAY)
      deadly_error(class_name(), func, "failed to process the transfer reply!");
  
  }
*/

  if (returned == common::OKAY)
    guards::alert_message("file_transfer_tentacle:: works for those "
        "functions tested.");
  else
    guards::alert_message(istring("file_transfer_tentacle:: failed with "
        "outcome=") + recursive_file_copy::outcome_name(returned));
  return 0;
}

HOOPLE_MAIN(test_file_transfer_tentacle, )

---