/netbsd-src/sys/nfs/ |
H A D | nfs_clntsocket.c | 96 nfs_receive(struct nfsreq *rep, struct mbuf **aname, struct mbuf **mp, in nfs_receive() argument 113 sotype = rep->r_nmp->nm_sotype; in nfs_receive() 124 error = nfs_sndlock(rep->r_nmp, rep); in nfs_receive() 137 if (rep->r_mrep || (rep->r_flags & R_SOFTTERM)) { in nfs_receive() 138 nfs_sndunlock(rep->r_nmp); in nfs_receive() 141 so = rep->r_nmp->nm_so; in nfs_receive() 143 error = nfs_reconnect(rep); in nfs_receive() 145 nfs_sndunlock(rep->r_nmp); in nfs_receive() 150 while (rep->r_flags & R_MUSTRESEND) { in nfs_receive() 151 m = m_copym(rep->r_mreq, 0, M_COPYALL, M_WAIT); in nfs_receive() [all …]
|
H A D | nfs_socket.c | 182 nfs_connect(struct nfsmount *nmp, struct nfsreq *rep, struct lwp *l) in nfs_connect() argument 262 so->so_error == 0 && rep && in nfs_connect() 263 (error = nfs_sigintr(nmp, rep, rep->r_lwp)) != 0){ in nfs_connect() 349 nfs_reconnect(struct nfsreq *rep) in nfs_reconnect() argument 352 struct nfsmount *nmp = rep->r_nmp; in nfs_reconnect() 365 while ((error = nfs_connect(nmp, rep, &lwp0)) != 0) { in nfs_reconnect() 369 if (rep->r_flags & R_SOFTTERM) in nfs_reconnect() 468 nfs_send(struct socket *so, struct mbuf *nam, struct mbuf *top, struct nfsreq *rep, struct lwp *l) in nfs_send() argument 474 if (l == NULL && rep->r_lwp == NULL) in nfs_send() 477 if (rep) { in nfs_send() [all …]
|
/netbsd-src/external/bsd/unbound/dist/iterator/ |
H A D | iter_resptype.c | 57 if(FLAGS_GET_RCODE(msg->rep->flags) == LDNS_RCODE_NXDOMAIN) in response_type_from_cache() 64 if(msg->rep->an_numrrsets > 0) { in response_type_from_cache() 72 for(i=0; i<msg->rep->an_numrrsets; i++) { in response_type_from_cache() 73 struct ub_packed_rrset_key* s = msg->rep->rrsets[i]; in response_type_from_cache() 120 if((msg->rep->flags & BIT_TC)) in response_type_from_server() 124 if(FLAGS_GET_RCODE(msg->rep->flags) == LDNS_RCODE_NXDOMAIN) { in response_type_from_server() 126 if( (msg->rep->flags&BIT_RA) && in response_type_from_server() 127 !(msg->rep->flags&BIT_AA) && !rdset) in response_type_from_server() 130 for(i=0; i<msg->rep->an_numrrsets; i++) { in response_type_from_server() 131 s = msg->rep->rrsets[i]; in response_type_from_server() [all …]
|
H A D | iter_utils.c | 669 if(!parse_create_msg(pkt, msg, NULL, &m->qinfo, &m->rep, region)) { in dns_alloc_msg() 687 if(!(m->rep = reply_info_copy(from->rep, NULL, region))) in dns_copy_msg() 874 if(msg && msg->rep && in iter_indicates_dnssec() 875 reply_find_rrset_section_ns(msg->rep, dp->name, dp->namelen, in iter_indicates_dnssec() 902 if(!msg || !msg->rep) in iter_msg_has_dnssec() 904 for(i=0; i<msg->rep->an_numrrsets + msg->rep->ns_numrrsets; i++) { in iter_msg_has_dnssec() 905 if(((struct packed_rrset_data*)msg->rep->rrsets[i]-> in iter_msg_has_dnssec() 917 if(!msg || !dp || !msg->rep || !dp->name) in iter_msg_from_zone() 920 if(reply_find_rrset_section_an(msg->rep, dp->name, dp->namelen, in iter_msg_from_zone() 922 reply_find_rrset_section_ns(msg->rep, dp->name, dp->namelen, in iter_msg_from_zone() [all …]
|
H A D | iterator.c | 323 struct reply_info* rep = (struct reply_info*)msg->entry.data; in error_response_cache() local 325 qstate->env->cfg->serve_expired_ttl_reset && rep && in error_response_cache() 327 > rep->serve_expired_ttl) { in error_response_cache() 330 rep->serve_expired_ttl = *qstate->env->now + in error_response_cache() 333 if(rep && (FLAGS_GET_RCODE(rep->flags) == in error_response_cache() 335 FLAGS_GET_RCODE(rep->flags) == in error_response_cache() 337 FLAGS_GET_RCODE(rep->flags) == in error_response_cache() 340 *qstate->env->now <= rep->ttl)) { in error_response_cache() 400 msg->rep->rrset_count > RR_COUNT_MAX) return 0; /* overflow */ in iter_prepend() 401 sets = regional_alloc(region, (num_an+num_ns+msg->rep->rrset_count) * in iter_prepend() [all …]
|
/netbsd-src/external/gpl3/gcc/dist/libsanitizer/tsan/ |
H A D | tsan_report.cpp | 273 static ReportStack *ChooseSummaryStack(const ReportDesc *rep) { in ChooseSummaryStack() argument 274 if (rep->mops.Size()) in ChooseSummaryStack() 275 return rep->mops[0]->stack; in ChooseSummaryStack() 276 if (rep->stacks.Size()) in ChooseSummaryStack() 277 return rep->stacks[0]; in ChooseSummaryStack() 278 if (rep->mutexes.Size()) in ChooseSummaryStack() 279 return rep->mutexes[0]->stack; in ChooseSummaryStack() 280 if (rep->threads.Size()) in ChooseSummaryStack() 281 return rep->threads[0]->stack; in ChooseSummaryStack() 306 void PrintReport(const ReportDesc *rep) { in PrintReport() argument [all …]
|
H A D | tsan_debugging.cpp | 77 const ReportDesc *rep = (ReportDesc *)report; in __tsan_get_report_data() local 78 *description = ReportTypeDescription(rep->typ); in __tsan_get_report_data() 79 *count = rep->count; in __tsan_get_report_data() 80 *stack_count = rep->stacks.Size(); in __tsan_get_report_data() 81 *mop_count = rep->mops.Size(); in __tsan_get_report_data() 82 *loc_count = rep->locs.Size(); in __tsan_get_report_data() 83 *mutex_count = rep->mutexes.Size(); in __tsan_get_report_data() 84 *thread_count = rep->threads.Size(); in __tsan_get_report_data() 85 *unique_tid_count = rep->unique_tids.Size(); in __tsan_get_report_data() 86 if (rep->sleep) CopyTrace(rep->sleep->frames, sleep_trace, trace_size); in __tsan_get_report_data() [all …]
|
/netbsd-src/external/bsd/unbound/dist/services/cache/ |
H A D | dns.c | 78 store_rrsets(struct module_env* env, struct reply_info* rep, time_t now, in store_rrsets() argument 84 for(i=0; i<rep->rrset_count; i++) { in store_rrsets() 85 rep->ref[i].key = rep->rrsets[i]; in store_rrsets() 86 rep->ref[i].id = rep->rrsets[i]->id; in store_rrsets() 88 switch(rrset_cache_update(env->rrset_cache, &rep->ref[i], in store_rrsets() 89 env->alloc, ((ntohs(rep->ref[i].key->rk.type)== in store_rrsets() 96 lock_rw_rdlock(&rep->ref[i].key->entry.lock); in store_rrsets() 98 if(rep->ref[i].key->id == 0) in store_rrsets() 101 rep->ref[i].key, region, now); in store_rrsets() 102 lock_rw_unlock(&rep->ref[i].key->entry.lock); in store_rrsets() [all …]
|
/netbsd-src/external/bsd/unbound/dist/cachedb/ |
H A D | redis.c | 108 redisReply* rep; in redis_connect() local 109 rep = redisCommand(ctx, "AUTH %s", moddata->server_password); in redis_connect() 110 if(!rep || rep->type == REDIS_REPLY_ERROR) { in redis_connect() 112 freeReplyObject(rep); in redis_connect() 115 freeReplyObject(rep); in redis_connect() 118 redisReply* rep; in redis_connect() local 119 rep = redisCommand(ctx, "SELECT %d", moddata->logical_db); in redis_connect() 120 if(!rep || rep->type == REDIS_REPLY_ERROR) { in redis_connect() 123 freeReplyObject(rep); in redis_connect() 126 freeReplyObject(rep); in redis_connect() [all …]
|
/netbsd-src/sys/external/bsd/compiler_rt/dist/lib/tsan/rtl/ |
H A D | tsan_report.cc | 281 static ReportStack *ChooseSummaryStack(const ReportDesc *rep) { in ChooseSummaryStack() argument 282 if (rep->mops.Size()) in ChooseSummaryStack() 283 return rep->mops[0]->stack; in ChooseSummaryStack() 284 if (rep->stacks.Size()) in ChooseSummaryStack() 285 return rep->stacks[0]; in ChooseSummaryStack() 286 if (rep->mutexes.Size()) in ChooseSummaryStack() 287 return rep->mutexes[0]->stack; in ChooseSummaryStack() 288 if (rep->threads.Size()) in ChooseSummaryStack() 289 return rep->threads[0]->stack; in ChooseSummaryStack() 314 void PrintReport(const ReportDesc *rep) { in PrintReport() argument [all …]
|
H A D | tsan_debugging.cc | 72 const ReportDesc *rep = (ReportDesc *)report; in __tsan_get_report_data() local 73 *description = ReportTypeDescription(rep->typ); in __tsan_get_report_data() 74 *count = rep->count; in __tsan_get_report_data() 75 *stack_count = rep->stacks.Size(); in __tsan_get_report_data() 76 *mop_count = rep->mops.Size(); in __tsan_get_report_data() 77 *loc_count = rep->locs.Size(); in __tsan_get_report_data() 78 *mutex_count = rep->mutexes.Size(); in __tsan_get_report_data() 79 *thread_count = rep->threads.Size(); in __tsan_get_report_data() 80 *unique_tid_count = rep->unique_tids.Size(); in __tsan_get_report_data() 81 if (rep->sleep) CopyTrace(rep->sleep->frames, sleep_trace, trace_size); in __tsan_get_report_data() [all …]
|
/netbsd-src/external/gpl3/gcc.old/dist/libsanitizer/tsan/ |
H A D | tsan_report.cc | 279 static ReportStack *ChooseSummaryStack(const ReportDesc *rep) { in ChooseSummaryStack() argument 280 if (rep->mops.Size()) in ChooseSummaryStack() 281 return rep->mops[0]->stack; in ChooseSummaryStack() 282 if (rep->stacks.Size()) in ChooseSummaryStack() 283 return rep->stacks[0]; in ChooseSummaryStack() 284 if (rep->mutexes.Size()) in ChooseSummaryStack() 285 return rep->mutexes[0]->stack; in ChooseSummaryStack() 286 if (rep->threads.Size()) in ChooseSummaryStack() 287 return rep->threads[0]->stack; in ChooseSummaryStack() 312 void PrintReport(const ReportDesc *rep) { in PrintReport() argument [all …]
|
H A D | tsan_debugging.cc | 70 const ReportDesc *rep = (ReportDesc *)report; in __tsan_get_report_data() local 71 *description = ReportTypeDescription(rep->typ); in __tsan_get_report_data() 72 *count = rep->count; in __tsan_get_report_data() 73 *stack_count = rep->stacks.Size(); in __tsan_get_report_data() 74 *mop_count = rep->mops.Size(); in __tsan_get_report_data() 75 *loc_count = rep->locs.Size(); in __tsan_get_report_data() 76 *mutex_count = rep->mutexes.Size(); in __tsan_get_report_data() 77 *thread_count = rep->threads.Size(); in __tsan_get_report_data() 78 *unique_tid_count = rep->unique_tids.Size(); in __tsan_get_report_data() 79 if (rep->sleep) CopyTrace(rep->sleep->frames, sleep_trace, trace_size); in __tsan_get_report_data() [all …]
|
/netbsd-src/external/bsd/unbound/dist/validator/ |
H A D | val_utils.c | 67 struct query_info* qinf, struct reply_info* rep, size_t skip) in val_classify_response() argument 69 int rcode = (int)FLAGS_GET_RCODE(rep->flags); in val_classify_response() 74 if(rcode == LDNS_RCODE_NXDOMAIN && rep->an_numrrsets == 0) in val_classify_response() 78 if(!(query_flags&BIT_RD) && rep->an_numrrsets == 0 && in val_classify_response() 85 for(i=0; i<rep->ns_numrrsets; i++) { in val_classify_response() 86 if(ntohs(rep->rrsets[i]->rk.type) == LDNS_RR_TYPE_SOA) in val_classify_response() 88 if(ntohs(rep->rrsets[i]->rk.type) == LDNS_RR_TYPE_DS) in val_classify_response() 90 if(ntohs(rep->rrsets[i]->rk.type) == LDNS_RR_TYPE_NS) in val_classify_response() 96 if(!(query_flags&BIT_RD) && rep->ns_numrrsets == 0 && in val_classify_response() 97 rep->an_numrrsets == 1 && rcode == LDNS_RCODE_NOERROR && in val_classify_response() [all …]
|
/netbsd-src/external/bsd/unbound/dist/util/data/ |
H A D | msgreply.c | 99 struct reply_info* rep; in construct_reply_info_base() local 105 rep = (struct reply_info*)regional_alloc(region, s); in construct_reply_info_base() 106 else rep = (struct reply_info*)malloc(s + in construct_reply_info_base() 108 if(!rep) in construct_reply_info_base() 110 rep->flags = flags; in construct_reply_info_base() 111 rep->qdcount = qd; in construct_reply_info_base() 112 rep->ttl = ttl; in construct_reply_info_base() 113 rep->prefetch_ttl = prettl; in construct_reply_info_base() 114 rep->serve_expired_ttl = expttl; in construct_reply_info_base() 115 rep->an_numrrsets = an; in construct_reply_info_base() [all …]
|
H A D | msgreply.h | 289 struct query_info* qinf, struct reply_info** rep, 309 struct reply_info** rep, struct regional* region); 319 void reply_info_sortref(struct reply_info* rep); 327 void reply_info_set_ttls(struct reply_info* rep, time_t timenow); 335 void reply_info_parsedelete(struct reply_info* rep, struct alloc_cache* alloc); 383 struct reply_info* reply_info_copy(struct reply_info* rep, 398 int reply_info_alloc_rrset_keys(struct reply_info* rep, 413 make_new_reply_info(const struct reply_info* rep, struct regional* region, 438 struct reply_info* rep); 446 int reply_check_cname_chain(struct query_info* qinfo, struct reply_info* rep); [all …]
|
/netbsd-src/sys/dev/fdt/ |
H A D | fdt_port.c | 180 struct fdt_endpoint *rep = fdt_endpoint_remote(ep); in fdt_endpoint_activate() local 184 if (rep == NULL) in fdt_endpoint_activate() 187 KASSERT(ep->ep_active == rep->ep_active); in fdt_endpoint_activate() 188 KASSERT(ep->ep_enabled == rep->ep_enabled); in fdt_endpoint_activate() 192 rdp = rep->ep_port->port_dp; in fdt_endpoint_activate() 194 fdt_endpoint_port_index(rep), fdt_endpoint_index(rep)); in fdt_endpoint_activate() 196 error = rdp->dp_ep_activate(rdp->dp_dev, rep, activate); in fdt_endpoint_activate() 199 rep->ep_active = ep->ep_active = activate; in fdt_endpoint_activate() 221 struct fdt_endpoint *rep = fdt_endpoint_remote(ep); in fdt_endpoint_enable() local 225 if (rep == NULL) in fdt_endpoint_enable() [all …]
|
/netbsd-src/external/bsd/unbound/dist/testcode/ |
H A D | unitmsgparse.c | 166 perf_encode(struct query_info* qi, struct reply_info* rep, uint16_t id, in perf_encode() argument 181 ret = reply_info_encode(qi, rep, id, flags, out, timenow, in perf_encode() 204 struct reply_info* rep = 0; in perftestpkt() local 218 ret = reply_info_parse(pkt, alloc, &qi, &rep, region, &edns); in perftestpkt() 227 perf_encode(&qi, rep, id, flags, out, timenow, &edns); in perftestpkt() 231 reply_info_parsedelete(rep, alloc); in perftestpkt() 253 print_packet_rrsets(struct query_info* qinfo, struct reply_info* rep) in print_packet_rrsets() argument 257 printf(";; ANSWER SECTION (%d rrsets)\n", (int)rep->an_numrrsets); in print_packet_rrsets() 258 for(i=0; i<rep->an_numrrsets; i++) { in print_packet_rrsets() 260 print_rrset(rep->rrsets[i]); in print_packet_rrsets() [all …]
|
H A D | unitverify.c | 86 struct reply_info** rep) in entry_to_repinfo() argument 96 ret = reply_info_parse(pkt, alloc, qi, rep, region, &edns); in entry_to_repinfo() 113 struct reply_info* rep = NULL; in extract_keys() local 116 entry_to_repinfo(e, alloc, region, pkt, &qinfo, &rep); in extract_keys() 117 for(i=0; i<rep->an_numrrsets; i++) { in extract_keys() 118 if(ntohs(rep->rrsets[i]->rk.type) == LDNS_RR_TYPE_DNSKEY) { in extract_keys() 119 dnskey = rep->rrsets[i]; in extract_keys() 120 rep->rrsets[i] = NULL; in extract_keys() 126 reply_info_parsedelete(rep, alloc); in extract_keys() 212 struct reply_info* rep = NULL; in verifytest_entry() local [all …]
|
/netbsd-src/crypto/external/bsd/heimdal/dist/lib/krb5/ |
H A D | ticket.c | 406 krb5_kdc_rep *rep, in check_server_referral() argument 421 if (rep->kdc_rep.padata == NULL) in check_server_referral() 424 pa = krb5_find_padata(rep->kdc_rep.padata->val, in check_server_referral() 425 rep->kdc_rep.padata->len, in check_server_referral() 536 krb5_kdc_rep *rep, in check_client_anonymous() argument 543 if (!rep->enc_part.flags.anonymous) in check_client_anonymous() 577 krb5_kdc_rep *rep, in check_client_mismatch() argument 582 if (rep->enc_part.flags.anonymous) { in check_client_mismatch() 592 !rep->enc_part.flags.enc_pa_rep) { in check_client_mismatch() 650 krb5_kdc_rep *rep, in _krb5_extract_ticket() argument [all …]
|
/netbsd-src/sys/external/bsd/compiler_rt/dist/test/builtins/Unit/ |
H A D | fp_test.h | 83 uint16_t rep = toRep16(result); in compareResultH() local 85 if (rep == expected){ in compareResultH() 90 if ((rep & 0x7c00U) == 0x7c00U && in compareResultH() 91 (rep & 0x3ffU) > 0){ in compareResultH() 101 uint32_t rep = toRep32(result); in compareResultF() local 103 if (rep == expected){ in compareResultF() 108 if ((rep & 0x7f800000U) == 0x7f800000U && in compareResultF() 109 (rep & 0x7fffffU) > 0){ in compareResultF() 119 uint64_t rep = toRep64(result); in compareResultD() local 121 if (rep == expected){ in compareResultD() [all …]
|
/netbsd-src/external/gpl2/texinfo/dist/info/ |
H A D | infodoc.c | 747 char *rep; 753 rep = pretty_keyname (UnMeta (key)); 756 sprintf (temp, "M-%s", rep); 758 sprintf (temp, "ESC %s", rep); 761 rep = rep_buffer; 767 case '\n': rep = "LFD"; break; 768 case '\t': rep = "TAB"; break; 769 case '\r': rep = "RET"; break; 770 case ESC: rep = "ESC"; break; 774 rep = rep_buffer; [all …]
|
/netbsd-src/external/apache2/llvm/dist/libcxx/src/include/ |
H A D | refstring.h | 51 inline char * data_from_rep(_Rep_base *rep) noexcept { in data_from_rep() argument 52 char *data = reinterpret_cast<char *>(rep); in data_from_rep() 53 return data + sizeof(*rep); in data_from_rep() 85 _Rep_base* rep = static_cast<_Rep_base *>(::operator new(sizeof(*rep) + len + 1)); in __libcpp_refstring() local 86 rep->len = len; in __libcpp_refstring() 87 rep->cap = len; in __libcpp_refstring() 88 rep->count = 0; in __libcpp_refstring() 89 char *data = data_from_rep(rep); in __libcpp_refstring() 122 _Rep_base* rep = rep_from_data(__imp_); in ~__libcpp_refstring() local 123 if (__libcpp_atomic_add(&rep->count, count_t(-1)) < 0) { in ~__libcpp_refstring() [all …]
|
/netbsd-src/usr.bin/gzip/ |
H A D | unlz.c | 432 unsigned rep[4] = { 0 }; in lz_decode_member() local 448 int peek = lz_peek(lz, rep[0]); in lz_decode_member() 464 lz_put(lz, lz_peek(lz, rep[0])); in lz_decode_member() 472 distance = rep[1]; in lz_decode_member() 477 distance = rep[2]; in lz_decode_member() 479 distance = rep[3]; in lz_decode_member() 480 rep[3] = rep[2]; in lz_decode_member() 482 rep[2] = rep[1]; in lz_decode_member() 484 rep[1] = rep[0]; in lz_decode_member() 485 rep[0] = distance; in lz_decode_member() [all …]
|
/netbsd-src/external/bsd/unbound/dist/pythonmod/ |
H A D | ubmodule-tst.py | 49 qstate.return_msg.rep.ttl = ttl 50 if (qstate.return_msg.rep): 51 for i in range(0,qstate.return_msg.rep.rrset_count): 52 d = qstate.return_msg.rep.rrsets[i].entry.data 78 …TTL=%d" % (qstate.return_msg.rep.flags, qstate.return_msg.rep.qdcount,qstate.return_msg.rep.securi… 80 if (qstate.return_msg.rep): 81 print("RRSets:",qstate.return_msg.rep.rrset_count) 83 for i in range(0,qstate.return_msg.rep.rrset_count): 84 r = qstate.return_msg.rep.rrsets[i] 123 if (qstate.return_msg.rep.authoritative): [all …]
|