美國Tilera公司的眾核伺服器，單顆核心包含64顆CPU。硬體架構圖：

卡長這樣的：

Erlang已經可以在這款CPU上成功執行，我們可以參考Ulf Wiger在Multicore ☺ Message-passing Concurrency 文件中關於Erlang在Tilera上的效能圖.

Erlang系統前2年就開始正式支援Tilera，一直用這個CPU來調整他的排程器，所以效能和基礎的編譯執行支援都很到位。

Linux核心2.6.36起就開始支援Tilera的CPU架構了，看起來前途不錯。

最近 上海泛騰電子科技 開始在國內銷售 Tilera機器， 我公司也得到一臺樣機，使得我有機會把玩下這個高科技！

該測試機是PCI-e的形式，是單板機，直接安裝在PC機或者是伺服器裡,好處是可以通過主機的VGA口接顯示器直接除錯。當然也可以作為智慧網絡卡來使用。構成一個與Host的異構結構，通過PCI-e匯流排進行通訊。

還需要相應的配套SDK: 目前有TileraMDE-2.1.2.112814 和 TileraMDE-3.0.alpha3.116173 二個版本, 來負責和板卡的通訊。 推薦用2.0的，好像不容易出問題。

廢話少說，讓我們開始享受64核心快樂旅程吧！

# wget http://www.erlang.org/download/otp_src_R13B03.tar.gz  %%R13B04後otp_build變了好像有點問題，編譯不過去。
# tar xzf otp_src_R13B03.tar.gz 
# cd otp_src_R13B03
%%由於R13B03有個小小的bug會導致segment fault,我們需要對erl_misc_utils.c打個patch,以下是要打patch的地方:
# diff -Nau otp_src_R13B04/erts/lib_src/common/erl_misc_utils.c{~,}
--- otp_src_R13B04/erts/lib_src/common/erl_misc_utils.c~
2009-11-20 14:32:23.000000000 +0100
+++ otp_src_R13B04/erts/lib_src/common/erl_misc_utils.c 2010-03-29
15:53:28.000000000 +0200
@@ -373,8 +373,8 @@
        return 0;
     memcpy((void *) topology,
           (void *) cpuinfo->topology,
-          cpuinfo->configured*sizeof(erts_cpu_topology_t));
-    return cpuinfo->configured;
+          cpuinfo->topology_size*sizeof(erts_cpu_topology_t));
+    return cpuinfo->topology_size;
 } 
%%原始碼算是準備完畢了 

%%開始編譯前的環境準備
# export ERL_TOP=`pwd`  
# eval `./otp_build env_cross $ERL_TOP/xcomp/erl-xcomp-TileraMDE2.0-tilepro.conf`
# export TILERA_ROOT=/root/TileraMDE-2.1.2.112814/tilepro/  %%這個最好用2.x版本的
# export PATH=$TILERA_ROOT/bin:$PATH 
# tile-monitor --pci -- uname -a  %%驗證板卡確實可用
Linux localhost 2.6.26.7-MDE-2.1.2.112814 #1 SMP Wed Sep 1 00:05:06 EDT 2010 tile GNU/Linux

%%開始交叉編譯
# ./otp_build configure 
# touch lib/crypto/SKIP &&  touch lib/ssl/SKIP && touch lib/ssh/SKIP   %%這幾個模組用到了openssl, 編譯不過去，忽略掉
# ./otp_build boot -a  
# ./otp_build release -a /tmp/otp %%安裝到/tmp/otp目錄去

%%如果一切順利，到這時候就編譯完畢了。

%%我們開始收穫成果。

# cd /tmp/otp
# ./Install `pwd` 
#  tile-monitor --pci --here -- bin/erl  %%沒出錯的話，就說明我們成功了。

%%當然我們可以把otp系統上載到板卡去，方便日後使用
# $TILERA_ROOT/bin/tile-monitor --pci  --upload /tmp/otp /tmp/otp --quit   %% 放在板卡的/tmp/otp目錄下

%%我們還可以定義個命令別名，方便我們執行命令
# tile_erl="$TILERA_ROOT/bin/tile-monitor --pci --resume --tunnel 2023 23  --env HOME=/tmp  --tiles - all ^0 - -- /tmp/otp/bin/erl"
# $tile_erl +sct L10-18,1-9,19-55,57,58,61c1-55,57,58,61 +sbt db   -noshell +S 58 -s init stop 

好吧到此為止，我們在目標機器上/tmp/otp目錄下有個完整的erlang系統。

