/macosx-10.9.5/dcerpc-58/dcerpc/ncklib/ |
H A D | dgrq.c | 112 rpc_dg_recvq_p_t rq 120 rq->head = rq->last_inorder = NULL; 128 rq->high_rcv_frag_size = RPC_C_DG_INITIAL_MAX_PKT_SIZE; 129 rq->next_fragnum = 0; 130 rq->high_fragnum = -1; 131 rq->high_serial_num = -1; 132 rq->head_fragnum = -1; 133 rq->head_serial_num = -1; 135 rq [all...] |
H A D | dgrq.h | 115 #define RPC_DG_RECVQ_REINIT(rq) { \ 116 if ((rq)->head != NULL) rpc__dg_recvq_free(rq); \ 117 rpc__dg_recvq_init(rq); /* !!! Maybe be smarter later -- this may be losing "history" */ \ 141 PRIVATE void rpc__dg_recvq_init ( rpc_dg_recvq_p_t /*rq*/); 143 PRIVATE void rpc__dg_recvq_free ( rpc_dg_recvq_p_t /*rq*/);
|
H A D | dgcall.c | 161 rpc_dg_recvq_p_t rq = &call->rq; local 179 hdr.fragnum = rq->next_fragnum - 1; 249 body.serial_num = call->rq.head_serial_num; 255 body.serial_num = call->rq.high_serial_num; 329 if (rq->high_rcv_frag_size > RPC_C_DG_MUST_RECV_FRAG_SIZE) 331 body.window_size = ((rq->max_queue_len - rq->queue_len) 336 body.window_size = ((rq->max_queue_len - rq 1156 rpc_dg_recvq_p_t rq = &call->rq; local [all...] |
H A D | dg.c | 249 if (call->rq.high_rcv_frag_size > xq->snd_frag_size) 251 xq->snd_frag_size = MIN(call->rq.high_rcv_frag_size, 508 rpc_dg_recvq_p_t rq = &call->rq; local 529 if (rq->head != NULL) 530 rpc__dg_recvq_free(rq); 540 if (rq->all_pkts_recvd && rq->head == NULL) 548 while (rq->last_inorder == NULL) 556 rqe = rq [all...] |
/macosx-10.9.5/OpenLDAP-491.1/OpenLDAP/libraries/libldap_r/ |
H A D | rq.c | 38 struct runqueue_s* rq, 58 LDAP_STAILQ_INSERT_HEAD( &rq->task_list, entry, tnext ); 65 struct runqueue_s *rq, 72 LDAP_STAILQ_FOREACH( e, &rq->task_list, tnext ) { 81 struct runqueue_s* rq, 87 LDAP_STAILQ_FOREACH( e, &rq->task_list, tnext ) { 94 LDAP_STAILQ_REMOVE( &rq->task_list, entry, re_s, tnext ); 101 struct runqueue_s* rq, 107 entry = LDAP_STAILQ_FIRST( &rq->task_list ); 118 struct runqueue_s* rq, 37 ldap_pvt_runqueue_insert( struct runqueue_s* rq, time_t interval, ldap_pvt_thread_start_t *routine, void *arg, char *tname, char *tspec ) argument 64 ldap_pvt_runqueue_find( struct runqueue_s *rq, ldap_pvt_thread_start_t *routine, void *arg ) argument 80 ldap_pvt_runqueue_remove( struct runqueue_s* rq, struct re_s* entry ) argument 100 ldap_pvt_runqueue_next_sched( struct runqueue_s* rq, struct timeval* next_run ) argument 117 ldap_pvt_runqueue_runtask( struct runqueue_s* rq, struct re_s* entry ) argument 126 ldap_pvt_runqueue_stoptask( struct runqueue_s* rq, struct re_s* entry ) argument 135 ldap_pvt_runqueue_isrunning( struct runqueue_s* rq, struct re_s* entry ) argument 151 ldap_pvt_runqueue_resched( struct runqueue_s* rq, struct re_s* entry, int defer ) argument [all...] |
/macosx-10.9.5/OpenLDAP-491.1/OpenLDAP/include/ |
H A D | ldap_rq.h | 42 struct runqueue_s* rq, 52 struct runqueue_s* rq, 59 struct runqueue_s* rq, 65 struct runqueue_s* rq, 71 struct runqueue_s* rq, 77 struct runqueue_s* rq, 83 struct runqueue_s* rq, 89 struct runqueue_s* rq, 96 struct runqueue_s* rq
|
/macosx-10.9.5/smb-697.95.1/lib/smb/ |
H A D | smbio_2.c | 61 struct smb2ioc_check_dir rq; local 67 bzero(&rq, sizeof(rq)); 68 rq.ioc_version = SMB_IOC_STRUCT_VERSION; 74 rq.ioc_path = path; 76 if (rq.ioc_path != NULL) 77 rq.ioc_path_len = (uint32_t)strlen(rq.ioc_path) + 1; /* end with null */ 79 rq.ioc_path_len = 0; 82 if (smb_ioctl_call(ctx->ct_fd, SMB2IOC_CHECK_DIR, &rq) 119 struct smb2ioc_close rq; local 261 struct smb2ioc_create rq; local [all...] |
H A D | rq.c | 52 #include <netsmb/rq.h> 77 struct smbioc_path_convert rq; local 79 bzero(&rq, sizeof(rq)); 80 rq.ioc_version = SMB_IOC_STRUCT_VERSION; 81 rq.ioc_direction = NETWORK_TO_LOCAL; 82 rq.ioc_flags = flags; 83 rq.ioc_src_len = (uint32_t)ntwrk_len; 84 rq.ioc_src = ntwrkstr; 85 rq 109 struct smbioc_path_convert rq; local [all...] |
H A D | ctx.c | 600 struct smbioc_negotiate rq; local 618 bzero(&rq, sizeof(rq)); 619 rq.ioc_version = SMB_IOC_STRUCT_VERSION; 620 rq.ioc_saddr_len = conn->addr.sa_len; 621 rq.ioc_saddr = &conn->addr; 622 bcopy(&ctx->ct_ssn, &rq.ioc_ssn, sizeof(struct smbioc_ossn)); 623 /* ct_setup.ioc_user and rq.ioc_user must be the same size */ 624 bcopy(&ctx->ct_setup.ioc_user, &rq.ioc_user, sizeof(rq 720 struct smbioc_negotiate rq; local [all...] |
/macosx-10.9.5/xnu-2422.115.4/osfmk/kern/ |
H A D | sched_grrr.c | 73 grrr_run_queue_t rq, 78 grrr_run_queue_t rq); 82 grrr_run_queue_t rq, 87 grrr_sorted_list_insert_group(grrr_run_queue_t rq, 91 grrr_rescale_work(grrr_run_queue_t rq); 312 grrr_run_queue_t rq = &processor->grrr_runq; local 314 return grrr_select(rq); 347 grrr_run_queue_t rq = &processor->grrr_runq; local 350 result = grrr_enqueue(rq, thread); 406 grrr_run_queue_t rq local 438 grrr_run_queue_t rq = &processor->grrr_runq; local 610 grrr_intergroup_schedule(grrr_run_queue_t rq) argument 695 grrr_rescale_work(grrr_run_queue_t rq) argument 708 grrr_enqueue( grrr_run_queue_t rq, thread_t thread) argument 755 grrr_select(grrr_run_queue_t rq) argument 798 grrr_remove( grrr_run_queue_t rq, thread_t thread) argument 835 grrr_sorted_list_insert_group(grrr_run_queue_t rq, grrr_group_t group) argument [all...] |
H A D | sched_proto.c | 296 run_queue_t rq = global_runq; local 304 queue = rq->queues + rq->highq; 305 pri = rq->highq; 306 count = rq->count; 328 SCHED_STATS_RUNQ_CHANGE(&rq->runq_stats, rq->count); 329 rq->count--; 332 clrbit(MAXPRI - pri, rq->bitmap); 333 rq 396 run_queue_t rq = global_runq; local 421 run_queue_t rq; local [all...] |
/macosx-10.9.5/xnu-2422.115.4/osfmk/kdp/ |
H A D | kdp.c | 240 kdp_connect_req_t *rq = &pkt->connect_req; local 247 if (plen < sizeof (*rq)) 250 dprintf(("kdp_connect seq %x greeting %s\n", rq->hdr.seq, rq->greeting)); 252 rport = rq->req_reply_port; 253 eport = rq->exc_note_port; 254 key = rq->hdr.key; 255 seq = rq->hdr.seq; 294 kdp_disconnect_req_t *rq = &pkt->disconnect_req; local 298 if (plen < sizeof (*rq)) 339 kdp_reattach_req_t *rq = &pkt->reattach_req; local 355 kdp_hostinfo_req_t *rq = &pkt->hostinfo_req; local 382 kdp_kernelversion_req_t *rq = &pkt->kernelversion_req; local 411 kdp_suspend_req_t *rq = &pkt->suspend_req; local 438 kdp_resumecpus_req_t *rq = &pkt->resumecpus_req; local 465 kdp_writemem_req_t *rq = &pkt->writemem_req; local 498 kdp_writemem64_req_t *rq = &pkt->writemem64_req; local 531 kdp_writephysmem64_req_t *rq = &pkt->writephysmem64_req; local 566 kdp_readmem_req_t *rq = &pkt->readmem_req; local 603 kdp_readmem64_req_t *rq = &pkt->readmem64_req; local 640 kdp_readphysmem64_req_t *rq = &pkt->readphysmem64_req; local 677 kdp_maxbytes_req_t *rq = &pkt->maxbytes_req; local 704 kdp_version_req_t *rq = &pkt->version_req; local 735 kdp_regions_req_t *rq = &pkt->regions_req; local 771 kdp_writeregs_req_t *rq = &pkt->writeregs_req; local 798 kdp_readregs_req_t *rq = &pkt->readregs_req; local 826 kdp_breakpoint_req_t *rq = &pkt->breakpoint_req; local 855 kdp_breakpoint64_req_t *rq = &pkt->breakpoint64_req; local 884 kdp_breakpoint_req_t *rq = &pkt->breakpoint_req; local 912 kdp_breakpoint64_req_t *rq = &pkt->breakpoint64_req; local 1518 kdp_readioport_req_t *rq = &pkt->readioport_req; local 1555 kdp_writeioport_req_t *rq = &pkt->writeioport_req; local 1587 kdp_readmsr64_req_t *rq = &pkt->readmsr64_req; local 1615 kdp_writemsr64_req_t *rq = &pkt->writemsr64_req; local 1641 kdp_dumpinfo_req_t *rq = &pkt->dumpinfo_req; local [all...] |
H A D | kdp_internal.h | 188 kdp_machine_phys_read(kdp_readphysmem64_req_t *rq, caddr_t /* data */, 192 kdp_machine_phys_write(kdp_writephysmem64_req_t *rq, caddr_t /* data */,
|
/macosx-10.9.5/OpenLDAP-491.1/OpenLDAP/servers/slapd/overlays/ |
H A D | refint.c | 403 refint_q *rq = op->o_callback->sc_private; local 404 refint_data *dd = rq->rdata; 428 ip->next = rq->attrs; 429 rq->attrs = ip; 438 if(dnIsSuffix(&b[i], &rq->oldndn)) { 439 is_exact = b[i].bv_len == rq->oldndn.bv_len; 474 if ( BER_BVISEMPTY( &rq->newdn ) ) 479 newsub.bv_len -= rq->olddn.bv_len + 1; 480 build_new_dn( &newdn, &rq->newdn, &newsub, op->o_tmpmemctx ); 484 newsub.bv_len -= rq 703 refint_q *rq; local 851 refint_q *rq; local [all...] |
/macosx-10.9.5/CPANInternal-140/HTTP-Proxy/eg/ |
H A D | rainbow.pl | 36 my ( $rq, $gq, $bq ) = qw/ 0 0 0/; 49 $rq = $rp <=> $rs; 58 if ( $rr == 1 and $rq < 1 and $rs < 1 ); 64 $rr = $rq;
|
/macosx-10.9.5/CPANInternal-140/HTTP-Proxy-0.25/eg/ |
H A D | rainbow.pl | 36 my ( $rq, $gq, $bq ) = qw/ 0 0 0/; 49 $rq = $rp <=> $rs; 58 if ( $rr == 1 and $rq < 1 and $rs < 1 ); 64 $rr = $rq;
|
/macosx-10.9.5/xnu-2422.115.4/osfmk/kdp/ml/i386/ |
H A D | kdp_x86_common.c | 111 kdp_readphysmem64_req_t rq; local 114 rq.address = src; 115 rq.nbytes = (uint32_t)len; 116 ret = kdp_machine_phys_read(&rq, dst, KDP_CURRENT_LCPU); 165 kdp_machine_phys_read(kdp_readphysmem64_req_t *rq, caddr_t dst, argument 168 mach_vm_address_t src = rq->address; 169 mach_vm_size_t len = rq->nbytes; 178 kdp_x86_xcpu_invoke(lcpu, (kdp_x86_xcpu_func_t)kdp_machine_phys_read, rq, dst); 270 kdp_machine_phys_write(kdp_writephysmem64_req_t *rq, caddr_t src, argument 273 mach_vm_address_t dst = rq 321 kdp_machine_ioport_read(kdp_readioport_req_t *rq, caddr_t data, uint16_t lcpu) argument 350 kdp_machine_ioport_write(kdp_writeioport_req_t *rq, caddr_t data, uint16_t lcpu) argument 379 kdp_machine_msr64_read(kdp_readmsr64_req_t *rq, caddr_t data, uint16_t lcpu) argument 393 kdp_machine_msr64_write(kdp_writemsr64_req_t *rq, caddr_t data, uint16_t lcpu) argument [all...] |
/macosx-10.9.5/bootp-268.1/bootpd.tproj/ |
H A D | dhcpd.c | 476 dhcp_bootp_allocate(char * idstr, char * hwstr, struct dhcp * rq, argument 490 match.giaddr = rq->dp_giaddr; 493 if (bootp_getbyhw_file(rq->dp_htype, rq->dp_chaddr, rq->dp_hlen, 497 && bootp_getbyhw_ds(rq->dp_htype, rq->dp_chaddr, rq->dp_hlen, 543 subnet = acquire_ip(rq->dp_giaddr, if_p, time_in_p, &iaddr); 545 if (DHCPLeases_reclaim(&S_leases, if_p, rq 597 struct dhcp * rq = request->pkt; local [all...] |
H A D | dhcpd.h | 43 dhcp_bootp_allocate(char * idstr, char * hwstr, struct dhcp * rq,
|
H A D | bsdpd.c | 1441 struct dhcp * rq = request->pkt; local 1442 char scratch_idstr[3 * sizeof(rq->dp_chaddr)]; 1445 || rq->dp_htype != ARPHRD_ETHER 1446 || rq->dp_hlen != ETHER_ADDR_LEN) { 1456 idstr = identifierToStringWithBuffer(rq->dp_htype, rq->dp_chaddr, 1457 rq->dp_hlen, scratch_idstr, 1527 struct dhcp * rq = request->pkt; local 1529 char scratch_idstr[3 * sizeof(rq->dp_chaddr)]; 1532 if (rq 2117 struct dhcp * rq = request->pkt; local [all...] |
/macosx-10.9.5/xnu-2422.115.4/osfmk/kdp/ml/x86_64/ |
H A D | kdp_machdep.c | 89 kdp_exception_t *rq = (kdp_exception_t *)pkt; local 91 rq->hdr.request = KDP_EXCEPTION; 92 rq->hdr.is_reply = 0; 93 rq->hdr.seq = kdp.exception_seq; 94 rq->hdr.key = 0; 95 rq->hdr.len = sizeof (*rq); 97 rq->n_exc_info = 1; 98 rq->exc_info[0].cpu = 0; 99 rq 119 kdp_exception_ack_t *rq = (kdp_exception_ack_t *)pkt; local [all...] |
/macosx-10.9.5/Libinfo-449.1.3/rpc.subproj/ |
H A D | clnt.h | 232 #define CLNT_CONTROL(cl,rq,in) ((*(cl)->cl_ops->cl_control)(cl,rq,in)) 233 #define clnt_control(cl,rq,in) ((*(cl)->cl_ops->cl_control)(cl,rq,in))
|
/macosx-10.9.5/ruby-104/ruby/lib/rake/contrib/ |
H A D | publisher.rb | 44 run %{scp -rq #{@local_dir}/* #{@host}:#{@remote_dir}}
|
H A D | sshpublisher.rb | 18 sh %{scp -rq #{@local_dir}/* #{@host}:#{@remote_dir}}
|
/macosx-10.9.5/libdispatch-339.92.1/src/ |
H A D | apply.c | 148 dispatch_queue_t dq = da->da_dc->dc_data, rq = dq, tq; local 151 uint32_t running, width = rq->dq_width; 152 running = dispatch_atomic_add2o(rq, dq_running, da_width, relaxed); 157 if (tq == rq) { 167 rq = rq->do_targetq; 168 } while (slowpath(rq->do_targetq)); 169 _dispatch_apply_f2(rq, da, _dispatch_apply_redirect_invoke);
|