diff options
Diffstat (limited to 'bitbake/lib/bb/server/xmlrpc.py')
-rw-r--r-- | bitbake/lib/bb/server/xmlrpc.py | 45 |
1 files changed, 0 insertions, 45 deletions
diff --git a/bitbake/lib/bb/server/xmlrpc.py b/bitbake/lib/bb/server/xmlrpc.py index a28672c447..8326623520 100644 --- a/bitbake/lib/bb/server/xmlrpc.py +++ b/bitbake/lib/bb/server/xmlrpc.py | |||
@@ -169,51 +169,6 @@ class BitBakeXMLRPCRequestHandler(SimpleXMLRPCRequestHandler): | |||
169 | self.end_headers() | 169 | self.end_headers() |
170 | self.wfile.write(response) | 170 | self.wfile.write(response) |
171 | 171 | ||
172 | class BitBakeUIEventServer(threading.Thread): | ||
173 | class EventAdapter(): | ||
174 | """ | ||
175 | Adapter to wrap our event queue since the caller (bb.event) expects to | ||
176 | call a send() method, but our actual queue only has put() | ||
177 | """ | ||
178 | def __init__(self, notify): | ||
179 | self.queue = [] | ||
180 | self.notify = notify | ||
181 | self.qlock = threading.Lock() | ||
182 | |||
183 | def send(self, event): | ||
184 | self.qlock.acquire() | ||
185 | self.queue.append(event) | ||
186 | self.qlock.release() | ||
187 | self.notify.set() | ||
188 | |||
189 | def get(self): | ||
190 | self.qlock.acquire() | ||
191 | if len(self.queue) == 0: | ||
192 | self.qlock.release() | ||
193 | return None | ||
194 | e = self.queue.pop(0) | ||
195 | if len(self.queue) == 0: | ||
196 | self.notify.clear() | ||
197 | self.qlock.release() | ||
198 | return e | ||
199 | |||
200 | def __init__(self, connection): | ||
201 | self.connection = connection | ||
202 | self.notify = threading.Event() | ||
203 | self.event = BitBakeUIEventServer.EventAdapter(self.notify) | ||
204 | self.quit = False | ||
205 | threading.Thread.__init__(self) | ||
206 | |||
207 | def terminateServer(self): | ||
208 | self.quit = True | ||
209 | |||
210 | def run(self): | ||
211 | while not self.quit: | ||
212 | self.notify.wait(0.1) | ||
213 | evt = self.event.get() | ||
214 | if evt: | ||
215 | self.connection.event.sendpickle(pickle.dumps(evt)) | ||
216 | |||
217 | 172 | ||
218 | class XMLRPCProxyServer(BaseImplServer): | 173 | class XMLRPCProxyServer(BaseImplServer): |
219 | """ not a real working server, but a stub for a proxy server connection | 174 | """ not a real working server, but a stub for a proxy server connection |