1
0
Fork 0
mirror of https://github.com/vanitasvitae/Smack.git synced 2024-11-25 13:32:07 +01:00

Rename "Packet (Reader|Writer)" to just Reader or Writer

This commit is contained in:
Florian Schmaus 2018-02-09 10:26:42 +01:00
parent dfe5c5c09f
commit 6dfc20ee5e

View file

@ -647,9 +647,9 @@ public class XMPPTCPConnection extends AbstractXMPPConnection {
} }
} }
} }
// Start the packet writer. This will open an XMPP stream to the server // Start the writer thread. This will open an XMPP stream to the server
packetWriter.init(); packetWriter.init();
// Start the packet reader. The startup() method will block until we // Start the reader thread. The startup() method will block until we
// get an opening stream packet back from server // get an opening stream packet back from server
packetReader.init(); packetReader.init();
} }
@ -1009,7 +1009,7 @@ public class XMPPTCPConnection extends AbstractXMPPConnection {
public void run() { public void run() {
parsePackets(); parsePackets();
} }
}, "Smack Packet Reader (" + getConnectionCounter() + ")"); }, "Smack Reader (" + getConnectionCounter() + ")");
} }
/** /**
@ -1305,7 +1305,7 @@ public class XMPPTCPConnection extends AbstractXMPPConnection {
public void run() { public void run() {
writePackets(); writePackets();
} }
}, "Smack Packet Writer (" + getConnectionCounter() + ")"); }, "Smack Writer (" + getConnectionCounter() + ")");
} }
private boolean done() { private boolean done() {
@ -1383,7 +1383,7 @@ public class XMPPTCPConnection extends AbstractXMPPConnection {
catch (InterruptedException e) { catch (InterruptedException e) {
if (!queue.isShutdown()) { if (!queue.isShutdown()) {
// Users shouldn't try to interrupt the packet writer thread // Users shouldn't try to interrupt the packet writer thread
LOGGER.log(Level.WARNING, "Packet writer thread was interrupted. Don't do that. Use disconnect() instead.", e); LOGGER.log(Level.WARNING, "Writer thread was interrupted. Don't do that. Use disconnect() instead.", e);
} }
} }
return packet; return packet;