You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@openmeetings.apache.org by so...@apache.org on 2016/01/27 12:21:25 UTC
svn commit: r1726998 - in /openmeetings/application:
branches/3.1.x/openmeetings-core/src/main/java/org/apache/openmeetings/core/data/conference/
branches/3.1.x/openmeetings-core/src/main/java/org/apache/openmeetings/core/data/record/
branches/3.1.x/op...
Author: solomax
Date: Wed Jan 27 11:21:25 2016
New Revision: 1726998
URL: http://svn.apache.org/viewvc?rev=1726998&view=rev
Log:
Issues reported by coverity are fixed
Modified:
openmeetings/application/branches/3.1.x/openmeetings-core/src/main/java/org/apache/openmeetings/core/data/conference/RoomManager.java
openmeetings/application/branches/3.1.x/openmeetings-core/src/main/java/org/apache/openmeetings/core/data/record/BatikMethods.java
openmeetings/application/branches/3.1.x/openmeetings-core/src/main/java/org/apache/openmeetings/core/documents/LibraryChartLoader.java
openmeetings/application/branches/3.1.x/openmeetings-core/src/main/java/org/apache/openmeetings/core/documents/LibraryDocumentConverter.java
openmeetings/application/branches/3.1.x/openmeetings-core/src/main/java/org/apache/openmeetings/core/remote/UserService.java
openmeetings/application/branches/3.1.x/openmeetings-core/src/main/java/org/apache/openmeetings/core/remote/WhiteBoardService.java
openmeetings/application/branches/3.1.x/openmeetings-core/src/main/java/org/apache/openmeetings/core/remote/red5/ScopeApplicationAdapter.java
openmeetings/application/branches/3.1.x/openmeetings-core/src/main/java/org/apache/openmeetings/core/servlet/outputhandler/ExportToImage.java
openmeetings/application/branches/3.1.x/openmeetings-core/src/main/java/org/apache/openmeetings/core/session/SessionManager.java
openmeetings/application/branches/3.1.x/openmeetings-db/src/main/java/org/apache/openmeetings/db/dao/server/ISessionManager.java
openmeetings/application/branches/3.1.x/openmeetings-db/src/main/java/org/apache/openmeetings/db/dao/user/IUserManager.java
openmeetings/application/branches/3.1.x/openmeetings-db/src/main/java/org/apache/openmeetings/db/dao/user/IUserService.java
openmeetings/application/branches/3.1.x/openmeetings-service/src/main/java/org/apache/openmeetings/service/user/UserManager.java
openmeetings/application/branches/3.1.x/openmeetings-util/src/main/java/org/apache/openmeetings/util/stringhandlers/ChatString.java
openmeetings/application/trunk/openmeetings-core/src/main/java/org/apache/openmeetings/core/data/conference/RoomManager.java
openmeetings/application/trunk/openmeetings-core/src/main/java/org/apache/openmeetings/core/data/record/BatikMethods.java
openmeetings/application/trunk/openmeetings-core/src/main/java/org/apache/openmeetings/core/documents/LibraryChartLoader.java
openmeetings/application/trunk/openmeetings-core/src/main/java/org/apache/openmeetings/core/documents/LibraryDocumentConverter.java
openmeetings/application/trunk/openmeetings-core/src/main/java/org/apache/openmeetings/core/remote/UserService.java
openmeetings/application/trunk/openmeetings-core/src/main/java/org/apache/openmeetings/core/remote/WhiteBoardService.java
openmeetings/application/trunk/openmeetings-core/src/main/java/org/apache/openmeetings/core/remote/red5/ScopeApplicationAdapter.java
openmeetings/application/trunk/openmeetings-core/src/main/java/org/apache/openmeetings/core/servlet/outputhandler/ExportToImage.java
openmeetings/application/trunk/openmeetings-core/src/main/java/org/apache/openmeetings/core/session/SessionManager.java
openmeetings/application/trunk/openmeetings-db/src/main/java/org/apache/openmeetings/db/dao/server/ISessionManager.java
openmeetings/application/trunk/openmeetings-db/src/main/java/org/apache/openmeetings/db/dao/user/IUserManager.java
openmeetings/application/trunk/openmeetings-db/src/main/java/org/apache/openmeetings/db/dao/user/IUserService.java
openmeetings/application/trunk/openmeetings-service/src/main/java/org/apache/openmeetings/service/user/UserManager.java
Modified: openmeetings/application/branches/3.1.x/openmeetings-core/src/main/java/org/apache/openmeetings/core/data/conference/RoomManager.java
URL: http://svn.apache.org/viewvc/openmeetings/application/branches/3.1.x/openmeetings-core/src/main/java/org/apache/openmeetings/core/data/conference/RoomManager.java?rev=1726998&r1=1726997&r2=1726998&view=diff
==============================================================================
--- openmeetings/application/branches/3.1.x/openmeetings-core/src/main/java/org/apache/openmeetings/core/data/conference/RoomManager.java (original)
+++ openmeetings/application/branches/3.1.x/openmeetings-core/src/main/java/org/apache/openmeetings/core/data/conference/RoomManager.java Wed Jan 27 11:21:25 2016
@@ -280,37 +280,15 @@ public class RoomManager {
return null;
}
- public List<Room> getRoomsByIds(List<Integer> roomIds) {
+ public List<Room> getRoomsByIds(List<Long> roomIds) {
try {
- if (roomIds == null || roomIds.size() == 0) {
- return new LinkedList<Room>();
+ if (roomIds != null && !roomIds.isEmpty()) {
+ return roomDao.get(roomIds);
}
-
- String queryString = "SELECT r from Room r " + "WHERE ";
-
- queryString += "(";
-
- int i = 0;
- for (Integer roomId : roomIds) {
- if (i != 0) {
- queryString += " OR ";
- }
- queryString += " r.id = " + roomId;
- i++;
- }
-
- queryString += ")";
-
- TypedQuery<Room> q = em.createQuery(queryString, Room.class);
-
- List<Room> ll = q.getResultList();
-
- return ll;
-
} catch (Exception ex2) {
log.error("[getRoomsByIds] ", ex2);
}
- return null;
+ return new LinkedList<Room>();
}
// ---------------------------------------------------------------------------------------------
Modified: openmeetings/application/branches/3.1.x/openmeetings-core/src/main/java/org/apache/openmeetings/core/data/record/BatikMethods.java
URL: http://svn.apache.org/viewvc/openmeetings/application/branches/3.1.x/openmeetings-core/src/main/java/org/apache/openmeetings/core/data/record/BatikMethods.java?rev=1726998&r1=1726997&r2=1726998&view=diff
==============================================================================
--- openmeetings/application/branches/3.1.x/openmeetings-core/src/main/java/org/apache/openmeetings/core/data/record/BatikMethods.java (original)
+++ openmeetings/application/branches/3.1.x/openmeetings-core/src/main/java/org/apache/openmeetings/core/data/record/BatikMethods.java Wed Jan 27 11:21:25 2016
@@ -290,16 +290,16 @@ public class BatikMethods {
// log.debug("TEXT: "+stringsText);
// log.debug("TEXT: "+stringsText.length);
- String newText = "";
+ StringBuilder newText = new StringBuilder();
for (int i = 0; i < stringsText.length; i++) {
- newText += stringsText[i];
+ newText.append(stringsText[i]);
if (i + 1 < stringsText.length) {
- newText += "\n";
+ newText.append("\n");
}
}
- JTextArea n = new JTextArea(newText);
+ JTextArea n = new JTextArea(newText.toString());
n.setFont(font);
n.setWrapStyleWord(true);
n.setLineWrap(true);
Modified: openmeetings/application/branches/3.1.x/openmeetings-core/src/main/java/org/apache/openmeetings/core/documents/LibraryChartLoader.java
URL: http://svn.apache.org/viewvc/openmeetings/application/branches/3.1.x/openmeetings-core/src/main/java/org/apache/openmeetings/core/documents/LibraryChartLoader.java?rev=1726998&r1=1726997&r2=1726998&view=diff
==============================================================================
--- openmeetings/application/branches/3.1.x/openmeetings-core/src/main/java/org/apache/openmeetings/core/documents/LibraryChartLoader.java (original)
+++ openmeetings/application/branches/3.1.x/openmeetings-core/src/main/java/org/apache/openmeetings/core/documents/LibraryChartLoader.java Wed Jan 27 11:21:25 2016
@@ -18,20 +18,24 @@
*/
package org.apache.openmeetings.core.documents;
+import static org.apache.openmeetings.util.OpenmeetingsVariables.webAppRootKey;
+
import java.io.BufferedReader;
import java.io.File;
-import java.io.FileReader;
-import java.io.IOException;
+import java.io.FileInputStream;
+import java.io.InputStream;
+import java.io.InputStreamReader;
+import java.nio.charset.StandardCharsets;
import java.util.ArrayList;
-import org.apache.openmeetings.util.Logger;
+import org.red5.logging.Red5LoggerFactory;
+import org.slf4j.Logger;
import com.thoughtworks.xstream.XStream;
import com.thoughtworks.xstream.io.xml.XppDriver;
public class LibraryChartLoader {
-
- private static final Logger log = new Logger();
+ private static final Logger log = Red5LoggerFactory.getLogger(LibraryWmlLoader.class, webAppRootKey);
private static final String fileExt = ".xchart";
@@ -49,7 +53,6 @@ public class LibraryChartLoader {
@SuppressWarnings("rawtypes")
public ArrayList loadChart(File dir, String fileName) {
- BufferedReader reader = null;
try {
File file = new File(dir, fileName + fileExt);
@@ -58,18 +61,14 @@ public class LibraryChartLoader {
XStream xStream = new XStream(new XppDriver());
xStream.setMode(XStream.NO_REFERENCES);
- reader = new BufferedReader(new FileReader(file));
- ArrayList lMapList = (ArrayList) xStream.fromXML(reader);
-
- return lMapList;
- } catch (Exception err) {
- log.error(err);
- } finally {
- if (reader != null) {
- try {
- reader.close();
- } catch (IOException e) {}
+ try (InputStream is = new FileInputStream(file);
+ BufferedReader reader = new BufferedReader(new InputStreamReader(is, StandardCharsets.UTF_8)))
+ {
+ ArrayList lMapList = (ArrayList) xStream.fromXML(reader);
+ return lMapList;
}
+ } catch (Exception err) {
+ log.error("Unexpected error while loading chart", err);
}
return null;
Modified: openmeetings/application/branches/3.1.x/openmeetings-core/src/main/java/org/apache/openmeetings/core/documents/LibraryDocumentConverter.java
URL: http://svn.apache.org/viewvc/openmeetings/application/branches/3.1.x/openmeetings-core/src/main/java/org/apache/openmeetings/core/documents/LibraryDocumentConverter.java?rev=1726998&r1=1726997&r2=1726998&view=diff
==============================================================================
--- openmeetings/application/branches/3.1.x/openmeetings-core/src/main/java/org/apache/openmeetings/core/documents/LibraryDocumentConverter.java (original)
+++ openmeetings/application/branches/3.1.x/openmeetings-core/src/main/java/org/apache/openmeetings/core/documents/LibraryDocumentConverter.java Wed Jan 27 11:21:25 2016
@@ -18,13 +18,17 @@
*/
package org.apache.openmeetings.core.documents;
+import static org.apache.openmeetings.util.OpenmeetingsVariables.webAppRootKey;
+
import java.io.File;
-import java.io.FileWriter;
-import java.io.PrintWriter;
+import java.io.FileOutputStream;
+import java.io.OutputStream;
+import java.io.OutputStreamWriter;
+import java.io.Writer;
+import java.nio.charset.StandardCharsets;
import java.util.ArrayList;
import org.apache.openmeetings.util.OmFileHelper;
-import org.apache.openmeetings.util.OpenmeetingsVariables;
import org.apache.openmeetings.util.stringhandlers.StringComparer;
import org.red5.logging.Red5LoggerFactory;
import org.slf4j.Logger;
@@ -33,13 +37,12 @@ import com.thoughtworks.xstream.XStream;
import com.thoughtworks.xstream.io.xml.XppDriver;
public class LibraryDocumentConverter {
- private static final Logger log = Red5LoggerFactory.getLogger(LibraryDocumentConverter.class, OpenmeetingsVariables.webAppRootKey);
+ private static final Logger log = Red5LoggerFactory.getLogger(LibraryDocumentConverter.class, webAppRootKey);
private static final String fileExt = ".wml";
public static String writeToLocalFolder(String fileName, @SuppressWarnings("rawtypes")ArrayList objList) {
try {
-
log.debug("filePath: " + OmFileHelper.getUploadWmlDir().getCanonicalPath());
String fileNameExtName = fileName.substring(fileName.length()-4,fileName.length());
@@ -49,14 +52,14 @@ public class LibraryDocumentConverter {
fileName = StringComparer.getInstance().compareForRealPaths(fileName.substring(0, fileName.length()));
}
- if (fileName.length()<=0){
+ if (fileName.length() <= 0){
//return new Long(-21);
return "-20";
}
//Add the Folder for the wmlFiles if it does not exist yet
- File filePathComplete = new File(OmFileHelper.getUploadWmlDir(), fileName + fileExt);
+ File file = new File(OmFileHelper.getUploadWmlDir(), fileName + fileExt);
- if (filePathComplete.exists()){
+ if (file.exists()){
return "-20";
}
@@ -64,16 +67,18 @@ public class LibraryDocumentConverter {
xStream.setMode(XStream.NO_REFERENCES);
String xmlString = xStream.toXML(objList);
- log.debug("Write to "+filePathComplete);
+ log.debug("Write to " + file);
- PrintWriter pw = new PrintWriter(new FileWriter(filePathComplete));
- pw.println(xmlString);
- pw.flush();
- pw.close();
+ try (OutputStream os = new FileOutputStream(file);
+ Writer out = new OutputStreamWriter(os, StandardCharsets.UTF_8))
+ {
+ out.write(xmlString);
+ out.flush();
+ }
//return new Long(1);
- return filePathComplete.getCanonicalPath();
+ return file.getCanonicalPath();
} catch (Exception err){
log.error("writeToLocalFolder",err);
}
Modified: openmeetings/application/branches/3.1.x/openmeetings-core/src/main/java/org/apache/openmeetings/core/remote/UserService.java
URL: http://svn.apache.org/viewvc/openmeetings/application/branches/3.1.x/openmeetings-core/src/main/java/org/apache/openmeetings/core/remote/UserService.java?rev=1726998&r1=1726997&r2=1726998&view=diff
==============================================================================
--- openmeetings/application/branches/3.1.x/openmeetings-core/src/main/java/org/apache/openmeetings/core/remote/UserService.java (original)
+++ openmeetings/application/branches/3.1.x/openmeetings-core/src/main/java/org/apache/openmeetings/core/remote/UserService.java Wed Jan 27 11:21:25 2016
@@ -122,7 +122,7 @@ public class UserService implements IUse
* REST call
* @return - true if user has sufficient permissions, false otherwise
*/
- public Boolean kickUserByStreamId(String SID, String streamid, long serverId) {
+ public boolean kickUserByStreamId(String SID, String streamid, long serverId) {
try {
Long userId = sessiondataDao.checkSession(SID);
// admins only
@@ -176,7 +176,7 @@ public class UserService implements IUse
* @param publicSID
* @return - true in case user have sufficient permissions, null otherwise
*/
- public Boolean kickUserByPublicSID(String SID, String publicSID) {
+ public boolean kickUserByPublicSID(String SID, String publicSID) {
try {
Long userId = sessiondataDao.checkSession(SID);
// users only
@@ -204,20 +204,21 @@ public class UserService implements IUse
} catch (Exception err) {
log.error("[kickUserByPublicSID]", err);
}
- return null;
+ return false;
}
@Override
- public Boolean kickUserBySessionId(String SID, long userId, String sessionId) {
+ public boolean kickUserBySessionId(String SID, long userId, String sessionId) {
try {
Long users_id = sessiondataDao.checkSession(SID);
// admin only
if (AuthLevelUtil.hasAdminLevel(userDao.getRights(users_id))) {
((IApplication)Application.get(wicketApplicationName)).invalidateClient(userId, sessionId);
+ return true;
}
} catch (Exception err) {
log.error("[kickUserBySessionId]", err);
}
- return null;
+ return false;
}
}
Modified: openmeetings/application/branches/3.1.x/openmeetings-core/src/main/java/org/apache/openmeetings/core/remote/WhiteBoardService.java
URL: http://svn.apache.org/viewvc/openmeetings/application/branches/3.1.x/openmeetings-core/src/main/java/org/apache/openmeetings/core/remote/WhiteBoardService.java?rev=1726998&r1=1726997&r2=1726998&view=diff
==============================================================================
--- openmeetings/application/branches/3.1.x/openmeetings-core/src/main/java/org/apache/openmeetings/core/remote/WhiteBoardService.java (original)
+++ openmeetings/application/branches/3.1.x/openmeetings-core/src/main/java/org/apache/openmeetings/core/remote/WhiteBoardService.java Wed Jan 27 11:21:25 2016
@@ -88,7 +88,7 @@ public class WhiteBoardService implement
return null;
}
- public Boolean deleteWhiteboard(Long whiteBoardId) {
+ public boolean deleteWhiteboard(Long whiteBoardId) {
try {
IConnection current = Red5.getConnectionLocal();
String streamid = current.getClient().getId();
@@ -104,13 +104,11 @@ public class WhiteBoardService implement
if (returnValue != null) {
return true;
- } else {
- return false;
}
} catch (Exception err) {
log.error("[deleteWhiteboard]", err);
}
- return null;
+ return false;
}
public WhiteboardObjectList getRoomItemsBy() {
Modified: openmeetings/application/branches/3.1.x/openmeetings-core/src/main/java/org/apache/openmeetings/core/remote/red5/ScopeApplicationAdapter.java
URL: http://svn.apache.org/viewvc/openmeetings/application/branches/3.1.x/openmeetings-core/src/main/java/org/apache/openmeetings/core/remote/red5/ScopeApplicationAdapter.java?rev=1726998&r1=1726997&r2=1726998&view=diff
==============================================================================
--- openmeetings/application/branches/3.1.x/openmeetings-core/src/main/java/org/apache/openmeetings/core/remote/red5/ScopeApplicationAdapter.java (original)
+++ openmeetings/application/branches/3.1.x/openmeetings-core/src/main/java/org/apache/openmeetings/core/remote/red5/ScopeApplicationAdapter.java Wed Jan 27 11:21:25 2016
@@ -422,7 +422,7 @@ public class ScopeApplicationAdapter ext
*
* @param newPublicSID
*/
- public Boolean overwritePublicSID(String newPublicSID) {
+ public boolean overwritePublicSID(String newPublicSID) {
try {
log.debug("----------- overwritePublicSID");
IConnection current = Red5.getConnectionLocal();
@@ -438,7 +438,7 @@ public class ScopeApplicationAdapter ext
} catch (Exception err) {
log.error("[overwritePublicSID]", err);
}
- return null;
+ return false;
}
/**
@@ -1905,7 +1905,7 @@ public class ScopeApplicationAdapter ext
* recording instead of iterating through connections!
* @return true in case there is recording session, false otherwise, null if any exception happend
*/
- public Boolean getInterviewRecordingStatus() {
+ public boolean getInterviewRecordingStatus() {
try {
IConnection current = Red5.getConnectionLocal();
@@ -1918,19 +1918,17 @@ public class ScopeApplicationAdapter ext
}
}
}
- return false;
} catch (Exception err) {
log.error("[getInterviewRecordingStatus]", err);
}
-
- return null;
+ return false;
}
/**
* @deprecated @see {@link ScopeApplicationAdapter#getInterviewRecordingStatus()}
* @return - false if there were existing recording, true if recording was started successfully, null if any exception happens
*/
- public Boolean startInterviewRecording() {
+ public boolean startInterviewRecording() {
try {
log.debug("----------- startInterviewRecording");
IConnection current = Red5.getConnectionLocal();
@@ -1974,11 +1972,11 @@ public class ScopeApplicationAdapter ext
} catch (Exception err) {
log.debug("[startInterviewRecording]", err);
}
- return null;
+ return false;
}
@SuppressWarnings({ "rawtypes" })
- public Boolean sendRemoteCursorEvent(final String streamid, Map messageObj) {
+ public boolean sendRemoteCursorEvent(final String streamid, Map messageObj) {
new MessageSender("sendRemoteCursorEvent", messageObj) {
@Override
@@ -1987,7 +1985,7 @@ public class ScopeApplicationAdapter ext
return !SessionVariablesUtil.isScreenClient(client) || !conn.getClient().getId().equals(streamid);
}
}.start();
- return null;
+ return true;
}
private Long checkRecordingClient(IConnection conn) {
@@ -2023,7 +2021,7 @@ public class ScopeApplicationAdapter ext
*
* @return true if interview was found
*/
- private Boolean _stopInterviewRecording(Client currentClient, IScope currentScope) {
+ private boolean _stopInterviewRecording(Client currentClient, IScope currentScope) {
try {
log.debug("----------- stopInterviewRecording");
Long clientRecordingId = currentClient.getRecordingId();
@@ -2051,7 +2049,7 @@ public class ScopeApplicationAdapter ext
} catch (Exception err) {
log.debug("[stopInterviewRecording]", err);
}
- return null;
+ return false;
}
/**
Modified: openmeetings/application/branches/3.1.x/openmeetings-core/src/main/java/org/apache/openmeetings/core/servlet/outputhandler/ExportToImage.java
URL: http://svn.apache.org/viewvc/openmeetings/application/branches/3.1.x/openmeetings-core/src/main/java/org/apache/openmeetings/core/servlet/outputhandler/ExportToImage.java?rev=1726998&r1=1726997&r2=1726998&view=diff
==============================================================================
--- openmeetings/application/branches/3.1.x/openmeetings-core/src/main/java/org/apache/openmeetings/core/servlet/outputhandler/ExportToImage.java (original)
+++ openmeetings/application/branches/3.1.x/openmeetings-core/src/main/java/org/apache/openmeetings/core/servlet/outputhandler/ExportToImage.java Wed Jan 27 11:21:25 2016
@@ -20,9 +20,11 @@ package org.apache.openmeetings.core.ser
import java.io.File;
import java.io.FileOutputStream;
-import java.io.FileWriter;
import java.io.IOException;
import java.io.OutputStream;
+import java.io.OutputStreamWriter;
+import java.io.Writer;
+import java.nio.charset.StandardCharsets;
import java.util.Date;
import java.util.List;
import java.util.Set;
@@ -132,8 +134,7 @@ public class ExportToImage extends BaseH
// Create an instance of the SVG Generator.
SVGGraphics2D svgGenerator = new SVGGraphics2D(document);
- svgGenerator = WhiteboardMapToSVG.getInstance()
- .convertMapToSVG(svgGenerator, whiteBoardMap);
+ svgGenerator = WhiteboardMapToSVG.getInstance().convertMapToSVG(svgGenerator, whiteBoardMap);
// Finally, stream out SVG to the standard output using
// UTF-8 encoding.
@@ -144,10 +145,12 @@ public class ExportToImage extends BaseH
String reqFilePrefix = fileName + "_" + CalendarPatterns.getTimeForStreamId(new Date());
File svgFile = new File(uploadTempDir, reqFilePrefix + ".svg");
log.debug("exported svg file: " + svgFile.getCanonicalPath());
- FileWriter out = new FileWriter(svgFile);
- svgGenerator.stream(out, useCSS);
- out.flush();
- out.close();
+ try (OutputStream os = new FileOutputStream(svgFile);
+ Writer out = new OutputStreamWriter(os, StandardCharsets.UTF_8))
+ {
+ svgGenerator.stream(out, useCSS);
+ out.flush();
+ }
File expFile = new File(uploadTempDir, reqFilePrefix + "." + exportType);
log.debug("exported file: " + expFile.getCanonicalPath());
if ("svg".equals(exportType)) {
Modified: openmeetings/application/branches/3.1.x/openmeetings-core/src/main/java/org/apache/openmeetings/core/session/SessionManager.java
URL: http://svn.apache.org/viewvc/openmeetings/application/branches/3.1.x/openmeetings-core/src/main/java/org/apache/openmeetings/core/session/SessionManager.java?rev=1726998&r1=1726997&r2=1726998&view=diff
==============================================================================
--- openmeetings/application/branches/3.1.x/openmeetings-core/src/main/java/org/apache/openmeetings/core/session/SessionManager.java (original)
+++ openmeetings/application/branches/3.1.x/openmeetings-core/src/main/java/org/apache/openmeetings/core/session/SessionManager.java Wed Jan 27 11:21:25 2016
@@ -167,7 +167,7 @@ public class SessionManager implements I
return null;
}
- public synchronized Boolean updateAVClientByStreamId(String streamId, Client rcm, Server server) {
+ public synchronized boolean updateAVClientByStreamId(String streamId, Client rcm, Server server) {
try {
// get the corresponding user session object and update the settings
Client rclUsual = getClientByPublicSID(rcm.getPublicSID(), server);
@@ -187,13 +187,14 @@ public class SessionManager implements I
}
updateClientByStreamId(streamId, rcm, false, server);
+ return true;
} catch (Exception err) {
log.error("[updateAVClientByStreamId]", err);
}
- return null;
+ return false;
}
- public synchronized Boolean updateClientByStreamId(String streamId,
+ public synchronized boolean updateClientByStreamId(String streamId,
Client rcm, boolean updateRoomCount, Server server) {
try {
@@ -204,27 +205,25 @@ public class SessionManager implements I
return true;
} else {
log.debug("Tried to update a non existing Client " + streamId);
- return false;
}
} catch (Exception err) {
log.error("[updateClientByStreamId]", err);
}
- return null;
+ return false;
}
- public synchronized Boolean removeClient(String streamId, Server server) {
+ public synchronized boolean removeClient(String streamId, Server server) {
try {
if (cache.containsKey(server,streamId)) {
cache.remove(server,streamId);
return true;
} else {
log.debug("Tried to remove a non existing Client " + streamId);
- return false;
}
} catch (Exception err) {
log.error("[removeClient]", err);
}
- return null;
+ return false;
}
public synchronized ArrayList<Client> getClientListByRoom(Long roomId) {
@@ -355,14 +354,14 @@ public class SessionManager implements I
return sessionManager.getClientByUserId(userId);
}
- public Boolean updateAVClientByStreamId(String streamId, Client rcm, Server server) {
+ public boolean updateAVClientByStreamId(String streamId, Client rcm, Server server) {
if (server == null) {
server = serverUtil.getCurrentServer();
}
return sessionManager.updateAVClientByStreamId(streamId, rcm, server);
}
- public Boolean updateClientByStreamId(String streamId, Client rcm,
+ public boolean updateClientByStreamId(String streamId, Client rcm,
boolean updateRoomCount, Server server) {
if (server == null) {
server = serverUtil.getCurrentServer();
@@ -371,7 +370,7 @@ public class SessionManager implements I
updateRoomCount, server);
}
- public Boolean removeClient(String streamId, Server server) {
+ public boolean removeClient(String streamId, Server server) {
if (server == null) {
server = serverUtil.getCurrentServer();
}
Modified: openmeetings/application/branches/3.1.x/openmeetings-db/src/main/java/org/apache/openmeetings/db/dao/server/ISessionManager.java
URL: http://svn.apache.org/viewvc/openmeetings/application/branches/3.1.x/openmeetings-db/src/main/java/org/apache/openmeetings/db/dao/server/ISessionManager.java?rev=1726998&r1=1726997&r2=1726998&view=diff
==============================================================================
--- openmeetings/application/branches/3.1.x/openmeetings-db/src/main/java/org/apache/openmeetings/db/dao/server/ISessionManager.java (original)
+++ openmeetings/application/branches/3.1.x/openmeetings-db/src/main/java/org/apache/openmeetings/db/dao/server/ISessionManager.java Wed Jan 27 11:21:25 2016
@@ -116,7 +116,7 @@ public interface ISessionManager {
* @param rcm
* @return
*/
- public abstract Boolean updateAVClientByStreamId(String streamId, Client rcm, Server server);
+ public abstract boolean updateAVClientByStreamId(String streamId, Client rcm, Server server);
/**
* Update the session object
@@ -131,7 +131,7 @@ public interface ISessionManager {
* true means the count for the room has to be updated
* @return
*/
- public abstract Boolean updateClientByStreamId(String streamId,
+ public abstract boolean updateClientByStreamId(String streamId,
Client rcm, boolean updateRoomCount, Server server);
/**
@@ -140,7 +140,7 @@ public interface ISessionManager {
* @param streamId
* @return
*/
- public abstract Boolean removeClient(String streamId, Server server);
+ public abstract boolean removeClient(String streamId, Server server);
/**
* Get all ClientList Objects of that room and domain This Function is
Modified: openmeetings/application/branches/3.1.x/openmeetings-db/src/main/java/org/apache/openmeetings/db/dao/user/IUserManager.java
URL: http://svn.apache.org/viewvc/openmeetings/application/branches/3.1.x/openmeetings-db/src/main/java/org/apache/openmeetings/db/dao/user/IUserManager.java?rev=1726998&r1=1726997&r2=1726998&view=diff
==============================================================================
--- openmeetings/application/branches/3.1.x/openmeetings-db/src/main/java/org/apache/openmeetings/db/dao/user/IUserManager.java (original)
+++ openmeetings/application/branches/3.1.x/openmeetings-db/src/main/java/org/apache/openmeetings/db/dao/user/IUserManager.java Wed Jan 27 11:21:25 2016
@@ -55,9 +55,9 @@ public interface IUserManager {
User loginOAuth(Map<String, String> params, long serverId) throws IOException, NoSuchAlgorithmException;
/** TODO FIXME seems to be unused **/
- Boolean kickUserByStreamId(String SID, Long roomId);
+ boolean kickUserByStreamId(String SID, Long roomId);
- Boolean kickUserByPublicSID(String SID, String publicSID);
+ boolean kickUserByPublicSID(String SID, String publicSID);
Long logout(String SID, long userId);
Modified: openmeetings/application/branches/3.1.x/openmeetings-db/src/main/java/org/apache/openmeetings/db/dao/user/IUserService.java
URL: http://svn.apache.org/viewvc/openmeetings/application/branches/3.1.x/openmeetings-db/src/main/java/org/apache/openmeetings/db/dao/user/IUserService.java?rev=1726998&r1=1726997&r2=1726998&view=diff
==============================================================================
--- openmeetings/application/branches/3.1.x/openmeetings-db/src/main/java/org/apache/openmeetings/db/dao/user/IUserService.java (original)
+++ openmeetings/application/branches/3.1.x/openmeetings-db/src/main/java/org/apache/openmeetings/db/dao/user/IUserService.java Wed Jan 27 11:21:25 2016
@@ -20,7 +20,7 @@ package org.apache.openmeetings.db.dao.u
//FIXME HACK to bypass cross project compilation
public interface IUserService {
- Boolean kickUserByStreamId(String sid, String streamid, long serverId);
+ boolean kickUserByStreamId(String sid, String streamid, long serverId);
- Boolean kickUserBySessionId(String sid, long userId, String sessionId);
+ boolean kickUserBySessionId(String sid, long userId, String sessionId);
}
Modified: openmeetings/application/branches/3.1.x/openmeetings-service/src/main/java/org/apache/openmeetings/service/user/UserManager.java
URL: http://svn.apache.org/viewvc/openmeetings/application/branches/3.1.x/openmeetings-service/src/main/java/org/apache/openmeetings/service/user/UserManager.java?rev=1726998&r1=1726997&r2=1726998&view=diff
==============================================================================
--- openmeetings/application/branches/3.1.x/openmeetings-service/src/main/java/org/apache/openmeetings/service/user/UserManager.java (original)
+++ openmeetings/application/branches/3.1.x/openmeetings-service/src/main/java/org/apache/openmeetings/service/user/UserManager.java Wed Jan 27 11:21:25 2016
@@ -426,7 +426,7 @@ public class UserManager implements IUse
* @param room_id
* @return
*/
- public Boolean kickUserByStreamId(String SID, Long room_id) {
+ public boolean kickUserByStreamId(String SID, Long room_id) {
try {
Long users_id = sessiondataDao.checkSession(SID);
@@ -455,10 +455,10 @@ public class UserManager implements IUse
} catch (Exception err) {
log.error("[kickUserByStreamId]", err);
}
- return null;
+ return false;
}
- public Boolean kickUserByPublicSID(String SID, String publicSID) {
+ public boolean kickUserByPublicSID(String SID, String publicSID) {
try {
Long userId = sessiondataDao.checkSession(SID);
@@ -487,7 +487,7 @@ public class UserManager implements IUse
} catch (Exception err) {
log.error("[kickUserByStreamId]", err);
}
- return null;
+ return false;
}
public Long getLanguage(Locale loc) {
Modified: openmeetings/application/branches/3.1.x/openmeetings-util/src/main/java/org/apache/openmeetings/util/stringhandlers/ChatString.java
URL: http://svn.apache.org/viewvc/openmeetings/application/branches/3.1.x/openmeetings-util/src/main/java/org/apache/openmeetings/util/stringhandlers/ChatString.java?rev=1726998&r1=1726997&r2=1726998&view=diff
==============================================================================
--- openmeetings/application/branches/3.1.x/openmeetings-util/src/main/java/org/apache/openmeetings/util/stringhandlers/ChatString.java (original)
+++ openmeetings/application/branches/3.1.x/openmeetings-util/src/main/java/org/apache/openmeetings/util/stringhandlers/ChatString.java Wed Jan 27 11:21:25 2016
@@ -187,17 +187,14 @@ public class ChatString {
}
public static String link(String input) {
+ StringBuilder tReturn = new StringBuilder();
try {
-
- String tReturn = "";
-
String parts[] = input.split(" ");
for (int t = 0; t < parts.length; t++) {
-
String text = parts[t];
- // System.out.println("Part 1 "+text);
+ // log.debug("Part 1 "+text);
Matcher matcher = Pattern
.compile(
@@ -205,27 +202,19 @@ public class ChatString {
.matcher(text);
if (matcher.find()) {
- text = matcher
- .replaceFirst("<u><FONT color=\"#0000CC\"><a href='"
- + text + "'>" + text + "</a></FONT></u>");
-
+ text = matcher.replaceFirst("<u><FONT color=\"#0000CC\"><a href='" + text + "'>" + text + "</a></FONT></u>");
}
- // System.out.println("Part 2 "+text);
+ // log.debug("Part 2 "+text);
if (t != 0) {
- tReturn += " ";
+ tReturn.append(" ");
}
-
- tReturn += text;
-
+ tReturn.append(text);
}
-
- return tReturn;
-
} catch (Exception e) {
log.error("[link]", e);
}
- return "";
+ return tReturn.toString();
}
}
Modified: openmeetings/application/trunk/openmeetings-core/src/main/java/org/apache/openmeetings/core/data/conference/RoomManager.java
URL: http://svn.apache.org/viewvc/openmeetings/application/trunk/openmeetings-core/src/main/java/org/apache/openmeetings/core/data/conference/RoomManager.java?rev=1726998&r1=1726997&r2=1726998&view=diff
==============================================================================
--- openmeetings/application/trunk/openmeetings-core/src/main/java/org/apache/openmeetings/core/data/conference/RoomManager.java (original)
+++ openmeetings/application/trunk/openmeetings-core/src/main/java/org/apache/openmeetings/core/data/conference/RoomManager.java Wed Jan 27 11:21:25 2016
@@ -280,37 +280,15 @@ public class RoomManager {
return null;
}
- public List<Room> getRoomsByIds(List<Integer> roomIds) {
+ public List<Room> getRoomsByIds(List<Long> roomIds) {
try {
- if (roomIds == null || roomIds.size() == 0) {
- return new LinkedList<Room>();
+ if (roomIds != null && !roomIds.isEmpty()) {
+ return roomDao.get(roomIds);
}
-
- String queryString = "SELECT r from Room r " + "WHERE ";
-
- queryString += "(";
-
- int i = 0;
- for (Integer roomId : roomIds) {
- if (i != 0) {
- queryString += " OR ";
- }
- queryString += " r.id = " + roomId;
- i++;
- }
-
- queryString += ")";
-
- TypedQuery<Room> q = em.createQuery(queryString, Room.class);
-
- List<Room> ll = q.getResultList();
-
- return ll;
-
} catch (Exception ex2) {
log.error("[getRoomsByIds] ", ex2);
}
- return null;
+ return new LinkedList<Room>();
}
// ---------------------------------------------------------------------------------------------
Modified: openmeetings/application/trunk/openmeetings-core/src/main/java/org/apache/openmeetings/core/data/record/BatikMethods.java
URL: http://svn.apache.org/viewvc/openmeetings/application/trunk/openmeetings-core/src/main/java/org/apache/openmeetings/core/data/record/BatikMethods.java?rev=1726998&r1=1726997&r2=1726998&view=diff
==============================================================================
--- openmeetings/application/trunk/openmeetings-core/src/main/java/org/apache/openmeetings/core/data/record/BatikMethods.java (original)
+++ openmeetings/application/trunk/openmeetings-core/src/main/java/org/apache/openmeetings/core/data/record/BatikMethods.java Wed Jan 27 11:21:25 2016
@@ -290,16 +290,16 @@ public class BatikMethods {
// log.debug("TEXT: "+stringsText);
// log.debug("TEXT: "+stringsText.length);
- String newText = "";
+ StringBuilder newText = new StringBuilder();
for (int i = 0; i < stringsText.length; i++) {
- newText += stringsText[i];
+ newText.append(stringsText[i]);
if (i + 1 < stringsText.length) {
- newText += "\n";
+ newText.append("\n");
}
}
- JTextArea n = new JTextArea(newText);
+ JTextArea n = new JTextArea(newText.toString());
n.setFont(font);
n.setWrapStyleWord(true);
n.setLineWrap(true);
Modified: openmeetings/application/trunk/openmeetings-core/src/main/java/org/apache/openmeetings/core/documents/LibraryChartLoader.java
URL: http://svn.apache.org/viewvc/openmeetings/application/trunk/openmeetings-core/src/main/java/org/apache/openmeetings/core/documents/LibraryChartLoader.java?rev=1726998&r1=1726997&r2=1726998&view=diff
==============================================================================
--- openmeetings/application/trunk/openmeetings-core/src/main/java/org/apache/openmeetings/core/documents/LibraryChartLoader.java (original)
+++ openmeetings/application/trunk/openmeetings-core/src/main/java/org/apache/openmeetings/core/documents/LibraryChartLoader.java Wed Jan 27 11:21:25 2016
@@ -18,20 +18,24 @@
*/
package org.apache.openmeetings.core.documents;
+import static org.apache.openmeetings.util.OpenmeetingsVariables.webAppRootKey;
+
import java.io.BufferedReader;
import java.io.File;
-import java.io.FileReader;
-import java.io.IOException;
+import java.io.FileInputStream;
+import java.io.InputStream;
+import java.io.InputStreamReader;
+import java.nio.charset.StandardCharsets;
import java.util.ArrayList;
-import org.apache.openmeetings.util.Logger;
+import org.red5.logging.Red5LoggerFactory;
+import org.slf4j.Logger;
import com.thoughtworks.xstream.XStream;
import com.thoughtworks.xstream.io.xml.XppDriver;
public class LibraryChartLoader {
-
- private static final Logger log = new Logger();
+ private static final Logger log = Red5LoggerFactory.getLogger(LibraryWmlLoader.class, webAppRootKey);
private static final String fileExt = ".xchart";
@@ -49,7 +53,6 @@ public class LibraryChartLoader {
@SuppressWarnings("rawtypes")
public ArrayList loadChart(File dir, String fileName) {
- BufferedReader reader = null;
try {
File file = new File(dir, fileName + fileExt);
@@ -58,18 +61,14 @@ public class LibraryChartLoader {
XStream xStream = new XStream(new XppDriver());
xStream.setMode(XStream.NO_REFERENCES);
- reader = new BufferedReader(new FileReader(file));
- ArrayList lMapList = (ArrayList) xStream.fromXML(reader);
-
- return lMapList;
- } catch (Exception err) {
- log.error(err);
- } finally {
- if (reader != null) {
- try {
- reader.close();
- } catch (IOException e) {}
+ try (InputStream is = new FileInputStream(file);
+ BufferedReader reader = new BufferedReader(new InputStreamReader(is, StandardCharsets.UTF_8)))
+ {
+ ArrayList lMapList = (ArrayList) xStream.fromXML(reader);
+ return lMapList;
}
+ } catch (Exception err) {
+ log.error("Unexpected error while loading chart", err);
}
return null;
Modified: openmeetings/application/trunk/openmeetings-core/src/main/java/org/apache/openmeetings/core/documents/LibraryDocumentConverter.java
URL: http://svn.apache.org/viewvc/openmeetings/application/trunk/openmeetings-core/src/main/java/org/apache/openmeetings/core/documents/LibraryDocumentConverter.java?rev=1726998&r1=1726997&r2=1726998&view=diff
==============================================================================
--- openmeetings/application/trunk/openmeetings-core/src/main/java/org/apache/openmeetings/core/documents/LibraryDocumentConverter.java (original)
+++ openmeetings/application/trunk/openmeetings-core/src/main/java/org/apache/openmeetings/core/documents/LibraryDocumentConverter.java Wed Jan 27 11:21:25 2016
@@ -18,13 +18,17 @@
*/
package org.apache.openmeetings.core.documents;
+import static org.apache.openmeetings.util.OpenmeetingsVariables.webAppRootKey;
+
import java.io.File;
-import java.io.FileWriter;
-import java.io.PrintWriter;
+import java.io.FileOutputStream;
+import java.io.OutputStream;
+import java.io.OutputStreamWriter;
+import java.io.Writer;
+import java.nio.charset.StandardCharsets;
import java.util.ArrayList;
import org.apache.openmeetings.util.OmFileHelper;
-import org.apache.openmeetings.util.OpenmeetingsVariables;
import org.apache.openmeetings.util.stringhandlers.StringComparer;
import org.red5.logging.Red5LoggerFactory;
import org.slf4j.Logger;
@@ -33,13 +37,12 @@ import com.thoughtworks.xstream.XStream;
import com.thoughtworks.xstream.io.xml.XppDriver;
public class LibraryDocumentConverter {
- private static final Logger log = Red5LoggerFactory.getLogger(LibraryDocumentConverter.class, OpenmeetingsVariables.webAppRootKey);
+ private static final Logger log = Red5LoggerFactory.getLogger(LibraryDocumentConverter.class, webAppRootKey);
private static final String fileExt = ".wml";
public static String writeToLocalFolder(String fileName, @SuppressWarnings("rawtypes")ArrayList objList) {
try {
-
log.debug("filePath: " + OmFileHelper.getUploadWmlDir().getCanonicalPath());
String fileNameExtName = fileName.substring(fileName.length()-4,fileName.length());
@@ -49,14 +52,14 @@ public class LibraryDocumentConverter {
fileName = StringComparer.getInstance().compareForRealPaths(fileName.substring(0, fileName.length()));
}
- if (fileName.length()<=0){
+ if (fileName.length() <= 0){
//return new Long(-21);
return "-20";
}
//Add the Folder for the wmlFiles if it does not exist yet
- File filePathComplete = new File(OmFileHelper.getUploadWmlDir(), fileName + fileExt);
+ File file = new File(OmFileHelper.getUploadWmlDir(), fileName + fileExt);
- if (filePathComplete.exists()){
+ if (file.exists()){
return "-20";
}
@@ -64,16 +67,18 @@ public class LibraryDocumentConverter {
xStream.setMode(XStream.NO_REFERENCES);
String xmlString = xStream.toXML(objList);
- log.debug("Write to "+filePathComplete);
+ log.debug("Write to " + file);
- PrintWriter pw = new PrintWriter(new FileWriter(filePathComplete));
- pw.println(xmlString);
- pw.flush();
- pw.close();
+ try (OutputStream os = new FileOutputStream(file);
+ Writer out = new OutputStreamWriter(os, StandardCharsets.UTF_8))
+ {
+ out.write(xmlString);
+ out.flush();
+ }
//return new Long(1);
- return filePathComplete.getCanonicalPath();
+ return file.getCanonicalPath();
} catch (Exception err){
log.error("writeToLocalFolder",err);
}
Modified: openmeetings/application/trunk/openmeetings-core/src/main/java/org/apache/openmeetings/core/remote/UserService.java
URL: http://svn.apache.org/viewvc/openmeetings/application/trunk/openmeetings-core/src/main/java/org/apache/openmeetings/core/remote/UserService.java?rev=1726998&r1=1726997&r2=1726998&view=diff
==============================================================================
--- openmeetings/application/trunk/openmeetings-core/src/main/java/org/apache/openmeetings/core/remote/UserService.java (original)
+++ openmeetings/application/trunk/openmeetings-core/src/main/java/org/apache/openmeetings/core/remote/UserService.java Wed Jan 27 11:21:25 2016
@@ -106,7 +106,7 @@ public class UserService implements IUse
* REST call
* @return - true if user has sufficient permissions, false otherwise
*/
- public Boolean kickUserByStreamId(String SID, String streamid, long serverId) {
+ public boolean kickUserByStreamId(String SID, String streamid, long serverId) {
try {
Long userId = sessiondataDao.checkSession(SID);
// admins only
@@ -160,7 +160,7 @@ public class UserService implements IUse
* @param publicSID
* @return - true in case user have sufficient permissions, null otherwise
*/
- public Boolean kickUserByPublicSID(String SID, String publicSID) {
+ public boolean kickUserByPublicSID(String SID, String publicSID) {
try {
Long userId = sessiondataDao.checkSession(SID);
// users only
@@ -188,20 +188,21 @@ public class UserService implements IUse
} catch (Exception err) {
log.error("[kickUserByPublicSID]", err);
}
- return null;
+ return false;
}
@Override
- public Boolean kickUserBySessionId(String SID, long userId, String sessionId) {
+ public boolean kickUserBySessionId(String SID, long userId, String sessionId) {
try {
Long users_id = sessiondataDao.checkSession(SID);
// admin only
if (AuthLevelUtil.hasAdminLevel(userDao.getRights(users_id))) {
((IApplication)Application.get(wicketApplicationName)).invalidateClient(userId, sessionId);
+ return true;
}
} catch (Exception err) {
log.error("[kickUserBySessionId]", err);
}
- return null;
+ return false;
}
}
Modified: openmeetings/application/trunk/openmeetings-core/src/main/java/org/apache/openmeetings/core/remote/WhiteBoardService.java
URL: http://svn.apache.org/viewvc/openmeetings/application/trunk/openmeetings-core/src/main/java/org/apache/openmeetings/core/remote/WhiteBoardService.java?rev=1726998&r1=1726997&r2=1726998&view=diff
==============================================================================
--- openmeetings/application/trunk/openmeetings-core/src/main/java/org/apache/openmeetings/core/remote/WhiteBoardService.java (original)
+++ openmeetings/application/trunk/openmeetings-core/src/main/java/org/apache/openmeetings/core/remote/WhiteBoardService.java Wed Jan 27 11:21:25 2016
@@ -88,7 +88,7 @@ public class WhiteBoardService implement
return null;
}
- public Boolean deleteWhiteboard(Long whiteBoardId) {
+ public boolean deleteWhiteboard(Long whiteBoardId) {
try {
IConnection current = Red5.getConnectionLocal();
String streamid = current.getClient().getId();
@@ -104,13 +104,11 @@ public class WhiteBoardService implement
if (returnValue != null) {
return true;
- } else {
- return false;
}
} catch (Exception err) {
log.error("[deleteWhiteboard]", err);
}
- return null;
+ return false;
}
public WhiteboardObjectList getRoomItemsBy() {
Modified: openmeetings/application/trunk/openmeetings-core/src/main/java/org/apache/openmeetings/core/remote/red5/ScopeApplicationAdapter.java
URL: http://svn.apache.org/viewvc/openmeetings/application/trunk/openmeetings-core/src/main/java/org/apache/openmeetings/core/remote/red5/ScopeApplicationAdapter.java?rev=1726998&r1=1726997&r2=1726998&view=diff
==============================================================================
--- openmeetings/application/trunk/openmeetings-core/src/main/java/org/apache/openmeetings/core/remote/red5/ScopeApplicationAdapter.java (original)
+++ openmeetings/application/trunk/openmeetings-core/src/main/java/org/apache/openmeetings/core/remote/red5/ScopeApplicationAdapter.java Wed Jan 27 11:21:25 2016
@@ -413,7 +413,7 @@ public class ScopeApplicationAdapter ext
*
* @param newPublicSID
*/
- public Boolean overwritePublicSID(String newPublicSID) {
+ public boolean overwritePublicSID(String newPublicSID) {
try {
log.debug("----------- overwritePublicSID");
IConnection current = Red5.getConnectionLocal();
@@ -429,7 +429,7 @@ public class ScopeApplicationAdapter ext
} catch (Exception err) {
log.error("[overwritePublicSID]", err);
}
- return null;
+ return false;
}
/**
@@ -1896,7 +1896,7 @@ public class ScopeApplicationAdapter ext
* recording instead of iterating through connections!
* @return true in case there is recording session, false otherwise, null if any exception happend
*/
- public Boolean getInterviewRecordingStatus() {
+ public boolean getInterviewRecordingStatus() {
try {
IConnection current = Red5.getConnectionLocal();
@@ -1909,19 +1909,17 @@ public class ScopeApplicationAdapter ext
}
}
}
- return false;
} catch (Exception err) {
log.error("[getInterviewRecordingStatus]", err);
}
-
- return null;
+ return false;
}
/**
* @deprecated @see {@link ScopeApplicationAdapter#getInterviewRecordingStatus()}
* @return - false if there were existing recording, true if recording was started successfully, null if any exception happens
*/
- public Boolean startInterviewRecording() {
+ public boolean startInterviewRecording() {
try {
log.debug("----------- startInterviewRecording");
IConnection current = Red5.getConnectionLocal();
@@ -1965,11 +1963,11 @@ public class ScopeApplicationAdapter ext
} catch (Exception err) {
log.debug("[startInterviewRecording]", err);
}
- return null;
+ return false;
}
@SuppressWarnings({ "rawtypes" })
- public Boolean sendRemoteCursorEvent(final String streamid, Map messageObj) {
+ public boolean sendRemoteCursorEvent(final String streamid, Map messageObj) {
new MessageSender("sendRemoteCursorEvent", messageObj) {
@Override
@@ -1978,7 +1976,7 @@ public class ScopeApplicationAdapter ext
return !SessionVariablesUtil.isScreenClient(client) || !conn.getClient().getId().equals(streamid);
}
}.start();
- return null;
+ return true;
}
private Long checkRecordingClient(IConnection conn) {
@@ -2014,7 +2012,7 @@ public class ScopeApplicationAdapter ext
*
* @return true if interview was found
*/
- private Boolean _stopInterviewRecording(Client currentClient, IScope currentScope) {
+ private boolean _stopInterviewRecording(Client currentClient, IScope currentScope) {
try {
log.debug("----------- stopInterviewRecording");
Long clientRecordingId = currentClient.getRecordingId();
@@ -2042,7 +2040,7 @@ public class ScopeApplicationAdapter ext
} catch (Exception err) {
log.debug("[stopInterviewRecording]", err);
}
- return null;
+ return false;
}
/**
Modified: openmeetings/application/trunk/openmeetings-core/src/main/java/org/apache/openmeetings/core/servlet/outputhandler/ExportToImage.java
URL: http://svn.apache.org/viewvc/openmeetings/application/trunk/openmeetings-core/src/main/java/org/apache/openmeetings/core/servlet/outputhandler/ExportToImage.java?rev=1726998&r1=1726997&r2=1726998&view=diff
==============================================================================
--- openmeetings/application/trunk/openmeetings-core/src/main/java/org/apache/openmeetings/core/servlet/outputhandler/ExportToImage.java (original)
+++ openmeetings/application/trunk/openmeetings-core/src/main/java/org/apache/openmeetings/core/servlet/outputhandler/ExportToImage.java Wed Jan 27 11:21:25 2016
@@ -20,9 +20,11 @@ package org.apache.openmeetings.core.ser
import java.io.File;
import java.io.FileOutputStream;
-import java.io.FileWriter;
import java.io.IOException;
import java.io.OutputStream;
+import java.io.OutputStreamWriter;
+import java.io.Writer;
+import java.nio.charset.StandardCharsets;
import java.util.Date;
import java.util.List;
import java.util.Set;
@@ -132,8 +134,7 @@ public class ExportToImage extends BaseH
// Create an instance of the SVG Generator.
SVGGraphics2D svgGenerator = new SVGGraphics2D(document);
- svgGenerator = WhiteboardMapToSVG.getInstance()
- .convertMapToSVG(svgGenerator, whiteBoardMap);
+ svgGenerator = WhiteboardMapToSVG.getInstance().convertMapToSVG(svgGenerator, whiteBoardMap);
// Finally, stream out SVG to the standard output using
// UTF-8 encoding.
@@ -144,10 +145,12 @@ public class ExportToImage extends BaseH
String reqFilePrefix = fileName + "_" + CalendarPatterns.getTimeForStreamId(new Date());
File svgFile = new File(uploadTempDir, reqFilePrefix + ".svg");
log.debug("exported svg file: " + svgFile.getCanonicalPath());
- FileWriter out = new FileWriter(svgFile);
- svgGenerator.stream(out, useCSS);
- out.flush();
- out.close();
+ try (OutputStream os = new FileOutputStream(svgFile);
+ Writer out = new OutputStreamWriter(os, StandardCharsets.UTF_8))
+ {
+ svgGenerator.stream(out, useCSS);
+ out.flush();
+ }
File expFile = new File(uploadTempDir, reqFilePrefix + "." + exportType);
log.debug("exported file: " + expFile.getCanonicalPath());
if ("svg".equals(exportType)) {
Modified: openmeetings/application/trunk/openmeetings-core/src/main/java/org/apache/openmeetings/core/session/SessionManager.java
URL: http://svn.apache.org/viewvc/openmeetings/application/trunk/openmeetings-core/src/main/java/org/apache/openmeetings/core/session/SessionManager.java?rev=1726998&r1=1726997&r2=1726998&view=diff
==============================================================================
--- openmeetings/application/trunk/openmeetings-core/src/main/java/org/apache/openmeetings/core/session/SessionManager.java (original)
+++ openmeetings/application/trunk/openmeetings-core/src/main/java/org/apache/openmeetings/core/session/SessionManager.java Wed Jan 27 11:21:25 2016
@@ -167,7 +167,7 @@ public class SessionManager implements I
return null;
}
- public synchronized Boolean updateAVClientByStreamId(String streamId, Client rcm, Server server) {
+ public synchronized boolean updateAVClientByStreamId(String streamId, Client rcm, Server server) {
try {
// get the corresponding user session object and update the settings
Client rclUsual = getClientByPublicSID(rcm.getPublicSID(), server);
@@ -187,13 +187,14 @@ public class SessionManager implements I
}
updateClientByStreamId(streamId, rcm, false, server);
+ return true;
} catch (Exception err) {
log.error("[updateAVClientByStreamId]", err);
}
- return null;
+ return false;
}
- public synchronized Boolean updateClientByStreamId(String streamId,
+ public synchronized boolean updateClientByStreamId(String streamId,
Client rcm, boolean updateRoomCount, Server server) {
try {
@@ -204,27 +205,25 @@ public class SessionManager implements I
return true;
} else {
log.debug("Tried to update a non existing Client " + streamId);
- return false;
}
} catch (Exception err) {
log.error("[updateClientByStreamId]", err);
}
- return null;
+ return false;
}
- public synchronized Boolean removeClient(String streamId, Server server) {
+ public synchronized boolean removeClient(String streamId, Server server) {
try {
if (cache.containsKey(server,streamId)) {
cache.remove(server,streamId);
return true;
} else {
log.debug("Tried to remove a non existing Client " + streamId);
- return false;
}
} catch (Exception err) {
log.error("[removeClient]", err);
}
- return null;
+ return false;
}
public synchronized ArrayList<Client> getClientListByRoom(Long roomId) {
@@ -355,14 +354,14 @@ public class SessionManager implements I
return sessionManager.getClientByUserId(userId);
}
- public Boolean updateAVClientByStreamId(String streamId, Client rcm, Server server) {
+ public boolean updateAVClientByStreamId(String streamId, Client rcm, Server server) {
if (server == null) {
server = serverUtil.getCurrentServer();
}
return sessionManager.updateAVClientByStreamId(streamId, rcm, server);
}
- public Boolean updateClientByStreamId(String streamId, Client rcm,
+ public boolean updateClientByStreamId(String streamId, Client rcm,
boolean updateRoomCount, Server server) {
if (server == null) {
server = serverUtil.getCurrentServer();
@@ -371,7 +370,7 @@ public class SessionManager implements I
updateRoomCount, server);
}
- public Boolean removeClient(String streamId, Server server) {
+ public boolean removeClient(String streamId, Server server) {
if (server == null) {
server = serverUtil.getCurrentServer();
}
Modified: openmeetings/application/trunk/openmeetings-db/src/main/java/org/apache/openmeetings/db/dao/server/ISessionManager.java
URL: http://svn.apache.org/viewvc/openmeetings/application/trunk/openmeetings-db/src/main/java/org/apache/openmeetings/db/dao/server/ISessionManager.java?rev=1726998&r1=1726997&r2=1726998&view=diff
==============================================================================
--- openmeetings/application/trunk/openmeetings-db/src/main/java/org/apache/openmeetings/db/dao/server/ISessionManager.java (original)
+++ openmeetings/application/trunk/openmeetings-db/src/main/java/org/apache/openmeetings/db/dao/server/ISessionManager.java Wed Jan 27 11:21:25 2016
@@ -116,7 +116,7 @@ public interface ISessionManager {
* @param rcm
* @return
*/
- public abstract Boolean updateAVClientByStreamId(String streamId, Client rcm, Server server);
+ public abstract boolean updateAVClientByStreamId(String streamId, Client rcm, Server server);
/**
* Update the session object
@@ -131,7 +131,7 @@ public interface ISessionManager {
* true means the count for the room has to be updated
* @return
*/
- public abstract Boolean updateClientByStreamId(String streamId,
+ public abstract boolean updateClientByStreamId(String streamId,
Client rcm, boolean updateRoomCount, Server server);
/**
@@ -140,7 +140,7 @@ public interface ISessionManager {
* @param streamId
* @return
*/
- public abstract Boolean removeClient(String streamId, Server server);
+ public abstract boolean removeClient(String streamId, Server server);
/**
* Get all ClientList Objects of that room and domain This Function is
Modified: openmeetings/application/trunk/openmeetings-db/src/main/java/org/apache/openmeetings/db/dao/user/IUserManager.java
URL: http://svn.apache.org/viewvc/openmeetings/application/trunk/openmeetings-db/src/main/java/org/apache/openmeetings/db/dao/user/IUserManager.java?rev=1726998&r1=1726997&r2=1726998&view=diff
==============================================================================
--- openmeetings/application/trunk/openmeetings-db/src/main/java/org/apache/openmeetings/db/dao/user/IUserManager.java (original)
+++ openmeetings/application/trunk/openmeetings-db/src/main/java/org/apache/openmeetings/db/dao/user/IUserManager.java Wed Jan 27 11:21:25 2016
@@ -55,9 +55,9 @@ public interface IUserManager {
User loginOAuth(Map<String, String> params, long serverId) throws IOException, NoSuchAlgorithmException;
/** TODO FIXME seems to be unused **/
- Boolean kickUserByStreamId(String SID, Long roomId);
+ boolean kickUserByStreamId(String SID, Long roomId);
- Boolean kickUserByPublicSID(String SID, String publicSID);
+ boolean kickUserByPublicSID(String SID, String publicSID);
Long logout(String SID, long userId);
Modified: openmeetings/application/trunk/openmeetings-db/src/main/java/org/apache/openmeetings/db/dao/user/IUserService.java
URL: http://svn.apache.org/viewvc/openmeetings/application/trunk/openmeetings-db/src/main/java/org/apache/openmeetings/db/dao/user/IUserService.java?rev=1726998&r1=1726997&r2=1726998&view=diff
==============================================================================
--- openmeetings/application/trunk/openmeetings-db/src/main/java/org/apache/openmeetings/db/dao/user/IUserService.java (original)
+++ openmeetings/application/trunk/openmeetings-db/src/main/java/org/apache/openmeetings/db/dao/user/IUserService.java Wed Jan 27 11:21:25 2016
@@ -20,7 +20,7 @@ package org.apache.openmeetings.db.dao.u
//FIXME HACK to bypass cross project compilation
public interface IUserService {
- Boolean kickUserByStreamId(String sid, String streamid, long serverId);
+ boolean kickUserByStreamId(String sid, String streamid, long serverId);
- Boolean kickUserBySessionId(String sid, long userId, String sessionId);
+ boolean kickUserBySessionId(String sid, long userId, String sessionId);
}
Modified: openmeetings/application/trunk/openmeetings-service/src/main/java/org/apache/openmeetings/service/user/UserManager.java
URL: http://svn.apache.org/viewvc/openmeetings/application/trunk/openmeetings-service/src/main/java/org/apache/openmeetings/service/user/UserManager.java?rev=1726998&r1=1726997&r2=1726998&view=diff
==============================================================================
--- openmeetings/application/trunk/openmeetings-service/src/main/java/org/apache/openmeetings/service/user/UserManager.java (original)
+++ openmeetings/application/trunk/openmeetings-service/src/main/java/org/apache/openmeetings/service/user/UserManager.java Wed Jan 27 11:21:25 2016
@@ -426,7 +426,7 @@ public class UserManager implements IUse
* @param room_id
* @return
*/
- public Boolean kickUserByStreamId(String SID, Long room_id) {
+ public boolean kickUserByStreamId(String SID, Long room_id) {
try {
Long users_id = sessiondataDao.checkSession(SID);
@@ -455,10 +455,10 @@ public class UserManager implements IUse
} catch (Exception err) {
log.error("[kickUserByStreamId]", err);
}
- return null;
+ return false;
}
- public Boolean kickUserByPublicSID(String SID, String publicSID) {
+ public boolean kickUserByPublicSID(String SID, String publicSID) {
try {
Long userId = sessiondataDao.checkSession(SID);
@@ -487,7 +487,7 @@ public class UserManager implements IUse
} catch (Exception err) {
log.error("[kickUserByStreamId]", err);
}
- return null;
+ return false;
}
public Long getLanguage(Locale loc) {