Home
last modified time | relevance | path

Searched refs:readSelector (Results 1 – 25 of 101) sorted by relevance

12345

/dports/devel/hadoop2/jetty-6.1.14/contrib/grizzly/src/main/java/org/mortbay/jetty/grizzly/
H A DGrizzlySocketChannel.java54 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 DGrizzlySocketChannel.java54 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 DSocketDescriptor.java40 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 DSocketDescriptor.java40 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 Ddatabase.go29 readSelector description.ServerSelector member
61 db.readSelector = description.CompositeSelector([]description.ServerSelector{
240 readSelector := description.CompositeSelector([]description.ServerSelector{
247 readSelector,
H A Dcollection.go35 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 Dkmovement.cpp169 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 Dguest_additions.cpp587 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 Dselector.h216 reg_t readSelector(SegManager *segMan, reg_t object, Selector selectorId);
217 #define readSelectorValue(segMan, _obj_, _slc_) (readSelector(segMan, _obj_, _slc_).getOffset())
H A Dklists.cpp482 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 Dkmovement.cpp169 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 Dguest_additions.cpp572 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 Dselector.h218 reg_t readSelector(SegManager *segMan, reg_t object, Selector selectorId);
219 #define readSelectorValue(segMan, _obj_, _slc_) (readSelector(segMan, _obj_, _slc_).getOffset())
H A Dklists.cpp482 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 Dcollection.go38 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 Dcollection.go38 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 Ddatabase.go38 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 Dcollection.go38 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 Dcollection.go38 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 Ddatabase.go38 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 Dcollection.go38 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 Dcollection.go38 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 Dcollection.go38 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 Ddatabase.go38 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 DServer.java348 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()

12345