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:
I hereby claim:
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>}} | |