48 cache:set(key, flags, exptime, received_buffer:sub(1,bytes)); |
48 cache:set(key, flags, exptime, received_buffer:sub(1,bytes)); |
49 conn:send("STORED\r\n"); |
49 conn:send("STORED\r\n"); |
50 conn:setlistener(memcached_listener); |
50 conn:setlistener(memcached_listener); |
51 conn:set_mode("*l"); |
51 conn:set_mode("*l"); |
52 if received_count > bytes then |
52 if received_count > bytes then |
|
53 log("debug", "Re-handling %d extra bytes", received_count-bytes); |
53 memcached_listener.onincoming(conn, received_buffer:sub(bytes+1)); |
54 memcached_listener.onincoming(conn, received_buffer:sub(bytes+1)); |
54 end |
55 end |
55 end |
56 end |
56 end |
57 end |
57 conn:setlistener({ |
58 conn:setlistener({ |