我們開個console連線到板載的linux系統去：

[[email protected] otp_src_R13B03]# /root/TileraMDE-2.1.2.112814/tilepro/bin/tile-console 
tile-console: Assuming '--pci'.
Connecting to /dev/ttyS0, speed 115200
 Escape character: Ctrl-\ (ASCII 28, FS): enabled
Type the escape character followed by C to get back,
or followed by ? to see other options.
----------------------------------------------------
# uname -a
Linux localhost 2.6.26.7-MDE-2.1.2.112814 #1 SMP Wed Sep 1 00:05:06 EDT 2010 tile GNU/Linux

# cd /tmp/otp
%%我們跑個erlang程式<em>64核心並行</em>進行數學計算
%% 程式碼在這裡下載 http://shootout.alioth.debian.org/u32/program.php?test=spectralnorm&lang=hipe&id=2
#cat > spectralnorm.erl 
%   The Computer Language Benchmarks Game
%   http://shootout.alioth.debian.org/
%   contributed by Fredrik Svahn

-module(spectralnorm).
-export([main/1]).
-compile( [ inline, { inline_size, 1000 } ] ).

main([Arg]) ->
    register(server, self()),
    N = list_to_integer(Arg),
    {U, V} = power_method(N, 10, erlang:make_tuple(N, 1), []),
    io:format("~.9f\n", [ eigen(N, U, V, 0, 0) ]),
    erlang:halt(0).

% eigenvalue of V
eigen(0, _, _, VBV, VV) when VV /= 0 -> math:sqrt(VBV / VV);

eigen(I, U, V, VBV, VV) when I /= 0 ->
    VI = element(I, V),
    eigen(I-1, U, V, VBV + element(I, U)*VI, VV + VI*VI).

% 2I steps of the power method
power_method(_, 0, A, B) -> {A, B};
power_method(N, I, A, _B) ->
    V = atav(N, A),
    U = atav(N, V),
    power_method(N, I-1, U, V).


% return element i,j of infinite matrix A
a(II,JJ) -> 1/((II+JJ-2)*(II-1+JJ)/2+II).


% multiply vector v by matrix A
av(N, V) -> pmap(N, fun(Begin, End) -> av(N, Begin, End, V) end).

av(N, Begin, End, V) -> server ! { self(), [ avloop(N, I, V, 0.0) || I <- lists:seq(Begin, End) ]}.

avloop(0, _, _, X) ->  X;
avloop(J, I, V, X) ->  avloop(J-1, I, V, X + a(I, J)*element(J, V) ).


% multiply vector v by matrix A transposed
atv(N, V) -> pmap(N, fun(Begin, End)-> atv(N, Begin, End, V) end).

atv(N, Begin, End, V) -> server ! { self(), [ atvloop(N, I, V, 0.0) || I <- lists:seq(Begin, End) ]}.

atvloop(0, _, _, X) -> X;
atvloop(J, I, V, X) -> atvloop(J-1, I, V, X + a(J, I)*element(J, V) ).


% multiply vector v by matrix A and then by matrix A transposed
atav(N, V) -> atv(N, av(N, V)).


%Helper function for multicore
pmap(N, F) ->
    Chunks = chunks(0, erlang:system_info(logical_processors), N, []),
    Pids = [spawn(fun()-> F(Begin, End) end) || {Begin, End} <- Chunks],
    Res = [ receive {Pid, X} -> X end || Pid <- Pids],
    list_to_tuple(lists:flatten(Res)).

chunks(I, P, N, A) when I == P-1 -> lists:reverse([{I*(N div P)+1, N} | A ]);
chunks(I, P, N, A) -> chunks(I+1, P, N, [{ I*(N div P)+1, (I+1)*(N div P)} | A ]).

CTRL+D

# bin/erlc spectralnorm.erl 
# time bin/erl -noshell -run spectralnorm  main 500  -s init stop
1.274224116
real    0m 16.90s
user    1m 16.07s
sys     0m 0.79s
# bin/erl  +sct L10-18,1-9,19-55,57,58,61c1-55,57,58,61 +sbt db   -noshell +S 58 -eval 'io:format("schedulers: ~p~n"[erlang:system_info(schedulers)])' -s init stop 
schedulers: 58

Bingo! 我們順利的跑了數學計算，同時繫結排程器到CPU core上去了。接下來就可以按照平常那樣進行Erlang併發程式設計了。

祝玩的開心！

Post Footer automatically generated by wp-posturl plugin for wordpress.

No related posts.