archive-gh-me/sofa-rpc-node
1
0
Fork 0
mirror of https://github.com/sofastack/sofa-rpc-node.git synced 2026-01-18 15:55:54 +00:00
Code Issues Projects Releases Wiki Activity

fix: 删除用户传参相关错误日志

Browse Source
This commit is contained in:
岱鹿 2022-03-17 17:18:27 +08:00
parent a5d779a989
commit 6490f1cbe8
1 changed files with 3 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
lib/server/server.js
View File

@ -88,7 +88,7 @@ class RpcServer extends Base {
}
get listenPorts() {
return [this.publishPort];
return [ this.publishPort ];
}
get logger() {
@ -188,7 +188,7 @@ class RpcServer extends Base {
this._handleUncaughtError();
},
});
Promise.all(this._servers.map(server => awaitFirst(server, ['listening', 'error'])))
Promise.all(this._servers.map(server => awaitFirst(server, [ 'listening', 'error' ])))
.then(() => {
this.emit('listening');
this.ready(true);
@ -254,7 +254,7 @@ class RpcServer extends Base {
this._connections.set(key, conn);
conn.on('request', req => {
this._handleRequest(req, conn).catch(err => {
const { packetId, packetType, className, options, meta, ctx } = req
const { packetId, packetType, className, options, meta, ctx } = req;
const { targetAppName, methodName, serverSignature, interfaceName, methodArgSigs, requestProps } = req.data;
err.req = { packetId, packetType, className, options, meta, ctx, data: { targetAppName, methodName, serverSignature, interfaceName, methodArgSigs, requestProps } };
this.emit('error', err);