/openbsd-current/gnu/usr.bin/perl/cpan/Scalar-List-Utils/t/ |
H A D | mesh.t | 7 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 D | crash9.C | 13 A* mesh; member in class:SimQuery 22 mesh = new C;// ERROR - .*
|
/openbsd-current/usr.sbin/unbound/services/ |
H A D | mesh.c | 2 * 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 D | mesh.h | 2 * 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 D | modstack.c | 277 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 D | listen_dnsport.h | 304 /** 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 D | listen_dnsport.c | 59 #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 D | mesh.c | 2 * 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 D | Makefile.inc | 5 SRCS+= authzone.c listen_dnsport.c localzone.c mesh.c modstack.c \
|
H A D | mesh.h | 2 * 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 D | modstack.c | 277 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 D | listen_dnsport.h | 304 /** 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 D | stats.c | 51 #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 D | worker.c | 62 #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 D | remote.c | 69 #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 D | unitzonemd.c | 293 env.mesh = mesh_create(&mods, &env); 294 if(!env.mesh) 329 mesh_delete(env.mesh);
|
/openbsd-current/usr.sbin/unbound/libunbound/ |
H A D | libworker.c | 54 #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 D | libworker.c | 54 #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 D | Makefile.in | 124 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 D | deroff.c | 227 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 D | netevent.h | 919 /** 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 D | module.h | 43 * 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 D | netevent.h | 919 /** 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 D | module.h | 43 * 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 D | Util.pm | 16 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
|