ZwOpenEvent

[grey]

Привет всем

У меня следующая проблемма:
создаю event в пользовательском режиме, а в драйвере не могу его открыть (хотя ведь это объект ядра). Искал в Global\\ и BaseNamedObjects\\ - так и не вышло.

P.S. Буду очень признателен за помощь [/list][/list]

[SlavaI]

Искал в Global\\ и BaseNamedObjects\\

Чем искал?

ObReferenceObjectByHandle описана в DDK.

[grey]

Воспользовался подсказкой про ObReferenceObjectByHandle, но что-то не совсем выходит ))

Правда потребовался не Event а Mutex (сори)

Подскажите пожалуйста где ошибка

Пользовательское приложение:

#define MUTEX_NAME "Glogal\\MyMutex"
hHookMutex = CreateMutex(NULL, FALSE, MUTEX_NAME);
...
WaitForSingleObject(hHookMutex, INFINITE);
...
ReleaseMutex(hHookMutex);

Через IOCTL передаю Handle Mutex

Драйвер:

Status = ObReferenceObjectByHandle((HANDLE)(*((PULONG)pBuffer)), 0, NULL, KernelMode, &hHookMutex, NULL);
...
KeWaitForSingleObject(hHookMutex, Executive, KernelMode, FALSE, NULL);
...
KeReleaseMutex(hHookMutex, FALSE);

В результате не происходит ожидание и сброс Mutex

P.S. Спасибо

[SlavaI]

В результате не происходит ожидание и сброс Mutex

А тебе чего надо? Работает.

[grey]

В результате не происходит ожидание и сброс Mutex

А тебе чего надо? Работает.

В том - то и дело что НЕ происходит сброс и ожидание (значит не работает)

[SlavaI]

сброс и ожидание

чего сброс. Нет такого понятия. Чего ты сбрасываешь, а потом ожидаешь?

[grey]

Привет

Хорошо, я объясню подробнее (Про сброс и ожидание я думаю понятно о чем я говорю. Суть не в словах а в смысле слов )))

Пользователь создает Mutex для синхронизации (монопольного доступа к памяти в которую драйвер пишет, а пользователь из нее читает). В то время пока драйвер заполняет память пользователь должен ждать, а когда она заполнена - драйвер приостанавливает все действия до того, как пользователь прочитает память и сообщит об этом драйверу. (Надеюсь идея понятна - причем это осуществляется не один раз, а постоянно).

Что происходит у меня:
пользователь создает Mutex и передает Handle через IOCTL для того, чтобы драйвер ObReferenceObjectByHandle и получил указатель на объект ядра. SoftIce показавает, что запись происходит, но когда буфер заполнился и вызывается KeReleaseMutex, то на KeWaitForMutexObject он не останавливается а продолжает писать. Причем пользователь вешается еще не доходя до WaitForSingleObject (причем висит не только пользователь, но и вся винда). Но что самое интересное - SoftIce показывает, что драйвер продолжает писать.

Тоесть вывод - неужели эта запись в буфер загружает процессор на 100% и почему не срабатывает KeReleaseMutex .

Надеюсь объяснил подробно ))

[Diletant]

Если у тебя для синхронизации используется только один мьютекс, то все логично. Так и должно быть.

[SlavaI]

заполнился и вызывается KeReleaseMutex, то на KeWaitForMutexObject он не останавливается а продолжает пи

У тебя программа задом наперед работает? Зачем сначала вызывать KeReleaseMutex а потом KeWaitForMutexObject ? В коде у тебя наоборот.

Причем пользователь вешается еще не доходя до WaitForSingleObject (причем висит не только пользователь, но и вся винда).

Ищи багу во всем коде.

Надеюсь объяснил подробно ))

ага, тока объяснение с кодом расходится.

[SlavaI]

А зачем тебе мютекс- у тебя несколько потоков или драйвер асинхронную обработку делает?

[grey]

Я приведу тогда код с пояснениями целиком (кстати нигде этого не упомянул - запись в буфер происходит при перехвате функции ядра)

1. Пользователь создает Mutex
 hMutex = CreateMutex(...);

пересылает его драйверу через IOCTL

2. Драйвер получает указатель на объект Mutex
ObReferenceObjectByHandle(hMutex,..., &pObject)

3. Если происходит перехват функции, то
   KeWaitForMutexObject()
   ...запись в память
   if(буфер заполнен){
      KeReleaseMutex(...)
   }

Если условие выполнилось, то при перехвате следующей функции KeWaitForMutexObject() не должен разрешить запись.

4. В этот момент пользователь должен пройти WaitForSingleObject и произвести чтение. Как только закончил - ReleaseMutex и драйвер продолжает запись

Но как я и описал выше KeReleaseMutex не срабатывает и при перехвате следующей функции KeWaitForMutexObject позволяет писать дальше

Почему этот код работает наоборот (SlavaI)

И еще: может ли в данном случае произойти deadlock (может где Sleep() использовать )

P.S. Надеюсь на помощь ))

[maaaad]

Мьютек перед рефренс надо бы открыть...

[SlavaI]

Почему этот код работает наоборот (SlavaI)

потому что ты так описал - "заполнился и вызывается KeReleaseMutex, то на KeWaitForMutexObject он не останавливается а продолжает ". Как это еще понимать.

Далее-

KeWaitForMutexObject()
...запись в память
if(буфер заполнен){
KeReleaseMutex(...)
}

