Skip to content
体验新版
项目
组织
正在加载...
登录
切换导航
打开侧边栏
openanolis
inclavare-containers
提交
debd3000
I
inclavare-containers
项目概览
openanolis
/
inclavare-containers
通知
4
Star
7
Fork
0
代码
文件
提交
分支
Tags
贡献者
分支图
Diff
Issue
5
列表
看板
标记
里程碑
合并请求
0
分析
仓库
DevOps
项目成员
Pages
I
inclavare-containers
项目概览
项目概览
详情
发布
仓库
仓库
文件
提交
分支
标签
贡献者
分支图
比较
Issue
5
Issue
5
列表
看板
标记
里程碑
合并请求
0
合并请求
0
Pages
分析
分析
仓库分析
DevOps
成员
成员
收起侧边栏
关闭侧边栏
动态
分支图
创建新Issue
提交
Issue看板
前往新版Gitcode,体验更适合开发者的 AI 搜索 >>
提交
debd3000
编写于
9月 16, 2020
作者:
J
jiazhiguang
浏览文件
操作
浏览文件
下载
电子邮件补丁
差异文件
fix epm listen address and configuration file
上级
b29509be
变更
5
隐藏空白更改
内联
并排
Showing
5 changed file
with
35 addition
and
13 deletion
+35
-13
epm/bin/epm
epm/bin/epm
+0
-0
epm/cmd/epm/app/server.go
epm/cmd/epm/app/server.go
+8
-4
epm/cmd/epm/app/start.go
epm/cmd/epm/app/start.go
+2
-2
epm/cmd/epm/main.go
epm/cmd/epm/main.go
+24
-6
epm/conf/config.toml
epm/conf/config.toml
+1
-1
未找到文件。
epm/bin/epm
0 → 100755
浏览文件 @
debd3000
文件已添加
epm/cmd/epm/app/server.go
浏览文件 @
debd3000
...
...
@@ -6,6 +6,8 @@ import (
"net"
"time"
"github.com/golang/glog"
"github.com/alibaba/inclavare-containers/epm/cmd/epm/app/options"
"github.com/alibaba/inclavare-containers/epm/config"
"github.com/alibaba/inclavare-containers/epm/pkg/epm"
...
...
@@ -16,7 +18,7 @@ import (
"google.golang.org/grpc"
)
func
runServer
(
opts
*
options
.
Options
)
error
{
func
runServer
(
opts
*
options
.
Options
,
stopCh
<-
chan
struct
{}
)
error
{
var
err
error
var
cfg
config
.
Config
...
...
@@ -36,11 +38,11 @@ func runServer(opts *options.Options) error {
serverOpts
=
append
(
serverOpts
,
grpc
.
MaxSendMsgSize
(
cfg
.
GRPC
.
MaxSendMsgSize
))
}
metadata
,
err
:=
cache_metadata
.
NewMetadataServer
(
cfg
.
DBPath
,
time
.
Second
*
time
.
Duration
(
cfg
.
DBTimeout
))
defer
metadata
.
Close
()
if
err
!=
nil
{
return
fmt
.
Errorf
(
"create metadata server failed. %++v"
,
err
)
}
defer
metadata
.
Close
()
server
:=
epm
.
EnclavePoolManagerServer
{}
...
...
@@ -58,12 +60,14 @@ func runServer(opts *options.Options) error {
// registry and start the cache pool manager server
v1alpha1
.
RegisterEnclavePoolManagerServer
(
s
,
&
server
)
// listen and serve
lis
,
err
:=
net
.
Listen
(
"u
dp
"
,
cfg
.
GRPC
.
Address
)
lis
,
err
:=
net
.
Listen
(
"u
nix
"
,
cfg
.
GRPC
.
Address
)
if
err
!=
nil
{
log
.
Fatalf
(
"failed to listen: %v"
,
err
)
}
glog
.
Info
(
"start the and epm server..."
)
if
err
:=
s
.
Serve
(
lis
);
err
!=
nil
{
log
.
Fatalf
(
"failed to start
cache pool manager
server: %v"
,
err
)
log
.
Fatalf
(
"failed to start
epm
server: %v"
,
err
)
}
<-
stopCh
return
nil
}
epm/cmd/epm/app/start.go
浏览文件 @
debd3000
...
...
@@ -6,13 +6,13 @@ import (
)
// NewEnclavePoolManagerServer creat and start the enclave pool manager server
func
NewEnclavePoolManagerServer
()
*
cobra
.
Command
{
func
NewEnclavePoolManagerServer
(
stopCh
<-
chan
struct
{}
)
*
cobra
.
Command
{
opts
:=
&
options
.
Options
{}
cmd
:=
&
cobra
.
Command
{
Short
:
"Launch signature server"
,
Long
:
"Launch signature server"
,
RunE
:
func
(
cmd
*
cobra
.
Command
,
args
[]
string
)
error
{
return
runServer
(
opts
)
return
runServer
(
opts
,
stopCh
)
},
}
flags
:=
cmd
.
Flags
()
...
...
epm/cmd/epm/main.go
浏览文件 @
debd3000
...
...
@@ -3,24 +3,42 @@ package main
import
(
"flag"
"os"
"os/signal"
"runtime"
"syscall"
"github.com/alibaba/inclavare-containers/epm/cmd/epm/app"
"github.com/golang/glog"
)
var
onlyOneSignalHandler
=
make
(
chan
struct
{})
var
shutdownSignals
=
[]
os
.
Signal
{
os
.
Interrupt
,
syscall
.
SIGTERM
}
func
setupSignalHandler
()
<-
chan
struct
{}
{
close
(
onlyOneSignalHandler
)
// panics when called twice
stop
:=
make
(
chan
struct
{})
c
:=
make
(
chan
os
.
Signal
,
2
)
signal
.
Notify
(
c
,
shutdownSignals
...
)
go
func
()
{
<-
c
close
(
stop
)
<-
c
os
.
Exit
(
1
)
// second signal. Exit directly.
}()
return
stop
}
func
main
()
{
if
len
(
os
.
Getenv
(
"GOMAXPROCS"
))
==
0
{
runtime
.
GOMAXPROCS
(
runtime
.
NumCPU
())
}
cmd
:=
app
.
NewEnclavePoolManagerServer
()
stopCh
:=
setupSignalHandler
()
cmd
:=
app
.
NewEnclavePoolManagerServer
(
stopCh
)
cmd
.
Flags
()
.
AddGoFlagSet
(
flag
.
CommandLine
)
if
err
:=
cmd
.
Execute
();
err
!=
nil
{
glog
.
Fatal
(
err
)
}
flag
.
CommandLine
.
Parse
([]
string
{})
if
err
:=
cmd
.
Execute
();
err
!=
nil
{
glog
.
Fatal
(
err
)
...
...
epm/conf/config.toml
浏览文件 @
debd3000
...
...
@@ -3,7 +3,7 @@ db_path = "/var/local/epm/epm.db"
db_timeout
=
10
[grpc]
address
=
"/var/run/
containerd/containerd
.sock"
address
=
"/var/run/
epm
.sock"
uid
=
0
gid
=
0
max_recv_message_size
=
16777216
...
...
编辑
预览
Markdown
is supported
0%
请重试
或
添加新附件
.
添加附件
取消
You are about to add
0
people
to the discussion. Proceed with caution.
先完成此消息的编辑!
取消
想要评论请
注册
或
登录