This commit is contained in:
@@ -19,7 +19,7 @@ import org.redkale.util.*;
|
|||||||
*
|
*
|
||||||
* @author zhangjx
|
* @author zhangjx
|
||||||
*/
|
*/
|
||||||
public final class SncpRequest extends Request<SncpContext> {
|
public class SncpRequest extends Request<SncpContext> {
|
||||||
|
|
||||||
public static final int HEADER_SIZE = 60;
|
public static final int HEADER_SIZE = 60;
|
||||||
|
|
||||||
|
|||||||
@@ -19,7 +19,7 @@ import org.redkale.util.*;
|
|||||||
*
|
*
|
||||||
* @author zhangjx
|
* @author zhangjx
|
||||||
*/
|
*/
|
||||||
public final class SncpResponse extends Response<SncpContext, SncpRequest> {
|
public class SncpResponse extends Response<SncpContext, SncpRequest> {
|
||||||
|
|
||||||
public static final int RETCODE_ILLSERVICEID = (1 << 1); //无效serviceid
|
public static final int RETCODE_ILLSERVICEID = (1 << 1); //无效serviceid
|
||||||
|
|
||||||
@@ -70,7 +70,7 @@ public final class SncpResponse extends Response<SncpContext, SncpRequest> {
|
|||||||
finish(buffers);
|
finish(buffers);
|
||||||
}
|
}
|
||||||
|
|
||||||
private void fillHeader(ByteBuffer buffer, int bodyLength, int retcode) {
|
protected void fillHeader(ByteBuffer buffer, int bodyLength, int retcode) {
|
||||||
//---------------------head----------------------------------
|
//---------------------head----------------------------------
|
||||||
final int currentpos = buffer.position();
|
final int currentpos = buffer.position();
|
||||||
buffer.position(0);
|
buffer.position(0);
|
||||||
|
|||||||
Reference in New Issue
Block a user