KeWaitForMutexObject и KeReleaseMutex в одном потоке вызываются?

И наконец главное- насколько я понимаю у мютекса ведется счетчик захватов, и он должен освобождаться. То есть каждому вызову KeWaitForMutexObject должен быть соответствующий  KeReleaseMutex. А у тебя много KeWait... и один KeReleaseMutex. Вот ты и получил все время захваченный мютекс и юзер мод его получить не может. Вот так вот. К тому же учти- множественные захваты только для одного потока разрешены. Как там у тебя с контекстом?

[Anonymous]

Спасибо большое  всем за ответы.

Я понял почему у меня происходит эта ошибка. Если не сложно, то можно подсказку - как выйти из этой ситуации )))

Заранее всем спасибо

[grey]

Сорри, забыл войти ))

Перехват функции и дальнейшая обработка происходит в контексте потока. Но если это приводит к постоянному захвату MUTEX, то существует ли какой-нибудь способ для выполнения моей задачи.

З.Ы. Спасибо

[Anonymous]

Или все-таки прейдется использовать 2 Event (т.к. для Event количество захватов не важно - ZwResetEvent вроде должен сбросить Event в любом случае)

Я нашел в google пример, но всеравно с Event не прошло (((

http://www.codeproject.com/system/driveguicomm.asp

Но почему-то Handle Mutex открывается с помощью ObReferenceObjectByHandle, а Event не хочет, хотя в примере именно так и делается.

[SlavaI]

Считай сколько раз захватил мютекс, столько раз и освобождай.

[grey]

Только что пробовал с Event - таже фигня (если с пишушим процессом ничего не делать, а только KeSetEvent пользователя - то все в порядке, но потеря данных, т.к. они могут перезаписаться)

Что касается на счет подсчета количества захватов, то я думаю что не выйдет. Количество захватов Mutex = числу блоков памяти. Если я KeReleaseMutex такое количество раз, до вроде бы должен сработать пользователь, но если в этот момент прийдет процесс с большим приоритетом, то он опять его захватит => опять таже проблемма ))

[SlavaI]

Я не пойму, почему тебя не устраивает вариант- сигналить юзерскому приложению через event, что буффер заполнен, при этом переключаться в драйвере на другой буффер, который расширять по мере необходимости, а из него опять писать в юзерский буффер и сигналить юзеру- потерь не будет. А юзер сигналить о прочтении своим event.
Или вобще, писать в какой-то буфер в драйвере, а юзеру по его запросам передавать данные, влезающие в его буфер. А в драйвере если буфер достиг максимального размера, то перезаписывать с начала.

[Anonymous]

Так я в принципе так и делаю

Заполняю буфер (если он полон, то пишу сначала) и сигнализирую пользователю о заполнении, а чтоб небыло потерть данных (перезапись) необходимо приостановить запись - в этот то момент и висит. Если не приостанавливать - то все ОК.

Если использовать несколько буферов, то необходимо передавать их адреса и размеры. Причем если какой-то привилегированный процесс будет в него долго писать, то его размер будет очень большим - не очень удобно.

Я понял почему не освобождается Mutex, но я пробовал с Event - таже беда.

P.S. Буду очень благодарен решению этой проблеммы ))

[grey]

Если я всем надоел своими тупыми вопросами, то просто скажите и я больше не буду ВАС беспокоить. Но я считаю, что единственный способ набраться опыта - это общение (т.к. в умных книгах обычно пишут в общем )))

[SlavaI]

Если я всем надоел своими тупыми вопросами, то просто скажите и я больше не буду ВАС беспокоить. Но я считаю, что единственный способ набраться опыта - это общение (т.к. в умных книгах обычно пишут в общем )))

Ну заняты сейчас все.
Проблемы то у тебя нет. Используй Event и дополнительные буфера. А проблема переполнения не должна стоять- если все дополнительные буферы заполнены- перезаписывай наиболее старые. А потом из этих буферов копируй в тот, который юзер читает, когда он просигналит что готов принять новые данные. Зачем и кому передавать их адреса я не понял.

P.S. Ты что думаешь- тебе тут код напишут- ну тогда выкладывай свой полностью, а так сидеть и придумывать для кого код никто не будет, если это не связано с решаемой им в данный момент проблемой.
А в умных книгах все написано, в том числе и про множественные захваты мютексов, просто надо внимательно читать. Есть сайт www.osronline.com а там статья Sharing Memory..., Sharing Event... и еще другие всякие.

На вопросы твои не отвечают, так как трудно понять, что ты имеешь в виду, например твоя цитата

Количество захватов Mutex = числу блоков памяти. Если я KeReleaseMutex такое количество раз, до вроде бы должен сработать пользователь, но если в этот момент прийдет процесс с большим приоритетом, то он опять его захватит => опять таже проблемма ))

от не понимаю я ее, о каких блоках памяти идет речь, если у тебя по твоим словам один буфер? Причем тут процесс(на самом деле единица выполнения- поток) с большим приоритетом? У тебя сколько читателей- писателей? Если твой драйвер (работающий в контексте одного и того же потока, так как ты же хочешь несколько раз хватать мютекс) решил освободить захваченный им несколько раз мютекс, нафига его сразу хватать, не дождавшись чтения от юзера, надо просто синхронизировать это, опять вылезают или Event или второй мютекс. Туманно все.