@@ -114,35 +114,6 @@ def read(self, whence: str='earliest', guarantee: bool=True) -> "ReadSequence":
114114 cur_seq .increment ()
115115 except EndOfDataStop :
116116 return
117- #def _data(self):
118- # data_ptr = _get(self.lib.bfRingLockedGetData, self.obj)
119- # #data_ptr = c_void_p()
120- # #self._check( self.lib.bfRingLockedGetData(self.obj, pointer(data_ptr)) )
121- # #data_ptr = data_ptr.value
122- # #data_ptr = self.lib.bfRingLockedGetData(self.obj)
123- # if self.space == 'cuda':
124- # # TODO: See if can wrap this in something like PyCUDA's GPUArray
125- # # Ideally actual GPUArray, but it doesn't appear to support wrapping pointers
126- # return data_ptr
127- # span = self._total_span()
128- # stride = self._stride()
129- # nringlet = self._nringlet()
130- # #print("******", span, stride, nringlet)
131- # BufferType = c_byte*(nringlet*stride)
132- # data_buffer_ptr = cast(data_ptr, POINTER(BufferType))
133- # data_buffer = data_buffer_ptr.contents
134- # data_array = np.ndarray(shape=(nringlet, span),
135- # strides=(stride, 1) if nringlet > 1 else None,
136- # buffer=data_buffer, dtype=np.uint8)
137- # return data_array
138- #def _contiguous_span(self):
139- # return self._get(BFsize, self.lib.bfRingLockedGetContiguousSpan, self.obj)
140- #def _total_span(self):
141- # return self._get(BFsize, self.lib.bfRingLockedGetTotalSpan, self.obj)
142- #def _nringlet(self):
143- # return self._get(BFsize, self.lib.bfRingLockedGetNRinglet, self.obj)
144- #def _stride(self):
145- # return self._get(BFsize, self.lib.bfRingLockedGetStride, self.obj)
146117
147118class RingWriter (object ):
148119 def __init__ (self , ring : Ring ):
@@ -308,15 +279,8 @@ def data_view(self, dtype: Union[str,np.dtype]=np.uint8,
308279 assert ( self .size % itemsize == 0 )
309280 assert ( self .stride % itemsize == 0 )
310281 data_ptr = self ._data_ptr
311- #if self.sequence.ring.space == 'cuda':
312- # # TODO: See if can wrap this in something like PyCUDA's GPUArray
313- # # Ideally actual GPUArray, but it doesn't appear to support wrapping pointers
314- # # Could also try writing a custom GPUArray implem for this purpose
315- # return data_ptr
316282 span_size = self .size
317283 nringlet = self .nringlet
318- #print("******", span_size, stride, nringlet)
319- #BufferType = c_byte*(span_size*self.stride)
320284 # TODO: We should really map the actual ring memory space and index
321285 # it with offset rather than mapping from the current pointer.
322286 _shape = (nringlet , span_size // itemsize )
0 commit comments