Searched refs:rq (Results 1 - 25 of 75) sorted by relevance

123

/macosx-10.9.5/dcerpc-58/dcerpc/ncklib/
H A Ddgrq.c112 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 Ddgrq.h115 #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 Ddgcall.c161 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 Ddg.c249 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 Drq.c38 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 Dldap_rq.h42 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 Dsmbio_2.c61 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 Drq.c52 #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 Dctx.c600 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 Dsched_grrr.c73 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 Dsched_proto.c296 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 Dkdp.c240 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 Dkdp_internal.h188 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 Drefint.c403 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 Drainbow.pl36 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 Drainbow.pl36 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 Dkdp_x86_common.c111 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 Ddhcpd.c476 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 Ddhcpd.h43 dhcp_bootp_allocate(char * idstr, char * hwstr, struct dhcp * rq,
H A Dbsdpd.c1441 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 Dkdp_machdep.c89 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 Dclnt.h232 #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 Dpublisher.rb44 run %{scp -rq #{@local_dir}/* #{@host}:#{@remote_dir}}
H A Dsshpublisher.rb18 sh %{scp -rq #{@local_dir}/* #{@host}:#{@remote_dir}}
/macosx-10.9.5/libdispatch-339.92.1/src/
H A Dapply.c148 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);

Completed in 376 milliseconds

123