자바 UDP 채팅에서 자꾸 타이머가 속을 썩히네요...
타이머 구현 부분(전역)
final int TIMEOUT = 5000;
boolean timer_set=false;
Timer timer=new Timer();
Time_count time_count;
class Time_count extends TimerTask{
MulticastSocket socket;
DatagramPacket packet;
public Time_count(MulticastSocket s, DatagramPacket dp){
socket=s;
packet=dp;
}
public void run(){
byte temp=send_window_first;
while(temp!=(byte)((int)send_window_now+1)%window_size){
try{
packet = new DatagramPacket(buffer[temp],DATA_FRAME_LENGTH,chatgroup,port);
socket.send(packet);
temp=(byte)(((int)temp+1)%window_size);
}catch(Exception e){
e.printStackTrace();
System.exit(1);
}
}
}
}
멀티캐스트 상에서 go-back-N ARQ를 이용하여
신뢰성 있는 채팅을 구현하는데 송신 측에서
프레임을 송신하고 타이머를 작동시킵니다.
s.send(dp); //송신하고
if(timer_set==false){//타이머가 없을시 작동
time_count=new Time_count(s,dp);
timer.schedule(time_count, TIMEOUT);
timer_set=true;
}//버퍼에 재전송 시를 위하여 전송된 데이터를 저장함
System.arraycopy(send_frame, 0, buffer[send_window_now], 0, buffer[send_window_now].length);
if(send_window_now==send_window_last){
sleep(TIMEOUT);
}
else{
send_window_now=(byte)(((int)send_window_now+1)%window_size);
}
수신 측에서 에크를 전송하면
//에크를 받을 경우
int shift=0;
while(send_window_first!=buff[ACK_NO]){
send_window_first=(byte)(((int)send_window_first+1)%window_size);
shift++;
}
send_window_last=(byte)(((int)send_window_last+shift)%window_size);
send_window_now=send_window_first;
time_count.cancel();
timer_set=false;
continue;
time_count.cancel(); 이구문에서 자꾸 죽네요 ...
문법적 에러인지 흐름 상 에러인지 감이 안오는데 아마 문법적인 부분인 것 같은데 타이머는 어떻게 사용해야 되나요 ㅜㅜ
댓글 달기