Bob Dionne bdionne
bdionne
/ couch_replicator_manager.erl
Created
February 12, 2013 13:38
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| update_rep_doc(RepDbName, RepDocId, KVs) when is_binary(RepDocId) -> | |
| {Pid, Ref} = | |
| spawn_monitor(fun() -> | |
| try | |
| case fabric:open_doc(mem3:dbname(RepDbName), RepDocId, []) of | |
| {ok, LatestRepDoc} -> | |
| update_rep_doc(RepDbName, LatestRepDoc, KVs); | |
| _ -> | |
| ok | |
| end |
bdionne
/ couch_replicator_manager.erl
Created
February 12, 2013 13:42
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| update_rep_doc(RepDbName, RepDocId, KVs) when is_binary(RepDocId) -> | |
| {Pid, Ref} = | |
| spawn_monitor(fun() -> | |
| try | |
| case fabric:open_doc(mem3:dbname(RepDbName), RepDocId, []) of | |
| {ok, LatestRepDoc} -> | |
| update_rep_doc(RepDbName, LatestRepDoc, KVs); | |
| _ -> | |
| ok | |
| end |
bdionne
/ *shell*<4>.txt
Created
February 15, 2013 14:44
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| wtf is this [{<<"seq">>, | |
| <<"65669-g1AAAAFTeJzLYWBg4MhgTmHgS0ktM3QwNDLXMwBCwxygOFMiQ5L8____s5IYGBQicClKUgCSSfYwdY441TmA1MXD1NnhVJcAUldP0Lw8FiDJ0ACkgErng9TKn8CvdgFE7X6w2l_41R6AqL0PVluEX-0DiFqIey2zAHNuV8A">>}, | |
| {<<"id">>,<<"t3">>}, | |
| {<<"changes">>, | |
| [{[{<<"rev">>,<<"3-979a18ab2b78ea0aed4f0744d8672ca9">>}]}]}, | |
| {<<"deleted">>,true}] | |
| (dev1@127.0.0.1)1> edat wtf {doc_info,<<"t3">>, | |
| <<"65669-g1AAAAFTeJzLYWBg4MhgTmHgS0ktM3QwNDLXMwBCwxygOFMiQ5L8____s5IYGBQicClKUgCSSfYwdY441TmA1MXD1NnhVJcAUldP0Lw8FiDJ0ACkgErng9TKn8CvdgFE7X6w2l_41R6AqL0PVluEX-0DiFqIey2zAHNuV8A">>, | |
| [{rev_info,{3, | |
| <<151,154,24,171,43,120,234,10,237,79,7,68,216, |
bdionne
/ *shell*.txt
Created
February 19, 2013 14:50
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| binary_to_term(couch_util:decodeBase64Url("g1AAAACfeJzLYWBgYMlgTmHgS0ktM3QwNDLXMwBCwxygOFMiQ5L8____sxIZcKlIcgCSSfFgRUy4FOWxAEmGBiAFVDcfyTQTrAoPQBTeB5qYBQBGTSmN")). | |
| [{'dev1@127.0.0.1',[0,536870911],0}, | |
| {'dev1@127.0.0.1',[1073741824,1610612735],2}, | |
| {'dev1@127.0.0.1',[2147483648,2684354559],0}, | |
| {'dev4@127.0.0.1',[3221225472,3758096383],2}] |
bdionne
/ fooseqs2.txt
Created
February 19, 2013 18:19
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| [[{'dev1@127.0.0.1',[0,536870911],0}, | |
| {'dev2@127.0.0.1',[536870912,1073741823],0}, | |
| {'dev3@127.0.0.1',[536870912,1073741823],0}, | |
| {'dev1@127.0.0.1',[1073741824,1610612735],0}, | |
| {'dev4@127.0.0.1',[1073741824,1610612735],0}, | |
| {'dev3@127.0.0.1',[1610612736,2147483647],0}, | |
| {'dev1@127.0.0.1',[2147483648,2684354559],0}, | |
| {'dev4@127.0.0.1',[2147483648,2684354559],0}, | |
| {'dev2@127.0.0.1',[2684354560,3221225471],1}, | |
| {'dev1@127.0.0.1',[3221225472,3758096383],0}, |
bdionne
/ fabric_view_changes.erl
Last active
December 14, 2015 00:08
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| handle_message({complete, EndSeq}, Worker, State) -> | |
| %io:format("complete with ~p from ~p ~n",[EndSeq, Worker]), | |
| #collector{ | |
| callback = Callback, | |
| counters = S0, | |
| total_rows = Completed, % override | |
| user_acc = Acc | |
| } = State, | |
| case fabric_dict:lookup_element(Worker, S0) of | |
| undefined -> |
bdionne
/ fooseqs7.txt
Created
February 20, 2013 19:24
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| ["g1AAAAHbeJzLYWBg4MlgTmHgS0ktM3EwNDLXMwBCwxygOFMiQ5L8____sxIZYCoM0VQkKQDJJHuwIkaYImN0RQ4gRfGoJqHbhVURhnUJIEX1qIrQrctjAZIMDUAKqG4-HitxKkS3FqJwAUThfiSFRsQqxO7GAxCF9wm6EYtC7G58AFEICp4sAAIafVo", | |
| "g1AAAAGNeJzLYWBg4MpgTmHgS0ktM3EwNDLXMwBCwxygOFMiQ5L8____sxIZYCoM0VQkKQDJJHuwIkZcxiQ5gBTFoyrCMCkBpKge1Tp0k_JYgCRDA5ACqpuPx10QhQsgCvcjKTQiVqExVoUHIArvE3QjFoXY3fgAohDk6ywAcXBo_w", | |
| "g1AAAAFkeJzLYWBg4MxgTmHgS0ktM3EwNDLXMwBCwxygOFMiQ5L8____sxIZYCoM0VQkKQDJJHuwIkZcxiQ5gBTFoyrCMCkBpKge1Tp0k_JYgCRDA5ACqpuPx10QhQsgCvcjKTQiVqExVoUHIArv4_EIROEDiEKQZ7IAsP1eAQ", | |
| "g1AAAAE7eJzLYWBg4MhgTmHgS0ktM3EwNDLXMwBCwxygOFMiQ5L8____sxIZYCoM0VQkKQDJJHuwIkZcxiQ5gBTFoyrCMCkBpKge1Tp0k_JYgCRDA5ACqpuPpNAIq8IFEIX7kaw1xqrwAEThfTzugyh8AFEIcmMWAMESU0Y", | |
| "g1AAAAE7eJzLYWBg4MhgTmHgS0ktM3EwNDLXMwBCwxygOFMiQ5L8____sxIZYCoM0VQkKQDJJHuwIkZcxiQ5gBTFoyrCMCkBpKge1Tp0k_JYgCRDA5ACqpuPpNAIq8IFEIX7kaw1xqrwAETh_axEJlzugyh8AFEIcmMWAME9U0c"] | |
| [[{'dev4@127.0.0.1',[0,536870911],0}, | |
| {'dev1@127.0.0.1',[536870912,1073741823],1}, | |
| {'dev3@127.0.0.1',[1073741824,1610612735],0}, |
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| (define-module (tekuti post) | |
| #:use-module (srfi srfi-1) | |
| #:use-module (web uri) | |
| #:use-module (tekuti match-bind) | |
| #:use-module (tekuti util) | |
| #:use-module (tekuti comment) | |
| #:use-module (tekuti config) | |
| #:use-module (tekuti git) | |
| #:use-module (tekuti filters) | |
| #:use-module (srfi srfi-1) |
bdionne
/ couch_replicator.erl
Created
February 22, 2013 13:00
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| read_changes(StartSeq, Db, ChangesQueue, Options) -> | |
| try | |
| couch_replicator_api_wrap:changes_since(Db, all_docs, StartSeq, | |
| fun(#doc_info{high_seq = Seq, id = Id} = DocInfo) -> | |
| case Id of | |
| <<>> -> | |
| % Previous CouchDB releases had a bug which allowed a doc | |
| % with an empty ID to be inserted into databases. Such doc | |
| % is impossible to GET. | |
| twig:log(error,"Replicator: ignoring document with empty ID in " |
bdionne
/ *shell*.txt
Created
February 26, 2013 00:12
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| (dev1@127.0.0.1)1> <148>1 2013-02-26T00:11:55.829840Z erlang.local twig <0.220.0> supervisor_report - {local,couch_replicator_sup} child_terminated ({unexpected_msg, | |
| {'EXIT',<0.588.0>, | |
| {{nocatch, | |
| {changes_feed_died,normal}}, | |
| [{fabric_db_update_listener, | |
| wait_db_updated,1, | |
| [{file, | |
| "src/fabric_db_update_listener.erl"}, | |
| {line,113}]}, | |
| {fabric_view_changes, |