Revert "Revert "improve plugin architecture""
[sdk/target/sdbd.git] / src / usb_linux_client.c
1 /*
2  * Copyright (c) 2011 Samsung Electronics Co., Ltd All Rights Reserved
3  *
4  * Licensed under the Apache License, Version 2.0 (the License);
5  * you may not use this file except in compliance with the License.
6  * You may obtain a copy of the License at
7  *
8  * http://www.apache.org/licenses/LICENSE-2.0
9  *
10  * Unless required by applicable law or agreed to in writing, software
11  * distributed under the License is distributed on an AS IS BASIS,
12  * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
13  * See the License for the specific language governing permissions and
14  * limitations under the License.
15  */
16
17 #include <stdio.h>
18 #include <stdlib.h>
19 #include <unistd.h>
20 #include <string.h>
21
22 #include <sys/ioctl.h>
23 #include <sys/types.h>
24 #include <dirent.h>
25 #include <errno.h>
26
27 #include "sysdeps.h"
28
29 #define   TRACE_TAG  TRACE_USB
30 #include "log.h"
31
32 #include "sdb.h"
33
34
35 struct usb_handle
36 {
37     int fd;
38     sdb_cond_t notify;
39     sdb_mutex_t lock;
40 };
41
42 static void *usb_open_thread(void *x)
43 {
44     struct usb_handle *usb = (struct usb_handle *)x;
45     int fd;
46
47     while (1) {
48         // wait until the USB device needs opening
49         sdb_mutex_lock(&usb->lock);
50         while (usb->fd != -1)
51             sdb_cond_wait(&usb->notify, &usb->lock);
52         sdb_mutex_unlock(&usb->lock);
53
54         D("[ usb_thread - opening device ]\n");
55         do {
56             /* XXX use inotify? */
57             fd = unix_open(USB_NODE_FILE, O_RDWR); /* tizen-specific */
58             if (fd < 0) {
59                 // to support older kernels
60                 //fd = unix_open("/dev/android", O_RDWR);
61                 D("[ opening %s device failed ]\n", USB_NODE_FILE);
62             }
63             if (fd < 0) {
64                 sdb_sleep_ms(1000);
65             }
66         } while (fd < 0);
67         D("[ opening device succeeded ]\n");
68
69         if (close_on_exec(fd) < 0) {
70             D("[closing fd exec failed ]\n");
71         }
72         usb->fd = fd;
73
74         D("[ usb_thread - registering device ]\n");
75         register_usb_transport(usb, 0, 1);
76     }
77
78     // never gets here
79     return 0;
80 }
81
82 // Public host/client interface
83
84 int linux_usb_write(usb_handle *h, const void *data, int len)
85 {
86     int n;
87
88     D("about to write (fd=%d, len=%d)\n", h->fd, len);
89     n = sdb_write(h->fd, data, len);
90     if(n != len) {
91         D("ERROR: fd = %d, n = %d, errno = %d\n",
92             h->fd, n, errno);
93         return -1;
94     }
95     D("[ done fd=%d ]\n", h->fd);
96     return 0;
97 }
98
99 int linux_usb_read(usb_handle *h, void *data, size_t len)
100 {
101     int n;
102
103     D("about to read (fd=%d, len=%d)\n", h->fd, len);
104     n = sdb_read(h->fd, data, len);
105     if(n != len) {
106         D("ERROR: fd = %d, n = %d, errno = %d\n",
107             h->fd, n, errno);
108         return -1;
109     }
110     D("[ done fd=%d ]\n", h->fd);
111     return 0;
112 }
113
114 void linux_usb_init()
115 {
116     usb_handle *h;
117     sdb_thread_t tid;
118 //  int fd;
119
120     h = calloc(1, sizeof(usb_handle));
121     if (h == NULL) {
122         D("failed to allocate memory of usb_handle\n");
123         return;
124     }
125
126     h->fd = -1;
127     sdb_cond_init(&h->notify, 0);
128     sdb_mutex_init(&h->lock, 0);
129
130     // Open the file /dev/android_sdb_enable to trigger
131     // the enabling of the sdb USB function in the kernel.
132     // We never touch this file again - just leave it open
133     // indefinitely so the kernel will know when we are running
134     // and when we are not.
135 #if 0 /* tizen specific */
136     fd = unix_open("/dev/android_sdb_enable", O_RDWR);
137     if (fd < 0) {
138        D("failed to open /dev/android_sdb_enable\n");
139     } else {
140         close_on_exec(fd);
141     }
142 #endif
143     D("[ usb_init - starting thread ]\n");
144     if(sdb_thread_create(&tid, usb_open_thread, h)){
145         fatal_errno("cannot create usb thread");
146     }
147 }
148
149 void linux_usb_kick(usb_handle *h)
150 {
151     D("usb_kick\n");
152     sdb_mutex_lock(&h->lock);
153     sdb_close(h->fd);
154     h->fd = -1;
155
156     // notify usb_open_thread that we are disconnected
157     sdb_cond_signal(&h->notify);
158     sdb_mutex_unlock(&h->lock);
159 }
160
161 int linux_usb_close(usb_handle *h)
162 {
163     // nothing to do here
164     return 0;
165 }
166
167 void linux_usb_cleanup()
168 {
169     // nothing to do here
170 }