/dports/net/rabbitmq/rabbitmq-server-3.9.11/deps/rabbit/src/ |
H A D | rabbit_mirror_queue_sync.erl | 153 {'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 D | writer.go | 31 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 D | writer.go | 31 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 D | writer.go | 31 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 D | writer.go | 31 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 D | writer.go | 31 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 D | writer.go | 31 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 D | writer.go | 31 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 D | writer.go | 31 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 D | writer.go | 31 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 D | writer.go | 31 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 D | writer.go | 31 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 D | writer.go | 31 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 D | writer.go | 31 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 D | writer.go | 31 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 D | writer.go | 31 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 D | syncer.cc | 35 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 D | syncer.h | 34 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 D | sync.go | 21 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 D | Syncer.cc | 31 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 D | Resource.hh | 35 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 D | Drive.hh | 32 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 D | fsync.go | 59 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 D | sync.go | 394 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 D | syncer.go | 14 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
|