Re: [akka-user] Akka-HTTP, Error: "Sending an 2xx 'early' response before end of request was received"

[Akka Team]

Looks like you are doing the right thing there, consuming the entity before
responding, could it be that the create methods throw an exception perhaps?
That would lead to the request body not being consumed as far as I can see.

--
Johan
Akka Team

On Thu, Feb 16, 2017 at 6:42 AM, Vasiliy Levykin 
wrote:

> val uploadF = Future {
>   Files.createDirectories(destPath.getParent)
>   Files.createTempFile(destPath.getParent, "", ".tmp")
> }(filesystemEc) flatMap { tmpPath =>
>
>   withTemporaryFile(tmpPath){ () =>
> for {
>   _ <- ctx.request.entity.withSizeLimit(
> MaxUploadableSize).dataBytes.runWith(FileIO.toPath(tmpPath))
>   lastModifiedTime <- commit(tmpPath, destPath)
> } yield lastModifiedTime
>   }
> }
>

-- 
>>  Read the docs: http://akka.io/docs/
>>  Check the FAQ: 
>> http://doc.akka.io/docs/akka/current/additional/faq.html
>>  Search the archives: https://groups.google.com/group/akka-user
--- 
You received this message because you are subscribed to the Google Groups "Akka 
User List" group.
To unsubscribe from this group and stop receiving emails from it, send an email 
to akka-user+unsubscr...@googlegroups.com.
To post to this group, send email to akka-user@googlegroups.com.
Visit this group at https://groups.google.com/group/akka-user.
For more options, visit https://groups.google.com/d/optout.

[akka-user] Akka-HTTP, Error: "Sending an 2xx 'early' response before end of request was received"

[Vasiliy Levykin]

Hello,

Some time after upgrading to Akka-HTTP 10.0.3, these errors started 
appearing in rare cases, in as yet unknown circumstances.
 

> Sending an 2xx 'early' response before end of request was received... 
> Note that the connection will be closed after this response. 
> Also, many clients will not read early responses! 
> Consider only issuing this response after the request data has been 
> completely read!


The code snippet with more or less relevant part of code:
post {
  extractRequestContext { ctx =>
val uploadF = Future {
  Files.createDirectories(destPath.getParent)
  Files.createTempFile(destPath.getParent, "", ".tmp")
}(filesystemEc) flatMap { tmpPath =>

  withTemporaryFile(tmpPath){ () =>
for {
  _ <- 
ctx.request.entity.withSizeLimit(MaxUploadableSize).dataBytes.runWith(FileIO.toPath(tmpPath))
  lastModifiedTime <- commit(tmpPath, destPath)
} yield lastModifiedTime
  }
}

onComplete(uploadF) {
  case Success(lastModifiedTime) =>
complete("")
  case Failure(ex: FileSystemException) if {
val lowerMessage = ex.getMessage.toLowerCase
lowerMessage.contains("disk quota exceeded") ||
  lowerMessage.contains("no space left on device")
  } =>
complete(HttpResponse(
  status = StatusCodes.RequestEntityTooLarge,
  entity = HttpEntity("Disk quota exceeded")
))

  case Failure(ex) =>
throw ex
}
  }
}

...

private def withTemporaryFile[T](tempFile: Path)
(body: () => Future[T]): Future[T] = {
  val result = body()

  result.recoverWith {
case e =>
  Future(Files.deleteIfExists(tempFile))
.flatMap(_ => result)
  }
}

Can someone help and tell me what is wrong?

Thanks,
Vasiliy

-- 
>>  Read the docs: http://akka.io/docs/
>>  Check the FAQ: 
>> http://doc.akka.io/docs/akka/current/additional/faq.html
>>  Search the archives: https://groups.google.com/group/akka-user
--- 
You received this message because you are subscribed to the Google Groups "Akka 
User List" group.
To unsubscribe from this group and stop receiving emails from it, send an email 
to akka-user+unsubscr...@googlegroups.com.
To post to this group, send email to akka-user@googlegroups.com.
Visit this group at https://groups.google.com/group/akka-user.
For more options, visit https://groups.google.com/d/optout.