Skip to content

Instantly share code, notes, and snippets.

View moonpolysoft's full-sized avatar

Cliff Moon moonpolysoft

View GitHub Profile
=INFO REPORT==== 6-Aug-2008::22:35:08 ===
writing <<0,0,15,241>> bytes at 0
=INFO REPORT==== 6-Aug-2008::22:35:08 ===
could not find offset
=INFO REPORT==== 6-Aug-2008::22:35:08 ===
writing <<0,0,0,0,0,0,0,0>> bytes at 4
=INFO REPORT==== 6-Aug-2008::22:35:08 ===
open_and_insert_260_test() ->
test_cleanup(),
Tree = lists:foldl(fun(N, Tree) ->
update(lists:concat(["key", N]), lists:concat(["value", N]), Tree)
end, open("/Users/cliff/data/dmerkle", 4096), lists:seq(1,260)),
Hash = hash("value200"),
Hash = find("key200", Tree),
File = Tree#dmerkle.file,
error_logger:info_msg("read ~p ~n", [block_server:read_block(File, 4, 8)]),
block_server:write_block(File, 4, <<8174:64>>),
=INFO REPORT==== 6-Aug-2008::22:35:08 ===
writing <<0,0,15,241>> bytes at 0
=INFO REPORT==== 6-Aug-2008::22:35:08 ===
could not find offset
=INFO REPORT==== 6-Aug-2008::22:35:08 ===
writing <<0,0,0,0,0,0,0,0>> bytes at 4
=INFO REPORT==== 6-Aug-2008::22:35:08 ===
This is a bench of dynomite put requests with disk based merkle trees. The ruby client is used with a configurable number of threads. Two servers are used. Time to generate test data is not included.
threads items size servers time
1 500 4096 2 42.0825250148773
2 500 4096 2 21.0988519191742
3 500 4096 2 13.8805010318756
4 500 4096 2 10.7571620941162
1 5000 4096 2 416.328256845474
2 5000 4096 2 207.473428010941
WORKERS=16
$pids = []
while $pids.length >= WORKERS
exited = Process.wait
$pids.delete exited
end
$pids << fork do
yield
end
diff --git a/src/erlang/rabbit/src/rabbit_control.erl b/src/erlang/rabbit/src/rabbit_control.erl
index b02afcb..52fb9b0 100644
--- a/src/erlang/rabbit/src/rabbit_control.erl
+++ b/src/erlang/rabbit/src/rabbit_control.erl
@@ -128,6 +128,11 @@ action(force_reset, Node, []) ->
io:format("Forcefully resetting node ~p ...", [Node]),
call(Node, {rabbit_mnesia, force_reset, []});
+action(stat_all, Node, []) ->
+ Res = call(Node, {rabbit_amqqueue, stat_all, []}),
require 'rlibs/dynomite'
dyn = Dynomite.new(:host => 'localhost', :port => 11222)
dyn.put("mahkey", nil, "mayvalue")
(context, data_items) = dyn.get("mahkey")
puts data_items.inspect
class ScriptNameFix
def call(app)
class << app
def new_call(env)
env["SCRIPT_NAME"] = ""
original_call(env)
end
diff --git a/lib/thin/connection.rb b/lib/thin/connection.rb
index e267f45..88064ff 100644
--- a/lib/thin/connection.rb
+++ b/lib/thin/connection.rb
@@ -69,25 +69,42 @@ module Thin
def post_process(result)
return unless result
+ send_results = Proc.new do |result|
+ # Set the Content-Length header if possible
diff --git a/steezychat.js b/steezychat.js
index 900a5e7..d3ad8ec 100644
--- a/steezychat.js
+++ b/steezychat.js
@@ -88,18 +88,20 @@ var ChatRoom = function(client, browser) {
var message = new self.client.message(elem)
var msg = message.body
- if (self.inline_images_checkbox.checked)
- msg += self.add_img_tags(msg)