Context Navigation

matperfServer.asv

Last change on this file was 951, checked in by chunter, 16 years ago
adding matperf
Property svn:executable set to ``*
File size: 27.0 KB

Line
1	function [report servrep report_port] = matperfServer
2	%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%
3	% usage: matperfServer
4	%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%
5	% initialize all variables
6	servrep = 0;
7	report = 0;
8	report_port = 0;
9	yes = 1; t1 = []; t2 = []; b1 = []; b2 = [];
10	j1 = []; j2 = []; l1 = []; l2 = []; tp1= [];
11	t3 = []; t4 = []; b3 = []; b4 = []; j3 = [];
12	j4 = []; l3 = []; l4 = []; tp3= []; oisup = 0;
13	ti = []; ti2 = [];
14	req_band = []; leng = []; times = [];
15	reqports = []; repnum = 0; portadd = 0;
16	numexp = 1; data_old = 0;
17	windows = [];
18	%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%
19	disp('%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%');
20	disp('server quits when matperfClient_complete with specific address is called');
21	disp('%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%');
22
23	%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%
24	% This is the server that receives signals from the client and execute
25	% the commands client demands. Different from the client, server will
26	% execute the commands and parse and collect the outputs into vectors and
27	% structs.
28	%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%
29
30
31	%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%
32	% To check if this program is running properly, check the struct values
33	% with the iperf results recorded in checkresult.txt
34	%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%
35	udp = pnet('udpsocket', 3333);
36	while 1,
37	pnet(udp,'setreadtimeout',15);
38	len = pnet(udp,'readpacket');
39	[ip] = pnet(udp,'gethost'); % receives the address of the responded client
40	address = strcat(num2str(ip(1)),{'.'},num2str(ip(2)),{'.'},num2str(ip(3)),{'.'},num2str(ip(4)));
41	if len > 0,
42	data = pnet(udp,'read',1000,'double');
43	%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%
44	% mode 1 -> single
45	% mode 2 -> double
46	% mode 3 -> tradeoff
47	% UdpTcp = 1 ->> UDP
48	% UdpTcp = 2 ->> TCP
49	% experiment request => 0
50	% trial request => 1
51	% asking success/failure => 4
52	% asking to parse & collect the data => 6
53	% complete exp => 7
54	%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%
55
56	%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%
57	% when the server receives 0, it should also have received %
58	% information of whether the client is UDP or TCP and %
59	% its mode. %
60	% [req; UDP/TCP ; mode] <- do not change during the exp. %
61	%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%
62
63	%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%
64	% when the server receives 1, it also receives length, bandwidth, %
65	% window size, port# the client wants to access on server and %
66	% prepare the iperf command line that will be executed. Then it %
67	% executes the command and send the client a signal that allows the
68	% client to execute its iperf command. %
69	%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%
70
71	if data(1) == 0,
72	data_old = data;
73	disp('experiment request submitted');
74	clear_set; % delete all the temporary files being used in previous trial.
75	req = 0;
76	UdpTcp = data(2);
77	mode = data(3);
78	pnet(udp,'write',req);
79	pnet(udp,'setwritetimeout',1);
80	pnet(udp,'writepacket',char(address),3333); % this sends to client that server recognized the client
81	oisup = 1;
82	continue;
83	elseif data(1) ==1,
84	if oisup == 0,
85	disp('experiment not initialized');
86	return
87	end
88	clear_set
89	data_old = data(1);
90
91	%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%
92	% WARNING: only one iperf should run during the test %
93	%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%
94	pac = data;
95	if pac(2) == 1 %if UDP,
96	length = pac(3); % these pac variables are from the received packet from the client
97	reqband = pac(4);
98	timeb = pac(5);
99	reqport = pac(6);
100	systemcall = 'iperf -s -u -P 1 -f B -f b';
101	systemcall = strcat(systemcall,{' -p '},num2str(reqport),{' > tempo_result.txt &'});
102	elseif pac(2) ==2, % if TCP,
103	window = pac(3);
104	timeb = pac(4);
105	reqport = pac(5);
106	systemcall = 'iperf -s -P 1 -f B -f b';
107	systemcall = strcat(systemcall,{' -p '},num2str(reqport),{' > tempo_result.txt &'});
108	end
109
110	%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%
111	% based on received data, above two if statements build a
112	% command line to be used to call iperf
113	%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%
114	system('ps -a > jobs_l');
115	system('python weird');
116	jobs_l = load('check_jobs');
117	if jobs_l == 1,
118	system('killall iperf');
119	end
120	disp('trial request submitted');
121
122	% call iperf
123	system(char(systemcall));
124
125	pnet(udp,'write',1);
126	pnet(udp,'setwritetimeout',.5);
127	pnet(udp,'writepacket',char(address),3333); % server tells client to begin the iperf trial
128	continue
129	elseif data == 5
130	%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%
131	% when the server receives 5, matlab begins to check the iperf
132	% results written on the specified file. In our case it
133	% is tempo_reult.txt. First matlab uses python to call pint.txt.
134	% pint.txt is a python script that gets rid of all unnecessary
135	% lines in the iperf output s othat all the outputs have the same
136	% structures.
137	%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%
138	if oisup == 0,
139	disp('experiment not initialized');
140	return
141	end
142	data_old = data;
143	system('python pint.txt');
144
145	%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%
146	% below serverudpsingle/dual/tradeoff are the scripts that
147	% parse the output to the vectors saved into different files so
148	% that matlab can call each of them in order to use them as
149	% variables.
150	%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%
151	if mode == 1,
152	if UdpTcp == 1,
153	system('python serverudpsingle');
154	elseif UdpTcp == 2,
155	system('python servertcpsingle');
156	end
157	elseif mode ==2,
158	if UdpTcp == 1,
159	system('python serverudpdual');
160	elseif UdpTcp ==2,
161	system('python servertcpdual');
162	end
163	elseif mode == 3,
164	if UdpTcp == 1,
165	system('python serverudptradeoff');
166	end
167	end
168
169	%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%
170	% below script lines will load the results saved in separate
171	% files into matlab workspace. They will also check if the
172	% server got stuck or not by checking whether there were
173	% outputs or not. If the server gets stuck, there are no lines
174	% to parse and save into files. So If files don't exist, that
175	% means there are no outputs and also means the server was
176	% stuck. If the matlab determines that server is stuck, then it
177	% will kill the running iperf and send client 3, which means
178	% the trial failed and client has to execute the same command again.
179	% But if those lines successively parse and save them into
180	% separate files then it will send client 2, which means the
181	% trial has succeeded.
182	%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%
183	if exist('repnum.txt','file') == 2 && exist('portadd.txt','file') == 2,
184	temp_repnum = textread('repnum.txt','%s') ;
185	temp_portadd = textread('portadd.txt','%s');
186	sf = 2;
187	if mode == 2,
188	if exist('dual_repnum.txt','file') ==2 && exist('dual_portadd.txt','file') == 2,
189	tempd_repnum = textread('dual_repnum.txt','%s');
190	tempd_portadd = textread('dual_portadd.txt','%s');
191	else
192	disp('server stuck')
193	system('killall iperf'); % kills iperf
194	sf = 3; %fail
195	end
196	elseif mode == 3,
197	if exist('tradeoff_repnum.txt','file') ==2 && exist('tradeoff_portadd.txt','file') == 2,
198	t_repnum = textread('tradeoff_repnum.txt','%s');
199	t_portadd = textread('tradeoff_portadd.txt','%s');
200	else
201	disp('server stuck')
202	system('killall iperf'); %klls iperf
203	sf = 3; %fail
204	end
205	end
206	else
207	disp('server stuck');
208	system('killall iperf');
209	sf = 3; %fail
210	end
211	clear_set;
212	pnet(udp,'write',sf); %success
213	pnet(udp,'setwritetimeout',1);
214	pnet(udp,'writepacket',char(address),3333); % server tells client whether trial succeeded or failed
215	continue;
216
217	elseif data == 6,
218	%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%
219	% below if statement prevents the results are presented twice
220	% at the same time. data_old is the copied version of data and
221	% if signal 6 is sent twice at the same time, server jumps back
222	% to the start.
223	%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%
224	if data_old == data,
225	pnet(udp,'write',yes);
226	pnet(udp,'setwritetimeout',2);
227	pnet(udp,'writepacket',char(address),3333);
228	continue;
229	end
230	if mode == 2,
231	%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%
232	% first, portadd, the vector that carries information about
233	% the port numbers has been examined. It checks if that
234	% line tells whether server connected to client back or
235	% client connected to server. Then portadd becomes the
236	% vector consist of line that contains the data of client
237	% connected to server, and d_portadd becomes the vector that
238	% consist of line that contains the data of server
239	% connected to client.
240	%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%
241	porter = cell2mat(temp_portadd(7));
242
243	if num2str(reqport) == porter,
244	portadd = temp_portadd;
245	d_portadd = tempd_portadd;
246	else
247	portadd = tempd_portadd;
248	d_portadd = temp_portadd;
249	end
250	%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%
251	% these below liines are to check if the results are sorted
252	% correctly or not. I checked if the results are correctly
253	% sorted by checking the ID in every lines. For example [3]
254	% is sorted with all [3] lines and [142] lines are all
255	% sorted with [142].
256	%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%
257
258	numer = cell2mat(portadd(2));
259	if numer == cell2mat(temp_repnum(2)),
260	repnum = temp_repnum;
261	d_repnum = tempd_repnum;
262	else
263	repnum = tempd_repnum;
264	d_repnum = temp_repnum;
265	end
266
267	elseif mode == 3,
268	repnum = temp_repnum;
269	portadd = temp_portadd;
270
271	elseif mode == 1,
272	repnum = temp_repnum;
273	portadd = temp_portadd;
274	end
275
276	%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%
277	% repnum contains info about the jitter, totalpacket,loss, etc.
278	% and portadd contains info about the port and address of
279	% client and server. d_repnum and d_portadd contain info of the
280	% client's server report.
281	%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%
282
283
284
285	%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%
286	% These are the algorithms that create the struct that will be
287	% shown as a result. First, I loaded a file that contains
288	% information about the bandwidth, jitter, lost,
289	% totalpackets, and port numbers of client and server into work
290	% space. Then, I just picked up a number from that vector by
291	% giving a matlab a location of those necessary values. number
292	% in below box is the row # of the vectors that contain the
293	% answers i need.
294	%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%
295	if UdpTcp == 1
296	%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%
297	% for UDP results
298	% j ==> Transfer => 7; Bandwidth => 9; Jitter => 12;
299	% Lost => 14; Total => 15; time => 5;
300	% k ==> s.add => 5 s.port => 7 c.add => 10 c.port => 12
301	%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%
302	for i = 1: size(repnum)
303	% change rem(i,j) j to the # of lines of one report.
304	j = rem(i,18);
305	if (j == 5)
306	Ti = str2double(cell2mat(repnum(i)));
307	ti = [ti;Ti];
308	elseif (j == 7)
309	T1 = str2double(cell2mat(repnum(i)));
310	%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%
311	% conversion.m
312	% this conversion function changes the size of the
313	% values for example from Bytes to GBytes or
314	% KBytes. inputs are what size you want, the value,
315	% and the current size.
316	% e.g. conversion('Bytes',T1,'KBytes')
317	% first one is what size you want, second one is
318	% the value, and the third one is the current size.
319	%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%
320	T1 = conversion('Bytes',T1,repnum(i+1));
321	% it creates saves the value as vectors.
322	t1 = [t1;T1];
323	elseif (j == 9)
324	B1 = str2double(cell2mat(repnum(i)));
325	B1 = conversion('bits',B1,repnum(i+1));
326	b1 = [b1;B1];
327	elseif (j == 12)
328	J1 = str2double(cell2mat(repnum(i)));
329	j1 = [j1;J1];
330	elseif (j == 14)
331	L1 = str2double(cell2mat(repnum(i)));
332	l1 = [l1;L1];
333	elseif (j == 15)
334	TP1 = str2double(cell2mat(repnum(i)));
335	tp1 = [tp1; TP1];
336	end
337	end
338	for k = 1:size(portadd)
339	% change rem(k,l) l to the # of lines of one report.
340	l = rem(k,12);
341	if (l == 5)
342	T2 = (cell2mat(portadd(k)));
343	t2 = [t2; T2];
344	elseif (l == 7)
345	B2 = (cell2mat(portadd(k)));
346	b2 = [b2;B2];
347	elseif (l == 10)
348	J2 = (cell2mat(portadd(k)));
349	j2 = [j2; J2];
350	elseif (l == 0)
351	L2 = (cell2mat(portadd(k)));
352	l2 = [l2; L2];
353	end
354	end
355	if(mode == 2)
356	for i1 = 1: size(d_repnum)
357	% change rem(i,j) j to the # of lines of one report.
358	j = rem(i1,18);
359	if (j == 5)
360	Ti2 = str2double(cell2mat(d_repnum(i1)));
361	ti2 = [ti2;Ti2];
362	elseif (j == 7)
363	T3 = str2double(cell2mat(d_repnum(i1)));
364	T3 = conversion('Bytes',T3,d_repnum(i1+1));
365	t3 = [t3;T3];
366	elseif (j == 9)
367	B3 = str2double(cell2mat(d_repnum(i1)));
368	B3 = conversion('bits',B3,d_repnum(i1+1));
369	b3 = [b3;B3];
370	elseif (j == 12)
371	J3 = str2double(cell2mat(d_repnum(i1)));
372	j3 = [j3;J3];
373	elseif (j == 14)
374	L3 = str2double(cell2mat(d_repnum(i1)));
375	l3 = [l3;L3];
376	elseif (j == 15)
377	TP3 = str2double(cell2mat(d_repnum(i1)));
378	tp3 = [tp3; TP3];
379	end
380	end
381
382	for k1 = 1:size(d_portadd)
383	% change rem(k,l) l to the # of lines of one report.
384	l = rem(k1,12);
385	if (l == 5)
386	T4 = (cell2mat(d_portadd(k1)));
387	t4 = [t4; T4];
388	elseif (l == 7)
389	B4 = (cell2mat(d_portadd(k1)));
390	b4 = [b4;B4];
391	elseif (l == 10)
392	J4 = (cell2mat(d_portadd(k1)));
393	j4 = [j4; J4];
394	elseif (l == 0)
395	L4 = (cell2mat(d_portadd(k1)));
396	l4 = [l4; L4];
397	end
398	end
399	elseif mode == 3,
400	for i1 = 1: size(t_repnum)
401	% change rem(i,j) j to the # of lines of one report.
402	j = rem(i1,18);
403	if (j == 5)
404	Ti2 = str2double(cell2mat(t_repnum(i1)));
405	ti2 = [ti2;Ti2];
406	elseif (j == 7)
407	T3 = str2double(cell2mat(t_repnum(i1)));
408	T3 = conversion('Bytes',T3,t_repnum(i1+1));
409	t3 = [t3;T3];
410	elseif (j == 9)
411	B3 = str2double(cell2mat(t_repnum(i1)));
412	B3 = conversion('bits',B3,t_repnum(i1+1));
413	b3 = [b3;B3];
414	elseif (j == 12)
415	J3 = str2double(cell2mat(t_repnum(i1)));
416	j3 = [j3;J3];
417	elseif (j == 14)
418	L3 = str2double(cell2mat(t_repnum(i1)));
419	l3 = [l3;L3];
420	elseif (j == 15)
421	TP3 = str2double(cell2mat(t_repnum(i1)));
422	tp3 = [tp3; TP3];
423	end
424	end
425
426	for k1 = 1:size(t_portadd)
427	% change rem(k,l) l to the # of lines of one report.
428	l = rem(k1,12);
429	if (l == 5)
430	T4 = (cell2mat(t_portadd(k1)));
431	t4 = [t4; T4];
432	elseif (l == 7)
433	B4 = (cell2mat(t_portadd(k1)));
434	b4 = [b4;B4];
435	elseif (l == 10)
436	J4 = (cell2mat(t_portadd(k1)));
437	j4 = [j4; J4];
438	elseif (l == 0)
439	L4 = (cell2mat(t_portadd(k1)));
440	l4 = [l4; L4];
441	end
442	end
443
444	end
445	leng = [leng; length];
446	req_band = [req_band;reqband];
447
448	elseif UdpTcp == 2,
449	%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%
450	% for TCP results:
451	% j ==> Throughput = 7; Bandwidth = 9; Jitter = 12;
452	% Lost = 14; Total 15; time => 5;
453	% k ==> s.add 5 s.port 7 c.add 10 c.port 12
454	%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%
455	for i = 1: size(repnum)
456	% change rem(i,j) j to the # of lines of one report.
457	j = rem(i,11);
458	if (j == 5)
459	Ti = str2double(cell2mat(repnum(i)));
460	ti = [ti;Ti];
461	elseif (j == 7)
462	T1 = str2double(cell2mat(repnum(i)));
463	T1 = conversion('Bytes',T1,repnum(i+1));
464	t1 = [t1;T1];
465	elseif (j == 9)
466	B1 = str2double(cell2mat(repnum(i)));
467	B1 = conversion('bits',B1,repnum(i+1));
468	b1 = [b1;B1];
469	end
470	end
471	for k = 1:size(portadd)
472	% change rem(k,l) l to the # of lines of one report.
473	l = rem(k,12);
474	if (l == 5)
475	T2 = (cell2mat(portadd(k)));
476	t2 = [t2; T2];
477	elseif (l == 7)
478	B2 = (cell2mat(portadd(k)));
479	b2 = [b2;B2];
480	elseif (l == 10)
481	J2 = (cell2mat(portadd(k)));
482	j2 = [j2; J2];
483	elseif (l == 0)
484	L2 = (cell2mat(portadd(k)));
485	l2 = [l2; L2];
486	end
487	end
488	if mode == 2,
489	for i1 = 1: size(d_repnum)
490	% change rem(i,j) j to the # of lines of one report.
491	j = rem(i1,11);
492	if (j == 5)
493	Ti2 = str2double(cell2mat(d_repnum(i1)));
494	ti2 = [ti2;Ti2];
495	elseif (j == 7)
496	T3 = str2double(cell2mat(d_repnum(i1)));
497	T3 = conversion('Bytes',T3,d_repnum(i1+1));
498	t3 = [t3;T3];
499	elseif (j == 9)
500	B3 = str2double(cell2mat(d_repnum(i1)));
501	B3 = conversion('bits',B3,d_repnum(i1+1));
502	b3 = [b3;B3];
503	end
504	end
505
506	for k1 = 1:size(d_portadd)
507	% change rem(k,l) l to the # of lines of one report.
508	l = rem(k1,12);
509	if (l == 5)
510	T4 = (cell2mat(d_portadd(k1)));
511	t4 = [t4; T4];
512	elseif (l == 7)
513	B4 = (cell2mat(d_portadd(k1)));
514	b4 = [b4;B4];
515	elseif (l == 10)
516	J4 = (cell2mat(d_portadd(k1)));
517	j4 = [j4; J4];
518	elseif (l == 0)
519	L4 = (cell2mat(d_portadd(k1)));
520	l4 = [l4; L4];
521	end
522	end
523
524	end
525	% requested window size
526	windows = [windows;window];
527
528	end
529	% create and save the requested time & port values as vectors
530	times = [times;timeb];
531	reqports = [reqports; reqport];
532	%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%
533	% based on the created vectors, below command lines create
534	% structs that will be out as results.
535	% report carries information from the server report. Servrep
536	% carries info from the client server report when dualtest or
537	% tradeoff test was ran. report_port carries the used port
538	% numbers of client and server.
539	%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%
540	if UdpTcp == 1,
541	report = struct('Transfer',t1','length',leng','req_bandwidth',req_band','bandwidth',b1','jitter',j1','losses',l1','totalpackets',tp1','requested_time_int',times','actual_time_int',ti','used_ports',reqports');
542	if mode == 2 \|\| mode == 3,
543	servrep = struct('Transfer',t3','length',leng','req_bandwidth',req_band','bandwidth',b3','jitter',j3','losses',l3','totalpackets', tp3','requested_time_int',times','actual_time_int',ti2','used_ports',reqports');
544	end
545	elseif UdpTcp == 2,
546	report = struct('Transfer',t1','bandwidth',b1','window',windows','requested_time_int',times','actual_time_int',ti','used_ports',reqports');
547	if mode == 2 \|\| mode == 3,
548	servrep = struct('Transfer',t3','bandwidth',b3,'window',windows','requested_time_int',times','actual_time_int',ti2','used_ports',reqports');
549	end
550	end
551	report_port = struct('s_address',t2,'s_port',b2,'c_address',j2,'c_port',l2);
552	pnet(udp,'write',yes);
553	pnet(udp,'writepacket',char(address),3333);
554	nmep = sprintf('%d trial is done',numexp);
555	disp(nmep);
556	numexp = numexp + 1;
557	data_old = data;
558	save temp_matperf_data
559	continue
560	elseif data == 7,
561	%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%
562	% when 7 is received from client, the server returns the result
563	% to the matlab.
564	%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%
565	disp('experiment done');
566	return
567	else
568	disp('no such code');
569	continue
570	end
571
572	else
573	% give server time to prepare
574	pnet('closeall');
575	udp = pnet('udpsocket',3333);
576	continue;
577	end
578	end
579
580	pnet('closeall');
581
582	return

Note: See TracBrowser for help on using the repository browser.

Download in other formats:

Original Format