import java.io.IOException;
import java.net.Socket;
import java.net.UnknownHostException;
-import java.util.UUID;
import java.util.concurrent.Executors;
import java.util.concurrent.ScheduledExecutorService;
import java.util.concurrent.TimeUnit;
public static final int HEART_BEAT_INTERVAL = 1; //second
public static final int HEART_BEAT_EXPIRE = 5;
+ private static int reqId;
+
private Logger logger = SkinLogger.getSkinLogger( SocketCommunicator.class ).getLogger();
private EmulatorConfig config;
try {
- // anyway down casting
- long longReqId = UUID.randomUUID().getMostSignificantBits();
- int reqId = (int) ( longReqId >> 32 );
-
+ reqId = ( Integer.MAX_VALUE == reqId ) ? 0 : ++reqId;
+
ByteArrayOutputStream bao = new ByteArrayOutputStream();
DataOutputStream dataOutputStream = new DataOutputStream( bao );
MULTI_DEBUG_CHANNEL( qemu, maruskin_server );
+#define MAX_REQ_ID 0x7fffffff
#define RECV_BUF_SIZE 32
#define RECV_HEADER_SIZE 12
SEND_SHUTDOWN = 999,
};
+static int seq_req_id = 0;
+
static uint16_t svr_port = 0;
static int server_sock = 0;
static int client_sock = 0;
memset( sendbuf, 0, SEND_HEADER_SIZE );
- int request_id = rand();
+ int request_id = ( MAX_REQ_ID == seq_req_id ) ? 0 : ++seq_req_id;
TRACE( "== SEND skin request_id:%d, send_cmd:%d ==\n", request_id, send_cmd );
request_id = htonl( request_id );