(wr io.Writer)
| 134 | } |
| 135 | return &snap{s: s}, nil |
| 136 | } |
| 137 | |
| 138 | func restore(rd io.Reader) (interface{}, error) { |
| 139 | return nil, restoreSnapshot(storageDriver(), rd) |
| 140 | } |
| 141 | |
| 142 | func connOpened(addr string) (context interface{}, accept bool) { |
| 143 | atomic.AddInt64(&respClientNum, 1) |
| 144 | return nil, true |
| 145 | } |
| 146 | |
| 147 | func connClosed(context interface{}, addr string) { |
| 148 | atomic.AddInt64(&respClientNum, -1) |
| 149 | return |
| 150 | } |