Mercurial > hg > Gears > Gears
view src/parallel_execution/lib/Gears/Context.pm @ 705:cf82fc3512dd
fix collect local variables
author | anatofuz <anatofuz@cr.ie.u-ryukyu.ac.jp> |
---|---|
date | Sun, 23 Aug 2020 08:54:17 +0900 |
parents | 3d959f470c8b |
children | 843a94916d8a |
line wrap: on
line source
package Gears::Context; use strict; use warnings; use Gears::Util; use Gears::Interface; use Module::Load qw/load/; use Carp qw/croak carp/; sub new { my ($class, %args) = @_; my $self = { data_gears_with_count => {}, find_root => $args{find_root} // ".", output => $args{output}, template => $args{template} // "Gears::Context::Template", }; if ($args{compile_sources}) { $self->{compile_sources} = $args{compile_sources}; map { Gears::Util->file_checking($_); } @{$self->{compile_sources}}; } return bless $self, $class; } sub extraction_dg_compile_sources { my ($self, $compile_sources) = @_; my %counter; my %include_pool = (); for my $cbc_file (@{$compile_sources}) { open my $fh , '<', $cbc_file; while (my $line = <$fh>) { if ($line =~ m|//\s*:skip|) { next; } if ($line =~ /#interface\s*"(.*)\.h"/) { push(@{$counter{interfaces}->{$1}->{$cbc_file}},$.); next; } if ($line =~ /^\/\/\s*include\s*"(.*)\.(?:h|dg)?"/) { push(@{$include_pool{$1}->{$cbc_file}},$.); next; } if ($line =~ m|//\s*Skip:\s*generate_context|) { $line = <$fh>; next; } if ($line =~ /^(\w+)\*\s*create(\w+)\(([*\w\s]+)\)/) { my $interface = $1; my $implementation = $2; my $arg = $3; if ($arg eq "") { next; } push(@{$counter{interfaces}->{$interface}->{$cbc_file}},$.); push(@{$counter{impl}->{$implementation}->{$cbc_file}},$.); next; } if ($line =~ /Gearef\(context,\s*(\w+)\)/) { my $implementation = $1; push(@{$counter{impl}->{$implementation}->{$cbc_file}},$.); next; } # ALLOCATE is generated by generate_stub.pl # because extraction_dg_compile_sources caller after translated .cbc to .c #Element* element = &ALLOCATE(cbc_context, Element)->Element; if ($line =~ /ALLOCATE\w*\((?:cbc_)?context,\s*(\w+)\)/) { my $implementation = $1; push(@{$counter{impl}->{$implementation}->{$cbc_file}},$.); next; } if ($line =~ /ALLOCATE_(?:PTR_)?ARRAY\((?:cbc_)?context,\s*(\w+),[\s\w]+\)/) { my $implementation = $1; push(@{$counter{impl}->{$implementation}->{$cbc_file}},$.); next; } if ($line =~ /new\s+(\w+?)\([\w\s]*\);/) { my $implementation = $1; push(@{$counter{impl}->{$implementation}->{$cbc_file}},$.); next; } if ($line =~ /ALLOCATE_DATA_GEAR\((\w+),\s*(\w+)\)/) { my $implementation = $2; push(@{$counter{impl}->{$implementation}->{$cbc_file}},$.); next; } #TaskManagerImpl* taskManager = (TaskManagerImpl*)GearImpl(context, TaskManager, taskManager); if ($line =~ /\((\w+)\*\)GearImpl\(context,\s*(\w+),\s*(\w+)\)/) { my $interface = $2; my $implementation = $1; push(@{$counter{impl}->{$implementation}->{$cbc_file}},$.); push(@{$counter{interfaces}->{$interface}->{$cbc_file}},$.); next; } if ($line =~ /^__code/) { while ($line =~ /struct (\w+)\s*\*/g) { next if $1 eq "Context"; next if (exists $counter{interfaces}->{$1}); push(@{$counter{impl}->{$1}->{$cbc_file}},$.); } } } close $fh; } use Data::Dumper; for my $cg_name (keys %include_pool) { my @tmp_cbc_file_names = keys %{$include_pool{$cg_name}}; my $tmp_cbc_file_name = shift @tmp_cbc_file_names; if (exists $counter{interfaces}->{$cg_name}){ push(@{$counter{interfaces}->{$cg_name}->{$tmp_cbc_file_name}},$include_pool{$cg_name}->{$tmp_cbc_file_name}); delete $include_pool{$cg_name}; next; } if (exists $counter{impl}->{$cg_name}){ push(@{$counter{impl}->{$cg_name}->{$tmp_cbc_file_name}},$include_pool{$cg_name}->{$tmp_cbc_file_name}); delete $include_pool{$cg_name}; next; } push(@{$counter{interfaces}->{$cg_name}->{$tmp_cbc_file_name}},$include_pool{$cg_name}->{$tmp_cbc_file_name}); delete $include_pool{$cg_name}; } $counter{interfaces}->{Meta}++; $counter{interfaces}->{TaskManager}++; #print "-----------\n"; #print Dumper \%counter; #this line is debug message #print "-----------\n"; return \%counter; } sub _docking_header_name_to_path { my ($root_path, $data_gears_name) = @_; my %res; map { $res{$_}++ } @$data_gears_name; my $header_paths = Gears::Util->find_headers_from_path($root_path); map { if (/(\w+)\.(?:h|dg)$/) { my $header_file = $1; if (exists $res{$header_file}) { if ($res{$header_file} =~ /^\d+$/){ $res{$header_file} = $_; } elsif (($_ =~ /\.dg$/) && ($res{$header_file} =~ /\.h$/)) { $res{$header_file} = $_; } } } } sort @$header_paths; return \%res; } sub set_data_gear_header_path { my $self = shift; my @data_gears_name; map { push (@data_gears_name,$_) if $_ ne "Context" } @_; return _docking_header_name_to_path($self->{find_root},\@data_gears_name); } sub update_dg_each_header_path { my ($self, $dgs, $dg2path) = @_; my $new_dgs; for my $kind (keys %$dgs) { for my $dg_name (keys %{$dgs->{$kind}}) { if ($dg2path->{$dg_name}) { $new_dgs->{$kind}->{$dg_name} = $dg2path->{$dg_name}; } else { croak "failed trans header $dg_name\n"; } } } for my $kind (keys %$dgs) { map { if ($new_dgs->{$kind}->{$_} =~ /^\d+$/) { carp "failed: not found $_.(h|dg)\n"; delete $new_dgs->{$kind}->{$_}; } } keys %{$new_dgs->{$kind}}; } return $new_dgs; } sub tree2create_context_h { my ($self, $dg2path) = @_; unless ($dg2path) { croak "require ast at tree2create_context_h"; } my $template = $self->{template}; load $template; my ($data_struct_str, $from_header_to_caller) = $self->tree2data_struct_str($dg2path); my $output = $self->_select_output(); $template->emit_top_header($output); if (%{$from_header_to_caller}) { $template->emit_include_header($output,$from_header_to_caller); } $template->emit_start_context($output); $template->emit_data_gears($output,$data_struct_str); $template->emit_last_header($output); close $output; } sub _select_output { my $self = shift; #print "$self->{output}\n"; if ($self->{output} eq 'stdout') { return *STDOUT; } open my $fh, '>', $self->{output}; return $fh; } # Generate a header with include file list from a structure's tree structure sub tree2data_struct_str { my ($self, $dg_str) = @_; my %from_header_to_caller; my $data_struct_str = ""; for my $interface (sort keys %$dg_str) { my $elem = $dg_str->{$interface}->{elem}; $data_struct_str .= $self->h2context_str_w_macro($elem); for my $header (_find_include_header_each_cbc($elem)) { push(@{$from_header_to_caller{$header}},$elem->{file_name}); } my $root_impl = $dg_str->{$interface}->{impl}; next unless ($root_impl); for my $impl_name (sort keys %{$root_impl}) { my $impl = $root_impl->{$impl_name}; $data_struct_str .= $self->h2context_str_w_macro($impl); for my $header (_find_include_header_each_cbc($impl)) { push(@{$from_header_to_caller{$header}},$impl->{file_name}); } } } return $data_struct_str, \%from_header_to_caller; } sub _find_include_header_each_cbc { my $ir = shift; unless (exists $ir->{cbc_context_include_headers}) { return (); } return @{$ir->{cbc_context_include_headers}}; } sub createImplTree_from_header { my ($self, $dg2path) = @_; my %dg_str = (); my $inters = $dg2path->{interfaces}; my $impls = $dg2path->{impl}; use Data::Dumper; #print Dumper $dg2path; #print Dumper $self; map { my $ir = Gears::Interface->parse($inters->{$_}); $dg_str{$_}->{elem} = $ir if $ir} keys %$inters; map { my $res = Gears::Interface->parse($impls->{$_}); if ($res) { if ($res->{isa}) { $dg_str{$res->{isa}}->{impl}->{$_} = $res; } else { $dg_str{$_}->{elem} = $res; } } } keys %$impls; return \%dg_str; } sub h2context_str_w_macro { my ($self, $h2context) = @_; my $space = ' '; my $context = "${space}//$h2context->{file_name}\n"; $context .= "#ifndef ". uc($h2context->{name}) ."_STRUCT \n"; $context .= $self->h2context_str($h2context); $context .= "#define ". uc($h2context->{name}) ."_STRUCT \n"; $context .= "#else\n"; $context .= "${space}struct $h2context->{name};\n"; $context .= "#endif\n"; return $context; } sub h2context_str { my ($self, $h2context) = @_; my $space = ' '; my $context = "${space}struct $h2context->{name} {\n"; my $content_space; my @enumCodes; my @var; for my $c (@{$h2context->{content}}) { if ($c =~ /\A\s*enum Code/) { push(@enumCodes,$c); } else { push(@var,$c); } } if (@var){ my @chars = split //, $var[0]; for my $w (@chars) { last if ($w !~ /\s/); $content_space .= $w; } } unless (defined $content_space) { $content_space = ""; } for my $c (@var) { $c =~ s/$content_space//; $context .= "${space}${space}$c"; $context .= "\n"; } for my $c (@enumCodes) { $c =~ s/$content_space//; $context .= "${space}${space}$c"; $context .= "\n"; } $context .= "${space}} $h2context->{name};\n"; return $context; } 1;