Menu
▾
▴
cogkit-svn — SVN update notifications are sent to this mailing list
You can subscribe to this list here.
| 2006 |
Jan
|
Feb
|
Mar
|
Apr
(39) |
May
(165) |
Jun
(164) |
Jul
(127) |
Aug
(81) |
Sep
(146) |
Oct
(375) |
Nov
(241) |
Dec
(77) |
|---|---|---|---|---|---|---|---|---|---|---|---|---|
| 2007 |
Jan
(42) |
Feb
(38) |
Mar
(30) |
Apr
(6) |
May
(17) |
Jun
|
Jul
(15) |
Aug
(59) |
Sep
(31) |
Oct
(44) |
Nov
(30) |
Dec
(12) |
| 2008 |
Jan
(9) |
Feb
(63) |
Mar
(18) |
Apr
(43) |
May
(28) |
Jun
(32) |
Jul
(61) |
Aug
(5) |
Sep
(72) |
Oct
(48) |
Nov
(6) |
Dec
|
|
From: <b_...@us...> - 2008-06-25 13:14:15
|
Revision: 2057
http://cogkit.svn.sourceforge.net/cogkit/?rev=2057&view=rev
Author: b_z_c
Date: 2008-06-25 06:14:02 -0700 (Wed, 25 Jun 2008)
Log Message:
-----------
factor maximum load calculation into separate function
Modified Paths:
--------------
trunk/current/src/cog/modules/karajan/src/org/globus/cog/karajan/scheduler/WeightedHost.java
Modified: trunk/current/src/cog/modules/karajan/src/org/globus/cog/karajan/scheduler/WeightedHost.java
===================================================================
--- trunk/current/src/cog/modules/karajan/src/org/globus/cog/karajan/scheduler/WeightedHost.java 2008-06-24 20:55:56 UTC (rev 2056)
+++ trunk/current/src/cog/modules/karajan/src/org/globus/cog/karajan/scheduler/WeightedHost.java 2008-06-25 13:14:02 UTC (rev 2057)
@@ -106,7 +106,7 @@
public String toString() {
return host.toString() + ":" + D4.format(score) + "(" + D4.format(tscore) + "):" + load
- + "/" + (int)(jobThrottle * tscore + 2) + (isOverloaded() ? " overloaded" : "");
+ + "/" + (int)(maxLoad()) + (isOverloaded() ? " overloaded" : "");
}
public int compareTo(Object o) {
@@ -130,10 +130,14 @@
}
public boolean isOverloaded() {
- return !(load < jobThrottle * tscore + 2);
+ return !(load < maxLoad());
}
public float getJobThrottle() {
return jobThrottle;
}
+
+ public double maxLoad() {
+ return jobThrottle * tscore + 2;
+ }
}
This was sent by the SourceForge.net collaborative development platform, the world's largest Open Source development site.
|
|
From: <li...@us...> - 2008-06-24 20:56:40
|
Revision: 2056
http://cogkit.svn.sourceforge.net/cogkit/?rev=2056&view=rev
Author: liuwt
Date: 2008-06-24 13:55:56 -0700 (Tue, 24 Jun 2008)
Log Message:
-----------
Modified Paths:
--------------
trunk/current/src/cog/modules/transfer-gui/src/org/globus/transfer/reliable/client/webstart/ProgramStarter.java
Modified: trunk/current/src/cog/modules/transfer-gui/src/org/globus/transfer/reliable/client/webstart/ProgramStarter.java
===================================================================
--- trunk/current/src/cog/modules/transfer-gui/src/org/globus/transfer/reliable/client/webstart/ProgramStarter.java 2008-06-24 20:55:09 UTC (rev 2055)
+++ trunk/current/src/cog/modules/transfer-gui/src/org/globus/transfer/reliable/client/webstart/ProgramStarter.java 2008-06-24 20:55:56 UTC (rev 2056)
@@ -157,7 +157,7 @@
private void invokeAnt() {
try {
URL url = Thread.currentThread().getContextClassLoader().getResource("scripts/build.xml");
- System.out.println(url);
+ //System.out.println(new File(".").getCanonicalPath());
logger.debug(url);
Project p = new Project();
p.init();
This was sent by the SourceForge.net collaborative development platform, the world's largest Open Source development site.
|
|
From: <li...@us...> - 2008-06-24 20:55:35
|
Revision: 2055
http://cogkit.svn.sourceforge.net/cogkit/?rev=2055&view=rev
Author: liuwt
Date: 2008-06-24 13:55:09 -0700 (Tue, 24 Jun 2008)
Log Message:
-----------
Modified Paths:
--------------
trunk/current/src/cog/modules/transfer-gui/src/org/globus/transfer/reliable/client/GridFTPGUIView.java
Modified: trunk/current/src/cog/modules/transfer-gui/src/org/globus/transfer/reliable/client/GridFTPGUIView.java
===================================================================
--- trunk/current/src/cog/modules/transfer-gui/src/org/globus/transfer/reliable/client/GridFTPGUIView.java 2008-06-24 20:02:01 UTC (rev 2054)
+++ trunk/current/src/cog/modules/transfer-gui/src/org/globus/transfer/reliable/client/GridFTPGUIView.java 2008-06-24 20:55:09 UTC (rev 2055)
@@ -569,8 +569,14 @@
File logConfigFile = new File(UIConstants.LOG_CONFIG);
String logLocation = null;
if (!logConfigFile.exists()) {
- String JWSCacheDir = System.getProperty("deployment.user.cachedir");
- logLocation = JWSCacheDir + File.separator + "logoutput";
+ String dir;
+ try {
+ dir = new File(".").getCanonicalPath();
+ logLocation = dir + File.separator + "logoutput";
+ } catch (IOException e) {
+
+ }
+
} else {
InputStream is = null;
try {
This was sent by the SourceForge.net collaborative development platform, the world's largest Open Source development site.
|
|
From: <li...@us...> - 2008-06-24 20:03:15
|
Revision: 2054
http://cogkit.svn.sourceforge.net/cogkit/?rev=2054&view=rev
Author: liuwt
Date: 2008-06-24 13:02:01 -0700 (Tue, 24 Jun 2008)
Log Message:
-----------
Added Paths:
-----------
trunk/current/src/cog/modules/transfer-gui/src/scripts/
trunk/current/src/cog/modules/transfer-gui/src/scripts/build.xml
trunk/current/src/cog/modules/transfer-gui/src/scripts/gui.bat
trunk/current/src/cog/modules/transfer-gui/src/scripts/gui.sh
Added: trunk/current/src/cog/modules/transfer-gui/src/scripts/build.xml
===================================================================
--- trunk/current/src/cog/modules/transfer-gui/src/scripts/build.xml (rev 0)
+++ trunk/current/src/cog/modules/transfer-gui/src/scripts/build.xml 2008-06-24 20:02:01 UTC (rev 2054)
@@ -0,0 +1,62 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<project name="IGTFScratcher" default="run" basedir=".">
+ <property name="dist_base_name" value="igtf-policy-installation-bundle-1.22"/>
+ <property name="dist_package_name" value="${dist_base_name}.tar.gz"/>
+ <property name="IGTFDist" value="https://dist.eugridpma.info/distribution/igtf/current/accredited/${dist_package_name}"/>
+ <property name="tmp_file" value="tmf_file"/>
+ <property name="home_dir" value="${user.home}"/>
+ <property name="root_home" value="/root"/>
+ <property name="cert_files" value="${dist_base_name}/src/accredited/"/>
+
+
+ <!-- add support for "Ant-Contrib" -->
+ <!-- this resource is searched from CLASSPATH -->
+ <taskdef resource="net/sf/antcontrib/antcontrib.properties">
+ <classpath>
+ <pathelement location="./gridftpgui_lib/ant-contrib-1.0b3.jar"/>
+ </classpath>
+ </taskdef>
+
+ <target name="downloadIGTFDist">
+ <get src="${IGTFDist}" dest="${JWSCacheDir}/${dist_package_name}"/>
+ </target>
+
+ <target name="decompressDist">
+ <gunzip src="${JWSCacheDir}/${dist_package_name}" dest="${JWSCacheDir}/${tmp_file}"/>
+ <untar src="${JWSCacheDir}/${tmp_file}" dest="${JWSCacheDir}/"/>
+ </target>
+
+ <target name="run" depends="downloadIGTFDist, decompressDist">
+ <if>
+ <!-- UNIX-like system -->
+ <os family="unix"/>
+ <then>
+ <if>
+ <!-- root user -->
+ <equals arg1="${home_dir}" arg2="${root_home}"/>
+ <then>
+ <copy todir="/etc/grid-security/certificates/">
+ <fileset dir="${cert_files}"/>
+ </copy>
+ </then>
+
+ <!-- non-root user -->
+ <else>
+ <copy todir="${home_dir}/.globus/certificates/">
+ <fileset dir="${cert_files}"/>
+ </copy>
+ </else>
+ </if>
+ </then>
+
+ <!-- Windows System -->
+ <else>
+ <copy todir="${home_dir}/.globus/certificates/">
+ <fileset dir="${cert_files}"/>
+ </copy>
+ </else>
+ </if>
+ </target>
+
+
+</project>
\ No newline at end of file
Added: trunk/current/src/cog/modules/transfer-gui/src/scripts/gui.bat
===================================================================
--- trunk/current/src/cog/modules/transfer-gui/src/scripts/gui.bat (rev 0)
+++ trunk/current/src/cog/modules/transfer-gui/src/scripts/gui.bat 2008-06-24 20:02:01 UTC (rev 2054)
@@ -0,0 +1,19 @@
+@echo off
+
+if "%GLOBUS_LOCATION%" == "" goto nogl
+goto run
+
+:nogl
+
+ echo Error: GLOBUS_LOCATION not set
+ goto end
+
+:run
+
+ set _RUNJAVA=java
+ if not "%JAVA_HOME%" == "" set _RUNJAVA="%JAVA_HOME%\bin\java"
+ %_RUNJAVA% -DGLOBUS_LOCATION="%GLOBUS_LOCATION%" -Daxis.ClientConfigFile="%GLOBUS_LOCATION%"\client-config.wsdd -jar gui.jar
+
+:end
+
+
\ No newline at end of file
Added: trunk/current/src/cog/modules/transfer-gui/src/scripts/gui.sh
===================================================================
--- trunk/current/src/cog/modules/transfer-gui/src/scripts/gui.sh (rev 0)
+++ trunk/current/src/cog/modules/transfer-gui/src/scripts/gui.sh 2008-06-24 20:02:01 UTC (rev 2054)
@@ -0,0 +1,14 @@
+# !/bin/sh
+
+if [ ! -d "$GLOBUS_LOCATION" ] then
+ echo "Error: GLOBUS_LOCATION invalid or not set: $GLOBUS_LOCATION" 1>&2
+ exit 1
+fi
+
+if [ "X$JAVA_HOME" = "X" ] then
+ _RUNJAVA=java
+else
+ _RUNJAVA="$JAVA_HOME"/bin/java
+fi
+
+exec $_RUNJAVA -Daxis.ClientConfigFile="$GLOBUS_LOCATION"\client-config.wsdd -jar gui.jar
\ No newline at end of file
This was sent by the SourceForge.net collaborative development platform, the world's largest Open Source development site.
|
|
From: <li...@us...> - 2008-06-24 20:01:09
|
Revision: 2053
http://cogkit.svn.sourceforge.net/cogkit/?rev=2053&view=rev
Author: liuwt
Date: 2008-06-24 13:00:49 -0700 (Tue, 24 Jun 2008)
Log Message:
-----------
Modified Paths:
--------------
trunk/current/src/cog/modules/transfer-gui/src/org/globus/transfer/reliable/client/GridFTPGUIView.java
trunk/current/src/cog/modules/transfer-gui/src/org/globus/transfer/reliable/client/resources/GridFTPGUIView.properties
Modified: trunk/current/src/cog/modules/transfer-gui/src/org/globus/transfer/reliable/client/GridFTPGUIView.java
===================================================================
--- trunk/current/src/cog/modules/transfer-gui/src/org/globus/transfer/reliable/client/GridFTPGUIView.java 2008-06-23 19:48:29 UTC (rev 2052)
+++ trunk/current/src/cog/modules/transfer-gui/src/org/globus/transfer/reliable/client/GridFTPGUIView.java 2008-06-24 20:00:49 UTC (rev 2053)
@@ -12,11 +12,17 @@
import org.jdesktop.application.TaskMonitor;
import java.awt.event.ActionEvent;
import java.awt.event.ActionListener;
+import java.io.BufferedInputStream;
import java.io.BufferedReader;
import java.io.File;
+import java.io.FileInputStream;
+import java.io.FileNotFoundException;
import java.io.FileReader;
import java.io.FileWriter;
import java.io.IOException;
+import java.io.InputStream;
+import java.util.Properties;
+
import javax.swing.Timer;
import javax.swing.Icon;
import javax.swing.JDialog;
@@ -24,6 +30,8 @@
import javax.swing.JFrame;
import javax.swing.JInternalFrame;
import javax.swing.JOptionPane;
+
+import org.apache.axis.utils.JWSClassLoader;
import org.apache.commons.logging.Log;
import org.apache.commons.logging.LogFactory;
import org.globus.common.CoGProperties;
@@ -155,9 +163,12 @@
jMenuItem10 = new javax.swing.JMenuItem();
jMenuItem2 = new javax.swing.JMenuItem();
jMenu2 = new javax.swing.JMenu();
+ jMenu3 = new javax.swing.JMenu();
jMenuItem3 = new javax.swing.JMenuItem();
jMenuItem4 = new javax.swing.JMenuItem();
jMenuItem5 = new javax.swing.JMenuItem();
+ jMenuItem11 = new javax.swing.JMenuItem();
+ jMenuItem12 = new javax.swing.JMenuItem();
javax.swing.JMenu helpMenu = new javax.swing.JMenu();
javax.swing.JMenuItem aboutMenuItem = new javax.swing.JMenuItem();
statusPanel = new javax.swing.JPanel();
@@ -262,7 +273,7 @@
jButton8ActionPerformed(evt);
}
});
- jToolBar1.add(jButton8);
+ //jToolBar1.add(jButton8);
statusPanelSeparator.setName("statusPanelSeparator"); // NOI18N
@@ -412,7 +423,33 @@
jMenu2.add(jMenuItem5);
menuBar.add(jMenu2);
-
+
+ jMenu3.setText(resourceMap.getString("jMenu3.text")); // NOI18N
+ jMenu3.setName("jMenu3"); // NOI18N
+ jMenu3.addActionListener(new java.awt.event.ActionListener() {
+ public void actionPerformed(java.awt.event.ActionEvent evt) {
+ jMenu3ActionPerformed(evt);
+ }
+ });
+
+ jMenuItem11.setText(resourceMap.getString("jMenuItem11.text")); // NOI18N
+ jMenuItem11.setName("jMenuItem11"); // NOI18N
+ jMenuItem11.addActionListener(new java.awt.event.ActionListener() {
+ public void actionPerformed(java.awt.event.ActionEvent evt) {
+ jMenuItem11ActionPerformed(evt);
+ }
+ });
+ jMenu3.add(jMenuItem11);
+
+ jMenuItem12.setText(resourceMap.getString("jMenuItem12.text")); // NOI18N
+ jMenuItem12.setName("jMenuItem12"); // NOI18N
+ jMenuItem12.addActionListener(new java.awt.event.ActionListener() {
+ public void actionPerformed(java.awt.event.ActionEvent evt) {
+ jMenuItem12ActionPerformed(evt);
+ }
+ });
+ jMenu3.add(jMenuItem12);
+ menuBar.add(jMenu3);
helpMenu.setText(resourceMap.getString("helpMenu.text")); // NOI18N
helpMenu.setName("helpMenu"); // NOI18N
@@ -472,6 +509,10 @@
private void jMenu2ActionPerformed(java.awt.event.ActionEvent evt) {//GEN-FIRST:event_jMenu2ActionPerformed
}//GEN-LAST:event_jMenu2ActionPerformed
+
+ private void jMenu3ActionPerformed(java.awt.event.ActionEvent evt) {//GEN-FIRST:event_jMenu2ActionPerformed
+
+ }//GEN-LAST:event_jMenu2ActionPerformed
private void jMenuItem3ActionPerformed(java.awt.event.ActionEvent evt) {//GEN-FIRST:event_jMenuItem3ActionPerformed
createProxy();
@@ -523,6 +564,53 @@
private void jMenuItem7ActionPerformed(java.awt.event.ActionEvent evt) {//GEN-FIRST:event_jMenuItem7ActionPerformed
saveFile();
}//GEN-LAST:event_jMenuItem7ActionPerformed
+
+ private void jMenuItem11ActionPerformed(java.awt.event.ActionEvent evt) {//GEN-FIRST:event_jMenuItem7ActionPerformed
+ File logConfigFile = new File(UIConstants.LOG_CONFIG);
+ String logLocation = null;
+ if (!logConfigFile.exists()) {
+ String JWSCacheDir = System.getProperty("deployment.user.cachedir");
+ logLocation = JWSCacheDir + File.separator + "logoutput";
+ } else {
+ InputStream is = null;
+ try {
+ is = new BufferedInputStream(new FileInputStream(logConfigFile));
+ Properties prop = new Properties();
+ prop.load(is);
+ logLocation = prop.getProperty("log4j.appender.A1.file");
+ } catch (Exception e) {
+ logLocation="can not get log file location";
+ } finally {
+ try {
+ is.close();
+ } catch (IOException e) {
+
+ }
+ }
+ }
+
+ JOptionPane.showMessageDialog(null, logLocation, "Log Location", JOptionPane.INFORMATION_MESSAGE);
+ }//GEN-LAST:event_jMenuItem7ActionPerformed
+
+ private void jMenuItem12ActionPerformed(java.awt.event.ActionEvent evt) {//GEN-FIRST:event_jMenuItem7ActionPerformed
+ JFileChooser chooser = new JFileChooser();
+ chooser.setDialogTitle("Choose Log File");
+ int flag = chooser.showSaveDialog(null);
+ if (flag == JFileChooser.APPROVE_OPTION) {
+ File f = chooser.getSelectedFile();
+ try {
+ logFileName = f.getCanonicalPath();
+ File logConfigFile = new File(UIConstants.LOG_CONFIG);
+ if (!logConfigFile.exists() || !logConfigFile.isFile()) {
+ LogFileUtils.createNewLogConfigFile(logFileName);
+ } else {
+ LogFileUtils.updateLogConfigFile(logFileName);
+ }
+ } catch (IOException e) {
+ logFileName = "error_log";
+ }
+ }
+ }//GEN-LAST:event_jMenuItem7ActionPerformed
private void jButton3ActionPerformed(java.awt.event.ActionEvent evt) {//GEN-FIRST:event_jButton3ActionPerformed
fileTransferMainPanel1.createNewLocalFrame();
@@ -814,6 +902,7 @@
private javax.swing.JDesktopPane jDesktopPane1;
private javax.swing.JMenu jMenu1;
private javax.swing.JMenu jMenu2;
+ private javax.swing.JMenu jMenu3;
private javax.swing.JMenuItem jMenuItem1;
private javax.swing.JMenuItem jMenuItem2;
private javax.swing.JMenuItem jMenuItem3;
@@ -824,6 +913,8 @@
private javax.swing.JMenuItem jMenuItem8;
private javax.swing.JMenuItem jMenuItem9;
private javax.swing.JMenuItem jMenuItem10;
+ private javax.swing.JMenuItem jMenuItem11;
+ private javax.swing.JMenuItem jMenuItem12;
private javax.swing.JToolBar jToolBar1;
private javax.swing.JPanel mainPanel;
private javax.swing.JMenuBar menuBar;
Modified: trunk/current/src/cog/modules/transfer-gui/src/org/globus/transfer/reliable/client/resources/GridFTPGUIView.properties
===================================================================
--- trunk/current/src/cog/modules/transfer-gui/src/org/globus/transfer/reliable/client/resources/GridFTPGUIView.properties 2008-06-23 19:48:29 UTC (rev 2052)
+++ trunk/current/src/cog/modules/transfer-gui/src/org/globus/transfer/reliable/client/resources/GridFTPGUIView.properties 2008-06-24 20:00:49 UTC (rev 2053)
@@ -34,11 +34,14 @@
jMenuItem1.text=GridFTP
jMenuItem2.text=Local
jMenu2.text=Security
+jMenu3.text=Log
jMenuItem3.text=Create Grid Proxy
jMenuItem4.text=Destroy Grid Proxy
jMenuItem5.text=Grid Proxy Info
jMenuItem6.text=Load
jMenuItem7.text=Save
+jMenuItem11.text=Log Location
+jMenuItem12.text=Log Config
#NOI18N
jButton1.icon=unlock.png
jButton3.text=Local
This was sent by the SourceForge.net collaborative development platform, the world's largest Open Source development site.
|
|
From: <li...@us...> - 2008-06-23 19:48:38
|
Revision: 2052
http://cogkit.svn.sourceforge.net/cogkit/?rev=2052&view=rev
Author: liuwt
Date: 2008-06-23 12:48:29 -0700 (Mon, 23 Jun 2008)
Log Message:
-----------
Modified Paths:
--------------
trunk/current/src/cog/modules/transfer-gui/docs/Notes
Modified: trunk/current/src/cog/modules/transfer-gui/docs/Notes
===================================================================
--- trunk/current/src/cog/modules/transfer-gui/docs/Notes 2008-06-23 18:30:46 UTC (rev 2051)
+++ trunk/current/src/cog/modules/transfer-gui/docs/Notes 2008-06-23 19:48:29 UTC (rev 2052)
@@ -1,2 +1,3 @@
www.globus.org
-/www/www-unix.globus.org/cog/demo/ogce
\ No newline at end of file
+/www/www-unix.globus.org/cog/demo/ogce
+DOE service credential:http://www.doegrids.org/pages/ModelCertificateDeployment.html
\ No newline at end of file
This was sent by the SourceForge.net collaborative development platform, the world's largest Open Source development site.
|
|
From: <li...@us...> - 2008-06-23 18:31:31
|
Revision: 2051
http://cogkit.svn.sourceforge.net/cogkit/?rev=2051&view=rev
Author: liuwt
Date: 2008-06-23 11:30:46 -0700 (Mon, 23 Jun 2008)
Log Message:
-----------
Modified Paths:
--------------
trunk/current/src/cog/modules/transfer-gui/src/org/globus/transfer/reliable/client/GridFTPGUIView.java
Modified: trunk/current/src/cog/modules/transfer-gui/src/org/globus/transfer/reliable/client/GridFTPGUIView.java
===================================================================
--- trunk/current/src/cog/modules/transfer-gui/src/org/globus/transfer/reliable/client/GridFTPGUIView.java 2008-06-23 18:03:35 UTC (rev 2050)
+++ trunk/current/src/cog/modules/transfer-gui/src/org/globus/transfer/reliable/client/GridFTPGUIView.java 2008-06-23 18:30:46 UTC (rev 2051)
@@ -539,7 +539,7 @@
private void jButton8ActionPerformed(java.awt.event.ActionEvent evt) {//GEN-FIRST:event_jButton3ActionPerformed
JFileChooser chooser = new JFileChooser();
chooser.setDialogTitle("Choose Log File");
- int flag = chooser.showOpenDialog(null);
+ int flag = chooser.showSaveDialog(null);
if (flag == JFileChooser.APPROVE_OPTION) {
File f = chooser.getSelectedFile();
try {
This was sent by the SourceForge.net collaborative development platform, the world's largest Open Source development site.
|
|
From: <li...@us...> - 2008-06-23 18:05:33
|
Revision: 2050
http://cogkit.svn.sourceforge.net/cogkit/?rev=2050&view=rev
Author: liuwt
Date: 2008-06-23 11:03:35 -0700 (Mon, 23 Jun 2008)
Log Message:
-----------
Added Paths:
-----------
trunk/current/src/cog/modules/transfer-gui/lib/bcprov-jdk15-139.jar
Removed Paths:
-------------
trunk/current/src/cog/modules/transfer-gui/lib/jce-jdk13-120.jar
Added: trunk/current/src/cog/modules/transfer-gui/lib/bcprov-jdk15-139.jar
===================================================================
(Binary files differ)
Property changes on: trunk/current/src/cog/modules/transfer-gui/lib/bcprov-jdk15-139.jar
___________________________________________________________________
Name: svn:mime-type
+ application/octet-stream
Deleted: trunk/current/src/cog/modules/transfer-gui/lib/jce-jdk13-120.jar
===================================================================
(Binary files differ)
This was sent by the SourceForge.net collaborative development platform, the world's largest Open Source development site.
|
|
From: <li...@us...> - 2008-06-23 16:36:52
|
Revision: 2049
http://cogkit.svn.sourceforge.net/cogkit/?rev=2049&view=rev
Author: liuwt
Date: 2008-06-23 09:36:51 -0700 (Mon, 23 Jun 2008)
Log Message:
-----------
perl scripts used for signing jars and other utilities
Added Paths:
-----------
trunk/current/src/cog/modules/transfer-gui/tools/
trunk/current/src/cog/modules/transfer-gui/tools/SignJarCommand.pl
trunk/current/src/cog/modules/transfer-gui/tools/path.pl
Added: trunk/current/src/cog/modules/transfer-gui/tools/SignJarCommand.pl
===================================================================
--- trunk/current/src/cog/modules/transfer-gui/tools/SignJarCommand.pl (rev 0)
+++ trunk/current/src/cog/modules/transfer-gui/tools/SignJarCommand.pl 2008-06-23 16:36:51 UTC (rev 2049)
@@ -0,0 +1,29 @@
+#!/bin/perl
+if (opendir(DIR, "lib")) {
+
+ $output_file=">tmp";
+ open(OUTPUT_FILE, $output_file);
+ @entries = readdir(DIR);
+ closedir(DIR);
+ $alias = "mykey";
+ $keystore="mykeystore";
+ $storepass="mcs123";
+ `keytool -genkey -alias $alias -keystore $keystore -keypass mcs123 -storepass $storepass`;
+ $sign_jar_cmd_base = "jarsigner -keystore $keystore -storepass $storepass ";
+ $sign_jar_cmd = $sign_jar_cmd_base."gui.jar ".$alias;
+ `$sign_jar_cmd`;
+ foreach (@entries) {
+ if ($_ ne "." && $_ ne "..") {
+ $entry = "lib/".$_;
+ $sign_jar_cmd = $sign_jar_cmd_base.$entry." ".$alias;
+ print $sign_jar_cmd;
+ print "\n";
+ `$sign_jar_cmd`;
+
+ }
+ }
+
+ close(OUTPUT_FILE);
+
+
+}
\ No newline at end of file
Added: trunk/current/src/cog/modules/transfer-gui/tools/path.pl
===================================================================
--- trunk/current/src/cog/modules/transfer-gui/tools/path.pl (rev 0)
+++ trunk/current/src/cog/modules/transfer-gui/tools/path.pl 2008-06-23 16:36:51 UTC (rev 2049)
@@ -0,0 +1,20 @@
+#!/bin/perl
+if (opendir(DIR, "lib")) {
+
+ $output_file=">tmp";
+ open(OUTPUT_FILE, $output_file);
+ @entries = readdir(DIR);
+ $scalar = @entries;
+ print $scalar;
+ closedir(DIR);
+ foreach (@entries) {
+ if ($_ ne "." && $_ ne "..") {
+ $entry = "<jar href=\""."lib/".$_."\"/>";
+ print OUTPUT_FILE $entry;
+ print OUTPUT_FILE "\n";
+ }
+ }
+ close(OUTPUT_FILE);
+
+
+}
\ No newline at end of file
This was sent by the SourceForge.net collaborative development platform, the world's largest Open Source development site.
|
|
From: <li...@us...> - 2008-06-23 16:34:52
|
Revision: 2048
http://cogkit.svn.sourceforge.net/cogkit/?rev=2048&view=rev
Author: liuwt
Date: 2008-06-23 09:34:48 -0700 (Mon, 23 Jun 2008)
Log Message:
-----------
default log4j properties file
Added Paths:
-----------
trunk/current/src/cog/modules/transfer-gui/log4j_gui_default.properties
Added: trunk/current/src/cog/modules/transfer-gui/log4j_gui_default.properties
===================================================================
--- trunk/current/src/cog/modules/transfer-gui/log4j_gui_default.properties (rev 0)
+++ trunk/current/src/cog/modules/transfer-gui/log4j_gui_default.properties 2008-06-23 16:34:48 UTC (rev 2048)
@@ -0,0 +1,22 @@
+# Set root category priority to WARN and its only appender to A1.
+
+log4j.rootCategory=ERROR, A1
+
+# A1 is set to be a ConsoleAppender.
+
+log4j.appender.A1=org.apache.log4j.FileAppender
+
+# A1 uses PatternLayout.
+log4j.appender.A1.file=logoutput
+log4j.appender.A1.layout=org.apache.log4j.PatternLayout
+log4j.appender.A1.layout.ConversionPattern=%d{ISO8601} %-5p %c{2} [%t,%M:%L] %m%n
+
+# Display any warnings generated by our code
+log4j.category.org.globus=DEBUG
+
+# Enable SOAP Message Logging
+# log4j.category.org.globus.wsrf.handlers.MessageLoggingHandler=DEBUG
+
+# Comment out the line below if you want to log every authorization
+# decision the notification consumer makes.
+#log4j.category.org.globus.wsrf.impl.security.authorization.ServiceAuthorizationChain=WARN
This was sent by the SourceForge.net collaborative development platform, the world's largest Open Source development site.
|
|
From: <li...@us...> - 2008-06-23 16:20:27
|
Revision: 2047
http://cogkit.svn.sourceforge.net/cogkit/?rev=2047&view=rev
Author: liuwt
Date: 2008-06-23 09:20:22 -0700 (Mon, 23 Jun 2008)
Log Message:
-----------
Added Paths:
-----------
trunk/current/src/cog/modules/transfer-gui/lib/ant-contrib-1.0b3.jar
trunk/current/src/cog/modules/transfer-gui/lib/ant-launcher.jar
trunk/current/src/cog/modules/transfer-gui/lib/ant.jar
Added: trunk/current/src/cog/modules/transfer-gui/lib/ant-contrib-1.0b3.jar
===================================================================
(Binary files differ)
Property changes on: trunk/current/src/cog/modules/transfer-gui/lib/ant-contrib-1.0b3.jar
___________________________________________________________________
Name: svn:mime-type
+ application/octet-stream
Added: trunk/current/src/cog/modules/transfer-gui/lib/ant-launcher.jar
===================================================================
(Binary files differ)
Property changes on: trunk/current/src/cog/modules/transfer-gui/lib/ant-launcher.jar
___________________________________________________________________
Name: svn:mime-type
+ application/octet-stream
Added: trunk/current/src/cog/modules/transfer-gui/lib/ant.jar
===================================================================
(Binary files differ)
Property changes on: trunk/current/src/cog/modules/transfer-gui/lib/ant.jar
___________________________________________________________________
Name: svn:mime-type
+ application/octet-stream
This was sent by the SourceForge.net collaborative development platform, the world's largest Open Source development site.
|
|
From: <li...@us...> - 2008-06-23 16:15:12
|
Revision: 2046
http://cogkit.svn.sourceforge.net/cogkit/?rev=2046&view=rev
Author: liuwt
Date: 2008-06-23 09:14:54 -0700 (Mon, 23 Jun 2008)
Log Message:
-----------
Added Paths:
-----------
trunk/current/src/cog/modules/transfer-gui/lib/GlobusPortal-0.0.1.jar
trunk/current/src/cog/modules/transfer-gui/lib/addressing-1.0.jar
trunk/current/src/cog/modules/transfer-gui/lib/appframework-1.0.3.jar
trunk/current/src/cog/modules/transfer-gui/lib/axis-url.jar
trunk/current/src/cog/modules/transfer-gui/lib/axis.jar
trunk/current/src/cog/modules/transfer-gui/lib/beansbinding-1.2.1.jar
trunk/current/src/cog/modules/transfer-gui/lib/cog-axis.jar
trunk/current/src/cog/modules/transfer-gui/lib/cog-jglobus.jar
trunk/current/src/cog/modules/transfer-gui/lib/cog-ogce.jar
trunk/current/src/cog/modules/transfer-gui/lib/commonj.jar
trunk/current/src/cog/modules/transfer-gui/lib/commons-beanutils.jar
trunk/current/src/cog/modules/transfer-gui/lib/commons-cli-2.0.jar
trunk/current/src/cog/modules/transfer-gui/lib/commons-collections-3.0.jar
trunk/current/src/cog/modules/transfer-gui/lib/commons-digester.jar
trunk/current/src/cog/modules/transfer-gui/lib/commons-discovery.jar
trunk/current/src/cog/modules/transfer-gui/lib/commons-logging.jar
trunk/current/src/cog/modules/transfer-gui/lib/concurrent.jar
trunk/current/src/cog/modules/transfer-gui/lib/cryptix-asn1.jar
trunk/current/src/cog/modules/transfer-gui/lib/cryptix.jar
trunk/current/src/cog/modules/transfer-gui/lib/cryptix32.jar
trunk/current/src/cog/modules/transfer-gui/lib/globus_delegation_client.jar
trunk/current/src/cog/modules/transfer-gui/lib/globus_delegation_service.jar
trunk/current/src/cog/modules/transfer-gui/lib/globus_delegation_stubs.jar
trunk/current/src/cog/modules/transfer-gui/lib/globus_delegation_test.jar
trunk/current/src/cog/modules/transfer-gui/lib/globus_wsrf_rft.jar
trunk/current/src/cog/modules/transfer-gui/lib/globus_wsrf_rft_client.jar
trunk/current/src/cog/modules/transfer-gui/lib/globus_wsrf_rft_stubs.jar
trunk/current/src/cog/modules/transfer-gui/lib/gridant-old.jar
trunk/current/src/cog/modules/transfer-gui/lib/gridant.jar
trunk/current/src/cog/modules/transfer-gui/lib/gridsdk.jar
trunk/current/src/cog/modules/transfer-gui/lib/jaxrpc.jar
trunk/current/src/cog/modules/transfer-gui/lib/jce-jdk13-120.jar
trunk/current/src/cog/modules/transfer-gui/lib/jgss.jar
trunk/current/src/cog/modules/transfer-gui/lib/junit.jar
trunk/current/src/cog/modules/transfer-gui/lib/log4j-1.2.8.jar
trunk/current/src/cog/modules/transfer-gui/lib/naming-common.jar
trunk/current/src/cog/modules/transfer-gui/lib/naming-factory.jar
trunk/current/src/cog/modules/transfer-gui/lib/naming-java.jar
trunk/current/src/cog/modules/transfer-gui/lib/naming-resources.jar
trunk/current/src/cog/modules/transfer-gui/lib/ogsa.jar
trunk/current/src/cog/modules/transfer-gui/lib/puretls.jar
trunk/current/src/cog/modules/transfer-gui/lib/saaj.jar
trunk/current/src/cog/modules/transfer-gui/lib/swing-layout-1.0.3.jar
trunk/current/src/cog/modules/transfer-gui/lib/swing-worker-1.1.jar
trunk/current/src/cog/modules/transfer-gui/lib/wsdl4j.jar
trunk/current/src/cog/modules/transfer-gui/lib/wsrf_core.jar
trunk/current/src/cog/modules/transfer-gui/lib/wsrf_core_stubs.jar
trunk/current/src/cog/modules/transfer-gui/lib/wsrf_tools.jar
trunk/current/src/cog/modules/transfer-gui/lib/wss4j.jar
trunk/current/src/cog/modules/transfer-gui/lib/xercesImpl.jar
trunk/current/src/cog/modules/transfer-gui/lib/xml4j.jar
trunk/current/src/cog/modules/transfer-gui/lib/xmlsec.jar
Added: trunk/current/src/cog/modules/transfer-gui/lib/GlobusPortal-0.0.1.jar
===================================================================
(Binary files differ)
Property changes on: trunk/current/src/cog/modules/transfer-gui/lib/GlobusPortal-0.0.1.jar
___________________________________________________________________
Name: svn:mime-type
+ application/octet-stream
Added: trunk/current/src/cog/modules/transfer-gui/lib/addressing-1.0.jar
===================================================================
(Binary files differ)
Property changes on: trunk/current/src/cog/modules/transfer-gui/lib/addressing-1.0.jar
___________________________________________________________________
Name: svn:mime-type
+ application/octet-stream
Added: trunk/current/src/cog/modules/transfer-gui/lib/appframework-1.0.3.jar
===================================================================
(Binary files differ)
Property changes on: trunk/current/src/cog/modules/transfer-gui/lib/appframework-1.0.3.jar
___________________________________________________________________
Name: svn:mime-type
+ application/octet-stream
Added: trunk/current/src/cog/modules/transfer-gui/lib/axis-url.jar
===================================================================
(Binary files differ)
Property changes on: trunk/current/src/cog/modules/transfer-gui/lib/axis-url.jar
___________________________________________________________________
Name: svn:mime-type
+ application/octet-stream
Added: trunk/current/src/cog/modules/transfer-gui/lib/axis.jar
===================================================================
(Binary files differ)
Property changes on: trunk/current/src/cog/modules/transfer-gui/lib/axis.jar
___________________________________________________________________
Name: svn:mime-type
+ application/octet-stream
Added: trunk/current/src/cog/modules/transfer-gui/lib/beansbinding-1.2.1.jar
===================================================================
(Binary files differ)
Property changes on: trunk/current/src/cog/modules/transfer-gui/lib/beansbinding-1.2.1.jar
___________________________________________________________________
Name: svn:mime-type
+ application/octet-stream
Added: trunk/current/src/cog/modules/transfer-gui/lib/cog-axis.jar
===================================================================
(Binary files differ)
Property changes on: trunk/current/src/cog/modules/transfer-gui/lib/cog-axis.jar
___________________________________________________________________
Name: svn:mime-type
+ application/octet-stream
Added: trunk/current/src/cog/modules/transfer-gui/lib/cog-jglobus.jar
===================================================================
(Binary files differ)
Property changes on: trunk/current/src/cog/modules/transfer-gui/lib/cog-jglobus.jar
___________________________________________________________________
Name: svn:mime-type
+ application/octet-stream
Added: trunk/current/src/cog/modules/transfer-gui/lib/cog-ogce.jar
===================================================================
(Binary files differ)
Property changes on: trunk/current/src/cog/modules/transfer-gui/lib/cog-ogce.jar
___________________________________________________________________
Name: svn:mime-type
+ application/octet-stream
Added: trunk/current/src/cog/modules/transfer-gui/lib/commonj.jar
===================================================================
(Binary files differ)
Property changes on: trunk/current/src/cog/modules/transfer-gui/lib/commonj.jar
___________________________________________________________________
Name: svn:mime-type
+ application/octet-stream
Added: trunk/current/src/cog/modules/transfer-gui/lib/commons-beanutils.jar
===================================================================
(Binary files differ)
Property changes on: trunk/current/src/cog/modules/transfer-gui/lib/commons-beanutils.jar
___________________________________________________________________
Name: svn:mime-type
+ application/octet-stream
Added: trunk/current/src/cog/modules/transfer-gui/lib/commons-cli-2.0.jar
===================================================================
(Binary files differ)
Property changes on: trunk/current/src/cog/modules/transfer-gui/lib/commons-cli-2.0.jar
___________________________________________________________________
Name: svn:mime-type
+ application/octet-stream
Added: trunk/current/src/cog/modules/transfer-gui/lib/commons-collections-3.0.jar
===================================================================
(Binary files differ)
Property changes on: trunk/current/src/cog/modules/transfer-gui/lib/commons-collections-3.0.jar
___________________________________________________________________
Name: svn:mime-type
+ application/octet-stream
Added: trunk/current/src/cog/modules/transfer-gui/lib/commons-digester.jar
===================================================================
(Binary files differ)
Property changes on: trunk/current/src/cog/modules/transfer-gui/lib/commons-digester.jar
___________________________________________________________________
Name: svn:mime-type
+ application/octet-stream
Added: trunk/current/src/cog/modules/transfer-gui/lib/commons-discovery.jar
===================================================================
(Binary files differ)
Property changes on: trunk/current/src/cog/modules/transfer-gui/lib/commons-discovery.jar
___________________________________________________________________
Name: svn:mime-type
+ application/octet-stream
Added: trunk/current/src/cog/modules/transfer-gui/lib/commons-logging.jar
===================================================================
(Binary files differ)
Property changes on: trunk/current/src/cog/modules/transfer-gui/lib/commons-logging.jar
___________________________________________________________________
Name: svn:mime-type
+ application/octet-stream
Added: trunk/current/src/cog/modules/transfer-gui/lib/concurrent.jar
===================================================================
(Binary files differ)
Property changes on: trunk/current/src/cog/modules/transfer-gui/lib/concurrent.jar
___________________________________________________________________
Name: svn:mime-type
+ application/octet-stream
Added: trunk/current/src/cog/modules/transfer-gui/lib/cryptix-asn1.jar
===================================================================
(Binary files differ)
Property changes on: trunk/current/src/cog/modules/transfer-gui/lib/cryptix-asn1.jar
___________________________________________________________________
Name: svn:mime-type
+ application/octet-stream
Added: trunk/current/src/cog/modules/transfer-gui/lib/cryptix.jar
===================================================================
(Binary files differ)
Property changes on: trunk/current/src/cog/modules/transfer-gui/lib/cryptix.jar
___________________________________________________________________
Name: svn:mime-type
+ application/octet-stream
Added: trunk/current/src/cog/modules/transfer-gui/lib/cryptix32.jar
===================================================================
(Binary files differ)
Property changes on: trunk/current/src/cog/modules/transfer-gui/lib/cryptix32.jar
___________________________________________________________________
Name: svn:mime-type
+ application/octet-stream
Added: trunk/current/src/cog/modules/transfer-gui/lib/globus_delegation_client.jar
===================================================================
(Binary files differ)
Property changes on: trunk/current/src/cog/modules/transfer-gui/lib/globus_delegation_client.jar
___________________________________________________________________
Name: svn:mime-type
+ application/octet-stream
Added: trunk/current/src/cog/modules/transfer-gui/lib/globus_delegation_service.jar
===================================================================
(Binary files differ)
Property changes on: trunk/current/src/cog/modules/transfer-gui/lib/globus_delegation_service.jar
___________________________________________________________________
Name: svn:mime-type
+ application/octet-stream
Added: trunk/current/src/cog/modules/transfer-gui/lib/globus_delegation_stubs.jar
===================================================================
(Binary files differ)
Property changes on: trunk/current/src/cog/modules/transfer-gui/lib/globus_delegation_stubs.jar
___________________________________________________________________
Name: svn:mime-type
+ application/octet-stream
Added: trunk/current/src/cog/modules/transfer-gui/lib/globus_delegation_test.jar
===================================================================
(Binary files differ)
Property changes on: trunk/current/src/cog/modules/transfer-gui/lib/globus_delegation_test.jar
___________________________________________________________________
Name: svn:mime-type
+ application/octet-stream
Added: trunk/current/src/cog/modules/transfer-gui/lib/globus_wsrf_rft.jar
===================================================================
(Binary files differ)
Property changes on: trunk/current/src/cog/modules/transfer-gui/lib/globus_wsrf_rft.jar
___________________________________________________________________
Name: svn:mime-type
+ application/octet-stream
Added: trunk/current/src/cog/modules/transfer-gui/lib/globus_wsrf_rft_client.jar
===================================================================
(Binary files differ)
Property changes on: trunk/current/src/cog/modules/transfer-gui/lib/globus_wsrf_rft_client.jar
___________________________________________________________________
Name: svn:mime-type
+ application/octet-stream
Added: trunk/current/src/cog/modules/transfer-gui/lib/globus_wsrf_rft_stubs.jar
===================================================================
(Binary files differ)
Property changes on: trunk/current/src/cog/modules/transfer-gui/lib/globus_wsrf_rft_stubs.jar
___________________________________________________________________
Name: svn:mime-type
+ application/octet-stream
Added: trunk/current/src/cog/modules/transfer-gui/lib/gridant-old.jar
===================================================================
(Binary files differ)
Property changes on: trunk/current/src/cog/modules/transfer-gui/lib/gridant-old.jar
___________________________________________________________________
Name: svn:mime-type
+ application/octet-stream
Added: trunk/current/src/cog/modules/transfer-gui/lib/gridant.jar
===================================================================
(Binary files differ)
Property changes on: trunk/current/src/cog/modules/transfer-gui/lib/gridant.jar
___________________________________________________________________
Name: svn:mime-type
+ application/octet-stream
Added: trunk/current/src/cog/modules/transfer-gui/lib/gridsdk.jar
===================================================================
(Binary files differ)
Property changes on: trunk/current/src/cog/modules/transfer-gui/lib/gridsdk.jar
___________________________________________________________________
Name: svn:mime-type
+ application/octet-stream
Added: trunk/current/src/cog/modules/transfer-gui/lib/jaxrpc.jar
===================================================================
(Binary files differ)
Property changes on: trunk/current/src/cog/modules/transfer-gui/lib/jaxrpc.jar
___________________________________________________________________
Name: svn:mime-type
+ application/octet-stream
Added: trunk/current/src/cog/modules/transfer-gui/lib/jce-jdk13-120.jar
===================================================================
(Binary files differ)
Property changes on: trunk/current/src/cog/modules/transfer-gui/lib/jce-jdk13-120.jar
___________________________________________________________________
Name: svn:mime-type
+ application/octet-stream
Added: trunk/current/src/cog/modules/transfer-gui/lib/jgss.jar
===================================================================
(Binary files differ)
Property changes on: trunk/current/src/cog/modules/transfer-gui/lib/jgss.jar
___________________________________________________________________
Name: svn:mime-type
+ application/octet-stream
Added: trunk/current/src/cog/modules/transfer-gui/lib/junit.jar
===================================================================
(Binary files differ)
Property changes on: trunk/current/src/cog/modules/transfer-gui/lib/junit.jar
___________________________________________________________________
Name: svn:mime-type
+ application/octet-stream
Added: trunk/current/src/cog/modules/transfer-gui/lib/log4j-1.2.8.jar
===================================================================
(Binary files differ)
Property changes on: trunk/current/src/cog/modules/transfer-gui/lib/log4j-1.2.8.jar
___________________________________________________________________
Name: svn:mime-type
+ application/octet-stream
Added: trunk/current/src/cog/modules/transfer-gui/lib/naming-common.jar
===================================================================
(Binary files differ)
Property changes on: trunk/current/src/cog/modules/transfer-gui/lib/naming-common.jar
___________________________________________________________________
Name: svn:mime-type
+ application/octet-stream
Added: trunk/current/src/cog/modules/transfer-gui/lib/naming-factory.jar
===================================================================
(Binary files differ)
Property changes on: trunk/current/src/cog/modules/transfer-gui/lib/naming-factory.jar
___________________________________________________________________
Name: svn:mime-type
+ application/octet-stream
Added: trunk/current/src/cog/modules/transfer-gui/lib/naming-java.jar
===================================================================
(Binary files differ)
Property changes on: trunk/current/src/cog/modules/transfer-gui/lib/naming-java.jar
___________________________________________________________________
Name: svn:mime-type
+ application/octet-stream
Added: trunk/current/src/cog/modules/transfer-gui/lib/naming-resources.jar
===================================================================
(Binary files differ)
Property changes on: trunk/current/src/cog/modules/transfer-gui/lib/naming-resources.jar
___________________________________________________________________
Name: svn:mime-type
+ application/octet-stream
Added: trunk/current/src/cog/modules/transfer-gui/lib/ogsa.jar
===================================================================
(Binary files differ)
Property changes on: trunk/current/src/cog/modules/transfer-gui/lib/ogsa.jar
___________________________________________________________________
Name: svn:mime-type
+ application/octet-stream
Added: trunk/current/src/cog/modules/transfer-gui/lib/puretls.jar
===================================================================
(Binary files differ)
Property changes on: trunk/current/src/cog/modules/transfer-gui/lib/puretls.jar
___________________________________________________________________
Name: svn:mime-type
+ application/octet-stream
Added: trunk/current/src/cog/modules/transfer-gui/lib/saaj.jar
===================================================================
(Binary files differ)
Property changes on: trunk/current/src/cog/modules/transfer-gui/lib/saaj.jar
___________________________________________________________________
Name: svn:mime-type
+ application/octet-stream
Added: trunk/current/src/cog/modules/transfer-gui/lib/swing-layout-1.0.3.jar
===================================================================
(Binary files differ)
Property changes on: trunk/current/src/cog/modules/transfer-gui/lib/swing-layout-1.0.3.jar
___________________________________________________________________
Name: svn:mime-type
+ application/octet-stream
Added: trunk/current/src/cog/modules/transfer-gui/lib/swing-worker-1.1.jar
===================================================================
(Binary files differ)
Property changes on: trunk/current/src/cog/modules/transfer-gui/lib/swing-worker-1.1.jar
___________________________________________________________________
Name: svn:mime-type
+ application/octet-stream
Added: trunk/current/src/cog/modules/transfer-gui/lib/wsdl4j.jar
===================================================================
(Binary files differ)
Property changes on: trunk/current/src/cog/modules/transfer-gui/lib/wsdl4j.jar
___________________________________________________________________
Name: svn:mime-type
+ application/octet-stream
Added: trunk/current/src/cog/modules/transfer-gui/lib/wsrf_core.jar
===================================================================
(Binary files differ)
Property changes on: trunk/current/src/cog/modules/transfer-gui/lib/wsrf_core.jar
___________________________________________________________________
Name: svn:mime-type
+ application/octet-stream
Added: trunk/current/src/cog/modules/transfer-gui/lib/wsrf_core_stubs.jar
===================================================================
(Binary files differ)
Property changes on: trunk/current/src/cog/modules/transfer-gui/lib/wsrf_core_stubs.jar
___________________________________________________________________
Name: svn:mime-type
+ application/octet-stream
Added: trunk/current/src/cog/modules/transfer-gui/lib/wsrf_tools.jar
===================================================================
(Binary files differ)
Property changes on: trunk/current/src/cog/modules/transfer-gui/lib/wsrf_tools.jar
___________________________________________________________________
Name: svn:mime-type
+ application/octet-stream
Added: trunk/current/src/cog/modules/transfer-gui/lib/wss4j.jar
===================================================================
(Binary files differ)
Property changes on: trunk/current/src/cog/modules/transfer-gui/lib/wss4j.jar
___________________________________________________________________
Name: svn:mime-type
+ application/octet-stream
Added: trunk/current/src/cog/modules/transfer-gui/lib/xercesImpl.jar
===================================================================
(Binary files differ)
Property changes on: trunk/current/src/cog/modules/transfer-gui/lib/xercesImpl.jar
___________________________________________________________________
Name: svn:mime-type
+ application/octet-stream
Added: trunk/current/src/cog/modules/transfer-gui/lib/xml4j.jar
===================================================================
(Binary files differ)
Property changes on: trunk/current/src/cog/modules/transfer-gui/lib/xml4j.jar
___________________________________________________________________
Name: svn:mime-type
+ application/octet-stream
Added: trunk/current/src/cog/modules/transfer-gui/lib/xmlsec.jar
===================================================================
(Binary files differ)
Property changes on: trunk/current/src/cog/modules/transfer-gui/lib/xmlsec.jar
___________________________________________________________________
Name: svn:mime-type
+ application/octet-stream
This was sent by the SourceForge.net collaborative development platform, the world's largest Open Source development site.
|
|
From: <li...@us...> - 2008-06-23 16:11:31
|
Revision: 2045
http://cogkit.svn.sourceforge.net/cogkit/?rev=2045&view=rev
Author: liuwt
Date: 2008-06-23 09:11:10 -0700 (Mon, 23 Jun 2008)
Log Message:
-----------
Added Paths:
-----------
trunk/current/src/cog/modules/transfer-gui/docs/User Guide for GridFTP and RFT GUI.doc
Removed Paths:
-------------
trunk/current/src/cog/modules/transfer-gui/User Guide for GridFTP and RFT GUI.doc
Deleted: trunk/current/src/cog/modules/transfer-gui/User Guide for GridFTP and RFT GUI.doc
===================================================================
(Binary files differ)
Copied: trunk/current/src/cog/modules/transfer-gui/docs/User Guide for GridFTP and RFT GUI.doc (from rev 2044, trunk/current/src/cog/modules/transfer-gui/User Guide for GridFTP and RFT GUI.doc)
===================================================================
(Binary files differ)
This was sent by the SourceForge.net collaborative development platform, the world's largest Open Source development site.
|
|
From: <li...@us...> - 2008-06-23 16:10:52
|
Revision: 2044
http://cogkit.svn.sourceforge.net/cogkit/?rev=2044&view=rev
Author: liuwt
Date: 2008-06-23 09:10:33 -0700 (Mon, 23 Jun 2008)
Log Message:
-----------
Added Paths:
-----------
trunk/current/src/cog/modules/transfer-gui/docs/todo.txt
Removed Paths:
-------------
trunk/current/src/cog/modules/transfer-gui/todo.txt
Copied: trunk/current/src/cog/modules/transfer-gui/docs/todo.txt (from rev 2043, trunk/current/src/cog/modules/transfer-gui/todo.txt)
===================================================================
--- trunk/current/src/cog/modules/transfer-gui/docs/todo.txt (rev 0)
+++ trunk/current/src/cog/modules/transfer-gui/docs/todo.txt 2008-06-23 16:10:33 UTC (rev 2044)
@@ -0,0 +1,9 @@
+Todo list:
+1. The GUI is based on OGCE now, we need to transfer it to Cog4 first. This task involves some interface changes.
+2. merge "Generate Credential" button and "Myproxy" button into one "authentication" button. When users click it, a dialog will popup and
+ provide two options for users:
+ 1) generate a proxy from local certificate;
+ 2) get a short-term proxy from a Myproxy server;
+ Some explanation text will help users to make a decision and prevent confusion.
+3. Add a "Advanced options" button to replace "RFT" button. Clicking that button will also popup a dialog to set parallel streams,
+ TCP buffer, concurrency and whether reliable transfer is enforced or not.
\ No newline at end of file
Deleted: trunk/current/src/cog/modules/transfer-gui/todo.txt
===================================================================
--- trunk/current/src/cog/modules/transfer-gui/todo.txt 2008-06-23 16:09:26 UTC (rev 2043)
+++ trunk/current/src/cog/modules/transfer-gui/todo.txt 2008-06-23 16:10:33 UTC (rev 2044)
@@ -1,9 +0,0 @@
-Todo list:
-1. The GUI is based on OGCE now, we need to transfer it to Cog4 first. This task involves some interface changes.
-2. merge "Generate Credential" button and "Myproxy" button into one "authentication" button. When users click it, a dialog will popup and
- provide two options for users:
- 1) generate a proxy from local certificate;
- 2) get a short-term proxy from a Myproxy server;
- Some explanation text will help users to make a decision and prevent confusion.
-3. Add a "Advanced options" button to replace "RFT" button. Clicking that button will also popup a dialog to set parallel streams,
- TCP buffer, concurrency and whether reliable transfer is enforced or not.
\ No newline at end of file
This was sent by the SourceForge.net collaborative development platform, the world's largest Open Source development site.
|
|
From: <li...@us...> - 2008-06-23 16:09:40
|
Revision: 2043
http://cogkit.svn.sourceforge.net/cogkit/?rev=2043&view=rev
Author: liuwt
Date: 2008-06-23 09:09:26 -0700 (Mon, 23 Jun 2008)
Log Message:
-----------
Added Paths:
-----------
trunk/current/src/cog/modules/transfer-gui/docs/Notes
Removed Paths:
-------------
trunk/current/src/cog/modules/transfer-gui/Notes
Deleted: trunk/current/src/cog/modules/transfer-gui/Notes
===================================================================
--- trunk/current/src/cog/modules/transfer-gui/Notes 2008-06-23 16:07:30 UTC (rev 2042)
+++ trunk/current/src/cog/modules/transfer-gui/Notes 2008-06-23 16:09:26 UTC (rev 2043)
@@ -1,2 +0,0 @@
-www.globus.org
-/www/www-unix.globus.org/cog/demo/ogce
\ No newline at end of file
Copied: trunk/current/src/cog/modules/transfer-gui/docs/Notes (from rev 2042, trunk/current/src/cog/modules/transfer-gui/Notes)
===================================================================
--- trunk/current/src/cog/modules/transfer-gui/docs/Notes (rev 0)
+++ trunk/current/src/cog/modules/transfer-gui/docs/Notes 2008-06-23 16:09:26 UTC (rev 2043)
@@ -0,0 +1,2 @@
+www.globus.org
+/www/www-unix.globus.org/cog/demo/ogce
\ No newline at end of file
This was sent by the SourceForge.net collaborative development platform, the world's largest Open Source development site.
|
|
From: <li...@us...> - 2008-06-23 16:07:33
|
Revision: 2042
http://cogkit.svn.sourceforge.net/cogkit/?rev=2042&view=rev
Author: liuwt
Date: 2008-06-23 09:07:30 -0700 (Mon, 23 Jun 2008)
Log Message:
-----------
Added Paths:
-----------
trunk/current/src/cog/modules/transfer-gui/Notes
trunk/current/src/cog/modules/transfer-gui/User Guide for GridFTP and RFT GUI.doc
trunk/current/src/cog/modules/transfer-gui/todo.txt
Added: trunk/current/src/cog/modules/transfer-gui/Notes
===================================================================
--- trunk/current/src/cog/modules/transfer-gui/Notes (rev 0)
+++ trunk/current/src/cog/modules/transfer-gui/Notes 2008-06-23 16:07:30 UTC (rev 2042)
@@ -0,0 +1,2 @@
+www.globus.org
+/www/www-unix.globus.org/cog/demo/ogce
\ No newline at end of file
Added: trunk/current/src/cog/modules/transfer-gui/User Guide for GridFTP and RFT GUI.doc
===================================================================
(Binary files differ)
Property changes on: trunk/current/src/cog/modules/transfer-gui/User Guide for GridFTP and RFT GUI.doc
___________________________________________________________________
Name: svn:mime-type
+ application/octet-stream
Added: trunk/current/src/cog/modules/transfer-gui/todo.txt
===================================================================
--- trunk/current/src/cog/modules/transfer-gui/todo.txt (rev 0)
+++ trunk/current/src/cog/modules/transfer-gui/todo.txt 2008-06-23 16:07:30 UTC (rev 2042)
@@ -0,0 +1,9 @@
+Todo list:
+1. The GUI is based on OGCE now, we need to transfer it to Cog4 first. This task involves some interface changes.
+2. merge "Generate Credential" button and "Myproxy" button into one "authentication" button. When users click it, a dialog will popup and
+ provide two options for users:
+ 1) generate a proxy from local certificate;
+ 2) get a short-term proxy from a Myproxy server;
+ Some explanation text will help users to make a decision and prevent confusion.
+3. Add a "Advanced options" button to replace "RFT" button. Clicking that button will also popup a dialog to set parallel streams,
+ TCP buffer, concurrency and whether reliable transfer is enforced or not.
\ No newline at end of file
This was sent by the SourceForge.net collaborative development platform, the world's largest Open Source development site.
|
|
From: <li...@us...> - 2008-06-23 16:05:30
|
Revision: 2041
http://cogkit.svn.sourceforge.net/cogkit/?rev=2041&view=rev
Author: liuwt
Date: 2008-06-23 09:05:11 -0700 (Mon, 23 Jun 2008)
Log Message:
-----------
Added Paths:
-----------
trunk/current/src/cog/modules/transfer-gui/docs/
This was sent by the SourceForge.net collaborative development platform, the world's largest Open Source development site.
|
|
From: <ha...@us...> - 2008-06-19 19:49:38
|
Revision: 2040
http://cogkit.svn.sourceforge.net/cogkit/?rev=2040&view=rev
Author: hategan
Date: 2008-06-19 12:49:09 -0700 (Thu, 19 Jun 2008)
Log Message:
-----------
added transfer tool module
Added Paths:
-----------
trunk/current/src/cog/modules/transfer-gui/
trunk/current/src/cog/modules/transfer-gui/build.xml
trunk/current/src/cog/modules/transfer-gui/dependencies.xml
trunk/current/src/cog/modules/transfer-gui/etc/
trunk/current/src/cog/modules/transfer-gui/etc/MANIFEST.MF.head
trunk/current/src/cog/modules/transfer-gui/etc/MANIFEST.MF.tail
trunk/current/src/cog/modules/transfer-gui/etc/log4j.properties.module
trunk/current/src/cog/modules/transfer-gui/launchers.xml
trunk/current/src/cog/modules/transfer-gui/lib/
trunk/current/src/cog/modules/transfer-gui/project.properties
trunk/current/src/cog/modules/transfer-gui/src/
trunk/current/src/cog/modules/transfer-gui/src/org/
trunk/current/src/cog/modules/transfer-gui/src/org/globus/
trunk/current/src/cog/modules/transfer-gui/src/org/globus/transfer/
trunk/current/src/cog/modules/transfer-gui/src/org/globus/transfer/reliable/
trunk/current/src/cog/modules/transfer-gui/src/org/globus/transfer/reliable/client/
trunk/current/src/cog/modules/transfer-gui/src/org/globus/transfer/reliable/client/BaseRFTClient.java
trunk/current/src/cog/modules/transfer-gui/src/org/globus/transfer/reliable/client/GridFTPGUIAboutBox.java
trunk/current/src/cog/modules/transfer-gui/src/org/globus/transfer/reliable/client/GridFTPGUIApp.java
trunk/current/src/cog/modules/transfer-gui/src/org/globus/transfer/reliable/client/GridFTPGUIView.java
trunk/current/src/cog/modules/transfer-gui/src/org/globus/transfer/reliable/client/RFTButtonActionListener.java
trunk/current/src/cog/modules/transfer-gui/src/org/globus/transfer/reliable/client/RFTClient.java
trunk/current/src/cog/modules/transfer-gui/src/org/globus/transfer/reliable/client/RFTJob.java
trunk/current/src/cog/modules/transfer-gui/src/org/globus/transfer/reliable/client/RFTOptions.java
trunk/current/src/cog/modules/transfer-gui/src/org/globus/transfer/reliable/client/RFTOptionsPanel.java
trunk/current/src/cog/modules/transfer-gui/src/org/globus/transfer/reliable/client/RFTPanel.java
trunk/current/src/cog/modules/transfer-gui/src/org/globus/transfer/reliable/client/RFTTransferFileParser.java
trunk/current/src/cog/modules/transfer-gui/src/org/globus/transfer/reliable/client/RFTTransferParam.java
trunk/current/src/cog/modules/transfer-gui/src/org/globus/transfer/reliable/client/RFTTransferParamPanel.java
trunk/current/src/cog/modules/transfer-gui/src/org/globus/transfer/reliable/client/ReliableFileDeleteClient.java
trunk/current/src/cog/modules/transfer-gui/src/org/globus/transfer/reliable/client/ReliableFileTransferClient.java
trunk/current/src/cog/modules/transfer-gui/src/org/globus/transfer/reliable/client/client-security-config.xml
trunk/current/src/cog/modules/transfer-gui/src/org/globus/transfer/reliable/client/myproxy/
trunk/current/src/cog/modules/transfer-gui/src/org/globus/transfer/reliable/client/myproxy/MyProxyLogon.java
trunk/current/src/cog/modules/transfer-gui/src/org/globus/transfer/reliable/client/myproxy/MyProxyLogonGUI.java
trunk/current/src/cog/modules/transfer-gui/src/org/globus/transfer/reliable/client/resources/
trunk/current/src/cog/modules/transfer-gui/src/org/globus/transfer/reliable/client/resources/GridFTPGUIAboutBox.properties
trunk/current/src/cog/modules/transfer-gui/src/org/globus/transfer/reliable/client/resources/GridFTPGUIApp.properties
trunk/current/src/cog/modules/transfer-gui/src/org/globus/transfer/reliable/client/resources/GridFTPGUIView.properties
trunk/current/src/cog/modules/transfer-gui/src/org/globus/transfer/reliable/client/resources/LocalFileSystemView.properties
trunk/current/src/cog/modules/transfer-gui/src/org/globus/transfer/reliable/client/resources/NewJDialog.properties
trunk/current/src/cog/modules/transfer-gui/src/org/globus/transfer/reliable/client/resources/NewJFrame.properties
trunk/current/src/cog/modules/transfer-gui/src/org/globus/transfer/reliable/client/resources/RFTOptionsPanel.properties
trunk/current/src/cog/modules/transfer-gui/src/org/globus/transfer/reliable/client/resources/RFTPanel.properties
trunk/current/src/cog/modules/transfer-gui/src/org/globus/transfer/reliable/client/resources/RFTTransferParamPanel.properties
trunk/current/src/cog/modules/transfer-gui/src/org/globus/transfer/reliable/client/resources/about-small.png
trunk/current/src/cog/modules/transfer-gui/src/org/globus/transfer/reliable/client/resources/about.png
trunk/current/src/cog/modules/transfer-gui/src/org/globus/transfer/reliable/client/resources/busyicons/
trunk/current/src/cog/modules/transfer-gui/src/org/globus/transfer/reliable/client/resources/busyicons/busy-icon0.png
trunk/current/src/cog/modules/transfer-gui/src/org/globus/transfer/reliable/client/resources/busyicons/busy-icon1.png
trunk/current/src/cog/modules/transfer-gui/src/org/globus/transfer/reliable/client/resources/busyicons/busy-icon10.png
trunk/current/src/cog/modules/transfer-gui/src/org/globus/transfer/reliable/client/resources/busyicons/busy-icon11.png
trunk/current/src/cog/modules/transfer-gui/src/org/globus/transfer/reliable/client/resources/busyicons/busy-icon12.png
trunk/current/src/cog/modules/transfer-gui/src/org/globus/transfer/reliable/client/resources/busyicons/busy-icon13.png
trunk/current/src/cog/modules/transfer-gui/src/org/globus/transfer/reliable/client/resources/busyicons/busy-icon14.png
trunk/current/src/cog/modules/transfer-gui/src/org/globus/transfer/reliable/client/resources/busyicons/busy-icon2.png
trunk/current/src/cog/modules/transfer-gui/src/org/globus/transfer/reliable/client/resources/busyicons/busy-icon3.png
trunk/current/src/cog/modules/transfer-gui/src/org/globus/transfer/reliable/client/resources/busyicons/busy-icon4.png
trunk/current/src/cog/modules/transfer-gui/src/org/globus/transfer/reliable/client/resources/busyicons/busy-icon5.png
trunk/current/src/cog/modules/transfer-gui/src/org/globus/transfer/reliable/client/resources/busyicons/busy-icon6.png
trunk/current/src/cog/modules/transfer-gui/src/org/globus/transfer/reliable/client/resources/busyicons/busy-icon7.png
trunk/current/src/cog/modules/transfer-gui/src/org/globus/transfer/reliable/client/resources/busyicons/busy-icon8.png
trunk/current/src/cog/modules/transfer-gui/src/org/globus/transfer/reliable/client/resources/busyicons/busy-icon9.png
trunk/current/src/cog/modules/transfer-gui/src/org/globus/transfer/reliable/client/resources/busyicons/idle-icon.png
trunk/current/src/cog/modules/transfer-gui/src/org/globus/transfer/reliable/client/resources/rft.png
trunk/current/src/cog/modules/transfer-gui/src/org/globus/transfer/reliable/client/resources/splash.png
trunk/current/src/cog/modules/transfer-gui/src/org/globus/transfer/reliable/client/resources/unlock.png
trunk/current/src/cog/modules/transfer-gui/src/org/globus/transfer/reliable/client/resources/window_globus.png
trunk/current/src/cog/modules/transfer-gui/src/org/globus/transfer/reliable/client/resources/window_new.png
trunk/current/src/cog/modules/transfer-gui/src/org/globus/transfer/reliable/client/resources/window_new_ftp.png
trunk/current/src/cog/modules/transfer-gui/src/org/globus/transfer/reliable/client/resources/window_new_gridftp.png
trunk/current/src/cog/modules/transfer-gui/src/org/globus/transfer/reliable/client/utils/
trunk/current/src/cog/modules/transfer-gui/src/org/globus/transfer/reliable/client/utils/LogFileUtils.java
trunk/current/src/cog/modules/transfer-gui/src/org/globus/transfer/reliable/client/utils/UIConstants.java
trunk/current/src/cog/modules/transfer-gui/src/org/globus/transfer/reliable/client/utils/Utils.java
trunk/current/src/cog/modules/transfer-gui/src/org/globus/transfer/reliable/client/webstart/
trunk/current/src/cog/modules/transfer-gui/src/org/globus/transfer/reliable/client/webstart/ProgramStarter.java
Added: trunk/current/src/cog/modules/transfer-gui/build.xml
===================================================================
--- trunk/current/src/cog/modules/transfer-gui/build.xml (rev 0)
+++ trunk/current/src/cog/modules/transfer-gui/build.xml 2008-06-19 19:49:09 UTC (rev 2040)
@@ -0,0 +1,167 @@
+<!-- ===================================================================
+ This code is developed as part of the Java CoG Kit project
+ The terms of the license can be found at http://www.cogkit.org/license
+ This message may not be removed or altered.
+==================================================================== -->
+
+<project name="Java CoG Kit" default="dist" basedir=".">
+
+ <property file="project.properties"/>
+ <property name="cog.dir" value="${basedir}/../../"/>
+ <property name="main.buildfile" value="${cog.dir}/mbuild.xml"/>
+ <property name="dist.dir" value="${cog.dir}/modules/${module.name}/dist/${module.name}-${version}"/>
+ <property name="build.dir" value="${cog.dir}/modules/${module.name}/build"/>
+
+ <!-- ================================================ -->
+ <!-- Help -->
+ <!-- ================================================ -->
+
+ <target name="help">
+ <echo>
+ Available targets:
+ help:
+ prints out this help message
+
+ dist:
+ creates a distribution directory of the
+ ${project} ${long.name}
+
+ jar:
+ creates a jar file for the ${project} ${long.name}
+ named ${jar.filename}
+
+ javadoc:
+ creates the documentation
+
+ clean:
+ removes the compiled classes
+
+ distclean:
+ deletes the distribution directory
+
+ all:
+ dist and javadoc
+
+ deploy.webstart:
+ deploys the module as a webstart application
+
+ dist.joint:
+ builds everything into one jar file. Should only
+ be used globally (from all)
+
+ fixeol:
+ change newlines to the unix standard
+ </echo>
+ </target>
+
+
+ <!-- ================================================ -->
+ <!-- Dist -->
+ <!-- ================================================ -->
+
+ <target name="dist">
+ <ant antfile="${main.buildfile}" target="dist"/>
+ </target>
+
+
+ <!-- ================================================ -->
+ <!-- Compile -->
+ <!-- ================================================ -->
+
+ <target name="compile">
+ <ant antfile="${main.buildfile}" target="compile"/>
+ </target>
+
+ <!-- ================================================ -->
+ <!-- Clean -->
+ <!-- ================================================ -->
+
+ <target name="clean">
+ <ant antfile="${main.buildfile}" target="clean"/>
+ </target>
+
+
+ <!-- ================================================ -->
+ <!-- Distclean -->
+ <!-- ================================================ -->
+
+ <target name="distclean">
+ <ant antfile="${main.buildfile}" target="distclean"/>
+ </target>
+
+
+ <!-- ================================================ -->
+ <!-- Jar -->
+ <!-- ================================================ -->
+
+ <target name="jar">
+ <ant antfile="${main.buildfile}" target="jar"/>
+ </target>
+
+
+
+ <!-- ================================================ -->
+ <!-- Javadoc -->
+ <!-- ================================================ -->
+
+ <target name="javadoc">
+ <ant antfile="${main.buildfile}" target="javadoc"/>
+ </target>
+
+
+
+ <!-- ================================================ -->
+ <!-- PMD -->
+ <!-- ================================================ -->
+
+ <target name="pmd">
+ <ant antfile="${main.buildfile}" target="pmd"/>
+ </target>
+
+ <!-- ================================================ -->
+ <!-- deploy.webstart -->
+ <!-- ================================================ -->
+
+ <target name="deploy.webstart">
+ <ant antfile="${main.buildfile}" target="deploy.webstart"/>
+ </target>
+
+ <!-- ================================================ -->
+ <!-- replacelibs -->
+ <!-- ================================================ -->
+
+ <target name="replacelibs">
+ <ant antfile="${main.buildfile}" target="replacelibs"/>
+ </target>
+
+ <!-- ================================================ -->
+ <!-- webstart.launchers -->
+ <!-- ================================================ -->
+
+ <target name="webstart.launchers">
+ <ant antfile="${main.buildfile}" target="webstart.launchers"/>
+ </target>
+
+ <!-- ================================================ -->
+ <!-- dist.joint -->
+ <!-- ================================================ -->
+
+ <target name="dist.joint">
+ <ant antfile="${main.buildfile}" target="dist.all"/>
+ </target>
+ <!-- ================================================ -->
+ <!-- fixeol -->
+ <!-- ================================================ -->
+
+ <target name="fixeol">
+ <ant antfile="${main.buildfile}" target="fixeol"/>
+ </target>
+
+
+ <target name="module.package">
+ <ant antfile="${main.buildfile}" target="module.package"/>
+ </target>
+
+</project>
+
+
Added: trunk/current/src/cog/modules/transfer-gui/dependencies.xml
===================================================================
--- trunk/current/src/cog/modules/transfer-gui/dependencies.xml (rev 0)
+++ trunk/current/src/cog/modules/transfer-gui/dependencies.xml 2008-06-19 19:49:09 UTC (rev 2040)
@@ -0,0 +1,20 @@
+<!-- ===================================================================
+ This code is developed as part of the Java CoG Kit project
+ The terms of the license can be found at http://www.cogkit.org/license
+ This message may not be removed or altered.
+==================================================================== -->
+
+<project name="Project dependencies" default="deps" basedir=".">
+ <!-- project dependencies -->
+ <target name="deps">
+ <ant antfile="${main.buildfile}" target="dep">
+ <property name="module" value="abstraction"/>
+ </ant>
+ <ant antfile="${main.buildfile}" target="dep">
+ <property name="module" value="resources"/>
+ </ant>
+ <ant antfile="${main.buildfile}" target="dep">
+ <property name="module" value="util"/>
+ </ant>
+ </target>
+</project>
Added: trunk/current/src/cog/modules/transfer-gui/etc/MANIFEST.MF.head
===================================================================
--- trunk/current/src/cog/modules/transfer-gui/etc/MANIFEST.MF.head (rev 0)
+++ trunk/current/src/cog/modules/transfer-gui/etc/MANIFEST.MF.head 2008-06-19 19:49:09 UTC (rev 2040)
@@ -0,0 +1 @@
+Manifest-Version: 1.0
Added: trunk/current/src/cog/modules/transfer-gui/etc/MANIFEST.MF.tail
===================================================================
--- trunk/current/src/cog/modules/transfer-gui/etc/MANIFEST.MF.tail (rev 0)
+++ trunk/current/src/cog/modules/transfer-gui/etc/MANIFEST.MF.tail 2008-06-19 19:49:09 UTC (rev 2040)
@@ -0,0 +1 @@
+
Added: trunk/current/src/cog/modules/transfer-gui/etc/log4j.properties.module
===================================================================
--- trunk/current/src/cog/modules/transfer-gui/etc/log4j.properties.module (rev 0)
+++ trunk/current/src/cog/modules/transfer-gui/etc/log4j.properties.module 2008-06-19 19:49:09 UTC (rev 2040)
@@ -0,0 +1 @@
+log4j.logger.org.globus.cog.example=INFO
Added: trunk/current/src/cog/modules/transfer-gui/launchers.xml
===================================================================
--- trunk/current/src/cog/modules/transfer-gui/launchers.xml (rev 0)
+++ trunk/current/src/cog/modules/transfer-gui/launchers.xml 2008-06-19 19:49:09 UTC (rev 2040)
@@ -0,0 +1,30 @@
+<!-- ===================================================================
+ This code is developed as part of the Java CoG Kit project
+ The terms of the license can be found at http://www.cogkit.org/license
+ This message may not be removed or altered.
+==================================================================== -->
+
+<project name="Launchers" default="create" basedir=".">
+ <target name="create">
+ <ant antfile="${main.buildfile}" target="launcher">
+ <property name="launcher-name" value="sample-launcher"/>
+ <property name="class-name" value="org.globus.cog.example.Class"/>
+ </ant>
+ </target>
+ <target name="webstart">
+ <ant antfile="${main.buildfile}" target="webstart.launcher">
+ <property name="launcher-name" value="sample-app"/>
+ <property name="class-name" value="org.globus.cog.example.Class"/>
+ <property name="launcher-description" value="Example Application"/>
+ </ant>
+ <ant antfile="${main.buildfile}" target="webstart.launcher">
+ <property name="launcher-name" value="sample-applet"/>
+ <property name="class-name" value="org.globus.cog.example.Applet"/>
+ <property name="launcher-description" value="Example Application"/>
+ <property name="applet" value="true"/>
+ <property name="width" value="320"/>
+ <property name="height" value="240"/>
+ <property name="applet-params" value="<param name="param1" value="value1"/>"/>
+ </ant>
+ </target>
+</project>
Added: trunk/current/src/cog/modules/transfer-gui/project.properties
===================================================================
--- trunk/current/src/cog/modules/transfer-gui/project.properties (rev 0)
+++ trunk/current/src/cog/modules/transfer-gui/project.properties 2008-06-19 19:49:09 UTC (rev 2040)
@@ -0,0 +1,12 @@
+#===================================================================
+# This code is developed as part of the Java CoG Kit project
+# The terms of the license can be found at http://www.cogkit.org/license
+# This message may not be removed or altered.
+#====================================================================
+#
+module.name = transfer-gui
+long.name = File Transfer Graphical Interface
+version = 0.1
+project = Java CoG Kit
+lib.deps = -
+
Added: trunk/current/src/cog/modules/transfer-gui/src/org/globus/transfer/reliable/client/BaseRFTClient.java
===================================================================
--- trunk/current/src/cog/modules/transfer-gui/src/org/globus/transfer/reliable/client/BaseRFTClient.java (rev 0)
+++ trunk/current/src/cog/modules/transfer-gui/src/org/globus/transfer/reliable/client/BaseRFTClient.java 2008-06-19 19:49:09 UTC (rev 2040)
@@ -0,0 +1,414 @@
+/*
+ * Portions of this file Copyright 1999-2005 University of Chicago
+ * Portions of this file Copyright 1999-2005 The University of Southern California.
+ *
+ * This file or a portion of this file is licensed under the
+ * terms of the Globus Toolkit Public License, found at
+ * http://www.globus.org/toolkit/download/license.html.
+ * If you redistribute this file, with or without
+ * modifications, you must include this notice in the file.
+ */
+package org.globus.transfer.reliable.client;
+
+import java.net.URL;
+import java.security.cert.X509Certificate;
+import java.util.Calendar;
+import java.util.List;
+import java.util.Vector;
+import java.util.Map;
+import java.util.HashMap;
+
+import javax.xml.rpc.Stub;
+
+import org.globus.axis.util.Util;
+
+import org.apache.axis.message.addressing.EndpointReferenceType;
+import org.apache.commons.logging.Log;
+import org.apache.commons.logging.LogFactory;
+import org.globus.delegation.DelegationConstants;
+import org.globus.delegation.DelegationUtil;
+import org.globus.gsi.GlobusCredential;
+import org.globus.wsrf.impl.security.util.AuthUtil;
+import org.globus.ogsa.impl.security.authorization.SelfAuthorization;
+import org.globus.rft.generated.BaseRequestType;
+import org.globus.rft.generated.CreateReliableFileTransferInputType;
+import org.globus.rft.generated.CreateReliableFileTransferOutputType;
+import org.globus.rft.generated.DeleteRequestType;
+import org.globus.rft.generated.OverallStatus;
+import org.globus.rft.generated.RFTFaultResourcePropertyType;
+import org.globus.rft.generated.ReliableFileTransferFactoryPortType;
+import org.globus.rft.generated.ReliableFileTransferPortType;
+import org.globus.rft.generated.TransferRequestType;
+import org.globus.rft.generated.service.ReliableFileTransferFactoryServiceAddressingLocator;
+import org.globus.rft.generated.service.ReliableFileTransferServiceAddressingLocator;
+import org.globus.transfer.reliable.client.utils.LogFileUtils;
+import org.globus.transfer.reliable.service.RFTConstants;
+
+import org.globus.wsrf.container.ServiceContainer;
+import org.globus.wsrf.NotificationConsumerManager;
+import org.globus.wsrf.NotifyCallback;
+import org.globus.wsrf.WSNConstants;
+import org.globus.wsrf.client.BaseClient;
+import org.globus.wsrf.core.notification.ResourcePropertyValueChangeNotificationElementType;
+import org.globus.wsrf.impl.security.authorization.Authorization;
+import org.globus.wsrf.impl.security.authorization.HostAuthorization;
+import org.globus.wsrf.impl.security.authorization.ResourcePDPConfig;
+import org.globus.wsrf.impl.security.authorization.ServiceAuthorizationChain;
+import org.globus.wsrf.impl.security.descriptor.GSISecureMsgAuthMethod;
+import org.globus.wsrf.impl.security.descriptor.GSISecureConvAuthMethod;
+import org.globus.wsrf.impl.security.descriptor.GSITransportAuthMethod;
+import org.globus.wsrf.impl.security.descriptor.ResourceSecurityDescriptor;
+import org.globus.wsrf.impl.security.descriptor.ClientSecurityDescriptor;
+import org.globus.wsrf.security.Constants;
+import org.globus.wsrf.utils.AddressingUtils;
+import org.oasis.wsn.Subscribe;
+import org.oasis.wsn.TopicExpressionType;
+import org.oasis.wsrf.faults.BaseFaultType;
+import org.oasis.wsrf.properties.ResourcePropertyValueChangeNotificationType;
+
+/**
+ * BaseClient for RFT service
+ */
+public class BaseRFTClient extends BaseClient implements NotifyCallback {
+ private static Log logger = LogFactory.getLog(BaseRFTClient.class);
+ public static ReliableFileTransferServiceAddressingLocator rftLocator =
+ new ReliableFileTransferServiceAddressingLocator();
+
+ static final String SERVICE_URL_ROOT = "/wsrf/services/";
+
+ public static ReliableFileTransferFactoryServiceAddressingLocator
+ rftFactoryLocator =
+ new ReliableFileTransferFactoryServiceAddressingLocator();
+
+ private static ReliableFileTransferFactoryPortType factoryPort;
+
+ private static NotificationConsumerManager consumer = null;
+
+ public static int transferCount = 0;
+
+ public static int finished = 0;
+
+ public static int failed = 0;
+
+
+ public static URL endpoint = null;
+
+ public static String HOST = "127.0.0.1";
+
+ public static String PORT = null;
+
+ public static String PROTOCOL = "http";
+
+ public static int TERM_TIME = 60;
+
+ public static String PATH_TO_FILE = null;
+
+ public static String AUTHZ = "host";
+
+ public static String cmd[];
+
+ public static String outFileName = null;
+
+ public static Object authType = Constants.GSI_TRANSPORT;
+
+ public static Object authVal = Constants.SIGNATURE;
+
+ public static Authorization authzVal = HostAuthorization.getInstance();
+
+ public static String optionString =
+ "rft [options] -f <path to transfers file>\n"
+ + "Where options can be:\n"
+ + "-h <hostname or ip-address of container> Defaults to 'localhost'.\n"
+ + "-r <port on which container is listening> Defaults to TCP port 8443.\n"
+ + "-l lifetime of the created resource in minutes Defaults to 60 mins.\n"
+ + "-m security mechanism Allowed values: 'msg' for secure messages, 'conv' for\n"
+ + " secure conversation and 'trans' for secure transport. Defaults to \n"
+ + " 'trans'.\n"
+ + " -p protection type Allowed values: 'sig' for signature and 'enc' for encryption.\n"
+ + " Defaults to 'sig'.\n"
+ + " -z authorization Defaults to 'host' authorization. Allowed values: 'self' for\n"
+ + " self authorization and 'host' for host authorization.\n"
+ + " -file filename to write EPR of created Reliable"
+ + " File Transfer Resource\n";
+
+ static {
+ Util.registerTransport();
+ }
+
+
+ public BaseRFTClient() {
+ super();
+ }
+
+ public static void parseArgs() {
+ for(int i =0; i< cmd.length; i++) {
+ if ((cmd[i].equals("--help")) || (cmd[i].equals("-help"))) {
+ System.out.println( optionString );
+ System.exit(0);
+ } else if(cmd[i].equals("-h")) {
+ HOST = getValue(i);
+ i++;
+ } else if(cmd[i].equals("-r")) {
+ PORT = getValue(i);
+ i++;
+ } else if(cmd[i].equals("-l")) {
+ TERM_TIME = Integer.parseInt(getValue(i));
+ i++;
+ } else if(cmd[i].equals("-z")) {
+ AUTHZ = getValue(i);
+ authzVal = AuthUtil.getClientAuthorization(AUTHZ);
+ i++;
+ } else if(cmd[i].equals("-m")) {
+ String secType = getValue(i);
+ if (secType.equals("msg")) {
+ authType = Constants.GSI_SEC_MSG;
+ } else if (secType.equals("conv")) {
+ authType = Constants.GSI_SEC_CONV;
+ } else if(secType.equals("trans")) {
+ authType = Constants.GSI_TRANSPORT;
+ }
+ } else if (cmd[i].equals("-p")) {
+ String prot = getValue(i);
+ if (prot.equals("sig")) {
+ authVal = Constants.SIGNATURE;
+ } else if(prot.equals("enc")) {
+ authVal = Constants.ENCRYPTION;
+ }
+ } else if (cmd[i].equals("-file")) {
+ outFileName = getValue(i);
+ } else if (cmd[i].equals("-f")) {
+ PATH_TO_FILE = getValue(i);
+ }
+ }
+ if (PATH_TO_FILE == null) {
+ printUsage();
+ System.exit(-1);
+ }
+ }
+ protected static String getValue(int i) {
+ if (i + 1 > cmd.length) {
+ System.err.println(cmd[i] + " needs a argument");
+ System.exit(-1);
+ }
+ return cmd[i+1];
+ }
+
+ /**
+ * @param request
+ * @return rft epr
+ * @exception Exception
+ */
+ public static EndpointReferenceType createRFT(String rftFactoryAddress,
+ BaseRequestType request)
+ throws Exception {
+ endpoint = new URL(rftFactoryAddress);
+ factoryPort = rftFactoryLocator
+ .getReliableFileTransferFactoryPortTypePort(endpoint);
+ CreateReliableFileTransferInputType input =
+ new CreateReliableFileTransferInputType();
+ //input.setTransferJob(transferType);
+ if(request instanceof TransferRequestType) {
+ input.setTransferRequest((TransferRequestType)request);
+ } else {
+ input.setDeleteRequest((DeleteRequestType)request);
+ }
+ Calendar termTime = Calendar.getInstance();
+ termTime.add(Calendar.HOUR, 1);
+ input.setInitialTerminationTime(termTime);
+ setSecurity((Stub)factoryPort);
+ CreateReliableFileTransferOutputType response = factoryPort
+ .createReliableFileTransfer(input);
+
+ return response.getReliableTransferEPR();
+ }
+ /**
+ * Prints the usage
+ */
+ public static void printUsage() {
+ System.out.println(optionString);
+ }
+ /**
+ *
+ * @param topicPath
+ * @param producer
+ * @param message
+ */
+ public void deliver(List topicPath, EndpointReferenceType producer,
+ Object message) {
+ ResourcePropertyValueChangeNotificationType changeMessage =
+ ((ResourcePropertyValueChangeNotificationElementType) message)
+ .getResourcePropertyValueChangeNotification();
+ BaseFaultType fault = null;
+ try {
+
+ if (changeMessage != null) {
+
+ OverallStatus overallStatus = (OverallStatus) changeMessage
+ .getNewValue().get_any()[0].getValueAsType(
+ RFTConstants.OVERALL_STATUS_RESOURCE,
+ OverallStatus.class);
+ System.out.println("\n Overall status of transfer:");
+ System.out.println("Finished/Active/Failed/Retrying/Pending");
+ System.out.print(overallStatus.getTransfersFinished() + "/");
+ System.out.print(overallStatus.getTransfersActive() + "/");
+ System.out.print(overallStatus.getTransfersFailed() + "/");
+ System.out.print(overallStatus.getTransfersRestarted() + "/");
+ System.out.println(overallStatus.getTransfersPending());
+ if ( finished < overallStatus.getTransfersFinished()) {
+ finished = overallStatus.getTransfersFinished();
+ }
+ if (failed < overallStatus.getTransfersFailed()) {
+ failed = overallStatus.getTransfersFailed();
+ }
+ transferCount = overallStatus.getTransfersFinished() + overallStatus.getTransfersActive()
+ + overallStatus.getTransfersFailed() + overallStatus.getTransfersRestarted()
+ + overallStatus.getTransfersPending();
+ RFTFaultResourcePropertyType faultRP = overallStatus.getFault();
+ if(faultRP != null) {
+ fault = getFaultFromRP(faultRP);
+ }
+ if (fault != null) {
+ System.err.println("Error:" + fault.getDescription(0));
+ }
+
+ }
+ } catch (Exception e) {
+ logger.debug(e.getMessage(), e);
+ System.err.println(e.getMessage());
+ }
+ }
+
+ /**
+ * @param host
+ * @param port
+ * @return
+ * @throws Exception
+ */
+ public static EndpointReferenceType
+ delegateCredential(String host, String port) throws Exception {
+ ClientSecurityDescriptor desc = getClientSecDesc();
+ // Credential to sign with, assuming default credential
+ GlobusCredential credential = GlobusCredential.getDefaultCredential();
+
+ String factoryUrl = PROTOCOL + "://" + host + ":"
+ + port + SERVICE_URL_ROOT
+ + DelegationConstants.FACTORY_PATH;
+
+ // lifetime in seconds
+ int lifetime = TERM_TIME * 60;
+
+ // Get the public key to delegate on.
+ EndpointReferenceType delegEpr = AddressingUtils
+ .createEndpointReference(factoryUrl, null);
+ X509Certificate[] certsToDelegateOn = DelegationUtil
+ .getCertificateChainRP(delegEpr, desc);
+ X509Certificate certToSign = certsToDelegateOn[0];
+
+ // send to delegation service and get epr.
+ // Authz set to null, so HostAuthz will be done.
+ return DelegationUtil.delegate(factoryUrl,
+ credential, certToSign, lifetime, false,
+ desc);
+ }
+
+ public static void setSecurity(Stub stub) {
+ stub._setProperty(Constants.CLIENT_DESCRIPTOR,
+ getClientSecDesc());
+ }
+
+ public static void
+ subscribe(ReliableFileTransferPortType rft)
+ throws Exception {
+ Subscribe request = new Subscribe();
+ request.setUseNotify(Boolean.TRUE);
+ if(PROTOCOL.equals("http")) {
+ consumer = NotificationConsumerManager.getInstance();
+ } else if (PROTOCOL.equals("https")) {
+ Map properties = new HashMap();
+ properties.put(ServiceContainer.CLASS,
+ "org.globus.wsrf.container.GSIServiceContainer");
+ consumer = NotificationConsumerManager.getInstance(properties);
+ }
+ consumer.startListening();
+ EndpointReferenceType consumerEPR = null;
+ ResourceSecurityDescriptor resDesc = new ResourceSecurityDescriptor();
+ Vector authMethod = new Vector();
+ if(AUTHZ.equalsIgnoreCase("host")) {
+ ResourcePDPConfig pdpConfig = new ResourcePDPConfig("host");
+ pdpConfig.setProperty(Authorization.HOST_PREFIX,
+ HostAuthorization.URL_PROPERTY,endpoint);
+ ServiceAuthorizationChain authz = new ServiceAuthorizationChain();
+ authz.initialize(pdpConfig, "chainName", "someId");
+ resDesc.setAuthzChain(authz);
+ } else if(AUTHZ.equalsIgnoreCase("self")) {
+ resDesc.setAuthz("self");
+ }
+ if (PROTOCOL.equals("http")) {
+ if (authType.equals(Constants.GSI_SEC_MSG)) {
+ authMethod.add(GSISecureMsgAuthMethod.BOTH);
+ } else if (authType.equals(Constants.GSI_SEC_CONV)) {
+ authMethod.add(GSISecureConvAuthMethod.BOTH);
+ }
+ } else if (PROTOCOL.equals("https")) {
+ authMethod.add(GSITransportAuthMethod.BOTH);
+ }
+ resDesc.setAuthMethods(authMethod);
+ consumerEPR = consumer.createNotificationConsumer(
+ new BaseRFTClient(), resDesc);
+ request.setConsumerReference(consumerEPR);
+ TopicExpressionType topicExpression = new TopicExpressionType();
+ topicExpression.setDialect(WSNConstants.SIMPLE_TOPIC_DIALECT);
+ topicExpression.setValue(RFTConstants.OVERALL_STATUS_RESOURCE);
+ request.setTopicExpression(topicExpression);
+
+ rft.subscribe(request);
+ }
+
+ private BaseFaultType getFaultFromRP(RFTFaultResourcePropertyType faultRP) {
+ if(faultRP.getRftAuthenticationFaultType() != null) {
+ return faultRP.getRftAuthenticationFaultType();
+ } else if(faultRP.getRftAuthorizationFaultType() != null) {
+ return faultRP.getRftAuthorizationFaultType();
+ } else if(faultRP.getRftDatabaseFaultType() != null) {
+ return faultRP.getRftDatabaseFaultType();
+ } else if(faultRP.getRftRepeatedlyStartedFaultType() != null) {
+ return faultRP.getRftRepeatedlyStartedFaultType();
+ } else if(faultRP.getRftTransferFaultType() != null) {
+ return faultRP.getRftTransferFaultType();
+ } else if(faultRP.getTransferTransientFaultType() != null) {
+ return faultRP.getTransferTransientFaultType();
+ } else {
+ return null;
+ }
+ }
+
+ public static void setAuthzValue(String authz) {
+ if ("SELF".equals(authz)) {
+ authzVal = HostAuthorization.getInstance();
+ } else if ("HOST".equals(authz)) {
+ authzVal = HostAuthorization.getInstance();
+ }
+
+ }
+
+ public static ClientSecurityDescriptor getClientSecDesc() {
+ ClientSecurityDescriptor desc = new ClientSecurityDescriptor();
+ if (authType.equals(Constants.GSI_SEC_MSG)) {
+ desc.setGSISecureMsg((Integer)authVal);
+ } else if (authType.equals(Constants.GSI_SEC_CONV)) {
+ desc.setGSISecureConv((Integer)authVal);
+ } else if (authType.equals(Constants.GSI_TRANSPORT)) {
+ desc.setGSITransport((Integer)authVal);
+ Util.registerTransport();
+ }
+ desc.setAuthz(authzVal);
+ return desc;
+ }
+
+ public static ReliableFileTransferFactoryPortType
+ getFactoryPort(String rftFactoryAddress) throws Exception {
+ endpoint = new URL(rftFactoryAddress);
+ return rftFactoryLocator.getReliableFileTransferFactoryPortTypePort(endpoint);
+ }
+
+}
Added: trunk/current/src/cog/modules/transfer-gui/src/org/globus/transfer/reliable/client/GridFTPGUIAboutBox.java
===================================================================
--- trunk/current/src/cog/modules/transfer-gui/src/org/globus/transfer/reliable/client/GridFTPGUIAboutBox.java (rev 0)
+++ trunk/current/src/cog/modules/transfer-gui/src/org/globus/transfer/reliable/client/GridFTPGUIAboutBox.java 2008-06-19 19:49:09 UTC (rev 2040)
@@ -0,0 +1,141 @@
+/*
+ * GridFTPGUIAboutBox.java
+ */
+
+package org.globus.transfer.reliable.client;
+
+import org.jdesktop.application.Action;
+
+public class GridFTPGUIAboutBox extends javax.swing.JDialog {
+
+ public GridFTPGUIAboutBox(java.awt.Frame parent) {
+ super(parent);
+ initComponents();
+ getRootPane().setDefaultButton(closeButton);
+ }
+
+ @Action public void closeAboutBox() {
+ setVisible(false);
+ }
+
+ /** This method is called from within the constructor to
+ * initialize the form.
+ * WARNING: Do NOT modify this code. The content of this method is
+ * always regenerated by the Form Editor.
+ */
+ // <editor-fold defaultstate="collapsed" desc="Generated Code">//GEN-BEGIN:initComponents
+ private void initComponents() {
+
+ closeButton = new javax.swing.JButton();
+ javax.swing.JLabel appTitleLabel = new javax.swing.JLabel();
+ javax.swing.JLabel versionLabel = new javax.swing.JLabel();
+ javax.swing.JLabel appVersionLabel = new javax.swing.JLabel();
+ javax.swing.JLabel vendorLabel = new javax.swing.JLabel();
+ javax.swing.JLabel appVendorLabel = new javax.swing.JLabel();
+ javax.swing.JLabel homepageLabel = new javax.swing.JLabel();
+ javax.swing.JLabel appHomepageLabel = new javax.swing.JLabel();
+ javax.swing.JLabel appDescLabel = new javax.swing.JLabel();
+ imageLabel = new javax.swing.JLabel();
+
+ setDefaultCloseOperation(javax.swing.WindowConstants.DISPOSE_ON_CLOSE);
+ org.jdesktop.application.ResourceMap resourceMap = org.jdesktop.application.Application.getInstance(org.globus.transfer.reliable.client.GridFTPGUIApp.class).getContext().getResourceMap(GridFTPGUIAboutBox.class);
+ setTitle(resourceMap.getString("title")); // NOI18N
+ setModal(true);
+ setName("aboutBox"); // NOI18N
+ setResizable(false);
+
+ javax.swing.ActionMap actionMap = org.jdesktop.application.Application.getInstance(org.globus.transfer.reliable.client.GridFTPGUIApp.class).getContext().getActionMap(GridFTPGUIAboutBox.class, this);
+ closeButton.setAction(actionMap.get("closeAboutBox")); // NOI18N
+ closeButton.setName("closeButton"); // NOI18N
+
+ appTitleLabel.setFont(appTitleLabel.getFont().deriveFont(appTitleLabel.getFont().getStyle() | java.awt.Font.BOLD, appTitleLabel.getFont().getSize()+4));
+ appTitleLabel.setText(resourceMap.getString("Application.title")); // NOI18N
+ appTitleLabel.setName("appTitleLabel"); // NOI18N
+
+ versionLabel.setFont(versionLabel.getFont().deriveFont(versionLabel.getFont().getStyle() | java.awt.Font.BOLD));
+ versionLabel.setText(resourceMap.getString("versionLabel.text")); // NOI18N
+ versionLabel.setName("versionLabel"); // NOI18N
+
+ appVersionLabel.setText(resourceMap.getString("Application.version")); // NOI18N
+ appVersionLabel.setName("appVersionLabel"); // NOI18N
+
+ vendorLabel.setFont(vendorLabel.getFont().deriveFont(vendorLabel.getFont().getStyle() | java.awt.Font.BOLD));
+ vendorLabel.setText(resourceMap.getString("vendorLabel.text")); // NOI18N
+ vendorLabel.setName("vendorLabel"); // NOI18N
+
+ appVendorLabel.setText(resourceMap.getString("Application.vendor")); // NOI18N
+ appVendorLabel.setName("appVendorLabel"); // NOI18N
+
+ homepageLabel.setFont(homepageLabel.getFont().deriveFont(homepageLabel.getFont().getStyle() | java.awt.Font.BOLD));
+ homepageLabel.setText(resourceMap.getString("homepageLabel.text")); // NOI18N
+ homepageLabel.setName("homepageLabel"); // NOI18N
+
+ appHomepageLabel.setText(resourceMap.getString("Application.homepage")); // NOI18N
+ appHomepageLabel.setName("appHomepageLabel"); // NOI18N
+
+ appDescLabel.setText(resourceMap.getString("appDescLabel.text")); // NOI18N
+ appDescLabel.setName("appDescLabel"); // NOI18N
+
+ imageLabel.setIcon(resourceMap.getIcon("imageLabel.icon")); // NOI18N
+ imageLabel.setName("imageLabel"); // NOI18N
+
+ org.jdesktop.layout.GroupLayout layout = new org.jdesktop.layout.GroupLayout(getContentPane());
+ getContentPane().setLayout(layout);
+ layout.setHorizontalGroup(
+ layout.createParallelGroup(org.jdesktop.layout.GroupLayout.LEADING)
+ .add(layout.createSequentialGroup()
+ .addContainerGap()
+ .add(imageLabel)
+ .add(32, 32, 32)
+ .add(layout.createParallelGroup(org.jdesktop.layout.GroupLayout.TRAILING)
+ .add(org.jdesktop.layout.GroupLayout.LEADING, layout.createSequentialGroup()
+ .add(layout.createParallelGroup(org.jdesktop.layout.GroupLayout.LEADING)
+ .add(versionLabel)
+ .add(vendorLabel)
+ .add(homepageLabel))
+ .addPreferredGap(org.jdesktop.layout.LayoutStyle.RELATED)
+ .add(layout.createParallelGroup(org.jdesktop.layout.GroupLayout.LEADING)
+ .add(appVersionLabel)
+ .add(appVendorLabel)
+ .add(appHomepageLabel)))
+ .add(org.jdesktop.layout.GroupLayout.LEADING, appTitleLabel)
+ .add(org.jdesktop.layout.GroupLayout.LEADING, appDescLabel, org.jdesktop.layout.GroupLayout.DEFAULT_SIZE, 368, Short.MAX_VALUE)
+ .add(closeButton))
+ .addContainerGap())
+ );
+ layout.setVerticalGroup(
+ layout.createParallelGroup(org.jdesktop.layout.GroupLayout.LEADING)
+ .add(layout.createSequentialGroup()
+ .add(layout.createParallelGroup(org.jdesktop.layout.GroupLayout.LEADING)
+ .add(org.jdesktop.layout.GroupLayout.TRAILING, layout.createSequentialGroup()
+ .addContainerGap()
+ .add(appTitleLabel)
+ .addPreferredGap(org.jdesktop.layout.LayoutStyle.RELATED)
+ .add(appDescLabel)
+ .addPreferredGap(org.jdesktop.layout.LayoutStyle.RELATED)
+ .add(layout.createParallelGroup(org.jdesktop.layout.GroupLayout.BASELINE)
+ .add(versionLabel)
+ .add(appVersionLabel))
+ .addPreferredGap(org.jdesktop.layout.LayoutStyle.RELATED)
+ .add(layout.createParallelGroup(org.jdesktop.layout.GroupLayout.BASELINE)
+ .add(vendorLabel)
+ .add(appVendorLabel))
+ .addPreferredGap(org.jdesktop.layout.LayoutStyle.RELATED)
+ .add(layout.createParallelGroup(org.jdesktop.layout.GroupLayout.BASELINE)
+ .add(homepageLabel)
+ .add(appHomepageLabel))
+ .add(119, 119, Short.MAX_VALUE)
+ .add(closeButton))
+ .add(imageLabel, org.jdesktop.layout.GroupLayout.DEFAULT_SIZE, 252, Short.MAX_VALUE))
+ .addContainerGap())
+ );
+
+ pack();
+ }// </editor-fold>//GEN-END:initComponents
+
+ // Variables declaration - do not modify//GEN-BEGIN:variables
+ private javax.swing.JButton closeButton;
+ private javax.swing.JLabel imageLabel;
+ // End of variables declaration//GEN-END:variables
+
+}
Added: trunk/current/src/cog/modules/transfer-gui/src/org/globus/transfer/reliable/client/GridFTPGUIApp.java
===================================================================
--- trunk/current/src/cog/modules/transfer-gui/src/org/globus/transfer/reliable/client/GridFTPGUIApp.java (rev 0)
+++ trunk/current/src/cog/modules/transfer-gui/src/org/globus/transfer/reliable/client/GridFTPGUIApp.java 2008-06-19 19:49:09 UTC (rev 2040)
@@ -0,0 +1,48 @@
+/*
+ * GridFTPGUIApp.java
+ */
+
+package org.globus.transfer.reliable.client;
+
+import org.apache.log4j.PropertyConfigurator;
+import org.globus.axis.util.Util;
+import org.jdesktop.application.Application;
+import org.jdesktop.application.SingleFrameApplication;
+
+/**
+ * The main class of the application.
+ */
+public class GridFTPGUIApp extends SingleFrameApplication {
+
+
+ /**
+ * At startup create and show the main frame of the application.
+ */
+ @Override protected void startup() {
+ show(new GridFTPGUIView(this));
+ }
+
+ /**
+ * This method is to initialize the specified window by injecting resources.
+ * Windows shown in our application come fully initialized from the GUI
+ * builder, so this additional configuration is not needed.
+ */
+ @Override protected void configureWindow(java.awt.Window root) {
+ }
+
+ /**
+ * A convenient static getter for the application instance.
+ * @return the instance of GridFTPGUIApp
+ */
+ public static GridFTPGUIApp getApplication() {
+ return Application.getInstance(GridFTPGUIApp.class);
+ }
+
+ /**
+ * Main method launching the application.
+ */
+ public static void main(String[] args) {
+ //PropertyConfigurator.configure("log4j.properties");
+ launch(GridFTPGUIApp.class, args);
+ }
+}
Added: trunk/current/src/cog/modules/transfer-gui/src/org/globus/transfer/reliable/client/GridFTPGUIView.java
===================================================================
--- trunk/current/src/cog/modules/transfer-gui/src/org/globus/transfer/reliable/client/GridFTPGUIView.java (rev 0)
+++ trunk/current/src/cog/modules/transfer-gui/src/org/globus/transfer/reliable/client/GridFTPGUIView.java 2008-06-19 19:49:09 UTC (rev 2040)
@@ -0,0 +1,845 @@
+/*
+ * GridFTPGUIView.java
+ */
+
+package org.globus.transfer.reliable.client;
+
+import java.awt.GridLayout;
+import org.jdesktop.application.Action;
+import org.jdesktop.application.ResourceMap;
+import org.jdesktop.application.SingleFrameApplication;
+import org.jdesktop.application.FrameView;
+import org.jdesktop.application.TaskMonitor;
+import java.awt.event.ActionEvent;
+import java.awt.event.ActionListener;
+import java.io.BufferedReader;
+import java.io.File;
+import java.io.FileReader;
+import java.io.FileWriter;
+import java.io.IOException;
+import javax.swing.Timer;
+import javax.swing.Icon;
+import javax.swing.JDialog;
+import javax.swing.JFileChooser;
+import javax.swing.JFrame;
+import javax.swing.JInternalFrame;
+import javax.swing.JOptionPane;
+import org.apache.commons.logging.Log;
+import org.apache.commons.logging.LogFactory;
+import org.globus.common.CoGProperties;
+import org.globus.gsi.CertUtil;
+import org.globus.gsi.GlobusCredential;
+import org.globus.ogce.beans.filetransfer.FtpProperties;
+import org.globus.ogce.beans.filetransfer.gui.FileTransferMainPanel;
+import org.globus.ogce.beans.filetransfer.gui.monitor.OptionsPanel;
+import org.globus.ogce.beans.filetransfer.gui.remote.common.DisplayInterface;
+import org.globus.ogce.beans.filetransfer.gui.remote.ftp.FtpClient;
+import org.globus.ogce.beans.filetransfer.gui.remote.gridftp.GridClient;
+import org.globus.ogce.util.StringUtil;
+import org.globus.tools.proxy.GridProxyInit;
+import org.globus.tools.ui.util.CustomFileFilter;
+import org.globus.tools.ui.util.UITools;
+import org.globus.transfer.reliable.client.myproxy.MyProxyLogonGUI;
+import org.globus.transfer.reliable.client.utils.LogFileUtils;
+import org.globus.transfer.reliable.client.utils.UIConstants;
+import org.globus.util.ConfigUtil;
+import org.globus.util.Util;
+
+/**
+ * The application's main frame.
+ */
+public class GridFTPGUIView extends FrameView {
+ private Log logger = LogFactory.getLog(GridFTPGUIView.class);
+
+ public GridFTPGUIView(SingleFrameApplication app) {
+ super(app);
+
+ initComponents();
+ //
+ //fileTransferMainPanel1.add(fileTransferMainPanel1.getDesktopPane());
+ //mainPanel.add(fileTransferMainPanel1.getDesktopPane());
+ //mainPanel.add(fileTransferPanel.getDesktopPane());
+ // status bar initialization - message timeout, idle icon and busy animation, etc
+ ResourceMap resourceMap = getResourceMap();
+ int messageTimeout = resourceMap.getInteger("StatusBar.messageTimeout");
+ messageTimer = new Timer(messageTimeout, new ActionListener() {
+ public void actionPerformed(ActionEvent e) {
+ statusMessageLabel.setText("");
+ }
+ });
+ messageTimer.setRepeats(false);
+ int busyAnimationRate = resourceMap.getInteger("StatusBar.busyAnimationRate");
+ for (int i = 0; i < busyIcons.length; i++) {
+ busyIcons[i] = resourceMap.getIcon("StatusBar.busyIcons[" + i + "]");
+ }
+ busyIconTimer = new Timer(busyAnimationRate, new ActionListener() {
+ public void actionPerformed(ActionEvent e) {
+ busyIconIndex = (busyIconIndex + 1) % busyIcons.length;
+ statusAnimationLabel.setIcon(busyIcons[busyIconIndex]);
+ }
+ });
+ idleIcon = resourceMap.getIcon("StatusBar.idleIcon");
+ statusAnimationLabel.setIcon(idleIcon);
+ progressBar.setVisible(false);
+
+ // connecting action tasks to status bar via TaskMonitor
+ TaskMonitor taskMonitor = new TaskMonitor(getApplication().getContext());
+ taskMonitor.addPropertyChangeListener(new java.beans.PropertyChangeListener() {
+ public void propertyChange(java.beans.PropertyChangeEvent evt) {
+ String propertyName = evt.getPropertyName();
+ if ("started".equals(propertyName)) {
+ if (!busyIconTimer.isRunning()) {
+ statusAnimationLabel.setIcon(busyIcons[0]);
+ busyIconIndex = 0;
+ busyIconTimer.start();
+ }
+ progressBar.setVisible(true);
+ progressBar.setIndeterminate(true);
+ } else if ("done".equals(propertyName)) {
+ busyIconTimer.stop();
+ statusAnimationLabel.setIcon(idleIcon);
+ progressBar.setVisible(false);
+ progressBar.setValue(0);
+ } else if ("message".equals(propertyName)) {
+ String text = (String)(evt.getNewValue());
+ statusMessageLabel.setText((text == null) ? "" : text);
+ messageTimer.restart();
+ } else if ("progress".equals(propertyName)) {
+ int value = (Integer)(evt.getNewValue());
+ progressBar.setVisible(true);
+ progressBar.setIndeterminate(false);
+ progressBar.setValue(value);
+ }
+ }
+ });
+ }
+
+ @Action
+ public void showAboutBox() {
+ if (aboutBox == null) {
+ JFrame mainFrame = GridFTPGUIApp.getApplication().getMainFrame();
+ aboutBox = new GridFTPGUIAboutBox(mainFrame);
+ aboutBox.setLocationRelativeTo(mainFrame);
+ }
+ GridFTPGUIApp.getApplication().show(aboutBox);
+ }
+
+ /** This method is called from within the constructor to
+ * initialize the form.
+ * WARNING: Do NOT modify this code. The content of this method is
+ * always regenerated by the Form Editor.
+ */
+ // <editor-fold defaultstate="collapsed" desc="Generated Code">//GEN-BEGIN:initComponents
+ private void initComponents() {
+
+ mainPanel = new javax.swing.JPanel();
+ jToolBar1 = new javax.swing.JToolBar();
+ jButton1 = new javax.swing.JButton();
+ jButton2 = new javax.swing.JButton();
+ jButton4 = new javax.swing.JButton();
+ jButton3 = new javax.swing.JButton();
+ jButton5 = new javax.swing.JButton();
+ jButton7 = new javax.swing.JButton();
+ jButton8 = new javax.swing.JButton();
+ javax.swing.JSeparator statusPanelSeparator = new javax.swing.JSeparator();
+ jDesktopPane1 = fileTransferMainPanel1.getDesktopPane();
+ menuBar = new javax.swing.JMenuBar();
+ javax.swing.JMenu fileMenu = new javax.swing.JMenu();
+ jMenuItem6 = new javax.swing.JMenuItem();
+ jMenuItem7 = new javax.swing.JMenuItem();
+ javax.swing.JMenuItem exitMenuItem = new javax.swing.JMenuItem();
+ jMenu1 = new javax.swing.JMenu();
+ jMenuItem1 = new javax.swing.JMenuItem();
+ jMenuItem8 = new javax.swing.JMenuItem();
+ jMenuItem9 = new javax.swing.JMenuItem();
+ jMenuItem10 = new javax.swing.JMenuItem();
+ jMenuItem2 = new javax.swing.JMenuItem();
+ jMenu2 = new javax.swing.JMenu();
+ jMenuItem3 = new javax.swing.JMenuItem();
+ jMenuItem4 = new javax.swing.JMenuItem();
+ jMenuItem5 = new javax.swing.JMenuItem();
+ javax.swing.JMenu helpMenu = new javax.swing.JMenu();
+ javax.swing.JMenuItem aboutMenuItem = new javax.swing.JMenuItem();
+ statusPanel = new javax.swing.JPanel();
+ statusMessageLabel = new javax.swing.JLabel();
+ statusAnimationLabel = new javax.swing.JLabel();
+ progressBar = new javax.swing.JProgressBar();
+
+ mainPanel.setName("mainPanel"); // NOI18N
+
+ jToolBar1.setRollover(true);
+ jToolBar1.setName("jToolBar1"); // NOI18N
+
+ org.jdesktop.application.ResourceMap resourceMap = org.jdesktop.application.Application.getInstance(org.globus.transfer.reliable.client.GridFTPGUIApp.class).getContext().getResourceMap(GridFTPGUIView.class);
+ jButton1.setIcon(resourceMap.getIcon("jButton1.icon")); // NOI18N
+ jButton1.setText(resourceMap.getString("jButton1.text")); // NOI18N
+ jButton1.setToolTipText(resourceMap.getString("jButton1.toolTipText")); // NOI18N
+ jButton1.setFocusable(false);
+ jButton1.setHorizontalTextPosition(javax.swing.SwingConstants.CENTER);
+ jButton1.setName("jButton1"); // NOI18N
+ jButton1.setVerticalTextPosition(javax.swing.SwingConstants.BOTTOM);
+ jButton1.addActionListener(new java.awt.event.ActionListener() {
+ public void actionPerformed(java.awt.event.ActionEvent evt) {
+ jButton1ActionPerformed(evt);
+ }
+ });
+ jToolBar1.add(jButton1);
+
+ jButton2.setIcon(resourceMap.getIcon("jButton2.icon")); // NOI18N
+ jButton2.setText(resourceMap.getString("jButton2.text")); // NOI18N
+ jButton2.setToolTipText(resourceMap.getString("jButton2.toolTipText")); // NOI18N
+ jButton2.setFocusable(false);
+ jButton2.setHorizontalTextPosition(javax.swing.SwingConstants.CENTER);
+ jButton2.setName("jButton2"); // NOI18N
+ jButton2.setVerticalTextPosition(javax.swing.SwingConstants.BOTTOM);
+ jButton2.addActionListener(new java.awt.event.ActionListener() {
+ public void actionPerformed(java.awt.event.ActionEvent evt) {
+ jButton2ActionPerformed(evt);
+ }
+ });
+ jToolBar1.add(jButton2);
+
+ jButton4.setIcon(resourceMap.getIcon("jButton4.icon")); // NOI18N
+ jButton4.setText(resourceMap.getString("jButton4.text")); // NOI18N
+ jButton4.setFocusable(false);
+ jButton4.setHorizontalTextPosition(javax.swing.SwingConstants.CENTER);
+ jButton4.setName("jButton4"); // NOI18N
+ jButton4.setVerticalTextPosition(javax.swing.SwingConstants.BOTTOM);
+ jButton4.addActionListener(new java.awt.event.ActionListener() {
+ public void actionPerformed(java.awt.event.ActionEvent evt) {
+ jButton4ActionPerformed(evt);
+ }
+ });
+ //jToolBar1.add(jButton4);
+
+ jButton3.setIcon(resourceMap.getIcon("jButton3.icon")); // NOI18N
+ jButton3.setText(resourceMap.getString("jButton3.text")); // NOI18N
+ jButton3.setFocusable(false);
+ jButton3.setHorizontalTextPosition(javax.swing.SwingConstants.CENTER);
+ jButton3.setName("jButton3"); // NOI18N
+ jButton3.setVerticalTextPosition(javax.swing.SwingConstants.BOTTOM);
+ jButton3.addActionListener(new java.awt.event.ActionListener() {
+ public void actionPerformed(java.awt.event.ActionEvent evt) {
+ jButton3ActionPerformed(evt);
+ }
+ });
+ jToolBar1.add(jButton3);
+
+ jButton5.setIcon(resourceMap.getIcon("jButton5.icon")); // NOI18N
+ jButton5.setText(resourceMap.getString("jButton5.text")); // NOI18N
+ jButton5.setFocusable(false);
+ jButton5.setHorizontalTextPosition(javax.swing.SwingConstants.CENTER);
+ jButton5.setName("jButton5"); // NOI18N
+ jButton5.setVerticalTextPosition(javax.swing.SwingConstants.BOTTOM);
+ jButton5.addActionListener(new java.awt.event.ActionListener() {
+ public void actionPerformed(java.awt.event.ActionEvent evt) {
+ jButton5ActionPerformed(evt);
+ }
+ });
+ jToolBar1.add(jButton5);
+
+ jButton7.setIcon(resourceMap.getIcon("jButton7.icon")); // NOI18N
+ jButton7.setText("MyProxy"); // NOI18N
+ jButton7.setFocusable(false);
+ jButton7.setHorizontalTextPosition(javax.swing.SwingConstants.CENTER);
+ jButton7.setName("jButton7"); // NOI18N
+ jButton7.setVerticalTextPosition(javax.swing.SwingConstants.BOTTOM);
+ jButton7.addActionListener(new java.awt.event.ActionListener() {
+ public void actionPerformed(java.awt.event.ActionEvent evt) {
+ jButton7ActionPerformed(evt);
+ }
+ });
+ jToolBar1.add(jButton7);
+
+ jButton8.setIcon(resourceMap.getIcon("jButton8.icon")); // NOI18N
+ jButton8.setText(resourceMap.getString("jButton8.text")); // NOI18N
+ jButton8.setFocusable(false);
+ jButton8.setHorizontalTextPosition(javax.swing.SwingConstants.CENTER);
+ jButton8.setName("jButton8"); // NOI18N
+ jButton8.setVerticalTextPosition(javax.swing.SwingConstants.BOTTOM);
+ jButton8.addActionListener(new java.awt.event.ActionListener() {
+ public void actionPerformed(java.awt.event.ActionEvent evt) {
+ jButton8ActionPerformed(evt);
+ }
+ });
+ jToolBar1.add(jButton8);
+
+ statusPanelSeparator.setName("statusPanelSeparator"); // NOI18N
+
+ jDesktopPane1.setBackground(resourceMap.getColor("jDesktopPane1.background")); // NOI18N
+ jDesktopPane1.setBorder(javax.swing.BorderFactory.createLineBorder(new java.awt.Color(0, 0, 0)));
+ jDesktopPane1.setName("jDesktopPane1"); // NOI18N
+
+ org.jdesktop.layout.GroupLayout mainPanelLayout = new org.jdesktop.layout.GroupLayout(mainPanel);
+ mainPanel.setLayout(mainPanelLayout);
+ mainPanelLayout.setHorizontalGroup(
+ mainPanelLayout.createParallelGroup(org.jdesktop.layout.GroupLayout.LEADING)
+ .add(org.jdesktop.layout.GroupLayout.TRAILING, mainPanelLayout.createSequentialGroup()
+ .addContainerGap()
+ .add(statusPanelSeparator, org.jdesktop.layout.GroupLayout.DEFAULT_SIZE, 834, Short.MAX_VALUE))
+ .add(jToolBar1, org.jdesktop.layou...
[truncated message content] |
|
From: <b_...@us...> - 2008-06-17 11:28:13
|
Revision: 2039
http://cogkit.svn.sourceforge.net/cogkit/?rev=2039&view=rev
Author: b_z_c
Date: 2008-06-17 04:28:03 -0700 (Tue, 17 Jun 2008)
Log Message:
-----------
allow specification of condor requirements string
Modified Paths:
--------------
trunk/current/src/cog/modules/provider-gt2/src/org/globus/cog/abstraction/impl/execution/gt2/JobSubmissionTaskHandler.java
Modified: trunk/current/src/cog/modules/provider-gt2/src/org/globus/cog/abstraction/impl/execution/gt2/JobSubmissionTaskHandler.java
===================================================================
--- trunk/current/src/cog/modules/provider-gt2/src/org/globus/cog/abstraction/impl/execution/gt2/JobSubmissionTaskHandler.java 2008-06-12 22:46:57 UTC (rev 2038)
+++ trunk/current/src/cog/modules/provider-gt2/src/org/globus/cog/abstraction/impl/execution/gt2/JobSubmissionTaskHandler.java 2008-06-17 11:28:03 UTC (rev 2039)
@@ -417,10 +417,21 @@
.getStdError()));
}
+ if (spec.getAttribute("condor_requirements") != null) {
+ String requirementString = (String) spec.getAttribute("condor_requirements");
+ NameOpValue req = new NameOpValue("condorsubmit", NameOpValue.EQ);
+ List l = new LinkedList();
+ l.add(new Value("Requirements"));
+ l.add(new Value(requirementString));
+ req.add(l);
+ rsl.add(req);
+ }
+
Iterator i = spec.getAttributeNames().iterator();
while (i.hasNext()) {
try {
String key = (String) i.next();
+ if(key.equals("condor_requirements")) continue;
rsl.add(new NameOpValue(key, NameOpValue.EQ, (String) spec
.getAttribute(key)));
}
This was sent by the SourceForge.net collaborative development platform, the world's largest Open Source development site.
|
|
From: <ha...@us...> - 2008-06-12 22:47:11
|
Revision: 2038
http://cogkit.svn.sourceforge.net/cogkit/?rev=2038&view=rev
Author: hategan
Date: 2008-06-12 15:46:57 -0700 (Thu, 12 Jun 2008)
Log Message:
-----------
removed compiled stuff
Removed Paths:
-------------
branches/karajan2/src/cog/modules/karajan2/examples/order_dot_k.class
branches/karajan2/src/cog/modules/karajan2/examples/order_dot_k.java
branches/karajan2/src/cog/modules/karajan2/examples/sys_dot_k.class
branches/karajan2/src/cog/modules/karajan2/examples/sys_dot_k.java
Deleted: branches/karajan2/src/cog/modules/karajan2/examples/order_dot_k.class
===================================================================
(Binary files differ)
Deleted: branches/karajan2/src/cog/modules/karajan2/examples/order_dot_k.java
===================================================================
--- branches/karajan2/src/cog/modules/karajan2/examples/order_dot_k.java 2008-06-12 22:45:56 UTC (rev 2037)
+++ branches/karajan2/src/cog/modules/karajan2/examples/order_dot_k.java 2008-06-12 22:46:57 UTC (rev 2038)
@@ -1,235 +0,0 @@
-import org.globus.cog.karajan.threading.LWThread;
-import org.globus.cog.karajan.threading.Yield;
-import org.globus.cog.karajan.runtime.Context;
-import org.globus.cog.karajan.runtime.Channel;
-import org.globus.cog.karajan.runtime.Exceptions;
-import org.globus.cog.karajan.runtime.KFile;
-import org.globus.cog.karajan.runtime.KLine;
-import org.globus.cog.karajan.runtime.Callable;
-import org.globus.cog.karajan.runtime.StdSink.StdoutSink;
-import org.globus.cog.karajan.runtime.StdSink.StderrSink;
-import org.globus.cog.karajan.runtime.NVPair;
-import org.globus.cog.karajan.runtime.Arguments;
-import java.util.Collection;
-import org.globus.cog.karajan.threading.StateTables;
-import org.globus.cog.karajan.threading.LWThreadDeath;
-import org.globus.cog.karajan.threading.KRunnable;
-import org.globus.cog.karajan.runtime.OrderedParallelChannel;
-import org.globus.cog.karajan.runtime.KIterator;
-import org.globus.cog.karajan.runtime.ExecutionException;
-
-
-@KFile("order_dot_k")
-public final class order_dot_k implements KRunnable {
- public static void main(String[] args) {
- LWThread thread = new LWThread(new order_dot_k());
- thread.start();
- try {
- thread.waitFor();
- }
- catch (InterruptedException e) {
- e.printStackTrace();
- }
- }
-
- public void run() {
- run(LWThread.currentThread().getContext());
- }
-
- public void run(Context ctx) {
- try {
- LWThread thread = LWThread.currentThread();
- thread.checkSlice();
- int __state__ = thread.popState();
- switch(__state__) {
- case 0:
- thread.setContext(ctx = new Context(20, ctx));
- case 1:
- ctx.pushChannel(1, new StdoutSink());
- ctx.pushChannel(2, new StderrSink());
- //[Exception, throw, range, __eq___eq_, __times_, __plus_, wait, __gt_, echo, print, __lt_, __minus_]
- thread.setContext(ctx = new Context(12, ctx));
- case 2:
- k_dot_import000000(ctx);
- case 3:
- k_dot_par000001(ctx);
- thread.setContext(ctx = ctx.p);
- thread.setContext(ctx = ctx.p);
- }
- }
- catch (Exception e) {
- Exceptions.handleException(e);
- }
- }
-
- // import (order_dot_k:1)
- @KLine("1")
- private void k_dot_import000000(Context ctx) throws Exception {
- LWThread thread = LWThread.currentThread();
- thread.checkSlice();
- int __state__ = thread.popState();
- switch(__state__) {
- case 0:
- ctx.pushChannel(0);
- case 1:
- ((KRunnable) getClass().getClassLoader().loadClass("sys_dot_k").newInstance()).run(ctx);
- Channel c = ctx.popChannel(0);
- ctx.set(0, c.get(0));
- ctx.set(1, c.get(1));
- ctx.set(2, c.get(2));
- ctx.set(3, c.get(3));
- ctx.set(4, c.get(4));
- ctx.set(5, c.get(5));
- ctx.set(6, c.get(6));
- ctx.set(7, c.get(7));
- ctx.set(8, c.get(8));
- ctx.set(9, c.get(9));
- ctx.set(10, c.get(10));
- ctx.set(11, c.get(11));
- }
- }
-
- private Object k_dot_named000003(Context ctx){
- ctx.pushChannel(0);
- try {
- // k.number (order_dot_k:9)
- ctx.append(0, new Double(200));
- return ctx.getChannel(0).get(0);
- }
- finally {
- ctx.popChannel(0);
- }
- }
- // seq (order_dot_k:5)
- @KLine("5")
- private void k_dot_seq000002(Context ctx) throws Exception {
- LWThread thread = LWThread.currentThread();
- thread.checkSlice();
- int __state__ = thread.popState();
- switch(__state__) {
- case 0:
- // wait (order_dot_k:5)
- ctx.pushChannel(0, new Arguments(2, 0, 0, false, org.globus.cog.karajan.lib.sys.Wait.SIGNATURE.getDefaultValues(), ctx, ctx));
- // k.named (order_dot_k:9)
- ((Arguments) ctx.getChannel(0)).set(0, k_dot_named000003(ctx));
- thread.setContext(ctx = (Arguments) ctx.popChannel(0));
- case 1:
- ((Callable) ctx.p.p.get(3)).invoke(ctx);
- thread.setContext(ctx = ((Arguments) ctx).s);
- // echo (order_dot_k:6)
- ctx.pushChannel(0, new Arguments(1, 0, 0, true, org.globus.cog.karajan.lib.sys.Echo.SIGNATURE.getDefaultValues(), ctx, ctx));
- // k.string (order_dot_k:13)
- ctx.append(0, "a1");
- thread.setContext(ctx = (Arguments) ctx.popChannel(0));
- case 2:
- ((Callable) ctx.p.p.get(0)).invoke(ctx);
- thread.setContext(ctx = ((Arguments) ctx).s);
- // print (order_dot_k:7)
- ctx.pushChannel(0, new Arguments(1, 0, 0, true, org.globus.cog.karajan.lib.sys.Print.SIGNATURE.getDefaultValues(), ctx, ctx));
- // k.string (order_dot_k:16)
- ctx.append(0, "b1");
- thread.setContext(ctx = (Arguments) ctx.popChannel(0));
- case 3:
- ((Callable) ctx.p.p.get(1)).invoke(ctx);
- thread.setContext(ctx = ((Arguments) ctx).s);
- }
- }
-
- private Object k_dot_named000005(Context ctx){
- ctx.pushChannel(0);
- try {
- // k.number (order_dot_k:22)
- ctx.append(0, new Double(100));
- return ctx.getChannel(0).get(0);
- }
- finally {
- ctx.popChannel(0);
- }
- }
- // seq (order_dot_k:10)
- @KLine("10")
- private void k_dot_seq000004(Context ctx) throws Exception {
- LWThread thread = LWThread.currentThread();
- thread.checkSlice();
- int __state__ = thread.popState();
- switch(__state__) {
- case 0:
- // wait (order_dot_k:10)
- ctx.pushChannel(0, new Arguments(2, 0, 0, false, org.globus.cog.karajan.lib.sys.Wait.SIGNATURE.getDefaultValues(), ctx, ctx));
- // k.named (order_dot_k:22)
- ((Arguments) ctx.getChannel(0)).set(0, k_dot_named000005(ctx));
- thread.setContext(ctx = (Arguments) ctx.popChannel(0));
- case 1:
- ((Callable) ctx.p.p.get(3)).invoke(ctx);
- thread.setContext(ctx = ((Arguments) ctx).s);
- // echo (order_dot_k:11)
- ctx.pushChannel(0, new Arguments(1, 0, 0, true, org.globus.cog.karajan.lib.sys.Echo.SIGNATURE.getDefaultValues(), ctx, ctx));
- // k.string (order_dot_k:26)
- ctx.append(0, "a2");
- thread.setContext(ctx = (Arguments) ctx.popChannel(0));
- case 2:
- ((Callable) ctx.p.p.get(0)).invoke(ctx);
- thread.setContext(ctx = ((Arguments) ctx).s);
- // print (order_dot_k:12)
- ctx.pushChannel(0, new Arguments(1, 0, 0, true, org.globus.cog.karajan.lib.sys.Print.SIGNATURE.getDefaultValues(), ctx, ctx));
- // k.string (order_dot_k:29)
- ctx.append(0, "b2");
- thread.setContext(ctx = (Arguments) ctx.popChannel(0));
- case 3:
- ((Callable) ctx.p.p.get(1)).invoke(ctx);
- thread.setContext(ctx = ((Arguments) ctx).s);
- }
- }
-
- // par (order_dot_k:4)
- @KLine("4")
- private void k_dot_par000001(Context ctx) throws Exception {
- LWThread thread = LWThread.currentThread();
- thread.checkSlice();
- int __state__ = thread.popState();
- switch(__state__) {
- case 0:
- LWThread[] t000006 = new LWThread[2];
- t000006[0] = thread.fork(2);
- t000006[0].setContext(new Context(ctx));
- t000006[0].getContext().pushChannel(1, new OrderedParallelChannel(1, ctx, null));
- t000006[1] = thread.fork(3);
- t000006[1].setContext(new Context(ctx));
- t000006[1].getContext().pushChannel(1, new OrderedParallelChannel(1, ctx, t000006[0].getContext()));
- t000006[0].start();
- t000006[1].start();
- t000006 = null;
- case 1:
- thread.waitForChildren();
- break;
- case 2:
- k_dot_seq000002(ctx);
- ((OrderedParallelChannel) ctx.getChannel(1)).close();
- thread.die();
- case 3:
- k_dot_seq000004(ctx);
- ((OrderedParallelChannel) ctx.getChannel(1)).close();
- thread.die();
- }
- }
-
- public static final int[] __LINE_TABLE = new int[] {
- 45, 47, 52, 54, 58, //run
- 72, 74, 89, //k_dot_import000000
- 110, 116, 124, 132, 135, //k_dot_seq000002
- 156, 162, 170, 178, 181, //k_dot_seq000004
- 191, 202, 205, 209//k_dot_par000001
- };
- public static final int[] __STATE_TABLE = new int[] {
- 0, 1, 2, 3, -1, //run
- 0, 1, -1, //k_dot_import000000
- 0, 1, 2, 3, -1, //k_dot_seq000002
- 0, 1, 2, 3, -1, //k_dot_seq000004
- 0, 1, 2, 3//k_dot_par000001
- };
- static {
- StateTables.register(order_dot_k.class);
- }
- public static void __exports__() {
- }
-}
Deleted: branches/karajan2/src/cog/modules/karajan2/examples/sys_dot_k.class
===================================================================
(Binary files differ)
Deleted: branches/karajan2/src/cog/modules/karajan2/examples/sys_dot_k.java
===================================================================
--- branches/karajan2/src/cog/modules/karajan2/examples/sys_dot_k.java 2008-06-12 22:45:56 UTC (rev 2037)
+++ branches/karajan2/src/cog/modules/karajan2/examples/sys_dot_k.java 2008-06-12 22:46:57 UTC (rev 2038)
@@ -1,342 +0,0 @@
-import org.globus.cog.karajan.threading.LWThread;
-import org.globus.cog.karajan.threading.Yield;
-import org.globus.cog.karajan.runtime.Context;
-import org.globus.cog.karajan.runtime.Channel;
-import org.globus.cog.karajan.runtime.Exceptions;
-import org.globus.cog.karajan.runtime.KFile;
-import org.globus.cog.karajan.runtime.KLine;
-import org.globus.cog.karajan.runtime.Callable;
-import org.globus.cog.karajan.runtime.StdSink.StdoutSink;
-import org.globus.cog.karajan.runtime.StdSink.StderrSink;
-import org.globus.cog.karajan.runtime.NVPair;
-import org.globus.cog.karajan.runtime.Arguments;
-import java.util.Collection;
-import org.globus.cog.karajan.threading.StateTables;
-import org.globus.cog.karajan.threading.LWThreadDeath;
-import org.globus.cog.karajan.threading.KRunnable;
-import org.globus.cog.karajan.runtime.OrderedParallelChannel;
-import org.globus.cog.karajan.runtime.KIterator;
-import org.globus.cog.karajan.runtime.ExecutionException;
-
-
-@KFile("sys_dot_k")
-public final class sys_dot_k implements KRunnable {
- public static void main(String[] args) {
- LWThread thread = new LWThread(new sys_dot_k());
- thread.start();
- try {
- thread.waitFor();
- }
- catch (InterruptedException e) {
- e.printStackTrace();
- }
- }
-
- public void run() {
- run(LWThread.currentThread().getContext());
- }
-
- public void run(Context ctx) {
- try {
- LWThread thread = LWThread.currentThread();
- thread.checkSlice();
- int __state__ = thread.popState();
- switch(__state__) {
- case 0:
- thread.setContext(ctx = new Context(20, ctx));
- case 1:
- ctx.pushChannel(1, new StdoutSink());
- ctx.pushChannel(2, new StderrSink());
- //[Exception, throw, range, __eq___eq_, __times_, __plus_, wait, __gt_, echo, print, __minus_, __lt_]
- thread.setContext(ctx = new Context(12, ctx));
- case 2:
- k_dot_set000000(ctx);
- case 3:
- k_dot_set000001(ctx);
- case 4:
- k_dot_set000002(ctx);
- case 5:
- k_dot_set000003(ctx);
- case 6:
- k_dot_set000004(ctx);
- case 7:
- k_dot_set000005(ctx);
- case 8:
- k_dot_set000006(ctx);
- case 9:
- k_dot_set000007(ctx);
- case 10:
- k_dot_set000008(ctx);
- case 11:
- k_dot_set000009(ctx);
- case 12:
- k_dot_set000010(ctx);
- case 13:
- k_dot_set000011(ctx);
- // export (sys_dot_k:15)
- ctx.getChannel(0).append(ctx.get(0));
- ctx.getChannel(0).append(ctx.get(1));
- ctx.getChannel(0).append(ctx.get(2));
- ctx.getChannel(0).append(ctx.get(3));
- ctx.getChannel(0).append(ctx.get(4));
- ctx.getChannel(0).append(ctx.get(7));
- ctx.getChannel(0).append(ctx.get(8));
- ctx.getChannel(0).append(ctx.get(10));
- ctx.getChannel(0).append(ctx.get(11));
- ctx.getChannel(0).append(ctx.get(5));
- ctx.getChannel(0).append(ctx.get(6));
- ctx.getChannel(0).append(ctx.get(9));
- thread.setContext(ctx = ctx.p);
- thread.setContext(ctx = ctx.p);
- }
- }
- catch (Exception e) {
- Exceptions.handleException(e);
- }
- }
-
- private void checkMismatch(int expected, int actual) throws ExecutionException {
- if(expected != actual) {
- throw new ExecutionException("Got " + expected + " identifier(s) and " + actual + " values");
- }
- }
- // k.set (sys_dot_k:1)
- @KLine("1")
- private void k_dot_set000000(Context ctx) throws Exception {
- LWThread thread = LWThread.currentThread();
- thread.checkSlice();
- int __state__ = thread.popState();
- switch(__state__) {
- case 0:
- ctx.pushChannel(0);
- case 1:
- // native (sys_dot_k:1)
- ctx.append(0, new org.globus.cog.karajan.lib.sys.Echo());
- Channel def = ctx.popChannel(0);
- ctx.set(0, def.get(0));
- }
- }
-
- // k.set (sys_dot_k:2)
- @KLine("2")
- private void k_dot_set000001(Context ctx) throws Exception {
- LWThread thread = LWThread.currentThread();
- thread.checkSlice();
- int __state__ = thread.popState();
- switch(__state__) {
- case 0:
- ctx.pushChannel(0);
- case 1:
- // native (sys_dot_k:2)
- ctx.append(0, new org.globus.cog.karajan.lib.sys.Print());
- Channel def = ctx.popChannel(0);
- ctx.set(1, def.get(0));
- }
- }
-
- // k.set (sys_dot_k:3)
- @KLine("3")
- private void k_dot_set000002(Context ctx) throws Exception {
- LWThread thread = LWThread.currentThread();
- thread.checkSlice();
- int __state__ = thread.popState();
- switch(__state__) {
- case 0:
- ctx.pushChannel(0);
- case 1:
- // native (sys_dot_k:3)
- ctx.append(0, new org.globus.cog.karajan.lib.sys.Range());
- Channel def = ctx.popChannel(0);
- ctx.set(2, def.get(0));
- }
- }
-
- // k.set (sys_dot_k:4)
- @KLine("4")
- private void k_dot_set000003(Context ctx) throws Exception {
- LWThread thread = LWThread.currentThread();
- thread.checkSlice();
- int __state__ = thread.popState();
- switch(__state__) {
- case 0:
- ctx.pushChannel(0);
- case 1:
- // native (sys_dot_k:4)
- ctx.append(0, new org.globus.cog.karajan.lib.sys.Wait());
- Channel def = ctx.popChannel(0);
- ctx.set(3, def.get(0));
- }
- }
-
- // k.set (sys_dot_k:5)
- @KLine("5")
- private void k_dot_set000004(Context ctx) throws Exception {
- LWThread thread = LWThread.currentThread();
- thread.checkSlice();
- int __state__ = thread.popState();
- switch(__state__) {
- case 0:
- ctx.pushChannel(0);
- case 1:
- // native (sys_dot_k:5)
- ctx.append(0, new org.globus.cog.karajan.lib.sys.Equals());
- Channel def = ctx.popChannel(0);
- ctx.set(4, def.get(0));
- }
- }
-
- // k.set (sys_dot_k:6)
- @KLine("6")
- private void k_dot_set000005(Context ctx) throws Exception {
- LWThread thread = LWThread.currentThread();
- thread.checkSlice();
- int __state__ = thread.popState();
- switch(__state__) {
- case 0:
- ctx.pushChannel(0);
- case 1:
- // native (sys_dot_k:6)
- ctx.append(0, new org.globus.cog.karajan.lib.sys.GreaterThan());
- Channel def = ctx.popChannel(0);
- ctx.set(5, def.get(0));
- }
- }
-
- // k.set (sys_dot_k:7)
- @KLine("7")
- private void k_dot_set000006(Context ctx) throws Exception {
- LWThread thread = LWThread.currentThread();
- thread.checkSlice();
- int __state__ = thread.popState();
- switch(__state__) {
- case 0:
- ctx.pushChannel(0);
- case 1:
- // native (sys_dot_k:7)
- ctx.append(0, new org.globus.cog.karajan.lib.sys.LessThan());
- Channel def = ctx.popChannel(0);
- ctx.set(6, def.get(0));
- }
- }
-
- // k.set (sys_dot_k:8)
- @KLine("8")
- private void k_dot_set000007(Context ctx) throws Exception {
- LWThread thread = LWThread.currentThread();
- thread.checkSlice();
- int __state__ = thread.popState();
- switch(__state__) {
- case 0:
- ctx.pushChannel(0);
- case 1:
- // native (sys_dot_k:8)
- ctx.append(0, new org.globus.cog.karajan.lib.sys.Plus());
- Channel def = ctx.popChannel(0);
- ctx.set(7, def.get(0));
- }
- }
-
- // k.set (sys_dot_k:9)
- @KLine("9")
- private void k_dot_set000008(Context ctx) throws Exception {
- LWThread thread = LWThread.currentThread();
- thread.checkSlice();
- int __state__ = thread.popState();
- switch(__state__) {
- case 0:
- ctx.pushChannel(0);
- case 1:
- // native (sys_dot_k:9)
- ctx.append(0, new org.globus.cog.karajan.lib.sys.Minus());
- Channel def = ctx.popChannel(0);
- ctx.set(8, def.get(0));
- }
- }
-
- // k.set (sys_dot_k:10)
- @KLine("10")
- private void k_dot_set000009(Context ctx) throws Exception {
- LWThread thread = LWThread.currentThread();
- thread.checkSlice();
- int __state__ = thread.popState();
- switch(__state__) {
- case 0:
- ctx.pushChannel(0);
- case 1:
- // native (sys_dot_k:10)
- ctx.append(0, new org.globus.cog.karajan.lib.sys.Times());
- Channel def = ctx.popChannel(0);
- ctx.set(9, def.get(0));
- }
- }
-
- // k.set (sys_dot_k:12)
- @KLine("12")
- private void k_dot_set000010(Context ctx) throws Exception {
- LWThread thread = LWThread.currentThread();
- thread.checkSlice();
- int __state__ = thread.popState();
- switch(__state__) {
- case 0:
- ctx.pushChannel(0);
- case 1:
- // native (sys_dot_k:12)
- ctx.append(0, new org.globus.cog.karajan.lib.sys.Throw());
- Channel def = ctx.popChannel(0);
- ctx.set(10, def.get(0));
- }
- }
-
- // k.set (sys_dot_k:13)
- @KLine("13")
- private void k_dot_set000011(Context ctx) throws Exception {
- LWThread thread = LWThread.currentThread();
- thread.checkSlice();
- int __state__ = thread.popState();
- switch(__state__) {
- case 0:
- ctx.pushChannel(0);
- case 1:
- // native (sys_dot_k:13)
- ctx.append(0, new org.globus.cog.karajan.lib.sys.KException());
- Channel def = ctx.popChannel(0);
- ctx.set(11, def.get(0));
- }
- }
-
- public static final int[] __LINE_TABLE = new int[] {
- 45, 47, 52, 54, 56, 58, 60, 62, 64, 66, 68, 70, 72, 74, 91, //run
- 110, 112, 117, //k_dot_set000000
- 127, 129, 134, //k_dot_set000001
- 144, 146, 151, //k_dot_set000002
- 161, 163, 168, //k_dot_set000003
- 178, 180, 185, //k_dot_set000004
- 195, 197, 202, //k_dot_set000005
- 212, 214, 219, //k_dot_set000006
- 229, 231, 236, //k_dot_set000007
- 246, 248, 253, //k_dot_set000008
- 263, 265, 270, //k_dot_set000009
- 280, 282, 287, //k_dot_set000010
- 297, 299//k_dot_set000011
- };
- public static final int[] __STATE_TABLE = new int[] {
- 0, 1, 2, 3, 4, 5, 6, 7, 8, 9, 10, 11, 12, 13, -1, //run
- 0, 1, -1, //k_dot_set000000
- 0, 1, -1, //k_dot_set000001
- 0, 1, -1, //k_dot_set000002
- 0, 1, -1, //k_dot_set000003
- 0, 1, -1, //k_dot_set000004
- 0, 1, -1, //k_dot_set000005
- 0, 1, -1, //k_dot_set000006
- 0, 1, -1, //k_dot_set000007
- 0, 1, -1, //k_dot_set000008
- 0, 1, -1, //k_dot_set000009
- 0, 1, -1, //k_dot_set000010
- 0, 1//k_dot_set000011
- };
- static {
- StateTables.register(sys_dot_k.class);
- }
- public static void __exports__() {
- }
-}
This was sent by the SourceForge.net collaborative development platform, the world's largest Open Source development site.
|
|
From: <ha...@us...> - 2008-06-12 22:45:59
|
Revision: 2037
http://cogkit.svn.sourceforge.net/cogkit/?rev=2037&view=rev
Author: hategan
Date: 2008-06-12 15:45:56 -0700 (Thu, 12 Jun 2008)
Log Message:
-----------
very early version of what may never be
Added Paths:
-----------
branches/karajan2/src/cog/modules/karajan2/
branches/karajan2/src/cog/modules/karajan2/build.xml
branches/karajan2/src/cog/modules/karajan2/dependencies.xml
branches/karajan2/src/cog/modules/karajan2/etc/
branches/karajan2/src/cog/modules/karajan2/etc/MANIFEST.MF.head
branches/karajan2/src/cog/modules/karajan2/etc/MANIFEST.MF.tail
branches/karajan2/src/cog/modules/karajan2/etc/karajan.properties
branches/karajan2/src/cog/modules/karajan2/examples/
branches/karajan2/src/cog/modules/karajan2/examples/currying.k
branches/karajan2/src/cog/modules/karajan2/examples/order.k
branches/karajan2/src/cog/modules/karajan2/examples/order_dot_k.class
branches/karajan2/src/cog/modules/karajan2/examples/order_dot_k.java
branches/karajan2/src/cog/modules/karajan2/examples/recursion.k
branches/karajan2/src/cog/modules/karajan2/examples/scoping.k
branches/karajan2/src/cog/modules/karajan2/examples/sys.k
branches/karajan2/src/cog/modules/karajan2/examples/sys_dot_k.class
branches/karajan2/src/cog/modules/karajan2/examples/sys_dot_k.java
branches/karajan2/src/cog/modules/karajan2/launchers.xml
branches/karajan2/src/cog/modules/karajan2/lib/
branches/karajan2/src/cog/modules/karajan2/lib/backport-util-concurrent.jar
branches/karajan2/src/cog/modules/karajan2/lib/cog-util-0.92.jar
branches/karajan2/src/cog/modules/karajan2/lib/log4j-1.2.8.jar
branches/karajan2/src/cog/modules/karajan2/lib/xpp3-1.1.3.4d_b4_min.jar
branches/karajan2/src/cog/modules/karajan2/lib/xpp3.LICENSE
branches/karajan2/src/cog/modules/karajan2/lib/xstream-1.1.1-patched.jar
branches/karajan2/src/cog/modules/karajan2/lib/xstream.LICENSE
branches/karajan2/src/cog/modules/karajan2/project.properties
branches/karajan2/src/cog/modules/karajan2/resources/
branches/karajan2/src/cog/modules/karajan2/resources/karajan-language.gr
branches/karajan2/src/cog/modules/karajan2/resources/karajan-language.map
branches/karajan2/src/cog/modules/karajan2/src/
branches/karajan2/src/cog/modules/karajan2/src/com/
branches/karajan2/src/cog/modules/karajan2/src/com/thoughtworks/
branches/karajan2/src/cog/modules/karajan2/src/com/thoughtworks/xstream/
branches/karajan2/src/cog/modules/karajan2/src/com/thoughtworks/xstream/XStream.java
branches/karajan2/src/cog/modules/karajan2/src/com/thoughtworks/xstream/alias/
branches/karajan2/src/cog/modules/karajan2/src/com/thoughtworks/xstream/alias/ClassMapper.java
branches/karajan2/src/cog/modules/karajan2/src/com/thoughtworks/xstream/converters/
branches/karajan2/src/cog/modules/karajan2/src/com/thoughtworks/xstream/converters/ConversionException.java
branches/karajan2/src/cog/modules/karajan2/src/com/thoughtworks/xstream/ext/
branches/karajan2/src/cog/modules/karajan2/src/com/thoughtworks/xstream/ext/IntQueue.java
branches/karajan2/src/cog/modules/karajan2/src/com/thoughtworks/xstream/ext/MXppDriver.java
branches/karajan2/src/cog/modules/karajan2/src/com/thoughtworks/xstream/ext/MXppReader.java
branches/karajan2/src/cog/modules/karajan2/src/com/thoughtworks/xstream/mapper/
branches/karajan2/src/cog/modules/karajan2/src/com/thoughtworks/xstream/mapper/DefaultMapper.java
branches/karajan2/src/cog/modules/karajan2/src/com/thoughtworks/xstream/mapper/MapperWrapper.java
branches/karajan2/src/cog/modules/karajan2/src/org/
branches/karajan2/src/cog/modules/karajan2/src/org/globus/
branches/karajan2/src/cog/modules/karajan2/src/org/globus/cog/
branches/karajan2/src/cog/modules/karajan2/src/org/globus/cog/karajan/
branches/karajan2/src/cog/modules/karajan2/src/org/globus/cog/karajan/Configuration.java
branches/karajan2/src/cog/modules/karajan2/src/org/globus/cog/karajan/Loader.java
branches/karajan2/src/cog/modules/karajan2/src/org/globus/cog/karajan/SpecificationException.java
branches/karajan2/src/cog/modules/karajan2/src/org/globus/cog/karajan/compiler/
branches/karajan2/src/cog/modules/karajan2/src/org/globus/cog/karajan/compiler/AmbiguousVariableException.java
branches/karajan2/src/cog/modules/karajan2/src/org/globus/cog/karajan/compiler/CompilationException.java
branches/karajan2/src/cog/modules/karajan2/src/org/globus/cog/karajan/compiler/Compiler.java
branches/karajan2/src/cog/modules/karajan2/src/org/globus/cog/karajan/compiler/DynamicClassLoader.java
branches/karajan2/src/cog/modules/karajan2/src/org/globus/cog/karajan/compiler/DynamicLambda.java
branches/karajan2/src/cog/modules/karajan2/src/org/globus/cog/karajan/compiler/IndentingWriter.java
branches/karajan2/src/cog/modules/karajan2/src/org/globus/cog/karajan/compiler/InlineFunction.java
branches/karajan2/src/cog/modules/karajan2/src/org/globus/cog/karajan/compiler/Lambda.java
branches/karajan2/src/cog/modules/karajan2/src/org/globus/cog/karajan/compiler/NativeFunction.java
branches/karajan2/src/cog/modules/karajan2/src/org/globus/cog/karajan/compiler/OutputContext.java
branches/karajan2/src/cog/modules/karajan2/src/org/globus/cog/karajan/compiler/QName.java
branches/karajan2/src/cog/modules/karajan2/src/org/globus/cog/karajan/compiler/Scope.java
branches/karajan2/src/cog/modules/karajan2/src/org/globus/cog/karajan/compiler/State.java
branches/karajan2/src/cog/modules/karajan2/src/org/globus/cog/karajan/compiler/Type.java
branches/karajan2/src/cog/modules/karajan2/src/org/globus/cog/karajan/compiler/TypedValue.java
branches/karajan2/src/cog/modules/karajan2/src/org/globus/cog/karajan/compiler/VarRef.java
branches/karajan2/src/cog/modules/karajan2/src/org/globus/cog/karajan/compiler/VariableNotFoundException.java
branches/karajan2/src/cog/modules/karajan2/src/org/globus/cog/karajan/compiler/kernel/
branches/karajan2/src/cog/modules/karajan2/src/org/globus/cog/karajan/compiler/kernel/Def.java
branches/karajan2/src/cog/modules/karajan2/src/org/globus/cog/karajan/compiler/kernel/Export.java
branches/karajan2/src/cog/modules/karajan2/src/org/globus/cog/karajan/compiler/kernel/For.java
branches/karajan2/src/cog/modules/karajan2/src/org/globus/cog/karajan/compiler/kernel/Function.java
branches/karajan2/src/cog/modules/karajan2/src/org/globus/cog/karajan/compiler/kernel/GenericSeq.java
branches/karajan2/src/cog/modules/karajan2/src/org/globus/cog/karajan/compiler/kernel/If.java
branches/karajan2/src/cog/modules/karajan2/src/org/globus/cog/karajan/compiler/kernel/Import.java
branches/karajan2/src/cog/modules/karajan2/src/org/globus/cog/karajan/compiler/kernel/Invoke.java
branches/karajan2/src/cog/modules/karajan2/src/org/globus/cog/karajan/compiler/kernel/Karajan.java
branches/karajan2/src/cog/modules/karajan2/src/org/globus/cog/karajan/compiler/kernel/Named.java
branches/karajan2/src/cog/modules/karajan2/src/org/globus/cog/karajan/compiler/kernel/Native.java
branches/karajan2/src/cog/modules/karajan2/src/org/globus/cog/karajan/compiler/kernel/Num.java
branches/karajan2/src/cog/modules/karajan2/src/org/globus/cog/karajan/compiler/kernel/Par.java
branches/karajan2/src/cog/modules/karajan2/src/org/globus/cog/karajan/compiler/kernel/Seq.java
branches/karajan2/src/cog/modules/karajan2/src/org/globus/cog/karajan/compiler/kernel/Set.java
branches/karajan2/src/cog/modules/karajan2/src/org/globus/cog/karajan/compiler/kernel/Str.java
branches/karajan2/src/cog/modules/karajan2/src/org/globus/cog/karajan/compiler/kernel/Var.java
branches/karajan2/src/cog/modules/karajan2/src/org/globus/cog/karajan/compiler/types/
branches/karajan2/src/cog/modules/karajan2/src/org/globus/cog/karajan/compiler/types/ChannelType.java
branches/karajan2/src/cog/modules/karajan2/src/org/globus/cog/karajan/compiler/types/NamedType.java
branches/karajan2/src/cog/modules/karajan2/src/org/globus/cog/karajan/compiler/types/Null.java
branches/karajan2/src/cog/modules/karajan2/src/org/globus/cog/karajan/compiler/types/ProductType.java
branches/karajan2/src/cog/modules/karajan2/src/org/globus/cog/karajan/compiler/types/SimpleType.java
branches/karajan2/src/cog/modules/karajan2/src/org/globus/cog/karajan/compiler/types/TypeReductor.java
branches/karajan2/src/cog/modules/karajan2/src/org/globus/cog/karajan/compiler/types/Types.java
branches/karajan2/src/cog/modules/karajan2/src/org/globus/cog/karajan/compiler/types/UnionType.java
branches/karajan2/src/cog/modules/karajan2/src/org/globus/cog/karajan/compiler/types/UnknownType.java
branches/karajan2/src/cog/modules/karajan2/src/org/globus/cog/karajan/lib/
branches/karajan2/src/cog/modules/karajan2/src/org/globus/cog/karajan/lib/NativeLambda.java
branches/karajan2/src/cog/modules/karajan2/src/org/globus/cog/karajan/lib/sys/
branches/karajan2/src/cog/modules/karajan2/src/org/globus/cog/karajan/lib/sys/Echo.java
branches/karajan2/src/cog/modules/karajan2/src/org/globus/cog/karajan/lib/sys/Equals.java
branches/karajan2/src/cog/modules/karajan2/src/org/globus/cog/karajan/lib/sys/GreaterThan.java
branches/karajan2/src/cog/modules/karajan2/src/org/globus/cog/karajan/lib/sys/KException.java
branches/karajan2/src/cog/modules/karajan2/src/org/globus/cog/karajan/lib/sys/LessThan.java
branches/karajan2/src/cog/modules/karajan2/src/org/globus/cog/karajan/lib/sys/Minus.java
branches/karajan2/src/cog/modules/karajan2/src/org/globus/cog/karajan/lib/sys/Plus.java
branches/karajan2/src/cog/modules/karajan2/src/org/globus/cog/karajan/lib/sys/Print.java
branches/karajan2/src/cog/modules/karajan2/src/org/globus/cog/karajan/lib/sys/Range.java
branches/karajan2/src/cog/modules/karajan2/src/org/globus/cog/karajan/lib/sys/Throw.java
branches/karajan2/src/cog/modules/karajan2/src/org/globus/cog/karajan/lib/sys/Times.java
branches/karajan2/src/cog/modules/karajan2/src/org/globus/cog/karajan/lib/sys/Wait.java
branches/karajan2/src/cog/modules/karajan2/src/org/globus/cog/karajan/parser/
branches/karajan2/src/cog/modules/karajan2/src/org/globus/cog/karajan/parser/AbstractGrammarElement.java
branches/karajan2/src/cog/modules/karajan2/src/org/globus/cog/karajan/parser/And.java
branches/karajan2/src/cog/modules/karajan2/src/org/globus/cog/karajan/parser/ElementTree.java
branches/karajan2/src/cog/modules/karajan2/src/org/globus/cog/karajan/parser/EvaluationContext.java
branches/karajan2/src/cog/modules/karajan2/src/org/globus/cog/karajan/parser/EvaluationException.java
branches/karajan2/src/cog/modules/karajan2/src/org/globus/cog/karajan/parser/Grammar.java
branches/karajan2/src/cog/modules/karajan2/src/org/globus/cog/karajan/parser/GrammarElement.java
branches/karajan2/src/cog/modules/karajan2/src/org/globus/cog/karajan/parser/GrammarException.java
branches/karajan2/src/cog/modules/karajan2/src/org/globus/cog/karajan/parser/Lexer.java
branches/karajan2/src/cog/modules/karajan2/src/org/globus/cog/karajan/parser/Node.java
branches/karajan2/src/cog/modules/karajan2/src/org/globus/cog/karajan/parser/OptimizerException.java
branches/karajan2/src/cog/modules/karajan2/src/org/globus/cog/karajan/parser/Or.java
branches/karajan2/src/cog/modules/karajan2/src/org/globus/cog/karajan/parser/ParseTree.java
branches/karajan2/src/cog/modules/karajan2/src/org/globus/cog/karajan/parser/Parser.java
branches/karajan2/src/cog/modules/karajan2/src/org/globus/cog/karajan/parser/ParserContext.java
branches/karajan2/src/cog/modules/karajan2/src/org/globus/cog/karajan/parser/ParsingException.java
branches/karajan2/src/cog/modules/karajan2/src/org/globus/cog/karajan/parser/PeekableEnumeration.java
branches/karajan2/src/cog/modules/karajan2/src/org/globus/cog/karajan/parser/PredicateMapping.java
branches/karajan2/src/cog/modules/karajan2/src/org/globus/cog/karajan/parser/Rule.java
branches/karajan2/src/cog/modules/karajan2/src/org/globus/cog/karajan/parser/Rules.java
branches/karajan2/src/cog/modules/karajan2/src/org/globus/cog/karajan/parser/SimpleLexer.java
branches/karajan2/src/cog/modules/karajan2/src/org/globus/cog/karajan/parser/Stack.java
branches/karajan2/src/cog/modules/karajan2/src/org/globus/cog/karajan/parser/UndefinedVariableException.java
branches/karajan2/src/cog/modules/karajan2/src/org/globus/cog/karajan/parser/UnresolvedRule.java
branches/karajan2/src/cog/modules/karajan2/src/org/globus/cog/karajan/parser/predicates/
branches/karajan2/src/cog/modules/karajan2/src/org/globus/cog/karajan/parser/predicates/AbstractBinaryNumericEvaluator.java
branches/karajan2/src/cog/modules/karajan2/src/org/globus/cog/karajan/parser/predicates/AbstractBinaryNumericPredicate.java
branches/karajan2/src/cog/modules/karajan2/src/org/globus/cog/karajan/parser/predicates/AbstractEvaluator.java
branches/karajan2/src/cog/modules/karajan2/src/org/globus/cog/karajan/parser/predicates/AbstractPredicate.java
branches/karajan2/src/cog/modules/karajan2/src/org/globus/cog/karajan/parser/predicates/Add.java
branches/karajan2/src/cog/modules/karajan2/src/org/globus/cog/karajan/parser/predicates/AddToChild.java
branches/karajan2/src/cog/modules/karajan2/src/org/globus/cog/karajan/parser/predicates/Alphanumeric.java
branches/karajan2/src/cog/modules/karajan2/src/org/globus/cog/karajan/parser/predicates/AnyToken.java
branches/karajan2/src/cog/modules/karajan2/src/org/globus/cog/karajan/parser/predicates/Comma.java
branches/karajan2/src/cog/modules/karajan2/src/org/globus/cog/karajan/parser/predicates/Concat.java
branches/karajan2/src/cog/modules/karajan2/src/org/globus/cog/karajan/parser/predicates/Digits.java
branches/karajan2/src/cog/modules/karajan2/src/org/globus/cog/karajan/parser/predicates/Divide.java
branches/karajan2/src/cog/modules/karajan2/src/org/globus/cog/karajan/parser/predicates/Drop.java
branches/karajan2/src/cog/modules/karajan2/src/org/globus/cog/karajan/parser/predicates/EOF.java
branches/karajan2/src/cog/modules/karajan2/src/org/globus/cog/karajan/parser/predicates/Emit.java
branches/karajan2/src/cog/modules/karajan2/src/org/globus/cog/karajan/parser/predicates/EmptyString.java
branches/karajan2/src/cog/modules/karajan2/src/org/globus/cog/karajan/parser/predicates/Epsilon.java
branches/karajan2/src/cog/modules/karajan2/src/org/globus/cog/karajan/parser/predicates/Error.java
branches/karajan2/src/cog/modules/karajan2/src/org/globus/cog/karajan/parser/predicates/Evaluator.java
branches/karajan2/src/cog/modules/karajan2/src/org/globus/cog/karajan/parser/predicates/Fractional.java
branches/karajan2/src/cog/modules/karajan2/src/org/globus/cog/karajan/parser/predicates/HorizontalWhitespace.java
branches/karajan2/src/cog/modules/karajan2/src/org/globus/cog/karajan/parser/predicates/IgnoreWhitespace.java
branches/karajan2/src/cog/modules/karajan2/src/org/globus/cog/karajan/parser/predicates/Inspect.java
branches/karajan2/src/cog/modules/karajan2/src/org/globus/cog/karajan/parser/predicates/Integral.java
branches/karajan2/src/cog/modules/karajan2/src/org/globus/cog/karajan/parser/predicates/Letter.java
branches/karajan2/src/cog/modules/karajan2/src/org/globus/cog/karajan/parser/predicates/List.java
branches/karajan2/src/cog/modules/karajan2/src/org/globus/cog/karajan/parser/predicates/ListAdd.java
branches/karajan2/src/cog/modules/karajan2/src/org/globus/cog/karajan/parser/predicates/Literal.java
branches/karajan2/src/cog/modules/karajan2/src/org/globus/cog/karajan/parser/predicates/LiteralNC.java
branches/karajan2/src/cog/modules/karajan2/src/org/globus/cog/karajan/parser/predicates/Multiply.java
branches/karajan2/src/cog/modules/karajan2/src/org/globus/cog/karajan/parser/predicates/Negate.java
branches/karajan2/src/cog/modules/karajan2/src/org/globus/cog/karajan/parser/predicates/Newline.java
branches/karajan2/src/cog/modules/karajan2/src/org/globus/cog/karajan/parser/predicates/NotLiteral.java
branches/karajan2/src/cog/modules/karajan2/src/org/globus/cog/karajan/parser/predicates/Op.java
branches/karajan2/src/cog/modules/karajan2/src/org/globus/cog/karajan/parser/predicates/Push.java
branches/karajan2/src/cog/modules/karajan2/src/org/globus/cog/karajan/parser/predicates/Remainder.java
branches/karajan2/src/cog/modules/karajan2/src/org/globus/cog/karajan/parser/predicates/Rot.java
branches/karajan2/src/cog/modules/karajan2/src/org/globus/cog/karajan/parser/predicates/StringPredicate.java
branches/karajan2/src/cog/modules/karajan2/src/org/globus/cog/karajan/parser/predicates/Subtract.java
branches/karajan2/src/cog/modules/karajan2/src/org/globus/cog/karajan/parser/predicates/Swap.java
branches/karajan2/src/cog/modules/karajan2/src/org/globus/cog/karajan/parser/predicates/Underscore.java
branches/karajan2/src/cog/modules/karajan2/src/org/globus/cog/karajan/parser/predicates/Variable.java
branches/karajan2/src/cog/modules/karajan2/src/org/globus/cog/karajan/runtime/
branches/karajan2/src/cog/modules/karajan2/src/org/globus/cog/karajan/runtime/Arguments.java
branches/karajan2/src/cog/modules/karajan2/src/org/globus/cog/karajan/runtime/Callable.java
branches/karajan2/src/cog/modules/karajan2/src/org/globus/cog/karajan/runtime/Channel.java
branches/karajan2/src/cog/modules/karajan2/src/org/globus/cog/karajan/runtime/Channels.java
branches/karajan2/src/cog/modules/karajan2/src/org/globus/cog/karajan/runtime/Context.java
branches/karajan2/src/cog/modules/karajan2/src/org/globus/cog/karajan/runtime/Exceptions.java
branches/karajan2/src/cog/modules/karajan2/src/org/globus/cog/karajan/runtime/ExecutionException.java
branches/karajan2/src/cog/modules/karajan2/src/org/globus/cog/karajan/runtime/KFile.java
branches/karajan2/src/cog/modules/karajan2/src/org/globus/cog/karajan/runtime/KIterator.java
branches/karajan2/src/cog/modules/karajan2/src/org/globus/cog/karajan/runtime/KLine.java
branches/karajan2/src/cog/modules/karajan2/src/org/globus/cog/karajan/runtime/MemoryChannel.java
branches/karajan2/src/cog/modules/karajan2/src/org/globus/cog/karajan/runtime/NVPair.java
branches/karajan2/src/cog/modules/karajan2/src/org/globus/cog/karajan/runtime/OrderedParallelChannel.java
branches/karajan2/src/cog/modules/karajan2/src/org/globus/cog/karajan/runtime/Signature.java
branches/karajan2/src/cog/modules/karajan2/src/org/globus/cog/karajan/runtime/Sink.java
branches/karajan2/src/cog/modules/karajan2/src/org/globus/cog/karajan/runtime/StdSink.java
branches/karajan2/src/cog/modules/karajan2/src/org/globus/cog/karajan/runtime/Types.java
branches/karajan2/src/cog/modules/karajan2/src/org/globus/cog/karajan/threading/
branches/karajan2/src/cog/modules/karajan2/src/org/globus/cog/karajan/threading/KRunnable.java
branches/karajan2/src/cog/modules/karajan2/src/org/globus/cog/karajan/threading/LWThread.java
branches/karajan2/src/cog/modules/karajan2/src/org/globus/cog/karajan/threading/LWThreadDeath.java
branches/karajan2/src/cog/modules/karajan2/src/org/globus/cog/karajan/threading/Scheduler.java
branches/karajan2/src/cog/modules/karajan2/src/org/globus/cog/karajan/threading/SchedulerThread.java
branches/karajan2/src/cog/modules/karajan2/src/org/globus/cog/karajan/threading/State.java
branches/karajan2/src/cog/modules/karajan2/src/org/globus/cog/karajan/threading/StateTables.java
branches/karajan2/src/cog/modules/karajan2/src/org/globus/cog/karajan/threading/Yield.java
branches/karajan2/src/cog/modules/karajan2/src/org/globus/cog/karajan/translator/
branches/karajan2/src/cog/modules/karajan2/src/org/globus/cog/karajan/translator/IndentationLevel.java
branches/karajan2/src/cog/modules/karajan2/src/org/globus/cog/karajan/translator/KarajanTranslator.java
branches/karajan2/src/cog/modules/karajan2/src/org/globus/cog/karajan/translator/TranslationContext.java
branches/karajan2/src/cog/modules/karajan2/src/org/globus/cog/karajan/translator/TranslationException.java
branches/karajan2/src/cog/modules/karajan2/src/org/globus/cog/karajan/translator/predicates/
branches/karajan2/src/cog/modules/karajan2/src/org/globus/cog/karajan/translator/predicates/AbstractKarajanEvaluator.java
branches/karajan2/src/cog/modules/karajan2/src/org/globus/cog/karajan/translator/predicates/AddChild.java
branches/karajan2/src/cog/modules/karajan2/src/org/globus/cog/karajan/translator/predicates/BeginElement.java
branches/karajan2/src/cog/modules/karajan2/src/org/globus/cog/karajan/translator/predicates/CommaSeparator.java
branches/karajan2/src/cog/modules/karajan2/src/org/globus/cog/karajan/translator/predicates/Concat.java
branches/karajan2/src/cog/modules/karajan2/src/org/globus/cog/karajan/translator/predicates/ElementDef.java
branches/karajan2/src/cog/modules/karajan2/src/org/globus/cog/karajan/translator/predicates/EmptyProgram.java
branches/karajan2/src/cog/modules/karajan2/src/org/globus/cog/karajan/translator/predicates/EndElement.java
branches/karajan2/src/cog/modules/karajan2/src/org/globus/cog/karajan/translator/predicates/Identifier.java
branches/karajan2/src/cog/modules/karajan2/src/org/globus/cog/karajan/translator/predicates/Include.java
branches/karajan2/src/cog/modules/karajan2/src/org/globus/cog/karajan/translator/predicates/KarajanEvaluator.java
branches/karajan2/src/cog/modules/karajan2/src/org/globus/cog/karajan/translator/predicates/Kernel.java
branches/karajan2/src/cog/modules/karajan2/src/org/globus/cog/karajan/translator/predicates/MultiLineComment.java
branches/karajan2/src/cog/modules/karajan2/src/org/globus/cog/karajan/translator/predicates/Named.java
branches/karajan2/src/cog/modules/karajan2/src/org/globus/cog/karajan/translator/predicates/Namespace.java
branches/karajan2/src/cog/modules/karajan2/src/org/globus/cog/karajan/translator/predicates/NumericValue.java
branches/karajan2/src/cog/modules/karajan2/src/org/globus/cog/karajan/translator/predicates/RemoveChild.java
branches/karajan2/src/cog/modules/karajan2/src/org/globus/cog/karajan/translator/predicates/SingleLineComment.java
branches/karajan2/src/cog/modules/karajan2/src/org/globus/cog/karajan/translator/predicates/StringToken.java
branches/karajan2/src/cog/modules/karajan2/src/org/globus/cog/karajan/translator/predicates/StringValue.java
branches/karajan2/src/cog/modules/karajan2/src/org/globus/cog/karajan/translator/predicates/Transliterate.java
branches/karajan2/src/cog/modules/karajan2/src/org/globus/cog/karajan/translator/predicates/Transliterator.java
branches/karajan2/src/cog/modules/karajan2/src/org/globus/cog/karajan/translator/predicates/Variable.java
branches/karajan2/src/cog/modules/karajan2/src/org/globus/cog/karajan/util/
branches/karajan2/src/cog/modules/karajan2/src/org/globus/cog/karajan/util/ANSI.java
branches/karajan2/src/cog/modules/karajan2/src/org/globus/cog/karajan/util/AdaptiveArrayList.java
branches/karajan2/src/cog/modules/karajan2/src/org/globus/cog/karajan/util/AdaptiveMap.java
branches/karajan2/src/cog/modules/karajan2/src/org/globus/cog/karajan/util/MapFactory.java
branches/karajan2/src/cog/modules/karajan2/src/org/globus/cog/karajan/util/Queue.java
branches/karajan2/src/cog/modules/karajan2/src/org/globus/cog/karajan/util/serialization/
branches/karajan2/src/cog/modules/karajan2/src/org/globus/cog/karajan/util/serialization/AbstractElementMarshallingPolicy.java
branches/karajan2/src/cog/modules/karajan2/src/org/globus/cog/karajan/util/serialization/AbstractKarajanConverter.java
branches/karajan2/src/cog/modules/karajan2/src/org/globus/cog/karajan/util/serialization/DecimalFormatConverter.java
branches/karajan2/src/cog/modules/karajan2/src/org/globus/cog/karajan/util/serialization/ElementMarshallingPolicy.java
branches/karajan2/src/cog/modules/karajan2/src/org/globus/cog/karajan/util/serialization/KarajanMarshallingStrategy.java
branches/karajan2/src/cog/modules/karajan2/src/org/globus/cog/karajan/util/serialization/KarajanSerializationContext.java
branches/karajan2/src/cog/modules/karajan2/src/org/globus/cog/karajan/util/serialization/NodeConverter.java
branches/karajan2/src/cog/modules/karajan2/src/org/globus/cog/karajan/util/serialization/NullConverter.java
branches/karajan2/src/cog/modules/karajan2/src/org/globus/cog/karajan/util/serialization/RestrictedClassMapper.java
branches/karajan2/src/cog/modules/karajan2/src/org/globus/cog/karajan/util/serialization/SimpleDateFormatConverter.java
branches/karajan2/src/cog/modules/karajan2/src/org/globus/cog/karajan/util/serialization/SourceElementMarshallingPolicy.java
branches/karajan2/src/cog/modules/karajan2/src/org/globus/cog/karajan/util/serialization/SourceMarshaller.java
branches/karajan2/src/cog/modules/karajan2/src/org/globus/cog/karajan/util/serialization/SourceMarshallingStrategy.java
branches/karajan2/src/cog/modules/karajan2/src/org/globus/cog/karajan/util/serialization/XMLConverter.java
branches/karajan2/src/cog/modules/karajan2/src/org/globus/cog/karajan/util/serialization/XMLUtils.java
Added: branches/karajan2/src/cog/modules/karajan2/build.xml
===================================================================
--- branches/karajan2/src/cog/modules/karajan2/build.xml (rev 0)
+++ branches/karajan2/src/cog/modules/karajan2/build.xml 2008-06-12 22:45:56 UTC (rev 2037)
@@ -0,0 +1,152 @@
+<project name="Java CoG Kit" default="dist" basedir=".">
+
+ <property file="project.properties"/>
+ <property name="cog.dir" value="${basedir}/../../"/>
+ <property name="main.buildfile" value="${cog.dir}/mbuild.xml"/>
+ <property name="dist.dir" value="${cog.dir}/modules/${module.name}/dist/${module.name}-${version}"/>
+ <property name="build.dir" value="${cog.dir}/modules/${module.name}/build"/>
+
+ <!-- _________________________________________________________________ -->
+ <!-- / \ -->
+ <!-- | Help | -->
+ <!-- \_________________________________________________________________/ -->
+
+ <target name="help">
+ <echo>
+ Available targets:
+ help:
+ prints out this help message
+
+ dist:
+ creates a distribution directory of the
+ ${project} ${long.name}
+
+ jar:
+ creates a jar file for the ${project} ${long.name}
+ named ${jar.filename}
+
+ javadoc:
+ creates the documentation
+
+ clean:
+ removes the compiled classes
+
+ distclean:
+ deletes the distribution directory
+
+ all:
+ dist and javadoc
+
+ deploy.webstart:
+ deploys the module as a webstart application
+
+ dist.joint:
+ builds everything into one jar file. Should only
+ be used globally (from all)
+
+ fixeol:
+ change newlines to the unix standard
+ </echo>
+ </target>
+
+
+ <!-- _________________________________________________________________ -->
+ <!-- / \ -->
+ <!-- | Dist | -->
+ <!-- \_________________________________________________________________/ -->
+
+ <target name="dist">
+ <ant antfile="${main.buildfile}" target="dist"/>
+ </target>
+
+
+ <!-- _________________________________________________________________ -->
+ <!-- / \ -->
+ <!-- | Compile | -->
+ <!-- \_________________________________________________________________/ -->
+
+ <target name="compile">
+ <ant antfile="${main.buildfile}" target="compile"/>
+ </target>
+
+ <!-- _________________________________________________________________ -->
+ <!-- / \ -->
+ <!-- | Clean | -->
+ <!-- \_________________________________________________________________/ -->
+
+ <target name="clean">
+ <ant antfile="${main.buildfile}" target="clean"/>
+ </target>
+
+
+ <!-- _________________________________________________________________ -->
+ <!-- / \ -->
+ <!-- | Distclean | -->
+ <!-- \_________________________________________________________________/ -->
+
+ <target name="distclean">
+ <ant antfile="${main.buildfile}" target="distclean"/>
+ </target>
+
+
+ <!-- _________________________________________________________________ -->
+ <!-- / \ -->
+ <!-- | Jar | -->
+ <!-- \_________________________________________________________________/ -->
+
+ <target name="jar">
+ <ant antfile="${main.buildfile}" target="jar"/>
+ </target>
+
+
+ <!-- _________________________________________________________________ -->
+ <!-- / \ -->
+ <!-- | Javadoc | -->
+ <!-- \_________________________________________________________________/ -->
+
+ <target name="javadoc">
+ <ant antfile="${main.buildfile}" target="javadoc"/>
+ </target>
+
+
+
+ <!-- _________________________________________________________________ -->
+ <!-- / \ -->
+ <!-- | PMD | -->
+ <!-- \_________________________________________________________________/ -->
+
+ <target name="pmd">
+ <ant antfile="${main.buildfile}" target="pmd"/>
+ </target>
+
+ <target name="deploy.webstart">
+ <ant antfile="${main.buildfile}" target="deploy.webstart"/>
+ </target>
+
+ <target name="replacelibs">
+ <ant antfile="${main.buildfile}" target="replacelibs"/>
+ </target>
+
+ <target name="webstart.launchers">
+ <ant antfile="${main.buildfile}" target="webstart.launchers"/>
+ </target>
+
+ <target name="dist.joint">
+ <ant antfile="${main.buildfile}" target="dist.all"/>
+ </target>
+
+ <target name="module.package">
+ <ant antfile="${main.buildfile}" target="module.package"/>
+ </target>
+
+ <!-- ================================================ -->
+ <!-- fixeol -->
+ <!-- ================================================ -->
+
+ <target name="fixeol">
+ <ant antfile="${main.buildfile}" target="fixeol"/>
+ </target>
+
+</project>
+
+
Added: branches/karajan2/src/cog/modules/karajan2/dependencies.xml
===================================================================
--- branches/karajan2/src/cog/modules/karajan2/dependencies.xml (rev 0)
+++ branches/karajan2/src/cog/modules/karajan2/dependencies.xml 2008-06-12 22:45:56 UTC (rev 2037)
@@ -0,0 +1,8 @@
+<project name="Project dependencies" default="deps" basedir=".">
+ <!-- project dependencies -->
+ <target name="deps">
+ <ant antfile="${main.buildfile}" target="dep">
+ <property name="module" value="util"/>
+ </ant>
+ </target>
+</project>
Added: branches/karajan2/src/cog/modules/karajan2/etc/MANIFEST.MF.head
===================================================================
--- branches/karajan2/src/cog/modules/karajan2/etc/MANIFEST.MF.head (rev 0)
+++ branches/karajan2/src/cog/modules/karajan2/etc/MANIFEST.MF.head 2008-06-12 22:45:56 UTC (rev 2037)
@@ -0,0 +1 @@
+Manifest-Version: 1.0
Added: branches/karajan2/src/cog/modules/karajan2/etc/MANIFEST.MF.tail
===================================================================
--- branches/karajan2/src/cog/modules/karajan2/etc/MANIFEST.MF.tail (rev 0)
+++ branches/karajan2/src/cog/modules/karajan2/etc/MANIFEST.MF.tail 2008-06-12 22:45:56 UTC (rev 2037)
@@ -0,0 +1 @@
+
Added: branches/karajan2/src/cog/modules/karajan2/etc/karajan.properties
===================================================================
--- branches/karajan2/src/cog/modules/karajan2/etc/karajan.properties (rev 0)
+++ branches/karajan2/src/cog/modules/karajan2/etc/karajan.properties 2008-06-12 22:45:56 UTC (rev 2037)
@@ -0,0 +1 @@
+include.dirs=.:@classpath/
Added: branches/karajan2/src/cog/modules/karajan2/examples/currying.k
===================================================================
--- branches/karajan2/src/cog/modules/karajan2/examples/currying.k (rev 0)
+++ branches/karajan2/src/cog/modules/karajan2/examples/currying.k 2008-06-12 22:45:56 UTC (rev 2037)
@@ -0,0 +1,12 @@
+import(sys)
+
+g := function(x) {
+ function(y) {
+ echo(x, ", ", y)
+ }
+}
+
+a1 := g(1)
+a2 := g(3)
+a1(2)
+a2(4)
Added: branches/karajan2/src/cog/modules/karajan2/examples/order.k
===================================================================
--- branches/karajan2/src/cog/modules/karajan2/examples/order.k (rev 0)
+++ branches/karajan2/src/cog/modules/karajan2/examples/order.k 2008-06-12 22:45:56 UTC (rev 2037)
@@ -0,0 +1,14 @@
+import(sys)
+
+par(
+ seq(
+ wait(delay=200)
+ echo("a1")
+ print("b1")
+ )
+ seq(
+ wait(delay=100)
+ echo("a2")
+ print("b2")
+ )
+)
\ No newline at end of file
Added: branches/karajan2/src/cog/modules/karajan2/examples/order_dot_k.class
===================================================================
(Binary files differ)
Property changes on: branches/karajan2/src/cog/modules/karajan2/examples/order_dot_k.class
___________________________________________________________________
Name: svn:mime-type
+ application/octet-stream
Added: branches/karajan2/src/cog/modules/karajan2/examples/order_dot_k.java
===================================================================
--- branches/karajan2/src/cog/modules/karajan2/examples/order_dot_k.java (rev 0)
+++ branches/karajan2/src/cog/modules/karajan2/examples/order_dot_k.java 2008-06-12 22:45:56 UTC (rev 2037)
@@ -0,0 +1,235 @@
+import org.globus.cog.karajan.threading.LWThread;
+import org.globus.cog.karajan.threading.Yield;
+import org.globus.cog.karajan.runtime.Context;
+import org.globus.cog.karajan.runtime.Channel;
+import org.globus.cog.karajan.runtime.Exceptions;
+import org.globus.cog.karajan.runtime.KFile;
+import org.globus.cog.karajan.runtime.KLine;
+import org.globus.cog.karajan.runtime.Callable;
+import org.globus.cog.karajan.runtime.StdSink.StdoutSink;
+import org.globus.cog.karajan.runtime.StdSink.StderrSink;
+import org.globus.cog.karajan.runtime.NVPair;
+import org.globus.cog.karajan.runtime.Arguments;
+import java.util.Collection;
+import org.globus.cog.karajan.threading.StateTables;
+import org.globus.cog.karajan.threading.LWThreadDeath;
+import org.globus.cog.karajan.threading.KRunnable;
+import org.globus.cog.karajan.runtime.OrderedParallelChannel;
+import org.globus.cog.karajan.runtime.KIterator;
+import org.globus.cog.karajan.runtime.ExecutionException;
+
+
+@KFile("order_dot_k")
+public final class order_dot_k implements KRunnable {
+ public static void main(String[] args) {
+ LWThread thread = new LWThread(new order_dot_k());
+ thread.start();
+ try {
+ thread.waitFor();
+ }
+ catch (InterruptedException e) {
+ e.printStackTrace();
+ }
+ }
+
+ public void run() {
+ run(LWThread.currentThread().getContext());
+ }
+
+ public void run(Context ctx) {
+ try {
+ LWThread thread = LWThread.currentThread();
+ thread.checkSlice();
+ int __state__ = thread.popState();
+ switch(__state__) {
+ case 0:
+ thread.setContext(ctx = new Context(20, ctx));
+ case 1:
+ ctx.pushChannel(1, new StdoutSink());
+ ctx.pushChannel(2, new StderrSink());
+ //[Exception, throw, range, __eq___eq_, __times_, __plus_, wait, __gt_, echo, print, __lt_, __minus_]
+ thread.setContext(ctx = new Context(12, ctx));
+ case 2:
+ k_dot_import000000(ctx);
+ case 3:
+ k_dot_par000001(ctx);
+ thread.setContext(ctx = ctx.p);
+ thread.setContext(ctx = ctx.p);
+ }
+ }
+ catch (Exception e) {
+ Exceptions.handleException(e);
+ }
+ }
+
+ // import (order_dot_k:1)
+ @KLine("1")
+ private void k_dot_import000000(Context ctx) throws Exception {
+ LWThread thread = LWThread.currentThread();
+ thread.checkSlice();
+ int __state__ = thread.popState();
+ switch(__state__) {
+ case 0:
+ ctx.pushChannel(0);
+ case 1:
+ ((KRunnable) getClass().getClassLoader().loadClass("sys_dot_k").newInstance()).run(ctx);
+ Channel c = ctx.popChannel(0);
+ ctx.set(0, c.get(0));
+ ctx.set(1, c.get(1));
+ ctx.set(2, c.get(2));
+ ctx.set(3, c.get(3));
+ ctx.set(4, c.get(4));
+ ctx.set(5, c.get(5));
+ ctx.set(6, c.get(6));
+ ctx.set(7, c.get(7));
+ ctx.set(8, c.get(8));
+ ctx.set(9, c.get(9));
+ ctx.set(10, c.get(10));
+ ctx.set(11, c.get(11));
+ }
+ }
+
+ private Object k_dot_named000003(Context ctx){
+ ctx.pushChannel(0);
+ try {
+ // k.number (order_dot_k:9)
+ ctx.append(0, new Double(200));
+ return ctx.getChannel(0).get(0);
+ }
+ finally {
+ ctx.popChannel(0);
+ }
+ }
+ // seq (order_dot_k:5)
+ @KLine("5")
+ private void k_dot_seq000002(Context ctx) throws Exception {
+ LWThread thread = LWThread.currentThread();
+ thread.checkSlice();
+ int __state__ = thread.popState();
+ switch(__state__) {
+ case 0:
+ // wait (order_dot_k:5)
+ ctx.pushChannel(0, new Arguments(2, 0, 0, false, org.globus.cog.karajan.lib.sys.Wait.SIGNATURE.getDefaultValues(), ctx, ctx));
+ // k.named (order_dot_k:9)
+ ((Arguments) ctx.getChannel(0)).set(0, k_dot_named000003(ctx));
+ thread.setContext(ctx = (Arguments) ctx.popChannel(0));
+ case 1:
+ ((Callable) ctx.p.p.get(3)).invoke(ctx);
+ thread.setContext(ctx = ((Arguments) ctx).s);
+ // echo (order_dot_k:6)
+ ctx.pushChannel(0, new Arguments(1, 0, 0, true, org.globus.cog.karajan.lib.sys.Echo.SIGNATURE.getDefaultValues(), ctx, ctx));
+ // k.string (order_dot_k:13)
+ ctx.append(0, "a1");
+ thread.setContext(ctx = (Arguments) ctx.popChannel(0));
+ case 2:
+ ((Callable) ctx.p.p.get(0)).invoke(ctx);
+ thread.setContext(ctx = ((Arguments) ctx).s);
+ // print (order_dot_k:7)
+ ctx.pushChannel(0, new Arguments(1, 0, 0, true, org.globus.cog.karajan.lib.sys.Print.SIGNATURE.getDefaultValues(), ctx, ctx));
+ // k.string (order_dot_k:16)
+ ctx.append(0, "b1");
+ thread.setContext(ctx = (Arguments) ctx.popChannel(0));
+ case 3:
+ ((Callable) ctx.p.p.get(1)).invoke(ctx);
+ thread.setContext(ctx = ((Arguments) ctx).s);
+ }
+ }
+
+ private Object k_dot_named000005(Context ctx){
+ ctx.pushChannel(0);
+ try {
+ // k.number (order_dot_k:22)
+ ctx.append(0, new Double(100));
+ return ctx.getChannel(0).get(0);
+ }
+ finally {
+ ctx.popChannel(0);
+ }
+ }
+ // seq (order_dot_k:10)
+ @KLine("10")
+ private void k_dot_seq000004(Context ctx) throws Exception {
+ LWThread thread = LWThread.currentThread();
+ thread.checkSlice();
+ int __state__ = thread.popState();
+ switch(__state__) {
+ case 0:
+ // wait (order_dot_k:10)
+ ctx.pushChannel(0, new Arguments(2, 0, 0, false, org.globus.cog.karajan.lib.sys.Wait.SIGNATURE.getDefaultValues(), ctx, ctx));
+ // k.named (order_dot_k:22)
+ ((Arguments) ctx.getChannel(0)).set(0, k_dot_named000005(ctx));
+ thread.setContext(ctx = (Arguments) ctx.popChannel(0));
+ case 1:
+ ((Callable) ctx.p.p.get(3)).invoke(ctx);
+ thread.setContext(ctx = ((Arguments) ctx).s);
+ // echo (order_dot_k:11)
+ ctx.pushChannel(0, new Arguments(1, 0, 0, true, org.globus.cog.karajan.lib.sys.Echo.SIGNATURE.getDefaultValues(), ctx, ctx));
+ // k.string (order_dot_k:26)
+ ctx.append(0, "a2");
+ thread.setContext(ctx = (Arguments) ctx.popChannel(0));
+ case 2:
+ ((Callable) ctx.p.p.get(0)).invoke(ctx);
+ thread.setContext(ctx = ((Arguments) ctx).s);
+ // print (order_dot_k:12)
+ ctx.pushChannel(0, new Arguments(1, 0, 0, true, org.globus.cog.karajan.lib.sys.Print.SIGNATURE.getDefaultValues(), ctx, ctx));
+ // k.string (order_dot_k:29)
+ ctx.append(0, "b2");
+ thread.setContext(ctx = (Arguments) ctx.popChannel(0));
+ case 3:
+ ((Callable) ctx.p.p.get(1)).invoke(ctx);
+ thread.setContext(ctx = ((Arguments) ctx).s);
+ }
+ }
+
+ // par (order_dot_k:4)
+ @KLine("4")
+ private void k_dot_par000001(Context ctx) throws Exception {
+ LWThread thread = LWThread.currentThread();
+ thread.checkSlice();
+ int __state__ = thread.popState();
+ switch(__state__) {
+ case 0:
+ LWThread[] t000006 = new LWThread[2];
+ t000006[0] = thread.fork(2);
+ t000006[0].setContext(new Context(ctx));
+ t000006[0].getContext().pushChannel(1, new OrderedParallelChannel(1, ctx, null));
+ t000006[1] = thread.fork(3);
+ t000006[1].setContext(new Context(ctx));
+ t000006[1].getContext().pushChannel(1, new OrderedParallelChannel(1, ctx, t000006[0].getContext()));
+ t000006[0].start();
+ t000006[1].start();
+ t000006 = null;
+ case 1:
+ thread.waitForChildren();
+ break;
+ case 2:
+ k_dot_seq000002(ctx);
+ ((OrderedParallelChannel) ctx.getChannel(1)).close();
+ thread.die();
+ case 3:
+ k_dot_seq000004(ctx);
+ ((OrderedParallelChannel) ctx.getChannel(1)).close();
+ thread.die();
+ }
+ }
+
+ public static final int[] __LINE_TABLE = new int[] {
+ 45, 47, 52, 54, 58, //run
+ 72, 74, 89, //k_dot_import000000
+ 110, 116, 124, 132, 135, //k_dot_seq000002
+ 156, 162, 170, 178, 181, //k_dot_seq000004
+ 191, 202, 205, 209//k_dot_par000001
+ };
+ public static final int[] __STATE_TABLE = new int[] {
+ 0, 1, 2, 3, -1, //run
+ 0, 1, -1, //k_dot_import000000
+ 0, 1, 2, 3, -1, //k_dot_seq000002
+ 0, 1, 2, 3, -1, //k_dot_seq000004
+ 0, 1, 2, 3//k_dot_par000001
+ };
+ static {
+ StateTables.register(order_dot_k.class);
+ }
+ public static void __exports__() {
+ }
+}
Added: branches/karajan2/src/cog/modules/karajan2/examples/recursion.k
===================================================================
--- branches/karajan2/src/cog/modules/karajan2/examples/recursion.k (rev 0)
+++ branches/karajan2/src/cog/modules/karajan2/examples/recursion.k 2008-06-12 22:45:56 UTC (rev 2037)
@@ -0,0 +1,7 @@
+import(sys)
+
+fact := function(n) {
+ if (n > 1, n * fact(n - 1), 1)
+}
+
+print(fact(10))
Added: branches/karajan2/src/cog/modules/karajan2/examples/scoping.k
===================================================================
--- branches/karajan2/src/cog/modules/karajan2/examples/scoping.k (rev 0)
+++ branches/karajan2/src/cog/modules/karajan2/examples/scoping.k 2008-06-12 22:45:56 UTC (rev 2037)
@@ -0,0 +1,18 @@
+import(sys)
+
+x := 0
+
+seq(
+ x := 1
+ echo(x)
+)
+
+f := function() {x}
+
+echo(x)
+
+x := 2
+
+echo(x)
+
+echo(f())
\ No newline at end of file
Added: branches/karajan2/src/cog/modules/karajan2/examples/sys.k
===================================================================
--- branches/karajan2/src/cog/modules/karajan2/examples/sys.k (rev 0)
+++ branches/karajan2/src/cog/modules/karajan2/examples/sys.k 2008-06-12 22:45:56 UTC (rev 2037)
@@ -0,0 +1,16 @@
+echo := native(org.globus.cog.karajan.lib.sys.Echo)
+print := native(org.globus.cog.karajan.lib.sys.Print)
+range := native(org.globus.cog.karajan.lib.sys.Range)
+wait := native(org.globus.cog.karajan.lib.sys.Wait)
+__eq___eq_ := native(org.globus.cog.karajan.lib.sys.Equals)
+__gt_ := native(org.globus.cog.karajan.lib.sys.GreaterThan)
+__lt_ := native(org.globus.cog.karajan.lib.sys.LessThan)
+__plus_ := native(org.globus.cog.karajan.lib.sys.Plus)
+__minus_ := native(org.globus.cog.karajan.lib.sys.Minus)
+__times_ := native(org.globus.cog.karajan.lib.sys.Times)
+
+throw := native(org.globus.cog.karajan.lib.sys.Throw)
+Exception := native(org.globus.cog.karajan.lib.sys.KException)
+
+export(echo, print, range, wait, __eq___eq_, __plus_, __minus_,
+ throw, Exception, __gt_, __lt_, __times_)
Added: branches/karajan2/src/cog/modules/karajan2/examples/sys_dot_k.class
===================================================================
(Binary files differ)
Property changes on: branches/karajan2/src/cog/modules/karajan2/examples/sys_dot_k.class
___________________________________________________________________
Name: svn:mime-type
+ application/octet-stream
Added: branches/karajan2/src/cog/modules/karajan2/examples/sys_dot_k.java
===================================================================
--- branches/karajan2/src/cog/modules/karajan2/examples/sys_dot_k.java (rev 0)
+++ branches/karajan2/src/cog/modules/karajan2/examples/sys_dot_k.java 2008-06-12 22:45:56 UTC (rev 2037)
@@ -0,0 +1,342 @@
+import org.globus.cog.karajan.threading.LWThread;
+import org.globus.cog.karajan.threading.Yield;
+import org.globus.cog.karajan.runtime.Context;
+import org.globus.cog.karajan.runtime.Channel;
+import org.globus.cog.karajan.runtime.Exceptions;
+import org.globus.cog.karajan.runtime.KFile;
+import org.globus.cog.karajan.runtime.KLine;
+import org.globus.cog.karajan.runtime.Callable;
+import org.globus.cog.karajan.runtime.StdSink.StdoutSink;
+import org.globus.cog.karajan.runtime.StdSink.StderrSink;
+import org.globus.cog.karajan.runtime.NVPair;
+import org.globus.cog.karajan.runtime.Arguments;
+import java.util.Collection;
+import org.globus.cog.karajan.threading.StateTables;
+import org.globus.cog.karajan.threading.LWThreadDeath;
+import org.globus.cog.karajan.threading.KRunnable;
+import org.globus.cog.karajan.runtime.OrderedParallelChannel;
+import org.globus.cog.karajan.runtime.KIterator;
+import org.globus.cog.karajan.runtime.ExecutionException;
+
+
+@KFile("sys_dot_k")
+public final class sys_dot_k implements KRunnable {
+ public static void main(String[] args) {
+ LWThread thread = new LWThread(new sys_dot_k());
+ thread.start();
+ try {
+ thread.waitFor();
+ }
+ catch (InterruptedException e) {
+ e.printStackTrace();
+ }
+ }
+
+ public void run() {
+ run(LWThread.currentThread().getContext());
+ }
+
+ public void run(Context ctx) {
+ try {
+ LWThread thread = LWThread.currentThread();
+ thread.checkSlice();
+ int __state__ = thread.popState();
+ switch(__state__) {
+ case 0:
+ thread.setContext(ctx = new Context(20, ctx));
+ case 1:
+ ctx.pushChannel(1, new StdoutSink());
+ ctx.pushChannel(2, new StderrSink());
+ //[Exception, throw, range, __eq___eq_, __times_, __plus_, wait, __gt_, echo, print, __minus_, __lt_]
+ thread.setContext(ctx = new Context(12, ctx));
+ case 2:
+ k_dot_set000000(ctx);
+ case 3:
+ k_dot_set000001(ctx);
+ case 4:
+ k_dot_set000002(ctx);
+ case 5:
+ k_dot_set000003(ctx);
+ case 6:
+ k_dot_set000004(ctx);
+ case 7:
+ k_dot_set000005(ctx);
+ case 8:
+ k_dot_set000006(ctx);
+ case 9:
+ k_dot_set000007(ctx);
+ case 10:
+ k_dot_set000008(ctx);
+ case 11:
+ k_dot_set000009(ctx);
+ case 12:
+ k_dot_set000010(ctx);
+ case 13:
+ k_dot_set000011(ctx);
+ // export (sys_dot_k:15)
+ ctx.getChannel(0).append(ctx.get(0));
+ ctx.getChannel(0).append(ctx.get(1));
+ ctx.getChannel(0).append(ctx.get(2));
+ ctx.getChannel(0).append(ctx.get(3));
+ ctx.getChannel(0).append(ctx.get(4));
+ ctx.getChannel(0).append(ctx.get(7));
+ ctx.getChannel(0).append(ctx.get(8));
+ ctx.getChannel(0).append(ctx.get(10));
+ ctx.getChannel(0).append(ctx.get(11));
+ ctx.getChannel(0).append(ctx.get(5));
+ ctx.getChannel(0).append(ctx.get(6));
+ ctx.getChannel(0).append(ctx.get(9));
+ thread.setContext(ctx = ctx.p);
+ thread.setContext(ctx = ctx.p);
+ }
+ }
+ catch (Exception e) {
+ Exceptions.handleException(e);
+ }
+ }
+
+ private void checkMismatch(int expected, int actual) throws ExecutionException {
+ if(expected != actual) {
+ throw new ExecutionException("Got " + expected + " identifier(s) and " + actual + " values");
+ }
+ }
+ // k.set (sys_dot_k:1)
+ @KLine("1")
+ private void k_dot_set000000(Context ctx) throws Exception {
+ LWThread thread = LWThread.currentThread();
+ thread.checkSlice();
+ int __state__ = thread.popState();
+ switch(__state__) {
+ case 0:
+ ctx.pushChannel(0);
+ case 1:
+ // native (sys_dot_k:1)
+ ctx.append(0, new org.globus.cog.karajan.lib.sys.Echo());
+ Channel def = ctx.popChannel(0);
+ ctx.set(0, def.get(0));
+ }
+ }
+
+ // k.set (sys_dot_k:2)
+ @KLine("2")
+ private void k_dot_set000001(Context ctx) throws Exception {
+ LWThread thread = LWThread.currentThread();
+ thread.checkSlice();
+ int __state__ = thread.popState();
+ switch(__state__) {
+ case 0:
+ ctx.pushChannel(0);
+ case 1:
+ // native (sys_dot_k:2)
+ ctx.append(0, new org.globus.cog.karajan.lib.sys.Print());
+ Channel def = ctx.popChannel(0);
+ ctx.set(1, def.get(0));
+ }
+ }
+
+ // k.set (sys_dot_k:3)
+ @KLine("3")
+ private void k_dot_set000002(Context ctx) throws Exception {
+ LWThread thread = LWThread.currentThread();
+ thread.checkSlice();
+ int __state__ = thread.popState();
+ switch(__state__) {
+ case 0:
+ ctx.pushChannel(0);
+ case 1:
+ // native (sys_dot_k:3)
+ ctx.append(0, new org.globus.cog.karajan.lib.sys.Range());
+ Channel def = ctx.popChannel(0);
+ ctx.set(2, def.get(0));
+ }
+ }
+
+ // k.set (sys_dot_k:4)
+ @KLine("4")
+ private void k_dot_set000003(Context ctx) throws Exception {
+ LWThread thread = LWThread.currentThread();
+ thread.checkSlice();
+ int __state__ = thread.popState();
+ switch(__state__) {
+ case 0:
+ ctx.pushChannel(0);
+ case 1:
+ // native (sys_dot_k:4)
+ ctx.append(0, new org.globus.cog.karajan.lib.sys.Wait());
+ Channel def = ctx.popChannel(0);
+ ctx.set(3, def.get(0));
+ }
+ }
+
+ // k.set (sys_dot_k:5)
+ @KLine("5")
+ private void k_dot_set000004(Context ctx) throws Exception {
+ LWThread thread = LWThread.currentThread();
+ thread.checkSlice();
+ int __state__ = thread.popState();
+ switch(__state__) {
+ case 0:
+ ctx.pushChannel(0);
+ case 1:
+ // native (sys_dot_k:5)
+ ctx.append(0, new org.globus.cog.karajan.lib.sys.Equals());
+ Channel def = ctx.popChannel(0);
+ ctx.set(4, def.get(0));
+ }
+ }
+
+ // k.set (sys_dot_k:6)
+ @KLine("6")
+ private void k_dot_set000005(Context ctx) throws Exception {
+ LWThread thread = LWThread.currentThread();
+ thread.checkSlice();
+ int __state__ = thread.popState();
+ switch(__state__) {
+ case 0:
+ ctx.pushChannel(0);
+ case 1:
+ // native (sys_dot_k:6)
+ ctx.append(0, new org.globus.cog.karajan.lib.sys.GreaterThan());
+ Channel def = ctx.popChannel(0);
+ ctx.set(5, def.get(0));
+ }
+ }
+
+ // k.set (sys_dot_k:7)
+ @KLine("7")
+ private void k_dot_set000006(Context ctx) throws Exception {
+ LWThread thread = LWThread.currentThread();
+ thread.checkSlice();
+ int __state__ = thread.popState();
+ switch(__state__) {
+ case 0:
+ ctx.pushChannel(0);
+ case 1:
+ // native (sys_dot_k:7)
+ ctx.append(0, new org.globus.cog.karajan.lib.sys.LessThan());
+ Channel def = ctx.popChannel(0);
+ ctx.set(6, def.get(0));
+ }
+ }
+
+ // k.set (sys_dot_k:8)
+ @KLine("8")
+ private void k_dot_set000007(Context ctx) throws Exception {
+ LWThread thread = LWThread.currentThread();
+ thread.checkSlice();
+ int __state__ = thread.popState();
+ switch(__state__) {
+ case 0:
+ ctx.pushChannel(0);
+ case 1:
+ // native (sys_dot_k:8)
+ ctx.append(0, new org.globus.cog.karajan.lib.sys.Plus());
+ Channel def = ctx.popChannel(0);
+ ctx.set(7, def.get(0));
+ }
+ }
+
+ // k.set (sys_dot_k:9)
+ @KLine("9")
+ private void k_dot_set000008(Context ctx) throws Exception {
+ LWThread thread = LWThread.currentThread();
+ thread.checkSlice();
+ int __state__ = thread.popState();
+ switch(__state__) {
+ case 0:
+ ctx.pushChannel(0);
+ case 1:
+ // native (sys_dot_k:9)
+ ctx.append(0, new org.globus.cog.karajan.lib.sys.Minus());
+ Channel def = ctx.popChannel(0);
+ ctx.set(8, def.get(0));
+ }
+ }
+
+ // k.set (sys_dot_k:10)
+ @KLine("10")
+ private void k_dot_set000009(Context ctx) throws Exception {
+ LWThread thread = LWThread.currentThread();
+ thread.checkSlice();
+ int __state__ = thread.popState();
+ switch(__state__) {
+ case 0:
+ ctx.pushChannel(0);
+ case 1:
+ // native (sys_dot_k:10)
+ ctx.append(0, new org.globus.cog.karajan.lib.sys.Times());
+ Channel def = ctx.popChannel(0);
+ ctx.set(9, def.get(0));
+ }
+ }
+
+ // k.set (sys_dot_k:12)
+ @KLine("12")
+ private void k_dot_set000010(Context ctx) throws Exception {
+ LWThread thread = LWThread.currentThread();
+ thread.checkSlice();
+ int __state__ = thread.popState();
+ switch(__state__) {
+ case 0:
+ ctx.pushChannel(0);
+ case 1:
+ // native (sys_dot_k:12)
+ ctx.append(0, new org.globus.cog.karajan.lib.sys.Throw());
+ Channel def = ctx.popChannel(0);
+ ctx.set(10, def.get(0));
+ }
+ }
+
+ // k.set (sys_dot_k:13)
+ @KLine("13")
+ private void k_dot_set000011(Context ctx) throws Exception {
+ LWThread thread = LWThread.currentThread();
+ thread.checkSlice();
+ int __state__ = thread.popState();
+ switch(__state__) {
+ case 0:
+ ctx.pushChannel(0);
+ case 1:
+ // native (sys_dot_k:13)
+ ctx.append(0, new org.globus.cog.karajan.lib.sys.KException());
+ Channel def = ctx.popChannel(0);
+ ctx.set(11, def.get(0));
+ }
+ }
+
+ public static final int[] __LINE_TABLE = new int[] {
+ 45, 47, 52, 54, 56, 58, 60, 62, 64, 66, 68, 70, 72, 74, 91, //run
+ 110, 112, 117, //k_dot_set000000
+ 127, 129, 134, //k_dot_set000001
+ 144, 146, 151, //k_dot_set000002
+ 161, 163, 168, //k_dot_set000003
+ 178, 180, 185, //k_dot_set000004
+ 195, 197, 202, //k_dot_set000005
+ 212, 214, 219, //k_dot_set000006
+ 229, 231, 236, //k_dot_set000007
+ 246, 248, 253, //k_dot_set000008
+ 263, 265, 270, //k_dot_set000009
+ 280, 282, 287, //k_dot_set000010
+ 297, 299//k_dot_set000011
+ };
+ public static final int[] __STATE_TABLE = new int[] {
+ 0, 1, 2, 3, 4, 5, 6, 7, 8, 9, 10, 11, 12, 13, -1, //run
+ 0, 1, -1, //k_dot_set000000
+ 0, 1, -1, //k_dot_set000001
+ 0, 1, -1, //k_dot_set000002
+ 0, 1, -1, //k_dot_set000003
+ 0, 1, -1, //k_dot_set000004
+ 0, 1, -1, //k_dot_set000005
+ 0, 1, -1, //k_dot_set000006
+ 0, 1, -1, //k_dot_set000007
+ 0, 1, -1, //k_dot_set000008
+ 0, 1, -1, //k_dot_set000009
+ 0, 1, -1, //k_dot_set000010
+ 0, 1//k_dot_set000011
+ };
+ static {
+ StateTables.register(sys_dot_k.class);
+ }
+ public static void __exports__() {
+ }
+}
Added: branches/karajan2/src/cog/modules/karajan2/launchers.xml
===================================================================
--- branches/karajan2/src/cog/modules/karajan2/launchers.xml (rev 0)
+++ branches/karajan2/src/cog/modules/karajan2/launchers.xml 2008-06-12 22:45:56 UTC (rev 2037)
@@ -0,0 +1,11 @@
+<project name="Launchers" default="create" basedir=".">
+ <target name="create">
+ <ant antfile="${main.buildfile}" target="launcher">
+ <property name="launcher-name" value="k"/>
+ <property name="class-name"
+ value="org.globus.cog.karajan.Loader"/>
+ </ant>
+ </target>
+ <target name="webstart">
+ </target>
+</project>
Added: branches/karajan2/src/cog/modules/karajan2/lib/backport-util-concurrent.jar
===================================================================
(Binary files differ)
Property changes on: branches/karajan2/src/cog/modules/karajan2/lib/backport-util-concurrent.jar
___________________________________________________________________
Name: svn:mime-type
+ application/octet-stream
Added: branches/karajan2/src/cog/modules/karajan2/lib/cog-util-0.92.jar
===================================================================
(Binary files differ)
Property changes on: branches/karajan2/src/cog/modules/karajan2/lib/cog-util-0.92.jar
___________________________________________________________________
Name: svn:mime-type
+ application/octet-stream
Added: branches/karajan2/src/cog/modules/karajan2/lib/log4j-1.2.8.jar
===================================================================
(Binary files differ)
Property changes on: branches/karajan2/src/cog/modules/karajan2/lib/log4j-1.2.8.jar
___________________________________________________________________
Name: svn:mime-type
+ application/octet-stream
Added: branches/karajan2/src/cog/modules/karajan2/lib/xpp3-1.1.3.4d_b4_min.jar
===================================================================
(Binary files differ)
Property changes on: branches/karajan2/src/cog/modules/karajan2/lib/xpp3-1.1.3.4d_b4_min.jar
___________________________________________________________________
Name: svn:mime-type
+ application/octet-stream
Added: branches/karajan2/src/cog/modules/karajan2/lib/xpp3.LICENSE
===================================================================
--- branches/karajan2/src/cog/modules/karajan2/lib/xpp3.LICENSE (rev 0)
+++ branches/karajan2/src/cog/modules/karajan2/lib/xpp3.LICENSE 2008-06-12 22:45:56 UTC (rev 2037)
@@ -0,0 +1,46 @@
+Indiana University Extreme! Lab Software License
+
+Version 1.1.1
+
+Copyright (c) 2002 Extreme! Lab, Indiana University. All rights reserved.
+
+Redistribution and use in source and binary forms, with or without
+modification, are permitted provided that the following conditions
+are met:
+
+1. Redistributions of source code must retain the above copyright notice,
+ this list of conditions and the following disclaimer.
+
+2. Redistributions in binary form must reproduce the above copyright
+ notice, this list of conditions and the following disclaimer in
+ the documentation and/or other materials provided with the distribution.
+
+3. The end-user documentation included with the redistribution, if any,
+ must include the following acknowledgment:
+
+ "This product includes software developed by the Indiana University
+ Extreme! Lab (http://www.extreme.indiana.edu/)."
+
+Alternately, this acknowledgment may appear in the software itself,
+if and wherever such third-party acknowledgments normally appear.
+
+4. The names "Indiana Univeristy" and "Indiana Univeristy Extreme! Lab"
+must not be used to endorse or promote products derived from this
+software without prior written permission. For written permission,
+please contact http://www.extreme.indiana.edu/.
+
+5. Products derived from this software may not use "Indiana Univeristy"
+name nor may "Indiana Univeristy" appear in their name, without prior
+written permission of the Indiana University.
+
+THIS SOFTWARE IS PROVIDED "AS IS" AND ANY EXPRESSED OR IMPLIED
+WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED WARRANTIES OF
+MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE DISCLAIMED.
+IN NO EVENT SHALL THE AUTHORS, COPYRIGHT HOLDERS OR ITS CONTRIBUTORS
+BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR
+CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF
+SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR
+BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY,
+WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR
+OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN IF
+ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
Added: branches/karajan2/src/cog/modules/karajan2/lib/xstream-1.1.1-patched.jar
===================================================================
(Binary files differ)
Property changes on: branches/karajan2/src/cog/modules/karajan2/lib/xstream-1.1.1-patched.jar
___________________________________________________________________
Name: svn:mime-type
+ application/octet-stream
Added: branches/karajan2/src/cog/modules/karajan2/lib/xstream.LICENSE
===================================================================
--- branches/karajan2/src/cog/modules/karajan2/lib/xstream.LICENSE (rev 0)
+++ branches/karajan2/src/cog/modules/karajan2/lib/xstream.LICENSE 2008-06-12 22:45:56 UTC (rev 2037)
@...
[truncated message content] |
|
From: <ha...@us...> - 2008-06-12 22:44:24
|
Revision: 2036
http://cogkit.svn.sourceforge.net/cogkit/?rev=2036&view=rev
Author: hategan
Date: 2008-06-12 15:43:59 -0700 (Thu, 12 Jun 2008)
Log Message:
-----------
woop to java 6
Modified Paths:
--------------
branches/karajan2/src/cog/mbuild.xml
Modified: branches/karajan2/src/cog/mbuild.xml
===================================================================
--- branches/karajan2/src/cog/mbuild.xml 2008-06-12 22:25:04 UTC (rev 2035)
+++ branches/karajan2/src/cog/mbuild.xml 2008-06-12 22:43:59 UTC (rev 2036)
@@ -223,8 +223,8 @@
debug="${debug}"
optimize="${optimize}"
deprecation="${deprecation}"
- source="1.4"
- target="1.4"/>
+ source="1.6"
+ target="1.6"/>
<copy todir="${build.dir}" >
<fileset dir="src" includes="**/*.properties" />
This was sent by the SourceForge.net collaborative development platform, the world's largest Open Source development site.
|
|
From: <ha...@us...> - 2008-06-12 22:25:10
|
Revision: 2035
http://cogkit.svn.sourceforge.net/cogkit/?rev=2035&view=rev
Author: hategan
Date: 2008-06-12 15:25:04 -0700 (Thu, 12 Jun 2008)
Log Message:
-----------
Branching trunk to branches/karajan2
Added Paths:
-----------
branches/karajan2/
Copied: branches/karajan2 (from rev 2034, trunk/current)
This was sent by the SourceForge.net collaborative development platform, the world's largest Open Source development site.
|
|
From: <b_...@us...> - 2008-06-10 14:36:14
|
Revision: 2034
http://cogkit.svn.sourceforge.net/cogkit/?rev=2034&view=rev
Author: b_z_c
Date: 2008-06-10 07:36:05 -0700 (Tue, 10 Jun 2008)
Log Message:
-----------
r2025 caused a regression of the fix introduced in r2024 to pass job submission attributes.
Modified Paths:
--------------
trunk/current/src/cog/modules/provider-coaster/src/org/globus/cog/abstraction/coaster/service/job/manager/WorkerManager.java
Modified: trunk/current/src/cog/modules/provider-coaster/src/org/globus/cog/abstraction/coaster/service/job/manager/WorkerManager.java
===================================================================
--- trunk/current/src/cog/modules/provider-coaster/src/org/globus/cog/abstraction/coaster/service/job/manager/WorkerManager.java 2008-05-30 17:05:25 UTC (rev 2033)
+++ trunk/current/src/cog/modules/provider-coaster/src/org/globus/cog/abstraction/coaster/service/job/manager/WorkerManager.java 2008-06-10 14:36:05 UTC (rev 2034)
@@ -206,7 +206,7 @@
private void copyAttributes(Task t, Task prototype, int maxWallTime) {
JobSpecification pspec = (JobSpecification) prototype.getSpecification();
- JobSpecification tspec = (JobSpecification) prototype.getSpecification();
+ JobSpecification tspec = (JobSpecification) t.getSpecification();
Iterator i = pspec.getAttributeNames().iterator();
while (i.hasNext()) {
String name = (String) i.next();
This was sent by the SourceForge.net collaborative development platform, the world's largest Open Source development site.
|
|
From: <ha...@us...> - 2008-05-30 17:05:27
|
Revision: 2033
http://cogkit.svn.sourceforge.net/cogkit/?rev=2033&view=rev
Author: hategan
Date: 2008-05-30 10:05:25 -0700 (Fri, 30 May 2008)
Log Message:
-----------
a task can be canceled from any state
Modified Paths:
--------------
trunk/current/src/cog/modules/abstraction-common/src/org/globus/cog/abstraction/impl/common/task/StatusOrder.java
Modified: trunk/current/src/cog/modules/abstraction-common/src/org/globus/cog/abstraction/impl/common/task/StatusOrder.java
===================================================================
--- trunk/current/src/cog/modules/abstraction-common/src/org/globus/cog/abstraction/impl/common/task/StatusOrder.java 2008-05-30 13:22:51 UTC (rev 2032)
+++ trunk/current/src/cog/modules/abstraction-common/src/org/globus/cog/abstraction/impl/common/task/StatusOrder.java 2008-05-30 17:05:25 UTC (rev 2033)
@@ -20,6 +20,7 @@
public static int pred(int code) {
switch (code) {
case Status.CANCELED:
+ return -1;
case Status.FAILED:
case Status.COMPLETED:
return Status.ACTIVE;
This was sent by the SourceForge.net collaborative development platform, the world's largest Open Source development site.
|
