Skip to content

Instantly share code, notes, and snippets.

2013-02-25_21:21:37.54324 0 [main] WARN com.mapr.franz.server.ClusterState - connecting to localhost:2108
2013-02-25_21:40:54.42294 1156878 [New I/O worker #5] WARN com.googlecode.protobuf.pro.duplex.handler.ServerConnectRequestHandler - Exception caught during RPC connection handshake.
2013-02-25_21:40:54.42299 com.google.protobuf.InvalidProtocolBufferException: Protocol message end-group tag did not match expected tag.
2013-02-25_21:40:54.42300 at com.google.protobuf.InvalidProtocolBufferException.invalidEndTag(InvalidProtocolBufferException.java:73)
2013-02-25_21:40:54.42300 at com.google.protobuf.CodedInputStream.checkLastTagWas(CodedInputStream.java:124)
2013-02-25_21:40:54.42301 at com.google.protobuf.AbstractMessageLite$Builder.mergeFrom(AbstractMessageLite.java:163)
2013-02-25_21:40:54.42302 at com.google.protobuf.AbstractMessage$Builder.mergeFrom(AbstractMessage.java:716)
2013-02-25_21:40:54.42302 at com.google.protobuf.AbstractMessage$Builder.mergeFrom(AbstractMessage.java:238)
2013-02
@boorad
boorad / server.log
Last active December 13, 2015 23:29
0 [main] WARN com.mapr.franz.server.ClusterState - connecting to localhost:2108
489 [main-EventThread] INFO com.mapr.franz.server.ClusterState - SyncConnected
987 [main] INFO com.mapr.franz.server.ClusterState - Server -3851085439804092173 reading from status directory /franz
1681 [main] INFO com.mapr.franz.server.ClusterState - Entries: [ca8e323248cc50f3], our file: ca8e323248cc50f3
1681 [main] INFO com.mapr.franz.server.ClusterState - Server -3851085439804092173 read 1 entries in status directory
1681 [main] INFO com.mapr.franz.server.ClusterState - Server -3851085439804092173 has position 0
6964 [main] INFO com.googlecode.protobuf.pro.duplex.RpcServiceRegistry - Registered Blocking CatcherService allowTimeout=Y
18575 [New I/O worker #1] DEBUG com.googlecode.protobuf.pro.duplex.handler.ServerConnectRequestHandler - Received [2]ConnectRequest.
18579 [New I/O worker #1] DEBUG com.googlecode.protobuf.pro.duplex.handler.ServerConnectRequestHandler - Sending [2]ConnectResponse.
18591 [New
@boorad
boorad / sudo.sh
Created November 12, 2012 19:21
sudo to sesudo
#!/bin/bash
declare -a args
while [ $# -gt 0 ] ; do
case "$1" in
-n) shift ;;
*) args=("${args[@]}" "$1") ; shift ;;
esac
done
ERL ?= erl
APP := koth
.PHONY: deps
all: deps
@./rebar compile
deps:
@./rebar get-deps
%%-*- mode: erlang -*-
{deps, [
{webmachine, "1.8.*",
{git, "git://github.com/basho/webmachine", "HEAD"}},
{ibrowse, ".*",
{git, "git://github.com/cmullaparthi/ibrowse.git", "master"}},
{bcrypt, ".*",
{git, "https://github.com/smarkets/erlang-bcrypt.git", {tag, "0.4.1"}}},
{epgsql, ".*",
{git, "https://github.com/wg/epgsql.git", {branch, "master"}}}
@boorad
boorad / gist:775184
Created January 11, 2011 21:28
just... damn.
An innovative and creative leader who excels in strategic planning, distribution development and execution,
analysis of inventory levels and strategic partnerships. Excellent communication and presentation skills.
Core strength in building and cultivating value based distributor relationships generating high impact results
and creating new avenues for growth. Proven ability to foster a team focused environment, fully leveraging cross
functional collaboration among key stakeholders to achieve objectives and develop effective consumer engagement
strategies and realize ROI.
{clause,2179,
[{nil,2179},{var,2179,'Acc'}],
[],
[{call,2180,
{remote,2180,{atom,2180,lists},{atom,2180,reverse}},
[{var,2180,'Acc'}]}]},
{clause,2181,
[{cons,2181,{var,2181,'H'},{var,2181,'T'}},
{var,2181,'Acc'}],
[],
-module(rexi_example).
-export([setup/0, go/0, oh/0]).
setup() ->
% assuming dist. erlang already set up across nodes
rpc:multicall(rexi, start, []).
%% submit the jobs to individual workers (a little verbose for illustration)
go() ->
%% @author Bob Ippolito <bob@mochimedia.com>
%% @copyright 2007 Mochi Media, Inc.
%% @doc Yet another JSON (RFC 4627) library for Erlang. mochijson2 works
%% with binaries as strings, arrays as lists (without an {array, _})
%% wrapper and it only knows how to decode UTF-8 (and ASCII).
-module(mochijson2).
-author('bob@mochimedia.com').
-export([encoder/1, encode/1]).
% fprof:apply(M, F, A)
% fprof:profile()
% fprof:analyse()
-module (reads_bench).
-export ([doit/2]).
doit(Conns, Reps) ->
Begin = erlang:now(),
Self = self(),