MCPcopy Create free account
hub / github.com/DeNA/HandlerSocket-Plugin-for-MySQL / verify_readnolock

Method verify_readnolock

client/hslongrun.cpp:334–357  ·  view source on GitHub ↗

Source from the content-addressed store, hash-verified

332}
333
334int
335hs_longrun_thread_base::verify_readnolock(const std::string& k,
336 uint32_t num_rows, uint32_t num_flds, const std::string rrec[4])
337{
338 int ret = 0;
339 if (num_rows != 1 || num_flds != 4) {
340 ++stat.verify_error_count;
341 if (arg.sh.verbose > 0) {
342 fprintf(stderr, "VERIFY_ERROR: %s wid=%d k=%s "
343 "unexpected_read_failure\n",
344 arg.worker_type.c_str(), arg.id, k.c_str());
345 }
346 ret = 1;
347 }
348 if (arg.sh.verbose >= 100 && ret == 0) {
349 fprintf(stderr, "%s -> %s %s %s %s %s\n", arg.worker_type.c_str(),
350 k.c_str(), rrec[0].c_str(), rrec[1].c_str(), rrec[2].c_str(),
351 rrec[3].c_str());
352 }
353 if (ret == 0) {
354 ++stat.success_count;
355 }
356 return ret;
357}
358
359struct hs_longrun_thread_hs : public hs_longrun_thread_base {
360 hs_longrun_thread_hs(const arg_type& arg)

Callers

nothing calls this directly

Calls

no outgoing calls

Tested by

no test coverage detected