Home
last modified time | relevance | path

Searched refs:Syncer (Results 1 – 25 of 232) sorted by relevance

12345678910

/dports/net/rabbitmq/rabbitmq-server-3.9.11/deps/rabbit/src/
H A Drabbit_mirror_queue_sync.erl153 {'EXIT', Syncer, Reason} ->
157 stop_syncer(Syncer, Msg) ->
158 unlink(Syncer),
159 Syncer ! Msg,
160 receive {'EXIT', Syncer, _} -> ok
322 Syncer ! {sync_deny, Ref, self()},
326 MRef = erlang:monitor(process, Syncer),
327 Syncer ! {sync_ready, Ref, self()},
343 credit_flow:peer_down(Syncer),
350 credit_flow:peer_down(Syncer),
[all …]
/dports/net-mgmt/carbonzipper/carbonzipper-0.74/vendor/go.uber.org/zap/zaptest/
H A Dwriter.go31 type Syncer struct { struct
37 func (s *Syncer) SetError(err error) { argument
43 func (s *Syncer) Sync() error { argument
49 func (s *Syncer) Called() bool { argument
54 type Discarder struct{ Syncer } member
62 type FailWriter struct{ Syncer } member
71 type ShortWriter struct{ Syncer } member
83 Syncer anonMember
/dports/net/rclone/rclone-1.57.0/vendor/go.uber.org/zap/internal/ztest/
H A Dwriter.go31 type Syncer struct { struct
37 func (s *Syncer) SetError(err error) { argument
43 func (s *Syncer) Sync() error { argument
49 func (s *Syncer) Called() bool { argument
54 type Discarder struct{ Syncer } member
62 type FailWriter struct{ Syncer } member
71 type ShortWriter struct{ Syncer } member
83 Syncer anonMember
/dports/security/vault/vault-1.8.2/vendor/go.uber.org/zap/internal/ztest/
H A Dwriter.go31 type Syncer struct { struct
37 func (s *Syncer) SetError(err error) { argument
43 func (s *Syncer) Sync() error { argument
49 func (s *Syncer) Called() bool { argument
54 type Discarder struct{ Syncer } member
62 type FailWriter struct{ Syncer } member
71 type ShortWriter struct{ Syncer } member
83 Syncer anonMember
/dports/devel/app-builder/app-builder-3.4.2/vendor/go.uber.org/zap/internal/ztest/
H A Dwriter.go31 type Syncer struct { struct
37 func (s *Syncer) SetError(err error) { argument
43 func (s *Syncer) Sync() error { argument
49 func (s *Syncer) Called() bool { argument
54 type Discarder struct{ Syncer } member
62 type FailWriter struct{ Syncer } member
71 type ShortWriter struct{ Syncer } member
83 Syncer anonMember
/dports/net-im/dendrite/dendrite-0.5.1/vendor/go.uber.org/zap/internal/ztest/
H A Dwriter.go31 type Syncer struct { struct
37 func (s *Syncer) SetError(err error) { argument
43 func (s *Syncer) Sync() error { argument
49 func (s *Syncer) Called() bool { argument
54 type Discarder struct{ Syncer } member
62 type FailWriter struct{ Syncer } member
71 type ShortWriter struct{ Syncer } member
83 Syncer anonMember
/dports/databases/cayley/cayley-0.7.5-2-gcf576ba/vendor/go.uber.org/zap/internal/ztest/
H A Dwriter.go31 type Syncer struct { struct
37 func (s *Syncer) SetError(err error) { argument
43 func (s *Syncer) Sync() error { argument
49 func (s *Syncer) Called() bool { argument
54 type Discarder struct{ Syncer } member
62 type FailWriter struct{ Syncer } member
71 type ShortWriter struct{ Syncer } member
83 Syncer anonMember
/dports/security/vuls/vuls-0.13.7/vendor/go.uber.org/zap/internal/ztest/
H A Dwriter.go31 type Syncer struct { struct
37 func (s *Syncer) SetError(err error) { argument
43 func (s *Syncer) Sync() error { argument
49 func (s *Syncer) Called() bool { argument
54 type Discarder struct{ Syncer } member
62 type FailWriter struct{ Syncer } member
71 type ShortWriter struct{ Syncer } member
83 Syncer anonMember
/dports/net-im/nextcloud-spreed-signaling/nextcloud-spreed-signaling-0.2.0/vendor/src/go.uber.org/zap/internal/ztest/
H A Dwriter.go31 type Syncer struct { struct
37 func (s *Syncer) SetError(err error) { argument
43 func (s *Syncer) Sync() error { argument
49 func (s *Syncer) Called() bool { argument
54 type Discarder struct{ Syncer } member
62 type FailWriter struct{ Syncer } member
71 type ShortWriter struct{ Syncer } member
83 Syncer anonMember
/dports/sysutils/helmfile/helmfile-0.138.7/vendor/go.uber.org/zap/internal/ztest/
H A Dwriter.go31 type Syncer struct { struct
37 func (s *Syncer) SetError(err error) { argument
43 func (s *Syncer) Sync() error { argument
49 func (s *Syncer) Called() bool { argument
54 type Discarder struct{ Syncer } member
62 type FailWriter struct{ Syncer } member
71 type ShortWriter struct{ Syncer } member
83 Syncer anonMember
/dports/sysutils/kubectl/kubernetes-1.22.2/vendor/go.uber.org/zap/internal/ztest/
H A Dwriter.go31 type Syncer struct { struct
37 func (s *Syncer) SetError(err error) { argument
43 func (s *Syncer) Sync() error { argument
49 func (s *Syncer) Called() bool { argument
54 type Discarder struct{ Syncer } member
62 type FailWriter struct{ Syncer } member
71 type ShortWriter struct{ Syncer } member
83 Syncer anonMember
/dports/www/minio-client/mc-RELEASE.2021-12-10T00-14-28Z/vendor/go.uber.org/zap/internal/ztest/
H A Dwriter.go31 type Syncer struct { struct
37 func (s *Syncer) SetError(err error) { argument
43 func (s *Syncer) Sync() error { argument
49 func (s *Syncer) Called() bool { argument
54 type Discarder struct{ Syncer } member
62 type FailWriter struct{ Syncer } member
71 type ShortWriter struct{ Syncer } member
83 Syncer anonMember
/dports/devel/etcd33/etcd-3.3.23/vendor/go.uber.org/zap/zap-1.10.0/internal/ztest/
H A Dwriter.go31 type Syncer struct { struct
37 func (s *Syncer) SetError(err error) { argument
43 func (s *Syncer) Sync() error { argument
49 func (s *Syncer) Called() bool { argument
54 type Discarder struct{ Syncer } member
62 type FailWriter struct{ Syncer } member
71 type ShortWriter struct{ Syncer } member
83 Syncer anonMember
/dports/net/storj/storj-1.45.3/vendor/go.uber.org/zap/internal/ztest/
H A Dwriter.go31 type Syncer struct { struct
37 func (s *Syncer) SetError(err error) { argument
43 func (s *Syncer) Sync() error { argument
49 func (s *Syncer) Called() bool { argument
54 type Discarder struct{ Syncer } member
62 type FailWriter struct{ Syncer } member
71 type ShortWriter struct{ Syncer } member
83 Syncer anonMember
/dports/sysutils/istio/istio-1.6.7/vendor/go.uber.org/zap/internal/ztest/
H A Dwriter.go31 type Syncer struct { struct
37 func (s *Syncer) SetError(err error) { argument
43 func (s *Syncer) Sync() error { argument
49 func (s *Syncer) Called() bool { argument
54 type Discarder struct{ Syncer } member
62 type FailWriter struct{ Syncer } member
71 type ShortWriter struct{ Syncer } member
83 Syncer anonMember
/dports/sysutils/terraform/terraform-1.0.11/vendor/go.uber.org/zap/internal/ztest/
H A Dwriter.go31 type Syncer struct { struct
37 func (s *Syncer) SetError(err error) { argument
43 func (s *Syncer) Sync() error { argument
49 func (s *Syncer) Called() bool { argument
54 type Discarder struct{ Syncer } member
62 type FailWriter struct{ Syncer } member
71 type ShortWriter struct{ Syncer } member
83 Syncer anonMember
/dports/www/chromium-legacy/chromium-88.0.4324.182/components/sync/engine_impl/
H A Dsyncer.cc35 Syncer::Syncer(CancelationSignal* cancelation_signal) in Syncer() function in syncer::Syncer
38 Syncer::~Syncer() {} in ~Syncer()
40 bool Syncer::IsSyncing() const { in IsSyncing()
44 bool Syncer::NormalSyncShare(ModelTypeSet request_types, in NormalSyncShare()
64 bool Syncer::ConfigureSyncShare(const ModelTypeSet& request_types, in ConfigureSyncShare()
84 bool Syncer::PollSyncShare(ModelTypeSet request_types, SyncCycle* cycle) { in PollSyncShare()
92 bool Syncer::DownloadAndApplyUpdates(ModelTypeSet* request_types, in DownloadAndApplyUpdates()
136 SyncerError Syncer::BuildAndPostCommits(const ModelTypeSet& request_types, in BuildAndPostCommits()
176 bool Syncer::ExitRequested() { in ExitRequested()
180 bool Syncer::HandleCycleEnd(SyncCycle* cycle, in HandleCycleEnd()
H A Dsyncer.h34 class Syncer {
36 explicit Syncer(CancelationSignal* cancelation_signal);
37 virtual ~Syncer();
95 DISALLOW_COPY_AND_ASSIGN(Syncer);
/dports/security/keybase/client-v5.7.1/go/chat/
H A Dsync.go21 type Syncer struct { struct
43 func NewSyncer(g *globals.Context) *Syncer {
44 s := &Syncer{
62 func (s *Syncer) SetClock(clock clockwork.Clock) { argument
66 func (s *Syncer) Shutdown() { argument
91 func (s *Syncer) sendNotificationsOnce() { argument
116 func (s *Syncer) sendNotificationLoop() { argument
167 func (s *Syncer) IsConnected(ctx context.Context) bool { argument
189 func (s *Syncer) Disconnected(ctx context.Context) { argument
231 func (s *Syncer) maxSyncUnboxConvs() int { argument
[all …]
/dports/net/grive2/grive2-ffb744a/libgrive/src/base/
H A DSyncer.cc31 Syncer::Syncer( http::Agent *http ): in Syncer() function in gr::Syncer
36 http::Agent* Syncer::Agent() const in Agent()
41 void Syncer::Download( Resource *res, const fs::path& file ) in Download()
54 void Syncer::AssignIDs( Resource *res, const Entry& remote ) in AssignIDs()
H A DResource.hh35 class Syncer ;
120 void Sync( Syncer* syncer, ResourceTree *res_tree, const Val& options ) ;
135 friend class Syncer ;
147 bool CheckRename( Syncer* syncer, ResourceTree *res_tree ) ;
148 void SyncSelf( Syncer* syncer, ResourceTree *res_tree, const Val& options ) ;
H A DDrive.hh32 class Syncer ;
41 Drive( Syncer *syncer, const Val& options ) ;
57 Syncer *m_syncer ;
/dports/www/gohugo/hugo-0.91.2/vendor/github.com/spf13/fsync/
H A Dfsync.go59 type Syncer struct { struct
82 func NewSyncer() *Syncer {
83 s := Syncer{SrcFs: new(afero.OsFs), DestFs: new(afero.OsFs)}
91 func (s *Syncer) Sync(dst, src string) error { argument
107 func (s *Syncer) SyncTo(to string, srcs ...string) error { argument
118 func (s *Syncer) syncRecover(dst, src string) (err error) { argument
133 func (s *Syncer) sync(dst, src string) { argument
214 func (s *Syncer) syncstats(dst, src string) { argument
245 func (s *Syncer) equal(dst, src string) bool { argument
295 func (s *Syncer) checkDir(dst, src string) (b bool, err error) { argument
/dports/net-p2p/go-ethereum/go-ethereum-1.10.14/eth/protocols/snap/
H A Dsync.go394 type Syncer struct {
456 func NewSyncer(db ethdb.KeyValueStore) *Syncer {
457 return &Syncer{
484 func (s *Syncer) Register(peer SyncPeer) error {
512 func (s *Syncer) Unregister(id string) error {
676 func (s *Syncer) loadSyncStatus() {
766 func (s *Syncer) saveSyncStatus() {
828 func (s *Syncer) cleanAccountTasks() {
853 func (s *Syncer) cleanStorageTasks() {
1482 func (s *Syncer) revertRequests(peer string) {
[all …]
/dports/security/keybase/client-v5.7.1/go/libkb/
H A Dsyncer.go14 type Syncer interface { interface
23 func RunSyncer(m MetaContext, s Syncer, uid keybase1.UID, loggedIn bool, forceReload bool) (err err… argument
57 func RunSyncerCached(m MetaContext, s Syncer, uid keybase1.UID) (err error) { argument

12345678910