sync_test.c revision b6279689edecc898bd9622f4ac562239650815bc 
1/*
2 *  sync_test.c
3 *
4 *   Copyright 2012 Google, Inc
5 *
6 *  Licensed under the Apache License, Version 2.0 (the "License");
7 *  you may not use this file except in compliance with the License.
8 *  You may obtain a copy of the License at
9 *
10 *      http://www.apache.org/licenses/LICENSE-2.0
11 *
12 *  Unless required by applicable law or agreed to in writing, software
13 *  distributed under the License is distributed on an "AS IS" BASIS,
14 *  WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
15 *  See the License for the specific language governing permissions and
16 *  limitations under the License.
17 */
18
19#include <errno.h>
20#include <pthread.h>
21#include <stdio.h>
22#include <string.h>
23#include <unistd.h>
24
25#include <sync/sync.h>
26
27pthread_mutex_t printf_mutex = PTHREAD_MUTEX_INITIALIZER;
28
29struct sync_thread_data {
30    int thread_no;
31    int fd[2];
32};
33
34void *sync_thread(void *data)
35{
36    struct sync_thread_data *sync_data = data;
37    struct sync_fence_info_data *info;
38    int err;
39    int i;
40
41    for (i = 0; i < 2; i++) {
42        err = sync_wait(sync_data->fd[i], 10000);
43
44        pthread_mutex_lock(&printf_mutex);
45        if (err < 0) {
46            printf("thread %d wait %d failed: %s\n", sync_data->thread_no,
47                   i, strerror(errno));
48        } else {
49            printf("thread %d wait %d done\n", sync_data->thread_no, i);
50        }
51        info = sync_fence_info(sync_data->fd[i]);
52        if (info) {
53            struct sync_pt_info *pt_info = NULL;
54            printf("  fence %s %d\n", info->name, info->status);
55
56            while ((pt_info = sync_pt_info(info, pt_info))) {
57                int ts_sec = pt_info->timestamp_ns / 1000000000LL;
58                int ts_usec = (pt_info->timestamp_ns % 1000000000LL) / 1000LL;
59                printf("    pt %s %s %d %d.%06d", pt_info->obj_name,
60                       pt_info->driver_name, pt_info->status,
61                       ts_sec, ts_usec);
62                if (!strcmp(pt_info->driver_name, "sw_sync"))
63                    printf(" val=%d\n", *(uint32_t *)pt_info->driver_data);
64                else
65                    printf("\n");
66            }
67            sync_fence_info_free(info);
68        }
69        pthread_mutex_unlock(&printf_mutex);
70    }
71
72    return NULL;
73}
74
75int main(int argc __attribute__((unused)), char *argv[] __attribute__((unused)))
76{
77    struct sync_thread_data sync_data[4];
78    pthread_t threads[4];
79    int sync_timeline_fd;
80    int i, j;
81    char str[256];
82
83    sync_timeline_fd = sw_sync_timeline_create();
84    if (sync_timeline_fd < 0) {
85        perror("can't create sw_sync_timeline:");
86        return 1;
87    }
88
89    for (i = 0; i < 3; i++) {
90        sync_data[i].thread_no = i;
91
92        for (j = 0; j < 2; j++) {
93            unsigned val = i + j * 3 + 1;
94            sprintf(str, "test_fence%d-%d", i, j);
95            int fd = sw_sync_fence_create(sync_timeline_fd, str, val);
96            if (fd < 0) {
97                printf("can't create sync pt %d: %s", val, strerror(errno));
98                return 1;
99            }
100            sync_data[i].fd[j] = fd;
101            printf("sync_data[%d].fd[%d] = %d;\n", i, j, fd);
102
103        }
104    }
105
106    sync_data[3].thread_no = 3;
107    for (j = 0; j < 2; j++) {
108        sprintf(str, "merged_fence%d", j);
109        sync_data[3].fd[j] = sync_merge(str, sync_data[0].fd[j], sync_data[1].fd[j]);
110        if (sync_data[3].fd[j] < 0) {
111            printf("can't merge sync pts %d and %d: %s\n",
112                   sync_data[0].fd[j], sync_data[1].fd[j], strerror(errno));
113            return 1;
114        }
115    }
116
117    for (i = 0; i < 4; i++)
118        pthread_create(&threads[i], NULL, sync_thread, &sync_data[i]);
119
120
121    for (i = 0; i < 3; i++) {
122        int err;
123        printf("press enter to inc to %d\n", i+1);
124        fgets(str, sizeof(str), stdin);
125        err = sw_sync_timeline_inc(sync_timeline_fd, 1);
126        if (err < 0) {
127            perror("can't increment sync obj:");
128            return 1;
129        }
130    }
131
132    printf("press enter to close sync_timeline\n");
133    fgets(str, sizeof(str), stdin);
134
135    close(sync_timeline_fd);
136
137    printf("press enter to end test\n");
138    fgets(str, sizeof(str), stdin);
139
140    for (i = 0; i < 3; i++) {
141        void *val;
142        pthread_join(threads[i], &val);
143    }
144
145    return 0;
146}
147