| 357 | } |
| 358 | |
| 359 | struct hs_longrun_thread_hs : public hs_longrun_thread_base { |
| 360 | hs_longrun_thread_hs(const arg_type& arg) |
| 361 | : hs_longrun_thread_base(arg) { } |
| 362 | void run(); |
| 363 | int check_hs_error(const char *mess, record_value *rec); |
| 364 | int op_insert(record_value& rec); |
| 365 | int op_delete(record_value& rec); |
| 366 | int op_update(record_value& rec); |
| 367 | int op_read(record_value& rec); |
| 368 | int op_readnolock(int k); |
| 369 | hstcpcli_ptr cli; |
| 370 | socket_args sockargs; |
| 371 | }; |
| 372 | |
| 373 | struct lock_guard : noncopyable { |
| 374 | lock_guard(mutex& mtx) : mtx(mtx) { |
nothing calls this directly
no outgoing calls
no test coverage detected