Advertisement
Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- int main(int argc,char** argv){
- msg r,t;
- init(HOST,PORT);
- // recv_message(&t);
- // send_message(&t);
- int file = open("primit", O_WRONLY | O_CREAT | O_TRUNC, 0644);
- printf("receiv\n");
- fflush(stdout);
- printf("receive message = %d\n",recv_message(&r));
- fflush(stdout);
- if (recv_message(&r)<0){
- perror("Receive message");
- return -1;
- }
- while(recv_message(&r) > 0){
- write(file, r.payload, sizeof(r.payload));
- printf("[%s] Got msg with payload: %s\n",argv[0],r.payload);
- sprintf(t.payload,"ACK(%s)",r.payload);
- t.len = strlen(t.payload+1);
- send_message(&t);
- }
- close(file);
- return 0;
- }
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement