Method test_11

plugin/handler_socket/client/hstest.cpp:1025–1090

}

void
hstest_thread::test_11(int test_num)
{
  const int keep_connection = arg.sh.conf.get_int("keep_connection", 1);
  const int tablesize = arg.sh.conf.get_int("tablesize", 0);
  unsigned int seed = arg.id;
  seed ^= arg.sh.conf.get_int("seed_xor", 0);
  std::string err;
  hstcpcli_ptr cli;
  for (size_t i = 0; i < arg.sh.loop; ++i) {
    if (cli.get() == 0) {
      cli = hstcpcli_i::create(arg.sh.arg);
      cli->request_buf_open_index(0, "hstest", "hstest_table1", "", "v");
	/* pst_num, db, table, index, retflds */
      if (cli->request_send() != 0) {
	fprintf(stderr, "reuqest_send: %s\n", cli->get_error().c_str());
	return;
      }
      size_t num_flds = 0;
      if (cli->response_recv(num_flds) != 0) {
	fprintf(stderr, "reuqest_recv: %s\n", cli->get_error().c_str());
	return;
      }
      cli->response_buf_remove();
    }
    for (size_t j = 0; j < arg.sh.pipe; ++j) {
      char buf[256];
      int k = 0, v = 0, len = 0;
      {
	k = rand_r(&seed);
	v = rand_r(&seed); /* unused */
	if (tablesize != 0) {
	  k &= tablesize;
	}
	len = snprintf(buf, sizeof(buf), "%d", k);
      }
      const string_ref key(buf, len);
      const string_ref op("=", 1);
      cli->request_buf_exec_generic(0, op, &key, 1, 1, 0, string_ref(), 0, 0);
    }
    if (cli->request_send() != 0) {
      fprintf(stderr, "reuqest_send: %s\n", cli->get_error().c_str());
      return;
    }
    size_t read_cnt = 0;
    for (size_t j = 0; j < arg.sh.pipe; ++j) {
      size_t num_flds = 0;
      if (cli->response_recv(num_flds) != 0) {
	fprintf(stderr, "reuqest_recv: %s\n", cli->get_error().c_str());
	return;
      }
      {
	++read_cnt;
	++io_success_count;
	arg.sh.increment_count();
	{
	  ++op_success_count;
	}