1 karl 1.54 //%2006////////////////////////////////////////////////////////////////////////
|
2 kumpf 1.1 //
|
3 karl 1.33 // Copyright (c) 2000, 2001, 2002 BMC Software; Hewlett-Packard Development
4 // Company, L.P.; IBM Corp.; The Open Group; Tivoli Systems.
5 // Copyright (c) 2003 BMC Software; Hewlett-Packard Development Company, L.P.;
|
6 karl 1.3 // IBM Corp.; EMC Corporation, The Open Group.
|
7 karl 1.33 // Copyright (c) 2004 BMC Software; Hewlett-Packard Development Company, L.P.;
8 // IBM Corp.; EMC Corporation; VERITAS Software Corporation; The Open Group.
|
9 karl 1.36 // Copyright (c) 2005 Hewlett-Packard Development Company, L.P.; IBM Corp.;
10 // EMC Corporation; VERITAS Software Corporation; The Open Group.
|
11 karl 1.54 // Copyright (c) 2006 Hewlett-Packard Development Company, L.P.; IBM Corp.;
12 // EMC Corporation; Symantec Corporation; The Open Group.
|
13 kumpf 1.1 //
14 // Permission is hereby granted, free of charge, to any person obtaining a copy
15 // of this software and associated documentation files (the "Software"), to
16 // deal in the Software without restriction, including without limitation the
17 // rights to use, copy, modify, merge, publish, distribute, sublicense, and/or
18 // sell copies of the Software, and to permit persons to whom the Software is
19 // furnished to do so, subject to the following conditions:
|
20 karl 1.54 //
|
21 kumpf 1.1 // THE ABOVE COPYRIGHT NOTICE AND THIS PERMISSION NOTICE SHALL BE INCLUDED IN
22 // ALL COPIES OR SUBSTANTIAL PORTIONS OF THE SOFTWARE. THE SOFTWARE IS PROVIDED
23 // "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR IMPLIED, INCLUDING BUT NOT
24 // LIMITED TO THE WARRANTIES OF MERCHANTABILITY, FITNESS FOR A PARTICULAR
25 // PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE AUTHORS OR COPYRIGHT
26 // HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER LIABILITY, WHETHER IN AN
27 // ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, OUT OF OR IN CONNECTION
28 // WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE SOFTWARE.
29 //
30 //==============================================================================
31 //
32 //%/////////////////////////////////////////////////////////////////////////////
33
34 #include "CIMClientRep.h"
35
36 #include <Pegasus/Common/MessageLoader.h>
|
37 joyce.j 1.41 #include <Pegasus/Common/System.h>
|
38 kumpf 1.51 #include <Pegasus/Common/LanguageParser.h>
|
39 kumpf 1.1
40 #include <iostream>
41 #include <fstream>
|
42 mike 1.55 #include <Pegasus/Common/Network.h>
|
43 kumpf 1.1
44 PEGASUS_USING_STD;
45
46 PEGASUS_NAMESPACE_BEGIN
47
48 ///////////////////////////////////////////////////////////////////////////////
49 //
50 // CIMClientRep
51 //
52 ///////////////////////////////////////////////////////////////////////////////
53
54 CIMClientRep::CIMClientRep(Uint32 timeoutMilliseconds)
55 :
56 MessageQueue(PEGASUS_QUEUENAME_CLIENT),
57 _timeoutMilliseconds(timeoutMilliseconds),
|
58 kumpf 1.61 _connected(false),
59 _doReconnect(false)
|
60 kumpf 1.1 {
61 //
62 // Create Monitor and HTTPConnector
63 //
|
64 a.arora 1.31 _monitor.reset(new Monitor());
65 _httpConnector.reset(new HTTPConnector(_monitor.get()));
|
66 kumpf 1.1
|
67 kumpf 1.51 requestAcceptLanguages.clear();
68 requestContentLanguages.clear();
|
69 kumpf 1.1 }
70
71 CIMClientRep::~CIMClientRep()
72 {
73 disconnect();
74 }
75
76 void CIMClientRep::handleEnqueue()
77 {
78 }
79
80 Uint32 _getShowType(String& s)
81 {
82 String log = "log";
83 String con = "con";
84 String both = "both";
85 if (s == log)
|
86 tony 1.7 return 2;
87 if (s == con)
|
88 karl 1.6 return 1;
|
89 kumpf 1.1 if (s == both)
|
90 karl 1.6 return 3;
|
91 kumpf 1.1 return 0;
92 }
93
|
94 a.arora 1.32 void CIMClientRep::_connect()
|
95 kumpf 1.1 {
96 //
97 // Test for Display optons of the form
98 // Use Env variable PEGASUS_CLIENT_TRACE= <intrace> : <outtrace
99 // intrace = "con" | "log" | "both"
100 // outtrace = intrace
101 // ex set PEGASUS_CLIENT_TRACE=BOTH:BOTH traces input and output
102 // to console and log
103 // Keywords are case insensitive.
104 // PEP 90
105 //
106 Uint32 showOutput = 0;
107 Uint32 showInput = 0;
108 #ifdef PEGASUS_CLIENT_TRACE_ENABLE
109 String input;
110 if (char * envVar = getenv("PEGASUS_CLIENT_TRACE"))
111 {
112 input = envVar;
113 input.toLower();
|
114 kumpf 1.63 String io;
|
115 kumpf 1.1 Uint32 pos = input.find(':');
116 if (pos == PEG_NOT_FOUND)
117 pos = 0;
118 else
119 io = input.subString(0,pos);
120
|
121 tony 1.5 // some compilers do not allow temporaries to be passed to a
122 // reference argument - so break into 2 lines
123 String out = input.subString(pos + 1);
124 showOutput = _getShowType(out);
|
125 kumpf 1.1
126 showInput = _getShowType(io);
127 }
128 #endif
129
130 //
131 // Create response decoder:
132 //
|
133 kumpf 1.60 AutoPtr<CIMOperationResponseDecoder> responseDecoder(
134 new CIMOperationResponseDecoder(
135 this, _requestEncoder.get(), &_authenticator, showInput));
|
136 kumpf 1.1
137 //
138 // Attempt to establish a connection:
139 //
|
140 a.arora 1.31 AutoPtr<HTTPConnection> httpConnection(_httpConnector->connect(
|
141 kumpf 1.60 _connectHost,
142 _connectPortNumber,
143 _connectSSLContext.get(),
144 responseDecoder.get()));
|
145 david.dillard 1.42
|
146 kumpf 1.1 //
147 // Create request encoder:
148 //
|
149 kumpf 1.30 String connectHost = _connectHost;
150 if (connectHost.size())
151 {
152 char portStr[32];
153 sprintf(portStr, ":%u", _connectPortNumber);
154 connectHost.append(portStr);
155 }
156
|
157 kumpf 1.60 AutoPtr<CIMOperationRequestEncoder> requestEncoder(
158 new CIMOperationRequestEncoder(
|
159 a.arora 1.31 httpConnection.get(), connectHost, &_authenticator, showOutput));
|
160 david.dillard 1.42
|
161 a.arora 1.31 _responseDecoder.reset(responseDecoder.release());
|
162 denise.eckstein 1.46 _httpConnection = httpConnection.release();
|
163 a.arora 1.31 _requestEncoder.reset(requestEncoder.release());
164 _responseDecoder->setEncoderQueue(_requestEncoder.get());
|
165 kumpf 1.60
166 //pass encoder and decoder a pointer to CIMClientRep::perfDataStore
|
167 a.dunfey 1.53 _requestEncoder->setDataStorePointer(&perfDataStore);
168 _responseDecoder->setDataStorePointer(&perfDataStore);
169
|
170 kumpf 1.61 _doReconnect = false;
|
171 kumpf 1.1 _connected = true;
|
172 marek 1.56 _httpConnection->setSocketWriteTimeout(_timeoutMilliseconds/1000+1);
|
173 kumpf 1.1 }
174
|
175 kumpf 1.8 void CIMClientRep::_disconnect()
176 {
177 if (_connected)
178 {
179 //
180 // destroy response decoder
181 //
|
182 a.arora 1.31 _responseDecoder.reset();
|
183 david.dillard 1.42
|
184 kumpf 1.8
185 //
186 // Close the connection
187 //
|
188 a.arora 1.31 if (_httpConnector.get())
|
189 kumpf 1.8 {
|
190 denise.eckstein 1.46 _httpConnector->disconnect(_httpConnection);
191 _httpConnection = 0;
|
192 kumpf 1.8 }
193
194 //
195 // destroy request encoder
196 //
|
197 a.arora 1.31 _requestEncoder.reset();
|
198 kumpf 1.8
199 _connected = false;
200 }
201
|
202 kumpf 1.61 // Reconnect no longer applies
203 _doReconnect = false;
204
205 // Let go of the cached request message if we have one
206 _authenticator.setRequestMessage(0);
|
207 kumpf 1.1 }
208
209 void CIMClientRep::connect(
210 const String& host,
211 const Uint32 portNumber,
212 const String& userName,
|
213 kumpf 1.60 const String& password)
|
214 kumpf 1.1 {
215 //
216 // If already connected, bail out!
217 //
218 if (_connected)
219 throw AlreadyConnectedException();
220
221 //
222 // If the host is empty, set hostName to "localhost"
223 //
224 String hostName = host;
225 if (host == String::EMPTY)
226 {
227 hostName = "localhost";
228 }
229
230 //
231 // Set authentication information
232 //
|
233 kumpf 1.8 _authenticator.clear();
|
234 kumpf 1.1
235 if (userName.size())
236 {
237 _authenticator.setUserName(userName);
238 }
239
240 if (password.size())
241 {
242 _authenticator.setPassword(password);
243 }
244
|
245 a.arora 1.31 _connectSSLContext.reset();
|
246 kumpf 1.1 _connectHost = hostName;
247 _connectPortNumber = portNumber;
248
|
249 a.arora 1.32 _connect();
|
250 kumpf 1.1 }
251
252
253 void CIMClientRep::connect(
254 const String& host,
255 const Uint32 portNumber,
256 const SSLContext& sslContext,
257 const String& userName,
|
258 kumpf 1.60 const String& password)
|
259 kumpf 1.1 {
260 //
261 // If already connected, bail out!
262 //
263 if (_connected)
264 throw AlreadyConnectedException();
265
266 //
267 // If the host is empty, set hostName to "localhost"
268 //
269 String hostName = host;
270 if (host == String::EMPTY)
271 {
272 hostName = "localhost";
273 }
274
275 //
276 // Set authentication information
277 //
|
278 kumpf 1.8 _authenticator.clear();
|
279 kumpf 1.1
280 if (userName.size())
281 {
282 _authenticator.setUserName(userName);
283 }
284
285 if (password.size())
286 {
287 _authenticator.setPassword(password);
288 }
289
290 _connectHost = hostName;
291 _connectPortNumber = portNumber;
292
|
293 a.arora 1.32 _connectSSLContext.reset(new SSLContext(sslContext));
294 _connect();
|
295 kumpf 1.1 }
296
297
298 void CIMClientRep::connectLocal()
299 {
300 //
301 // If already connected, bail out!
302 //
303 if (_connected)
304 throw AlreadyConnectedException();
305
306 //
307 // Set authentication type
308 //
|
309 kumpf 1.8 _authenticator.clear();
|
310 kumpf 1.1 _authenticator.setAuthType(ClientAuthenticator::LOCAL);
311
|
312 h.sterling 1.43 #ifndef PEGASUS_DISABLE_LOCAL_DOMAIN_SOCKET
|
313 a.arora 1.31 _connectSSLContext.reset();
|
314 kumpf 1.30 _connectHost = String::EMPTY;
315 _connectPortNumber = 0;
|
316 a.arora 1.32 _connect();
|
317 kumpf 1.1 #else
318
319 try
320 {
321 //
322 // Look up the WBEM HTTP port number for the local system
323 //
324 _connectPortNumber = System::lookupPort (WBEM_HTTP_SERVICE_NAME,
325 WBEM_DEFAULT_HTTP_PORT);
326
327 //
328 // Assign host
329 //
|
330 kumpf 1.61 _connectHost.assign(System::getHostName());
|
331 kumpf 1.1
|
332 a.arora 1.31 _connectSSLContext.reset();
|
333 kumpf 1.1
|
334 a.arora 1.32 _connect();
|
335 kumpf 1.1 }
|
336 kumpf 1.60 catch (const CannotConnectException &)
|
337 kumpf 1.1 {
338 //
339 // Look up the WBEM HTTPS port number for the local system
340 //
341 _connectPortNumber = System::lookupPort (WBEM_HTTPS_SERVICE_NAME,
342 WBEM_DEFAULT_HTTPS_PORT);
343
344 //
345 // Assign host
346 //
|
347 kumpf 1.61 _connectHost.assign(System::getHostName());
|
348 kumpf 1.1
349 //
350 // Create SSLContext
351 //
352 const char* pegasusHome = getenv("PEGASUS_HOME");
353
|
354 kumpf 1.63 String randFile;
|
355 kumpf 1.1
356 #ifdef PEGASUS_SSL_RANDOMFILE
357 randFile = FileSystem::getAbsolutePath(
358 pegasusHome, PEGASUS_SSLCLIENT_RANDOMFILE);
359 #endif
360
361 try
362 {
|
363 a.arora 1.32 _connectSSLContext.reset(
|
364 kumpf 1.28 new SSLContext(String::EMPTY, NULL, randFile));
|
365 kumpf 1.1 }
|
366 david.dillard 1.44 catch (const SSLException &)
|
367 kumpf 1.1 {
|
368 david.dillard 1.44 throw;
|
369 kumpf 1.1 }
370
|
371 a.arora 1.32 _connect();
|
372 kumpf 1.1 }
373 #endif
374 }
375
376
377 void CIMClientRep::disconnect()
378 {
|
379 kumpf 1.8 _disconnect();
380 _authenticator.clear();
|
381 kumpf 1.28 _connectSSLContext.reset();
|
382 kumpf 1.8 }
|
383 kumpf 1.1
|
384 david.dillard 1.42 Boolean CIMClientRep::isConnected() const throw()
|
385 marek 1.21 {
|
386 david.dillard 1.42 return _connected;
|
387 marek 1.21 }
388
|
389 kumpf 1.52 AcceptLanguageList CIMClientRep::getRequestAcceptLanguages() const
|
390 kumpf 1.1 {
391 return requestAcceptLanguages;
392 }
393
|
394 kumpf 1.52 ContentLanguageList CIMClientRep::getRequestContentLanguages() const
|
395 kumpf 1.1 {
396 return requestContentLanguages;
397 }
398
|
399 kumpf 1.52 ContentLanguageList CIMClientRep::getResponseContentLanguages() const
|
400 kumpf 1.1 {
401 return responseContentLanguages;
402 }
403
|
404 kumpf 1.52 void CIMClientRep::setRequestAcceptLanguages(const AcceptLanguageList& langs)
|
405 kumpf 1.1 {
406 requestAcceptLanguages = langs;
407 }
408
|
409 kumpf 1.52 void CIMClientRep::setRequestContentLanguages(const ContentLanguageList& langs)
|
410 kumpf 1.1 {
411 requestContentLanguages = langs;
412 }
413
414 void CIMClientRep::setRequestDefaultLanguages()
415 {
|
416 kumpf 1.51 requestAcceptLanguages = LanguageParser::getDefaultAcceptLanguages();
|
417 kumpf 1.1 }
418
419 CIMClass CIMClientRep::getClass(
420 const CIMNamespaceName& nameSpace,
421 const CIMName& className,
422 Boolean localOnly,
423 Boolean includeQualifiers,
424 Boolean includeClassOrigin,
|
425 kumpf 1.60 const CIMPropertyList& propertyList)
|
426 kumpf 1.1 {
|
427 a.arora 1.31 AutoPtr<CIMRequestMessage> request(new CIMGetClassRequestMessage(
|
428 kumpf 1.1 String::EMPTY,
429 nameSpace,
430 className,
431 localOnly,
432 includeQualifiers,
433 includeClassOrigin,
434 propertyList,
|
435 a.arora 1.31 QueueIdStack()));
|
436 kumpf 1.1
437 Message* message = _doRequest(request, CIM_GET_CLASS_RESPONSE_MESSAGE);
438
439 CIMGetClassResponseMessage* response =
440 (CIMGetClassResponseMessage*)message;
441
|
442 a.arora 1.31 AutoPtr<CIMGetClassResponseMessage> destroyer(response);
|
443 kumpf 1.1
|
444 kumpf 1.60 return response->cimClass;
|
445 kumpf 1.1 }
446
447 CIMInstance CIMClientRep::getInstance(
448 const CIMNamespaceName& nameSpace,
449 const CIMObjectPath& instanceName,
450 Boolean localOnly,
451 Boolean includeQualifiers,
452 Boolean includeClassOrigin,
|
453 kumpf 1.60 const CIMPropertyList& propertyList)
|
454 kumpf 1.1 {
|
455 a.arora 1.31 AutoPtr<CIMRequestMessage> request(new CIMGetInstanceRequestMessage(
|
456 kumpf 1.1 String::EMPTY,
457 nameSpace,
458 instanceName,
459 localOnly,
460 includeQualifiers,
461 includeClassOrigin,
462 propertyList,
|
463 a.arora 1.31 QueueIdStack()));
|
464 kumpf 1.1
465 Message* message = _doRequest(request, CIM_GET_INSTANCE_RESPONSE_MESSAGE);
466
467 CIMGetInstanceResponseMessage* response =
468 (CIMGetInstanceResponseMessage*)message;
469
|
470 a.arora 1.31 AutoPtr<CIMGetInstanceResponseMessage> destroyer(response);
|
471 kumpf 1.1
|
472 kumpf 1.60 return response->cimInstance;
|
473 kumpf 1.1 }
474
475 void CIMClientRep::deleteClass(
476 const CIMNamespaceName& nameSpace,
|
477 kumpf 1.60 const CIMName& className)
|
478 kumpf 1.1 {
|
479 a.arora 1.31 AutoPtr<CIMRequestMessage> request(new CIMDeleteClassRequestMessage(
|
480 kumpf 1.1 String::EMPTY,
481 nameSpace,
482 className,
|
483 a.arora 1.31 QueueIdStack()));
|
484 kumpf 1.1
485 Message* message = _doRequest(request, CIM_DELETE_CLASS_RESPONSE_MESSAGE);
486
487 CIMDeleteClassResponseMessage* response =
488 (CIMDeleteClassResponseMessage*)message;
489
|
490 a.arora 1.31 AutoPtr<CIMDeleteClassResponseMessage> destroyer(response);
|
491 kumpf 1.1 }
492
493 void CIMClientRep::deleteInstance(
494 const CIMNamespaceName& nameSpace,
|
495 kumpf 1.60 const CIMObjectPath& instanceName)
|
496 kumpf 1.1 {
|
497 a.arora 1.31 AutoPtr<CIMRequestMessage> request(new CIMDeleteInstanceRequestMessage(
|
498 kumpf 1.1 String::EMPTY,
499 nameSpace,
500 instanceName,
|
501 a.arora 1.31 QueueIdStack()));
|
502 kumpf 1.1
|
503 kumpf 1.60 Message* message =
504 _doRequest(request, CIM_DELETE_INSTANCE_RESPONSE_MESSAGE);
|
505 kumpf 1.1
506 CIMDeleteInstanceResponseMessage* response =
507 (CIMDeleteInstanceResponseMessage*)message;
508
|
509 a.arora 1.31 AutoPtr<CIMDeleteInstanceResponseMessage> destroyer(response);
|
510 kumpf 1.1 }
511
512 void CIMClientRep::createClass(
513 const CIMNamespaceName& nameSpace,
|
514 kumpf 1.60 const CIMClass& newClass)
|
515 kumpf 1.1 {
|
516 a.arora 1.31 AutoPtr<CIMRequestMessage> request(new CIMCreateClassRequestMessage(
|
517 kumpf 1.1 String::EMPTY,
518 nameSpace,
519 newClass,
|
520 a.arora 1.31 QueueIdStack()));
|
521 kumpf 1.1
522 Message* message = _doRequest(request, CIM_CREATE_CLASS_RESPONSE_MESSAGE);
523
524 CIMCreateClassResponseMessage* response =
525 (CIMCreateClassResponseMessage*)message;
526
|
527 a.arora 1.31 AutoPtr<CIMCreateClassResponseMessage> destroyer(response);
|
528 kumpf 1.1 }
529
530 CIMObjectPath CIMClientRep::createInstance(
531 const CIMNamespaceName& nameSpace,
|
532 kumpf 1.60 const CIMInstance& newInstance)
|
533 kumpf 1.1 {
|
534 a.arora 1.31 AutoPtr<CIMRequestMessage> request(new CIMCreateInstanceRequestMessage(
|
535 kumpf 1.1 String::EMPTY,
536 nameSpace,
537 newInstance,
|
538 a.arora 1.31 QueueIdStack()));
|
539 kumpf 1.1
|
540 kumpf 1.60 Message* message =
541 _doRequest(request, CIM_CREATE_INSTANCE_RESPONSE_MESSAGE);
|
542 kumpf 1.1
543 CIMCreateInstanceResponseMessage* response =
544 (CIMCreateInstanceResponseMessage*)message;
545
|
546 a.arora 1.31 AutoPtr<CIMCreateInstanceResponseMessage> destroyer(response);
|
547 kumpf 1.1
|
548 kumpf 1.60 return response->instanceName;
|
549 kumpf 1.1 }
550
551 void CIMClientRep::modifyClass(
552 const CIMNamespaceName& nameSpace,
|
553 kumpf 1.60 const CIMClass& modifiedClass)
|
554 kumpf 1.1 {
|
555 a.arora 1.31 AutoPtr<CIMRequestMessage> request(new CIMModifyClassRequestMessage(
|
556 kumpf 1.1 String::EMPTY,
557 nameSpace,
558 modifiedClass,
|
559 a.arora 1.31 QueueIdStack()));
|
560 kumpf 1.1
561 Message* message = _doRequest(request, CIM_MODIFY_CLASS_RESPONSE_MESSAGE);
562
563 CIMModifyClassResponseMessage* response =
564 (CIMModifyClassResponseMessage*)message;
565
|
566 a.arora 1.31 AutoPtr<CIMModifyClassResponseMessage> destroyer(response);
|
567 kumpf 1.1 }
568
569 void CIMClientRep::modifyInstance(
570 const CIMNamespaceName& nameSpace,
571 const CIMInstance& modifiedInstance,
572 Boolean includeQualifiers,
|
573 kumpf 1.60 const CIMPropertyList& propertyList)
|
574 kumpf 1.1 {
|
575 a.arora 1.31 AutoPtr<CIMRequestMessage> request(new CIMModifyInstanceRequestMessage(
|
576 kumpf 1.1 String::EMPTY,
577 nameSpace,
578 modifiedInstance,
579 includeQualifiers,
580 propertyList,
|
581 a.arora 1.31 QueueIdStack()));
|
582 kumpf 1.1
|
583 kumpf 1.60 Message* message =
584 _doRequest(request, CIM_MODIFY_INSTANCE_RESPONSE_MESSAGE);
|
585 kumpf 1.1
586 CIMModifyInstanceResponseMessage* response =
587 (CIMModifyInstanceResponseMessage*)message;
588
|
589 a.arora 1.31 AutoPtr<CIMModifyInstanceResponseMessage> destroyer(response);
|
590 kumpf 1.1 }
591
592 Array<CIMClass> CIMClientRep::enumerateClasses(
593 const CIMNamespaceName& nameSpace,
594 const CIMName& className,
595 Boolean deepInheritance,
596 Boolean localOnly,
597 Boolean includeQualifiers,
|
598 kumpf 1.60 Boolean includeClassOrigin)
|
599 kumpf 1.1 {
|
600 a.arora 1.31 AutoPtr<CIMRequestMessage> request(new CIMEnumerateClassesRequestMessage(
|
601 kumpf 1.1 String::EMPTY,
602 nameSpace,
603 className,
604 deepInheritance,
605 localOnly,
606 includeQualifiers,
607 includeClassOrigin,
|
608 a.arora 1.31 QueueIdStack()));
|
609 kumpf 1.1
|
610 kumpf 1.60 Message* message =
611 _doRequest(request, CIM_ENUMERATE_CLASSES_RESPONSE_MESSAGE);
|
612 kumpf 1.1
613 CIMEnumerateClassesResponseMessage* response =
614 (CIMEnumerateClassesResponseMessage*)message;
615
|
616 a.arora 1.31 AutoPtr<CIMEnumerateClassesResponseMessage> destroyer(response);
|
617 kumpf 1.1
|
618 kumpf 1.60 return response->cimClasses;
|
619 kumpf 1.1 }
620
621 Array<CIMName> CIMClientRep::enumerateClassNames(
622 const CIMNamespaceName& nameSpace,
623 const CIMName& className,
|
624 kumpf 1.60 Boolean deepInheritance)
|
625 kumpf 1.1 {
|
626 a.arora 1.31 AutoPtr<CIMRequestMessage> request(new CIMEnumerateClassNamesRequestMessage(
|
627 kumpf 1.1 String::EMPTY,
628 nameSpace,
629 className,
630 deepInheritance,
|
631 a.arora 1.31 QueueIdStack()));
|
632 kumpf 1.1
|
633 kumpf 1.60 Message* message =
634 _doRequest(request, CIM_ENUMERATE_CLASS_NAMES_RESPONSE_MESSAGE);
|
635 kumpf 1.1
636 CIMEnumerateClassNamesResponseMessage* response =
637 (CIMEnumerateClassNamesResponseMessage*)message;
638
|
639 a.arora 1.31 AutoPtr<CIMEnumerateClassNamesResponseMessage> destroyer(response);
|
640 kumpf 1.1
641 // Temporary code until internal structures use CIMName instead of String
642 Array<CIMName> classNameArray;
643 classNameArray.reserveCapacity(response->classNames.size());
644 for (Uint32 i=0; i<response->classNames.size(); i++)
645 {
646 classNameArray.append(response->classNames[i]);
647 }
|
648 kumpf 1.60 return classNameArray;
|
649 kumpf 1.1 }
650
651 Array<CIMInstance> CIMClientRep::enumerateInstances(
652 const CIMNamespaceName& nameSpace,
653 const CIMName& className,
654 Boolean deepInheritance,
655 Boolean localOnly,
656 Boolean includeQualifiers,
657 Boolean includeClassOrigin,
|
658 kumpf 1.60 const CIMPropertyList& propertyList)
|
659 kumpf 1.1 {
|
660 a.arora 1.31 AutoPtr<CIMRequestMessage> request(new CIMEnumerateInstancesRequestMessage(
|
661 kumpf 1.1 String::EMPTY,
662 nameSpace,
663 className,
664 deepInheritance,
665 localOnly,
666 includeQualifiers,
667 includeClassOrigin,
668 propertyList,
|
669 a.arora 1.31 QueueIdStack()));
|
670 kumpf 1.1
|
671 kumpf 1.60 Message* message =
672 _doRequest(request, CIM_ENUMERATE_INSTANCES_RESPONSE_MESSAGE);
|
673 kumpf 1.1
674 CIMEnumerateInstancesResponseMessage* response =
675 (CIMEnumerateInstancesResponseMessage*)message;
676
|
677 a.arora 1.31 AutoPtr<CIMEnumerateInstancesResponseMessage> destroyer(response);
|
678 kumpf 1.1
|
679 kumpf 1.60 return response->cimNamedInstances;
|
680 kumpf 1.1 }
681
682 Array<CIMObjectPath> CIMClientRep::enumerateInstanceNames(
683 const CIMNamespaceName& nameSpace,
|
684 kumpf 1.60 const CIMName& className)
|
685 kumpf 1.1 {
|
686 kumpf 1.60 AutoPtr<CIMRequestMessage> request(
687 new CIMEnumerateInstanceNamesRequestMessage(
688 String::EMPTY,
689 nameSpace,
690 className,
691 QueueIdStack()));
|
692 kumpf 1.1
|
693 kumpf 1.60 Message* message =
694 _doRequest(request, CIM_ENUMERATE_INSTANCE_NAMES_RESPONSE_MESSAGE);
|
695 kumpf 1.1
696 CIMEnumerateInstanceNamesResponseMessage* response =
697 (CIMEnumerateInstanceNamesResponseMessage*)message;
698
|
699 a.arora 1.31 AutoPtr<CIMEnumerateInstanceNamesResponseMessage> destroyer(response);
|
700 kumpf 1.1
|
701 kumpf 1.60 return response->instanceNames;
|
702 kumpf 1.1 }
703
704 Array<CIMObject> CIMClientRep::execQuery(
705 const CIMNamespaceName& nameSpace,
706 const String& queryLanguage,
|
707 kumpf 1.60 const String& query)
|
708 kumpf 1.1 {
|
709 a.arora 1.31 AutoPtr<CIMRequestMessage> request(new CIMExecQueryRequestMessage(
|
710 kumpf 1.1 String::EMPTY,
711 nameSpace,
712 queryLanguage,
713 query,
|
714 a.arora 1.31 QueueIdStack()));
|
715 kumpf 1.1
716 Message* message = _doRequest(request, CIM_EXEC_QUERY_RESPONSE_MESSAGE);
717
718 CIMExecQueryResponseMessage* response =
719 (CIMExecQueryResponseMessage*)message;
720
|
721 a.arora 1.31 AutoPtr<CIMExecQueryResponseMessage> destroyer(response);
|
722 kumpf 1.1
|
723 kumpf 1.60 return response->cimObjects;
|
724 kumpf 1.1 }
725
726 Array<CIMObject> CIMClientRep::associators(
727 const CIMNamespaceName& nameSpace,
728 const CIMObjectPath& objectName,
729 const CIMName& assocClass,
730 const CIMName& resultClass,
731 const String& role,
732 const String& resultRole,
733 Boolean includeQualifiers,
734 Boolean includeClassOrigin,
|
735 kumpf 1.60 const CIMPropertyList& propertyList)
|
736 kumpf 1.1 {
|
737 a.arora 1.31 AutoPtr<CIMRequestMessage> request(new CIMAssociatorsRequestMessage(
|
738 kumpf 1.1 String::EMPTY,
739 nameSpace,
740 objectName,
741 assocClass,
742 resultClass,
743 role,
744 resultRole,
745 includeQualifiers,
746 includeClassOrigin,
747 propertyList,
|
748 a.arora 1.31 QueueIdStack()));
|
749 kumpf 1.1
750 Message* message = _doRequest(request, CIM_ASSOCIATORS_RESPONSE_MESSAGE);
751
752 CIMAssociatorsResponseMessage* response =
753 (CIMAssociatorsResponseMessage*)message;
754
|
755 a.arora 1.31 AutoPtr<CIMAssociatorsResponseMessage> destroyer(response);
|
756 kumpf 1.1
|
757 kumpf 1.60 return response->cimObjects;
|
758 kumpf 1.1 }
759
760 Array<CIMObjectPath> CIMClientRep::associatorNames(
761 const CIMNamespaceName& nameSpace,
762 const CIMObjectPath& objectName,
763 const CIMName& assocClass,
764 const CIMName& resultClass,
765 const String& role,
|
766 kumpf 1.60 const String& resultRole)
|
767 kumpf 1.1 {
|
768 a.arora 1.31 AutoPtr<CIMRequestMessage> request(new CIMAssociatorNamesRequestMessage(
|
769 kumpf 1.1 String::EMPTY,
770 nameSpace,
771 objectName,
772 assocClass,
773 resultClass,
774 role,
775 resultRole,
|
776 a.arora 1.31 QueueIdStack()));
|
777 kumpf 1.1
|
778 kumpf 1.60 Message* message =
779 _doRequest(request, CIM_ASSOCIATOR_NAMES_RESPONSE_MESSAGE);
|
780 kumpf 1.1
781 CIMAssociatorNamesResponseMessage* response =
782 (CIMAssociatorNamesResponseMessage*)message;
783
|
784 a.arora 1.31 AutoPtr<CIMAssociatorNamesResponseMessage> destroyer(response);
|
785 kumpf 1.1
|
786 kumpf 1.60 return response->objectNames;
|
787 kumpf 1.1 }
788
789 Array<CIMObject> CIMClientRep::references(
790 const CIMNamespaceName& nameSpace,
791 const CIMObjectPath& objectName,
792 const CIMName& resultClass,
793 const String& role,
794 Boolean includeQualifiers,
795 Boolean includeClassOrigin,
|
796 kumpf 1.60 const CIMPropertyList& propertyList)
|
797 kumpf 1.1 {
|
798 a.arora 1.31 AutoPtr<CIMRequestMessage> request(new CIMReferencesRequestMessage(
|
799 kumpf 1.1 String::EMPTY,
800 nameSpace,
801 objectName,
802 resultClass,
803 role,
804 includeQualifiers,
805 includeClassOrigin,
806 propertyList,
|
807 a.arora 1.31 QueueIdStack()));
|
808 kumpf 1.1
809 Message* message = _doRequest(request, CIM_REFERENCES_RESPONSE_MESSAGE);
810
811 CIMReferencesResponseMessage* response =
812 (CIMReferencesResponseMessage*)message;
813
|
814 a.arora 1.31 AutoPtr<CIMReferencesResponseMessage> destroyer(response);
|
815 kumpf 1.1
|
816 kumpf 1.60 return response->cimObjects;
|
817 kumpf 1.1 }
818
819 Array<CIMObjectPath> CIMClientRep::referenceNames(
820 const CIMNamespaceName& nameSpace,
821 const CIMObjectPath& objectName,
822 const CIMName& resultClass,
|
823 kumpf 1.60 const String& role)
|
824 kumpf 1.1 {
|
825 a.arora 1.31 AutoPtr<CIMRequestMessage> request(new CIMReferenceNamesRequestMessage(
|
826 kumpf 1.1 String::EMPTY,
827 nameSpace,
828 objectName,
829 resultClass,
830 role,
|
831 a.arora 1.31 QueueIdStack()));
|
832 kumpf 1.1
|
833 kumpf 1.60 Message* message =
834 _doRequest(request, CIM_REFERENCE_NAMES_RESPONSE_MESSAGE);
|
835 kumpf 1.1
836 CIMReferenceNamesResponseMessage* response =
837 (CIMReferenceNamesResponseMessage*)message;
838
|
839 a.arora 1.31 AutoPtr<CIMReferenceNamesResponseMessage> destroyer(response);
|
840 kumpf 1.1
|
841 kumpf 1.60 return response->objectNames;
|
842 kumpf 1.1 }
843
844 CIMValue CIMClientRep::getProperty(
845 const CIMNamespaceName& nameSpace,
846 const CIMObjectPath& instanceName,
|
847 kumpf 1.60 const CIMName& propertyName)
|
848 kumpf 1.1 {
|
849 a.arora 1.31 AutoPtr<CIMRequestMessage> request(new CIMGetPropertyRequestMessage(
|
850 kumpf 1.1 String::EMPTY,
851 nameSpace,
852 instanceName,
853 propertyName,
|
854 a.arora 1.31 QueueIdStack()));
|
855 kumpf 1.1
856 Message* message = _doRequest(request, CIM_GET_PROPERTY_RESPONSE_MESSAGE);
857
858 CIMGetPropertyResponseMessage* response =
859 (CIMGetPropertyResponseMessage*)message;
860
|
861 a.arora 1.31 AutoPtr<CIMGetPropertyResponseMessage> destroyer(response);
|
862 kumpf 1.1
|
863 kumpf 1.60 return response->value;
|
864 kumpf 1.1 }
865
866 void CIMClientRep::setProperty(
867 const CIMNamespaceName& nameSpace,
868 const CIMObjectPath& instanceName,
869 const CIMName& propertyName,
|
870 kumpf 1.60 const CIMValue& newValue)
|
871 kumpf 1.1 {
|
872 a.arora 1.31 AutoPtr<CIMRequestMessage> request(new CIMSetPropertyRequestMessage(
|
873 kumpf 1.1 String::EMPTY,
874 nameSpace,
875 instanceName,
876 propertyName,
877 newValue,
|
878 a.arora 1.31 QueueIdStack()));
|
879 kumpf 1.1
880 Message* message = _doRequest(request, CIM_SET_PROPERTY_RESPONSE_MESSAGE);
881
882 CIMSetPropertyResponseMessage* response =
883 (CIMSetPropertyResponseMessage*)message;
884
|
885 a.arora 1.31 AutoPtr<CIMSetPropertyResponseMessage> destroyer(response);
|
886 kumpf 1.1 }
887
888 CIMQualifierDecl CIMClientRep::getQualifier(
889 const CIMNamespaceName& nameSpace,
|
890 kumpf 1.60 const CIMName& qualifierName)
|
891 kumpf 1.1 {
|
892 a.arora 1.31 AutoPtr<CIMRequestMessage> request(new CIMGetQualifierRequestMessage(
|
893 kumpf 1.1 String::EMPTY,
894 nameSpace,
895 qualifierName,
|
896 a.arora 1.31 QueueIdStack()));
|
897 kumpf 1.1
898 Message* message = _doRequest(request, CIM_GET_QUALIFIER_RESPONSE_MESSAGE);
899
900 CIMGetQualifierResponseMessage* response =
901 (CIMGetQualifierResponseMessage*)message;
902
|
903 a.arora 1.31 AutoPtr<CIMGetQualifierResponseMessage> destroyer(response);
|
904 kumpf 1.1
|
905 kumpf 1.60 return response->cimQualifierDecl;
|
906 kumpf 1.1 }
907
908 void CIMClientRep::setQualifier(
909 const CIMNamespaceName& nameSpace,
|
910 kumpf 1.60 const CIMQualifierDecl& qualifierDeclaration)
|
911 kumpf 1.1 {
|
912 a.arora 1.31 AutoPtr<CIMRequestMessage> request(new CIMSetQualifierRequestMessage(
|
913 kumpf 1.1 String::EMPTY,
914 nameSpace,
915 qualifierDeclaration,
|
916 a.arora 1.31 QueueIdStack()));
|
917 kumpf 1.1
918 Message* message = _doRequest(request, CIM_SET_QUALIFIER_RESPONSE_MESSAGE);
919
920 CIMSetQualifierResponseMessage* response =
921 (CIMSetQualifierResponseMessage*)message;
922
|
923 a.arora 1.31 AutoPtr<CIMSetQualifierResponseMessage> destroyer(response);
|
924 kumpf 1.1 }
925
926 void CIMClientRep::deleteQualifier(
927 const CIMNamespaceName& nameSpace,
|
928 kumpf 1.60 const CIMName& qualifierName)
|
929 kumpf 1.1 {
|
930 a.arora 1.31 AutoPtr<CIMRequestMessage> request(new CIMDeleteQualifierRequestMessage(
|
931 kumpf 1.1 String::EMPTY,
932 nameSpace,
933 qualifierName,
|
934 a.arora 1.31 QueueIdStack()));
|
935 kumpf 1.1
|
936 kumpf 1.60 Message* message =
937 _doRequest(request, CIM_DELETE_QUALIFIER_RESPONSE_MESSAGE);
|
938 kumpf 1.1
939 CIMDeleteQualifierResponseMessage* response =
940 (CIMDeleteQualifierResponseMessage*)message;
941
|
942 a.arora 1.31 AutoPtr<CIMDeleteQualifierResponseMessage> destroyer(response);
|
943 kumpf 1.1 }
944
945 Array<CIMQualifierDecl> CIMClientRep::enumerateQualifiers(
|
946 kumpf 1.60 const CIMNamespaceName& nameSpace)
|
947 kumpf 1.1 {
|
948 a.arora 1.31 AutoPtr<CIMRequestMessage> request(new CIMEnumerateQualifiersRequestMessage(
|
949 kumpf 1.1 String::EMPTY,
950 nameSpace,
|
951 a.arora 1.31 QueueIdStack()));
|
952 kumpf 1.1
|
953 kumpf 1.60 Message* message =
954 _doRequest(request, CIM_ENUMERATE_QUALIFIERS_RESPONSE_MESSAGE);
|
955 kumpf 1.1
956 CIMEnumerateQualifiersResponseMessage* response =
957 (CIMEnumerateQualifiersResponseMessage*)message;
958
|
959 a.arora 1.31 AutoPtr<CIMEnumerateQualifiersResponseMessage> destroyer(response);
|
960 kumpf 1.1
|
961 kumpf 1.60 return response->qualifierDeclarations;
|
962 kumpf 1.1 }
963
964 CIMValue CIMClientRep::invokeMethod(
965 const CIMNamespaceName& nameSpace,
966 const CIMObjectPath& instanceName,
967 const CIMName& methodName,
968 const Array<CIMParamValue>& inParameters,
|
969 kumpf 1.60 Array<CIMParamValue>& outParameters)
|
970 kumpf 1.1 {
971 // ATTN-RK-P2-20020301: Does it make sense to have a nameSpace parameter
972 // when the namespace should already be included in the instanceName?
973 // ATTN-RK-P3-20020301: Do we need to make sure the caller didn't specify
974 // a host name in the instanceName?
975
|
976 david.dillard 1.42 // solved with PEP#139 Stage1 as other CIMOMs contained in the object path
977 // will cause a TypeMisMatchException
|
978 marek 1.12
|
979 a.arora 1.31 AutoPtr<CIMRequestMessage> request(new CIMInvokeMethodRequestMessage(
|
980 kumpf 1.1 String::EMPTY,
981 nameSpace,
982 instanceName,
983 methodName,
984 inParameters,
|
985 a.arora 1.31 QueueIdStack()));
|
986 kumpf 1.1
987 Message* message = _doRequest(request, CIM_INVOKE_METHOD_RESPONSE_MESSAGE);
988
989 CIMInvokeMethodResponseMessage* response =
990 (CIMInvokeMethodResponseMessage*)message;
991
|
992 a.arora 1.31 AutoPtr<CIMInvokeMethodResponseMessage> destroyer(response);
|
993 kumpf 1.1
994 outParameters = response->outParameters;
995
|
996 kumpf 1.60 return response->retValue;
|
997 kumpf 1.1 }
998
999 Message* CIMClientRep::_doRequest(
|
1000 a.arora 1.31 AutoPtr<CIMRequestMessage>& request,
|
1001 kumpf 1.65 MessageType expectedResponseMessageType)
|
1002 kumpf 1.1 {
|
1003 kumpf 1.61 if (!_connected && !_doReconnect)
|
1004 kumpf 1.1 {
1005 throw NotConnectedException();
1006 }
1007
|
1008 kumpf 1.61 if (_doReconnect)
1009 {
1010 _connect();
1011 _doReconnect = false;
1012 }
1013
|
1014 kumpf 1.1 String messageId = XmlWriter::getNextMessageId();
1015 const_cast<String &>(request->messageId) = messageId;
1016
|
1017 kumpf 1.8 _authenticator.setRequestMessage(0);
|
1018 kumpf 1.1
1019 // ATTN-RK-P2-20020416: We should probably clear out the queue first.
1020 PEGASUS_ASSERT(getCount() == 0); // Shouldn't be any messages in our queue
1021
1022 //
|
1023 karl 1.2 // Set HTTP method in request to POST
|
1024 kumpf 1.1 //
|
1025 david.dillard 1.42 //Bug 478/418 - Change this to do post call, not mpost
|
1026 karl 1.2 request->setHttpMethod (HTTP_METHOD__POST);
|
1027 kumpf 1.1
1028 // Set the Accept-Languages and Content-Languages into
1029 // the request message
1030
|
1031 kumpf 1.60 request->operationContext.set(
1032 AcceptLanguageListContainer(requestAcceptLanguages));
1033 request->operationContext.set(
1034 ContentLanguageListContainer(requestContentLanguages));
|
1035 se.gupta 1.22
1036
|
1037 kumpf 1.60 //gathering statistical information about client operation
1038 perfDataStore.reset();
1039 perfDataStore.setOperationType(request->getType());
1040 perfDataStore.setMessageID(request->messageId);
|
1041 w.white 1.35
|
1042 kumpf 1.1 // Sending a new request, so clear out the response Content-Languages
|
1043 kumpf 1.51 responseContentLanguages.clear();
|
1044 kumpf 1.1
|
1045 a.arora 1.32 _requestEncoder->enqueue(request.get());
1046 request.release();
|
1047 kumpf 1.1
1048 Uint64 startMilliseconds = TimeValue::getCurrentTime().toMilliseconds();
1049 Uint64 nowMilliseconds = startMilliseconds;
1050 Uint64 stopMilliseconds = nowMilliseconds + _timeoutMilliseconds;
1051
1052 while (nowMilliseconds < stopMilliseconds)
1053 {
1054 //
1055 // Wait until the timeout expires or an event occurs:
1056 //
|
1057 kumpf 1.34 _monitor->run(Uint32(stopMilliseconds - nowMilliseconds));
|
1058 kumpf 1.1
1059 //
1060 // Check to see if incoming queue has a message
1061 //
1062
|
1063 kumpf 1.61 AutoPtr<Message> response(dequeue());
|
1064 kumpf 1.1
|
1065 kumpf 1.61 if (response.get())
|
1066 kumpf 1.1 {
1067 // Shouldn't be any more messages in our queue
1068 PEGASUS_ASSERT(getCount() == 0);
1069
1070 //
|
1071 kumpf 1.61 // Close the connection if response contained a "Connection: Close"
1072 // header (e.g. at authentication challenge)
|
1073 j.alex 1.47 //
|
1074 kumpf 1.60 if (response->getCloseConnect() == true)
1075 {
|
1076 kumpf 1.61 _disconnect();
1077 _doReconnect = true;
|
1078 j.alex 1.48 response->setCloseConnect(false);
|
1079 j.alex 1.47 }
1080
1081 //
|
1082 kumpf 1.4 // Future: If M-POST is used and HTTP response is 501 Not
1083 // Implemented or 510 Not Extended, retry with POST method
|
1084 kumpf 1.1 //
1085
1086 if (response->getType() == CLIENT_EXCEPTION_MESSAGE)
1087 {
1088 Exception* clientException =
|
1089 kumpf 1.61 ((ClientExceptionMessage*)response.get())->clientException;
|
1090 kumpf 1.4
|
1091 a.arora 1.31 AutoPtr<Exception> d(clientException);
|
1092 kumpf 1.4
|
1093 david.dillard 1.42 // Make the ContentLanguage of the exception available through
1094 // the CIMClient API (its also available in the exception).
|
1095 kumpf 1.60 responseContentLanguages =
1096 clientException->getContentLanguages();
|
1097 chuck 1.27
|
1098 kumpf 1.4 //
1099 // Determine and throw the specific class of client exception
1100 //
1101
1102 CIMClientMalformedHTTPException* malformedHTTPException =
1103 dynamic_cast<CIMClientMalformedHTTPException*>(
1104 clientException);
1105 if (malformedHTTPException)
1106 {
1107 throw *malformedHTTPException;
1108 }
1109
1110 CIMClientHTTPErrorException* httpErrorException =
1111 dynamic_cast<CIMClientHTTPErrorException*>(
1112 clientException);
1113 if (httpErrorException)
1114 {
1115 throw *httpErrorException;
1116 }
1117
1118 CIMClientXmlException* xmlException =
1119 kumpf 1.4 dynamic_cast<CIMClientXmlException*>(clientException);
1120 if (xmlException)
1121 {
1122 throw *xmlException;
1123 }
1124
1125 CIMClientResponseException* responseException =
1126 dynamic_cast<CIMClientResponseException*>(clientException);
1127 if (responseException)
1128 {
1129 throw *responseException;
1130 }
1131
|
1132 david.dillard 1.42 CIMException* cimException =
|
1133 brian.campbell 1.25 dynamic_cast<CIMException*>(clientException);
1134 if (cimException)
1135 {
1136 throw *cimException;
1137 }
1138
|
1139 kumpf 1.1 throw *clientException;
1140 }
1141 else if (response->getType() == expectedResponseMessageType)
1142 {
|
1143 kumpf 1.61 CIMResponseMessage* cimResponse =
1144 (CIMResponseMessage*)response.get();
|
1145 kumpf 1.1
1146 if (cimResponse->messageId != messageId)
1147 {
1148 MessageLoaderParms mlParms(
1149 "Client.CIMClient.MISMATCHED_RESPONSE",
1150 "Mismatched response message ID: Got \"$0\", "
1151 "expected \"$1\".",
1152 cimResponse->messageId, messageId);
1153 String mlString(MessageLoader::getMessage(mlParms));
1154
1155 CIMClientResponseException responseException(mlString);
1156
1157 throw responseException;
1158 }
1159
|
1160 kumpf 1.60 // Get the Content-Languages from the response's
1161 // operationContext and make available through the
1162 // CIMClient API
1163 responseContentLanguages = ((ContentLanguageListContainer)
1164 cimResponse->operationContext.get(
1165 ContentLanguageListContainer::NAME)).getLanguages();
|
1166 kumpf 1.1
1167 if (cimResponse->cimException.getCode() != CIM_ERR_SUCCESS)
1168 {
|
1169 karl 1.59 CIMException cimException(cimResponse->cimException);
1170
|
1171 david.dillard 1.42 cimException.setContentLanguages(responseContentLanguages);
|
1172 kumpf 1.1 throw cimException;
1173 }
|
1174 w.white 1.37
|
1175 kumpf 1.60 // if execution gets here everytihng is working correctly
1176 // and a proper response was generated and received.
|
1177 w.white 1.37
|
1178 kumpf 1.60 // Check that client side statistics are valid before
1179 // handing them to the client application via a call back
1180 Boolean re_check = perfDataStore.checkMessageIDandType(
1181 cimResponse->messageId,
1182 cimResponse->getType());
1183
1184 if (re_check &&
1185 !perfDataStore.getStatError() &&
1186 perfDataStore.isClassRegistered())
|
1187 david.dillard 1.42 {
|
1188 kumpf 1.60 // If callback method throws an exception it will be seen
1189 // by the client no try/catch block is used here
1190 // intentionaly - because exceptions come from the client
1191 // application so client app. should handle them
1192 ClientOpPerformanceData item =
1193 perfDataStore.createPerfDataStruct();
1194 perfDataStore.handler_prt->handleClientOpPerformanceData(
1195 item);
|
1196 david.dillard 1.42
|
1197 w.white 1.37 }//end of if statmet that call the callback method
|
1198 kumpf 1.61 return response.release();
|
1199 kumpf 1.1 }
|
1200 kumpf 1.61 else if (dynamic_cast<CIMRequestMessage*>(response.get()) != 0)
|
1201 j.alex 1.48 {
|
1202 kumpf 1.61 //
1203 // Respond to an authentication challenge.
1204 // Reconnect if the connection was closed.
1205 //
1206 if (_doReconnect)
1207 {
1208 _connect();
1209 }
1210
1211 _requestEncoder->enqueue(response.release());
|
1212 j.alex 1.48 nowMilliseconds = TimeValue::getCurrentTime().toMilliseconds();
1213 stopMilliseconds = nowMilliseconds + _timeoutMilliseconds;
1214 continue;
1215 }
|
1216 kumpf 1.1 else
1217 {
1218 MessageLoaderParms mlParms(
|
1219 kumpf 1.60 "Client.CIMOperationResponseDecoder."
1220 "MISMATCHED_RESPONSE_TYPE",
|
1221 j.alex 1.48 "Mismatched response message type.");
|
1222 kumpf 1.1 String mlString(MessageLoader::getMessage(mlParms));
1223
1224 CIMClientResponseException responseException(mlString);
1225
1226 throw responseException;
1227 }
1228 }
1229
1230 nowMilliseconds = TimeValue::getCurrentTime().toMilliseconds();
1231 }
1232
1233 //
1234 // Reconnect to reset the connection (disregard late response)
1235 //
|
1236 kumpf 1.61
1237 _disconnect();
1238 _authenticator.resetChallengeStatus();
1239 _doReconnect = true;
|
1240 kumpf 1.1
1241 //
1242 // Throw timed out exception:
1243 //
1244 throw ConnectionTimeoutException();
1245 }
1246
|
1247 kumpf 1.60 void CIMClientRep::registerClientOpPerformanceDataHandler(
1248 ClientOpPerformanceDataHandler& handler)
|
1249 david.dillard 1.42 {
|
1250 kumpf 1.60 perfDataStore.handler_prt = &handler;
1251 perfDataStore.setClassRegistered(true);
|
1252 w.white 1.37 }
|
1253 david.dillard 1.42
|
1254 w.white 1.37 void CIMClientRep::deregisterClientOpPerformanceDataHandler()
1255 {
|
1256 a.dunfey 1.53 perfDataStore.handler_prt = NULL;
1257 perfDataStore.setClassRegistered(false);
|
1258 w.white 1.37 }
1259
|
1260 kumpf 1.1 PEGASUS_NAMESPACE_END
|
Return to
CIMClientRep.cpp
CVS log
Up to [Pegasus] / pegasus / src / Pegasus / Client