oltarasenko

    def spider_closed(self, spider):
        path = spider.crawler.settings\
            .get('AUTOQA_REPORTING_BACKEND')

        reporting = load_object(path)()

        reporting.send_report(self.issues, spider.crawler.stats)

oltarasenko

<div class="login-entry">
        <div class="head">
            <h2>账户登录</h2>
            <b class="line"></b> </div>
       	<div style="font-size: 12px; display: block;" class="login-error"><table><tbody><tr><td id="tip">请输入用户名</td></tr></tbody></table></div>
        <ul class="login-items">
            <li>
                <label>用户名</label>
                <input type="text" value="昵称/邮箱/手机号" maxlength="32" onblur="chekNkNamefor();" class="input" name="userName" id="userName">
                <div id="messageUserName" class="error"></div>

oltarasenko

(oleg@10.154.1.59)20> eprof:analyze(total).
FUNCTION                                      CALLS        %     TIME  [uS / CALLS]
--------                                      -----  -------     ----  [----------]
io:o_request/3                                    1     0.00        1  [      1.00]
io:format/2                                       1     0.00        1  [      1.00]
io:format/3                                       1     0.00        1  [      1.00]
flood1:'-start_ping/2-fun-0-'/1                   1     0.00        1  [      1.00]
rpc:do_call/3                                     1     0.00        1  [      1.00]
rpc:rpc_check/1                                   1     0.00        1  [      1.00]
gen:'-call/4-fun-0-'/4                            2     0.00        2  [      1.00]

oltarasenko

➜  erlang_mq_boost_2 erl -name oleg@10.154.1.59 -setcookie a -kernel dist_nodelay 'false' inet_dist_connect_options '[{buffer, 365536}, {sndbuf, 265536}]' +zdbbl 209715
Erlang/OTP 20 [erts-9.2] [source] [64-bit] [smp:8:8] [ds:8:8:10] [async-threads:10] [hipe] [kernel-poll:false]

Eshell V9.2  (abort with ^G)
(oleg@10.154.1.59)1> dbg:tracer().
{ok,<0.72.0>}
(oleg@10.154.1.59)2> dbg:p(all, c).
{ok,[{matched,'oleg@10.154.1.59',40}]}
(oleg@10.154.1.59)3> dbg:tp(prim_inet, send, cx).
{ok,[{matched,'oleg@10.154.1.59',2},{saved,cx}]}

oltarasenko

loop(State) ->
    receive
	{From, {write, Tid, Oid}} ->
	    try_sticky_lock(Tid, write, From, Oid),
	    loop(State);

	%% If Key == ?ALL it's a request to lock the entire table
	%%

	{From, {read, Tid, Oid}} ->

oltarasenko

{"Multiline for long messages", {timeout, 190 ,fun() -> 
                meck:expect(gen_tcp, recv, fun(_, _, _) -> {ok, <<"+OK POP3 ready">>} end),
                Opts = [{addr, "pop.gmail.com"}, {port, 995}],
                {ok, Connection} = epop_client:connect("test@example.com", "foo", Opts, 1000),

                Chunk = << <<"X">> || X <- lists:seq(1,  10 * 1000) >>,
                Msgs = [{ok, <<"+OK Some">>}] ++ [{ok, Chunk} || _X <- lists:seq(1, 1 * 100)] ++ [{ok, <<"\r\n.\r\n">>}],
                ?debugMsg("List generated"),
                Loop = meck:loop(Msgs),
                meck:expect(gen_tcp, recv, 3, Loop),

oltarasenko

iex(1)> Sample.start_kids(2, 150_000)
pids: [#PID<0.120.0>, #PID<0.121.0>]
[#PID<0.120.0>, #PID<0.121.0>]
iex(2)> erlang:process_info(pid("0.120.0"))
** (SyntaxError) iex:2: keyword argument must be followed by space after: erlang:

iex(2)> :erlang.process_info(pid("0.120.0"))
[current_function: {:timer, :sleep, 1}, initial_call: {:erlang, :apply, 2},
 status: :waiting, message_queue_len: 0, messages: [], links: [#PID<0.117.0>],
 dictionary: [], trap_exit: false, error_handler: :error_handler,

oltarasenko

{"Multiline for long messages", {timeout, 190 ,fun() -> 
                meck:expect(gen_tcp, recv, fun(_, _, _) -> {ok, <<"+OK POP3 ready">>} end),
                Opts = [{addr, "pop.gmail.com"}, {port, 995}],
                {ok, Connection} = epop_client:connect("test@example.com", "foo", Opts, 1000),

                % Creating 1Kb chunk
                Chunk = << <<"X">> || X <- lists:seq(1,  1 * 1000) >>,

                % Generating a 10 Mb binary
                Msgs = [{ok, <<"+OK Some">>}] ++ [{ok, Chunk} || _X <- lists:seq(1, 10 * 1000)] ++ [{ok, <<"\r\n.\r\n">>}],

oltarasenko

# Node1: 
Process.register(self(), :test)
  x = 100000
  list = :lists.seq(1, x)
  sender = fn -> Enum.each(list, fn x -> send({:test, :'master@127.0.0.1'}, {:msg, x}) end) end
  sender_pid =
    spawn(
      fn ->
        receive do

oltarasenko

 - {:bad_cert, :hostname_check_failed}

# 14:42:34 #PID<0.2421.0> :tls_connection.init/1
# :public_key.pkix_verify_hostname({:OTPCertificate, {:OTPTBSCertificate, :v3, 1, {:SignatureAlgorithm, {1, 2, 840, 113549, 1, 1, 11}, :NULL}, {:rdnSequence, [[{:AttributeTypeAndValue, {2, 5, 4, 3}, {:utf8String, "TLSGenSelfSignedtRootCA"}}], [{:AttributeTypeAndValue, {2, 5, 4, 7}, {:utf8String, "$$$$"}}]]}, {:Validity, {:utcTime, '200824121748Z'}, {:utcTime, '300822121748Z'}}, {:rdnSequence, [[{:AttributeTypeAndValue, {2, 5, 4, 3}, {:utf8String, "Olegs-MacBook-Pro.local"}}], [{:AttributeTypeAndValue, {2, 5, 4, 10}, {:utf8String, "server"}}]]}, {:OTPSubjectPublicKeyInfo, {:PublicKeyAlgorithm, {1, 2, 840, 113549, 1, 1, 1}, :NULL}, {:RSAPublicKey, 25486709655316474076753646767195200610076586850994254987565594242766448221943942069841762706618919149033159989017996028984363458414468212282394755490965231574106428020325828854087333938956723307642962597950997009629974443986464219080665540561545073193548723741481282110582424037942