extent_server.h

#ifndef extent_server_h
#define extent_server_h

#include <string>
#include <map>
#include "extent_protocol.h"

/** 
  * A simple map from extentid_t ids to extents. 
  * An extent is a pair (buffer, attribute)
  * To be used within an RPC server
  * all methods protected by a mutex
  */
class extent_server {

private:
  pthread_mutex_t mutex_ = PTHREAD_MUTEX_INITIALIZER;

  struct Extent {
  	extent_protocol::attr attr;
  	std::string buf;
  };

  std::map<extent_protocol::extentid_t, Extent> store_; 

public:
  extent_server();

  // last parameter is useless, needed to conform to the rpc's templates
  extent_protocol::status put(extent_protocol::extentid_t id, std::string, 
                              int &);

  extent_protocol::status get(extent_protocol::extentid_t id, std::string &);

  extent_protocol::status getattr(extent_protocol::extentid_t id, extent_protocol::attr &);

  // last parameter is useless, needed to conform to the rpc's templates
  extent_protocol::status remove(extent_protocol::extentid_t id, 
                                 int &);
};

#endif