MCPcopy
hub / github.com/davyxu/cellnet / NewEventQueue

Function NewEventQueue

queue.go:125–137  ·  view source on GitHub ↗

创建默认长度的队列

()

Source from the content-addressed store, hash-verified

123
124// 创建默认长度的队列
125func NewEventQueue() EventQueue {
126
127 return &eventQueue{
128 Pipe: NewPipe(),
129
130 // 默认的崩溃捕获打印
131 onPanic: func(raw interface{}, queue EventQueue) {
132
133 fmt.Printf("%s: %v \n%s\n", time.Now().Format("2006-01-02 15:04:05"), raw, string(debug.Stack()))
134 debug.PrintStack()
135 },
136 }
137}
138
139// 在会话对应的Peer上的事件队列中执行callback,如果没有队列,则马上执行
140func SessionQueuedCall(ses Session, callback func()) {

Callers 15

serverFunction · 0.92
clientFunction · 0.92
TestAfterTimerFunction · 0.92
TestLoopTimerFunction · 0.92
rpc_StartServerFunction · 0.92
rpc_StartClientFunction · 0.92
relay_backendFunction · 0.92
relay_clientFunction · 0.92
echo_StartServerFunction · 0.92
echo_StartClientFunction · 0.92
recreateConn_StartServerFunction · 0.92
runConnCloseFunction · 0.92

Calls 1

NewPipeFunction · 0.85

Tested by 12

TestAfterTimerFunction · 0.74
TestLoopTimerFunction · 0.74
rpc_StartServerFunction · 0.74
rpc_StartClientFunction · 0.74
relay_backendFunction · 0.74
relay_clientFunction · 0.74
echo_StartServerFunction · 0.74
echo_StartClientFunction · 0.74
recreateConn_StartServerFunction · 0.74
runConnCloseFunction · 0.74
TestLoopPanicFunction · 0.74