get_items(Nidx, _From, undefined) ->
RItems = lists:keysort(#pubsub_item.creation,
mnesia:index_read(pubsub_item, Nidx, #pubsub_item.nodeidx)),
- Count = length(RItems),
- if Count =< ?MAXITEMS ->
- {result, {RItems, undefined}};
- true ->
- ItemsPage = lists:sublist(RItems, ?MAXITEMS),
- Rsm = rsm_page(Count, 0, 0, ItemsPage),
- {result, {ItemsPage, Rsm}}
- end;
+ {result, {RItems, undefined}};
get_items(Nidx, _From, #rsm_set{max = Max, index = IncIndex,
'after' = After, before = Before}) ->
" from pubsub_item where nodeid='", SNidx/binary, "'",
" order by creation asc">>]) of
{selected, _, AllItems} ->
- Count = length(AllItems),
- if Count =< ?MAXITEMS ->
- {result, {[raw_to_item(Nidx, RItem) || RItem <- AllItems], undefined}};
- true ->
- RItems = lists:sublist(AllItems, ?MAXITEMS),
- Rsm = rsm_page(Count, 0, 0, RItems),
- {result, {[raw_to_item(Nidx, RItem) || RItem <- RItems], Rsm}}
- end;
+ {result, {[raw_to_item(Nidx, RItem) || RItem <- AllItems], undefined}};
_ ->
{result, {[], undefined}}
end;