Skip to content

Commit 7ba1824

Browse files
committed
fixed transmitter receiver
1 parent aed6920 commit 7ba1824

File tree

2 files changed

+5
-6
lines changed

2 files changed

+5
-6
lines changed

src/receiver.cpp

Lines changed: 2 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -215,7 +215,7 @@ static int rcvframe(QTYPE *q){
215215
sendto(sockfd, &sendxonxoff, 1, 0, (struct sockaddr*)&cli_addr, clilen);
216216
}
217217
}
218-
else if (M.fi > -100){ //masih ada yang dibenerin
218+
else if (M.fi > -100 && M.fi < 0){ //masih ada yang dibenerin
219219
sendNAK(M.fi * -1 - 1);
220220
}
221221
else{
@@ -334,8 +334,7 @@ void *childProcess(void *threadid){
334334
sendNAK(rxq->front);
335335
}
336336
}
337-
338-
sleep(1);
337+
usleep(400000);
339338
}
340339
pthread_exit(NULL);
341340
}

src/transmitter.cpp

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -103,7 +103,7 @@ int main(int argc, char *argv[]){
103103
usleep(200000);
104104
}
105105
else{ // !xoff or NAKnum != -1
106-
if(NAKnum == -1) NAKnum = (lastacked + 1) % NAKnum;
106+
if(NAKnum == -1) NAKnum = (lastacked + 1) % RXQSIZE;
107107
mesg.msgno = NAKnum;
108108
mesg.data = cc[NAKnum % RXQSIZE];
109109
string s = convMESGBtostr(mesg);
@@ -113,9 +113,9 @@ int main(int argc, char *argv[]){
113113
c_sendto[i] = s[i];
114114
}
115115

116-
printf("Mengirim NAK ke-%d: \'%s\' \n", NAKnum, cc[NAKnum]);
116+
printf("Mengirim frame dengan no NAK %d: \'%s\' \n", NAKnum, cc[NAKnum]);
117117
sendto(sockfd, c_sendto, sizeof(c_sendto), 0, (struct sockaddr*)&serv_addr, serv_len);
118-
usleep(200000);
118+
usleep(2000000);
119119
NAKnum = -1;
120120
}
121121
}

0 commit comments

Comments
 (0)