|
@@ -627,10 +627,15 @@ int process_rpc_req(unsigned char* buf, int size, int* bytes_needed,
|
|
rpc_export_t* rpc_e;
|
|
rpc_export_t* rpc_e;
|
|
struct binrpc_ctx f_ctx;
|
|
struct binrpc_ctx f_ctx;
|
|
struct binrpc_parse_ctx* ctx;
|
|
struct binrpc_parse_ctx* ctx;
|
|
-
|
|
|
|
|
|
+
|
|
|
|
+ if(ksr_shutdown_phase()) {
|
|
|
|
+ /* during shutdown - no more RPC command handling */
|
|
|
|
+ return 0;
|
|
|
|
+ }
|
|
|
|
+
|
|
if (size<BINRPC_MIN_PKT_SIZE){
|
|
if (size<BINRPC_MIN_PKT_SIZE){
|
|
*bytes_needed=BINRPC_MIN_PKT_SIZE-size;
|
|
*bytes_needed=BINRPC_MIN_PKT_SIZE-size;
|
|
- return 0; /* more data , nothing processed */
|
|
|
|
|
|
+ return 0; /* more data, nothing processed */
|
|
}
|
|
}
|
|
err=init_binrpc_ctx(&f_ctx, buf, size, sh);
|
|
err=init_binrpc_ctx(&f_ctx, buf, size, sh);
|
|
ctx=&f_ctx.in.ctx;
|
|
ctx=&f_ctx.in.ctx;
|