Searched refs:tid (Results 1 - 25 of 58) sorted by relevance

123

/barrelfish-2018-10-04/lib/bulk_transfer/backends/sm/
H A Dpending_msg.c34 debug_printf(" %u\n", node->tid);
44 * generates tid automatically
47 * @param tid: will be filled in with transaction id
51 uint32_t *tid,
64 p->tid = thistid;
66 // debug_printf("PENDING MSG: [new tid=%u]\n", thistid);
75 *tid = thistid;
82 if (node->tid < thistid){
88 *tid = thistid;
94 } else if (node->tid > thisti
50 pending_msg_add(struct bulk_channel* channel, uint32_t *tid, union pending_msg_data data) argument
134 pending_msg_get(struct bulk_channel *channel, uint32_t tid, union pending_msg_data *data, bool do_remove) argument
[all...]
H A Dpending_msg.h66 uint32_t tid; //key member in struct:bulk_sm_pending_msg
74 * generates tid automatically
77 * @param tid: will be filled in with transaction id
81 uint32_t *tid,
88 * @param tid: transaction id to look up
93 uint32_t tid,
H A Dbulk_sm_impl.h52 uint32_t tid,
61 uint32_t tid,
68 uint32_t tid);
74 uint32_t tid,
83 uint32_t tid,
90 uint32_t tid);
96 uint32_t tid,
105 uint32_t tid,
112 uint32_t tid);
118 uint32_t tid);
[all...]
H A Dbuffers.c27 uint32_t tid; member in struct:pass_data
49 d->tid, d->cap, d->meta, d->metasize);
52 d->tid, d->meta, d->metasize);
60 bulk_sm_move_rx_response(b, err, d->tid);
72 uint32_t tid; local
79 err = pending_msg_add(channel, &tid, pmsg);
93 d->tid = tid;
119 d->tid, d->cap, d->meta, d->metasize);
122 d->tid,
142 uint32_t tid; local
206 uint32_t tid; local
266 uint32_t tid; local
309 uint32_t tid; member in struct:bulk_sm_reply_data
327 bulk_sm_move_rx_call( struct bulk_ctrl_binding *b, bulk_ctrl_poolid_t poolid, uint32_t bufferid, uint32_t tid, struct capref cap, const uint8_t *meta, size_t metasize) argument
392 bulk_sm_move_trusted_rx_call( struct bulk_ctrl_binding *b, bulk_ctrl_poolid_t poolid, uint32_t bufferid, uint32_t tid, const uint8_t *meta, size_t metasize) argument
405 bulk_sm_move_rx_response( struct bulk_ctrl_binding *b, bulk_ctrl_error_t error, uint32_t tid) argument
440 bulk_sm_copy_rx_call( struct bulk_ctrl_binding *b, bulk_ctrl_poolid_t poolid, uint32_t bufferid, uint32_t tid, struct capref cap, const uint8_t *meta, size_t metasize) argument
504 bulk_sm_copy_trusted_rx_call( struct bulk_ctrl_binding *b, bulk_ctrl_poolid_t poolid, uint32_t bufferid, uint32_t tid, const uint8_t *meta, size_t metasize) argument
517 bulk_sm_copy_rx_response( struct bulk_ctrl_binding *b, bulk_ctrl_error_t error, uint32_t tid) argument
553 bulk_sm_pass_rx_call( struct bulk_ctrl_binding *b, bulk_ctrl_poolid_t poolid, uint32_t bufferid, uint32_t tid, struct capref cap, const uint8_t *meta, size_t metasize) argument
620 bulk_sm_pass_trusted_rx_call( struct bulk_ctrl_binding *b, bulk_ctrl_poolid_t poolid, uint32_t bufferid, uint32_t tid, const uint8_t *meta, size_t metasize) argument
633 bulk_sm_pass_rx_response( struct bulk_ctrl_binding *b, bulk_ctrl_error_t error, uint32_t tid) argument
670 bulk_sm_release_rx_call( struct bulk_ctrl_binding *b, bulk_ctrl_poolid_t poolid, uint32_t bufferid, uint32_t tid) argument
734 bulk_sm_release_rx_response( struct bulk_ctrl_binding *b, bulk_ctrl_error_t error, uint32_t tid) argument
[all...]
/barrelfish-2018-10-04/include/usb/
H A Dusb_transfer.h71 usb_error_t usb_transfer_unsetup(usb_xfer_id_t tid);
74 usb_error_t usb_transfer_start(usb_xfer_id_t tid);
76 usb_error_t usb_transfer_stop(usb_xfer_id_t tid);
79 usb_error_t usb_transfer_clear_stall(usb_xfer_id_t tid);
82 usb_error_t usb_transfer_get_state(usb_xfer_id_t tid, usb_tstate_t *ret_state);
84 usb_error_t usb_transfer_get_status(usb_xfer_id_t tid, uint32_t *ret_actlen,
/barrelfish-2018-10-04/usr/drivers/usb/usb_manager/include/
H A Dusb_transfer.h43 uint32_t tid);
44 void usb_rx_transfer_start_call(struct usb_manager_binding *bind, uint32_t tid);
45 void usb_rx_transfer_stop_call(struct usb_manager_binding *bind, uint32_t tid);
47 uint32_t tid);
48 void usb_rx_transfer_state_call(struct usb_manager_binding *bind, uint32_t tid);
50 uint32_t tid);
/barrelfish-2018-10-04/lib/usb/
H A Dusb_transfer.c36 usb_xfer_id_t tid; ///< the transfer id member in struct:usb_xfer_state
96 * \param tid the transfer ID
101 static struct usb_xfer_state *usb_xfer_get_state(usb_xfer_id_t tid) argument
105 if (st->tid == tid) {
111 assert(st==NULL || (st && st->tid == tid));
122 uint32_t tid, uint32_t error, const uint8_t *data, size_t length)
125 struct usb_xfer_state *st = usb_xfer_get_state(tid);
128 debug_printf("WARNING: xfer done with unknown tid
121 usb_driver_rx_done_notify(struct usb_driver_binding *b, uint32_t tid, uint32_t error, const uint8_t *data, size_t length) argument
328 usb_transfer_unsetup(usb_xfer_id_t tid) argument
364 usb_transfer_start(usb_xfer_id_t tid) argument
393 usb_transfer_stop(usb_xfer_id_t tid) argument
418 usb_transfer_clear_stall(usb_xfer_id_t tid) argument
450 usb_transfer_get_state(usb_xfer_id_t tid, usb_tstate_t *ret_state) argument
485 usb_transfer_get_status(usb_xfer_id_t tid, uint32_t *ret_actlen, uint32_t *ret_length, uint32_t *ret_actframes, uint32_t *ret_numframes) argument
[all...]
H A Dusb_manager_client.h20 uint32_t tid, uint32_t error, const uint8_t *data, size_t length);
/barrelfish-2018-10-04/lib/phoenix/
H A DtaskQ.h47 int tq_enqueue (taskQ_t* tq, task_t *task, int lgrp, int tid);
49 int tq_dequeue (taskQ_t* tq, task_t *task, int lgrp, int tid);
H A DtaskQ.c69 taskQ_t* tq, task_t* task, int lgrp, int tid);
71 taskQ_t* tq, task_t* task, int lgrp, int tid);
73 taskQ_t* tq, task_t* task, int lgrp, int tid, dequeue_fn dequeue_fn);
302 int tq_enqueue (taskQ_t* tq, task_t *task, int lgrp, int tid) argument
317 index = (lgrp < 0) ? rand_r(&tq->seeds[tid]) : lgrp;
320 lock_acquire (tq->locks[index].per_thread[tid]);
322 lock_release (tq->locks[index].per_thread[tid]);
355 * @param tid task id
360 taskQ_t* tq, int idx, int tid, queue_elem_t** qe)
378 * @param tid tas
359 tq_elem_into_free_seq( taskQ_t* tq, int idx, int tid, queue_elem_t** qe) argument
382 tq_elem_into_free( taskQ_t* tq, int idx, int tid, queue_elem_t** qe) argument
394 tq_dequeue_normal_seq( taskQ_t* tq, task_t* task, int lgrp, int tid) argument
401 tq_dequeue_normal( taskQ_t* tq, task_t* task, int lgrp, int tid) argument
408 tq_dequeue_normal_internal( taskQ_t* tq, task_t* task, int lgrp, int tid, dequeue_fn dequeue_fn) argument
445 tq_dequeue(taskQ_t* tq, task_t *task, int lgrp, int tid) argument
[all...]
/barrelfish-2018-10-04/usr/tests/tls/
H A Dtls.c29 uintptr_t tid = (uintptr_t)arg; local
34 debug_printf("%lu: %d\n", tid, mytest);
/barrelfish-2018-10-04/usr/tests/octopus/
H A Dd2trigger.c63 octopus_trigger_id_t tid; local
81 &tid, &error_code);
85 debug_printf("tid is: %"PRIu64"\n", tid);
94 tid = 0;
100 &tid, &error_code);
103 debug_printf("tid is: %"PRIu64"\n", tid);
118 err = oct_remove_trigger(tid);
H A Dd2bench1.c40 octopus_trigger_id_t tid; local
60 cl->call_seq.get(cl, "rec", NOP_TRIGGER, &reply, &tid, &error_code);
67 cl->call_seq.set(cl, record, SET_DEFAULT, NOP_TRIGGER, false, &reply, &tid, &error_code);
H A Dd2bench.c62 octopus_trigger_id_t tid; local
71 cl->call_seq.get(cl, buf, NOP_TRIGGER, &data, &tid, &error_code);
100 octopus_trigger_id_t tid; local
107 cl->call_seq.set(cl, record, SET_SEQUENTIAL, NOP_TRIGGER, false, &ret, &tid, &error_code);
117 cl->call_seq.set(cl, to_add, SET_DEFAULT, NOP_TRIGGER, false, &data, &tid, &error_code);
125 cl->call_seq.del(cl, to_add, NOP_TRIGGER, &tid, &error_code);
154 octopus_trigger_id_t tid; local
159 cl->call_seq.get(cl, "object0", NOP_TRIGGER, &data, &tid, &error_code);
179 octopus_trigger_id_t tid; local
189 cl->call_seq.get(cl, "_ { attr1: 'bla', attr2: 12.0 }", NOP_TRIGGER, &data, &tid,
[all...]
/barrelfish-2018-10-04/usr/tests/posixcompat/
H A Dpthreads.c49 pthread_t tid; local
55 int rv = pthread_create(&tid, &attr, prj_thread, NULL);
62 pthread_join(tid, NULL);
75 pthread_t tid; local
87 int rv = pthread_create(&tid, &attr, prj_thread, NULL);
94 pthread_join(tid, NULL);
131 pthread_t tid[cpu_count]; local
142 int rv = pthread_create(&tid[rep], &attr, mutex_increment, NULL);
150 pthread_join(tid[rep], NULL);
/barrelfish-2018-10-04/lib/octopus/client/
H A Dtrigger.c96 * \param[out] tid Trigger id.
102 octopus_trigger_id_t* tid)
115 t, reply.output, &reply.tid, &reply.error_code);
155 if (tid) {
156 *tid = reply.tid;
100 oct_trigger_existing_and_watch(const char* query, trigger_handler_fn event_handler, void* state, octopus_trigger_id_t* tid) argument
H A Dbarriers.c47 octopus_trigger_id_t tid; local
69 err = cl->call_seq.exists(cl, name, t, &tid, &exist_err);
118 octopus_trigger_id_t tid; local
139 err = cl->call_seq.exists(cl, barrier_name, t, &tid, &exist_err);
H A Dlocking.c56 octopus_trigger_id_t tid; local
98 err = cl->call_seq.exists(cl, names[i-1], t, &tid, &exist_err);
104 err = cl->recv.trigger(cl, &tid, NULL, &mode, NULL, NULL);
/barrelfish-2018-10-04/usr/drivers/xeon_phi/
H A Ddomain.c33 octopus_trigger_id_t tid; member in struct:wait_state
44 oct_remove_trigger(ws->tid);
74 err = r->rpc_tx_vtbl.get(r, iface, NOP_TRIGGER, reply.output, &reply.tid,
136 err = c->call_seq.get(c, iface, iface_set_trigger, NULL, &ws->tid,
188 octopus_trigger_id_t tid; local
190 err = r->rpc_tx_vtbl.set(r, record, 0, NOP_TRIGGER, 0, NULL, &tid, &error_code);
/barrelfish-2018-10-04/lib/bomp_new/
H A Dbomp_thread.c35 uint32_t tid; ///< thread ID member in struct:bomp_msg_st::__anon523::__anon524
85 st->args.exec.fn, st->args.exec.arg, st->args.exec.tid,
104 BOMP_DEBUG_THREAD("connection accepted. tid=%" PRIuCOREID "\n", t->coreid);
215 bomp_thread_fn_t fn, void *arg, uint32_t tid)
217 debug_printf("bomp_thread_exec(%p, %p, %p, %u) %p\n", thread, fn, arg, tid, thread->icvt);
232 bomp_msg_st->args.exec.tid = tid;
272 uint64_t fn, uint64_t arg, uint32_t tid, uint64_t icv_task)
288 tls->thread_id = tid;
300 BOMP_ERROR("allocation of message state failed: %" PRIu32 "\n", tid);
214 bomp_thread_exec(struct bomp_thread *thread, bomp_thread_fn_t fn, void *arg, uint32_t tid) argument
271 execute__rx(struct bomp_binding *_binding, uint64_t fn, uint64_t arg, uint32_t tid, uint64_t icv_task) argument
[all...]
/barrelfish-2018-10-04/usr/kaluga/
H A Dstart_cpu.c77 octopus_trigger_id_t tid; local
79 NULL, &tid);
85 octopus_trigger_id_t tid; member in struct:inheritcn_del_st
107 err = oct_remove_trigger(st->tid);
225 tstate, &tstate->tid);
290 octopus_trigger_id_t tid; local
291 err = oct_trigger_existing_and_watch(spawnds, spawnd_change_event, (void*)count, &tid);
H A Dstart_int_ctrl.c121 octopus_trigger_id_t tid; local
122 return oct_trigger_existing_and_watch(int_controller_device, int_controller_change_event, NULL, &tid);
/barrelfish-2018-10-04/include/bsm/
H A Daudit_record.h248 gid_t rgid, pid_t pid, au_asid_t sid, au_tid_t *tid);
250 gid_t rgid, pid_t pid, au_asid_t sid, au_tid_t *tid);
252 gid_t rgid, pid_t pid, au_asid_t sid, au_tid_t *tid);
254 gid_t rgid, pid_t pid, au_asid_t sid, au_tid_addr_t *tid);
257 au_tid_addr_t *tid);
259 gid_t rgid, pid_t pid, au_asid_t sid, au_tid_addr_t *tid);
272 gid_t rgid, pid_t pid, au_asid_t sid, au_tid_t *tid);
274 gid_t rgid, pid_t pid, au_asid_t sid, au_tid_t *tid);
276 gid_t rgid, pid_t pid, au_asid_t sid, au_tid_t *tid);
278 gid_t rgid, pid_t pid, au_asid_t sid, au_tid_addr_t *tid);
[all...]
/barrelfish-2018-10-04/lib/xeon_phi/
H A Dxeon_phi_domain.c105 err = r->rpc_tx_vtbl.get(r, iface, NOP_TRIGGER, reply.output, &reply.tid, &reply.error_code);
208 octopus_trigger_id_t tid;
210 err = r->rpc_tx_vtbl.set(r, record, 0, NOP_TRIGGER, 0, NULL, &tid, &error_code);
/barrelfish-2018-10-04/lib/barrelfish/
H A Dnameservice_client.c42 err = r->rpc_tx_vtbl.get(r, iface, NOP_TRIGGER, reply.output, &reply.tid,
135 octopus_trigger_id_t tid; local
137 err = r->rpc_tx_vtbl.set(r, record, 0, NOP_TRIGGER, 0, NULL, &tid, &error_code);

Completed in 116 milliseconds

123