Processes clients\' requests in sequential order.
(self)
| 112 | self.send(sock, item[4]) |
| 113 | |
| 114 | def processor(self): |
| 115 | 'Processes clients\' requests in sequential order.' |
| 116 | while True: |
| 117 | item = self.queue.get() |
| 118 | name, args, kwargs, sync = item |
| 119 | try: |
| 120 | item.append(self.services[name](*args, **kwargs)) |
| 121 | except: |
| 122 | item.append(None) |
| 123 | sync.sync() |
| 124 | |
| 125 | ################################################################################ |
| 126 |