joedb_server.cpp

Go to the documentation of this file.

#include "joedb/concurrency/Server.h"
#include "joedb/concurrency/Client.h"
#include "joedb/concurrency/IO_Context_Wrapper.h"
#include "joedb/ui/Client_Parser.h"
#include "joedb/ui/main_exception_catcher.h"
 
#include <iostream>
#include <cstring>
#include <cstdlib>
 
namespace joedb
{
 /////////////////////////////////////////////////////////////////////////////
 static int joedb_server(int argc, char **argv)
 /////////////////////////////////////////////////////////////////////////////
 {
  const Open_Mode default_open_mode = Open_Mode::write_existing_or_create_new;
 
  Client_Parser client_parser(default_open_mode, Client_Parser::DB_Type::none);
 
  if (argc <= 1)
  {
   std::cerr << "usage: " << argv[0];
   std::cerr << " [--socket <endpoint_path>] [--timeout t]";
   client_parser.print_help(std::cerr);
   std::cerr << R"RRR(
The timeout is the time (in seconds) during which a client lock is kept.
0 (the default) means there is no timeout, and the lock is kept until the
client unlocks or is disconnected. A client that timed out is not disconnected,
and can still push data: the push will succeed only if there is no conflict.
)RRR";
   return 1;
  }
 
  int32_t index = 1;
 
  std::string_view endpoint_base("joedb");
  for (int i = 1; i < argc; i++)
  {
   const std::string_view v(argv[i]);
   if (v.size() > 6 && v.compare(v.size() - 6, 6, ".joedb") == 0)
   {
    endpoint_base = v;
    endpoint_base.remove_suffix(6);
    break;
   }
  }
  std::string endpoint_path = std::string(endpoint_base) + ".sock";
 
  if (index + 1 < argc && std::strcmp(argv[index], "--socket") == 0)
  {
   endpoint_path = argv[index + 1];
   index += 2;
  }
 
  uint32_t timeout = 0;
  if (index + 1 < argc && std::strcmp(argv[index], "--timeout") == 0)
  {
   timeout = uint32_t(std::atoi(argv[index + 1]));
   index += 2;
  }
 
  Client &client = client_parser.parse(argc - index, argv + index);
 
  IO_Context_Wrapper io_context_wrapper;
 
  std::cout << "Creating server (endpoint_path = " << endpoint_path;
  std::cout << "; timeout = " << timeout << ")\n";
 
  Server server
  (
   client,
   io_context_wrapper.io_context,
   endpoint_path,
   std::chrono::seconds(timeout),
   &std::cerr
  );
 
  io_context_wrapper.run();
 
  return 0;
 }
}
 
/////////////////////////////////////////////////////////////////////////////
int main(int argc, char **argv)
/////////////////////////////////////////////////////////////////////////////
{
 return joedb::main_exception_catcher(joedb::joedb_server, argc, argv);
}