All about ashwini hikulkarni

please help me in threads

Hi all
I am not having much experience in thread programming , kindly help me out

1.This is the upload program and the file is uploading on the C:// drive successfully ,
2. I need to implement the thread in my program
3.If the user logs out the thread must execute the task .please can you help me,

public class UploadAction extends HttpServlet
{
ObjectStore m_objectStore;
RMObjectStore m_rmos;
ArrayList arrDocuments;
UploadForm uploadForm;
FileItem uploadedFileItem;
public UploadAction()
{
m_objectStore = null;
m_rmos = null;
arrDocuments = new ArrayList();
uploadForm = new UploadForm();
uploadedFileItem = null;
}
protected void doGet(HttpServletRequest request, HttpServletResponse response)
throws ServletException, IOException
{
doPost(request, response);
}
protected void doPost(HttpServletRequest request, HttpServletResponse response)
throws ServletException, IOException
{
HttpSession session = request.getSession();
if("status".equals(request.getParameter("c")))
{
System.out.println("In the IF STaTUS==" + request.getParameter("c"));
doStatus(session, response);
} else
{
System.out.println("HIDDEN" + request.getParameter("hidden"));
System.out.println("In the else==" + request.getParameter("c"));
doFileUpload(session, request, response);
}
}
private void doFileUpload(HttpSession session, HttpServletRequest request, HttpServletResponse response)
throws IOException
{
try
{
FileUploadListener listener = new FileUploadListener(request.getContentLength());
session.setAttribute("FILE_UPLOAD_STATS", listener.getFileUploadStats());
org.apache.commons.fileupload.FileItemFactory factory = new MonitoredDiskFileItemFactory(listener);
ServletFileUpload upload = new ServletFileUpload(factory);
ArrayList items = (ArrayList)upload.parseRequest(request);
boolean hasError = false;
long Lsize1 = 0L;
String strInputFileName = "";
String newFileName = "";
String strDestination = null;
java.io.InputStream fileStream = null;
Iterator iter = items.iterator();
while(iter.hasNext())
{
FileItem item = (FileItem)iter.next();
if(item.isFormField())
{
String name = item.getFieldName();
String value = item.getString();
if(name.equals("newFileName"))
{
newFileName = value;
}
continue;
}
strInputFileName = item.getName();
String strfilesize = "650000000000";
long lfilesize = Long.parseLong(strfilesize.trim());
long Lsize = item.getSize();
if(Lsize >= lfilesize)
{
Lsize1 = Lsize;
String LUsize1 = String.valueOf(Lsize1);
request.getSession().getServletContext().setAttribute("strloggedLUser", LUsize1);
break;
}
Lsize1 = Lsize;
if(Lsize1 != 0L)
{
String LUsize1 = String.valueOf(Lsize1);
request.getSession().getServletContext().setAttribute("strloggedLUser", LUsize1);
}
uploadedFileItem = item;
String filePath = "C:\\UploadFolder";
String newPath = filePath;
File file = new File(newPath);
file.mkdir();
strInputFileName = strInputFileName.substring(strInputFileName.lastIndexOf("\\") + 1);
System.out.println("strInputFileName :" + strInputFileName);
String strFileName = strInputFileName;
System.out.println("strFileName :" + strFileName);
File uploadedFile = new File(filePath + "/", newFileName + strFileName);
try
{
request.getSession().getServletContext().setAttribute("fileArrayUser", strFileName);
uploadedFileItem.write(uploadedFile);
addDocument(uploadedFile.getName(), uploadedFile);
}
catch(Exception e)
{
System.out.println("Exception in uploadedFileItem :" + e);
}
}
if(!hasError)
{
sendCompleteResponse(response, null);
} else
{
sendCompleteResponse(response, "Could not process uploaded file. Please see log for details.");
}
}
catch(Exception e)
{
sendCompleteResponse(response, e.getMessage());
}
}
private void doStatus(HttpSession session, HttpServletResponse response)
throws IOException
{
response.addHeader("Expires", "0");
response.addHeader("Cache-Control", "no-store, no-cache, must-revalidate");
response.addHeader("Cache-Control", "post-check=0, pre-check=0");
response.addHeader("Pragma", "no-cache");
FileUploadListener.FileUploadStats fileUploadStats = (FileUploadListener.FileUploadStats)session.getAttribute("FILE_UPLOAD_STATS");
if(fileUploadStats != null)
{
long bytesProcessed = fileUploadStats.getBytesRead();
long sizeTotal = fileUploadStats.getTotalSize();
long percentComplete = (long)Math.floor(((double)bytesProcessed / (double)sizeTotal) * 100D);
long timeInSeconds = fileUploadStats.getElapsedTimeInSeconds();
double uploadRate = (double)bytesProcessed / ((double)timeInSeconds + 1.0000000000000001E-005D);
double estimatedRuntime = (double)sizeTotal / (uploadRate + 1.0000000000000001E-005D);
if(fileUploadStats.getBytesRead() != fileUploadStats.getTotalSize())
}
if(fileUploadStats != null && fileUploadStats.getBytesRead() == fileUploadStats.getTotalSize())
{
response.getWriter().println("Upload complete.");
}
}
private String formatTime(double timeInSeconds)
{
long seconds = (long)Math.floor(timeInSeconds);
long minutes = (long)Math.floor(timeInSeconds / 60D);
long hours = (long)Math.floor((double)minutes / 60D);
if(hours != 0L)
{
return hours + "hours " + minutes % 60L + "minutes " + seconds % 60L + "seconds";
}
if(minutes % 60L != 0L)
{
return minutes % 60L + "minutes " + seconds % 60L + "seconds";
} else
{
return seconds % 60L + " seconds";
}
}
public void addDocument(String strDocTitle, File fileToCreate)
{
System.out.println("FILE TO CREATE IN FILENET REPOSITORY==" + fileToCreate);
System.out.println("FILE TITLE FOR FILE UPLOAD IN FILENET==" + strDocTitle);
try
{
if(fileToCreate != null && fileToCreate.length() > 0L)
{
m_objectStore = ObjectFactory.getObjectStore("Content_OS", CELoginPage.LoginInCE());
System.out.println("addDocument---------------->");
String fName = new String("/Test/ashwini");
Properties properties = ObjectFactory.getProperties();
Property property = ObjectFactory.getProperty("DocumentTitle");
property.setValue(strDocTitle);
properties.add(property);
Document document = (Document)m_objectStore.createObject("Document", properties, null);
Folder folder = (Folder)m_objectStore.getObject(2, fName);
TransportInputStream content = new TransportInputStream(new FileInputStream(fileToCreate));
content.setMimeType("application/zip");
document.setContent(content, true, false);
document.file(folder, true, true);
declareRecord(document.getId(), properties);
System.out.println("Document successfully added. DocID = " + document.getId());
}
}
catch(Exception e)
{
System.out.println("Exception in [UploadAction][addDocument]: ");
e.printStackTrace();
}
}
protected String declareRecord(String docid, Properties properties)
{
String lstrException = "";
try
{
System.out.println("--------------Declaring Record-----------------");
ObjectStore os = ObjectFactory.getObjectStore("Fileplan_OS", CELoginPage.LoginInCE());
new RMUtil();
m_rmos = RMUtil._getRMObjectStore(os);
RMRecordContainer moRecordContainer = (RMRecordContainer)m_rmos.getObject(101, "/Records Management/UNFCCC Records Classification Scheme/RDA_Submission");
String ldocId[] = {
docid
};
new RMUtil();
com.filenet.rm.api.RecordInfo loRecord = moRecordContainer.declare(RMUtil._getDocumentStore(m_objectStore), ldocId, null, properties, "ElectronicRecordInfo", null, false);
System.out.println("-------------------------------------------------");
}
catch(Exception e)
{
System.out.println("Exception in [UploadAction][declareRecord]: ");
e.printStackTrace();
}
return lstrException;
}
}

4. I need to implement the thread on this method
and run in background .
[ September 29, 2008: Message edited by: ashwini hikulkarni ]

ashwini hikulkarni

Recent posts by ashwini hikulkarni