diff options
Diffstat (limited to 'bitbake/lib/prserv/serv.py')
| -rw-r--r-- | bitbake/lib/prserv/serv.py | 12 |
1 files changed, 6 insertions, 6 deletions
diff --git a/bitbake/lib/prserv/serv.py b/bitbake/lib/prserv/serv.py index 6be78c82fb..dfcbd2058f 100644 --- a/bitbake/lib/prserv/serv.py +++ b/bitbake/lib/prserv/serv.py | |||
| @@ -78,7 +78,7 @@ class PRServer(SimpleXMLRPCServer): | |||
| 78 | 78 | ||
| 79 | bb.utils.set_process_name("PRServ Handler") | 79 | bb.utils.set_process_name("PRServ Handler") |
| 80 | 80 | ||
| 81 | while not self.quit: | 81 | while not self.quitflag: |
| 82 | try: | 82 | try: |
| 83 | (request, client_address) = self.requestqueue.get(True, 30) | 83 | (request, client_address) = self.requestqueue.get(True, 30) |
| 84 | except queue.Empty: | 84 | except queue.Empty: |
| @@ -142,7 +142,7 @@ class PRServer(SimpleXMLRPCServer): | |||
| 142 | return self.table.importone(version, pkgarch, checksum, value) | 142 | return self.table.importone(version, pkgarch, checksum, value) |
| 143 | 143 | ||
| 144 | def ping(self): | 144 | def ping(self): |
| 145 | return not self.quit | 145 | return not self.quitflag |
| 146 | 146 | ||
| 147 | def getinfo(self): | 147 | def getinfo(self): |
| 148 | return (self.host, self.port) | 148 | return (self.host, self.port) |
| @@ -158,13 +158,13 @@ class PRServer(SimpleXMLRPCServer): | |||
| 158 | return None | 158 | return None |
| 159 | 159 | ||
| 160 | def quit(self): | 160 | def quit(self): |
| 161 | self.quit=True | 161 | self.quitflag=True |
| 162 | os.write(self.quitpipeout, b"q") | 162 | os.write(self.quitpipeout, b"q") |
| 163 | os.close(self.quitpipeout) | 163 | os.close(self.quitpipeout) |
| 164 | return | 164 | return |
| 165 | 165 | ||
| 166 | def work_forever(self,): | 166 | def work_forever(self,): |
| 167 | self.quit = False | 167 | self.quitflag = False |
| 168 | # This timeout applies to the poll in TCPServer, we need the select | 168 | # This timeout applies to the poll in TCPServer, we need the select |
| 169 | # below to wake on our quit pipe closing. We only ever call into handle_request | 169 | # below to wake on our quit pipe closing. We only ever call into handle_request |
| 170 | # if there is data there. | 170 | # if there is data there. |
| @@ -180,9 +180,9 @@ class PRServer(SimpleXMLRPCServer): | |||
| 180 | (self.dbfile, self.host, self.port, str(os.getpid()))) | 180 | (self.dbfile, self.host, self.port, str(os.getpid()))) |
| 181 | 181 | ||
| 182 | self.handlerthread.start() | 182 | self.handlerthread.start() |
| 183 | while not self.quit: | 183 | while not self.quitflag: |
| 184 | ready = select.select([self.fileno(), self.quitpipein], [], [], 30) | 184 | ready = select.select([self.fileno(), self.quitpipein], [], [], 30) |
| 185 | if self.quit: | 185 | if self.quitflag: |
| 186 | break | 186 | break |
| 187 | if self.fileno() in ready[0]: | 187 | if self.fileno() in ready[0]: |
| 188 | self.handle_request() | 188 | self.handle_request() |
