diff options
Diffstat (limited to 'bitbake/lib/hashserv/server.py')
-rw-r--r-- | bitbake/lib/hashserv/server.py | 10 |
1 files changed, 5 insertions, 5 deletions
diff --git a/bitbake/lib/hashserv/server.py b/bitbake/lib/hashserv/server.py index 13b754805b..e6a3f40577 100644 --- a/bitbake/lib/hashserv/server.py +++ b/bitbake/lib/hashserv/server.py | |||
@@ -207,7 +207,7 @@ class ServerClient(bb.asyncrpc.AsyncServerConnection): | |||
207 | async def dispatch_message(self, msg): | 207 | async def dispatch_message(self, msg): |
208 | for k in self.handlers.keys(): | 208 | for k in self.handlers.keys(): |
209 | if k in msg: | 209 | if k in msg: |
210 | logger.debug('Handling %s' % k) | 210 | self.logger.debug('Handling %s' % k) |
211 | if 'stream' in k: | 211 | if 'stream' in k: |
212 | return await self.handlers[k](msg[k]) | 212 | return await self.handlers[k](msg[k]) |
213 | else: | 213 | else: |
@@ -351,7 +351,7 @@ class ServerClient(bb.asyncrpc.AsyncServerConnection): | |||
351 | break | 351 | break |
352 | 352 | ||
353 | (method, taskhash) = l.split() | 353 | (method, taskhash) = l.split() |
354 | #logger.debug('Looking up %s %s' % (method, taskhash)) | 354 | #self.logger.debug('Looking up %s %s' % (method, taskhash)) |
355 | cursor = self.db.cursor() | 355 | cursor = self.db.cursor() |
356 | try: | 356 | try: |
357 | row = self.query_equivalent(cursor, method, taskhash) | 357 | row = self.query_equivalent(cursor, method, taskhash) |
@@ -360,7 +360,7 @@ class ServerClient(bb.asyncrpc.AsyncServerConnection): | |||
360 | 360 | ||
361 | if row is not None: | 361 | if row is not None: |
362 | msg = row['unihash'] | 362 | msg = row['unihash'] |
363 | #logger.debug('Found equivalent task %s -> %s', (row['taskhash'], row['unihash'])) | 363 | #self.logger.debug('Found equivalent task %s -> %s', (row['taskhash'], row['unihash'])) |
364 | elif self.upstream_client is not None: | 364 | elif self.upstream_client is not None: |
365 | upstream = await self.upstream_client.get_unihash(method, taskhash) | 365 | upstream = await self.upstream_client.get_unihash(method, taskhash) |
366 | if upstream: | 366 | if upstream: |
@@ -480,8 +480,8 @@ class ServerClient(bb.asyncrpc.AsyncServerConnection): | |||
480 | row = self.query_equivalent(cursor, data['method'], data['taskhash']) | 480 | row = self.query_equivalent(cursor, data['method'], data['taskhash']) |
481 | 481 | ||
482 | if row['unihash'] == data['unihash']: | 482 | if row['unihash'] == data['unihash']: |
483 | logger.info('Adding taskhash equivalence for %s with unihash %s', | 483 | self.logger.info('Adding taskhash equivalence for %s with unihash %s', |
484 | data['taskhash'], row['unihash']) | 484 | data['taskhash'], row['unihash']) |
485 | 485 | ||
486 | d = {k: row[k] for k in ('taskhash', 'method', 'unihash')} | 486 | d = {k: row[k] for k in ('taskhash', 'method', 'unihash')} |
487 | 487 | ||