Lines Matching defs:thread
35 uint32_t tid; ///< thread ID
36 uint64_t icv; ///< thread's control variables
55 BOMP_DEBUG_THREAD("done__rx from thread\n");
92 * \brief callback when the BOMP thread connects to the node
132 * \brief initializes a thread on the given core
136 * \param thread pointer to the thread struct to create
143 struct bomp_thread *thread)
147 BOMP_DEBUG_THREAD("Creating thread on core %"PRIuCOREID " \n", core);
165 err = frame_alloc(&thread->msgframe, 2 * BOMP_CHANNEL_SIZE, &msg_frame_size);
170 err = vspace_map_one_frame(&thread->msgbuf, msg_frame_size, thread->msgframe,
177 .sendbase = (lpaddr_t)thread->msgbuf + BOMP_CHANNEL_SIZE,
178 .inbuf = thread->msgbuf,
180 .outbuf = ((uint8_t *) thread->msgbuf) + BOMP_CHANNEL_SIZE,
184 BOMP_DEBUG_THREAD("creating channel on %p\n", thread->msgbuf);
186 err = bomp_accept(&fi, thread, bomp_thread_accept_cb,
194 BOMP_DEBUG_THREAD("creating thread on core %" PRIuCOREID "\n", core);
196 thread->msgbuf, NULL);
202 while (thread->ctrl == NULL) {
209 BOMP_DEBUG_THREAD("thread on core %" PRIuCOREID " connected \n", core);
211 return thread->thread_err;
214 errval_t bomp_thread_exec(struct bomp_thread *thread,
217 debug_printf("bomp_thread_exec(%p, %p, %p, %u) %p\n", thread, fn, arg, tid, thread->icvt);
218 struct txq_msg_st *msg_st = txq_msg_st_alloc(&thread->txq);
233 bomp_msg_st->args.exec.icv = (uint64_t)thread->icvt;
281 assert(t == &tls->r.thread);
353 BOMP_DEBUG_THREAD("thread message handler started %p\n", tls);
357 tls->r.thread.coreid = disp_get_core_id();
358 tls->r.thread.msgbuf = arg;
359 tls->r.thread.tls = tls;
378 err = bomp_connect(&fi, bomp_thread_connect_cb, &tls->r.thread, ws,
406 BOMP_NOTICE("thread %" PRIuCOREID " terminated", disp_get_core_id());