|
589 | 589 | for node in nodes_dict: |
590 | 590 | containername,sourcecode = nodes_dict[node].split(':') |
591 | 591 | if len(sourcecode)!=0 and sourcecode.find(".")!=-1: #3/28/21 |
592 | | - dockername,langext = sourcecode.split(".") |
| 592 | + dockername,langext = sourcecode.rsplit(".", 1) |
593 | 593 | if not os.path.exists(outdir+"/src/Dockerfile."+dockername): # 3/30/21 |
594 | 594 | try: |
595 | 595 | if langext=="py": |
|
628 | 628 | for node in nodes_dict: |
629 | 629 | containername,sourcecode = nodes_dict[node].split(':') |
630 | 630 | if len(sourcecode)!=0 and sourcecode.find(".")!=-1: #3/28/21 |
631 | | - dockername,langext = sourcecode.split(".") |
| 631 | + dockername,langext = sourcecode.rsplit(".", 1) |
632 | 632 | fbuild.write("mkdir docker-"+dockername+"\n") |
633 | 633 | fbuild.write("cd docker-"+dockername+"\n") |
634 | 634 | fbuild.write("cp ../src/Dockerfile."+dockername+" Dockerfile\n") |
|
664 | 664 | logging.debug(f"Generating Docker run command: {DOCKEREXE} run --name={containername+volswr[i]+volsro[i]} {DOCKEREPO}/docker- {sourcecode}") |
665 | 665 | frun.write(DOCKEREXE+' run --name='+containername+volswr[i]+volsro[i]+" "+DOCKEREPO+"/docker-"+sourcecode+"&\n") |
666 | 666 | else: |
667 | | - dockername,langext = sourcecode.split(".") |
| 667 | + dockername,langext = sourcecode.rsplit(".", 1) |
668 | 668 | logging.debug(f"Generating Docker run command for {dockername}: {DOCKEREXE} run --name={containername+volswr[i]+volsro[i]} docker-{dockername}") |
669 | 669 | frun.write(DOCKEREXE+' run --name='+containername+volswr[i]+volsro[i]+" docker-"+dockername+"&\n") |
670 | 670 | #if langext != "m": #3/27/21 |
|
681 | 681 | for node in nodes_dict: |
682 | 682 | containername,sourcecode = nodes_dict[node].split(':') |
683 | 683 | if len(sourcecode)!=0: |
684 | | - #dockername,langext = sourcecode.split(".") |
685 | | - dockername = sourcecode.split(".")[0] # 3/28/21 |
| 684 | + #dockername,langext = sourcecode.rsplit(".", 1) |
| 685 | + dockername = sourcecode.rsplit(".", 1)[0] # 3/28/21 |
686 | 686 | fstop.write(DOCKEREXE+' stop '+containername+"\n") |
687 | 687 | fstop.write(DOCKEREXE+' rm '+containername+"\n") |
688 | 688 | i=i+1 |
|
693 | 693 | for node in nodes_dict: |
694 | 694 | containername,sourcecode = nodes_dict[node].split(':') |
695 | 695 | if len(sourcecode)!=0: |
696 | | - dockername = sourcecode.split(".")[0] #3/28/21 |
| 696 | + dockername = sourcecode.rsplit(".", 1)[0] #3/28/21 |
697 | 697 | writeedges = volswr[i] |
698 | 698 | while writeedges.find(":") != -1: |
699 | 699 | fclear.write(DOCKEREXE+' volume rm ' +writeedges.split(":")[0].split("-v")[1]+"\n") |
|
711 | 711 | for node in nodes_dict: |
712 | 712 | containername,sourcecode = nodes_dict[node].split(':') |
713 | 713 | if len(sourcecode)!=0: |
714 | | - dockername = sourcecode.split(".")[0] #3/28/21 |
| 714 | + dockername = sourcecode.rsplit(".", 1)[0] #3/28/21 |
715 | 715 | writeedges = volswr[i] |
716 | 716 | while writeedges.find(":") != -1: |
717 | 717 | fmaxtime.write(' -v ') |
|
726 | 726 | for node in nodes_dict: |
727 | 727 | containername,sourcecode = nodes_dict[node].split(':') |
728 | 728 | if len(sourcecode)!=0: |
729 | | - dockername = sourcecode.split(".")[0] #3/28/21 |
| 729 | + dockername = sourcecode.rsplit(".", 1)[0] #3/28/21 |
730 | 730 | writeedges = volswr[i] |
731 | 731 | while writeedges.find(":") != -1: |
732 | 732 | fmaxtime.write('sudo docker cp concore.maxtime concore:/') |
|
750 | 750 | for node in nodes_dict: |
751 | 751 | containername,sourcecode = nodes_dict[node].split(':') |
752 | 752 | if len(sourcecode)!=0: |
753 | | - dockername = sourcecode.split(".")[0] #3/28/21 |
| 753 | + dockername = sourcecode.rsplit(".", 1)[0] #3/28/21 |
754 | 754 | writeedges = volswr[i] |
755 | 755 | while writeedges.find(":") != -1: |
756 | 756 | fparams.write(' -v ') |
|
765 | 765 | for node in nodes_dict: |
766 | 766 | containername,sourcecode = nodes_dict[node].split(':') |
767 | 767 | if len(sourcecode)!=0: |
768 | | - dockername = sourcecode.split(".")[0] #3/28/21 |
| 768 | + dockername = sourcecode.rsplit(".", 1)[0] #3/28/21 |
769 | 769 | writeedges = volswr[i] |
770 | 770 | while writeedges.find(":") != -1: |
771 | 771 | fparams.write('sudo docker cp concore.params concore:/') |
|
788 | 788 | for node in nodes_dict: |
789 | 789 | containername,sourcecode = nodes_dict[node].split(':') |
790 | 790 | if len(sourcecode)!=0: |
791 | | - dockername = sourcecode.split(".")[0] #3/28/21 |
| 791 | + dockername = sourcecode.rsplit(".", 1)[0] #3/28/21 |
792 | 792 | writeedges = volswr[i] |
793 | 793 | while writeedges.find(":") != -1: |
794 | 794 | funlock.write(' -v ') |
|
803 | 803 | for node in nodes_dict: |
804 | 804 | containername,sourcecode = nodes_dict[node].split(':') |
805 | 805 | if len(sourcecode)!=0: |
806 | | - dockername = sourcecode.split(".")[0] #3/28/21 |
| 806 | + dockername = sourcecode.rsplit(".", 1)[0] #3/28/21 |
807 | 807 | writeedges = volswr[i] |
808 | 808 | while writeedges.find(":") != -1: |
809 | 809 | funlock.write('sudo docker cp ~/concore.apikey concore:/') |
|
821 | 821 | for node in nodes_dict: |
822 | 822 | containername,sourcecode = nodes_dict[node].split(':') |
823 | 823 | if len(sourcecode)!=0 and sourcecode.find(".")!=-1: #3/28/21 |
824 | | - dockername,langext = sourcecode.split(".") |
| 824 | + dockername,langext = sourcecode.rsplit(".", 1) |
825 | 825 | fdebug.write(DOCKEREXE+' run -it --name='+containername+volswr[i]+volsro[i]+" docker-"+dockername+"&\n") |
826 | 826 | i=i+1 |
827 | 827 | fdebug.close() |
|
847 | 847 | if sourcecode.find(".")==-1: |
848 | 848 | logging.error("cannot pull container "+sourcecode+" with control core type "+concoretype) #3/28/21 |
849 | 849 | quit() |
850 | | - dockername,langext = sourcecode.split(".") |
| 850 | + dockername,langext = sourcecode.rsplit(".", 1) |
851 | 851 | fbuild.write('mkdir '+containername+"\n") |
852 | 852 | if concoretype == "windows": |
853 | 853 | fbuild.write("copy .\\src\\"+sourcecode+" .\\"+containername+"\\"+sourcecode+"\n") |
|
898 | 898 | containername,sourcecode = edges_dict[edges][0].split(':') |
899 | 899 | outcount[nodes_num[edges_dict[edges][0]]] += 1 |
900 | 900 | if len(sourcecode)!=0: |
901 | | - dockername,langext = sourcecode.split(".") |
| 901 | + dockername,langext = sourcecode.rsplit(".", 1) |
902 | 902 | fbuild.write('cd '+containername+"\n") |
903 | 903 | if concoretype=="windows": |
904 | 904 | fbuild.write("mklink /J out"+str(outcount[nodes_num[edges_dict[edges][0]]])+" ..\\"+str(edges)+"\n") |
|
911 | 911 | for node in nodes_dict: |
912 | 912 | containername,sourcecode = nodes_dict[node].split(':') |
913 | 913 | if len(sourcecode)!=0: |
914 | | - dockername,langext = sourcecode.split(".") |
| 914 | + dockername,langext = sourcecode.rsplit(".", 1) |
915 | 915 | fbuild.write('cd '+containername+"\n") |
916 | 916 | for pair in indir[i]: |
917 | 917 | volname,dirname = pair.split(':/') |
|
932 | 932 | for node in nodes_dict: |
933 | 933 | containername,sourcecode = nodes_dict[node].split(':') |
934 | 934 | if len(sourcecode)!=0: |
935 | | - dockername,langext = sourcecode.split(".") |
| 935 | + dockername,langext = sourcecode.rsplit(".", 1) |
936 | 936 | if not (langext in ["py","m","sh","cpp","v"]): # 6/22/21 |
937 | 937 | logging.error(f"Extension .{langext} is unsupported") |
938 | 938 | quit() |
|
1028 | 1028 | for node in nodes_dict: |
1029 | 1029 | containername,sourcecode = nodes_dict[node].split(':') |
1030 | 1030 | if len(sourcecode)!=0: |
1031 | | - dockername = sourcecode.split(".")[0] # 3/28/21 |
| 1031 | + dockername = sourcecode.rsplit(".", 1)[0] # 3/28/21 |
1032 | 1032 | if concoretype=="windows": |
1033 | 1033 | fstop.write('cmd /C '+containername+"\\concorekill\n") |
1034 | 1034 | fstop.write('del '+containername+"\\concorekill.bat\n") |
|
1044 | 1044 | for node in nodes_dict: |
1045 | 1045 | containername,sourcecode = nodes_dict[node].split(':') |
1046 | 1046 | if len(sourcecode)!=0: |
1047 | | - dockername = sourcecode.split(".")[0] #3/28/21 |
| 1047 | + dockername = sourcecode.rsplit(".", 1)[0] #3/28/21 |
1048 | 1048 | writeedges = volswr[i] |
1049 | 1049 | while writeedges.find(":") != -1: |
1050 | 1050 | if concoretype=="windows": |
|
1061 | 1061 | for node in nodes_dict: |
1062 | 1062 | containername,sourcecode = nodes_dict[node].split(':') |
1063 | 1063 | if len(sourcecode)!=0: |
1064 | | - dockername = sourcecode.split(".")[0] #3/28/21 |
| 1064 | + dockername = sourcecode.rsplit(".", 1)[0] #3/28/21 |
1065 | 1065 | writeedges = volswr[i] |
1066 | 1066 | while writeedges.find(":") != -1: |
1067 | 1067 | if concoretype=="windows": |
|
1078 | 1078 | for node in nodes_dict: |
1079 | 1079 | containername,sourcecode = nodes_dict[node].split(':') |
1080 | 1080 | if len(sourcecode)!=0: |
1081 | | - dockername = sourcecode.split(".")[0] #3/28/21 |
| 1081 | + dockername = sourcecode.rsplit(".", 1)[0] #3/28/21 |
1082 | 1082 | writeedges = volswr[i] |
1083 | 1083 | while writeedges.find(":") != -1: |
1084 | 1084 | if concoretype=="windows": |
|
1095 | 1095 | for node in nodes_dict: |
1096 | 1096 | containername,sourcecode = nodes_dict[node].split(':') |
1097 | 1097 | if len(sourcecode)!=0: |
1098 | | - dockername = sourcecode.split(".")[0] #3/28/21 |
| 1098 | + dockername = sourcecode.rsplit(".", 1)[0] #3/28/21 |
1099 | 1099 | writeedges = volswr[i] |
1100 | 1100 | while writeedges.find(":") != -1: |
1101 | 1101 | if concoretype=="windows": |
|
0 commit comments