Changeset 3727


Ignore:
Timestamp:
Sep 13, 2007, 3:32:57 PM (15 years ago)
Author:
Johan Enell
Message:

Fixes #739

File:
1 edited

Legend:

Unmodified
Added
Removed
  • branches/2.4-stable/src/plugins/core/net/sf/basedb/plugins/Base1PluginExecuter.java

    r3726 r3727  
    654654          int exitValue = p.waitFor();
    655655
     656          progress.display(50, "Reading from error stream.");
    656657          for(int i = 0; errorStream.isAlive(); ++i)
    657658          {
     
    682683        {
    683684          //Copy files
    684 //          dc.deleteItem(stdin);
     685          progress.display(60, "Copying files to server.");
    685686          importFiles(dc, trans);
    686687          if (!deleteDir(getExecDirectory()))
     
    688689            response.setError("Could not remove execution directory: "+getExecDirectory().getAbsolutePath(), null);
    689690          }
    690         }
    691              
     691          stdout = File.getFile(dc, getPluginDirectory(dc), "stdout.txt", true);
     692        }
     693       
    692694        //Import data
    693695        try
    694696        {
    695697          progress.display(70, "Importing data from plugin.");
    696           importData(dc, trans);
     698          importData(dc, stdout, trans);
    697699          response.setDone(msg);
    698700        }
     
    701703          response.setError(ex.getMessage(), Arrays.asList(ex));
    702704          return;
     705        }
     706       
     707        //Clean up
     708        if (!Values.getBoolean(String.valueOf(configuration.getValue(leaveStdinParameter.getName()))))
     709        {
     710          dc.deleteItem(stdin);
     711        }
     712        if (!Values.getBoolean(String.valueOf(configuration.getValue(leaveStdoutParameter.getName()))))
     713        {
     714          dc.deleteItem(stdout);
    703715        }
    704716      }
     
    12481260    @throws IOException if there is any error reading from stdou.txt
    12491261  */
    1250   private int importData(DbControl dc, Transformation t)
     1262  private int importData(DbControl dc, File stdout, Transformation t)
    12511263    throws IOException
    12521264  {
     
    12591271    HashMap<String, ExtraValueType> evtMap = new HashMap<String, ExtraValueType>();
    12601272
    1261     File stdout = File.getFile(dc, getPluginDirectory(dc), "stdout.txt", true);
    12621273    FlatFileParser ffp = getInitializedFlatFileParser(stdout.getDownloadStream(0));
    12631274   
Note: See TracChangeset for help on using the changeset viewer.