| Index: third_party/twisted_8_1/twisted/internet/cfsupport/cfrunloop.pxi
|
| diff --git a/third_party/twisted_8_1/twisted/internet/cfsupport/cfrunloop.pxi b/third_party/twisted_8_1/twisted/internet/cfsupport/cfrunloop.pxi
|
| deleted file mode 100644
|
| index 8cd40a8946c1f3dff68cecb3a057e90fb617b8c3..0000000000000000000000000000000000000000
|
| --- a/third_party/twisted_8_1/twisted/internet/cfsupport/cfrunloop.pxi
|
| +++ /dev/null
|
| @@ -1,104 +0,0 @@
|
| -import traceback
|
| -
|
| -# possibly figure out how to subclass these or something
|
| -
|
| -cdef class PyCFRunLoopTimer:
|
| - cdef CFRunLoopTimerRef cf
|
| - cdef public object callout
|
| - cdef CFRunLoopTimerContext context
|
| -
|
| - def __new__(self, double fireDate, double interval, callout):
|
| - self.callout = callout
|
| - self.context.version = 0
|
| - self.context.info = <void *>self
|
| - self.context.retain = NULL
|
| - self.context.release = NULL
|
| - self.context.copyDescription = NULL
|
| - self.cf = CFRunLoopTimerCreate(kCFAllocatorDefault, fireDate, interval, 0, 0, <CFRunLoopTimerCallBack>&gilRunLoopTimerCallBack, &self.context)
|
| - if self.cf == NULL:
|
| - raise ValueError("Invalid Socket")
|
| -
|
| - def getNextFireDate(self):
|
| - return CFRunLoopTimerGetNextFireDate(self.cf)
|
| -
|
| - def setNextFireDate(self, double fireDate):
|
| - CFRunLoopTimerSetNextFireDate(self.cf, fireDate)
|
| -
|
| - def invalidate(self):
|
| - CFRunLoopTimerInvalidate(self.cf)
|
| -
|
| - def __dealloc__(self):
|
| - if self.cf != NULL:
|
| - CFRelease(self.cf)
|
| -
|
| -cdef void runLoopTimerCallBack(CFRunLoopTimerRef timer, void *info):
|
| - cdef PyCFRunLoopTimer obj
|
| - obj = <PyCFRunLoopTimer>info
|
| - try:
|
| - if obj.callout:
|
| - obj.callout()
|
| - except:
|
| - traceback.print_exc()
|
| -
|
| -cdef void gilRunLoopTimerCallBack(CFRunLoopTimerRef timer, void *info):
|
| - cdef PyGILState_STATE gil
|
| - gil = PyGILState_Ensure()
|
| - runLoopTimerCallBack(timer, info)
|
| - PyGILState_Release(gil)
|
| -
|
| -cdef class PyCFRunLoop:
|
| - cdef public object cf
|
| -
|
| - def __new__(self, runLoop=None):
|
| - cdef CFTypeRef _runLoop
|
| - if runLoop is None:
|
| - _runLoop = CFRunLoopGetCurrent()
|
| - else:
|
| - if CFObj_Convert(runLoop, &_runLoop) == 0:
|
| - raise
|
| - #return -1
|
| - # this is going to leak a reference
|
| - self.cf = CFObj_New(CFRetain(_runLoop))
|
| -
|
| - def run(self):
|
| - CFRunLoopRun()
|
| -
|
| - def stop(self):
|
| - cdef CFTypeRef _runLoop
|
| - if CFObj_Convert(self.cf, &_runLoop) == 0:
|
| - raise ValueError, "CFRunLoopReference is invalid"
|
| - CFRunLoopStop(_runLoop)
|
| -
|
| - def currentMode(self):
|
| - cdef CFTypeRef _currentMode
|
| - cdef CFTypeRef _runLoop
|
| - if CFObj_Convert(self.cf, &_runLoop) == 0:
|
| - raise ValueError, "CFRunLoopReference is invalid"
|
| - _currentMode = CFRunLoopCopyCurrentMode(_runLoop)
|
| - if _currentMode == NULL:
|
| - return None
|
| - return CFObj_New(_currentMode)
|
| -
|
| - def addSocket(self, PyCFSocket socket not None):
|
| - cdef CFTypeRef _runLoop
|
| - if CFObj_Convert(self.cf, &_runLoop) == 0:
|
| - raise ValueError, "CFRunLoopReference is invalid"
|
| - CFRunLoopAddSource(_runLoop, socket.source, kCFRunLoopCommonModes)
|
| -
|
| - def removeSocket(self, PyCFSocket socket not None):
|
| - cdef CFTypeRef _runLoop
|
| - if CFObj_Convert(self.cf, &_runLoop) == 0:
|
| - raise ValueError, "CFRunLoopReference is invalid"
|
| - CFRunLoopRemoveSource(_runLoop, socket.source, kCFRunLoopCommonModes)
|
| -
|
| - def addTimer(self, PyCFRunLoopTimer timer not None):
|
| - cdef CFTypeRef _runLoop
|
| - if CFObj_Convert(self.cf, &_runLoop) == 0:
|
| - raise ValueError, "CFRunLoopReference is invalid"
|
| - CFRunLoopAddTimer(_runLoop, timer.cf, kCFRunLoopCommonModes)
|
| -
|
| - def removeTimer(self, PyCFRunLoopTimer timer not None):
|
| - cdef CFTypeRef _runLoop
|
| - if CFObj_Convert(self.cf, &_runLoop) == 0:
|
| - raise ValueError, "CFRunLoopReference is invalid"
|
| - CFRunLoopRemoveTimer(_runLoop, timer.cf, kCFRunLoopCommonModes)
|
|
|