diff options
Diffstat (limited to 'plugins/org.eclipse.osee.framework.manager.servlet/src/org/eclipse/osee/framework/manager/servlet/SearchEngineTaggerServlet.java')
-rw-r--r-- | plugins/org.eclipse.osee.framework.manager.servlet/src/org/eclipse/osee/framework/manager/servlet/SearchEngineTaggerServlet.java | 194 |
1 files changed, 97 insertions, 97 deletions
diff --git a/plugins/org.eclipse.osee.framework.manager.servlet/src/org/eclipse/osee/framework/manager/servlet/SearchEngineTaggerServlet.java b/plugins/org.eclipse.osee.framework.manager.servlet/src/org/eclipse/osee/framework/manager/servlet/SearchEngineTaggerServlet.java index 2c572d4d7dd..6be22e83a01 100644 --- a/plugins/org.eclipse.osee.framework.manager.servlet/src/org/eclipse/osee/framework/manager/servlet/SearchEngineTaggerServlet.java +++ b/plugins/org.eclipse.osee.framework.manager.servlet/src/org/eclipse/osee/framework/manager/servlet/SearchEngineTaggerServlet.java @@ -28,106 +28,106 @@ import org.eclipse.osee.framework.search.engine.ISearchEngineTagger; * @author Roberto E. Escobar */ public class SearchEngineTaggerServlet extends SecureOseeHttpServlet { - private static final long serialVersionUID = 5104108752343302320L; + private static final long serialVersionUID = 5104108752343302320L; - private final ISearchEngineTagger searchTaggerService; + private final ISearchEngineTagger searchTaggerService; - public SearchEngineTaggerServlet(ISessionManager sessionManager, ISearchEngineTagger searchTaggerService) { - super(sessionManager); - this.searchTaggerService = searchTaggerService; - } + public SearchEngineTaggerServlet(ISessionManager sessionManager, ISearchEngineTagger searchTaggerService) { + super(sessionManager); + this.searchTaggerService = searchTaggerService; + } - @Override - protected void doPost(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException { - long start = System.currentTimeMillis(); - try { - StringBuffer message = new StringBuffer(); - int branchId = Integer.parseInt(request.getParameter("branchId")); - boolean waitForTags = Boolean.parseBoolean(request.getParameter("wait")); - if (waitForTags) { - TagListener listener = new TagListener(); - searchTaggerService.tagByBranchId(listener, branchId); - if (listener.wasProcessed() != true) { - synchronized (listener) { - listener.wait(); - } - } - message.append(String.format("Processed %d queries containing %d attributes in %d ms.", - listener.getQueryCount(), listener.getAttributeCount(), System.currentTimeMillis() - start)); - } else { - searchTaggerService.tagByBranchId(branchId); - } - response.setContentType("text/plain"); - response.setCharacterEncoding("UTF-8"); - response.setStatus(HttpServletResponse.SC_ACCEPTED); - response.getWriter().write(message.toString()); - } catch (Exception ex) { - response.setStatus(HttpServletResponse.SC_BAD_REQUEST); - response.setContentType("text/plain"); - OseeLog.log(Activator.class, Level.SEVERE, - String.format("Error submitting for tagging - [%s]", request.toString()), ex); - response.getWriter().write(Lib.exceptionToString(ex)); - } - response.getWriter().flush(); - response.getWriter().close(); - } + @Override + protected void doPost(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException { + long start = System.currentTimeMillis(); + try { + StringBuffer message = new StringBuffer(); + int branchId = Integer.parseInt(request.getParameter("branchId")); + boolean waitForTags = Boolean.parseBoolean(request.getParameter("wait")); + if (waitForTags) { + TagListener listener = new TagListener(); + searchTaggerService.tagByBranchId(listener, branchId); + if (listener.wasProcessed() != true) { + synchronized (listener) { + listener.wait(); + } + } + message.append(String.format("Processed %d queries containing %d attributes in %d ms.", + listener.getQueryCount(), listener.getAttributeCount(), System.currentTimeMillis() - start)); + } else { + searchTaggerService.tagByBranchId(branchId); + } + response.setContentType("text/plain"); + response.setCharacterEncoding("UTF-8"); + response.setStatus(HttpServletResponse.SC_ACCEPTED); + response.getWriter().write(message.toString()); + } catch (Exception ex) { + response.setStatus(HttpServletResponse.SC_BAD_REQUEST); + response.setContentType("text/plain"); + OseeLog.log(Activator.class, Level.SEVERE, + String.format("Error submitting for tagging - [%s]", request.toString()), ex); + response.getWriter().write(Lib.exceptionToString(ex)); + } + response.getWriter().flush(); + response.getWriter().close(); + } - @Override - protected void doPut(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException { - InputStream inputStream = null; - try { - boolean waitForTags = Boolean.parseBoolean(request.getParameter("wait")); - inputStream = request.getInputStream(); - if (waitForTags) { - TagListener listener = new TagListener(); - searchTaggerService.tagFromXmlStream(listener, inputStream); - if (listener.wasProcessed() != true) { - synchronized (listener) { - listener.wait(); - } - } - } else { - searchTaggerService.tagFromXmlStream(inputStream); - } - response.setContentType("text/plain"); - response.setCharacterEncoding("UTF-8"); - response.setStatus(HttpServletResponse.SC_CREATED); - } catch (Exception ex) { - response.setStatus(HttpServletResponse.SC_BAD_REQUEST); - response.setContentType("text/plain"); - OseeLog.log(Activator.class, Level.SEVERE, - String.format("Error submitting for tagging - [%s]", request.toString()), ex); - response.getWriter().write(Lib.exceptionToString(ex)); - } finally { - if (inputStream != null) { - inputStream.close(); - } - response.getWriter().flush(); - response.getWriter().close(); - } - } + @Override + protected void doPut(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException { + InputStream inputStream = null; + try { + boolean waitForTags = Boolean.parseBoolean(request.getParameter("wait")); + inputStream = request.getInputStream(); + if (waitForTags) { + TagListener listener = new TagListener(); + searchTaggerService.tagFromXmlStream(listener, inputStream); + if (listener.wasProcessed() != true) { + synchronized (listener) { + listener.wait(); + } + } + } else { + searchTaggerService.tagFromXmlStream(inputStream); + } + response.setContentType("text/plain"); + response.setCharacterEncoding("UTF-8"); + response.setStatus(HttpServletResponse.SC_CREATED); + } catch (Exception ex) { + response.setStatus(HttpServletResponse.SC_BAD_REQUEST); + response.setContentType("text/plain"); + OseeLog.log(Activator.class, Level.SEVERE, + String.format("Error submitting for tagging - [%s]", request.toString()), ex); + response.getWriter().write(Lib.exceptionToString(ex)); + } finally { + if (inputStream != null) { + inputStream.close(); + } + response.getWriter().flush(); + response.getWriter().close(); + } + } - @Override - protected void doDelete(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException { - try { - String queryId = request.getParameter("queryId"); - int value = searchTaggerService.deleteTags(Integer.parseInt(queryId)); - response.setContentType("text/plain"); - response.setCharacterEncoding("UTF-8"); - if (value > 0) { - response.setStatus(HttpServletResponse.SC_ACCEPTED); - } else { - response.setStatus(HttpServletResponse.SC_NOT_FOUND); - } - } catch (Exception ex) { - response.setStatus(HttpServletResponse.SC_BAD_REQUEST); - response.setContentType("text/plain"); - OseeLog.log(Activator.class, Level.SEVERE, - String.format("Error submitting for tagging - [%s]", request.toString()), ex); - response.getWriter().write(Lib.exceptionToString(ex)); - } finally { - response.getWriter().flush(); - response.getWriter().close(); - } - } + @Override + protected void doDelete(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException { + try { + String queryId = request.getParameter("queryId"); + int value = searchTaggerService.deleteTags(Integer.parseInt(queryId)); + response.setContentType("text/plain"); + response.setCharacterEncoding("UTF-8"); + if (value > 0) { + response.setStatus(HttpServletResponse.SC_ACCEPTED); + } else { + response.setStatus(HttpServletResponse.SC_NOT_FOUND); + } + } catch (Exception ex) { + response.setStatus(HttpServletResponse.SC_BAD_REQUEST); + response.setContentType("text/plain"); + OseeLog.log(Activator.class, Level.SEVERE, + String.format("Error submitting for tagging - [%s]", request.toString()), ex); + response.getWriter().write(Lib.exceptionToString(ex)); + } finally { + response.getWriter().flush(); + response.getWriter().close(); + } + } } |