silas/imdd_silas
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Merge branch 'main' of https://cau-git.rz.uni-kiel.de/nt/mitarbeiter/silas/imdd_simulation

Browse Source 
# Conflicts:
#	projects/ECOC_2025/dsp_run_id.m
#	projects/ECOC_2025/dsp_standalone.m
This commit is contained in:
Silas Labor Zizou
2025-04-16 09:21:52 +02:00
parent 943677ee40 2fcd6854ea
commit 982862d0fa
4 changed files with 140 additions and 17 deletions
Download Patch File Download Diff File Expand all files Collapse all files

68
projects/ECOC_2025/dsp_filtered_db.m Normal file
View File

@@ -0,0 +1,68 @@
% === SETTINGS ===
savePath = 'Z:\2025\ECOC Silas\ecoc_2025\';
% databasePath = '\\ntserver.tf.uni-kiel.de\scratch\sioe\ECOC_2025\';
databasePath = 'Z:\2025\ECOC Silas\';
databasePath = 'C:\Users\Silas\Documents\MATLAB\imdd_simulation\projects\ECOC_2025\';
database_name = 'ecoc2025_loops.db';
db = DBHandler("pathToDB", [databasePath, database_name],"type","sqlite");
num_occ = 30;
run_par = true;
refreshInterval = 300; % seconds
% In-memory list of currently processing run_ids
% currentlyProcessing = [];
alreadyProcessing = [];
fprintf('--- DSP WATCHDOG STARTED ---\n');
while true
try
% Query incomplete run_ids
sql_query = [
'SELECT ru.run_id ' ...
'FROM Runs ru ' ...
'LEFT JOIN Results r ON ru.run_id = r.run_id ' ...
'LEFT JOIN EqualizerParameters e ON r.eqParam_id = e.eq_id ' ...
'WHERE ru.loop_id IN ( ' ...
' SELECT loop_id FROM Runs GROUP BY loop_id HAVING COUNT(*) > 2 ' ...
') ' ...
'GROUP BY ru.run_id ' ...
'HAVING COUNT(CASE WHEN e.equalizer_structure = 1 THEN 1 END) < 5;'
];
runIdsFiltered = db.fetch(sql_query);
newRunIds = setdiff(runIdsFiltered.run_id, alreadyProcessing);
fprintf('[%s] Found %d run(s) needing processing, %d new.\n', ...
datestr(now, 'yyyy-mm-dd HH:MM:SS'), numel(runIdsFiltered.run_id), numel(newRunIds));
for i = 1:numel(newRunIds)
cur_id = newRunIds(i);
% Add to in-memory processing list
alreadyProcessing(end+1) = cur_id;
% Submit processing
try
[output, future] = submit_dsp(cur_id, databasePath, database_name, savePath, ...
"parallel", run_par, "max_occurences", num_occ);
% Add a listener for future completion (success or failure)
catch err
warning('Error processing run_id %d: %s', cur_id, err.message);
% Remove from in-memory list even on error (optional: you could leave it for retry)
alreadyProcessing(alreadyProcessing == cur_id) = [];
end
end
catch err
warning('Error in DSP queue watchdog: %s', err.message);
end
fprintf('Sleeping for %.0f seconds...\n\n', refreshInterval);
pause(refreshInterval);
end

37
projects/ECOC_2025/dsp_run_id.m
View File

@@ -12,7 +12,8 @@ arguments
options.storage_path
end
database = DBHandler("pathToDB",[options.database_path,options.database_name],"type",'mysql');
% database = DBHandler("pathToDB",[options.database_path,options.database_name],"type","sqlite");
database = DBHandler("type","mysql");
filterParams = database.tables;
filterParams.Configurations = struct('run_id', run_id);
@@ -47,6 +48,12 @@ mu_ffe3 = 0.001;
mu_dfe = 0.0004;
mu_dc = 0.00;
% mu_ffe1 = 0;
% mu_ffe2 = 0;
% mu_ffe3 = 0;
% mu_dfe =0;
% mu_dc = 0.00;
mu_ffe = [mu_ffe1 mu_ffe2 mu_ffe3];
vnle_order=[vnle_order1,vnle_order2,vnle_order3];
@@ -74,9 +81,6 @@ vnle_pf_package = {};
vnle_dfe_package = {};
dbtgt_package = {};
vnle_pf =1;
db_tgt = 0;
%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%
Tx_signal = load([options.storage_path, char(dataTable.tx_signal_path)]);
@@ -133,6 +137,8 @@ for occ = 1:record_realizations
if duob_mode ~= db_mode.db_encoded
vnle_pf = 1;
dbtgt = 0;
% %%%%% VNLE + DFE %%%%
if 0
@@ -157,7 +163,7 @@ for occ = 1:record_realizations
end
%%%%% Duobinary Targeting %%%%
if db_tgt
if dbtgt
[result] = duobinary_target(eq_, mlse_db_, M, Scpe_sig, Symbols, Tx_bits, "precode_mode", duob_mode,'showAnalysis',0,"postFFE",[]);
dbtgt_package{occ} = result;
@@ -169,19 +175,18 @@ for occ = 1:record_realizations
% fprintf("BER VNLE: %.2e | %.2e; BER MLSE: %.2e | %.2e; BER DB tgt: %.2e | %.2e \n",vnle_pf_package{occ}.resultsVNLE.BER,vnle_pf_package{occ}.resultsVNLE.BER_precoded ,vnle_pf_package{occ}.resultsMLSE.BER,vnle_pf_package{occ}.resultsMLSE.BER_precoded,dbtgt_package{occ}.resultsDBtgt.BER,dbtgt_package{occ}.resultsDBtgt.BER_precoded)
% % fprintf("BER VNLE: %.2e | %.2e; BER MLSE: %.2e | %.2e \n",vnle_pf_package{occ}.resultsVNLE.BER,vnle_pf_package{occ}.resultsVNLE.BER_precoded ,vnle_pf_package{occ}.resultsMLSE.BER,vnle_pf_package{occ}.resultsMLSE.BER_precoded);
occ = 1; % or whatever your loop index is
if vnle_pf
occ = 1; % or whatever your loop index is
% Extract VNLE results for readability
vnle = vnle_pf_package{occ}.resultsVNLE;
mlse = vnle_pf_package{occ}.resultsMLSE;
end
if db_tgt
dbtgt = dbtgt_package{occ}.resultsDBtgt;
end
% Print header
fprintf("==== EQUALIZATION RUN-ID %d | PAM-%d | %.2f GBd ====\n\n", run_id, M, Symbols.fs.*1e-9);
if vnle_pf
% Print header
fprintf("==== EQUALIZATION RUN-ID %d | PAM-%d | %.2f GBd ====\n\n", run_id, M, Symbols.fs.*1e-9);
% VNLE Results
fprintf(">> VNLE Results:\n");
fprintf(" BER %.2e\n", vnle.BER);
@@ -199,7 +204,9 @@ for occ = 1:record_realizations
fprintf(" Channel Alpha : %.2f\n", mlse.Alpha);
fprintf("\n");
end
if db_tgt
if dbtgt
dbtgt = dbtgt_package{occ}.resultsDBtgt;
% DB Target Results
fprintf(">> DB Target Results:\n");
fprintf(" BER: %.2e\n", dbtgt.BER);

