Home
last modified time | relevance | path

Searched refs:WatchId (Results 1 – 25 of 170) sorted by relevance

1234567

/dports/devel/stack/stack-2.7.3/_cabal_deps/fsnotify-0.3.0.1/win-src/System/Win32/
H A DNotify.hs6 , WatchId(..)
52 data WatchId = WatchId ThreadId ThreadId Handle deriving (Eq, Ord, Show) type
53 type WatchMap = Map WatchId Handler
66 watchDirectory :: WatchManager -> FilePath -> Bool -> FileNotificationFlag -> Handler -> IO WatchId
72 …modifyMVar_ mvarMap $ \watchMap -> return (Map.insert (WatchId tid1 tid2 watchHandle) handler watc…
73 return (WatchId tid1 tid2 watchHandle)
83 watch :: WatchManager -> FilePath -> Bool -> FileNotificationFlag -> IO (WatchId, Chan [Event])
88 …modifyMVar_ mvarMap $ \watchMap -> return (Map.insert (WatchId tid tid watchHandle) (const $ retur…
89 return ((WatchId tid tid watchHandle), chanEvents)
96 killWatch :: WatchId -> IO ()
[all …]
/dports/finance/hs-hledger-ui/hledger-ui-1.19/_cabal_deps/fsnotify-0.3.0.1/win-src/System/Win32/
H A DNotify.hs6 , WatchId(..)
52 data WatchId = WatchId ThreadId ThreadId Handle deriving (Eq, Ord, Show) constructor
53 type WatchMap = Map WatchId Handler
66 watchDirectory :: WatchManager -> FilePath -> Bool -> FileNotificationFlag -> Handler -> IO WatchId
72 …modifyMVar_ mvarMap $ \watchMap -> return (Map.insert (WatchId tid1 tid2 watchHandle) handler watc…
73 return (WatchId tid1 tid2 watchHandle)
83 watch :: WatchManager -> FilePath -> Bool -> FileNotificationFlag -> IO (WatchId, Chan [Event])
88 …modifyMVar_ mvarMap $ \watchMap -> return (Map.insert (WatchId tid tid watchHandle) (const $ retur…
89 return ((WatchId tid tid watchHandle), chanEvents)
96 killWatch :: WatchId -> IO ()
[all …]
/dports/devel/hs-spago/spago-0.20.3/_cabal_deps/fsnotify-0.3.0.1/win-src/System/Win32/
H A DNotify.hs6 , WatchId(..)
52 data WatchId = WatchId ThreadId ThreadId Handle deriving (Eq, Ord, Show) function
53 type WatchMap = Map WatchId Handler
66 watchDirectory :: WatchManager -> FilePath -> Bool -> FileNotificationFlag -> Handler -> IO WatchId
72 …modifyMVar_ mvarMap $ \watchMap -> return (Map.insert (WatchId tid1 tid2 watchHandle) handler watc…
73 return (WatchId tid1 tid2 watchHandle)
83 watch :: WatchManager -> FilePath -> Bool -> FileNotificationFlag -> IO (WatchId, Chan [Event])
88 …modifyMVar_ mvarMap $ \watchMap -> return (Map.insert (WatchId tid tid watchHandle) (const $ retur…
89 return ((WatchId tid tid watchHandle), chanEvents)
96 killWatch :: WatchId -> IO ()
[all …]
/dports/www/hs-yesod-bin/yesod-bin-1.6.1/_cabal_deps/fsnotify-0.3.0.1/win-src/System/Win32/
H A DNotify.hs6 , WatchId(..)
52 data WatchId = WatchId ThreadId ThreadId Handle deriving (Eq, Ord, Show) function
53 type WatchMap = Map WatchId Handler
66 watchDirectory :: WatchManager -> FilePath -> Bool -> FileNotificationFlag -> Handler -> IO WatchId
72 …modifyMVar_ mvarMap $ \watchMap -> return (Map.insert (WatchId tid1 tid2 watchHandle) handler watc…
73 return (WatchId tid1 tid2 watchHandle)
83 watch :: WatchManager -> FilePath -> Bool -> FileNotificationFlag -> IO (WatchId, Chan [Event])
88 …modifyMVar_ mvarMap $ \watchMap -> return (Map.insert (WatchId tid tid watchHandle) (const $ retur…
89 return ((WatchId tid tid watchHandle), chanEvents)
96 killWatch :: WatchId -> IO ()
[all …]
/dports/lang/purescript/purescript-0.14.5/_cabal_deps/fsnotify-0.3.0.1/win-src/System/Win32/
H A DNotify.hs6 , WatchId(..)
52 data WatchId = WatchId ThreadId ThreadId Handle deriving (Eq, Ord, Show) type
53 type WatchMap = Map WatchId Handler
66 watchDirectory :: WatchManager -> FilePath -> Bool -> FileNotificationFlag -> Handler -> IO WatchId
72 …modifyMVar_ mvarMap $ \watchMap -> return (Map.insert (WatchId tid1 tid2 watchHandle) handler watc…
73 return (WatchId tid1 tid2 watchHandle)
83 watch :: WatchManager -> FilePath -> Bool -> FileNotificationFlag -> IO (WatchId, Chan [Event])
88 …modifyMVar_ mvarMap $ \watchMap -> return (Map.insert (WatchId tid tid watchHandle) (const $ retur…
89 return ((WatchId tid tid watchHandle), chanEvents)
96 killWatch :: WatchId -> IO ()
[all …]
/dports/net/rabbitmq/rabbitmq-server-3.9.11/deps/eetcd/src/
H A Deetcd_watch.erl35 with_watch_id(Context, WatchId) ->
36 maps:put(watch_id, WatchId, Context).
139 watch_id := WatchId
149 watch_id => WatchId,
187 watch_id := WatchId} = Resp,
192 watch_id => WatchId,
230 watch_id := WatchId,
233 Request = #{request_union => {cancel_request, #{watch_id => WatchId}}},
235 await_unwatch_resp(Gun, StreamRef, Unprocessed, WatchId, Timeout, MRef, []).
241 await_unwatch_resp(Gun, StreamRef, Unprocessed, WatchId, Timeout, MRef, Acc) ->
[all …]
/dports/devel/etcd/etcd-2.3.8/clientv3/
H A Dwatch.go217 if resp.WatchId == -1 {
226 id: resp.WatchId,
299 delete(cancelSet, pbresp.WatchId)
306 if _, ok := cancelSet[pbresp.WatchId]; ok {
309 cancelSet[pbresp.WatchId] = struct{}{}
312 WatchId: pbresp.WatchId,
354 ws, ok := w.streams[pbresp.WatchId]
524 ws.id = resp.WatchId
/dports/www/gitea/gitea-1.16.5/vendor/go.etcd.io/etcd/client/v3/
H A Dwatch.go453 if resp.WatchId == -1 || (resp.Canceled && resp.CancelReason != "") {
459 ws.id = resp.WatchId
574 } else if cur != nil && cur.WatchId == pbresp.WatchId {
600 delete(cancelSet, pbresp.WatchId)
601 if ws, ok := w.substreams[pbresp.WatchId]; ok {
627 if _, ok := cancelSet[pbresp.WatchId]; ok {
631 cancelSet[pbresp.WatchId] = struct{}{}
634 WatchId: pbresp.WatchId,
676 WatchId: ws.id,
719 if wr.IsProgressNotify() && pbresp.WatchId == -1 {
[all …]
/dports/www/grafana8/grafana-8.3.6/vendor/github.com/grafana/loki/vendor/go.etcd.io/etcd/client/v3/
H A Dwatch.go453 if resp.WatchId == -1 || (resp.Canceled && resp.CancelReason != "") {
459 ws.id = resp.WatchId
574 } else if cur != nil && cur.WatchId == pbresp.WatchId {
602 delete(cancelSet, pbresp.WatchId)
603 if ws, ok := w.substreams[pbresp.WatchId]; ok {
629 if _, ok := cancelSet[pbresp.WatchId]; ok {
633 cancelSet[pbresp.WatchId] = struct{}{}
636 WatchId: pbresp.WatchId,
678 WatchId: ws.id,
721 if wr.IsProgressNotify() && pbresp.WatchId == -1 {
[all …]
/dports/www/grafana8/grafana-8.3.6/vendor/github.com/cortexproject/cortex/vendor/go.etcd.io/etcd/client/v3/
H A Dwatch.go453 if resp.WatchId == -1 || (resp.Canceled && resp.CancelReason != "") {
459 ws.id = resp.WatchId
574 } else if cur != nil && cur.WatchId == pbresp.WatchId {
602 delete(cancelSet, pbresp.WatchId)
603 if ws, ok := w.substreams[pbresp.WatchId]; ok {
629 if _, ok := cancelSet[pbresp.WatchId]; ok {
633 cancelSet[pbresp.WatchId] = struct{}{}
636 WatchId: pbresp.WatchId,
678 WatchId: ws.id,
721 if wr.IsProgressNotify() && pbresp.WatchId == -1 {
[all …]
/dports/net-im/nextcloud-spreed-signaling/nextcloud-spreed-signaling-0.2.0/vendor/src/go.etcd.io/etcd/clientv3/
H A Dwatch.go446 if resp.WatchId == -1 || (resp.Canceled && resp.CancelReason != "") {
452 ws.id = resp.WatchId
571 } else if cur != nil && cur.WatchId == pbresp.WatchId {
599 delete(cancelSet, pbresp.WatchId)
600 if ws, ok := w.substreams[pbresp.WatchId]; ok {
626 if _, ok := cancelSet[pbresp.WatchId]; ok {
630 cancelSet[pbresp.WatchId] = struct{}{}
633 WatchId: pbresp.WatchId,
675 WatchId: ws.id,
728 if wr.IsProgressNotify() && pbresp.WatchId == -1 {
[all …]
/dports/sysutils/kubectl/kubernetes-1.22.2/vendor/go.etcd.io/etcd/client/v3/
H A Dwatch.go453 if resp.WatchId == -1 || (resp.Canceled && resp.CancelReason != "") {
459 ws.id = resp.WatchId
574 } else if cur != nil && cur.WatchId == pbresp.WatchId {
602 delete(cancelSet, pbresp.WatchId)
603 if ws, ok := w.substreams[pbresp.WatchId]; ok {
629 if _, ok := cancelSet[pbresp.WatchId]; ok {
633 cancelSet[pbresp.WatchId] = struct{}{}
636 WatchId: pbresp.WatchId,
678 WatchId: ws.id,
721 if wr.IsProgressNotify() && pbresp.WatchId == -1 {
[all …]
/dports/www/minio-client/etcd-3.5.0/client/v3/
H A Dwatch.go453 if resp.WatchId == -1 || (resp.Canceled && resp.CancelReason != "") {
459 ws.id = resp.WatchId
574 } else if cur != nil && cur.WatchId == pbresp.WatchId {
602 delete(cancelSet, pbresp.WatchId)
603 if ws, ok := w.substreams[pbresp.WatchId]; ok {
629 if _, ok := cancelSet[pbresp.WatchId]; ok {
633 cancelSet[pbresp.WatchId] = struct{}{}
636 WatchId: pbresp.WatchId,
678 WatchId: ws.id,
721 if wr.IsProgressNotify() && pbresp.WatchId == -1 {
[all …]
/dports/devel/etcd34/etcd-3.4.18/clientv3/
H A Dwatch.go446 if resp.WatchId == -1 || (resp.Canceled && resp.CancelReason != "") {
452 ws.id = resp.WatchId
571 } else if cur != nil && cur.WatchId == pbresp.WatchId {
599 delete(cancelSet, pbresp.WatchId)
600 if ws, ok := w.substreams[pbresp.WatchId]; ok {
626 if _, ok := cancelSet[pbresp.WatchId]; ok {
630 cancelSet[pbresp.WatchId] = struct{}{}
633 WatchId: pbresp.WatchId,
675 WatchId: ws.id,
728 if wr.IsProgressNotify() && pbresp.WatchId == -1 {
[all …]
/dports/net/traefik/traefik-2.6.1/vendor/go.etcd.io/etcd/client/v3/
H A Dwatch.go453 if resp.WatchId == -1 || (resp.Canceled && resp.CancelReason != "") {
459 ws.id = resp.WatchId
574 } else if cur != nil && cur.WatchId == pbresp.WatchId {
602 delete(cancelSet, pbresp.WatchId)
603 if ws, ok := w.substreams[pbresp.WatchId]; ok {
629 if _, ok := cancelSet[pbresp.WatchId]; ok {
633 cancelSet[pbresp.WatchId] = struct{}{}
636 WatchId: pbresp.WatchId,
678 WatchId: ws.id,
721 if wr.IsProgressNotify() && pbresp.WatchId == -1 {
[all …]
/dports/sysutils/terraform/terraform-1.0.11/vendor/go.etcd.io/etcd/clientv3/
H A Dwatch.go446 if resp.WatchId == -1 || (resp.Canceled && resp.CancelReason != "") {
452 ws.id = resp.WatchId
571 } else if cur != nil && cur.WatchId == pbresp.WatchId {
599 delete(cancelSet, pbresp.WatchId)
600 if ws, ok := w.substreams[pbresp.WatchId]; ok {
626 if _, ok := cancelSet[pbresp.WatchId]; ok {
630 cancelSet[pbresp.WatchId] = struct{}{}
633 WatchId: pbresp.WatchId,
675 WatchId: ws.id,
728 if wr.IsProgressNotify() && pbresp.WatchId == -1 {
[all …]
/dports/devel/etcd/etcd-2.3.8/etcdserver/api/v3rpc/
H A Dwatch.go133 WatchId: int64(id),
139 id := uv.CancelRequest.WatchId
144 WatchId: id,
184 WatchId: int64(wresp.WatchID),
215 wid := storage.WatchID(c.WatchId)
/dports/security/vault/vault-1.8.2/vendor/go.etcd.io/etcd/etcdserver/api/v3rpc/
H A Dwatch.go250 WatchId: creq.WatchId,
271 …id, err := sws.watchStream.Watch(mvcc.WatchID(creq.WatchId), creq.Key, creq.RangeEnd, rev, filters…
287 WatchId: int64(id),
302 id := uv.CancelRequest.WatchId
307 WatchId: id,
321 …WatchId: -1, // response is not associated with any WatchId and will be broadcast to all watch cha…
384 WatchId: int64(wresp.WatchID),
443 wid := mvcc.WatchID(c.WatchId)
/dports/security/vault/vault-1.8.2/vendor/go.etcd.io/etcd/clientv3/
H A Dwatch.go442 if resp.WatchId == -1 || (resp.Canceled && resp.CancelReason != "") {
448 ws.id = resp.WatchId
563 } else if cur != nil && cur.WatchId == pbresp.WatchId {
589 delete(cancelSet, pbresp.WatchId)
590 if ws, ok := w.substreams[pbresp.WatchId]; ok {
616 if _, ok := cancelSet[pbresp.WatchId]; ok {
620 cancelSet[pbresp.WatchId] = struct{}{}
623 WatchId: pbresp.WatchId,
692 if wr.IsProgressNotify() && pbresp.WatchId == -1 {
696 return w.unicastResponse(wr, pbresp.WatchId)
/dports/sysutils/helmfile/vault-f6547fa8e820/vendor/go.etcd.io/etcd/clientv3/
H A Dwatch.go440 if resp.WatchId == -1 || (resp.Canceled && resp.CancelReason != "") {
446 ws.id = resp.WatchId
557 } else if cur != nil && cur.WatchId == pbresp.WatchId {
581 delete(cancelSet, pbresp.WatchId)
582 if ws, ok := w.substreams[pbresp.WatchId]; ok {
608 if _, ok := cancelSet[pbresp.WatchId]; ok {
612 cancelSet[pbresp.WatchId] = struct{}{}
615 WatchId: pbresp.WatchId,
680 if wr.IsProgressNotify() && pbresp.WatchId == -1 {
684 return w.unicastResponse(wr, pbresp.WatchId)
/dports/sysutils/istio/istio-1.6.7/vendor/github.com/coreos/etcd/clientv3/
H A Dwatch.go440 if resp.WatchId == -1 || (resp.Canceled && resp.CancelReason != "") {
446 ws.id = resp.WatchId
557 } else if cur != nil && cur.WatchId == pbresp.WatchId {
581 delete(cancelSet, pbresp.WatchId)
582 if ws, ok := w.substreams[pbresp.WatchId]; ok {
608 if _, ok := cancelSet[pbresp.WatchId]; ok {
612 cancelSet[pbresp.WatchId] = struct{}{}
615 WatchId: pbresp.WatchId,
680 if wr.IsProgressNotify() && pbresp.WatchId == -1 {
684 return w.unicastResponse(wr, pbresp.WatchId)
/dports/misc/concourse/vault-bdd38fca2cff/vendor/go.etcd.io/etcd/clientv3/
H A Dwatch.go439 if resp.WatchId == -1 || (resp.Canceled && resp.CancelReason != "") {
445 ws.id = resp.WatchId
556 } else if cur != nil && cur.WatchId == pbresp.WatchId {
580 delete(cancelSet, pbresp.WatchId)
581 if ws, ok := w.substreams[pbresp.WatchId]; ok {
607 if _, ok := cancelSet[pbresp.WatchId]; ok {
611 cancelSet[pbresp.WatchId] = struct{}{}
614 WatchId: pbresp.WatchId,
679 if wr.IsProgressNotify() && pbresp.WatchId == -1 {
683 return w.unicastResponse(wr, pbresp.WatchId)
/dports/sysutils/gomplate/gomplate-3.9.0/vendor/github.com/hashicorp/vault/vendor/go.etcd.io/etcd/clientv3/
H A Dwatch.go439 if resp.WatchId == -1 || (resp.Canceled && resp.CancelReason != "") {
445 ws.id = resp.WatchId
556 } else if cur != nil && cur.WatchId == pbresp.WatchId {
580 delete(cancelSet, pbresp.WatchId)
581 if ws, ok := w.substreams[pbresp.WatchId]; ok {
607 if _, ok := cancelSet[pbresp.WatchId]; ok {
611 cancelSet[pbresp.WatchId] = struct{}{}
614 WatchId: pbresp.WatchId,
679 if wr.IsProgressNotify() && pbresp.WatchId == -1 {
683 return w.unicastResponse(wr, pbresp.WatchId)
/dports/sysutils/helmfile/helmfile-0.138.7/vendor/github.com/hashicorp/vault/vendor/go.etcd.io/etcd/clientv3/
H A Dwatch.go439 if resp.WatchId == -1 || (resp.Canceled && resp.CancelReason != "") {
445 ws.id = resp.WatchId
556 } else if cur != nil && cur.WatchId == pbresp.WatchId {
580 delete(cancelSet, pbresp.WatchId)
581 if ws, ok := w.substreams[pbresp.WatchId]; ok {
607 if _, ok := cancelSet[pbresp.WatchId]; ok {
611 cancelSet[pbresp.WatchId] = struct{}{}
614 WatchId: pbresp.WatchId,
679 if wr.IsProgressNotify() && pbresp.WatchId == -1 {
683 return w.unicastResponse(wr, pbresp.WatchId)
/dports/devel/etcd33/etcd-3.3.23/vendor/github.com/coreos/etcd/clientv3/
H A Dwatch.go440 if resp.WatchId == -1 || (resp.Canceled && resp.CancelReason != "") {
446 ws.id = resp.WatchId
557 } else if cur != nil && cur.WatchId == pbresp.WatchId {
581 delete(cancelSet, pbresp.WatchId)
582 if ws, ok := w.substreams[pbresp.WatchId]; ok {
608 if _, ok := cancelSet[pbresp.WatchId]; ok {
612 cancelSet[pbresp.WatchId] = struct{}{}
615 WatchId: pbresp.WatchId,
680 if wr.IsProgressNotify() && pbresp.WatchId == -1 {
684 return w.unicastResponse(wr, pbresp.WatchId)

1234567