block_node.hh

Go to the documentation of this file.

#pragma once
 
#include "../nodes/node.hh"
#include "local_io.hh"
#include "../messages/IOoperation.hh"
#include "../common/context_singleton.hh"
#include <string>
#include <map>
#include <queue>
 
 
namespace eclipse {
 
using vec_str = std::vector<std::string>;
 
class BlockNode: public Node {
  public:
    BlockNode (network::ClientHandler*);
    ~BlockNode ();
 
    bool block_insert_local(Block&, bool replicate = true);
 
    bool block_delete_local(Block&, bool replicate = true);
 
    //bool block_update_local(Block& block, uint32_t pos, uint32_t len, bool replicate = true);
    bool block_update_local(Block& block, uint64_t pos, uint64_t len, bool replicate = true);
 
    bool block_read_local(Block& block, uint64_t off = 0, uint64_t len = 0, bool ignore_params = true);
  
  bool block_append_local(Block& block, uint64_t len);
 
//  bool send_primary_to_replica(std::string file, std::string node);
 
  protected:
    void replicate_message(messages::IOoperation*);
 
    Local_io local_io;
    int network_size;
//  std::string disk_path;
//  std::vector<int> replica_nodes;
};
 
}