New input parallel_info for masterparallel
parent
e1b64eae1d
commit
cb5fcdef10
|
@ -101,7 +101,7 @@ if isnumeric(options_.parallel),
|
||||||
UDIAG = fout.UDIAG;
|
UDIAG = fout.UDIAG;
|
||||||
clear fout
|
clear fout
|
||||||
else
|
else
|
||||||
[fout, nBlockPerCPU, totCPU] = masterParallel(options_.parallel, 1, npar,{},'McMCDiagnostics_core', localVars);
|
[fout, nBlockPerCPU, totCPU] = masterParallel(options_.parallel, 1, npar,{},'McMCDiagnostics_core', localVars, [], options_.parallel_info);
|
||||||
UDIAG = fout(1).UDIAG;
|
UDIAG = fout(1).UDIAG;
|
||||||
for j=2:totCPU,
|
for j=2:totCPU,
|
||||||
UDIAG = cat(3,UDIAG ,fout(j).UDIAG);
|
UDIAG = cat(3,UDIAG ,fout(j).UDIAG);
|
||||||
|
|
|
@ -94,7 +94,7 @@ else
|
||||||
% from where to get back results
|
% from where to get back results
|
||||||
% NamFileOutput(1,:) = {[M_.dname,'/metropolis/'],'*.*'};
|
% NamFileOutput(1,:) = {[M_.dname,'/metropolis/'],'*.*'};
|
||||||
|
|
||||||
[fout, nBlockPerCPU, totCPU] = masterParallel(options_.parallel, fblck, nblck,NamFileInput,'random_walk_metropolis_hastings_core', localVars, globalVars);
|
[fout, nBlockPerCPU, totCPU] = masterParallel(options_.parallel, fblck, nblck,NamFileInput,'random_walk_metropolis_hastings_core', localVars, globalVars, options_.parallel_info);
|
||||||
for j=1:totCPU,
|
for j=1:totCPU,
|
||||||
offset = sum(nBlockPerCPU(1:j-1))+fblck-1;
|
offset = sum(nBlockPerCPU(1:j-1))+fblck-1;
|
||||||
record.LastLogLiK(offset+1:sum(nBlockPerCPU(1:j)))=fout(j).record.LastLogLiK(offset+1:sum(nBlockPerCPU(1:j)));
|
record.LastLogLiK(offset+1:sum(nBlockPerCPU(1:j)))=fout(j).record.LastLogLiK(offset+1:sum(nBlockPerCPU(1:j)));
|
||||||
|
|
Loading…
Reference in New Issue