MDS/openide
1
0
Fork 0
mirror of https://gitflic.ru/project/openide/openide.git synced 2026-09-27 10:03:11 +07:00
Code Issues Packages Projects Releases Wiki Activity

inline HEADER_LENGTH

Browse Source
This commit is contained in:
Vladimir Krivosheev
2017-07-13 12:58:59 +02:00
parent 4e8024e4b4
commit 84aa38ffee
3 changed files with 5 additions and 8 deletions
Download Patch File Download Diff File Expand all files Collapse all files
platform/built-in-server/src/org/jetbrains/io/fastCgi/FastCgiConstants.java
-5
View File
@@ -1,5 +0,0 @@
package org.jetbrains.io.fastCgi;
public final class FastCgiConstants {
public static final int HEADER_LENGTH = 8;
}
platform/built-in-server/src/org/jetbrains/io/fastCgi/FastCgiDecoder.kt
+3 -1
View File
@@ -8,6 +8,8 @@ import io.netty.channel.ChannelHandlerContext
import io.netty.util.CharsetUtil
import org.jetbrains.io.Decoder
internal const val HEADER_LENGTH = 8
internal class FastCgiDecoder(private val errorOutputConsumer: Consumer<String>, private val responseHandler: FastCgiService) : Decoder(), Decoder.FullMessageConsumer<Void> {
private enum class State {
HEADER,
@@ -52,7 +54,7 @@ internal class FastCgiDecoder(private val errorOutputConsumer: Consumer<String>,
}
}
val buffer = getBufferIfSufficient(input, FastCgiConstants.HEADER_LENGTH, context) ?: return
val buffer = getBufferIfSufficient(input, HEADER_LENGTH, context) ?: return
decodeHeader(buffer)
state = State.CONTENT
platform/built-in-server/src/org/jetbrains/io/fastCgi/FastCgiRequest.kt
+2 -2
View File
@@ -23,7 +23,7 @@ class FastCgiRequest(val requestId: Int, allocator: ByteBufAllocator) {
private var buffer: ByteBuf? = allocator.ioBuffer(4096)
init {
writeHeader(buffer!!, BEGIN_REQUEST, FastCgiConstants.HEADER_LENGTH)
writeHeader(buffer!!, BEGIN_REQUEST, HEADER_LENGTH)
buffer!!.writeShort(RESPONDER)
buffer!!.writeByte(FCGI_KEEP_CONNECTION)
// reserved[5]
@@ -128,7 +128,7 @@ class FastCgiRequest(val requestId: Int, allocator: ByteBufAllocator) {
// channel.write releases
releaseContent = false
val headerBuffer = fastCgiChannel.alloc().ioBuffer(FastCgiConstants.HEADER_LENGTH, FastCgiConstants.HEADER_LENGTH)
val headerBuffer = fastCgiChannel.alloc().ioBuffer(HEADER_LENGTH, HEADER_LENGTH)
writeHeader(headerBuffer, STDIN, 0)
fastCgiChannel.write(headerBuffer)
}