/dports/devel/hadoop2/jetty-6.1.14/contrib/grizzly/src/main/java/org/mortbay/jetty/grizzly/ |
H A D | GrizzlySocketChannel.java | 54 Selector readSelector=null; in read() local 69 readSelector=SelectorFactory.getSelector(); in read() 71 if (readSelector==null) in read() 76 tmpKey=socketChannel.register(readSelector,SelectionKey.OP_READ); in read() 78 int code=readSelector.select(readTimeout); in read() 93 if (readSelector!=null) in read() 98 readSelector.selectNow(); in read() 104 SelectorFactory.returnSelector(readSelector); in read()
|
/dports/devel/hadoop/jetty-6.1.14/contrib/grizzly/src/main/java/org/mortbay/jetty/grizzly/ |
H A D | GrizzlySocketChannel.java | 54 Selector readSelector=null; in read() local 69 readSelector=SelectorFactory.getSelector(); in read() 71 if (readSelector==null) in read() 76 tmpKey=socketChannel.register(readSelector,SelectionKey.OP_READ); in read() 78 int code=readSelector.select(readTimeout); in read() 93 if (readSelector!=null) in read() 98 readSelector.selectNow(); in read() 104 SelectorFactory.returnSelector(readSelector); in read()
|
/dports/net/tigervnc-server/tigervnc-1.12.0/java/com/tigervnc/network/ |
H A D | SocketDescriptor.java | 40 readSelector = Selector.open(); in SocketDescriptor() 46 channel.register(readSelector, SelectionKey.OP_READ); in SocketDescriptor() 81 selector = readSelector; in select() 162 if (readSelector != null) in setChannel() 163 readSelector.close(); in setChannel() 169 readSelector = Selector.open(); in setChannel() 175 channel.register(readSelector, SelectionKey.OP_READ); in setChannel() 183 protected Selector readSelector; field in SocketDescriptor
|
/dports/net/tigervnc-viewer/tigervnc-1.12.0/java/com/tigervnc/network/ |
H A D | SocketDescriptor.java | 40 readSelector = Selector.open(); in SocketDescriptor() 46 channel.register(readSelector, SelectionKey.OP_READ); in SocketDescriptor() 81 selector = readSelector; in select() 162 if (readSelector != null) in setChannel() 163 readSelector.close(); in setChannel() 169 readSelector = Selector.open(); in setChannel() 175 channel.register(readSelector, SelectionKey.OP_READ); in setChannel() 183 protected Selector readSelector; field in SocketDescriptor
|
/dports/net-mgmt/thanos/thanos-0.11.0/vendor/go.mongodb.org/mongo-driver/mongo/ |
H A D | database.go | 29 readSelector description.ServerSelector member 61 db.readSelector = description.CompositeSelector([]description.ServerSelector{ 240 readSelector := description.CompositeSelector([]description.ServerSelector{ 247 readSelector,
|
H A D | collection.go | 35 readSelector description.ServerSelector member 63 readSelector := description.CompositeSelector([]description.ServerSelector{ 80 readSelector: readSelector, 96 readSelector: coll.readSelector, 123 copyColl.readSelector = description.CompositeSelector([]description.ServerSelector{ 717 coll.readSelector, 775 coll.readSelector, 823 coll.readSelector, 873 coll.readSelector, 923 coll.readSelector, [all …]
|
/dports/games/libretro-scummvm/scummvm-7b1e929/engines/sci/engine/ |
H A D | kmovement.cpp | 169 reg_t client = readSelector(segMan, mover, SELECTOR(client)); in kInitBresen() 260 reg_t client = readSelector(segMan, mover, SELECTOR(client)); in kDoBresen() 415 reg_t client = readSelector(segMan, avoider, SELECTOR(client)); in kDoAvoider() 416 reg_t mover = readSelector(segMan, client, SELECTOR(mover)); in kDoAvoider() 424 mover = readSelector(segMan, client, SELECTOR(mover)); in kDoAvoider() 445 reg_t clientLooper = readSelector(segMan, client, SELECTOR(looper)); in kDoAvoider()
|
H A D | guest_additions.cpp | 587 reg_t outDescription = readSelector(_segMan, editor, SELECTOR(text)); in promptSaveRestoreRama() 698 outDescription = readSelector(_segMan, outDescription, SELECTOR(data)); in runSaveRestore() 1147 List *sounds = _segMan->lookupList(readSelector(_segMan, soundsId, SELECTOR(elements))); in restoreFromLauncher() 1182 List *sounds = _segMan->lookupList(readSelector(_segMan, soundsId, SELECTOR(elements))); in restoreFromLauncher() 1234 List *sounds = _segMan->lookupList(readSelector(_segMan, soundsId, SELECTOR(elements))); in restoreFromLauncher() 1432 const reg_t planeId = readSelector(_segMan, sliderId, SELECTOR(plane)); in restoreFromLauncher() 1489 if (readSelector(_segMan, scrollBars[i], SELECTOR(client)) == masterVolumeScript) { in restoreFromLauncher() 1495 if (!readSelector(_segMan, scrollBars[i], SELECTOR(physicalBar)).isNull()) { in restoreFromLauncher() 1514 const reg_t planeId = readSelector(_segMan, sliderId, SELECTOR(plane)); in restoreFromLauncher() 1548 const reg_t planeId = readSelector(_segMan, sliderId, SELECTOR(plane)); in restoreFromLauncher() [all …]
|
H A D | selector.h | 216 reg_t readSelector(SegManager *segMan, reg_t object, Selector selectorId); 217 #define readSelectorValue(segMan, _obj_, _slc_) (readSelector(segMan, _obj_, _slc_).getOffset())
|
H A D | klists.cpp | 482 reg_t input_data = readSelector(segMan, source, SELECTOR(elements)); in kSort() 483 reg_t output_data = readSelector(segMan, dest, SELECTOR(elements)); in kSort() 669 if (!readSelector(s->_segMan, curObject, slc).isNull()) { in kListFirstTrue() 728 s->r_acc = readSelector(s->_segMan, curObject, slc); in kListAllTrue() 765 a = readSelector(s->_segMan, s->_segMan->lookupNode(node)->value, selector); in kListSort() 774 b = readSelector(s->_segMan, s->_segMan->lookupNode(newNode)->value, selector); in kListSort() 905 return readSelector(s->_segMan, argv[0], SELECTOR(data)); in kArrayGetData()
|
/dports/games/scummvm/scummvm-2.5.1/engines/sci/engine/ |
H A D | kmovement.cpp | 169 reg_t client = readSelector(segMan, mover, SELECTOR(client)); in kInitBresen() 260 reg_t client = readSelector(segMan, mover, SELECTOR(client)); in kDoBresen() 419 reg_t client = readSelector(segMan, avoider, SELECTOR(client)); in kDoAvoider() 420 reg_t mover = readSelector(segMan, client, SELECTOR(mover)); in kDoAvoider() 428 mover = readSelector(segMan, client, SELECTOR(mover)); in kDoAvoider() 449 reg_t clientLooper = readSelector(segMan, client, SELECTOR(looper)); in kDoAvoider()
|
H A D | guest_additions.cpp | 572 reg_t outDescription = readSelector(_segMan, editor, SELECTOR(text)); in promptSaveRestoreRama() 661 outDescription = readSelector(_segMan, outDescription, SELECTOR(data)); in runSaveRestore() 1190 List *sounds = _segMan->lookupList(readSelector(_segMan, soundsId, SELECTOR(elements))); in restoreFromLauncher() 1225 List *sounds = _segMan->lookupList(readSelector(_segMan, soundsId, SELECTOR(elements))); in restoreFromLauncher() 1272 List *sounds = _segMan->lookupList(readSelector(_segMan, soundsId, SELECTOR(elements))); in restoreFromLauncher() 1477 const reg_t planeId = readSelector(_segMan, sliderId, SELECTOR(plane)); in restoreFromLauncher() 1545 if (readSelector(_segMan, scrollBars[i], SELECTOR(client)) == masterVolumeScript) { in restoreFromLauncher() 1551 if (!readSelector(_segMan, scrollBars[i], SELECTOR(physicalBar)).isNull()) { in restoreFromLauncher() 1570 const reg_t planeId = readSelector(_segMan, sliderId, SELECTOR(plane)); in restoreFromLauncher() 1604 const reg_t planeId = readSelector(_segMan, sliderId, SELECTOR(plane)); in restoreFromLauncher() [all …]
|
H A D | selector.h | 218 reg_t readSelector(SegManager *segMan, reg_t object, Selector selectorId); 219 #define readSelectorValue(segMan, _obj_, _slc_) (readSelector(segMan, _obj_, _slc_).getOffset())
|
H A D | klists.cpp | 482 reg_t input_data = readSelector(segMan, source, SELECTOR(elements)); in kSort() 483 reg_t output_data = readSelector(segMan, dest, SELECTOR(elements)); in kSort() 669 if (!readSelector(s->_segMan, curObject, slc).isNull()) { in kListFirstTrue() 728 s->r_acc = readSelector(s->_segMan, curObject, slc); in kListAllTrue() 765 a = readSelector(s->_segMan, s->_segMan->lookupNode(node)->value, selector); in kListSort() 774 b = readSelector(s->_segMan, s->_segMan->lookupNode(newNode)->value, selector); in kListSort() 905 return readSelector(s->_segMan, argv[0], SELECTOR(data)); in kArrayGetData()
|
/dports/security/vault/vault-1.8.2/vendor/go.mongodb.org/mongo-driver/mongo/ |
H A D | collection.go | 38 readSelector description.ServerSelector member 54 readSelector description.ServerSelector member 89 readSelector := description.CompositeSelector([]description.ServerSelector{ 106 readSelector: readSelector, 122 readSelector: coll.readSelector, 151 copyColl.readSelector = description.CompositeSelector([]description.ServerSelector{ 711 readSelector: coll.readSelector, 758 selector = makeReadPrefSelector(sess, a.readSelector, a.client.localThreshold) 880 selector := makeReadPrefSelector(sess, coll.readSelector, coll.client.localThreshold) 961 selector := makeReadPrefSelector(sess, coll.readSelector, coll.client.localThreshold) [all …]
|
/dports/sysutils/helmfile/vault-f6547fa8e820/vendor/go.mongodb.org/mongo-driver/mongo/ |
H A D | collection.go | 38 readSelector description.ServerSelector member 54 readSelector description.ServerSelector member 89 readSelector := description.CompositeSelector([]description.ServerSelector{ 106 readSelector: readSelector, 122 readSelector: coll.readSelector, 151 copyColl.readSelector = description.CompositeSelector([]description.ServerSelector{ 700 readSelector: coll.readSelector, 747 selector = makeReadPrefSelector(sess, a.readSelector, a.client.localThreshold) 853 selector := makeReadPrefSelector(sess, coll.readSelector, coll.client.localThreshold) 934 selector := makeReadPrefSelector(sess, coll.readSelector, coll.client.localThreshold) [all …]
|
H A D | database.go | 38 readSelector description.ServerSelector member 75 db.readSelector = description.CompositeSelector([]description.ServerSelector{ 126 readSelector: db.readSelector,
|
/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 | 38 readSelector description.ServerSelector member 54 readSelector description.ServerSelector member 89 readSelector := description.CompositeSelector([]description.ServerSelector{ 106 readSelector: readSelector, 122 readSelector: coll.readSelector, 151 copyColl.readSelector = description.CompositeSelector([]description.ServerSelector{ 713 readSelector: coll.readSelector, 760 selector = makeReadPrefSelector(sess, a.readSelector, a.client.localThreshold) 882 selector := makeReadPrefSelector(sess, coll.readSelector, coll.client.localThreshold) 963 selector := makeReadPrefSelector(sess, coll.readSelector, coll.client.localThreshold) [all …]
|
/dports/net-mgmt/semaphore/semaphore-2.6.8/vendor/go.mongodb.org/mongo-driver/mongo/ |
H A D | collection.go | 38 readSelector description.ServerSelector member 54 readSelector description.ServerSelector member 89 readSelector := description.CompositeSelector([]description.ServerSelector{ 106 readSelector: readSelector, 122 readSelector: coll.readSelector, 151 copyColl.readSelector = description.CompositeSelector([]description.ServerSelector{ 700 readSelector: coll.readSelector, 747 selector = makeReadPrefSelector(sess, a.readSelector, a.client.localThreshold) 853 selector := makeReadPrefSelector(sess, coll.readSelector, coll.client.localThreshold) 934 selector := makeReadPrefSelector(sess, coll.readSelector, coll.client.localThreshold) [all …]
|
H A D | database.go | 38 readSelector description.ServerSelector member 75 db.readSelector = description.CompositeSelector([]description.ServerSelector{ 126 readSelector: db.readSelector,
|
/dports/www/grafana8/grafana-8.3.6/vendor/go.mongodb.org/mongo-driver/mongo/ |
H A D | collection.go | 38 readSelector description.ServerSelector member 54 readSelector description.ServerSelector member 89 readSelector := description.CompositeSelector([]description.ServerSelector{ 106 readSelector: readSelector, 122 readSelector: coll.readSelector, 151 copyColl.readSelector = description.CompositeSelector([]description.ServerSelector{ 732 readSelector: coll.readSelector, 779 selector = makeReadPrefSelector(sess, a.readSelector, a.client.localThreshold) 898 selector := makeReadPrefSelector(sess, coll.readSelector, coll.client.localThreshold) 979 selector := makeReadPrefSelector(sess, coll.readSelector, coll.client.localThreshold) [all …]
|
/dports/net-mgmt/prometheus2/prometheus-2.30.3/vendor/go.mongodb.org/mongo-driver/mongo/ |
H A D | collection.go | 38 readSelector description.ServerSelector member 54 readSelector description.ServerSelector member 89 readSelector := description.CompositeSelector([]description.ServerSelector{ 106 readSelector: readSelector, 122 readSelector: coll.readSelector, 151 copyColl.readSelector = description.CompositeSelector([]description.ServerSelector{ 732 readSelector: coll.readSelector, 779 selector = makeReadPrefSelector(sess, a.readSelector, a.client.localThreshold) 901 selector := makeReadPrefSelector(sess, coll.readSelector, coll.client.localThreshold) 982 selector := makeReadPrefSelector(sess, coll.readSelector, coll.client.localThreshold) [all …]
|
/dports/databases/mongodb42-tools/mongo-tools-r4.2.17/vendor/go.mongodb.org/mongo-driver/mongo/ |
H A D | collection.go | 38 readSelector description.ServerSelector member 54 readSelector description.ServerSelector member 89 readSelector := description.CompositeSelector([]description.ServerSelector{ 106 readSelector: readSelector, 122 readSelector: coll.readSelector, 151 copyColl.readSelector = description.CompositeSelector([]description.ServerSelector{ 700 readSelector: coll.readSelector, 747 selector = makeReadPrefSelector(sess, a.readSelector, a.client.localThreshold) 853 selector := makeReadPrefSelector(sess, coll.readSelector, coll.client.localThreshold) 934 selector := makeReadPrefSelector(sess, coll.readSelector, coll.client.localThreshold) [all …]
|
H A D | database.go | 38 readSelector description.ServerSelector member 75 db.readSelector = description.CompositeSelector([]description.ServerSelector{ 126 readSelector: db.readSelector,
|
/dports/devel/hadoop/hadoop-1.2.1/src/core/org/apache/hadoop/ipc/ |
H A D | Server.java | 348 Selector readSelector = Selector.open(); in Listener() local 349 Reader reader = new Reader(readSelector); in Listener() 362 private Selector readSelector = null; field in Server.Listener.Reader 364 Reader(Selector readSelector) { in Reader() argument 365 this.readSelector = readSelector; in Reader() 373 readSelector.select(); in run() 378 Iterator<SelectionKey> iter = readSelector.selectedKeys().iterator(); in run() 410 readSelector.wakeup(); in startAdd() 415 return channel.register(readSelector, SelectionKey.OP_READ); in registerChannel()
|