-
Notifications
You must be signed in to change notification settings - Fork 3
/
Copy pathtars-endpoint.js
71 lines (61 loc) · 2.12 KB
/
tars-endpoint.js
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
/**
* Tencent is pleased to support the open source community by making Tars available.
*
* Copyright (C) 2016THL A29 Limited, a Tencent company. All rights reserved.
*
* Licensed under the BSD 3-Clause License (the "License"); you may not use this file except
* in compliance with the License. You may obtain a copy of the License at
*
* https://opensource.org/licenses/BSD-3-Clause
*
* Unless required by applicable law or agreed to in writing, software distributed
* under the License is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR
* CONDITIONS OF ANY KIND, either express or implied. See the License for the
* specific language governing permissions and limitations under the License.
*/
'use strict';
var Endpoint = function (sHost, iPort) {
this.sProtocol = "";
this.sHost = sHost ? sHost : "";
this.iPort = iPort ? iPort : 0;
this.iTimeout = 0;
};
// 输出Endpoint信息
Endpoint.prototype.toString = function () {
return (this.sProtocol + " -h " + this.sHost + " -p " + this.iPort + " -t " + this.iTimeout).replace(/^[\s\t ]+|[\s\t ]+$/g, '');
};
// 拷贝Endpoint实例
Endpoint.prototype.copy = function () {
var temp = new Endpoint();
temp.sProtocol = this.sProtocol;
temp.sHost = this.sHost;
temp.iPort = this.iPort;
temp.iTimeout = this.iTimeout;
return temp;
};
// 从字符串中解析出Endpoint信息
Endpoint.parse = function(desc) {
var endpoint = new Endpoint();
var items = desc.split(" ");
var protocol = items[0].toLowerCase();
if (protocol != "http" && protocol != "tcp" && protocol != "udp") {
return undefined;
}
endpoint.sProtocol = protocol;
for (var ii = 1; ii < items.length; ii++) {
if (items[ii] === "-h") {
endpoint.sHost = items[++ii];
continue;
}
if (items[ii] === "-p") {
endpoint.iPort = parseInt(items[++ii]);
continue;
}
if (items[ii] === "-t") {
endpoint.iTimeout = parseInt(items[++ii]);
continue;
}
}
return endpoint;
};
module.exports = Endpoint;