|
@@ -127,8 +127,6 @@ class DataXceiver extends Receiver implements Runnable {
|
|
* Read/write data from/to the DataXceiverServer.
|
|
* Read/write data from/to the DataXceiverServer.
|
|
*/
|
|
*/
|
|
public void run() {
|
|
public void run() {
|
|
- updateCurrentThreadName("Waiting for operation");
|
|
|
|
-
|
|
|
|
int opsProcessed = 0;
|
|
int opsProcessed = 0;
|
|
Op op = null;
|
|
Op op = null;
|
|
try {
|
|
try {
|
|
@@ -138,6 +136,8 @@ class DataXceiver extends Receiver implements Runnable {
|
|
// This optimistic behaviour allows the other end to reuse connections.
|
|
// This optimistic behaviour allows the other end to reuse connections.
|
|
// Setting keepalive timeout to 0 disable this behavior.
|
|
// Setting keepalive timeout to 0 disable this behavior.
|
|
do {
|
|
do {
|
|
|
|
+ updateCurrentThreadName("Waiting for operation #" + (opsProcessed + 1));
|
|
|
|
+
|
|
try {
|
|
try {
|
|
if (opsProcessed != 0) {
|
|
if (opsProcessed != 0) {
|
|
assert socketKeepaliveTimeout > 0;
|
|
assert socketKeepaliveTimeout > 0;
|