6
projects/ECOC_2025/dsp_standalone.m
View File

@@ -1,9 +1,11 @@
savePath = 'Z:\2025\ECOC Silas\ecoc_2025\';
databasePath = 'C:\Users\sioe\Documents\MATLAB\imdd_simulation\projects\ECOC_2025\';
databasePath = 'C:\Users\Silas\Documents\MATLAB\imdd_simulation\projects\ECOC_2025\';
database_name = 'ecoc2025_loops.db';
% db = DBHandler("pathToDB", [databasePath, database_name],"type","sqlite");
db = DBHandler("type","mysql");
num_occ = 1;
run_par = false;
run_id = 2589;

46
projects/ECOC_2025/load_signal_standalone.m Normal file
View File

@@ -0,0 +1,46 @@
run_id = 231;
savePath = 'Z:\2025\ECOC Silas\ecoc_2025\';
databasePath = 'C:\Users\Silas\Documents\MATLAB\imdd_simulation\projects\ECOC_2025\';
database_name = 'ecoc2025_loops.db';
db = DBHandler("type","mysql");
% db = DBHandler("pathToDB", [databasePath, database_name],"type","sqlite");
filterParams = db.tables;
filterParams.Configurations = struct('run_id', run_id);
selectedFields = {'Runs.run_id','Runs.tx_bits_path','Runs.tx_signal_path','Runs.tx_symbols_path','Runs.rx_sync_path','Runs.rx_raw_path',...
'Configurations.db_mode','Configurations.pam_level','Configurations.bitrate','Configurations.symbolrate','Configurations.fiber_length','Configurations.wavelength','Configurations.precomp_amp','Measurements.power_rop','Configurations.v_bias',...
'Configurations.interference_attenuation'};
[dataTable,sql_query] = db.queryDB(filterParams, selectedFields);
[~, uniqueIdx] = unique(dataTable.run_id); % Get unique run_id indices
dataTable = dataTable(uniqueIdx,:); % Extract unique configurations for each run_id
fsym = dataTable.symbolrate;
M = double(dataTable.pam_level);
duob_mode = db_mode.(strrep(char(dataTable.db_mode),'"',''));
Tx_signal = load([savePath, char(dataTable.tx_signal_path)]);
Tx_signal = Tx_signal.Digi_sig;
Tx_bits = load([savePath, char(dataTable.tx_bits_path)]);
Tx_bits = Tx_bits.Bits;
Symbols_mapped = PAMmapper(M,0).map(Tx_bits);
Symbols_mapped.fs = dataTable.symbolrate;
Symbols = load([savePath, char(dataTable.tx_symbols_path)]);
Symbols = Symbols.Symbols;
Scpe_sig_raw = load([savePath, char(dataTable.rx_raw_path(1))]);
Scpe_sig_raw = Scpe_sig_raw.Scpe_sig_raw;
Scpe_sig_resampled = Scpe_sig_raw.resample("fs_in",Scpe_sig_raw.fs,"fs_out",2*fsym);
[~,Scpe_cell,found_sync,~,shifts] = Scpe_sig_resampled.tsynch("reference",Symbols,"fs_ref",dataTable.symbolrate,"debug_plots",1);
shifts_mus = shifts./Scpe_sig_resampled.fs .*1e6;
Scpe_sig_raw.plot("displayname",['Scope Signal (Run ID: ',num2str(run_id)],"fignum",2024,"clear",1);
hold on;
xline(shifts_mus,'HandleVisibility','off');