Searched refs:mesh (Results 1 - 25 of 39) sorted by relevance

12

/openbsd-current/gnu/usr.bin/perl/cpan/Scalar-List-Utils/t/
H A Dmesh.t7 use List::Util qw(mesh mesh_longest mesh_shortest);
9 is_deeply( [mesh ()], [],
10 'mesh empty returns empty');
12 is_deeply( [mesh ['a'..'c']], [ 'a', 'b', 'c' ],
13 'mesh of one list returns the list' );
15 is_deeply( [mesh ['one', 'two'], [1, 2]], [ one => 1, two => 2 ],
16 'mesh of two lists returns a list of two pairs' );
27 ok( !defined eval { mesh 1, 2, 3 },
30 ok( !defined eval { mesh +{ one => 1 } },
/openbsd-current/gnu/usr.bin/gcc/gcc/testsuite/g++.old-deja/g++.brendan/
H A Dcrash9.C13 A* mesh; member in class:SimQuery
22 mesh = new C;// ERROR - .*
/openbsd-current/usr.sbin/unbound/services/
H A Dmesh.c2 * services/mesh.c - deal with mesh of query states and handle events for that.
39 * This file contains functions to assist in dealing with a mesh of
40 * query states. This mesh is supposed to be thread-specific.
46 #include "services/mesh.h"
81 * Compare two response-ip client info entries for the purpose of mesh state
85 * We cannot share the mesh state for two queries if different response-ip
193 struct mesh_area* mesh = calloc(1, sizeof(struct mesh_area)); local
194 if(!mesh) {
195 log_err("mesh are
241 mesh_delete(struct mesh_area* mesh) argument
254 mesh_delete_all(struct mesh_area* mesh) argument
273 mesh_make_new_space(struct mesh_area* mesh, sldns_buffer* qbuf) argument
403 mesh_new_client(struct mesh_area* mesh, struct query_info* qinfo, struct respip_client_info* cinfo, uint16_t qflags, struct edns_data* edns, struct comm_reply* rep, uint16_t qid, int rpz_passthru) argument
575 mesh_new_callback(struct mesh_area* mesh, struct query_info* qinfo, uint16_t qflags, struct edns_data* edns, sldns_buffer* buf, uint16_t qid, mesh_cb_func_type cb, void* cb_arg, int rpz_passthru) argument
672 mesh_schedule_prefetch(struct mesh_area* mesh, struct query_info* qinfo, uint16_t qflags, time_t leeway, int run, int rpz_passthru) argument
750 mesh_schedule_prefetch_subnet(struct mesh_area* mesh, struct query_info* qinfo, uint16_t qflags, time_t leeway, int run, int rpz_passthru, struct sockaddr_storage* addr, struct edns_option* edns_list) argument
830 mesh_new_prefetch(struct mesh_area* mesh, struct query_info* qinfo, uint16_t qflags, time_t leeway, int rpz_passthru, struct sockaddr_storage* addr, struct edns_option* opt_list) argument
846 mesh_report_reply(struct mesh_area* mesh, struct outbound_entry* e, struct comm_reply* reply, int what) argument
948 struct mesh_area* mesh; local
996 struct mesh_area* mesh; local
1063 struct mesh_area* mesh = qstate->env->mesh; local
1093 struct mesh_area* mesh = qstate->env->mesh; local
1137 struct mesh_area* mesh = qstate->env->mesh; local
1625 mesh_walk_supers(struct mesh_area* mesh, struct mesh_state* mstate) argument
1642 mesh_area_find(struct mesh_area* mesh, struct respip_client_info* cinfo, struct query_info* qinfo, uint16_t qflags, int prime, int valrec) argument
1810 mesh_continue(struct mesh_area* mesh, struct mesh_state* mstate, enum module_ext_state s, enum module_ev* ev) argument
1923 mesh_run(struct mesh_area* mesh, struct mesh_state* mstate, enum module_ev ev, struct outbound_entry* e) argument
1960 mesh_log_list(struct mesh_area* mesh) argument
1981 mesh_stats(struct mesh_area* mesh, const char* str) argument
2006 mesh_stats_clear(struct mesh_area* mesh) argument
2026 mesh_get_mem(struct mesh_area* mesh) argument
2043 struct mesh_area* mesh = qstate->env->mesh; local
2072 mesh_state_remove_reply(struct mesh_area* mesh, struct mesh_state* m, struct comm_point* cp) argument
2143 struct mesh_area* mesh = qstate->env->mesh; local
2335 mesh_jostle_exceeded(struct mesh_area* mesh) argument
[all...]
H A Dmesh.h2 * services/mesh.h - deal with mesh of query states and handle events for that.
39 * This file contains functions to assist in dealing with a mesh of
40 * query states. This mesh is supposed to be thread-specific.
67 * Maximum number of mesh state activations. Any more is likely an
161 * A mesh query state
187 /** number of activations for the mesh state */
211 /** the mesh state */
231 /** qname from this query. len same as mesh qinfo. */
272 * Allocate mesh, t
[all...]
H A Dmodstack.c277 int m = modstack_find(&env->mesh->mods, name);
279 fptr_ok(fptr_whitelist_mod_get_mem(env->mesh->
281 return (*env->mesh->mods.mod[m]->get_mem)(env, m);
H A Dlisten_dnsport.h304 /** the buffer to use to spool reply from mesh into,
313 /** is the comm point set to send_reply (by mesh new client in worker
336 /** the mesh area of the mesh_state */
337 struct mesh_area* mesh; member in struct:tcp_req_open_item
338 /** the mesh state */
365 * Removes mesh entry references and stored results from the lists.
378 * Remove mesh state entry from list in tcp_req_info.
379 * caller has to manage the mesh state reply entry in the mesh state.
399 * Add mesh stat
[all...]
H A Dlisten_dnsport.c59 #include "services/mesh.h"
2050 /* free outstanding request mesh reply entries */
2054 mesh_state_remove_reply(open->mesh, open->mesh_state, req->cp);
2089 /* caller has to manage the mesh state reply entry */
2239 * or schedule a mesh entry for later */
2254 /* it should be waiting in the mesh for recursion.
2255 * If mesh failed to add a new entry and called commpoint_drop_reply.
2256 * Then the mesh state has been cleared. */
2261 /* If mesh failed(mallocfail) and called commpoint_send_reply with
2278 struct mesh_area* mesh, struc
2277 tcp_req_info_add_meshstate(struct tcp_req_info* req, struct mesh_area* mesh, struct mesh_state* m) argument
[all...]
/openbsd-current/sbin/unwind/libunbound/services/
H A Dmesh.c2 * services/mesh.c - deal with mesh of query states and handle events for that.
39 * This file contains functions to assist in dealing with a mesh of
40 * query states. This mesh is supposed to be thread-specific.
46 #include "services/mesh.h"
81 * Compare two response-ip client info entries for the purpose of mesh state
85 * We cannot share the mesh state for two queries if different response-ip
193 struct mesh_area* mesh = calloc(1, sizeof(struct mesh_area)); local
194 if(!mesh) {
195 log_err("mesh are
241 mesh_delete(struct mesh_area* mesh) argument
254 mesh_delete_all(struct mesh_area* mesh) argument
273 mesh_make_new_space(struct mesh_area* mesh, sldns_buffer* qbuf) argument
403 mesh_new_client(struct mesh_area* mesh, struct query_info* qinfo, struct respip_client_info* cinfo, uint16_t qflags, struct edns_data* edns, struct comm_reply* rep, uint16_t qid, int rpz_passthru) argument
575 mesh_new_callback(struct mesh_area* mesh, struct query_info* qinfo, uint16_t qflags, struct edns_data* edns, sldns_buffer* buf, uint16_t qid, mesh_cb_func_type cb, void* cb_arg, int rpz_passthru) argument
672 mesh_schedule_prefetch(struct mesh_area* mesh, struct query_info* qinfo, uint16_t qflags, time_t leeway, int run, int rpz_passthru) argument
750 mesh_schedule_prefetch_subnet(struct mesh_area* mesh, struct query_info* qinfo, uint16_t qflags, time_t leeway, int run, int rpz_passthru, struct sockaddr_storage* addr, struct edns_option* edns_list) argument
830 mesh_new_prefetch(struct mesh_area* mesh, struct query_info* qinfo, uint16_t qflags, time_t leeway, int rpz_passthru, struct sockaddr_storage* addr, struct edns_option* opt_list) argument
846 mesh_report_reply(struct mesh_area* mesh, struct outbound_entry* e, struct comm_reply* reply, int what) argument
948 struct mesh_area* mesh; local
996 struct mesh_area* mesh; local
1063 struct mesh_area* mesh = qstate->env->mesh; local
1093 struct mesh_area* mesh = qstate->env->mesh; local
1137 struct mesh_area* mesh = qstate->env->mesh; local
1625 mesh_walk_supers(struct mesh_area* mesh, struct mesh_state* mstate) argument
1642 mesh_area_find(struct mesh_area* mesh, struct respip_client_info* cinfo, struct query_info* qinfo, uint16_t qflags, int prime, int valrec) argument
1810 mesh_continue(struct mesh_area* mesh, struct mesh_state* mstate, enum module_ext_state s, enum module_ev* ev) argument
1923 mesh_run(struct mesh_area* mesh, struct mesh_state* mstate, enum module_ev ev, struct outbound_entry* e) argument
1960 mesh_log_list(struct mesh_area* mesh) argument
1981 mesh_stats(struct mesh_area* mesh, const char* str) argument
2006 mesh_stats_clear(struct mesh_area* mesh) argument
2026 mesh_get_mem(struct mesh_area* mesh) argument
2043 struct mesh_area* mesh = qstate->env->mesh; local
2072 mesh_state_remove_reply(struct mesh_area* mesh, struct mesh_state* m, struct comm_point* cp) argument
2143 struct mesh_area* mesh = qstate->env->mesh; local
2335 mesh_jostle_exceeded(struct mesh_area* mesh) argument
[all...]
H A DMakefile.inc5 SRCS+= authzone.c listen_dnsport.c localzone.c mesh.c modstack.c \
H A Dmesh.h2 * services/mesh.h - deal with mesh of query states and handle events for that.
39 * This file contains functions to assist in dealing with a mesh of
40 * query states. This mesh is supposed to be thread-specific.
67 * Maximum number of mesh state activations. Any more is likely an
161 * A mesh query state
187 /** number of activations for the mesh state */
211 /** the mesh state */
231 /** qname from this query. len same as mesh qinfo. */
272 * Allocate mesh, t
[all...]
H A Dmodstack.c277 int m = modstack_find(&env->mesh->mods, name);
279 fptr_ok(fptr_whitelist_mod_get_mem(env->mesh->
281 return (*env->mesh->mods.mod[m]->get_mem)(env, m);
H A Dlisten_dnsport.h304 /** the buffer to use to spool reply from mesh into,
313 /** is the comm point set to send_reply (by mesh new client in worker
336 /** the mesh area of the mesh_state */
337 struct mesh_area* mesh; member in struct:tcp_req_open_item
338 /** the mesh state */
365 * Removes mesh entry references and stored results from the lists.
378 * Remove mesh state entry from list in tcp_req_info.
379 * caller has to manage the mesh state reply entry in the mesh state.
399 * Add mesh stat
[all...]
/openbsd-current/usr.sbin/unbound/daemon/
H A Dstats.c51 #include "services/mesh.h"
99 stats->sum_query_list_size += worker->env.mesh->all.count;
100 if((long long)worker->env.mesh->all.count > stats->max_query_list_size)
101 stats->max_query_list_size = (long long)worker->env.mesh->all.count;
108 stats->sum_query_list_size += worker->env.mesh->all.count;
109 if((long long)worker->env.mesh->all.count > stats->max_query_list_size)
110 stats->max_query_list_size = (long long)worker->env.mesh->all.count;
132 (unsigned)worker->env.mesh->stats_dropped,
133 (unsigned)worker->env.mesh->stats_jostled);
143 int m = modstack_find(&worker->env.mesh
[all...]
H A Dworker.c62 #include "services/mesh.h"
124 size_t total, front, back, mesh, msg, rrset, infra, ac, superac; local
137 mesh = mesh_get_mem(worker->env.mesh);
143 for(i=0; i<worker->env.mesh->mods.num; i++) {
144 fptr_ok(fptr_whitelist_mod_get_mem(worker->env.mesh->
146 if(strcmp(worker->env.mesh->mods.mod[i]->name, "validator")==0)
147 val += (*worker->env.mesh->mods.mod[i]->get_mem)
150 else if(strcmp(worker->env.mesh->mods.mod[i]->name,
152 subnet += (*worker->env.mesh
[all...]
H A Dremote.c69 #include "services/mesh.h"
1694 mesh_delete_all(worker->env.mesh);
2089 * the actual mesh is not running, so we can freely edit it. */
2091 mesh_delete_all(worker->env.mesh);
2376 /** get age for the mesh state */
2395 /** get status of a mesh state */
2397 get_mesh_status(struct mesh_area* mesh, struct mesh_state* m, argument
2401 const char *modname = mesh->mods.mod[m->s.curmod]->name;
2425 /* look in subs from mesh state to see what */
2453 struct mesh_area* mesh; local
[all...]
/openbsd-current/usr.sbin/unbound/testcode/
H A Dunitzonemd.c293 env.mesh = mesh_create(&mods, &env);
294 if(!env.mesh)
329 mesh_delete(env.mesh);
/openbsd-current/usr.sbin/unbound/libunbound/
H A Dlibworker.c54 #include "services/mesh.h"
96 mesh_delete(w->env->mesh);
242 w->env->mesh = mesh_create(&ctx->mods, w->env);
243 if(!w->env->mesh) {
642 if(!mesh_new_callback(w->env->mesh, &qinfo, qflags, &edns,
722 if(!mesh_new_callback(w->env->mesh, &qinfo, qflags, &edns,
859 if(!mesh_new_callback(w->env->mesh, &qinfo, qflags, &edns,
905 mesh_report_reply(lw->env->mesh, e, reply_info, error);
915 mesh_report_reply(lw->env->mesh, e, reply_info,
919 mesh_report_reply(lw->env->mesh,
[all...]
/openbsd-current/sbin/unwind/libunbound/libunbound/
H A Dlibworker.c54 #include "services/mesh.h"
96 mesh_delete(w->env->mesh);
242 w->env->mesh = mesh_create(&ctx->mods, w->env);
243 if(!w->env->mesh) {
642 if(!mesh_new_callback(w->env->mesh, &qinfo, qflags, &edns,
722 if(!mesh_new_callback(w->env->mesh, &qinfo, qflags, &edns,
859 if(!mesh_new_callback(w->env->mesh, &qinfo, qflags, &edns,
905 mesh_report_reply(lw->env->mesh, e, reply_info, error);
915 mesh_report_reply(lw->env->mesh, e, reply_info,
919 mesh_report_reply(lw->env->mesh,
[all...]
/openbsd-current/usr.sbin/unbound/
H A DMakefile.in124 services/localzone.c services/mesh.c services/modstack.c services/view.c \
146 iter_scrub.lo iter_utils.lo localzone.lo mesh.lo modstack.lo view.lo \
477 $(srcdir)/services/cache/dns.h $(srcdir)/services/mesh.h \
750 $(srcdir)/util/fptr_wlist.h $(srcdir)/util/tube.h $(srcdir)/services/mesh.h $(srcdir)/util/rbtree.h \
769 $(srcdir)/services/authzone.h $(srcdir)/services/mesh.h \
820 $(srcdir)/util/tube.h $(srcdir)/services/mesh.h $(srcdir)/services/modstack.h $(srcdir)/services/rpz.h \
829 $(srcdir)/sldns/sbuffer.h $(srcdir)/sldns/parseutil.h $(srcdir)/services/mesh.h $(srcdir)/util/data/msgparse.h \
844 mesh.lo mesh.o: $(srcdir)/services/mesh
[all...]
/openbsd-current/usr.bin/deroff/
H A Dderoff.c227 int mesh(pacmac);
1349 mesh(pacmac c12) function
1692 M(NONE, 's','h', mesh),
1693 M(NONE, 'u','h', mesh),
/openbsd-current/usr.sbin/unbound/util/
H A Dnetevent.h919 /** mesh area containing mesh state */
920 struct mesh_area* mesh; member in struct:http2_stream
921 /** mesh state for query. Used to remove mesh reply before closing
953 /** Add mesh state to stream. To be able to remove mesh reply on stream closure
956 struct mesh_area* mesh, struct mesh_state* m);
H A Dmodule.h43 * they are done, the reply is passed back. In the usual setup the mesh
69 * A query comes in, and a mesh entry is created for it. The mesh
94 * There is no previous module from the validator module, and the mesh
95 * takes this to mean that the query is finally done. The mesh invokes
99 * query, then the mesh will tell them about it. It calls the inform_super
119 * The mesh meanwhile will have the newly created query (or queries) on
123 * done. When they are done the mesh calls inform_super on the module that
124 * wanted the recursion. After that the mesh calls operate() on the module
230 /** whether the option needs mesh aggregatio
490 struct mesh_area* mesh; member in struct:module_env
[all...]
/openbsd-current/sbin/unwind/libunbound/util/
H A Dnetevent.h919 /** mesh area containing mesh state */
920 struct mesh_area* mesh; member in struct:http2_stream
921 /** mesh state for query. Used to remove mesh reply before closing
953 /** Add mesh state to stream. To be able to remove mesh reply on stream closure
956 struct mesh_area* mesh, struct mesh_state* m);
H A Dmodule.h43 * they are done, the reply is passed back. In the usual setup the mesh
69 * A query comes in, and a mesh entry is created for it. The mesh
94 * There is no previous module from the validator module, and the mesh
95 * takes this to mean that the query is finally done. The mesh invokes
99 * query, then the mesh will tell them about it. It calls the inform_super
119 * The mesh meanwhile will have the newly created query (or queries) on
123 * done. When they are done the mesh calls inform_super on the module that
124 * wanted the recursion. After that the mesh calls operate() on the module
230 /** whether the option needs mesh aggregatio
490 struct mesh_area* mesh; member in struct:module_env
[all...]
/openbsd-current/gnu/usr.bin/perl/cpan/Scalar-List-Utils/lib/List/
H A DUtil.pm16 sample shuffle uniq uniqint uniqnum uniqstr zip zip_longest zip_shortest mesh mesh_longest mesh_shortest
60 shuffle uniq uniqint uniqnum uniqstr zip mesh
683 L<mesh>.
697 =head2 mesh
699 my @result = mesh [1..3], ['a'..'c'];
714 Because it returns a flat list of items, the C<mesh> function is particularly
717 my %hash = mesh \@keys, \@values;
719 my $href = { mesh \@keys, \@values };
722 equivalent to C<List::MoreUtils::mesh> or C<List::MoreUtils::zip> (themselves

Completed in 157 milliseconds

12