summaryrefslogtreecommitdiff
path: root/storage/ndb/src/old_files/rep/RepApiInterpreter.cpp
diff options
context:
space:
mode:
Diffstat (limited to 'storage/ndb/src/old_files/rep/RepApiInterpreter.cpp')
-rw-r--r--storage/ndb/src/old_files/rep/RepApiInterpreter.cpp80
1 files changed, 0 insertions, 80 deletions
diff --git a/storage/ndb/src/old_files/rep/RepApiInterpreter.cpp b/storage/ndb/src/old_files/rep/RepApiInterpreter.cpp
deleted file mode 100644
index 6e6f150713a..00000000000
--- a/storage/ndb/src/old_files/rep/RepApiInterpreter.cpp
+++ /dev/null
@@ -1,80 +0,0 @@
-/* Copyright (C) 2003 MySQL AB
-
- 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 program is distributed in the hope that it will be useful,
- but WITHOUT ANY WARRANTY; without even the implied warranty of
- MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
- GNU General Public License for more details.
-
- You should have received a copy of the GNU General Public License
- along with this program; if not, write to the Free Software
- Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA 02111-1307 USA */
-
-#include "RepApiInterpreter.hpp"
-#include <signaldata/GrepImpl.hpp>
-
-RepApiInterpreter::RepApiInterpreter(RepComponents * comps, int port)
-{
- m_repComponents = comps;
- m_repState = comps->getRepState();
- m_port = port;
- ss = new SocketServer();
- serv = new RepApiService(*this);
-}
-
-
-RepApiInterpreter::~RepApiInterpreter()
-{
-}
-
-void
-RepApiInterpreter::startInterpreter()
-{
- if(!ss->setup(serv, m_port)){
- sleep(1);
- delete ss;
- delete serv;
- }
- ss->startServer();
-}
-
-
-void
-RepApiInterpreter::stopInterpreter()
-{
- delete ss;
-}
-
-
-Properties *
-RepApiInterpreter::execCommand(const Properties & props)
-{
- Properties * result = new Properties();
- Uint32 req = 0;
- Uint32 epoch = 0;
- props.get("request", &req);
- props.get("epoch", &epoch);
- GrepError::Code err = m_repState->protectedRequest((GrepReq::Request)req,
- epoch);
- result->put("err", err);
- return result;
-}
-
-Properties *
-RepApiInterpreter::getStatus()
-{
-
- return m_repState->getStatus();
-}
-
-
-Properties *
-RepApiInterpreter::query(Uint32 counter, Uint32 replicationId)
-{
- return m_repState->query((QueryCounter)counter, replicationId);
-}
-