urlmon: Use wine lists to store namespaces and MIME filters.
[wine] / dlls / pdh / pdh_main.c
1 /*
2  * Performance Data Helper (pdh.dll)
3  *
4  * Copyright 2007 Andrey Turkin
5  * Copyright 2007 Hans Leidekker
6  *
7  * This library is free software; you can redistribute it and/or
8  * modify it under the terms of the GNU Lesser General Public
9  * License as published by the Free Software Foundation; either
10  * version 2.1 of the License, or (at your option) any later version.
11  *
12  * This library is distributed in the hope that it will be useful,
13  * but WITHOUT ANY WARRANTY; without even the implied warranty of
14  * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the GNU
15  * Lesser General Public License for more details.
16  *
17  * You should have received a copy of the GNU Lesser General Public
18  * License along with this library; if not, write to the Free Software
19  * Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA 02110-1301, USA
20  */
21
22 #include <stdarg.h>
23 #include <math.h>
24
25 #define NONAMELESSUNION
26 #define NONAMELESSSTRUCT
27 #include "windef.h"
28 #include "winbase.h"
29
30 #include "pdh.h"
31 #include "pdhmsg.h"
32 #include "winperf.h"
33
34 #include "wine/debug.h"
35 #include "wine/list.h"
36 #include "wine/unicode.h"
37
38 WINE_DEFAULT_DEBUG_CHANNEL(pdh);
39
40 static CRITICAL_SECTION pdh_handle_cs;
41 static CRITICAL_SECTION_DEBUG pdh_handle_cs_debug =
42 {
43     0, 0, &pdh_handle_cs,
44     { &pdh_handle_cs_debug.ProcessLocksList,
45       &pdh_handle_cs_debug.ProcessLocksList },
46       0, 0, { (DWORD_PTR)(__FILE__ ": pdh_handle_cs") }
47 };
48 static CRITICAL_SECTION pdh_handle_cs = { &pdh_handle_cs_debug, -1, 0, 0, 0, 0 };
49
50 static inline void *heap_alloc( SIZE_T size )
51 {
52     return HeapAlloc( GetProcessHeap(), 0, size );
53 }
54
55 static inline void *heap_alloc_zero( SIZE_T size )
56 {
57     return HeapAlloc( GetProcessHeap(), HEAP_ZERO_MEMORY, size );
58 }
59
60 static inline void heap_free( LPVOID mem )
61 {
62     HeapFree( GetProcessHeap(), 0, mem );
63 }
64
65 static inline WCHAR *pdh_strdup( const WCHAR *src )
66 {
67     WCHAR *dst;
68
69     if (!src) return NULL;
70     if ((dst = heap_alloc( (strlenW( src ) + 1) * sizeof(WCHAR) ))) strcpyW( dst, src );
71     return dst;
72 }
73
74 static inline WCHAR *pdh_strdup_aw( const char *src )
75 {
76     int len;
77     WCHAR *dst;
78
79     if (!src) return NULL;
80     len = MultiByteToWideChar( CP_ACP, 0, src, -1, NULL, 0 );
81     if ((dst = heap_alloc( len * sizeof(WCHAR) ))) MultiByteToWideChar( CP_ACP, 0, src, -1, dst, len );
82     return dst;
83 }
84
85 BOOL WINAPI DllMain(HINSTANCE hinstDLL, DWORD fdwReason, LPVOID lpvReserved)
86 {
87     TRACE("(0x%p, %d, %p)\n",hinstDLL,fdwReason,lpvReserved);
88     switch (fdwReason)
89     {
90     case DLL_WINE_PREATTACH:
91         return FALSE;    /* prefer native version */
92     case DLL_PROCESS_ATTACH:
93         DisableThreadLibraryCalls(hinstDLL);
94         break;
95     case DLL_PROCESS_DETACH:
96         DeleteCriticalSection(&pdh_handle_cs);
97         break;
98     }
99
100     return TRUE;
101 }
102
103 union value
104 {
105     LONG     longvalue;
106     double   doublevalue;
107     LONGLONG largevalue;
108 };
109
110 struct counter
111 {
112     DWORD           magic;                          /* signature */
113     struct list     entry;                          /* list entry */
114     WCHAR          *path;                           /* identifier */
115     DWORD           type;                           /* counter type */
116     DWORD           status;                         /* update status */
117     LONG            scale;                          /* scale factor */
118     LONG            defaultscale;                   /* default scale factor */
119     DWORD_PTR       user;                           /* user data */
120     DWORD_PTR       queryuser;                      /* query user data */
121     LONGLONG        base;                           /* samples per second */
122     FILETIME        stamp;                          /* time stamp */
123     void (CALLBACK *collect)( struct counter * );   /* collect callback */
124     union value     one;                            /* first value */
125     union value     two;                            /* second value */
126 };
127
128 #define PDH_MAGIC_COUNTER   0x50444831 /* 'PDH1' */
129
130 static struct counter *create_counter( void )
131 {
132     struct counter *counter;
133
134     if ((counter = heap_alloc_zero( sizeof(struct counter) )))
135     {
136         counter->magic = PDH_MAGIC_COUNTER;
137         return counter;
138     }
139     return NULL;
140 }
141
142 static void destroy_counter( struct counter *counter )
143 {
144     counter->magic = 0;
145     heap_free( counter->path );
146     heap_free( counter );
147 }
148
149 #define PDH_MAGIC_QUERY     0x50444830 /* 'PDH0' */
150
151 struct query
152 {
153     DWORD       magic;      /* signature */
154     DWORD_PTR   user;       /* user data */
155     HANDLE      thread;     /* collect thread */
156     DWORD       interval;   /* collect interval */
157     HANDLE      wait;       /* wait event */
158     HANDLE      stop;       /* stop event */
159     struct list counters;   /* counter list */
160 };
161
162 static struct query *create_query( void )
163 {
164     struct query *query;
165
166     if ((query = heap_alloc_zero( sizeof(struct query) )))
167     {
168         query->magic = PDH_MAGIC_QUERY;
169         list_init( &query->counters );
170         return query;
171     }
172     return NULL;
173 }
174
175 static void destroy_query( struct query *query )
176 {
177     query->magic = 0;
178     heap_free( query );
179 }
180
181 struct source
182 {
183     DWORD           index;                          /* name index */
184     const WCHAR    *path;                           /* identifier */
185     void (CALLBACK *collect)( struct counter * );   /* collect callback */
186     DWORD           type;                           /* counter type */
187     LONG            scale;                          /* default scale factor */
188     LONGLONG        base;                           /* samples per second */
189 };
190
191 static const WCHAR path_processor_time[] =
192     {'\\','P','r','o','c','e','s','s','o','r','(','_','T','o','t','a','l',')',
193      '\\','%',' ','P','r','o','c','e','s','s','o','r',' ','T','i','m','e',0};
194 static const WCHAR path_uptime[] =
195     {'\\','S','y','s','t','e','m', '\\', 'S','y','s','t','e','m',' ','U','p',' ','T','i','m','e',0};
196
197 static void CALLBACK collect_processor_time( struct counter *counter )
198 {
199     counter->two.largevalue = 500000; /* FIXME */
200     counter->status = PDH_CSTATUS_VALID_DATA;
201 }
202
203 static void CALLBACK collect_uptime( struct counter *counter )
204 {
205     counter->two.largevalue = GetTickCount64();
206     counter->status = PDH_CSTATUS_VALID_DATA;
207 }
208
209 #define TYPE_PROCESSOR_TIME \
210     (PERF_SIZE_LARGE | PERF_TYPE_COUNTER | PERF_COUNTER_RATE | PERF_TIMER_100NS | PERF_DELTA_COUNTER | \
211      PERF_INVERSE_COUNTER | PERF_DISPLAY_PERCENT)
212
213 #define TYPE_UPTIME \
214     (PERF_SIZE_LARGE | PERF_TYPE_COUNTER | PERF_COUNTER_ELAPSED | PERF_OBJECT_TIMER | PERF_DISPLAY_SECONDS)
215
216 /* counter source registry */
217 static const struct source counter_sources[] =
218 {
219     { 6,    path_processor_time,    collect_processor_time,     TYPE_PROCESSOR_TIME,    -5,     10000000 },
220     { 674,  path_uptime,            collect_uptime,             TYPE_UPTIME,            -3,     1000 }
221 };
222
223 static BOOL pdh_match_path( LPCWSTR fullpath, LPCWSTR path )
224 {
225     const WCHAR *p;
226
227     if (strchrW( path, '\\')) p = fullpath;
228     else p = strrchrW( fullpath, '\\' ) + 1;
229     if (strcmpW( p, path )) return FALSE;
230     return TRUE;
231 }
232
233 /***********************************************************************
234  *              PdhAddCounterA   (PDH.@)
235  */
236 PDH_STATUS WINAPI PdhAddCounterA( PDH_HQUERY query, LPCSTR path,
237                                   DWORD_PTR userdata, PDH_HCOUNTER *counter )
238 {
239     PDH_STATUS ret;
240     WCHAR *pathW;
241
242     TRACE("%p %s %lx %p\n", query, debugstr_a(path), userdata, counter);
243
244     if (!path) return PDH_INVALID_ARGUMENT;
245
246     if (!(pathW = pdh_strdup_aw( path )))
247         return PDH_MEMORY_ALLOCATION_FAILURE;
248
249     ret = PdhAddCounterW( query, pathW, userdata, counter );
250
251     heap_free( pathW );
252     return ret;
253 }
254
255 /***********************************************************************
256  *              PdhAddCounterW   (PDH.@)
257  */
258 PDH_STATUS WINAPI PdhAddCounterW( PDH_HQUERY hquery, LPCWSTR path,
259                                   DWORD_PTR userdata, PDH_HCOUNTER *hcounter )
260 {
261     struct query *query = hquery;
262     struct counter *counter;
263     unsigned int i;
264
265     TRACE("%p %s %lx %p\n", hquery, debugstr_w(path), userdata, hcounter);
266
267     if (!path  || !hcounter) return PDH_INVALID_ARGUMENT;
268
269     EnterCriticalSection( &pdh_handle_cs );
270     if (!query || query->magic != PDH_MAGIC_QUERY)
271     {
272         LeaveCriticalSection( &pdh_handle_cs );
273         return PDH_INVALID_HANDLE;
274     }
275
276     *hcounter = NULL;
277     for (i = 0; i < sizeof(counter_sources) / sizeof(counter_sources[0]); i++)
278     {
279         if (pdh_match_path( counter_sources[i].path, path ))
280         {
281             if ((counter = create_counter()))
282             {
283                 counter->path         = pdh_strdup( counter_sources[i].path );
284                 counter->collect      = counter_sources[i].collect;
285                 counter->type         = counter_sources[i].type;
286                 counter->defaultscale = counter_sources[i].scale;
287                 counter->base         = counter_sources[i].base;
288                 counter->queryuser    = query->user;
289                 counter->user         = userdata;
290
291                 list_add_tail( &query->counters, &counter->entry );
292                 *hcounter = counter;
293
294                 LeaveCriticalSection( &pdh_handle_cs );
295                 return ERROR_SUCCESS;
296             }
297             LeaveCriticalSection( &pdh_handle_cs );
298             return PDH_MEMORY_ALLOCATION_FAILURE;
299         }
300     }
301     LeaveCriticalSection( &pdh_handle_cs );
302     return PDH_CSTATUS_NO_COUNTER;
303 }
304
305 /***********************************************************************
306  *              PdhAddEnglishCounterA   (PDH.@)
307  */
308 PDH_STATUS WINAPI PdhAddEnglishCounterA( PDH_HQUERY query, LPCSTR path,
309                                          DWORD_PTR userdata, PDH_HCOUNTER *counter )
310 {
311     TRACE("%p %s %lx %p\n", query, debugstr_a(path), userdata, counter);
312
313     if (!query) return PDH_INVALID_ARGUMENT;
314     return PdhAddCounterA( query, path, userdata, counter );
315 }
316
317 /***********************************************************************
318  *              PdhAddEnglishCounterW   (PDH.@)
319  */
320 PDH_STATUS WINAPI PdhAddEnglishCounterW( PDH_HQUERY query, LPCWSTR path,
321                                          DWORD_PTR userdata, PDH_HCOUNTER *counter )
322 {
323     TRACE("%p %s %lx %p\n", query, debugstr_w(path), userdata, counter);
324
325     if (!query) return PDH_INVALID_ARGUMENT;
326     return PdhAddCounterW( query, path, userdata, counter );
327 }
328
329 /* caller must hold counter lock */
330 static PDH_STATUS format_value( struct counter *counter, DWORD format, union value *raw1,
331                                 union value *raw2, PDH_FMT_COUNTERVALUE *value )
332 {
333     LONG factor;
334
335     factor = counter->scale ? counter->scale : counter->defaultscale;
336     if (format & PDH_FMT_LONG)
337     {
338         if (format & PDH_FMT_1000) value->u.longValue = raw2->longvalue * 1000;
339         else value->u.longValue = raw2->longvalue * pow( 10, factor );
340     }
341     else if (format & PDH_FMT_LARGE)
342     {
343         if (format & PDH_FMT_1000) value->u.largeValue = raw2->largevalue * 1000;
344         else value->u.largeValue = raw2->largevalue * pow( 10, factor );
345     }
346     else if (format & PDH_FMT_DOUBLE)
347     {
348         if (format & PDH_FMT_1000) value->u.doubleValue = raw2->doublevalue * 1000;
349         else value->u.doubleValue = raw2->doublevalue * pow( 10, factor );
350     }
351     else
352     {
353         WARN("unknown format %x\n", format);
354         return PDH_INVALID_ARGUMENT;
355     }
356     return ERROR_SUCCESS;
357 }
358
359 /***********************************************************************
360  *              PdhCalculateCounterFromRawValue   (PDH.@)
361  */
362 PDH_STATUS WINAPI PdhCalculateCounterFromRawValue( PDH_HCOUNTER handle, DWORD format,
363                                                    PPDH_RAW_COUNTER raw1, PPDH_RAW_COUNTER raw2,
364                                                    PPDH_FMT_COUNTERVALUE value )
365 {
366     PDH_STATUS ret;
367     struct counter *counter = handle;
368
369     TRACE("%p 0x%08x %p %p %p\n", handle, format, raw1, raw2, value);
370
371     if (!value) return PDH_INVALID_ARGUMENT;
372
373     EnterCriticalSection( &pdh_handle_cs );
374     if (!counter || counter->magic != PDH_MAGIC_COUNTER)
375     {
376         LeaveCriticalSection( &pdh_handle_cs );
377         return PDH_INVALID_HANDLE;
378     }
379
380     ret = format_value( counter, format, (union value *)&raw1->SecondValue,
381                                          (union value *)&raw2->SecondValue, value );
382
383     LeaveCriticalSection( &pdh_handle_cs );
384     return ret;
385 }
386
387
388 /***********************************************************************
389  *              PdhCloseQuery   (PDH.@)
390  */
391 PDH_STATUS WINAPI PdhCloseQuery( PDH_HQUERY handle )
392 {
393     struct query *query = handle;
394     struct list *item, *next;
395
396     TRACE("%p\n", handle);
397
398     EnterCriticalSection( &pdh_handle_cs );
399     if (!query || query->magic != PDH_MAGIC_QUERY)
400     {
401         LeaveCriticalSection( &pdh_handle_cs );
402         return PDH_INVALID_HANDLE;
403     }
404
405     if (query->thread)
406     {
407         HANDLE thread = query->thread;
408         SetEvent( query->stop );
409         LeaveCriticalSection( &pdh_handle_cs );
410
411         WaitForSingleObject( thread, INFINITE );
412
413         EnterCriticalSection( &pdh_handle_cs );
414         if (query->magic != PDH_MAGIC_QUERY)
415         {
416             LeaveCriticalSection( &pdh_handle_cs );
417             return ERROR_SUCCESS;
418         }
419         CloseHandle( query->stop );
420         CloseHandle( query->thread );
421         query->thread = NULL;
422     }
423
424     LIST_FOR_EACH_SAFE( item, next, &query->counters )
425     {
426         struct counter *counter = LIST_ENTRY( item, struct counter, entry );
427
428         list_remove( &counter->entry );
429         destroy_counter( counter );
430     }
431
432     destroy_query( query );
433
434     LeaveCriticalSection( &pdh_handle_cs );
435     return ERROR_SUCCESS;
436 }
437
438 /* caller must hold query lock */
439 static void collect_query_data( struct query *query )
440 {
441     struct list *item;
442
443     LIST_FOR_EACH( item, &query->counters )
444     {
445         SYSTEMTIME time;
446         struct counter *counter = LIST_ENTRY( item, struct counter, entry );
447
448         counter->collect( counter );
449
450         GetLocalTime( &time );
451         SystemTimeToFileTime( &time, &counter->stamp );
452     }
453 }
454
455 /***********************************************************************
456  *              PdhCollectQueryData   (PDH.@)
457  */
458 PDH_STATUS WINAPI PdhCollectQueryData( PDH_HQUERY handle )
459 {
460     struct query *query = handle;
461
462     TRACE("%p\n", handle);
463
464     EnterCriticalSection( &pdh_handle_cs );
465     if (!query || query->magic != PDH_MAGIC_QUERY)
466     {
467         LeaveCriticalSection( &pdh_handle_cs );
468         return PDH_INVALID_HANDLE;
469     }
470
471     if (list_empty( &query->counters ))
472     {
473         LeaveCriticalSection( &pdh_handle_cs );
474         return PDH_NO_DATA;
475     }
476
477     collect_query_data( query );
478
479     LeaveCriticalSection( &pdh_handle_cs );
480     return ERROR_SUCCESS;
481 }
482
483 static DWORD CALLBACK collect_query_thread( void *arg )
484 {
485     struct query *query = arg;
486     DWORD interval = query->interval;
487     HANDLE stop = query->stop;
488
489     for (;;)
490     {
491         if (WaitForSingleObject( stop, interval ) != WAIT_TIMEOUT) ExitThread( 0 );
492
493         EnterCriticalSection( &pdh_handle_cs );
494         if (query->magic != PDH_MAGIC_QUERY)
495         {
496             LeaveCriticalSection( &pdh_handle_cs );
497             ExitThread( PDH_INVALID_HANDLE );
498         }
499
500         collect_query_data( query );
501
502         if (!SetEvent( query->wait ))
503         {
504             LeaveCriticalSection( &pdh_handle_cs );
505             ExitThread( 0 );
506         }
507         LeaveCriticalSection( &pdh_handle_cs );
508     }
509 }
510
511 /***********************************************************************
512  *              PdhCollectQueryDataEx   (PDH.@)
513  */
514 PDH_STATUS WINAPI PdhCollectQueryDataEx( PDH_HQUERY handle, DWORD interval, HANDLE event )
515 {
516     PDH_STATUS ret;
517     struct query *query = handle;
518
519     TRACE("%p %d %p\n", handle, interval, event);
520
521     EnterCriticalSection( &pdh_handle_cs );
522     if (!query || query->magic != PDH_MAGIC_QUERY)
523     {
524         LeaveCriticalSection( &pdh_handle_cs );
525         return PDH_INVALID_HANDLE;
526     }
527     if (list_empty( &query->counters ))
528     {
529         LeaveCriticalSection( &pdh_handle_cs );
530         return PDH_NO_DATA;
531     }
532     if (query->thread)
533     {
534         HANDLE thread = query->thread;
535         SetEvent( query->stop );
536         LeaveCriticalSection( &pdh_handle_cs );
537
538         WaitForSingleObject( thread, INFINITE );
539
540         EnterCriticalSection( &pdh_handle_cs );
541         if (query->magic != PDH_MAGIC_QUERY)
542         {
543             LeaveCriticalSection( &pdh_handle_cs );
544             return PDH_INVALID_HANDLE;
545         }
546         CloseHandle( query->thread );
547         query->thread = NULL;
548     }
549     else if (!(query->stop = CreateEventW( NULL, FALSE, FALSE, NULL )))
550     {
551         ret = GetLastError();
552         LeaveCriticalSection( &pdh_handle_cs );
553         return ret;
554     }
555     query->wait = event;
556     query->interval = interval * 1000;
557     if (!(query->thread = CreateThread( NULL, 0, collect_query_thread, query, 0, NULL )))
558     {
559         ret = GetLastError();
560         CloseHandle( query->stop );
561
562         LeaveCriticalSection( &pdh_handle_cs );
563         return ret;
564     }
565
566     LeaveCriticalSection( &pdh_handle_cs );
567     return ERROR_SUCCESS;
568 }
569
570 /***********************************************************************
571  *              PdhCollectQueryDataWithTime   (PDH.@)
572  */
573 PDH_STATUS WINAPI PdhCollectQueryDataWithTime( PDH_HQUERY handle, LONGLONG *timestamp )
574 {
575     struct query *query = handle;
576     struct counter *counter;
577     struct list *item;
578
579     TRACE("%p %p\n", handle, timestamp);
580
581     if (!timestamp) return PDH_INVALID_ARGUMENT;
582
583     EnterCriticalSection( &pdh_handle_cs );
584     if (!query || query->magic != PDH_MAGIC_QUERY)
585     {
586         LeaveCriticalSection( &pdh_handle_cs );
587         return PDH_INVALID_HANDLE;
588     }
589     if (list_empty( &query->counters ))
590     {
591         LeaveCriticalSection( &pdh_handle_cs );
592         return PDH_NO_DATA;
593     }
594
595     collect_query_data( query );
596
597     item = list_head( &query->counters );
598     counter = LIST_ENTRY( item, struct counter, entry );
599
600     *timestamp = ((LONGLONG)counter->stamp.dwHighDateTime << 32) | counter->stamp.dwLowDateTime;
601
602     LeaveCriticalSection( &pdh_handle_cs );
603     return ERROR_SUCCESS;
604 }
605
606 /***********************************************************************
607  *              PdhExpandWildCardPathA   (PDH.@)
608  */
609 PDH_STATUS WINAPI PdhExpandWildCardPathA( LPCSTR szDataSource, LPCSTR szWildCardPath, LPSTR mszExpandedPathList, LPDWORD pcchPathListLength, DWORD dwFlags )
610 {
611     FIXME("%s, %s, %p, %p, 0x%x: stub\n", debugstr_a(szDataSource), debugstr_a(szWildCardPath), mszExpandedPathList, pcchPathListLength, dwFlags);
612     return PDH_NOT_IMPLEMENTED;
613 }
614
615 /***********************************************************************
616  *              PdhExpandWildCardPathW   (PDH.@)
617  */
618 PDH_STATUS WINAPI PdhExpandWildCardPathW( LPCWSTR szDataSource, LPCWSTR szWildCardPath, LPWSTR mszExpandedPathList, LPDWORD pcchPathListLength, DWORD dwFlags )
619 {
620     FIXME("%s, %s, %p, %p, 0x%x: stub\n", debugstr_w(szDataSource), debugstr_w(szWildCardPath), mszExpandedPathList, pcchPathListLength, dwFlags);
621     return PDH_NOT_IMPLEMENTED;
622 }
623
624 /***********************************************************************
625  *              PdhGetCounterInfoA   (PDH.@)
626  */
627 PDH_STATUS WINAPI PdhGetCounterInfoA( PDH_HCOUNTER handle, BOOLEAN text, LPDWORD size, PPDH_COUNTER_INFO_A info )
628 {
629     struct counter *counter = handle;
630
631     TRACE("%p %d %p %p\n", handle, text, size, info);
632
633     EnterCriticalSection( &pdh_handle_cs );
634     if (!counter || counter->magic != PDH_MAGIC_COUNTER)
635     {
636         LeaveCriticalSection( &pdh_handle_cs );
637         return PDH_INVALID_HANDLE;
638     }
639     if (!size)
640     {
641         LeaveCriticalSection( &pdh_handle_cs );
642         return PDH_INVALID_ARGUMENT;
643     }
644     if (*size < sizeof(PDH_COUNTER_INFO_A))
645     {
646         *size = sizeof(PDH_COUNTER_INFO_A);
647         LeaveCriticalSection( &pdh_handle_cs );
648         return PDH_MORE_DATA;
649     }
650
651     memset( info, 0, sizeof(PDH_COUNTER_INFO_A) );
652
653     info->dwType          = counter->type;
654     info->CStatus         = counter->status;
655     info->lScale          = counter->scale;
656     info->lDefaultScale   = counter->defaultscale;
657     info->dwUserData      = counter->user;
658     info->dwQueryUserData = counter->queryuser;
659
660     *size = sizeof(PDH_COUNTER_INFO_A);
661
662     LeaveCriticalSection( &pdh_handle_cs );
663     return ERROR_SUCCESS;
664 }
665
666 /***********************************************************************
667  *              PdhGetCounterInfoW   (PDH.@)
668  */
669 PDH_STATUS WINAPI PdhGetCounterInfoW( PDH_HCOUNTER handle, BOOLEAN text, LPDWORD size, PPDH_COUNTER_INFO_W info )
670 {
671     struct counter *counter = handle;
672
673     TRACE("%p %d %p %p\n", handle, text, size, info);
674
675     EnterCriticalSection( &pdh_handle_cs );
676     if (!counter || counter->magic != PDH_MAGIC_COUNTER)
677     {
678         LeaveCriticalSection( &pdh_handle_cs );
679         return PDH_INVALID_HANDLE;
680     }
681     if (!size)
682     {
683         LeaveCriticalSection( &pdh_handle_cs );
684         return PDH_INVALID_ARGUMENT;
685     }
686     if (*size < sizeof(PDH_COUNTER_INFO_W))
687     {
688         *size = sizeof(PDH_COUNTER_INFO_W);
689         LeaveCriticalSection( &pdh_handle_cs );
690         return PDH_MORE_DATA;
691     }
692
693     memset( info, 0, sizeof(PDH_COUNTER_INFO_W) );
694
695     info->dwType          = counter->type;
696     info->CStatus         = counter->status;
697     info->lScale          = counter->scale;
698     info->lDefaultScale   = counter->defaultscale;
699     info->dwUserData      = counter->user;
700     info->dwQueryUserData = counter->queryuser;
701
702     *size = sizeof(PDH_COUNTER_INFO_W);
703
704     LeaveCriticalSection( &pdh_handle_cs );
705     return ERROR_SUCCESS;
706 }
707
708 /***********************************************************************
709  *              PdhGetCounterTimeBase   (PDH.@)
710  */
711 PDH_STATUS WINAPI PdhGetCounterTimeBase( PDH_HCOUNTER handle, LONGLONG *base )
712 {
713     struct counter *counter = handle;
714
715     TRACE("%p %p\n", handle, base);
716
717     if (!base) return PDH_INVALID_ARGUMENT;
718
719     EnterCriticalSection( &pdh_handle_cs );
720     if (!counter || counter->magic != PDH_MAGIC_COUNTER)
721     {
722         LeaveCriticalSection( &pdh_handle_cs );
723         return PDH_INVALID_HANDLE;
724     }
725
726     *base = counter->base;
727
728     LeaveCriticalSection( &pdh_handle_cs );
729     return ERROR_SUCCESS;
730 }
731
732 /***********************************************************************
733  *              PdhGetDllVersion   (PDH.@)
734  */
735 PDH_STATUS WINAPI PdhGetDllVersion( LPDWORD version )
736 {
737     if (!version)
738         return PDH_INVALID_ARGUMENT;
739
740     *version = PDH_VERSION;
741
742     return ERROR_SUCCESS;
743 }
744
745 /***********************************************************************
746  *              PdhGetFormattedCounterValue   (PDH.@)
747  */
748 PDH_STATUS WINAPI PdhGetFormattedCounterValue( PDH_HCOUNTER handle, DWORD format,
749                                                LPDWORD type, PPDH_FMT_COUNTERVALUE value )
750 {
751     PDH_STATUS ret;
752     struct counter *counter = handle;
753
754     TRACE("%p %x %p %p\n", handle, format, type, value);
755
756     if (!value) return PDH_INVALID_ARGUMENT;
757
758     EnterCriticalSection( &pdh_handle_cs );
759     if (!counter || counter->magic != PDH_MAGIC_COUNTER)
760     {
761         LeaveCriticalSection( &pdh_handle_cs );
762         return PDH_INVALID_HANDLE;
763     }
764     if (counter->status)
765     {
766         LeaveCriticalSection( &pdh_handle_cs );
767         return PDH_INVALID_DATA;
768     }
769     if (!(ret = format_value( counter, format, &counter->one, &counter->two, value )))
770     {
771         value->CStatus = ERROR_SUCCESS;
772         if (type) *type = counter->type;
773     }
774
775     LeaveCriticalSection( &pdh_handle_cs );
776     return ret;
777 }
778
779 /***********************************************************************
780  *              PdhGetRawCounterValue   (PDH.@)
781  */
782 PDH_STATUS WINAPI PdhGetRawCounterValue( PDH_HCOUNTER handle, LPDWORD type,
783                                          PPDH_RAW_COUNTER value )
784 {
785     struct counter *counter = handle;
786
787     TRACE("%p %p %p\n", handle, type, value);
788
789     if (!value) return PDH_INVALID_ARGUMENT;
790
791     EnterCriticalSection( &pdh_handle_cs );
792     if (!counter || counter->magic != PDH_MAGIC_COUNTER)
793     {
794         LeaveCriticalSection( &pdh_handle_cs );
795         return PDH_INVALID_HANDLE;
796     }
797
798     value->CStatus                  = counter->status;
799     value->TimeStamp.dwLowDateTime  = counter->stamp.dwLowDateTime;
800     value->TimeStamp.dwHighDateTime = counter->stamp.dwHighDateTime;
801     value->FirstValue               = counter->one.largevalue;
802     value->SecondValue              = counter->two.largevalue;
803     value->MultiCount               = 1; /* FIXME */
804
805     if (type) *type = counter->type;
806
807     LeaveCriticalSection( &pdh_handle_cs );
808     return ERROR_SUCCESS;
809 }
810
811 /***********************************************************************
812  *              PdhLookupPerfIndexByNameA   (PDH.@)
813  */
814 PDH_STATUS WINAPI PdhLookupPerfIndexByNameA( LPCSTR machine, LPCSTR name, LPDWORD index )
815 {
816     PDH_STATUS ret;
817     WCHAR *machineW = NULL;
818     WCHAR *nameW;
819
820     TRACE("%s %s %p\n", debugstr_a(machine), debugstr_a(name), index);
821
822     if (!name) return PDH_INVALID_ARGUMENT;
823
824     if (machine && !(machineW = pdh_strdup_aw( machine ))) return PDH_MEMORY_ALLOCATION_FAILURE;
825
826     if (!(nameW = pdh_strdup_aw( name )))
827         return PDH_MEMORY_ALLOCATION_FAILURE;
828
829     ret = PdhLookupPerfIndexByNameW( machineW, nameW, index );
830
831     heap_free( nameW );
832     heap_free( machineW );
833     return ret;
834 }
835
836 /***********************************************************************
837  *              PdhLookupPerfIndexByNameW   (PDH.@)
838  */
839 PDH_STATUS WINAPI PdhLookupPerfIndexByNameW( LPCWSTR machine, LPCWSTR name, LPDWORD index )
840 {
841     unsigned int i;
842
843     TRACE("%s %s %p\n", debugstr_w(machine), debugstr_w(name), index);
844
845     if (!name || !index) return PDH_INVALID_ARGUMENT;
846
847     if (machine)
848     {
849         FIXME("remote machine not supported\n");
850         return PDH_CSTATUS_NO_MACHINE;
851     }
852     for (i = 0; i < sizeof(counter_sources) / sizeof(counter_sources[0]); i++)
853     {
854         if (pdh_match_path( counter_sources[i].path, name ))
855         {
856             *index = counter_sources[i].index;
857             return ERROR_SUCCESS;
858         }
859     }
860     return PDH_STRING_NOT_FOUND;
861 }
862
863 /***********************************************************************
864  *              PdhLookupPerfNameByIndexA   (PDH.@)
865  */
866 PDH_STATUS WINAPI PdhLookupPerfNameByIndexA( LPCSTR machine, DWORD index, LPSTR buffer, LPDWORD size )
867 {
868     PDH_STATUS ret;
869     WCHAR *machineW = NULL;
870     WCHAR bufferW[PDH_MAX_COUNTER_NAME];
871     DWORD sizeW = sizeof(bufferW) / sizeof(WCHAR);
872
873     TRACE("%s %d %p %p\n", debugstr_a(machine), index, buffer, size);
874
875     if (!buffer || !size) return PDH_INVALID_ARGUMENT;
876
877     if (machine && !(machineW = pdh_strdup_aw( machine ))) return PDH_MEMORY_ALLOCATION_FAILURE;
878
879     if (!(ret = PdhLookupPerfNameByIndexW( machineW, index, bufferW, &sizeW )))
880     {
881         int required = WideCharToMultiByte( CP_ACP, 0, bufferW, -1, NULL, 0, NULL, NULL );
882
883         if (size && *size < required) ret = PDH_MORE_DATA;
884         else WideCharToMultiByte( CP_ACP, 0, bufferW, -1, buffer, required, NULL, NULL );
885         if (size) *size = required;
886     }
887     heap_free( machineW );
888     return ret;
889 }
890
891 /***********************************************************************
892  *              PdhLookupPerfNameByIndexW   (PDH.@)
893  */
894 PDH_STATUS WINAPI PdhLookupPerfNameByIndexW( LPCWSTR machine, DWORD index, LPWSTR buffer, LPDWORD size )
895 {
896     PDH_STATUS ret;
897     unsigned int i;
898
899     TRACE("%s %d %p %p\n", debugstr_w(machine), index, buffer, size);
900
901     if (machine)
902     {
903         FIXME("remote machine not supported\n");
904         return PDH_CSTATUS_NO_MACHINE;
905     }
906
907     if (!buffer || !size) return PDH_INVALID_ARGUMENT;
908     if (!index) return ERROR_SUCCESS;
909
910     for (i = 0; i < sizeof(counter_sources) / sizeof(counter_sources[0]); i++)
911     {
912         if (counter_sources[i].index == index)
913         {
914             WCHAR *p = strrchrW( counter_sources[i].path, '\\' ) + 1;
915             unsigned int required = strlenW( p ) + 1;
916
917             if (*size < required) ret = PDH_MORE_DATA;
918             else
919             {
920                 strcpyW( buffer, p );
921                 ret = ERROR_SUCCESS;
922             }
923             *size = required;
924             return ret;
925         }
926     }
927     return PDH_INVALID_ARGUMENT;
928 }
929
930 /***********************************************************************
931  *              PdhOpenQueryA   (PDH.@)
932  */
933 PDH_STATUS WINAPI PdhOpenQueryA( LPCSTR source, DWORD_PTR userdata, PDH_HQUERY *query )
934 {
935     PDH_STATUS ret;
936     WCHAR *sourceW = NULL;
937
938     TRACE("%s %lx %p\n", debugstr_a(source), userdata, query);
939
940     if (source && !(sourceW = pdh_strdup_aw( source ))) return PDH_MEMORY_ALLOCATION_FAILURE;
941
942     ret = PdhOpenQueryW( sourceW, userdata, query );
943     heap_free( sourceW );
944
945     return ret;
946 }
947
948 /***********************************************************************
949  *              PdhOpenQueryW   (PDH.@)
950  */
951 PDH_STATUS WINAPI PdhOpenQueryW( LPCWSTR source, DWORD_PTR userdata, PDH_HQUERY *handle )
952 {
953     struct query *query;
954
955     TRACE("%s %lx %p\n", debugstr_w(source), userdata, handle);
956
957     if (!handle) return PDH_INVALID_ARGUMENT;
958
959     if (source)
960     {
961         FIXME("log file data source not supported\n");
962         return PDH_INVALID_ARGUMENT;
963     }
964     if ((query = create_query()))
965     {
966         query->user = userdata;
967         *handle = query;
968
969         return ERROR_SUCCESS;
970     }
971     return PDH_MEMORY_ALLOCATION_FAILURE;
972 }
973
974 /***********************************************************************
975  *              PdhRemoveCounter   (PDH.@)
976  */
977 PDH_STATUS WINAPI PdhRemoveCounter( PDH_HCOUNTER handle )
978 {
979     struct counter *counter = handle;
980
981     TRACE("%p\n", handle);
982
983     EnterCriticalSection( &pdh_handle_cs );
984     if (!counter || counter->magic != PDH_MAGIC_COUNTER)
985     {
986         LeaveCriticalSection( &pdh_handle_cs );
987         return PDH_INVALID_HANDLE;
988     }
989
990     list_remove( &counter->entry );
991     destroy_counter( counter );
992
993     LeaveCriticalSection( &pdh_handle_cs );
994     return ERROR_SUCCESS;
995 }
996
997 /***********************************************************************
998  *              PdhSetCounterScaleFactor   (PDH.@)
999  */
1000 PDH_STATUS WINAPI PdhSetCounterScaleFactor( PDH_HCOUNTER handle, LONG factor )
1001 {
1002     struct counter *counter = handle;
1003
1004     TRACE("%p\n", handle);
1005
1006     EnterCriticalSection( &pdh_handle_cs );
1007     if (!counter || counter->magic != PDH_MAGIC_COUNTER)
1008     {
1009         LeaveCriticalSection( &pdh_handle_cs );
1010         return PDH_INVALID_HANDLE;
1011     }
1012     if (factor < PDH_MIN_SCALE || factor > PDH_MAX_SCALE)
1013     {
1014         LeaveCriticalSection( &pdh_handle_cs );
1015         return PDH_INVALID_ARGUMENT;
1016     }
1017
1018     counter->scale = factor;
1019
1020     LeaveCriticalSection( &pdh_handle_cs );
1021     return ERROR_SUCCESS;
1022 }
1023
1024 /***********************************************************************
1025  *              PdhValidatePathA   (PDH.@)
1026  */
1027 PDH_STATUS WINAPI PdhValidatePathA( LPCSTR path )
1028 {
1029     PDH_STATUS ret;
1030     WCHAR *pathW;
1031
1032     TRACE("%s\n", debugstr_a(path));
1033
1034     if (!path) return PDH_INVALID_ARGUMENT;
1035     if (!(pathW = pdh_strdup_aw( path ))) return PDH_MEMORY_ALLOCATION_FAILURE;
1036
1037     ret = PdhValidatePathW( pathW );
1038
1039     heap_free( pathW );
1040     return ret;
1041 }
1042
1043 static PDH_STATUS validate_path( LPCWSTR path )
1044 {
1045     if (!path || !*path) return PDH_INVALID_ARGUMENT;
1046     if (*path++ != '\\' || !strchrW( path, '\\' )) return PDH_CSTATUS_BAD_COUNTERNAME;
1047     return ERROR_SUCCESS;
1048  }
1049
1050 /***********************************************************************
1051  *              PdhValidatePathW   (PDH.@)
1052  */
1053 PDH_STATUS WINAPI PdhValidatePathW( LPCWSTR path )
1054 {
1055     PDH_STATUS ret;
1056     unsigned int i;
1057
1058     TRACE("%s\n", debugstr_w(path));
1059
1060     if ((ret = validate_path( path ))) return ret;
1061
1062     for (i = 0; i < sizeof(counter_sources) / sizeof(counter_sources[0]); i++)
1063         if (pdh_match_path( counter_sources[i].path, path )) return ERROR_SUCCESS;
1064
1065     return PDH_CSTATUS_NO_COUNTER;
1066 }
1067
1068 /***********************************************************************
1069  *              PdhValidatePathExA   (PDH.@)
1070  */
1071 PDH_STATUS WINAPI PdhValidatePathExA( PDH_HLOG source, LPCSTR path )
1072 {
1073     TRACE("%p %s\n", source, debugstr_a(path));
1074
1075     if (source)
1076     {
1077         FIXME("log file data source not supported\n");
1078         return ERROR_SUCCESS;
1079     }
1080     return PdhValidatePathA( path );
1081 }
1082
1083 /***********************************************************************
1084  *              PdhValidatePathExW   (PDH.@)
1085  */
1086 PDH_STATUS WINAPI PdhValidatePathExW( PDH_HLOG source, LPCWSTR path )
1087 {
1088     TRACE("%p %s\n", source, debugstr_w(path));
1089
1090     if (source)
1091     {
1092         FIXME("log file data source not supported\n");
1093         return ERROR_SUCCESS;
1094     }
1095     return PdhValidatePathW( path );
1096 }
1097
1098 /***********************************************************************
1099  *              PdhMakeCounterPathA   (PDH.@)
1100  */
1101 PDH_STATUS WINAPI PdhMakeCounterPathA( PDH_COUNTER_PATH_ELEMENTS_A *e, LPSTR buffer,
1102                                        LPDWORD buflen, DWORD flags )
1103 {
1104     PDH_STATUS ret = PDH_MEMORY_ALLOCATION_FAILURE;
1105     PDH_COUNTER_PATH_ELEMENTS_W eW;
1106     WCHAR *bufferW;
1107     DWORD buflenW;
1108
1109     TRACE("%p %p %p 0x%08x\n", e, buffer, buflen, flags);
1110
1111     if (!e || !buflen) return PDH_INVALID_ARGUMENT;
1112
1113     memset( &eW, 0, sizeof(eW) );
1114     if (e->szMachineName    && !(eW.szMachineName    = pdh_strdup_aw( e->szMachineName ))) goto done;
1115     if (e->szObjectName     && !(eW.szObjectName     = pdh_strdup_aw( e->szObjectName ))) goto done;
1116     if (e->szInstanceName   && !(eW.szInstanceName   = pdh_strdup_aw( e->szInstanceName ))) goto done;
1117     if (e->szParentInstance && !(eW.szParentInstance = pdh_strdup_aw( e->szParentInstance ))) goto done;
1118     if (e->szCounterName    && !(eW.szCounterName    = pdh_strdup_aw( e->szCounterName ))) goto done;
1119     eW.dwInstanceIndex = e->dwInstanceIndex;
1120
1121     buflenW = 0;
1122     ret = PdhMakeCounterPathW( &eW, NULL, &buflenW, flags );
1123     if (ret == PDH_MORE_DATA)
1124     {
1125         if ((bufferW = heap_alloc( buflenW * sizeof(WCHAR) )))
1126         {
1127             if (!(ret = PdhMakeCounterPathW( &eW, bufferW, &buflenW, flags )))
1128             {
1129                 int len = WideCharToMultiByte(CP_ACP, 0, bufferW, -1, NULL, 0, NULL, NULL);
1130                 if (*buflen >= len) WideCharToMultiByte(CP_ACP, 0, bufferW, -1, buffer, *buflen, NULL, NULL);
1131                 else ret = PDH_MORE_DATA;
1132                 *buflen = len;
1133             }
1134             heap_free( bufferW );
1135         }
1136         else
1137             ret = PDH_MEMORY_ALLOCATION_FAILURE;
1138     }
1139
1140 done:
1141     heap_free( eW.szMachineName );
1142     heap_free( eW.szObjectName );
1143     heap_free( eW.szInstanceName );
1144     heap_free( eW.szParentInstance );
1145     heap_free( eW.szCounterName );
1146     return ret;
1147 }
1148
1149 /***********************************************************************
1150  *              PdhMakeCounterPathW   (PDH.@)
1151  */
1152 PDH_STATUS WINAPI PdhMakeCounterPathW( PDH_COUNTER_PATH_ELEMENTS_W *e, LPWSTR buffer,
1153                                        LPDWORD buflen, DWORD flags )
1154 {
1155     static const WCHAR bslash[] = {'\\',0};
1156     static const WCHAR fslash[] = {'/',0};
1157     static const WCHAR lparen[] = {'(',0};
1158     static const WCHAR rparen[] = {')',0};
1159     static const WCHAR fmt[]    = {'#','%','u',0};
1160
1161     WCHAR path[PDH_MAX_COUNTER_NAME], instance[12];
1162     PDH_STATUS ret = ERROR_SUCCESS;
1163     DWORD len;
1164
1165     TRACE("%p %p %p 0x%08x\n", e, buffer, buflen, flags);
1166
1167     if (flags) FIXME("unimplemented flags 0x%08x\n", flags);
1168
1169     if (!e || !e->szCounterName || !e->szObjectName || !buflen)
1170         return PDH_INVALID_ARGUMENT;
1171
1172     path[0] = 0;
1173     if (e->szMachineName)
1174     {
1175         strcatW(path, bslash);
1176         strcatW(path, bslash);
1177         strcatW(path, e->szMachineName);
1178     }
1179     strcatW(path, bslash);
1180     strcatW(path, e->szObjectName);
1181     if (e->szInstanceName)
1182     {
1183         strcatW(path, lparen);
1184         if (e->szParentInstance)
1185         {
1186             strcatW(path, e->szParentInstance);
1187             strcatW(path, fslash);
1188         }
1189         strcatW(path, e->szInstanceName);
1190         sprintfW(instance, fmt, e->dwInstanceIndex);
1191         strcatW(path, instance);
1192         strcatW(path, rparen);
1193     }
1194     strcatW(path, bslash);
1195     strcatW(path, e->szCounterName);
1196
1197     len = strlenW(path) + 1;
1198     if (*buflen >= len) strcpyW(buffer, path);
1199     else ret = PDH_MORE_DATA;
1200     *buflen = len;
1201     return ret;
1202 }
1203
1204 /***********************************************************************
1205  *              PdhEnumObjectItemsA   (PDH.@)
1206  */
1207 PDH_STATUS WINAPI PdhEnumObjectItemsA(LPCSTR szDataSource, LPCSTR szMachineName, LPCSTR szObjectName,
1208                                       LPSTR mszCounterList, LPDWORD pcchCounterListLength, LPSTR mszInstanceList,
1209                                       LPDWORD pcchInstanceListLength, DWORD dwDetailLevel, DWORD dwFlags)
1210 {
1211     FIXME("%s, %s, %s, %p, %p, %p, %p, %d, 0x%x: stub\n", debugstr_a(szDataSource), debugstr_a(szMachineName),
1212          debugstr_a(szObjectName), mszCounterList, pcchCounterListLength, mszInstanceList,
1213          pcchInstanceListLength, dwDetailLevel, dwFlags);
1214
1215     return PDH_NOT_IMPLEMENTED;
1216 }
1217
1218 /***********************************************************************
1219  *              PdhEnumObjectItemsW   (PDH.@)
1220  */
1221 PDH_STATUS WINAPI PdhEnumObjectItemsW(LPCWSTR szDataSource, LPCWSTR szMachineName, LPCWSTR szObjectName,
1222                                       LPWSTR mszCounterList, LPDWORD pcchCounterListLength, LPWSTR mszInstanceList,
1223                                       LPDWORD pcchInstanceListLength, DWORD dwDetailLevel, DWORD dwFlags)
1224 {
1225     FIXME("%s, %s, %s, %p, %p, %p, %p, %d, 0x%x: stub\n", debugstr_w(szDataSource), debugstr_w(szMachineName),
1226          debugstr_w(szObjectName), mszCounterList, pcchCounterListLength, mszInstanceList,
1227          pcchInstanceListLength, dwDetailLevel, dwFlags);
1228
1229     return PDH_NOT_IMPLEMENTED;
1230 }
1231
1232 /***********************************************************************
1233  *              PdhSetDefaultRealTimeDataSource   (PDH.@)
1234  */
1235 PDH_STATUS WINAPI PdhSetDefaultRealTimeDataSource( DWORD source )
1236 {
1237     FIXME("%u\n", source);
1238     return ERROR_SUCCESS;
1239 }