From d460316332913e2a0aa3c39e715b45e850879933 Mon Sep 17 00:00:00 2001 From: Alan Conway Date: Wed, 15 Aug 2007 14:56:51 +0000 Subject: * perftest/topic_publisher.cpp, topic_listener.cpp: Combined into a single preftest.cpp executable and moved to src/tests. New perftest: - Supports all client-side options (--host, --port etc.) - Can be run as producer (--listen), consumer (--publish) or both. - --count specifies number of messages (default 500000 as before) git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@566211 13f79535-47bb-0310-9956-ffa450edef68 --- qpid/cpp/perftest/topic_publisher.cpp | 188 ---------------------------------- 1 file changed, 188 deletions(-) delete mode 100644 qpid/cpp/perftest/topic_publisher.cpp (limited to 'qpid/cpp/perftest/topic_publisher.cpp') diff --git a/qpid/cpp/perftest/topic_publisher.cpp b/qpid/cpp/perftest/topic_publisher.cpp deleted file mode 100644 index 80815fb143..0000000000 --- a/qpid/cpp/perftest/topic_publisher.cpp +++ /dev/null @@ -1,188 +0,0 @@ -/* - * - * Licensed to the Apache Software Foundation (ASF) under one - * or more contributor license agreements. See the NOTICE file - * distributed with this work for additional information - * regarding copyright ownership. The ASF licenses this file - * to you 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. - * - */ - -/** - * Test hack code -- will upadte into a harness, work in progress - */ - -#include "qpid/QpidError.h" -#include "qpid/client/ClientChannel.h" -#include "qpid/client/Connection.h" -#include "qpid/client/ClientExchange.h" -#include "qpid/client/MessageListener.h" -#include "qpid/client/ClientQueue.h" -#include "qpid/sys/Monitor.h" -#include -#include "qpid/sys/Time.h" -#include -#include -#include -#include - -using namespace qpid::client; -using namespace qpid::sys; -using std::string; - - -bool done = 0; - - -struct timespec operator-(const struct timespec& lhs, const struct timespec& rhs) { - timespec r; - r.tv_nsec = lhs.tv_nsec - rhs.tv_nsec; - r.tv_sec = lhs.tv_sec - rhs.tv_sec; - if (r.tv_nsec < 0) { - r.tv_nsec += 1000000000; - r.tv_sec -= 1; - } - return r; -} - -std::ostream& operator<<(std::ostream& o, const struct timespec& ts) { - o << ts.tv_sec << "." << std::setw(9) << std::setfill('0') << std::right << ts.tv_nsec; - return o; -} - -double toDouble(const struct timespec& ts) { - return double(ts.tv_nsec)/1000000000 + ts.tv_sec; -} - -class Listener : public MessageListener{ - -void set_time() { - timespec ts; - if (::clock_gettime(CLOCK_REALTIME, &ts)) - std::cout << "Error" << std::endl; - startTime = ts; - } - -void print_time() { - timespec ts; - if (::clock_gettime(CLOCK_REALTIME, &ts)) - std::cout << "Error" << std::endl; - std::cout << "Total Time:" << ts-startTime << std::endl; - double rate = messageCount*2/toDouble(ts-startTime); - std::cout << "returned Messages:" << messageCount << std::endl; - std::cout << "round trip Rate:" << rate << std::endl; - } - - struct timespec startTime; - int messageCount; - - public: - - - Listener(int mcount): messageCount(mcount) { - set_time(); - } - - virtual void received(Message& msg) { - print_time(); - std::cout << "Message: " << msg.getData() << std::endl; - done = 1; - } - - ~Listener() { }; - - - - -}; - - -int main() { - Connection connection; - Channel channel; - Message msg; - try { - connection.open("127.0.0.1", 5672, "guest", "guest", "/test"); - connection.openChannel(channel); - channel.start(); - - string queueControl = "control"; - Queue response(queueControl); - channel.declareQueue(response); - channel.bind(Exchange::STANDARD_TOPIC_EXCHANGE, response, queueControl); - - string queueName ="queue01"; - string queueNameC =queueName+"-1"; - - // create publish queue - Queue publish(queueName); - channel.declareQueue(publish); - channel.bind(Exchange::STANDARD_TOPIC_EXCHANGE, publish, queueName); - - // create completion queue - Queue completion(queueNameC); - channel.declareQueue(completion); - channel.bind(Exchange::STANDARD_TOPIC_EXCHANGE, completion, queueNameC); - - // pass queue name - msg.setData(queueName); - channel.publish(msg, Exchange::STANDARD_TOPIC_EXCHANGE, queueControl); - - std::cout << "Setup return queue:"<< queueNameC << std::endl; - - int count = 500000; - Listener listener(count); - channel.consume(completion, queueNameC, &listener); - std::cout << "Setup consumer:"<< queueNameC << std::endl; - - - - - struct timespec startTime; - if (::clock_gettime(CLOCK_REALTIME, &startTime)) - std::cout << "Error" << std::endl; - - for (int i=0; i