Mercurial Repositories > eric / file comparison
comparison: Cooperation/Connection.py
Cooperation/Connection.py
- changeset 4331
- 711e7c35a49b
- parent 4327
- ff666d8230f7
- child 4631
- 5c1a96925da4
equal
deleted
inserted
replaced
| 4327:ff666d8230f7 | 4331:711e7c35a49b |
|---|---|
| 139 return False | 139 return False |
| 140 | 140 |
| 141 msg = QByteArray(message.encode("utf-8")) | 141 msg = QByteArray(message.encode("utf-8")) |
| 142 data = QByteArray("{0}{1}{2}{1}".format( | 142 data = QByteArray("{0}{1}{2}{1}".format( |
| 143 Connection.ProtocolMessage, SeparatorToken, msg.size()) | 143 Connection.ProtocolMessage, SeparatorToken, msg.size()) |
| 144 .encode()) + msg | 144 .encode("utf-8")) + msg |
| 145 return self.write(data) == data.size() | 145 return self.write(data) == data.size() |
| 146 | 146 |
| 147 def timerEvent(self, evt): | 147 def timerEvent(self, evt): |
| 148 """ | 148 """ |
| 149 Protected method to handle timer events. | 149 Protected method to handle timer events. |
| 266 Private slot to send a greeting message. | 266 Private slot to send a greeting message. |
| 267 """ | 267 """ |
| 268 greeting = QByteArray(self.__greetingMessage.encode("utf-8")) | 268 greeting = QByteArray(self.__greetingMessage.encode("utf-8")) |
| 269 data = QByteArray("{0}{1}{2}{1}".format( | 269 data = QByteArray("{0}{1}{2}{1}".format( |
| 270 Connection.ProtocolGreeting, SeparatorToken, greeting.size()) | 270 Connection.ProtocolGreeting, SeparatorToken, greeting.size()) |
| 271 .encode()) + greeting | 271 .encode("utf-8")) + greeting |
| 272 if self.write(data) == data.size(): | 272 if self.write(data) == data.size(): |
| 273 self.__isGreetingMessageSent = True | 273 self.__isGreetingMessageSent = True |
| 274 | 274 |
| 275 def __readDataIntoBuffer(self, maxSize=MaxBufferSize): | 275 def __readDataIntoBuffer(self, maxSize=MaxBufferSize): |
| 276 """ | 276 """ |
| 427 else: | 427 else: |
| 428 message = "<empty>" | 428 message = "<empty>" |
| 429 msg = QByteArray(message.encode("utf-8")) | 429 msg = QByteArray(message.encode("utf-8")) |
| 430 data = QByteArray("{0}{1}{2}{1}".format( | 430 data = QByteArray("{0}{1}{2}{1}".format( |
| 431 Connection.ProtocolParticipants, SeparatorToken, msg.size()) | 431 Connection.ProtocolParticipants, SeparatorToken, msg.size()) |
| 432 .encode()) + msg | 432 .encode("utf-8")) + msg |
| 433 self.write(data) | 433 self.write(data) |
| 434 | 434 |
| 435 def sendEditorCommand(self, projectHash, filename, message): | 435 def sendEditorCommand(self, projectHash, filename, message): |
| 436 """ | 436 """ |
| 437 Public method to send an editor command. | 437 Public method to send an editor command. |
| 443 """ | 443 """ |
| 444 msg = QByteArray("{0}{1}{2}{1}{3}".format( | 444 msg = QByteArray("{0}{1}{2}{1}{3}".format( |
| 445 projectHash, SeparatorToken, filename, message).encode("utf-8")) | 445 projectHash, SeparatorToken, filename, message).encode("utf-8")) |
| 446 data = QByteArray("{0}{1}{2}{1}".format( | 446 data = QByteArray("{0}{1}{2}{1}".format( |
| 447 Connection.ProtocolEditor, SeparatorToken, msg.size()) | 447 Connection.ProtocolEditor, SeparatorToken, msg.size()) |
| 448 .encode()) + msg | 448 .encode("utf-8")) + msg |
| 449 self.write(data) | 449 self.write(data) |
| 450 | 450 |
| 451 def __disconnected(self): | 451 def __disconnected(self): |
| 452 """ | 452 """ |
| 453 Private slot to handle the connection being dropped. | 453 Private slot to handle the connection being dropped. |
