/dports/devel/py-trollius/trollius-2.2/trollius/ |
H A D | queues.py | 49 self._getters = collections.deque() 86 if self._getters: 96 while self._getters and self._getters[0].done(): 97 self._getters.popleft() 138 if self._getters: 142 getter = self._getters.popleft() 164 if self._getters: 168 getter = self._getters.popleft() 204 self._getters.append(waiter) 227 if self._getters: [all …]
|
/dports/devel/py-asyncio/asyncio-3.4.3/asyncio/ |
H A D | queues.py | 49 self._getters = collections.deque() 74 if self._getters: 75 result += ' _getters[{}]'.format(len(self._getters)) 82 while self._getters and self._getters[0].done(): 83 self._getters.popleft() 124 if self._getters: 128 getter = self._getters.popleft() 152 if self._getters: 156 getter = self._getters.popleft() 197 self._getters.append(waiter)
|
/dports/www/py-tornado4/tornado-4.5.3/tornado/ |
H A D | queues.py | 142 self._getters = collections.deque([]) # Futures. 188 if self._getters: 190 getter = self._getters.popleft() 208 self._getters.append(future) 281 while self._getters and self._getters[0].done(): 282 self._getters.popleft() 295 if self._getters: 296 result += ' getters[%s]' % len(self._getters)
|
/dports/www/py-tornado5/tornado-5.1.1/tornado/ |
H A D | queues.py | 145 self._getters = collections.deque([]) # Futures. 196 if self._getters: 198 getter = self._getters.popleft() 221 self._getters.append(future) 293 while self._getters and self._getters[0].done(): 294 self._getters.popleft() 307 if self._getters: 308 result += ' getters[%s]' % len(self._getters)
|
/dports/sysutils/py-salt/salt-3004.1/salt/ext/tornado/ |
H A D | queues.py | 143 self._getters = collections.deque([]) # Futures. 189 if self._getters: 191 getter = self._getters.popleft() 209 self._getters.append(future) 281 while self._getters and self._getters[0].done(): 282 self._getters.popleft() 295 if self._getters: 296 result += ' getters[%s]' % len(self._getters)
|
/dports/lang/mono/mono-5.10.1.57/mcs/class/referencesource/System.Data/System/Data/SqlClient/ |
H A D | SqlSequentialTextReaderSmi.cs | 11 private ITypedGettersV3 _getters; field in System.Data.SqlClient.SqlSequentialTextReaderSmi 20 _getters = getters; in SqlSequentialTextReaderSmi() 62 …int charsRead = ValueUtilsSmi.GetChars_Unchecked(_sink, _getters, _columnIndex, _position, tempBuf… in Read() 98 …int newCharsRead = ValueUtilsSmi.GetChars_Unchecked(_sink, _getters, _columnIndex, _position, buff… in Read() 113 _getters = null; in SetClosed() 122 get { return ((_sink == null) || (_getters == null)); }
|
H A D | SqlSequentialStreamSmi.cs | 10 private ITypedGettersV3 _getters; field in System.Data.SqlClient.SqlSequentialStreamSmi 18 _getters = getters; in SqlSequentialStreamSmi() 26 get { return ((_sink != null) && (_getters != null)); } 74 …bytesRead = ValueUtilsSmi.GetBytes_Unchecked(_sink, _getters, _columnIndex, _position, buffer, off… in Read() 108 _getters = null; in SetClosed()
|
/dports/www/py-tornado/tornado-6.1/tornado/ |
H A D | queues.py | 162 self._getters = collections.deque([]) # type: Deque[Future[_T]] 215 if self._getters: 217 getter = self._getters.popleft() 252 self._getters.append(future) 327 while self._getters and self._getters[0].done(): 328 self._getters.popleft() 340 if self._getters: 341 result += " getters[%s]" % len(self._getters)
|
/dports/lang/mono/mono-5.10.1.57/mcs/class/referencesource/System.Data/Microsoft/SqlServer/Server/ |
H A D | SmiGettersStream.cs | 19 private ITypedGettersV3 _getters; field in Microsoft.SqlServer.Server.SmiGettersStream 31 _getters = getters; in SmiGettersStream() 58 …return ValueUtilsSmi.GetBytesInternal( _sink, _getters, _ordinal, _metaData, 0, null, 0, 0, false … 84 …long bytesRead = ValueUtilsSmi.GetBytesInternal( _sink, _getters, _ordinal, _metaData, _readPositi… in Read()
|
/dports/lang/mono/mono-5.10.1.57/external/corefx/src/System.Data.SqlClient/src/Microsoft/SqlServer/Server/ |
H A D | SmiGettersStream.cs | 20 private ITypedGettersV3 _getters; field in Microsoft.SqlServer.Server.SmiGettersStream 33 _getters = getters; in SmiGettersStream() 68 … return ValueUtilsSmi.GetBytesInternal(_sink, _getters, _ordinal, _metaData, 0, null, 0, 0, false); 101 …long bytesRead = ValueUtilsSmi.GetBytesInternal(_sink, _getters, _ordinal, _metaData, _readPositio… in Read()
|
/dports/databases/py-gdbm/Python-3.8.12/Lib/asyncio/ |
H A D | queues.py | 44 self._getters = collections.deque() 83 if self._getters: 152 self._wakeup_next(self._getters) 161 self._getters.append(getter) 168 self._getters.remove(getter) 176 self._wakeup_next(self._getters)
|
/dports/databases/py-sqlite3/Python-3.8.12/Lib/asyncio/ |
H A D | queues.py | 44 self._getters = collections.deque() 83 if self._getters: 152 self._wakeup_next(self._getters) 161 self._getters.append(getter) 168 self._getters.remove(getter) 176 self._wakeup_next(self._getters)
|
/dports/lang/python37/Python-3.7.12/Lib/asyncio/ |
H A D | queues.py | 40 self._getters = collections.deque() 79 if self._getters: 148 self._wakeup_next(self._getters) 157 self._getters.append(getter) 164 self._getters.remove(getter) 172 self._wakeup_next(self._getters)
|
/dports/lang/python38/Python-3.8.12/Lib/asyncio/ |
H A D | queues.py | 44 self._getters = collections.deque() 83 if self._getters: 152 self._wakeup_next(self._getters) 161 self._getters.append(getter) 168 self._getters.remove(getter) 176 self._wakeup_next(self._getters)
|
/dports/lang/python-tools/Python-3.8.12/Lib/asyncio/ |
H A D | queues.py | 44 self._getters = collections.deque() 83 if self._getters: 152 self._wakeup_next(self._getters) 161 self._getters.append(getter) 168 self._getters.remove(getter) 176 self._wakeup_next(self._getters)
|
/dports/lang/python39/Python-3.9.9/Lib/asyncio/ |
H A D | queues.py | 44 self._getters = collections.deque() 86 if self._getters: 155 self._wakeup_next(self._getters) 164 self._getters.append(getter) 171 self._getters.remove(getter) 179 self._wakeup_next(self._getters)
|
/dports/x11-toolkits/py-tkinter/Python-3.8.12/Lib/asyncio/ |
H A D | queues.py | 44 self._getters = collections.deque() 83 if self._getters: 152 self._wakeup_next(self._getters) 161 self._getters.append(getter) 168 self._getters.remove(getter) 176 self._wakeup_next(self._getters)
|
/dports/lang/python310/Python-3.10.1/Lib/asyncio/ |
H A D | queues.py | 37 self._getters = collections.deque() 79 if self._getters: 148 self._wakeup_next(self._getters) 157 self._getters.append(getter) 164 self._getters.remove(getter) 172 self._wakeup_next(self._getters)
|
/dports/lang/python311/Python-3.11.0a3/Lib/asyncio/ |
H A D | queues.py | 37 self._getters = collections.deque() 79 if self._getters: 148 self._wakeup_next(self._getters) 157 self._getters.append(getter) 164 self._getters.remove(getter) 172 self._wakeup_next(self._getters)
|
/dports/devel/py-curio/curio-1.5/curio/ |
H A D | queue.py | 107 self._getters = deque() 170 if not self._queue or self._getters: 173 self._getters.append(fut) 239 while self._getters: 240 getter = self._getters.popleft()
|
/dports/irc/smuxi/smuxi-1.1/lib/db4o-net/Db4objects.Db4o/native/Db4objects.Db4o/Internal/Reflect/Emitters/ |
H A D | AccessorFactory.cs | 13 …private static readonly Dictionary<FieldInfo, Getter> _getters = new Dictionary<FieldInfo, Getter>… field in Db4objects.Db4o.Internal.Reflect.Emitters.AccessorFactory 23 return Produce(_getters, field, EmitGetter); in GetterFor()
|
/dports/www/py-tornado4/tornado-4.5.3/tornado/test/ |
H A D | queues_test.py | 150 self.assertEqual(11, len(q._getters)) 152 self.assertEqual(11, len(q._getters)) 155 self.assertEqual(2, len(q._getters)) 269 self.assertEqual(12, len(q._getters)) 271 self.assertEqual(12, len(q._getters)) 274 self.assertEqual(1, len(q._getters))
|
/dports/www/py-tornado5/tornado-5.1.1/tornado/test/ |
H A D | queues_test.py | 150 self.assertEqual(11, len(q._getters)) 152 self.assertEqual(11, len(q._getters)) 155 self.assertEqual(2, len(q._getters)) 269 self.assertEqual(12, len(q._getters)) 271 self.assertEqual(12, len(q._getters)) 274 self.assertEqual(1, len(q._getters))
|
/dports/www/py-tornado/tornado-6.1/tornado/test/ |
H A D | queues_test.py | 151 self.assertEqual(11, len(q._getters)) 153 self.assertEqual(11, len(q._getters)) 156 self.assertEqual(2, len(q._getters)) 274 self.assertEqual(12, len(q._getters)) 276 self.assertEqual(12, len(q._getters)) 279 self.assertEqual(1, len(q._getters))
|
/dports/sysutils/py-salt/salt-3004.1/salt/ext/tornado/test/ |
H A D | queues_test.py | 151 self.assertEqual(11, len(q._getters)) 153 self.assertEqual(11, len(q._getters)) 156 self.assertEqual(2, len(q._getters)) 270 self.assertEqual(12, len(q._getters)) 272 self.assertEqual(12, len(q._getters)) 275 self.assertEqual(1, len(q._getters))
|