wassname/ray
1
0
Fork 0
mirror of https://github.com/wassname/ray.git synced 2026-07-16 11:21:10 +08:00
Code Issues Packages Projects Releases Wiki Activity

fix formating

Browse Source
This commit is contained in:
Philipp Moritz
2016-10-12 01:10:05 -07:00
parent 50fb53fd91
commit 832888d473
2 changed files with 6 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files
event_loop.h
+1 -1
View File
@@ -31,7 +31,7 @@ typedef void (*event_loop_file_handler)(event_loop *loop,
* as well as the context that was specified when registering this handler
* are passed as arguments. The return is the number of milliseconds the
* timer shall be reset to or EVENT_LOOP_TIMER_DONE if the timer shall
* not triggered again. */
* not be triggered again. */
typedef int (*event_loop_timer_handler)(event_loop *loop,
timer_id timer_id,
void *context);
test/task_tests.c
+5 -5
View File
@@ -19,10 +19,10 @@ TEST task_test(void) {
unique_id arg1 = globally_unique_id();
ASSERT(task_args_add_ref(task, arg1) == 0);
ASSERT(task_args_add_val(task, (uint8_t*) "hello", 5) == 1);
ASSERT(task_args_add_val(task, (uint8_t *) "hello", 5) == 1);
unique_id arg2 = globally_unique_id();
ASSERT(task_args_add_ref(task, arg2) == 2);
ASSERT(task_args_add_val(task, (uint8_t*) "world", 5) == 3);
ASSERT(task_args_add_val(task, (uint8_t *) "world", 5) == 3);
unique_id ret0 = globally_unique_id();
unique_id ret1 = globally_unique_id();
@@ -30,10 +30,10 @@ TEST task_test(void) {
memcpy(task_return(task, 1), &ret1, sizeof(ret1));
ASSERT(memcmp(task_arg_id(task, 0), &arg1, sizeof(arg1)) == 0);
ASSERT(memcmp(task_arg_val(task, 1), (uint8_t*) "hello",
ASSERT(memcmp(task_arg_val(task, 1), (uint8_t *) "hello",
task_arg_length(task, 1)) == 0);
ASSERT(memcmp(task_arg_id(task, 2), &arg2, sizeof(arg2)) == 0);
ASSERT(memcmp(task_arg_val(task, 3), (uint8_t*) "world",
ASSERT(memcmp(task_arg_val(task, 3), (uint8_t *) "world",
task_arg_length(task, 3)) == 0);
ASSERT(memcmp(task_return(task, 0), &ret0, sizeof(unique_id)) == 0);
@@ -49,7 +49,7 @@ TEST send_task(void) {
*task_return(task, 1) = globally_unique_id();
int fd[2];
socketpair(AF_UNIX, SOCK_STREAM, 0, fd);
write_message(fd[0], SUBMIT_TASK, task_size(task), (uint8_t*) task);
write_message(fd[0], SUBMIT_TASK, task_size(task), (uint8_t *) task);
int64_t type;
int64_t length;
uint8_t *message;