obj 114 include/sys/prex.h int object_destroy(object_t obj); obj 117 include/sys/prex.h int msg_send(object_t obj, void *msg, size_t size); obj 118 include/sys/prex.h int msg_receive(object_t obj, void *msg, size_t size); obj 119 include/sys/prex.h int msg_reply(object_t obj, void *msg, size_t size); obj 81 sys/ipc/msg.c msg_send(object_t obj, void *msg, size_t size) obj 96 sys/ipc/msg.c if (!object_valid(obj)) { obj 105 sys/ipc/msg.c if (obj == curthread->recvobj) { obj 133 sys/ipc/msg.c if (!queue_empty(&obj->recvq)) { obj 134 sys/ipc/msg.c t = msg_dequeue(&obj->recvq); obj 143 sys/ipc/msg.c curthread->sendobj = obj; obj 144 sys/ipc/msg.c msg_enqueue(&obj->sendq, curthread); obj 188 sys/ipc/msg.c msg_receive(object_t obj, void *msg, size_t size) obj 199 sys/ipc/msg.c if (!object_valid(obj)) { obj 203 sys/ipc/msg.c if (obj->owner != curtask) { obj 216 sys/ipc/msg.c curthread->recvobj = obj; obj 221 sys/ipc/msg.c while (queue_empty(&obj->sendq)) { obj 225 sys/ipc/msg.c msg_enqueue(&obj->recvq, curthread); obj 257 sys/ipc/msg.c t = msg_dequeue(&obj->sendq); obj 265 sys/ipc/msg.c msg_enqueue(&obj->sendq, t); obj 288 sys/ipc/msg.c msg_reply(object_t obj, void *msg, size_t size) obj 298 sys/ipc/msg.c if (!object_valid(obj) || obj != curthread->recvobj) { obj 383 sys/ipc/msg.c msg_abort(object_t obj) obj 393 sys/ipc/msg.c while (!queue_empty(&obj->sendq)) { obj 394 sys/ipc/msg.c q = dequeue(&obj->sendq); obj 401 sys/ipc/msg.c while (!queue_empty(&obj->recvq)) { obj 402 sys/ipc/msg.c q = dequeue(&obj->recvq); obj 83 sys/ipc/object.c struct object *obj = 0; obj 108 sys/ipc/object.c if (copyout(&obj, objp, sizeof(obj))) { obj 116 sys/ipc/object.c if ((obj = kmem_alloc(sizeof(*obj))) == NULL) { obj 121 sys/ipc/object.c strlcpy(obj->name, str, MAXOBJNAME); obj 123 sys/ipc/object.c obj->owner = curtask; obj 124 sys/ipc/object.c queue_init(&obj->sendq); obj 125 sys/ipc/object.c queue_init(&obj->recvq); obj 126 sys/ipc/object.c list_insert(&curtask->objects, &obj->task_link); obj 128 sys/ipc/object.c list_insert(&object_list, &obj->link); obj 129 sys/ipc/object.c copyout(&obj, objp, sizeof(obj)); obj 142 sys/ipc/object.c object_t obj; obj 151 sys/ipc/object.c obj = object_find(str); obj 154 sys/ipc/object.c if (obj == NULL) obj 157 sys/ipc/object.c if (copyout(&obj, objp, sizeof(obj))) obj 163 sys/ipc/object.c object_valid(object_t obj) obj 171 sys/ipc/object.c if (tmp == obj) obj 180 sys/ipc/object.c object_t obj; obj 185 sys/ipc/object.c obj = list_entry(n, struct object, link); obj 186 sys/ipc/object.c if (!strncmp(obj->name, name, MAXOBJNAME)) obj 187 sys/ipc/object.c return obj; obj 196 sys/ipc/object.c object_deallocate(object_t obj) obj 199 sys/ipc/object.c msg_abort(obj); obj 200 sys/ipc/object.c obj->owner->nobjects--; obj 201 sys/ipc/object.c list_remove(&obj->task_link); obj 202 sys/ipc/object.c list_remove(&obj->link); obj 203 sys/ipc/object.c kmem_free(obj); obj 213 sys/ipc/object.c object_destroy(object_t obj) obj 217 sys/ipc/object.c if (!object_valid(obj)) { obj 221 sys/ipc/object.c if (obj->owner != curtask) { obj 225 sys/ipc/object.c object_deallocate(obj); obj 236 sys/ipc/object.c object_t obj; obj 239 sys/ipc/object.c obj = list_entry(list_first(&task->objects), obj 241 sys/ipc/object.c object_deallocate(obj); obj 43 usr/lib/posix/gen/__posix_call.c __posix_call(object_t obj, void *msg, size_t size, int restart) obj 47 usr/lib/posix/gen/__posix_call.c if (obj == 0) { obj 53 usr/lib/posix/gen/__posix_call.c error = msg_send(obj, msg, size); obj 81 usr/sample/ipc/ipc.c send_message(object_t obj, const char *str) obj 87 usr/sample/ipc/ipc.c msg_send(obj, &msg, sizeof(msg)); obj 98 usr/sample/ipc/ipc.c object_t obj; obj 106 usr/sample/ipc/ipc.c if ((error = object_lookup("test", &obj)) != 0) obj 112 usr/sample/ipc/ipc.c send_message(obj, "Hello!"); obj 113 usr/sample/ipc/ipc.c send_message(obj, "This is a client task."); obj 114 usr/sample/ipc/ipc.c send_message(obj, "Who are you?"); obj 115 usr/sample/ipc/ipc.c send_message(obj, "How are you?"); obj 116 usr/sample/ipc/ipc.c send_message(obj, "...."); obj 117 usr/sample/ipc/ipc.c send_message(obj, "Bye!"); obj 118 usr/sample/ipc/ipc.c send_message(obj, "Exit"); obj 129 usr/sample/ipc/ipc.c object_t obj = 0; obj 143 usr/sample/ipc/ipc.c if ((error = object_create("test", &obj)) != 0) obj 160 usr/sample/ipc/ipc.c error = msg_receive(obj, &msg, sizeof(msg)); obj 180 usr/sample/ipc/ipc.c msg_reply(obj, &msg, sizeof(msg)); obj 52 usr/sbin/debug/debug.c object_t obj; obj 58 usr/sbin/debug/debug.c if (object_lookup(argv[1], &obj) != 0) { obj 63 usr/sbin/debug/debug.c msg_send(obj, &m, sizeof(m)); obj 47 usr/sbin/ktrace/ktrace.c object_t obj; obj 57 usr/sbin/ktrace/ktrace.c if (object_lookup("!proc", &obj) != 0) { obj 62 usr/sbin/ktrace/ktrace.c msg_send(obj, &m, sizeof(m)); obj 110 usr/server/boot/boot.c send_bootmsg(object_t obj) obj 116 usr/server/boot/boot.c error = msg_send(obj, &m, sizeof(m)); obj 82 usr/server/exec/main.c object_t obj; obj 85 usr/server/exec/main.c error = object_lookup("!proc", &obj); obj 90 usr/server/exec/main.c msg_send(obj, &m, sizeof(m)); obj 166 usr/server/exec/main.c object_t obj; obj 192 usr/server/exec/main.c error = object_create("!exec", &obj); obj 206 usr/server/exec/main.c error = msg_receive(obj, msg, MAX_EXECMSG); obj 233 usr/server/exec/main.c error = msg_reply(obj, msg, MAX_EXECMSG); obj 327 usr/server/pow/pow.c object_t obj; obj 330 usr/server/pow/pow.c error = object_lookup("!proc", &obj); obj 335 usr/server/pow/pow.c msg_send(obj, &m, sizeof(m)); obj 369 usr/server/pow/pow.c object_t obj; obj 373 usr/server/pow/pow.c error = object_lookup((char *)name, &obj); obj 378 usr/server/pow/pow.c error = msg_send(obj, &m, sizeof(m)); obj 397 usr/server/pow/pow.c object_t obj; obj 434 usr/server/pow/pow.c error = object_create("!pow", &obj); obj 445 usr/server/pow/pow.c error = msg_receive(obj, &msg, sizeof(msg)); obj 472 usr/server/pow/pow.c msg_reply(obj, &msg, sizeof(msg)); obj 408 usr/server/proc/main.c object_t obj; obj 421 usr/server/proc/main.c if (object_lookup("!exec", &obj) != 0) obj 425 usr/server/proc/main.c msg_send(obj, &m, sizeof(m)); obj 526 usr/server/proc/main.c object_t obj; obj 541 usr/server/proc/main.c if ((error = object_create("!proc", &obj)) != 0) obj 551 usr/server/proc/main.c error = msg_receive(obj, &msg, sizeof(msg)); obj 574 usr/server/proc/main.c msg_reply(obj, &msg, sizeof(msg)); obj 45 usr/test/attack/attack.c object_t obj = (object_t)random(); obj 61 usr/test/attack/attack.c object_destroy(obj); obj 68 usr/test/attack/attack.c msg_send(obj, NULL, size); obj 69 usr/test/attack/attack.c msg_send(obj, msg, 0); obj 72 usr/test/attack/attack.c msg_send(obj, msg, size); obj 75 usr/test/attack/attack.c msg_receive(obj, NULL, size); obj 76 usr/test/attack/attack.c msg_receive(obj, msg, 0); obj 79 usr/test/attack/attack.c msg_receive(obj, msg, size); obj 82 usr/test/attack/attack.c msg_reply(obj, NULL, size); obj 83 usr/test/attack/attack.c msg_reply(obj, msg, 0); obj 86 usr/test/attack/attack.c msg_reply(obj, msg, size); obj 74 usr/test/ipc_mt/ipc_mt.c object_t obj; obj 84 usr/test/ipc_mt/ipc_mt.c error = object_lookup("test-A", &obj); obj 91 usr/test/ipc_mt/ipc_mt.c msg_receive(obj, &msg, sizeof(msg)); obj 100 usr/test/ipc_mt/ipc_mt.c msg_reply(obj, &msg, sizeof(msg)); obj 109 usr/test/ipc_mt/ipc_mt.c object_t obj; obj 117 usr/test/ipc_mt/ipc_mt.c error = object_create("test-A", &obj); obj 46 usr/test/memleak/memleak.c object_t obj; obj 66 usr/test/memleak/memleak.c error = object_create(str, &obj); obj 43 usr/test/object/object.c object_t obj; obj 51 usr/test/object/object.c error = object_create("test", &obj); obj 55 usr/test/object/object.c error = object_destroy(obj); obj 62 usr/test/object/object.c error = object_create("!test", &obj); obj 69 usr/test/object/object.c error = object_lookup("!proc", &obj); obj 73 usr/test/object/object.c error = object_destroy(obj);