Skip to content

Instantly share code, notes, and snippets.

@Vagabond
Vagabond / gist:667339
Created November 8, 2010 03:12
Ape socket server
Ape.addEvent("init", function() {
var socket = new Ape.sockServer(1337, "0.0.0.0", {flushlf: true});
socket.onAccept = function(client) {
Ape.log("Client connected");
}
socket.onRead = function(client, data) {
var parts = data.split(' ');
switch (parts[0]) {
case 'ADDMESSAGE':
@Vagabond
Vagabond / gist:674561
Created November 12, 2010 19:42
gen_leader netsplit diff
diff --git a/hanssv+serge_version/gen_leader.erl b/hanssv+serge_version/gen_leader.erl
index 036e2a6..c0808b1 100644
--- a/hanssv+serge_version/gen_leader.erl
+++ b/hanssv+serge_version/gen_leader.erl
@@ -555,7 +555,9 @@ safe_loop(#server{mod = Mod, state = State} = Server, Role,
%% A DOWN message should arrive to solve this situation
safe_loop(Server,Role,E,Msg)
end;
-
+ {election} = Msg ->
diff --cc src/agent_manager.erl
index cb67374,692b669..0000000
--- a/src/agent_manager.erl
+++ b/src/agent_manager.erl
@@@ -346,10 -359,13 +363,13 @@@ handle_DOWN(Node, #state{agents = Agent
Node =/= node(Apid)
end,
Agents2 = dict:filter(F, Agents),
- {ok, State#state{agents = Agents2}}.
+ Routelist = gb_trees_filter(fun({_Key, {Pid, _Id, _Skills}}) ->
^andrew@orz:: ./agner install mysql [~/agner]
remote: Counting objects: 46, done.
remote: Compressing objects: 100% (32/32), done.
remote: Total 46 (delta 18), reused 30 (delta 9)
Unpacking objects: 100% (46/46), done.
ok
[Building...]
==> agner18636 (get-deps)
==> agner18636 (compile)
Compiled src/mysql_auth.erl
include <syslog.h>
int main(int argc, char **argv) {
long logopt, facility;
openlog("test", LOG_PID, LOG_LOCAL0);
syslog(LOG_ERR, "This is a string with some newlines\n and some tabs\t and some carraige returns\r\n \n");
return 0;
}
1> erlang:system_monitor(self(), [{long_gc, 9999999999}]).
** exception error: bad argument
in function erlang:system_monitor/2
called as erlang:system_monitor(<0.31.0>,[{long_gc,9999999999}])
2> erlang:system_monitor(self(), [{long_gc, 999999999}]).
undefined
==> luwak (eunit)
** /Users/andrew/riak/deps/luwak/.eunit/luwak_wm_file.beam hides /Users/andrew/riak/deps/luwak/ebin/luwak_wm_file.beam
** /Users/andrew/riak/deps/luwak/.eunit/luwak_tree_utils.beam hides /Users/andrew/riak/deps/luwak/ebin/luwak_tree_utils.beam
** /Users/andrew/riak/deps/luwak/.eunit/luwak_tree.beam hides /Users/andrew/riak/deps/luwak/ebin/luwak_tree.beam
** /Users/andrew/riak/deps/luwak/.eunit/luwak_put_stream.beam hides /Users/andrew/riak/deps/luwak/ebin/luwak_put_stream.beam
** /Users/andrew/riak/deps/luwak/.eunit/luwak_io.beam hides /Users/andrew/riak/deps/luwak/ebin/luwak_io.beam
** /Users/andrew/riak/deps/luwak/.eunit/luwak_get_stream.beam hides /Users/andrew/riak/deps/luwak/ebin/luwak_get_stream.beam
** /Users/andrew/riak/deps/luwak/.eunit/luwak_file.beam hides /Users/andrew/riak/deps/luwak/ebin/luwak_file.beam
** /Users/andrew/riak/deps/luwak/.eunit/luwak_checksum.beam hides /Users/andrew/riak/deps/luwak/ebin/luwak_checksum.beam
** /Users/andrew/riak/deps/luwak/.eunit/luwak_block.beam
#!/bin/sh
BRANCH=$1
PWD=`pwd`
#git pull origin master
git checkout $BRANCH
for repo in `ls deps`; do
cd deps/$repo
15> riakc_pb_socket:put(RC, Object1, [return_body]).
{ok,{riakc_obj,<<"bucket">>,<<"key">>,
<<107,206,97,96,96,96,205,96,202,5,82,44,44,69,199,129,
204,68,198,60,86,6,99,...>>,
[{{dict,2,16,16,8,80,48,
{[],[],[],[],[],[],[],[],[],[],[],[],...},
{{[],[],[],[],[],[],[],[],[],[],...}}},
<<"value">>}],
undefined,undefined}}
16> riakc_pb_socket:put(RC, Object2, [return_body]).
^andrew@centos:: ulimit -n [~]
1024
^andrew@centos:: su - riak [~]
Password:
[riak@centos ~]$ ulimit -n
2048
[riak@centos ~]$ cat /etc/security/limits.conf | grep riak
riak soft nofile 2048
riak hard nofile 4096
[riak@centos ~]$