Home
last modified time | relevance | path

Searched refs:send_records (Results 1 – 25 of 127) sorted by relevance

123456

/dports/www/erlang-cowboy/cowboy-1.1.2/examples/rest_stream_response/src/
H A Dtoppage_handler.erl29 send_records(Socket, Transport, ets:select(Table, MS, 1))
32 send_records(Socket, Transport, {[Rec], Cont}) -> function
35 send_records(Socket, Transport, ets:select(Cont));
36 send_records(_Socket, _Transport, '$end_of_table') -> function
/dports/lang/erlang-runtime22/otp-OTP-22.3.4.24/lib/mnesia/src/
H A Dmnesia_registry.erl251 {send_records, ReplyTo} ->
252 send_records(AllRecords, ReplyTo),
273 send_records([H | T], ReplyTo) -> function
280 send_records(T, ReplyTo);
281 send_records([], _ReplyTo) -> function
/dports/lang/erlang-runtime22/otp-OTP-22.3.4.24/lib/dialyzer/test/r9c_SUITE_data/src/mnesia/
H A Dmnesia_registry.erl246 {send_records, ReplyTo} ->
247 send_records(AllRecords, ReplyTo),
268 send_records([H | T], ReplyTo) -> function
275 send_records(T, ReplyTo);
276 send_records([], _ReplyTo) -> function
/dports/lang/erlang-runtime23/otp-OTP-23.3.4.10/lib/dialyzer/test/r9c_SUITE_data/src/mnesia/
H A Dmnesia_registry.erl246 {send_records, ReplyTo} ->
247 send_records(AllRecords, ReplyTo),
268 send_records([H | T], ReplyTo) -> function
275 send_records(T, ReplyTo);
276 send_records([], _ReplyTo) -> function
/dports/lang/erlang-runtime23/otp-OTP-23.3.4.10/lib/mnesia/src/
H A Dmnesia_registry.erl251 {send_records, ReplyTo} ->
252 send_records(AllRecords, ReplyTo),
273 send_records([H | T], ReplyTo) -> function
280 send_records(T, ReplyTo);
281 send_records([], _ReplyTo) -> function
/dports/lang/erlang-runtime24/otp-OTP-24.1.7/lib/dialyzer/test/r9c_SUITE_data/src/mnesia/
H A Dmnesia_registry.erl246 {send_records, ReplyTo} ->
247 send_records(AllRecords, ReplyTo),
268 send_records([H | T], ReplyTo) -> function
275 send_records(T, ReplyTo);
276 send_records([], _ReplyTo) -> function
/dports/lang/erlang-runtime24/otp-OTP-24.1.7/lib/mnesia/src/
H A Dmnesia_registry.erl251 {send_records, ReplyTo} ->
252 send_records(AllRecords, ReplyTo),
273 send_records([H | T], ReplyTo) -> function
280 send_records(T, ReplyTo);
281 send_records([], _ReplyTo) -> function
/dports/lang/erlang-wx/otp-OTP-24.1.7/lib/dialyzer/test/r9c_SUITE_data/src/mnesia/
H A Dmnesia_registry.erl246 {send_records, ReplyTo} ->
247 send_records(AllRecords, ReplyTo),
268 send_records([H | T], ReplyTo) -> function
275 send_records(T, ReplyTo);
276 send_records([], _ReplyTo) -> function
/dports/lang/erlang-wx/otp-OTP-24.1.7/lib/mnesia/src/
H A Dmnesia_registry.erl251 {send_records, ReplyTo} ->
252 send_records(AllRecords, ReplyTo),
273 send_records([H | T], ReplyTo) -> function
280 send_records(T, ReplyTo);
281 send_records([], _ReplyTo) -> function
/dports/lang/erlang/otp-OTP-24.1.7/lib/dialyzer/test/r9c_SUITE_data/src/mnesia/
H A Dmnesia_registry.erl246 {send_records, ReplyTo} ->
247 send_records(AllRecords, ReplyTo),
268 send_records([H | T], ReplyTo) -> function
275 send_records(T, ReplyTo);
276 send_records([], _ReplyTo) -> function
/dports/lang/erlang/otp-OTP-24.1.7/lib/mnesia/src/
H A Dmnesia_registry.erl251 {send_records, ReplyTo} ->
252 send_records(AllRecords, ReplyTo),
273 send_records([H | T], ReplyTo) -> function
280 send_records(T, ReplyTo);
281 send_records([], _ReplyTo) -> function
/dports/lang/erlang-runtime21/otp-OTP-21.3.8.24/lib/mnesia/src/
H A Dmnesia_registry.erl251 {send_records, ReplyTo} ->
252 send_records(AllRecords, ReplyTo),
273 send_records([H | T], ReplyTo) -> function
280 send_records(T, ReplyTo);
281 send_records([], _ReplyTo) -> function
/dports/lang/erlang-java/otp-OTP-24.1.7/lib/mnesia/src/
H A Dmnesia_registry.erl251 {send_records, ReplyTo} ->
252 send_records(AllRecords, ReplyTo),
273 send_records([H | T], ReplyTo) -> function
280 send_records(T, ReplyTo);
281 send_records([], _ReplyTo) -> function
/dports/lang/erlang-java/otp-OTP-24.1.7/lib/dialyzer/test/r9c_SUITE_data/src/mnesia/
H A Dmnesia_registry.erl246 {send_records, ReplyTo} ->
247 send_records(AllRecords, ReplyTo),
268 send_records([H | T], ReplyTo) -> function
275 send_records(T, ReplyTo);
276 send_records([], _ReplyTo) -> function
/dports/lang/erlang-runtime21/otp-OTP-21.3.8.24/lib/dialyzer/test/r9c_SUITE_data/src/mnesia/
H A Dmnesia_registry.erl246 {send_records, ReplyTo} ->
247 send_records(AllRecords, ReplyTo),
268 send_records([H | T], ReplyTo) -> function
275 send_records(T, ReplyTo);
276 send_records([], _ReplyTo) -> function
/dports/databases/mariadb105-client/mariadb-10.5.15/sql/
H A Dgroup_by_handler.cc103 join->send_records)))) in execute()
112 if (++join->send_records >= max_limit && join->do_send_rows) in execute()
/dports/databases/mariadb105-server/mariadb-10.5.15/sql/
H A Dgroup_by_handler.cc103 join->send_records)))) in execute()
112 if (++join->send_records >= max_limit && join->do_send_rows) in execute()
/dports/databases/percona56-client/percona-server-5.6.51-91.0/sql/
H A Dsql_executor.cc167 thd->limit_found_rows= send_records; in exec()
348 send_records++; in rollup_send_data()
878 join->send_records=0; in do_select()
948 join->thd->limit_found_rows= join->send_records; in do_select()
2804 ++join->send_records; in end_send()
2845 join->send_records= table->sort.found_records; in end_send()
2850 join->send_records= table->file->stats.records; in end_send()
2933 join->send_records++; in end_send_group()
3030 if (++join_tab->send_records >= in end_write()
3123 join_tab->send_records++; in end_update()
[all …]
/dports/databases/percona-pam-for-mysql/percona-server-5.6.51-91.0/sql/
H A Dsql_executor.cc167 thd->limit_found_rows= send_records; in exec()
348 send_records++; in rollup_send_data()
878 join->send_records=0; in do_select()
948 join->thd->limit_found_rows= join->send_records; in do_select()
2804 ++join->send_records; in end_send()
2845 join->send_records= table->sort.found_records; in end_send()
2850 join->send_records= table->file->stats.records; in end_send()
2933 join->send_records++; in end_send_group()
3030 if (++join_tab->send_records >= in end_write()
3123 join_tab->send_records++; in end_update()
[all …]
/dports/databases/percona56-server/percona-server-5.6.51-91.0/sql/
H A Dsql_executor.cc167 thd->limit_found_rows= send_records; in exec()
348 send_records++; in rollup_send_data()
878 join->send_records=0; in do_select()
948 join->thd->limit_found_rows= join->send_records; in do_select()
2804 ++join->send_records; in end_send()
2845 join->send_records= table->sort.found_records; in end_send()
2850 join->send_records= table->file->stats.records; in end_send()
2933 join->send_records++; in end_send_group()
3030 if (++join_tab->send_records >= in end_write()
3123 join_tab->send_records++; in end_update()
[all …]
/dports/databases/mysqlwsrep56-server/mysql-wsrep-wsrep_5.6.51-25.33/sql/
H A Dsql_executor.cc167 thd->limit_found_rows= send_records; in exec()
348 send_records++; in rollup_send_data()
878 join->send_records=0; in do_select()
948 join->thd->limit_found_rows= join->send_records; in do_select()
2794 ++join->send_records; in end_send()
2835 join->send_records= table->sort.found_records; in end_send()
2840 join->send_records= table->file->stats.records; in end_send()
2923 join->send_records++; in end_send_group()
3020 if (++join_tab->send_records >= in end_write()
3113 join_tab->send_records++; in end_update()
[all …]
/dports/databases/mysql56-client/mysql-5.6.51/sql/
H A Dsql_executor.cc167 thd->limit_found_rows= send_records; in exec()
348 send_records++; in rollup_send_data()
878 join->send_records=0; in do_select()
948 join->thd->limit_found_rows= join->send_records; in do_select()
2794 ++join->send_records; in end_send()
2835 join->send_records= table->sort.found_records; in end_send()
2840 join->send_records= table->file->stats.records; in end_send()
2923 join->send_records++; in end_send_group()
3020 if (++join_tab->send_records >= in end_write()
3113 join_tab->send_records++; in end_update()
[all …]
/dports/databases/mysql57-client/mysql-5.7.36/sql/
H A Dsql_executor.cc173 thd->current_found_rows= send_records; in exec()
356 send_records++; in rollup_send_data()
889 join->send_records=0; in do_select()
962 join->thd->current_found_rows= join->send_records; in do_select()
2938 ++join->send_records; in end_send()
2979 join->send_records= table->sort.found_records; in end_send()
2984 join->send_records= table->file->stats.records; in end_send()
2997 else if (join->send_records >= join->fetch_limit) in end_send()
3067 join->send_records++; in end_send_group()
3403 if (++qep_tab->send_records >= in end_write()
[all …]
/dports/databases/xtrabackup/percona-xtrabackup-2.4.21/sql/
H A Dsql_executor.cc173 thd->current_found_rows= send_records; in exec()
356 send_records++; in rollup_send_data()
889 join->send_records=0; in do_select()
962 join->thd->current_found_rows= join->send_records; in do_select()
2938 ++join->send_records; in end_send()
2979 join->send_records= table->sort.found_records; in end_send()
2984 join->send_records= table->file->stats.records; in end_send()
2997 else if (join->send_records >= join->fetch_limit) in end_send()
3067 join->send_records++; in end_send_group()
3403 if (++qep_tab->send_records >= in end_write()
[all …]
/dports/databases/percona57-server/percona-server-5.7.36-39/sql/
H A Dsql_executor.cc173 thd->current_found_rows= send_records; in exec()
356 send_records++; in rollup_send_data()
889 join->send_records=0; in do_select()
962 join->thd->current_found_rows= join->send_records; in do_select()
2950 ++join->send_records; in end_send()
2991 join->send_records= table->sort.found_records; in end_send()
2996 join->send_records= table->file->stats.records; in end_send()
3009 else if (join->send_records >= join->fetch_limit) in end_send()
3079 join->send_records++; in end_send_group()
3415 if (++qep_tab->send_records >= in end_write()
[all …]

123456