| 224 | } |
| 225 | |
| 226 | redis_result* redis_client::get_integer(socket_stream& conn, dbuf_pool* dbuf) |
| 227 | { |
| 228 | string& buf = conn.get_buf(); |
| 229 | buf.clear(); |
| 230 | if (!conn_.gets(buf)) { |
| 231 | logger_error("gets error, server: %s", conn.get_peer(true)); |
| 232 | return NULL; |
| 233 | } |
| 234 | |
| 235 | redis_result* rr = new(dbuf) redis_result(dbuf); |
| 236 | rr->set_type(REDIS_RESULT_INTEGER); |
| 237 | rr->set_size(1); |
| 238 | |
| 239 | put_data(dbuf, rr, buf.c_str(), buf.length()); |
| 240 | return rr; |
| 241 | } |
| 242 | |
| 243 | redis_result* redis_client::get_string(socket_stream& conn, dbuf_pool* dbuf) |
| 244 | { |