diff options
Diffstat (limited to 'src/windows/identity/kmq/consumer.c')
| -rw-r--r-- | src/windows/identity/kmq/consumer.c | 16 |
1 files changed, 8 insertions, 8 deletions
diff --git a/src/windows/identity/kmq/consumer.c b/src/windows/identity/kmq/consumer.c index dd21834c6b..87d24130f1 100644 --- a/src/windows/identity/kmq/consumer.c +++ b/src/windows/identity/kmq/consumer.c @@ -1,6 +1,6 @@ /* * Copyright (c) 2005 Massachusetts Institute of Technology - * + * * Copyright (c) 2007 Secure Endpoints Inc. * * Permission is hereby granted, free of charge, to any person @@ -219,7 +219,7 @@ void kmqint_post(kmq_msg_subscription * s, kmq_message * m, khm_boolean try_send the message queue. */ m->refcount++; m->nSent++; - rv = s->recipient.cb(m->type, m->subtype, + rv = s->recipient.cb(m->type, m->subtype, m->uparam, m->vparam); m->refcount--; if(KHM_SUCCEEDED(rv)) @@ -254,8 +254,8 @@ void kmqint_post(kmq_msg_subscription * s, kmq_message * m, khm_boolean try_send #ifdef _WIN32 else if(s->rcpt_type == KMQ_RCPTTYPE_HWND) { - if(try_send && - GetCurrentThreadId() == GetWindowThreadProcessId(s->recipient.hwnd, + if(try_send && + GetCurrentThreadId() == GetWindowThreadProcessId(s->recipient.hwnd, NULL)) { /* kmqint_post does not know whether there are any other messages waiting to be posted at this point. Hence, @@ -270,7 +270,7 @@ void kmqint_post(kmq_msg_subscription * s, kmq_message * m, khm_boolean try_send /* the kmq_wm_begin()/kmq_wm_end() and kmq_wm_dispatch() handlers decrement the reference count on the message when they are done. */ - SendMessage(s->recipient.hwnd, KMQ_WM_DISPATCH, + SendMessage(s->recipient.hwnd, KMQ_WM_DISPATCH, m->type, (LPARAM) m); m->nSent++; @@ -282,7 +282,7 @@ void kmqint_post(kmq_msg_subscription * s, kmq_message * m, khm_boolean try_send /* the kmq_wm_begin()/kmq_wm_end() and kmq_wm_dispatch() handlers decrement the reference count on the message when they are done. */ - PostMessage(s->recipient.hwnd, KMQ_WM_DISPATCH, + PostMessage(s->recipient.hwnd, KMQ_WM_DISPATCH, m->type, (LPARAM) m); } } @@ -360,7 +360,7 @@ KHMEXP khm_int32 KHMAPI kmq_create_hwnd_subscription(HWND hw, /*! \internal \note Obtains ::cs_kmq_global */ -KHMEXP khm_int32 KHMAPI kmq_create_subscription(kmq_callback_t cb, +KHMEXP khm_int32 KHMAPI kmq_create_subscription(kmq_callback_t cb, khm_handle * result) { kmq_msg_subscription * s; @@ -498,7 +498,7 @@ KHMEXP khm_boolean KHMAPI kmq_is_call_aborted(void) { /*! \internal - \note Obtains ::cs_kmq_global, kmq_queue::cs, ::cs_kmq_msg_ref, ::cs_kmq_msg, + \note Obtains ::cs_kmq_global, kmq_queue::cs, ::cs_kmq_msg_ref, ::cs_kmq_msg, */ KHMEXP khm_int32 KHMAPI kmq_dispatch(kmq_timer timeout) { kmq_queue * q; |