/dports/net/tigervnc-server/tigervnc-1.12.0/java/com/tigervnc/network/ |
H A D | SocketDescriptor.java | 39 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 D | SocketDescriptor.java | 39 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 D | collection.go | 81 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 D | database.go | 30 writeSelector description.ServerSelector member 66 db.writeSelector = description.CompositeSelector([]description.ServerSelector{ 204 db.writeSelector,
|
H A D | index_view.go | 147 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 D | database.go | 39 writeSelector description.ServerSelector member 80 db.writeSelector = description.CompositeSelector([]description.ServerSelector{ 127 writeSelector: db.writeSelector, 263 selector := makePinnedSelector(sess, db.writeSelector)
|
H A D | collection.go | 39 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 D | database.go | 39 writeSelector description.ServerSelector member 80 db.writeSelector = description.CompositeSelector([]description.ServerSelector{ 127 writeSelector: db.writeSelector, 263 selector := makePinnedSelector(sess, db.writeSelector)
|
H A D | collection.go | 39 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 D | database.go | 39 writeSelector description.ServerSelector member 80 db.writeSelector = description.CompositeSelector([]description.ServerSelector{ 127 writeSelector: db.writeSelector, 263 selector := makePinnedSelector(sess, db.writeSelector)
|
H A D | collection.go | 39 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 D | collection.go | 39 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 D | database.go | 40 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 D | collection.go | 39 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 D | database.go | 40 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 D | collection.go | 39 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 D | database.go | 40 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 D | collection.go | 39 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 D | database.go | 40 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 D | selector.h | 228 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 D | selector.h | 230 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 D | aggregate.go | 33 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 D | Server.java | 624 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 D | Server.java | 822 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 D | RpcServer.java | 900 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()
|