From f25929e45cfbe25bb7401c9af126d353e1eaef86 Mon Sep 17 00:00:00 2001 From: Alex Auvolat Date: Tue, 6 Nov 2018 15:22:30 +0100 Subject: Cleanup ; make file download from CLI doable --- shard/lib/app/chat.ex | 2 +- shard/lib/app/file.ex | 13 ++++++------- shard/lib/app/pagestore.ex | 7 +++++++ shard/lib/cli/cli.ex | 36 ++++++++++++++++++++++++++++++++++-- shard/lib/manager.ex | 7 +++++++ 5 files changed, 55 insertions(+), 10 deletions(-) (limited to 'shard') diff --git a/shard/lib/app/chat.ex b/shard/lib/app/chat.ex index b046fc3..8a72d48 100644 --- a/shard/lib/app/chat.ex +++ b/shard/lib/app/chat.ex @@ -130,7 +130,7 @@ defmodule SApp.Chat do end def handle_call(:delete_shard, _from, state) do - GenServer.call(state.store, :delete_store) + SApp.PageStore.delete_store(state.store) {:stop, :normal, :ok, state} end diff --git a/shard/lib/app/file.ex b/shard/lib/app/file.ex index 0e07cc3..7f03e1f 100644 --- a/shard/lib/app/file.ex +++ b/shard/lib/app/file.ex @@ -85,7 +85,7 @@ defmodule SApp.File do infobin -> info = SData.term_unbin(infobin) Process.send_after(self(), {:calc_missing, 1}, 100) - GenServer.cast(store, {:set_roots, [info.merkle_root]}) + SApp.PageStore.set_roots(store, [info.merkle_root]) {infobin, info} end @@ -100,14 +100,14 @@ defmodule SApp.File do end def handle_call(:delete_shard, _from, state) do - GenServer.call(state.store, :delete_store) + SApp.PageStore.delete_store(state.store) File.rm(state.path) {:stop, :normal, :ok, state} end def handle_call(:get_info, _from, state) do reply = cond do - state.info != nil and GenServer.call(state.store, {:have_rec, state.info.merkle_root}) -> + state.info != nil and SApp.PageStore.have_rec?(state.store, state.info.merkle_root) -> mt = get_mt(state) nblk = MT.block_count(mt) [infohash: state.infohash, @@ -185,7 +185,7 @@ defmodule SApp.File do if state.infobin == nil and SData.bin_hash(infobin) == state.infohash do Shard.Manager.save_state(state.id, infobin) state = %{state | infobin: infobin, info: SData.term_unbin(infobin)} - GenServer.cast(state.store, {:set_roots, [state.info.merkle_root]}) + SApp.PageStore.set_roots(state.store, [state.info.merkle_root]) Process.send_after(self(), {:calc_missing, 1}, 100) state else @@ -240,7 +240,7 @@ defmodule SApp.File do def handle_info({:calc_missing, iter}, state) do if state.info != nil do Logger.info(":calc_missing for #{state.id|>Base.encode16}") - missing = case GenServer.call(state.store, {:have_rec, state.info.merkle_root}) do + missing = case SApp.PageStore.have_rec?(state.store, state.info.merkle_root) do true -> meta = get_mt(state) n_blocks = MT.block_count(meta) @@ -266,7 +266,7 @@ defmodule SApp.File do missing false -> Logger.info("Incomplete Merkle tree meta data, requesting info from peers.") - GenServer.cast(state.store, {:set_roots, [state.info.merkle_root]}) + SApp.PageStore.set_roots(state.store, [state.info.merkle_root]) Process.send_after(self(), {:calc_missing, iter + 1}, iter * 1000) nil end @@ -302,7 +302,6 @@ defmodule SApp.File do pieces = can_req |> Enum.sort() |> Enum.take(@concurrent_reqs - n_curr_req) Enum.reduce(pieces, state, fn id, state -> who = a_random_peer(state.missing[id]) - Logger.info("#{state.id|>Base.encode16} | Req #{id} to #{inspect who}") SNet.Manager.send(who, {state.id, nil, {:get, id}}) Process.send_after(self(), {:req_timeout, id}, @req_timeout_msec) put_in(state.reqs[id], who) diff --git a/shard/lib/app/pagestore.ex b/shard/lib/app/pagestore.ex index 0cbb10a..79d39b7 100644 --- a/shard/lib/app/pagestore.ex +++ b/shard/lib/app/pagestore.ex @@ -329,4 +329,11 @@ defmodule SApp.PageStore do def set_roots(pid, roots) do GenServer.cast(pid, {:set_roots, roots}) end + + @doc""" + Delete the page store. The process is stopped and the data file is deleted from disk. + """ + def delete_store(pid) do + GenServer.call(pid, :delete_store) + end end diff --git a/shard/lib/cli/cli.ex b/shard/lib/cli/cli.ex index 8495b93..a9eaa95 100644 --- a/shard/lib/cli/cli.ex +++ b/shard/lib/cli/cli.ex @@ -105,7 +105,7 @@ defmodule SCLI do end defp handle_command(state, ["list"]) do - IO.puts "Private conversations:" + IO.puts "\nPrivate conversations:\n----" for {_chid, %SApp.Chat.PrivChat.Manifest{pk_list: pk_list}, _} <- Shard.Manager.list_shards do pk_list |> Enum.filter(&(&1 != state.pk)) @@ -114,10 +114,11 @@ defmodule SCLI do |> IO.puts end - IO.puts "Public channels we are connected to:" + IO.puts "\nPublic channels we are connected to:\n----" for {_chid, %SApp.Chat.Manifest{channel: chan}, _} <- Shard.Manager.list_shards do IO.puts "##{chan}" end + IO.puts "" state end @@ -209,10 +210,41 @@ defmodule SCLI do end defp handle_command(state, ["shards"]) do + IO.puts("\nList of shards:\n----") Shard.Manager.list_shards |> Enum.map(&(ShardURI.from_manifest(elem(&1, 1)))) |> Enum.sort() |> Enum.map(&IO.puts/1) + IO.puts("") + state + end + + defp handle_command(state, ["delete", uri]) do + manifest = ShardURI.to_manifest uri + id = SData.term_hash manifest + case Shard.Manager.delete(id) do + :ok -> IO.puts "OK" + {:error, :not_found} -> IO.puts "Shard not found" + {:error, :pinned} -> IO.puts "Shard is pinned, could not be deleted" + end + state + end + + defp handle_command(state, ["info", uri]) do + manifest = ShardURI.to_manifest uri + case manifest do + %SApp.File.Manifest{} -> + pid = Shard.Manager.find_or_start manifest + info = GenServer.call(pid, :get_info) + IO.puts(inspect(info, pretty: true, width: 40)) + _ -> + IO.puts("Info not supported for this shard") + end + state + end + + defp handle_command(state, ["help"]) do + IO.puts("See README.md for help") state end diff --git a/shard/lib/manager.ex b/shard/lib/manager.ex index ed21380..efa9189 100644 --- a/shard/lib/manager.ex +++ b/shard/lib/manager.ex @@ -412,4 +412,11 @@ defmodule Shard.Manager do def list_shards() do for [{id, m, why, _}] <- :dets.match(@shard_db, :"$1"), do: {id, m, why} end + + @doc""" + Check if we are storing this shard + """ + def have_shard?(shard_id) do + :dets.lookup(@shard_db, shard_id) != [] + end end -- cgit v1.2.3