Unverified Commit b0303b5c authored by kladko's avatar kladko

Fixed docs

parent 5e9c346d
...@@ -22,21 +22,26 @@ ...@@ -22,21 +22,26 @@
*/ */
#include "CSRManagerServer.h"
#include "SGXException.h"
#include "sgxwallet_common.h"
#include <iostream> #include <iostream>
#include <fstream> #include <fstream>
#include <jsonrpccpp/server/connectors/httpserver.h> #include <jsonrpccpp/server/connectors/httpserver.h>
#include "spdlog/spdlog.h"
#include "CSRManagerServer.h"
#include "SGXException.h"
#include "sgxwallet_common.h"
#include "Log.h"
#include "common.h" #include "common.h"
CSRManagerServer *cs = nullptr; shared_ptr<CSRManagerServer> CSRManagerServer::cs = nullptr;
jsonrpc::HttpServer *hs3 = nullptr; shared_ptr<jsonrpc::HttpServer> CSRManagerServer::hs3 = nullptr;
CSRManagerServer::CSRManagerServer(AbstractServerConnector &connector, CSRManagerServer::CSRManagerServer(AbstractServerConnector &connector,
...@@ -44,22 +49,15 @@ CSRManagerServer::CSRManagerServer(AbstractServerConnector &connector, ...@@ -44,22 +49,15 @@ CSRManagerServer::CSRManagerServer(AbstractServerConnector &connector,
Json::Value getUnsignedCSRsImpl() { Json::Value getUnsignedCSRsImpl() {
spdlog::info("Enter getUnsignedCSRsImpl"); spdlog::info(__FUNCTION__);
Json::Value result; INIT_RESULT(result)
result["status"] = 0;
result["errorMessage"] = "";
try { try {
vector<string> hashes_vect = LevelDB::getCsrDb()->writeKeysToVector1(MAX_CSR_NUM); vector<string> hashes_vect = LevelDB::getCsrDb()->writeKeysToVector1(MAX_CSR_NUM);
for (int i = 0; i < (int) hashes_vect.size(); i++) { for (int i = 0; i < (int) hashes_vect.size(); i++) {
result["hashes"][i] = hashes_vect.at(i); result["hashes"][i] = hashes_vect.at(i);
} }
} catch (SGXException &_e) { } HANDLE_SGX_EXCEPTION(result);
cerr << " err str " << _e.errString << endl;
result["status"] = _e.status;
result["errorMessage"] = _e.errString;
}
return result; return result;
} }
...@@ -111,30 +109,26 @@ Json::Value signByHashImpl(const string &hash, int status) { ...@@ -111,30 +109,26 @@ Json::Value signByHashImpl(const string &hash, int status) {
result["status"] = status; result["status"] = status;
} catch (SGXException &_e) { } HANDLE_SGX_EXCEPTION(result)
cerr << " err str " << _e.errString << endl;
result["status"] = _e.status;
result["errorMessage"] = _e.errString;
}
return result; return result;
} }
Json::Value CSRManagerServer::getUnsignedCSRs() { Json::Value CSRManagerServer::getUnsignedCSRs() {
lock_guard<recursive_mutex> lock(m); LOCK(m)
return getUnsignedCSRsImpl(); return getUnsignedCSRsImpl();
} }
Json::Value CSRManagerServer::signByHash(const string &hash, int status) { Json::Value CSRManagerServer::signByHash(const string &hash, int status) {
lock_guard<recursive_mutex> lock(m); LOCK(m)
return signByHashImpl(hash, status); return signByHashImpl(hash, status);
} }
int CSRManagerServer::initCSRManagerServer() { int CSRManagerServer::initCSRManagerServer() {
hs3 = new jsonrpc::HttpServer(BASE_PORT + 2); hs3 = make_shared<jsonrpc::HttpServer>(BASE_PORT + 2);
hs3->BindLocalhost(); hs3->BindLocalhost();
cs = new CSRManagerServer(*hs3, JSONRPC_SERVER_V2); // server (json-rpc 2.0) cs = make_shared<CSRManagerServer>(*hs3, JSONRPC_SERVER_V2); // server (json-rpc 2.0)
if (!cs->StartListening()) { if (!cs->StartListening()) {
spdlog::info("CSR manager server could not start listening"); spdlog::info("CSR manager server could not start listening");
......
...@@ -25,23 +25,33 @@ ...@@ -25,23 +25,33 @@
#ifndef SGXD_CSRMANAGERSERVER_H #ifndef SGXD_CSRMANAGERSERVER_H
#define SGXD_CSRMANAGERSERVER_H #define SGXD_CSRMANAGERSERVER_H
#include <mutex>
#include <jsonrpccpp/server/connectors/httpserver.h>
#include "abstractCSRManagerServer.h" #include "abstractCSRManagerServer.h"
#include "LevelDB.h" #include "LevelDB.h"
#include <mutex>
using namespace jsonrpc; using namespace jsonrpc;
using namespace std;
class CSRManagerServer : public abstractCSRManagerServer { class CSRManagerServer : public abstractCSRManagerServer {
std::recursive_mutex m; recursive_mutex m;
static shared_ptr<HttpServer> hs3;
static shared_ptr<CSRManagerServer> cs;
public: public:
CSRManagerServer(AbstractServerConnector &connector, serverVersion_t type); CSRManagerServer(AbstractServerConnector &connector, serverVersion_t type);
virtual Json::Value getUnsignedCSRs(); virtual Json::Value getUnsignedCSRs();
virtual Json::Value signByHash(const std::string& hash, int status); virtual Json::Value signByHash(const string& hash, int status);
static int initCSRManagerServer(); static int initCSRManagerServer();
}; };
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment