Module Import alias Import alias ImportFrom alias Import alias Import alias ImportFrom alias ImportFrom alias ImportFrom alias ImportFrom alias alias ImportFrom alias Assign NameStore Call AttributeLoad NameLoad attr NameLoad ClassDef bases NameLoad body Expr Str FunctionDef arguments args NameParam NameParam NameParam defaults body Expr Call AttributeLoad NameLoad attr NameLoad NameLoad Assign AttributeStore NameLoad attr NameLoad Assign AttributeStore NameLoad attr NameLoad decorator_list FunctionDef arguments args NameParam defaults body Return Call AttributeLoad NameLoad attr decorator_list FunctionDef arguments args NameParam defaults body Assign AttributeStore NameLoad attr NameLoad Return Call AttributeLoad NameLoad attr NameLoad decorator_list FunctionDef arguments args NameParam defaults body Return Call AttributeLoad NameLoad attr decorator_list FunctionDef arguments args NameParam NameParam NameParam NameParam NameParam NameParam defaults body Assign NameStore BinOpAdd Call AttributeLoad NameLoad attr AttributeLoad NameLoad attr Assign NameStore Call AttributeLoad NameLoad attr NameLoad NameLoad NameLoad NameLoad keyword NameLoad FunctionDef arguments args defaults body Return Call AttributeLoad NameLoad attr NameLoad NameLoad decorator_list FunctionDef arguments args defaults body If CompareIsNot AttributeLoad NameLoad attr NameLoad body Expr Call AttributeLoad AttributeLoad NameLoad attr attr ListLoad NameLoad Return NameLoad decorator_list Expr Call AttributeLoad NameLoad attr Lambda arguments args NameParam defaults Call NameLoad Expr Call AttributeLoad NameLoad attr Lambda arguments args NameParam defaults Call NameLoad Return NameLoad decorator_list FunctionDef arguments args NameParam NameParam defaults body Return Call AttributeLoad NameLoad attr NameLoad decorator_list FunctionDef arguments args NameParam NameParam defaults body Return Call AttributeLoad NameLoad attr NameLoad decorator_list FunctionDef arguments args NameParam NameParam defaults body Return Call AttributeLoad NameLoad attr NameLoad decorator_list FunctionDef arguments args NameParam NameParam NameParam defaults body Return Call AttributeLoad NameLoad attr NameLoad NameLoad keyword NameLoad decorator_list FunctionDef arguments args NameParam NameParam NameParam NameParam NameParam NameParam defaults NameLoad NameLoad NameLoad NameLoad body Expr Call AttributeLoad NameLoad attr Str Call NameLoad NameLoad FunctionDef arguments args defaults body If CompareIsNot NameLoad NameLoad body Assign NameStore Call AttributeLoad NameLoad attr NameLoad NameLoad orelse Assign NameStore Call AttributeLoad NameLoad attr NameLoad If CompareIsNot NameLoad NameLoad body Assign NameStore Call AttributeLoad NameLoad attr NameLoad NameLoad orelse Assign NameStore Call AttributeLoad NameLoad attr NameLoad Assign NameStore Call AttributeLoad NameLoad attr ListLoad NameLoad NameLoad FunctionDef arguments args NameParam defaults body Assign NameStore NameLoad Assign NameStore NameLoad If CompareIs SubscriptLoad SubscriptLoad NameLoad Index Num Index Num NameLoad body Assign NameStore SubscriptLoad SubscriptLoad NameLoad Index Num Index Num If CompareIs SubscriptLoad SubscriptLoad NameLoad Index Num Index Num NameLoad body Assign NameStore SubscriptLoad SubscriptLoad NameLoad Index Num Index Num Return TupleLoad NameLoad NameLoad decorator_list Expr Call AttributeLoad NameLoad attr NameLoad Return NameLoad decorator_list FunctionDef arguments args NameParam defaults body Assign TupleStore NameStore NameStore NameLoad Return Call AttributeLoad NameLoad attr NameLoad NameLoad NameLoad NameLoad NameLoad decorator_list Assign NameStore Call NameLoad Expr Call AttributeLoad NameLoad attr NameLoad Return NameLoad decorator_list FunctionDef arguments args NameParam NameParam defaults body Return Call AttributeLoad NameLoad attr NameLoad decorator_list FunctionDef arguments args NameParam NameParam NameParam defaults body Return Call AttributeLoad NameLoad attr NameLoad NameLoad decorator_list FunctionDef arguments args NameParam NameParam defaults body Return Call AttributeLoad NameLoad attr NameLoad decorator_list FunctionDef arguments args NameParam defaults body Assign NameStore BinOpAdd Call AttributeLoad NameLoad attr AttributeLoad NameLoad attr Return Call AttributeLoad NameLoad attr NameLoad decorator_list FunctionDef arguments args NameParam defaults body Assign AttributeStore NameLoad attr Call AttributeLoad NameLoad attr Str Call AttributeLoad AttributeLoad NameLoad attr attr AttributeLoad NameLoad attr Str keyword NameLoad FunctionDef arguments args NameParam defaults body Expr Call AttributeLoad NameLoad attr BinOpAdd BinOpAdd BinOpAdd BinOpAdd BinOpAdd BinOpAdd Str Str Str Str Str Str Str Expr Call AttributeLoad NameLoad attr BinOpAdd BinOpAdd BinOpAdd BinOpAdd BinOpAdd BinOpAdd BinOpAdd BinOpAdd BinOpAdd Str Str Str Str Str Str Str Str Str Str Expr Call AttributeLoad NameLoad attr BinOpAdd BinOpAdd BinOpAdd BinOpAdd Str Str Str Str Str decorator_list Return Call AttributeLoad AttributeLoad NameLoad attr attr NameLoad decorator_list FunctionDef arguments args NameParam NameParam defaults body Assign NameStore Call AttributeLoad AttributeLoad NameLoad attr attr Str TupleLoad NameLoad Expr Call AttributeLoad NameLoad attr Lambda arguments args NameParam defaults IfExp Call NameLoad NameLoad SubscriptLoad SubscriptLoad NameLoad Index Num Index Num Call NameLoad Call NameLoad NameLoad FunctionDef arguments args NameParam NameParam defaults body Expr Call AttributeLoad NameLoad attr Str TupleLoad NameLoad Expr Call AttributeLoad NameLoad attr Str TupleLoad NameLoad Expr Call AttributeLoad NameLoad attr Str TupleLoad NameLoad decorator_list Expr Call AttributeLoad NameLoad attr Lambda arguments args NameParam defaults Call AttributeLoad AttributeLoad NameLoad attr attr NameLoad NameLoad Return NameLoad decorator_list NameLoad FunctionDef arguments args NameParam NameParam NameParam NameParam NameParam NameParam defaults NameLoad body Assign NameStore Call AttributeLoad AttributeLoad NameLoad attr attr Str TupleLoad NameLoad NameLoad NameLoad NameLoad NameLoad FunctionDef arguments args NameParam defaults body If Call AttributeLoad NameLoad attr AttributeLoad NameLoad attr body Raise Call NameLoad NameLoad Return NameLoad decorator_list Expr Call AttributeLoad NameLoad attr NameLoad Return NameLoad decorator_list NameLoad FunctionDef arguments args NameParam defaults body Assign NameStore Call AttributeLoad AttributeLoad NameLoad attr attr Str Expr Call AttributeLoad NameLoad attr Lambda arguments args NameParam defaults ListComp SubscriptLoad NameLoad Index Num comprehension NameStore NameLoad Return NameLoad decorator_list NameLoad FunctionDef arguments args NameParam NameParam defaults body Assign NameStore Call AttributeLoad AttributeLoad NameLoad attr attr Str TupleLoad NameLoad Expr Call AttributeLoad NameLoad attr Lambda arguments args NameParam defaults IfExp Call NameLoad NameLoad SubscriptLoad NameLoad Index Num Call NameLoad Call NameLoad NameLoad Return NameLoad decorator_list NameLoad FunctionDef arguments args NameParam NameParam defaults body Assign NameStore Call AttributeLoad AttributeLoad NameLoad attr attr Str TupleLoad NameLoad Expr Call AttributeLoad NameLoad attr Lambda arguments args NameParam defaults IfExp Call NameLoad NameLoad NameLoad NameLoad Return NameLoad decorator_list NameLoad FunctionDef arguments args NameParam NameParam defaults body FunctionDef arguments args NameParam defaults body Assign NameStore Call AttributeLoad NameLoad attr Assign NameStore Call AttributeLoad NameLoad attr BinOpAdd BinOpAdd Str Str Str TupleLoad NameLoad Assign NameStore ListComp NameLoad comprehension TupleStore NameStore Call AttributeLoad NameLoad attr Expr Call AttributeLoad NameLoad attr BinOpAdd Str Str TupleLoad NameLoad NameLoad Return NameLoad decorator_list Return Call AttributeLoad AttributeLoad NameLoad attr attr NameLoad decorator_list NameLoad FunctionDef arguments args NameParam NameParam NameParam defaults body Assign NameStore Call AttributeLoad AttributeLoad NameLoad attr attr Str TupleLoad NameLoad NameLoad Expr Call AttributeLoad NameLoad attr Lambda arguments args NameParam defaults IfExp Call NameLoad NameLoad SubscriptLoad SubscriptLoad NameLoad Index Num Index Num NameLoad Return NameLoad decorator_list NameLoad FunctionDef arguments args NameParam NameParam NameParam NameParam NameParam NameParam defaults NameLoad NameLoad body Assign NameStore ListLoad Assign NameStore Str AugAssignAdd NameStore Str AugAssignAdd NameStore Str Expr Call AttributeLoad NameLoad attr NameLoad If CompareIsNot NameLoad NameLoad body AugAssignAdd NameStore Str Expr Call AttributeLoad NameLoad attr NameLoad If CompareIsNot NameLoad NameLoad body AugAssignAdd NameStore Str Expr Call AttributeLoad NameLoad attr NameLoad AugAssignAdd NameStore Str If CompareIs NameLoad NameLoad body AugAssignAdd NameStore Str If CompareIsNot NameLoad NameLoad body AugAssignAdd NameStore Str Expr Call AttributeLoad NameLoad attr NameLoad AugAssignAdd NameStore Str Return Call AttributeLoad AttributeLoad NameLoad attr attr NameLoad Call NameLoad NameLoad decorator_list NameLoad FunctionDef arguments args NameParam NameParam NameParam NameParam defaults NameLoad body FunctionDef arguments args NameParam defaults body For NameStore NameLoad body TryExcept body Expr Call AttributeLoad NameLoad attr Str TupleLoad AttributeLoad NameLoad attr NameLoad AttributeLoad NameLoad attr AttributeLoad NameLoad attr AttributeLoad NameLoad attr AttributeLoad NameLoad attr AttributeLoad NameLoad attr handlers ExceptHandler type AttributeLoad NameLoad attr body If CompareIs NameLoad NameLoad body Raise decorator_list Return Call AttributeLoad AttributeLoad NameLoad attr attr NameLoad decorator_list NameLoad FunctionDef arguments args NameParam NameParam defaults body Assign NameStore Call AttributeLoad AttributeLoad NameLoad attr attr Str TupleLoad NameLoad Expr Call AttributeLoad NameLoad attr Lambda arguments args NameParam defaults IfExp Call NameLoad NameLoad SubscriptLoad SubscriptLoad NameLoad Index Num Index Num NameLoad Return NameLoad decorator_list NameLoad FunctionDef arguments args NameParam NameParam NameParam defaults body Return Call AttributeLoad AttributeLoad NameLoad attr attr Str TupleLoad NameLoad NameLoad decorator_list NameLoad FunctionDef arguments args NameParam NameParam defaults body Assign NameStore Call AttributeLoad AttributeLoad NameLoad attr attr Str TupleLoad NameLoad Expr Call AttributeLoad NameLoad attr Lambda arguments args NameParam defaults ListComp SubscriptLoad NameLoad Index Num comprehension NameStore NameLoad Return NameLoad decorator_list NameLoad decorator_list ClassDef bases NameLoad body FunctionDef arguments args NameParam NameParam defaults body Expr Call AttributeLoad NameLoad attr NameLoad NameLoad Assign AttributeStore NameLoad attr Dict Assign AttributeStore NameLoad attr Dict Assign AttributeStore NameLoad attr Dict decorator_list FunctionDef arguments args NameParam defaults body Return Call AttributeLoad NameLoad attr NameLoad decorator_list FunctionDef arguments args NameParam defaults body Return Call AttributeLoad NameLoad attr NameLoad decorator_list FunctionDef arguments args NameParam defaults body Return Call AttributeLoad NameLoad attr Call AttributeLoad AttributeLoad NameLoad attr attr decorator_list FunctionDef arguments args NameParam NameParam NameParam NameParam NameParam NameParam defaults body Assign NameStore BinOpAdd Call AttributeLoad NameLoad attr AttributeLoad NameLoad attr Assign SubscriptStore AttributeLoad NameLoad attr Index NameLoad Dict Str Str Str Str NameLoad NameLoad NameLoad NameLoad Assign NameStore Call AttributeLoad NameLoad attr NameLoad NameLoad FunctionDef arguments args defaults body If CompareIsNot AttributeLoad NameLoad attr NameLoad body Expr Call AttributeLoad AttributeLoad NameLoad attr attr ListLoad NameLoad Return NameLoad decorator_list Expr Call AttributeLoad NameLoad attr Lambda arguments args NameParam defaults Call NameLoad Return NameLoad decorator_list FunctionDef arguments args NameParam NameParam defaults body If CompareIn NameLoad AttributeLoad NameLoad attr body Assign NameStore SubscriptLoad AttributeLoad NameLoad attr Index NameLoad Return Call AttributeLoad NameLoad attr ListLoad SubscriptLoad NameLoad Index Str SubscriptLoad NameLoad Index Str SubscriptLoad NameLoad Index Str Return Call AttributeLoad NameLoad attr NameLoad decorator_list FunctionDef arguments args NameParam NameParam defaults body If CompareIn NameLoad AttributeLoad NameLoad attr body Delete SubscriptDel AttributeLoad NameLoad attr Index NameLoad For TupleStore NameStore NameStore Call AttributeLoad AttributeLoad NameLoad attr attr body If CompareEq NameLoad NameLoad body Delete SubscriptDel AttributeLoad NameLoad attr Index TupleLoad NameLoad NameLoad Return Call AttributeLoad NameLoad attr NameLoad decorator_list FunctionDef arguments args NameParam NameParam NameParam defaults body Assert CompareIn NameLoad AttributeLoad NameLoad attr Str For NameStore NameLoad body Assign NameStore Dict Assign SubscriptStore NameLoad Index Str AttributeLoad NameLoad attr Assign SubscriptStore NameLoad Index Str AttributeLoad NameLoad attr Assign SubscriptStore NameLoad Index Str AttributeLoad NameLoad attr Assign SubscriptStore NameLoad Index Str AttributeLoad NameLoad attr Assign SubscriptStore NameLoad Index Str AttributeLoad NameLoad attr Assign SubscriptStore AttributeLoad NameLoad attr Index TupleLoad NameLoad AttributeLoad NameLoad attr NameLoad Return Call AttributeLoad NameLoad attr NameLoad decorator_list FunctionDef arguments args NameParam NameParam NameParam NameParam NameParam NameParam defaults NameLoad NameLoad NameLoad NameLoad body If CompareIsNot NameLoad NameLoad body Assign NameStore Call AttributeLoad NameLoad attr NameLoad NameLoad orelse Assign NameStore NameLoad If CompareIsNot NameLoad NameLoad body Assign NameStore Call AttributeLoad NameLoad attr NameLoad NameLoad orelse Assign NameStore NameLoad Return Call AttributeLoad NameLoad attr NameLoad NameLoad NameLoad NameLoad NameLoad decorator_list FunctionDef arguments args NameParam NameParam defaults body For TupleStore NameStore NameStore Call AttributeLoad AttributeLoad NameLoad attr attr body If CompareEq NameLoad NameLoad body Return Call AttributeLoad NameLoad attr NameLoad Return Call AttributeLoad NameLoad attr NameLoad decorator_list FunctionDef arguments args NameParam NameParam NameParam NameParam NameParam NameParam defaults NameLoad NameLoad body Assign NameStore ListLoad For TupleStore TupleStore NameStore NameStore NameStore Call AttributeLoad AttributeLoad NameLoad attr attr body If CompareEq NameLoad NameLoad body Assign NameStore SubscriptLoad NameLoad Index Str Assign NameStore SubscriptLoad NameLoad Index Str Assign NameStore SubscriptLoad NameLoad Index Str Assign NameStore SubscriptLoad NameLoad Index Str Assign NameStore SubscriptLoad NameLoad Index Str If BoolOpOr CompareIs NameLoad NameLoad CompareGt NameLoad NameLoad body If BoolOpOr CompareIs NameLoad NameLoad CompareLt NameLoad NameLoad body Expr Call AttributeLoad NameLoad attr TupleLoad NameLoad NameLoad NameLoad NameLoad NameLoad NameLoad Expr Call AttributeLoad NameLoad attr keyword Lambda arguments args NameParam defaults SubscriptLoad NameLoad Index Num keyword NameLoad If CompareIsNot NameLoad NameLoad body Assign NameStore SubscriptLoad NameLoad Slice NameLoad Return Call AttributeLoad NameLoad attr NameLoad decorator_list FunctionDef arguments args NameParam NameParam NameParam defaults body If CompareIn TupleLoad NameLoad NameLoad AttributeLoad NameLoad attr body Return SubscriptLoad SubscriptLoad AttributeLoad NameLoad attr Index TupleLoad NameLoad NameLoad Index Str decorator_list FunctionDef arguments args NameParam NameParam NameParam defaults body Assign SubscriptStore AttributeLoad NameLoad attr Index NameLoad NameLoad Return Call AttributeLoad NameLoad attr NameLoad decorator_list FunctionDef arguments args NameParam NameParam defaults body Return Call AttributeLoad NameLoad attr ListComp NameLoad comprehension TupleStore NameStore NameStore Call AttributeLoad AttributeLoad NameLoad attr attr CompareEq NameLoad NameLoad decorator_list FunctionDef arguments args NameParam defaults body Assign NameStore BinOpAdd Call AttributeLoad NameLoad attr AttributeLoad NameLoad attr Assign NameStore ListLoad Assign NameStore Call AttributeLoad NameLoad attr For TupleStore NameStore NameStore Call AttributeLoad AttributeLoad NameLoad attr attr body Assign NameStore SubscriptLoad NameLoad Index Str If CompareLt NameLoad NameLoad body Assign SubscriptStore SubscriptLoad AttributeLoad NameLoad attr Index NameLoad Index Str NameLoad Expr Call AttributeLoad NameLoad attr NameLoad Return NameLoad decorator_list decorator_list
N/A N/A time N/A logging twisted.enterprise adbapi N/A os N/A sqlite3 twisted.internet defer twisted.python.failure Failure lbrynet.core.server.DHTHashAnnouncer DHTHashSupplier lbrynet.core.Error DuplicateStreamHashError NoSuchStreamHashError lbrynet.core.sqlite_helpers rerun_if_locked N/A log N/A N/A logging getLogger __name__ DBLiveStreamMetadataManager N/A DHTHashSupplier N/A N/A This class stores all stream info in a leveldb database stored in the same directory as the blobfiles __init__ N/A N/A self db_dir hash_announcer N/A N/A N/A N/A N/A DHTHashSupplier __init__ self hash_announcer N/A N/A self db_dir db_dir N/A N/A self db_conn None N/A setup N/A N/A self N/A N/A N/A N/A N/A self _open_db N/A stop N/A N/A self N/A N/A N/A N/A self db_conn None N/A N/A N/A defer succeed True N/A get_all_streams N/A N/A self N/A N/A N/A N/A N/A self _get_all_streams N/A save_stream N/A N/A self stream_hash pub_key file_name key blobs N/A N/A N/A next_announce_time N/A N/A N/A time time N/A self hash_reannounce_time N/A d N/A N/A self _store_stream stream_hash pub_key file_name key next_announce_time next_announce_time save_blobs N/A N/A N/A N/A N/A N/A N/A self add_blobs_to_stream stream_hash blobs N/A announce_have_stream N/A N/A N/A N/A N/A N/A N/A self hash_announcer None N/A N/A N/A N/A N/A self hash_announcer immediate_announce N/A stream_hash N/A stream_hash N/A N/A N/A N/A d addCallback N/A N/A N/A _ N/A N/A save_blobs N/A N/A N/A d addCallback N/A N/A N/A _ N/A N/A announce_have_stream N/A d N/A get_stream_info N/A N/A self stream_hash N/A N/A N/A N/A N/A self _get_stream_info stream_hash N/A check_if_stream_exists N/A N/A self stream_hash N/A N/A N/A N/A N/A self _check_if_stream_exists stream_hash N/A delete_stream N/A N/A self stream_hash N/A N/A N/A N/A N/A self _delete_stream stream_hash N/A add_blobs_to_stream N/A N/A self stream_hash blobs N/A N/A N/A N/A N/A self _add_blobs_to_stream stream_hash blobs ignore_duplicate_error True N/A get_blobs_for_stream N/A N/A self stream_hash start_blob end_blob count reverse N/A None None None False N/A N/A N/A N/A log info Getting blobs for a stream. Count is %s N/A str count get_positions_of_start_and_end N/A N/A N/A N/A N/A N/A start_blob None N/A N/A d1 N/A N/A self _get_blob_num_by_hash stream_hash start_blob N/A N/A d1 N/A N/A defer succeed None N/A N/A end_blob None N/A N/A d2 N/A N/A self _get_blob_num_by_hash stream_hash end_blob N/A N/A d2 N/A N/A defer succeed None N/A dl N/A N/A defer DeferredList N/A d1 d2 get_positions N/A N/A results N/A N/A N/A start_num None N/A end_num None N/A N/A N/A N/A results N/A 0 N/A 0 True N/A N/A start_num N/A N/A results N/A 0 N/A 1 N/A N/A N/A N/A results N/A 1 N/A 0 True N/A N/A end_num N/A N/A results N/A 1 N/A 1 N/A N/A start_num end_num N/A N/A N/A N/A dl addCallback get_positions N/A dl N/A get_blob_infos N/A N/A nums N/A N/A N/A N/A start_num end_num nums N/A N/A N/A self _get_further_blob_infos stream_hash start_num end_num count reverse N/A N/A d N/A get_positions_of_start_and_end N/A N/A N/A d addCallback get_blob_infos N/A d N/A get_stream_of_blob N/A N/A self blob_hash N/A N/A N/A N/A N/A self _get_stream_of_blobhash blob_hash N/A save_sd_blob_hash_to_stream N/A N/A self stream_hash sd_blob_hash N/A N/A N/A N/A N/A self _save_sd_blob_hash_to_stream stream_hash sd_blob_hash N/A get_sd_blob_hashes_for_stream N/A N/A self stream_hash N/A N/A N/A N/A N/A self _get_sd_blob_hashes_for_stream stream_hash N/A hashes_to_announce N/A N/A self N/A N/A N/A next_announce_time N/A N/A N/A time time N/A self hash_reannounce_time N/A N/A N/A self _get_streams_to_announce next_announce_time N/A _open_db N/A N/A self N/A N/A N/A N/A self db_conn N/A N/A adbapi ConnectionPool sqlite3 N/A N/A N/A os path join N/A self db_dir live_stream.db check_same_thread False create_tables N/A N/A transaction N/A N/A N/A N/A N/A transaction execute N/A N/A N/A N/A N/A N/A create table if not exists live_streams (     stream_hash text primary key,      public_key text,      key text,      stream_name text,      next_announce_time real ) N/A N/A N/A transaction execute N/A N/A N/A N/A N/A N/A N/A N/A N/A create table if not exists live_stream_blobs (     blob_hash text,      stream_hash text,      position integer,      revision integer,      iv text,      length integer,      signature text,      foreign key(stream_hash) references live_streams(stream_hash) ) N/A N/A N/A transaction execute N/A N/A N/A N/A create table if not exists live_stream_descriptors (     sd_blob_hash TEXT PRIMARY KEY,      stream_hash TEXT,      foreign key(stream_hash) references live_streams(stream_hash) ) N/A N/A N/A N/A N/A self db_conn runInteraction create_tables N/A _delete_stream N/A N/A self stream_hash N/A N/A N/A d N/A N/A N/A self db_conn runQuery select stream_hash from live_streams where stream_hash = ? N/A stream_hash N/A N/A N/A d addCallback N/A N/A N/A result N/A N/A N/A len result N/A N/A result N/A 0 N/A 0 N/A Failure N/A NoSuchStreamHashError stream_hash do_delete N/A N/A transaction s_h N/A N/A N/A N/A N/A transaction execute delete from live_streams where stream_hash = ? N/A s_h N/A N/A N/A transaction execute delete from live_stream_blobs where stream_hash = ? N/A s_h N/A N/A N/A transaction execute delete from live_stream_descriptors where stream_hash = ? N/A s_h N/A N/A N/A N/A d addCallback N/A N/A N/A s_h N/A N/A N/A N/A self db_conn runInteraction do_delete s_h N/A d N/A rerun_if_locked _store_stream N/A N/A self stream_hash public_key name key next_announce_time N/A None N/A N/A d N/A N/A N/A self db_conn runQuery insert into live_streams values (?, ?, ?, ?, ?) N/A stream_hash public_key key name next_announce_time check_duplicate N/A N/A err N/A N/A N/A N/A N/A err check N/A sqlite3 IntegrityError N/A N/A N/A DuplicateStreamHashError stream_hash N/A err N/A N/A N/A N/A d addErrback check_duplicate N/A d N/A rerun_if_locked _get_all_streams N/A N/A self N/A N/A N/A d N/A N/A N/A self db_conn runQuery select stream_hash from live_streams N/A N/A N/A d addCallback N/A N/A N/A results N/A N/A N/A r N/A 0 N/A r results N/A d N/A rerun_if_locked _get_stream_info N/A N/A self stream_hash N/A N/A N/A d N/A N/A N/A self db_conn runQuery select public_key, key, stream_name from live_streams where stream_hash = ? N/A stream_hash N/A N/A N/A d addCallback N/A N/A N/A result N/A N/A N/A len result N/A result N/A 0 N/A Failure N/A NoSuchStreamHashError stream_hash N/A d N/A rerun_if_locked _check_if_stream_exists N/A N/A self stream_hash N/A N/A N/A d N/A N/A N/A self db_conn runQuery select stream_hash from live_streams where stream_hash = ? N/A stream_hash N/A N/A N/A d addCallback N/A N/A N/A r N/A N/A N/A len r True False N/A d N/A rerun_if_locked _get_streams_to_announce N/A N/A self next_announce_time N/A N/A get_and_update N/A N/A transaction N/A N/A N/A timestamp N/A N/A time time N/A r N/A N/A transaction execute N/A N/A select stream_hash from live_streams where     (next_announce_time is null or next_announce_time < ?)      and stream_hash is not null N/A timestamp N/A s_hs N/A s_h N/A N/A s_h N/A N/A r fetchall N/A N/A N/A transaction execute N/A update live_streams set next_announce_time = ? where      (next_announce_time is null or next_announce_time < ?) N/A next_announce_time timestamp N/A s_hs N/A N/A N/A N/A N/A self db_conn runInteraction get_and_update N/A rerun_if_locked _get_blob_num_by_hash N/A N/A self stream_hash blob_hash N/A N/A N/A d N/A N/A N/A self db_conn runQuery select position from live_stream_blobs where stream_hash = ? and blob_hash = ? N/A stream_hash blob_hash N/A N/A N/A d addCallback N/A N/A N/A r N/A N/A N/A len r N/A N/A r N/A 0 N/A 0 None N/A d N/A rerun_if_locked _get_further_blob_infos N/A N/A self stream_hash start_num end_num count reverse N/A None False N/A N/A params N/A N/A q_string select * from ( N/A q_string   select blob_hash, position, revision, iv, length, signature from live_stream_blobs  N/A q_string     where stream_hash = ?  N/A N/A N/A params append stream_hash N/A N/A start_num None N/A N/A q_string     and position > ?  N/A N/A N/A params append start_num N/A N/A end_num None N/A N/A q_string     and position < ?  N/A N/A N/A params append end_num N/A q_string     order by position  N/A N/A reverse True N/A N/A q_string    DESC  N/A N/A count None N/A N/A q_string     limit ?  N/A N/A N/A params append count N/A q_string ) order by position N/A N/A N/A N/A self db_conn runQuery q_string N/A tuple params N/A rerun_if_locked _add_blobs_to_stream N/A N/A self stream_hash blob_infos ignore_duplicate_error N/A False N/A add_blobs N/A N/A transaction N/A N/A N/A blob_info blob_infos N/A N/A N/A N/A N/A N/A transaction execute insert into live_stream_blobs values (?, ?, ?, ?, ?, ?, ?) N/A N/A blob_info blob_hash stream_hash N/A blob_info blob_num N/A blob_info revision N/A blob_info iv N/A blob_info length N/A blob_info signature N/A N/A N/A N/A sqlite3 IntegrityError N/A N/A N/A ignore_duplicate_error False N/A N/A N/A N/A N/A N/A N/A self db_conn runInteraction add_blobs N/A rerun_if_locked _get_stream_of_blobhash N/A N/A self blob_hash N/A N/A N/A d N/A N/A N/A self db_conn runQuery select stream_hash from live_stream_blobs where blob_hash = ? N/A blob_hash N/A N/A N/A d addCallback N/A N/A N/A r N/A N/A N/A len r N/A N/A r N/A 0 N/A 0 None N/A d N/A rerun_if_locked _save_sd_blob_hash_to_stream N/A N/A self stream_hash sd_blob_hash N/A N/A N/A N/A N/A N/A self db_conn runQuery insert into live_stream_descriptors values (?, ?) N/A sd_blob_hash stream_hash N/A rerun_if_locked _get_sd_blob_hashes_for_stream N/A N/A self stream_hash N/A N/A N/A d N/A N/A N/A self db_conn runQuery select sd_blob_hash from live_stream_descriptors where stream_hash = ? N/A stream_hash N/A N/A N/A d addCallback N/A N/A N/A results N/A N/A N/A r N/A 0 N/A r results N/A d N/A rerun_if_locked N/A TempLiveStreamMetadataManager N/A DHTHashSupplier N/A __init__ N/A N/A self hash_announcer N/A N/A N/A N/A N/A DHTHashSupplier __init__ self hash_announcer N/A N/A self streams N/A N/A N/A self stream_blobs N/A N/A N/A self stream_desc N/A N/A setup N/A N/A self N/A N/A N/A N/A N/A defer succeed True N/A stop N/A N/A self N/A N/A N/A N/A N/A defer succeed True N/A get_all_streams N/A N/A self N/A N/A N/A N/A N/A defer succeed N/A N/A N/A self streams keys N/A save_stream N/A N/A self stream_hash pub_key file_name key blobs N/A N/A N/A next_announce_time N/A N/A N/A time time N/A self hash_reannounce_time N/A N/A N/A self streams N/A stream_hash N/A public_key stream_name key next_announce_time pub_key file_name key next_announce_time N/A d N/A N/A self add_blobs_to_stream stream_hash blobs announce_have_stream N/A N/A N/A N/A N/A N/A N/A self hash_announcer None N/A N/A N/A N/A N/A self hash_announcer immediate_announce N/A stream_hash N/A stream_hash N/A N/A N/A N/A d addCallback N/A N/A N/A _ N/A N/A announce_have_stream N/A d N/A get_stream_info N/A N/A self stream_hash N/A N/A N/A N/A stream_hash N/A self streams N/A N/A stream_info N/A N/A self streams N/A stream_hash N/A N/A N/A defer succeed N/A N/A stream_info N/A public_key N/A stream_info N/A key N/A stream_info N/A stream_name N/A N/A N/A defer succeed None N/A delete_stream N/A N/A self stream_hash N/A N/A N/A N/A stream_hash N/A self streams N/A N/A N/A N/A self streams N/A stream_hash N/A N/A s_h b_h N/A N/A N/A self stream_blobs keys N/A N/A N/A s_h stream_hash N/A N/A N/A N/A self stream_blobs N/A N/A s_h b_h N/A N/A N/A defer succeed True N/A add_blobs_to_stream N/A N/A self stream_hash blobs N/A N/A N/A N/A stream_hash N/A self streams Can't add blobs to a stream that isn't known N/A blob blobs N/A N/A info N/A N/A N/A info N/A blob_num N/A blob blob_num N/A N/A info N/A length N/A blob length N/A N/A info N/A iv N/A blob iv N/A N/A info N/A revision N/A blob revision N/A N/A info N/A signature N/A blob signature N/A N/A N/A self stream_blobs N/A N/A stream_hash N/A blob blob_hash info N/A N/A N/A defer succeed True N/A get_blobs_for_stream N/A N/A self stream_hash start_blob end_blob count reverse N/A None None None False N/A N/A N/A start_blob None N/A N/A start_num N/A N/A self _get_blob_num_by_hash stream_hash start_blob N/A N/A start_num None N/A N/A end_blob None N/A N/A end_num N/A N/A self _get_blob_num_by_hash stream_hash end_blob N/A N/A end_num None N/A N/A N/A self _get_further_blob_infos stream_hash start_num end_num count reverse N/A get_stream_of_blob N/A N/A self blob_hash N/A N/A N/A N/A s_h b_h N/A N/A N/A self stream_blobs iterkeys N/A N/A N/A b_h blob_hash N/A N/A N/A N/A defer succeed s_h N/A N/A N/A defer succeed None N/A _get_further_blob_infos N/A N/A self stream_hash start_num end_num count reverse N/A None False N/A N/A blob_infos N/A N/A N/A N/A s_h b_h info N/A N/A N/A self stream_blobs iteritems N/A N/A N/A stream_hash s_h N/A N/A position N/A info N/A blob_num N/A length N/A info N/A length N/A iv N/A info N/A iv N/A revision N/A info N/A revision N/A signature N/A info N/A signature N/A N/A N/A start_num None N/A position start_num N/A N/A N/A N/A end_num None N/A position end_num N/A N/A N/A N/A blob_infos append N/A b_h position revision iv length signature N/A N/A N/A blob_infos sort key N/A N/A N/A i N/A N/A i N/A 1 reverse reverse N/A N/A count None N/A N/A blob_infos N/A blob_infos N/A count N/A N/A N/A defer succeed blob_infos N/A _get_blob_num_by_hash N/A N/A self stream_hash blob_hash N/A N/A N/A N/A N/A stream_hash blob_hash N/A self stream_blobs N/A N/A N/A N/A N/A self stream_blobs N/A N/A stream_hash blob_hash N/A blob_num N/A save_sd_blob_hash_to_stream N/A N/A self stream_hash sd_blob_hash N/A N/A N/A N/A N/A self stream_desc N/A sd_blob_hash stream_hash N/A N/A N/A defer succeed True N/A get_sd_blob_hashes_for_stream N/A N/A self stream_hash N/A N/A N/A N/A N/A defer succeed N/A sd_hash N/A N/A sd_hash s_h N/A N/A N/A self stream_desc iteritems N/A s_h stream_hash N/A hashes_to_announce N/A N/A self N/A N/A N/A next_announce_time N/A N/A N/A time time N/A self hash_reannounce_time N/A stream_hashes N/A N/A current_time N/A N/A time time N/A N/A stream_hash stream_info N/A N/A N/A self streams iteritems N/A N/A announce_time N/A stream_info N/A announce_time N/A N/A announce_time current_time N/A N/A N/A N/A N/A self streams N/A stream_hash N/A announce_time next_announce_time N/A N/A N/A stream_hashes append stream_hash N/A stream_hashes N/A N/A