@override
| 136 | private: |
| 137 | // @override |
| 138 | void* run(void) { |
| 139 | wdb_sess sess(db_); |
| 140 | if (sess.open() == false) { |
| 141 | printf("open db session failed\r\n"); |
| 142 | return NULL; |
| 143 | } |
| 144 | |
| 145 | if (action_ == "add") { |
| 146 | add(sess, max_); |
| 147 | } else if (action_ == "get") { |
| 148 | get(sess, max_); |
| 149 | } else if (action_ == "del") { |
| 150 | del(sess, max_); |
| 151 | } else { |
| 152 | printf("invalid action=%s\r\n", action_.c_str()); |
| 153 | } |
| 154 | |
| 155 | return NULL; |
| 156 | } |
| 157 | |
| 158 | void add(wdb_sess& sess, long long max) { |
| 159 | acl::string key, value; |