# HG changeset patch
# User Matthew Wild <mwild1@gmail.com>
# Date 1280661366 -3600
# Node ID fb941ed514c6b05ac52863ce2ba8dc38a002d411
# Parent  85c18da60925bcc236269ba53728417b834977e8
Honour noreply flag for set command

diff -r 85c18da60925 -r fb941ed514c6 mooncached.lua
--- a/mooncached.lua	Sun Aug 01 01:23:32 2010 +0100
+++ b/mooncached.lua	Sun Aug 01 12:16:06 2010 +0100
@@ -35,7 +35,11 @@
 	local key, flags, exptime, bytes, reply = params:match("(%S+) (%d+) (%d+) (%d+) ?(.*)$");
 	flags, exptime, bytes, reply = tonumber(flags), tonumber(exptime), tonumber(bytes), reply ~= "noreply";
 	if not (flags and exptime and bytes) then
-		return false, "Invalid parameter(s)";
+		if reply then
+			return false, "Invalid parameter(s)";
+		else
+			return nil;
+		end
 	end
 	conn:set_mode("*a");
 	local received_count, received_buffer = 0, {};
@@ -46,10 +50,12 @@
 		if received_count >= bytes then
 			received_buffer = table.concat(received_buffer);
 			local ok, err = cache:set(key, flags, exptime, received_buffer:sub(1,bytes));
-			if ok then
-				conn:send("STORED\r\n");
-			else
-				conn:send("SERVER_ERROR "..(err or "Unknown error").."\r\n");
+			if reply then
+				if ok then
+					conn:send("STORED\r\n");
+				else
+					conn:send("SERVER_ERROR "..(err or "Unknown error").."\r\n");
+				end
 			end
 			conn:setlistener(memcached_listener);
 			conn:set_mode("*l");