typedef struct {
CONST_VTBL struct IStreamVtbl *lpVtbl;
- THREAD_T engine_thread;
+ DWORD engine_thread;
LONG refcount;
php_stream *stream;
int id;
istream_destructor(stm);
}
+#ifdef ZTS
+# define TSRMLS_FIXED() TSRMLS_FETCH();
+#else
+# define TSRMLS_FIXED()
+#endif
+
#define FETCH_STM() \
+ TSRMLS_FIXED() \
php_istream *stm = (php_istream*)This; \
- if (tsrm_thread_id() != stm->engine_thread) \
- return E_UNEXPECTED;
+ if (GetCurrentThreadId() != stm->engine_thread) \
+ return RPC_E_WRONG_THREAD;
static HRESULT STDMETHODCALLTYPE stm_queryinterface(
IStream *This,
/* [in] */ REFIID riid,
/* [iid_is][out] */ void **ppvObject)
{
- TSRMLS_FETCH();
FETCH_STM();
if (IsEqualGUID(&IID_IUnknown, riid) ||
static ULONG STDMETHODCALLTYPE stm_addref(IStream *This)
{
- TSRMLS_FETCH();
FETCH_STM();
return InterlockedIncrement(&stm->refcount);
static ULONG STDMETHODCALLTYPE stm_release(IStream *This)
{
ULONG ret;
- TSRMLS_FETCH();
FETCH_STM();
ret = InterlockedDecrement(&stm->refcount);
static HRESULT STDMETHODCALLTYPE stm_read(IStream *This, void *pv, ULONG cb, ULONG *pcbRead)
{
int nread;
- TSRMLS_FETCH();
FETCH_STM();
nread = php_stream_read(stm->stream, pv, cb);
static HRESULT STDMETHODCALLTYPE stm_write(IStream *This, void const *pv, ULONG cb, ULONG *pcbWritten)
{
int nwrote;
- TSRMLS_FETCH();
FETCH_STM();
nwrote = php_stream_write(stm->stream, pv, cb);
off_t offset;
int whence;
int ret;
- TSRMLS_FETCH();
FETCH_STM();
switch (dwOrigin) {
static HRESULT STDMETHODCALLTYPE stm_set_size(IStream *This, ULARGE_INTEGER libNewSize)
{
- TSRMLS_FETCH();
FETCH_STM();
if (libNewSize.HighPart) {
static HRESULT STDMETHODCALLTYPE stm_copy_to(IStream *This, IStream *pstm, ULARGE_INTEGER cb,
ULARGE_INTEGER *pcbRead, ULARGE_INTEGER *pcbWritten)
{
- TSRMLS_FETCH();
FETCH_STM();
return E_NOTIMPL;
static HRESULT STDMETHODCALLTYPE stm_commit(IStream *This, DWORD grfCommitFlags)
{
- TSRMLS_FETCH();
FETCH_STM();
php_stream_flush(stm->stream);
return NULL;
memset(stm, 0, sizeof(*stm));
- stm->engine_thread = tsrm_thread_id();
+ stm->engine_thread = GetCurrentThreadId();
stm->lpVtbl = &php_istream_vtbl;
stm->refcount = 1;
stm->stream = stream;
/* now the PHP stuff */
- THREAD_T engine_thread; /* for sanity checking */
+ DWORD engine_thread; /* for sanity checking */
zval *object; /* the object exported */
LONG refcount; /* COM reference count */
va_list ap;
char buf[4096];
- sprintf(buf, "T=%08x ", tsrm_thread_id());
+ sprintf(buf, "T=%08x ", GetCurrentThreadId());
OutputDebugString(buf);
va_start(ap, fmt);
}
/* }}} */
+#ifdef ZTS
+# define TSRMLS_FIXED() TSRMLS_FETCH();
+#else
+# define TSRMLS_FIXED()
+#endif
+
#define FETCH_DISP(methname) \
+ TSRMLS_FIXED() \
php_dispatchex *disp = (php_dispatchex*)This; \
trace(" PHP:%s %s\n", Z_OBJCE_P(disp->object)->name, methname); \
- if (tsrm_thread_id() != disp->engine_thread) \
+ if (GetCurrentThreadId() != disp->engine_thread) \
return RPC_E_WRONG_THREAD;
/* [in] */ REFIID riid,
/* [iid_is][out] */ void **ppvObject)
{
- TSRMLS_FETCH();
-
FETCH_DISP("QueryInterface");
if (IsEqualGUID(&IID_IUnknown, riid) ||
static ULONG STDMETHODCALLTYPE disp_addref(IDispatchEx *This)
{
- TSRMLS_FETCH();
-
FETCH_DISP("AddRef");
return InterlockedIncrement(&disp->refcount);
static ULONG STDMETHODCALLTYPE disp_release(IDispatchEx *This)
{
ULONG ret;
- TSRMLS_FETCH();
-
FETCH_DISP("Release");
ret = InterlockedDecrement(&disp->refcount);
IDispatchEx *This,
/* [out] */ UINT *pctinfo)
{
- TSRMLS_FETCH();
-
FETCH_DISP("GetTypeInfoCount");
*pctinfo = 0;
/* [in] */ LCID lcid,
/* [out] */ ITypeInfo **ppTInfo)
{
- TSRMLS_FETCH();
-
FETCH_DISP("GetTypeInfo");
*ppTInfo = NULL;
{
UINT i;
HRESULT ret = S_OK;
- TSRMLS_FETCH();
-
FETCH_DISP("GetIDsOfNames");
for (i = 0; i < cNames; i++) {
char *name;
unsigned int namelen;
zval **tmp;
- TSRMLS_FETCH();
-
FETCH_DISP("GetDispID");
name = php_com_olestring_to_string(bstrName, &namelen, COMG(code_page) TSRMLS_CC);
zval *retval = NULL;
zval ***params = NULL;
HRESULT ret = DISP_E_MEMBERNOTFOUND;
- TSRMLS_FETCH();
-
FETCH_DISP("InvokeEx");
if (SUCCESS == zend_hash_index_find(disp->dispid_to_name, id, (void**)&name)) {
/* [in] */ BSTR bstrName,
/* [in] */ DWORD grfdex)
{
- TSRMLS_FETCH();
-
FETCH_DISP("DeleteMemberByName");
/* TODO: unset */
IDispatchEx *This,
/* [in] */ DISPID id)
{
- TSRMLS_FETCH();
-
FETCH_DISP("DeleteMemberByDispID");
/* TODO: unset */
/* [in] */ DWORD grfdexFetch,
/* [out] */ DWORD *pgrfdex)
{
- TSRMLS_FETCH();
-
FETCH_DISP("GetMemberProperties");
return DISP_E_UNKNOWNNAME;
/* [out] */ BSTR *pbstrName)
{
zval *name;
- TSRMLS_FETCH();
-
FETCH_DISP("GetMemberName");
if (SUCCESS == zend_hash_index_find(disp->dispid_to_name, id, (void**)&name)) {
/* [out] */ DISPID *pid)
{
ulong next = id+1;
- TSRMLS_FETCH();
-
FETCH_DISP("GetNextDispID");
while(!zend_hash_index_exists(disp->dispid_to_name, next))
IDispatchEx *This,
/* [out] */ IUnknown **ppunk)
{
- TSRMLS_FETCH();
-
FETCH_DISP("GetNameSpaceParent");
*ppunk = NULL;
memset(disp, 0, sizeof(php_dispatchex));
- disp->engine_thread = tsrm_thread_id();
+ disp->engine_thread = GetCurrentThreadId();
disp->lpVtbl = &php_dispatch_vtbl;
disp->refcount = 1;