← Back to branch summary

~clint-fewbar/gearmand/fix-postgresql-path

« back to all changes in this revision

Viewing changes to bin/gearadmin.cc

  • Committer: Brian Aker
  • Date: 2011-07-21 04:50:58 UTC
  • mto: This revision was merged to the branch mainline in revision 442.
  • Revision ID: brian@tangent.org-20110721045058-tadgpgkjrf472rwy
Update all of test framework

Show diffs side-by-side

added added

removed removed

Lines of Context:
bin/gearadmin.cc
83
83
#include <libgearman/protocol.h>
84
84
#include <boost/program_options.hpp>
85
85
 
86
 
#include <util/instance.h>
 
86
#include <util/instance.hpp>
 
87
#include <util/string.hpp>
87
88
 
88
 
using namespace gearman_util;
 
89
using namespace datadifferential;
89
90
 
90
91
/*
91
92
  This is a very quickly build application, I am just tired of telneting to the port.
92
93
*/
93
94
 
94
 
#define STRING_WITH_LEN(X) (X), (static_cast<size_t>((sizeof(X) - 1)))
95
 
 
96
 
class Finish : public Instance::Finish
 
95
class Finish : public util::Instance::Finish
97
96
{
98
97
public:
99
98
  bool call(bool success, const std::string &response)
156
155
    return EXIT_FAILURE;
157
156
  }
158
157
 
159
 
  Instance instance(host, port);
 
158
  util::Instance instance(host, port);
160
159
  instance.set_finish(new Finish);
161
160
 
162
161
  if (vm.count("help"))
167
166
 
168
167
  if (vm.count("shutdown"))
169
168
  {
170
 
    instance.push(new Operation(STRING_WITH_LEN("shutdown\r\n"), false));
 
169
    instance.push(new util::Operation(util_literal_param("shutdown\r\n"), false));
171
170
  }
172
171
 
173
172
  if (vm.count("status"))
174
173
  {
175
 
    instance.push(new Operation(STRING_WITH_LEN("status\r\n")));
 
174
    instance.push(new util::Operation(util_literal_param("status\r\n")));
176
175
  }
177
176
 
178
177
  if (vm.count("workers"))
179
178
  {
180
 
    instance.push(new Operation(STRING_WITH_LEN("workers\r\n")));
 
179
    instance.push(new util::Operation(util_literal_param("workers\r\n")));
181
180
  }
182
181
 
183
182
  if (vm.count("server-version"))
184
183
  {
185
 
    instance.push(new Operation(STRING_WITH_LEN("version\r\n")));
 
184
    instance.push(new util::Operation(util_literal_param("version\r\n")));
186
185
  }
187
186
 
188
187
  if (vm.count("server-verbose"))
189
188
  {
190
 
    instance.push(new Operation(STRING_WITH_LEN("verbose\r\n")));
 
189
    instance.push(new util::Operation(util_literal_param("verbose\r\n")));
191
190
  }
192
191
 
193
192
  if (vm.count("drop-function"))
194
193
  {
195
 
    std::string execute(STRING_WITH_LEN("drop function "));
 
194
    std::string execute(util_literal_param("drop function "));
196
195
    execute.append(vm["drop-function"].as<std::string>());
197
196
    execute.append("\r\n");
198
 
    instance.push(new Operation(execute.c_str(), execute.size()));
 
197
    instance.push(new util::Operation(execute.c_str(), execute.size()));
199
198
  }
200
199
 
201
200
  if (vm.count("create-function"))
202
201
  {
203
 
    std::string execute(STRING_WITH_LEN("create function "));
 
202
    std::string execute(util_literal_param("create function "));
204
203
    execute.append(vm["create-function"].as<std::string>());
205
204
    execute.append("\r\n");
206
 
    instance.push(new Operation(execute.c_str(), execute.size()));
 
205
    instance.push(new util::Operation(execute.c_str(), execute.size()));
207
206
  }
208
207
 
209
208
  if (vm.count("getpid"))
210
209
  {
211
 
    instance.push(new Operation(STRING_WITH_LEN("getpid\r\n"), true));
 
210
    instance.push(new util::Operation(util_literal_param("getpid\r\n"), true));
212
211
  }
213
212
 
214
213
  instance.run();