Fix connection closing: close connection in all cases
authorValentina Kiryushkina <valentina.kiryushkina@jetbrains.com>
Sat, 6 Aug 2016 17:50:19 +0000 (20:50 +0300)
committerValentina Kiryushkina <valentina.kiryushkina@jetbrains.com>
Sat, 6 Aug 2016 18:04:34 +0000 (21:04 +0300)
python/educational-core/student/src/com/jetbrains/edu/learning/stepic/EduAdaptiveStepicConnector.java

index d02c43a1ee92e77eca692592e2f251d3fed755bf..118824fcc10b4e3790ed66809ac1bf808ed7e5d1 100644 (file)
@@ -201,6 +201,9 @@ public class EduAdaptiveStepicConnector {
     try {
       final CloseableHttpResponse execute = client.execute(post);
       final int statusCode = execute.getStatusLine().getStatusCode();
+      final HttpEntity entity = execute.getEntity();
+      final String entityString = EntityUtils.toString(entity);
+      EntityUtils.consume(entity);
       if (statusCode == HttpStatus.SC_CREATED) {
         return true;
       }
@@ -208,9 +211,6 @@ public class EduAdaptiveStepicConnector {
         if ((statusCode == HttpStatus.SC_BAD_REQUEST || statusCode == HttpStatus.SC_UNAUTHORIZED) && login(project)) {
           return postRecommendationReaction(project, lessonId, user, reaction);
         }
-        final HttpEntity entity = execute.getEntity();
-        final String entityString = EntityUtils.toString(entity);
-        EntityUtils.consume(entity);
         LOG.warn("Stepic returned non-201 status code: " + statusCode + " " + entityString);
         return false;
       }
@@ -549,10 +549,10 @@ public class EduAdaptiveStepicConnector {
     setTimeout(post);
     final CloseableHttpResponse httpResponse = client.execute(post);
     final int statusCode = httpResponse.getStatusLine().getStatusCode();
+    final HttpEntity entity = httpResponse.getEntity();
+    final String entityString = EntityUtils.toString(entity);
+    EntityUtils.consume(entity);
     if (statusCode == HttpStatus.SC_CREATED) {
-      final HttpEntity entity = httpResponse.getEntity();
-      final String entityString = EntityUtils.toString(entity);
-      EntityUtils.consume(entity);
       final StepicWrappers.AttemptContainer container =
         new Gson().fromJson(entityString, StepicWrappers.AttemptContainer.class);
       return (container.attempts != null && !container.attempts.isEmpty()) ? container.attempts.get(0).id : -1;