/barrelfish-2018-10-04/lib/bulk_transfer/backends/sm/ |
H A D | pending_msg.c | 34 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 D | pending_msg.h | 66 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 D | bulk_sm_impl.h | 52 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 D | buffers.c | 27 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 D | usb_transfer.h | 71 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 D | usb_transfer.h | 43 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 D | usb_transfer.c | 36 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 D | usb_manager_client.h | 20 uint32_t tid, uint32_t error, const uint8_t *data, size_t length);
|
/barrelfish-2018-10-04/lib/phoenix/ |
H A D | taskQ.h | 47 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 D | taskQ.c | 69 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 D | tls.c | 29 uintptr_t tid = (uintptr_t)arg; local 34 debug_printf("%lu: %d\n", tid, mytest);
|
/barrelfish-2018-10-04/usr/tests/octopus/ |
H A D | d2trigger.c | 63 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 D | d2bench1.c | 40 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 D | d2bench.c | 62 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 D | pthreads.c | 49 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 D | trigger.c | 96 * \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 D | barriers.c | 47 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 D | locking.c | 56 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 D | domain.c | 33 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 D | bomp_thread.c | 35 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 D | start_cpu.c | 77 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 D | start_int_ctrl.c | 121 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 D | audit_record.h | 248 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 D | xeon_phi_domain.c | 105 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 D | nameservice_client.c | 42 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);
|