| 177 | } |
| 178 | |
| 179 | func (c *Client) Create(path string, data []byte) error { |
| 180 | c.Lock() |
| 181 | defer c.Unlock() |
| 182 | if c.closed { |
| 183 | return errors.Trace(ErrClosedClient) |
| 184 | } |
| 185 | |
| 186 | if err := c.lockFs(); err != nil { |
| 187 | return err |
| 188 | } |
| 189 | defer c.unlockFs() |
| 190 | |
| 191 | if err := c.writeFile(c.realpath(path), data, true); err != nil { |
| 192 | log.Warnf("fsclient - create %s failed", path) |
| 193 | return err |
| 194 | } else { |
| 195 | log.Infof("fsclient - create %s OK", path) |
| 196 | return nil |
| 197 | } |
| 198 | } |
| 199 | |
| 200 | func (c *Client) Update(path string, data []byte) error { |
| 201 | c.Lock() |