1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
|
/*
Copyright (C) 2008 Renaissance Technologies Corp.
main developer: HP Wei <hp@rentec.com>
Copyright (C) 2006 Renaissance Technologies Corp.
main developer: HP Wei <hp@rentec.com>
Copyright (C) 2005 Renaissance Technologies Corp.
Copyright (C) 2001 Renaissance Technologies Corp.
main developer: HP Wei <hp@rentec.com>
This file was modified in 2001 and later from files in the program
multicaster copyrighted by Aaron Hillegass as found at
<http://sourceforge.net/projects/multicaster/>
Copyright (C) 2000 Aaron Hillegass <aaron@classmax.com>
This program is free software; you can redistribute it and/or modify
it under the terms of the GNU General Public License as published by
the Free Software Foundation; either version 2, or (at your option)
any later version.
This program is distributed in the hope that it will be useful,
but WITHOUT ANY WARRANTY; without even the implied warranty of
MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
GNU General Public License for more details.
You should have received a copy of the GNU General Public License
along with this program; see the file COPYING.
If not, write to the Free Software Foundation,
59 Temple Place - Suite 330, Boston, MA 02111-1307, USA.
*/
#include "main.h"
/* complaint_send_socket */
int complaint_fd;
#ifndef IPV6
struct sockaddr_in complaint_addr;
#else
struct sockaddr_in6 complaint_addr;
#endif
extern int my_FLOW_PORT;
extern int verbose;
int seq = 0;
/* send buffer */
char complaint_buffer[FLOW_BUFFSIZE];
int *ccode_ptr; /* complain code ---- see main.h */
int *cmid_ptr; /* which machine*/
int *cfile_ptr; /* which file -- for missing page */
int *npage_ptr; /* # of pages -- for missing page */
int *pArray_ptr; /* missing page arrary */
int *fill_ptr; /* point to next array element */
/* ----------------------------------------------------------------
routines to fill in pArray with the missing page indexes
--------------------------------------------------------------- */
void fill_in_int(int i)
{
*fill_ptr++ = htonl(i);
}
void init_fill_ptr()
{
fill_ptr = pArray_ptr;
}
/*----------------------------------------------------------
init_complaint_sender initializes the buffer to allow the
catcher to send complaints back to the sender.
ret_address of sender to whom we will complain
is determined when we receive the first UDP data
in read_handle_page() in page_reader.c
----------------------------------------------------------*/
void init_complaint_sender() /* (struct sockaddr_in *ret_addr) */
{
/* ret_addr is sent by master, in network-byte-order */
if (verbose>=2)
fprintf(stderr, "in init_complaint_sender\n");
/* init the send_socket */
complaint_fd = complaint_socket(&complaint_addr, my_FLOW_PORT);
/* set up the pointers so we know where to put complaint_data */
ccode_ptr = (int *) complaint_buffer;
cmid_ptr = (int *)(ccode_ptr + 1);
cfile_ptr = (int *)(cmid_ptr + 1);
npage_ptr = (int *)(cfile_ptr + 1);
pArray_ptr= (int *)(npage_ptr + 1);
}
#ifndef IPV6
void update_complaint_address(struct sockaddr_in *sa)
{
sock_set_addr((struct sockaddr *) &complaint_addr,
sizeof(complaint_addr), (void*)&sa->sin_addr);
}
#else
void update_complaint_address(struct sockaddr_in6 *sa)
{
sock_set_addr((struct sockaddr *) &complaint_addr,
sizeof(complaint_addr), (void*)&sa->sin6_addr);
}
#endif
/*------------------------------------------------------------------------
send_complaint fills the complaint buffer and send it through our socket
back to the sender
The major use is to tell master machine which pages of which file
needs to be re-transmitted.
complaint -- the complain code defined in main.h
mid -- machine id
file -- the file index
npage -- # of missing pages
followed by an array of missing page index [ page_1, page_2, ... ]
It is also used for sending back acknoledgement.
complaint -- the ack code defined in main.h in the same complaint section.
mid -- machine id
file -- which file
page -- seq number (out of seq complaints will be ignored by the catcher)
------------------------------------------------------------------------*/
void send_complaint(int complaint, int mid, int page, int file)
{
/* fill in the complaint data */
/* 20060323 add converting to network byte-order before sending out */
int bytes;
*ccode_ptr = htonl(complaint);
*cmid_ptr = htonl(mid);
*cfile_ptr = htonl(file);
if (complaint==MISSING_PAGE || complaint==MISSING_TOTAL) {
*npage_ptr = htonl(page);
} else {
*npage_ptr = htonl(seq++);
}
bytes = (complaint==MISSING_PAGE) ? ((char*)fill_ptr - (char*)ccode_ptr)
: (char*)pArray_ptr - (char*)ccode_ptr;
/* send it */
if(sendto(complaint_fd, complaint_buffer, bytes, 0,
(const struct sockaddr *)&complaint_addr,
sizeof(complaint_addr)) < 0) {
perror("Sending complaint\n");
}
if (verbose>=2)
printf("Sent complaint:code=%d mid=%d page=%d file=%d bytes=%d\n",
complaint, mid, page, file, bytes);
}
|
