blob: 432be8b3bb0bb01393b94c946a114992155af096
1 | #define LOG_TAG "TvClient" |
2 | #include <utils/Log.h> |
3 | #include <utils/threads.h> |
4 | #include <signal.h> |
5 | #include <binder/IServiceManager.h> |
6 | #include <binder/IMemory.h> |
7 | |
8 | #include <include/TvClient.h> |
9 | #include <include/ITvService.h> |
10 | |
11 | // client singleton for tv service binder interface |
12 | Mutex TvClient::mLock; |
13 | sp<ITvService> TvClient::mTvService; |
14 | sp<TvClient::DeathNotifier> TvClient::mDeathNotifier; |
15 | |
16 | // establish binder interface to tv service |
17 | const sp<ITvService> &TvClient::getTvService() |
18 | { |
19 | Mutex::Autolock _l(mLock); |
20 | if (mTvService.get() == 0) { |
21 | sp<IServiceManager> sm = defaultServiceManager(); |
22 | sp<IBinder> binder; |
23 | do { |
24 | binder = sm->getService(String16("aml.tvserver")); |
25 | if (binder != 0) |
26 | break; |
27 | ALOGW("TvService not published, waiting..."); |
28 | usleep(500000); // 0.5 s |
29 | } while (true); |
30 | if (mDeathNotifier == NULL) { |
31 | mDeathNotifier = new DeathNotifier(); |
32 | } |
33 | binder->linkToDeath(mDeathNotifier); |
34 | mTvService = interface_cast<ITvService>(binder); |
35 | } |
36 | ALOGE_IF(mTvService == 0, "no TvService!?"); |
37 | return mTvService; |
38 | } |
39 | |
40 | TvClient::TvClient() |
41 | { |
42 | init(); |
43 | } |
44 | |
45 | // construct a tv client from an existing tv remote |
46 | sp<TvClient> TvClient::create(const sp<ITv> &tv) |
47 | { |
48 | ALOGD("create"); |
49 | if (tv == 0) { |
50 | ALOGE("tv remote is a NULL pointer"); |
51 | return 0; |
52 | } |
53 | |
54 | sp<TvClient> c = new TvClient(); |
55 | if (tv->connect(c) == NO_ERROR) { |
56 | c->mStatus = NO_ERROR; |
57 | c->mTv = tv; |
58 | IInterface::asBinder(tv)->linkToDeath(c); |
59 | } |
60 | return c; |
61 | } |
62 | |
63 | void TvClient::init() |
64 | { |
65 | mStatus = UNKNOWN_ERROR; |
66 | } |
67 | |
68 | TvClient::~TvClient() |
69 | { |
70 | disconnect(); |
71 | } |
72 | |
73 | sp<TvClient> TvClient::connect() |
74 | { |
75 | ALOGD("Tv::connect------------------------------------------"); |
76 | sp<TvClient> c = new TvClient(); |
77 | const sp<ITvService> &cs = getTvService(); |
78 | if (cs != 0) { |
79 | c->mTv = cs->connect(c); |
80 | } |
81 | if (c->mTv != 0) { |
82 | IInterface::asBinder(c->mTv)->linkToDeath(c); |
83 | c->mStatus = NO_ERROR; |
84 | } else { |
85 | c.clear(); |
86 | } |
87 | return c; |
88 | } |
89 | |
90 | void TvClient::disconnect() |
91 | { |
92 | ALOGD("disconnect"); |
93 | if (mTv != 0) { |
94 | mTv->disconnect(); |
95 | IInterface::asBinder(mTv)->unlinkToDeath(this); |
96 | mTv = 0; |
97 | } |
98 | } |
99 | |
100 | status_t TvClient::reconnect() |
101 | { |
102 | ALOGD("reconnect"); |
103 | sp <ITv> c = mTv; |
104 | if (c == 0) return NO_INIT; |
105 | return c->connect(this); |
106 | } |
107 | |
108 | sp<ITv> TvClient::remote() |
109 | { |
110 | return mTv; |
111 | } |
112 | |
113 | status_t TvClient::lock() |
114 | { |
115 | sp <ITv> c = mTv; |
116 | if (c == 0) return NO_INIT; |
117 | return c->lock(); |
118 | } |
119 | |
120 | status_t TvClient::unlock() |
121 | { |
122 | sp <ITv> c = mTv; |
123 | if (c == 0) return NO_INIT; |
124 | return c->unlock(); |
125 | } |
126 | |
127 | status_t TvClient::processCmd(const Parcel &p, Parcel *r) |
128 | { |
129 | sp <ITv> c = mTv; |
130 | if (c == 0) return NO_INIT; |
131 | return c->processCmd(p, r); |
132 | } |
133 | |
134 | status_t TvClient::createSubtitle(const sp<IMemory> &share_mem) |
135 | { |
136 | sp <ITv> c = mTv; |
137 | if (c == 0) return NO_INIT; |
138 | return c->createSubtitle(share_mem); |
139 | } |
140 | |
141 | status_t TvClient::createVideoFrame(const sp<IMemory> &share_mem, int iSourceMode, int iCapVideoLayerOnly) |
142 | { |
143 | sp <ITv> c = mTv; |
144 | if (c == 0) return NO_INIT; |
145 | return c->createVideoFrame(share_mem, iSourceMode, iCapVideoLayerOnly); |
146 | } |
147 | |
148 | void TvClient::setListener(const sp<TvListener> &listener) |
149 | { |
150 | ALOGD("tv------------Tv::setListener"); |
151 | Mutex::Autolock _l(mLock); |
152 | mListener = listener; |
153 | } |
154 | |
155 | // callback from tv service |
156 | void TvClient::notifyCallback(int32_t msgType, const Parcel &p) |
157 | { |
158 | int size = p.dataSize(); |
159 | int pos = p.dataPosition(); |
160 | p.setDataPosition(0); |
161 | sp<TvListener> listener; |
162 | { |
163 | Mutex::Autolock _l(mLock); |
164 | listener = mListener; |
165 | } |
166 | if (listener != NULL) { |
167 | listener->notify(msgType, p); |
168 | } |
169 | } |
170 | |
171 | void TvClient::binderDied(const wp<IBinder> &who) |
172 | { |
173 | ALOGW("ITv died"); |
174 | //notifyCallback(1, 2, 0); |
175 | } |
176 | |
177 | void TvClient::DeathNotifier::binderDied(const wp<IBinder> &who) |
178 | { |
179 | ALOGW("-----------------binderDied"); |
180 | Mutex::Autolock _l(TvClient::mLock); |
181 | TvClient::mTvService.clear(); |
182 | ALOGW("kill myself"); |
183 | kill(getpid(), SIGKILL); |
184 | ALOGW("----------------Tv server died!"); |
185 | } |
186 | |
187 |