Python-сообщество

class Dask:
	lib = ctypes.WinDLL('pci-dask.dll')
	card = None	# идентификатор платы
	size = 100000 # размер буффера чтения
	pmem = (ctypes.c_uint32 * 100000)() # буффер чтения
	rate = 500000.0 # опорная частота
	tm = None # структура синхронизации времени
class Clock( object ):
	def __init__( self, clock=None ):
		if clock:
			self.clock = clock
		else:
			self.clock = time.clock()
	def elapsed( self, clock=None ):
		if clock:
			return clock - self.clock
		return time.clock() - self.clock
Tm = collections.namedtuple('Tm', 'clock shots')
def handleTm():
	clock = time.clock()
	err = resultCast(Dask.lib.DI_AsyncDblBufferTransfer(Dask.card, ctypes.byref(Dask.pmem)))
	if err == 0:
		pmem = Dask.pmem
		clk = Clock()
		shots = makeShots(pmem)	# !!!
		print u'elapsed> makeShots: {elapsed}'.format(elapsed=clk.elapsed())
		if shots:
			Dask.tm = Tm(clock, shots)

def makeShots( pmem ):
	ret = []
	for i in xrange(len(pmem)):
		if pmem[i] & 0x03:	# 1й канал чтение/запись
			ret.append(i)
	return ret

class Filter( object ):
	def __init__( self, pmem ):
		self.pmem = pmem
	def __call__( self, index ):
		return self.pmem[index] & 0x03
		
def makeShots_( pmem ):
	return filter(Filter(pmem), xrange(len(pmem)))

def makeShots__( pmem ):
	return [i for i in xrange(len(pmem)) if pmem[i] & 0x03]

def makeShots___( pmem ):
	beg = 0
	end = len(pmem)
	ret = []
	while beg < end:
		beg = daskaux.findnextmask(ctypes.byref(pmem), beg, end, 0x03)
		if beg < end:
			ret.append(beg)
			beg += 1
	return ret

import numpy
 
def makeShots(pmem):
    arr = numpy.frombuffer(pmem, dtype=numpy.uint32)
    return numpy.where(arr & 0x03)[0]

def makeShots(pmem):
	return list(numpy.where(numpy.frombuffer(pmem, dtype=numpy.uint32) & 0x03)[0])

def makeShots(pmem):
	return numpy.where(numpy.frombuffer(pmem, dtype=numpy.uint32) & 0x03)[0].tolist()