Commit 0dfddece authored by Kirill Smelkov's avatar Kirill Smelkov

.

parent b37dfbd2
...@@ -1164,6 +1164,7 @@ static void vma_page_ensure_notmappedrw(VMA *vma, Page *page) ...@@ -1164,6 +1164,7 @@ static void vma_page_ensure_notmappedrw(VMA *vma, Page *page)
/* return whether fileh page is dirty or not. /* return whether fileh page is dirty or not.
* *
* must be called under virtmem lock. * must be called under virtmem lock.
* XXX kill __ -> fileh_page_isdirty
*/ */
bool __fileh_page_isdirty(BigFileH *fileh, pgoff_t pgoffset) bool __fileh_page_isdirty(BigFileH *fileh, pgoff_t pgoffset)
{ {
......
...@@ -925,7 +925,7 @@ retry: ...@@ -925,7 +925,7 @@ retry:
// notify .wcfs/zhead // notify .wcfs/zhead
for sk := range gdebug.zheadSockTab { for sk := range gdebug.zheadSockTab {
_, err := fmt.Fprintf(xio.BindWriter(sk, ctx), "%s\n", δZ.Tid) _, err := fmt.Fprintf(xio.BindCtxW(sk, ctx), "%s\n", δZ.Tid)
if err != nil { if err != nil {
log.Errorf("%s", err) // XXX errctx + file, handle, reader pid log.Errorf("%s", err) // XXX errctx + file, handle, reader pid
sk.Close() sk.Close()
...@@ -1738,7 +1738,7 @@ func (wlink *WatchLink) _serve() (err error) { ...@@ -1738,7 +1738,7 @@ func (wlink *WatchLink) _serve() (err error) {
ctx, cancel := context.WithCancel(ctx0) ctx, cancel := context.WithCancel(ctx0)
wg, ctx := errgroup.WithContext(ctx) wg, ctx := errgroup.WithContext(ctx)
r := bufio.NewReader(xio.BindReader(wlink.sk, ctx)) r := bufio.NewReader(xio.BindCtxR(wlink.sk, ctx))
defer func() { defer func() {
// cancel all handlers on both error and ok return. // cancel all handlers on both error and ok return.
......
Markdown is supported
0%
or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment