Home
last modified time | relevance | path

Searched refs:writeSelector (Results 1 – 25 of 63) sorted by relevance

123

/dports/net/tigervnc-server/tigervnc-1.12.0/java/com/tigervnc/network/
H A DSocketDescriptor.java39 writeSelector = Selector.open(); in SocketDescriptor()
45 channel.register(writeSelector, SelectionKey.OP_WRITE); in SocketDescriptor()
83 selector = writeSelector; in select()
164 if (writeSelector != null) in setChannel()
165 writeSelector.close(); in setChannel()
168 writeSelector = Selector.open(); in setChannel()
174 channel.register(writeSelector, SelectionKey.OP_WRITE); in setChannel()
182 protected Selector writeSelector; field in SocketDescriptor
/dports/net/tigervnc-viewer/tigervnc-1.12.0/java/com/tigervnc/network/
H A DSocketDescriptor.java39 writeSelector = Selector.open(); in SocketDescriptor()
45 channel.register(writeSelector, SelectionKey.OP_WRITE); in SocketDescriptor()
83 selector = writeSelector; in select()
164 if (writeSelector != null) in setChannel()
165 writeSelector.close(); in setChannel()
168 writeSelector = Selector.open(); in setChannel()
174 channel.register(writeSelector, SelectionKey.OP_WRITE); in setChannel()
182 protected Selector writeSelector; field in SocketDescriptor
/dports/net-mgmt/thanos/thanos-0.11.0/vendor/go.mongodb.org/mongo-driver/mongo/
H A Dcollection.go81 writeSelector: writeSelector,
97 writeSelector: coll.writeSelector,
180 coll.writeSelector,
245 coll.writeSelector,
312 coll.writeSelector,
391 coll.writeSelector,
443 coll.writeSelector,
490 coll.writeSelector,
603 coll.writeSelector,
718 coll.writeSelector,
[all …]
H A Ddatabase.go30 writeSelector description.ServerSelector member
66 db.writeSelector = description.CompositeSelector([]description.ServerSelector{
204 db.writeSelector,
H A Dindex_view.go147 iv.coll.writeSelector,
261 iv.coll.writeSelector,
287 iv.coll.writeSelector,
/dports/sysutils/helmfile/vault-f6547fa8e820/vendor/go.mongodb.org/mongo-driver/mongo/
H A Ddatabase.go39 writeSelector description.ServerSelector member
80 db.writeSelector = description.CompositeSelector([]description.ServerSelector{
127 writeSelector: db.writeSelector,
263 selector := makePinnedSelector(sess, db.writeSelector)
H A Dcollection.go39 writeSelector description.ServerSelector member
55 writeSelector description.ServerSelector member
107 writeSelector: writeSelector,
123 writeSelector: coll.writeSelector,
210 selector := makePinnedSelector(sess, coll.writeSelector)
276 selector := makePinnedSelector(sess, coll.writeSelector)
410 selector := makePinnedSelector(sess, coll.writeSelector)
536 selector := makePinnedSelector(sess, coll.writeSelector)
701 writeSelector: coll.writeSelector,
745 selector := makePinnedSelector(sess, a.writeSelector)
[all …]
/dports/net-mgmt/semaphore/semaphore-2.6.8/vendor/go.mongodb.org/mongo-driver/mongo/
H A Ddatabase.go39 writeSelector description.ServerSelector member
80 db.writeSelector = description.CompositeSelector([]description.ServerSelector{
127 writeSelector: db.writeSelector,
263 selector := makePinnedSelector(sess, db.writeSelector)
H A Dcollection.go39 writeSelector description.ServerSelector member
55 writeSelector description.ServerSelector member
107 writeSelector: writeSelector,
123 writeSelector: coll.writeSelector,
210 selector := makePinnedSelector(sess, coll.writeSelector)
276 selector := makePinnedSelector(sess, coll.writeSelector)
410 selector := makePinnedSelector(sess, coll.writeSelector)
536 selector := makePinnedSelector(sess, coll.writeSelector)
701 writeSelector: coll.writeSelector,
745 selector := makePinnedSelector(sess, a.writeSelector)
[all …]
/dports/databases/mongodb42-tools/mongo-tools-r4.2.17/vendor/go.mongodb.org/mongo-driver/mongo/
H A Ddatabase.go39 writeSelector description.ServerSelector member
80 db.writeSelector = description.CompositeSelector([]description.ServerSelector{
127 writeSelector: db.writeSelector,
263 selector := makePinnedSelector(sess, db.writeSelector)
H A Dcollection.go39 writeSelector description.ServerSelector member
55 writeSelector description.ServerSelector member
107 writeSelector: writeSelector,
123 writeSelector: coll.writeSelector,
210 selector := makePinnedSelector(sess, coll.writeSelector)
276 selector := makePinnedSelector(sess, coll.writeSelector)
410 selector := makePinnedSelector(sess, coll.writeSelector)
536 selector := makePinnedSelector(sess, coll.writeSelector)
701 writeSelector: coll.writeSelector,
745 selector := makePinnedSelector(sess, a.writeSelector)
[all …]
/dports/security/vault/vault-1.8.2/vendor/go.mongodb.org/mongo-driver/mongo/
H A Dcollection.go39 writeSelector description.ServerSelector member
55 writeSelector description.ServerSelector member
107 writeSelector: writeSelector,
123 writeSelector: coll.writeSelector,
210 selector := makePinnedSelector(sess, coll.writeSelector)
276 selector := makePinnedSelector(sess, coll.writeSelector)
428 selector := makePinnedSelector(sess, coll.writeSelector)
545 selector := makePinnedSelector(sess, coll.writeSelector)
712 writeSelector: coll.writeSelector,
756 selector := makePinnedSelector(sess, a.writeSelector)
[all …]
H A Ddatabase.go40 writeSelector description.ServerSelector member
81 db.writeSelector = description.CompositeSelector([]description.ServerSelector{
128 writeSelector: db.writeSelector,
269 selector := makePinnedSelector(sess, db.writeSelector)
562 selector := makePinnedSelector(sess, db.writeSelector)
/dports/security/vault/vault-1.8.2/vendor/github.com/hashicorp/vault-plugin-database-mongodbatlas/vendor/go.mongodb.org/mongo-driver/mongo/
H A Dcollection.go39 writeSelector description.ServerSelector member
55 writeSelector description.ServerSelector member
107 writeSelector: writeSelector,
123 writeSelector: coll.writeSelector,
210 selector := makePinnedSelector(sess, coll.writeSelector)
276 selector := makePinnedSelector(sess, coll.writeSelector)
430 selector := makePinnedSelector(sess, coll.writeSelector)
547 selector := makePinnedSelector(sess, coll.writeSelector)
714 writeSelector: coll.writeSelector,
758 selector := makePinnedSelector(sess, a.writeSelector)
[all …]
H A Ddatabase.go40 writeSelector description.ServerSelector member
81 db.writeSelector = description.CompositeSelector([]description.ServerSelector{
128 writeSelector: db.writeSelector,
269 selector := makePinnedSelector(sess, db.writeSelector)
562 selector := makePinnedSelector(sess, db.writeSelector)
/dports/www/grafana8/grafana-8.3.6/vendor/go.mongodb.org/mongo-driver/mongo/
H A Dcollection.go39 writeSelector description.ServerSelector member
55 writeSelector description.ServerSelector member
107 writeSelector: writeSelector,
123 writeSelector: coll.writeSelector,
210 selector := makePinnedSelector(sess, coll.writeSelector)
276 selector := makePinnedSelector(sess, coll.writeSelector)
428 selector := makePinnedSelector(sess, coll.writeSelector)
545 selector := makePinnedSelector(sess, coll.writeSelector)
733 writeSelector: coll.writeSelector,
777 selector := makePinnedSelector(sess, a.writeSelector)
[all …]
H A Ddatabase.go40 writeSelector description.ServerSelector member
81 db.writeSelector = description.CompositeSelector([]description.ServerSelector{
128 writeSelector: db.writeSelector,
269 selector := makePinnedSelector(sess, db.writeSelector)
604 selector := makePinnedSelector(sess, db.writeSelector)
/dports/net-mgmt/prometheus2/prometheus-2.30.3/vendor/go.mongodb.org/mongo-driver/mongo/
H A Dcollection.go39 writeSelector description.ServerSelector member
55 writeSelector description.ServerSelector member
107 writeSelector: writeSelector,
123 writeSelector: coll.writeSelector,
210 selector := makePinnedSelector(sess, coll.writeSelector)
276 selector := makePinnedSelector(sess, coll.writeSelector)
428 selector := makePinnedSelector(sess, coll.writeSelector)
545 selector := makePinnedSelector(sess, coll.writeSelector)
733 writeSelector: coll.writeSelector,
777 selector := makePinnedSelector(sess, a.writeSelector)
[all …]
H A Ddatabase.go40 writeSelector description.ServerSelector member
81 db.writeSelector = description.CompositeSelector([]description.ServerSelector{
128 writeSelector: db.writeSelector,
269 selector := makePinnedSelector(sess, db.writeSelector)
601 selector := makePinnedSelector(sess, db.writeSelector)
/dports/games/libretro-scummvm/scummvm-7b1e929/engines/sci/engine/
H A Dselector.h228 void writeSelector(SegManager *segMan, reg_t object, Selector selectorId, reg_t value);
229 #define writeSelectorValue(segMan, _obj_, _slc_, _val_) writeSelector(segMan, _obj_, _slc_, make_re…
/dports/games/scummvm/scummvm-2.5.1/engines/sci/engine/
H A Dselector.h230 void writeSelector(SegManager *segMan, reg_t object, Selector selectorId, reg_t value);
231 #define writeSelectorValue(segMan, _obj_, _slc_, _val_) writeSelector(segMan, _obj_, _slc_, make_re…
/dports/net-mgmt/thanos/thanos-0.11.0/vendor/go.mongodb.org/mongo-driver/x/mongo/driver/
H A Daggregate.go33 readSelector, writeSelector description.ServerSelector,
46 ss, err = topo.SelectServer(ctx, writeSelector)
/dports/devel/hadoop/hadoop-1.2.1/src/core/org/apache/hadoop/ipc/
H A DServer.java624 private Selector writeSelector; field in Server.Responder
632 writeSelector = Selector.open(); // create a selector in Responder()
645 writeSelector.select(PURGE_INTERVAL); in run()
646 Iterator<SelectionKey> iter = writeSelector.selectedKeys().iterator(); in run()
671 synchronized (writeSelector.keys()) { in run()
672 calls = new ArrayList<Call>(writeSelector.keys().size()); in run()
673 iter = writeSelector.keys().iterator(); in run()
810 writeSelector.wakeup(); in processResponse()
811 channel.register(writeSelector, SelectionKey.OP_WRITE, call); in processResponse()
/dports/devel/hadoop2/hadoop-2.7.2-src/hadoop-common-project/hadoop-common/src/main/java/org/apache/hadoop/ipc/
H A DServer.java822 private final Selector writeSelector; field in Server.Responder
830 writeSelector = Selector.open(); // create a selector in Responder()
843 writeSelector.close(); in run()
856 writeSelector.select(PURGE_INTERVAL); in doRunLoop()
857 Iterator<SelectionKey> iter = writeSelector.selectedKeys().iterator(); in doRunLoop()
884 synchronized (writeSelector.keys()) { in doRunLoop()
885 calls = new ArrayList<Call>(writeSelector.keys().size()); in doRunLoop()
886 iter = writeSelector.keys().iterator(); in doRunLoop()
1018 writeSelector.wakeup(); in processResponse()
1019 channel.register(writeSelector, SelectionKey.OP_WRITE, call); in processResponse()
/dports/databases/hbase/hbase-1.2.1/hbase-server/src/main/java/org/apache/hadoop/hbase/ipc/
H A DRpcServer.java900 private final Selector writeSelector; field in RpcServer.Responder
907 writeSelector = Selector.open(); // create a selector in Responder()
918 writeSelector.close(); in run()
934 SelectionKey sk = c.channel.keyFor(writeSelector); in registerWrites()
938 c.channel.register(writeSelector, SelectionKey.OP_WRITE, c); in registerWrites()
958 writeSelector.wakeup(); in registerForWrite()
967 int keyCt = writeSelector.select(purgeTimeout); in doRunLoop()
972 Set<SelectionKey> keys = writeSelector.selectedKeys(); in doRunLoop()
1029 synchronized (writeSelector.keys()) { in purge()
1030 for (SelectionKey key : writeSelector.keys()) { in purge()

123