Skip to content

Instantly share code, notes, and snippets.

Keybase proof

I hereby claim:

  • I am tonysun83 on github.
  • I am azuredrake (https://keybase.io/azuredrake) on keybase.
  • I have a public key ASC1vLxVVURO8yLTlWeJag1rwL3imVXdYECUDbJG4meWFQo

To claim this, I am signing this object:

Regex for Floating Point, Hex Floating Point, Nan, and Infinity
Digits = "(\\p{N}+)",
HexDigits = "([0-9a-fA-F]+)",
Exp = "[eE][+-]?" ++ Digits,
FpRegexStr = "[\\x00-\\x20]*" ++ "[+-]?(" ++ "NaN|"
++ "Infinity|" ++ "((("
++ Digits
++ "(\\.)?("
Counters = fabric_dict:init(Workers0, nil),
RexiMon = fabric_util:create_monitors(Workers0),
try
case fabric_util:stream_start(Workers0, #shard.ref) of
{ok, Workers} ->
try
go(DbName, DDoc, IndexName, QueryArgs, Counters, Counters,HttpResp)
after
Counters = fabric_dict:init(Workers0, nil),
diff --git a/src/rexi.erl b/src/rexi.erl
index 6d0712c..c853ce9 100644
--- a/src/rexi.erl
+++ b/src/rexi.erl
@@ -11,7 +11,7 @@
% WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the
% License for the specific language governing permissions and limitations under
% the License.
-
+
% Copyright 2010 Cloudant
%
% Licensed under the Apache License, Version 2.0 (the "License"); you may not
% use this file except in compliance with the License. You may obtain a copy of
% the License at
%
% http://www.apache.org/licenses/LICENSE-2.0
%
% Unless required by applicable law or agreed to in writing, software
% distributed under the License is distributed on an "AS IS" BASIS, WITHOUT
scheduled for removal in erts-5.10/OTP-R16. For more
information see the erlang:system_flag/2 documentation.
<149>1 2014-10-01T21:56:46.686386Z Tonys-MacBook-Pro.local twig <0.192.0> std_info - [{warning,"TODO: max is currently unsupported"},{max,"2048"}]
Apache CouchDB has started. Time to relax.
<149>1 2014-10-01T21:56:46.687346Z Tonys-MacBook-Pro.local twig <0.184.0> -------- - Apache CouchDB has started on http://127.0.0.1:15986/
<147>1 2014-10-01T21:56:46.703755Z Tonys-MacBook-Pro.local twig <0.335.0> -------- - Metadata db "cassim" does not exist
<149>1 2014-10-01T21:56:46.706209Z Tonys-MacBook-Pro.local twig <0.466.0> -------- - Missing system database _users
<149>1 2014-10-01T21:56:46.724654Z Tonys-MacBook-Pro.local twig <0.466.0> -------- - Missing system database stats
<149>1 2014-10-01T20:36:30.572440Z Tonys-MacBook-Pro.local twig <0.1790.0> 8df23e1b5e - Reply: start_search
<147>1 2014-10-01T20:36:30.576056Z Tonys-MacBook-Pro.local twig <0.1742.0> 8df23e1b5e - Error: rexi_STREAM_INIT, Worker {{shard,
<<"shards/e0000000-ffffffff/mango_test.1412026511">>,
'node2@127.0.0.1',<<"mango_test">>,
[3758096384,4294967295],
#Ref<0.0.0.7061>},
{<0.1790.0>,#Ref<0.0.0.7131>}}
search_all(DbName, DDoc, IndexName, HttpResp, QueryArgs) ->
call(search_all, DbName, DDoc, IndexName, HttpResp, QueryArgs).
call(Fun, DbName, DDoc, IndexName,HttpResp, QueryArgs0) ->
QueryArgs = dreyfus_util:upgrade(QueryArgs0),
erlang:put(io_priority, {interactive, DbName}),
check_interactive_mode(),
{ok, Db} = get_or_create_db(DbName, []),
#index_query_args{
handle_message(start_search, {Worker, From}, State) ->
twig:log(notice, "START A MESSAGE"),
rexi:stream_ack(From),
{ok, State};
handle_message({ok, {hits,Val}}, {Worker, From}, State) ->
rexi:stream_ack(From),
{Req,Resp} = State#state.http_resp,
send_chunk(Resp,?JSON_ENCODE(Val)),
{ok, State};
<147>1 2014-10-01T17:32:01.795993Z Tonys-MacBook-Pro.local twig <0.17192.0> 84ad0d327e - Error: rexi_STREAM_INIT, Worker {{shard,
<<"shards/c0000000-dfffffff/mango_test.1412026511">>,
'node2@127.0.0.1',<<"mango_test">>,
[3221225472,3758096383],
#Ref<0.0.0.27352>},
{<23806.17244.0>,#Ref<23806.0.0.27161>}}