diff options
author | Varun Gudisena <vg411h@att.com> | 2017-08-30 20:49:32 -0500 |
---|---|---|
committer | Varun Gudisena <vg411h@att.com> | 2017-08-30 20:50:47 -0500 |
commit | cc9de9bc6803212f0233e0e1bf06aa63fe8b7a6a (patch) | |
tree | 7425883592f6cfe97c415f17ca80a0ba13041ce2 /src/main/cpp/loopingPostClient.cpp | |
parent | ffc0ccd5ab1ad5e6a5db2d674a4a6c30a31bc732 (diff) |
Add Initial Code Import
Intial Code import for dmaapClient
Issue-id: DMAAP-82
Change-Id: Ib627672d37e233b796619f93dd91f5caaf1592e4
Signed-off-by: Varun Gudisena <vg411h@att.com>
Diffstat (limited to 'src/main/cpp/loopingPostClient.cpp')
-rw-r--r-- | src/main/cpp/loopingPostClient.cpp | 92 |
1 files changed, 92 insertions, 0 deletions
diff --git a/src/main/cpp/loopingPostClient.cpp b/src/main/cpp/loopingPostClient.cpp new file mode 100644 index 0000000..1396eea --- /dev/null +++ b/src/main/cpp/loopingPostClient.cpp @@ -0,0 +1,92 @@ +/******************************************************************************* + * ============LICENSE_START======================================================= + * org.onap.dmaap + * ================================================================================ + * Copyright © 2017 AT&T Intellectual Property. All rights reserved. + * ================================================================================ + * Licensed under the Apache License, Version 2.0 (the "License"); + * you may not use this file except in compliance with the License. + * You may obtain a copy of the License at + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + * ============LICENSE_END========================================================= + * + * ECOMP is a trademark and service mark of AT&T Intellectual Property. + * + *******************************************************************************/ + +#include <stdio.h> +#include <ctime> +#include <string.h> +#include "cambria.h" + +const char* kAlarm = + "<EVENT>" + "<AGENT_ADDR>12.123.70.213</AGENT_ADDR>" + "<AGENT_RESOLVED>ptdor306me1.els-an.att.net</AGENT_RESOLVED>" + "<TIME_RECEIVED>1364716208</TIME_RECEIVED>" + " <PROTOCOL_VERSION>V1</PROTOCOL_VERSION>" + " <ENTERPRISE_LEN>9</ENTERPRISE_LEN>" + " <ENTERPRISE>.1.3.6.1.4.1.9.9.187</ENTERPRISE>" + " <GENERIC>6</GENERIC>" + " <SPECIFIC>2</SPECIFIC>" + " <COMMAND>167</COMMAND>" + " <REQUEST_ID>0</REQUEST_ID>" + " <ERROR_STATUS>0</ERROR_STATUS>" + " <ERROR_INDEX>0</ERROR_INDEX>" + " <AGENT_TIME_UP>1554393204</AGENT_TIME_UP>" + " <COMMUNITY_LEN>10</COMMUNITY_LEN>" + " <COMMUNITY>nidVeskaf0</COMMUNITY>" + " <VARBIND>" + " <VARBIND_OID>.1.3.6.1.2.1.15.3.1.14.32.4.52.58</VARBIND_OID>" + " <VARBIND_TYPE>OCTET_STRING_HEX</VARBIND_TYPE>" + " <VARBIND_VALUE>02 02 </VARBIND_VALUE>" + " </VARBIND>" + " <VARBIND>" + " <VARBIND_OID>.1.3.6.1.2.1.15.3.1.2.32.4.52.58</VARBIND_OID>" + " <VARBIND_TYPE>INTEGER</VARBIND_TYPE>" + " <VARBIND_VALUE>1</VARBIND_VALUE>" + " </VARBIND>" + " <VARBIND>" + " <VARBIND_OID>.1.3.6.1.4.1.9.9.187.1.2.1.1.7.32.4.52.58</VARBIND_OID>" + " <VARBIND_TYPE>OCTET_STRING_ASCII</VARBIND_TYPE>" + " <VARBIND_VALUE>peer in wrong AS</VARBIND_VALUE>" + " </VARBIND>" + " <VARBIND>" + " <VARBIND_OID>.1.3.6.1.4.1.9.9.187.1.2.1.1.8.32.4.52.58</VARBIND_OID>" + " <VARBIND_TYPE>INTEGER</VARBIND_TYPE>" + " <VARBIND_VALUE>4</VARBIND_VALUE>" + " </VARBIND>" + "</EVENT>"; + +int main ( int argc, const char* argv[] ) +{ + char** msgs = new char* [ 100 ]; + for ( int i=0; i<100; i++ ) + { + msgs[i] = new char [ ::strlen ( kAlarm + 1 ) ]; + ::strcpy ( msgs[i], kAlarm ); + } + + std::time_t start = std::time ( NULL ); + for ( int i=0; i<5000; i++ ) + { + ::cambriaSimpleSendMultiple ( "localhost", 8080, "topic", "streamName", (const char**)msgs, 100 ); + if ( i % 50 == 0 ) + { + std::time_t end = std::time ( NULL ); + double seconds = difftime ( end, start ); + ::printf ( "%.f seconds for %u posts.\n", seconds, i*100 ); + } + } + std::time_t end = std::time ( NULL ); + double seconds = difftime ( end, start ); + ::printf ( "%.f seconds for 1,000,000 posts.\n", seconds ); + + return 0; +} |