You are viewing a plain text version of this content. The canonical link for it is here.
Posted to users@activemq.apache.org by # Lalit Nagpal # <la...@gmail.com> on 2006/09/06 12:16:05 UTC
Sockets not connecting ... Invalid handle returned
The following piece of code in the class SocketFactory.cpp is throwing
exceptions ....
BufferedSocket* socket = new BufferedSocket(tcpSocket,
inputBufferSize, outputBufferSize);
socket->connect( host.c_str(), port );
it returns an invalid handle actually. I can see the call coming in twice to
this piece of code (producer and then the consumer ... both are threaded and
do a join inside the main method). The second time the call comes in it
bombs.
Cant understand why this is happening ... any ideas on what could be the
reason.
I tried changing the port to 61614 for the broker and the code in the client
too ... did not work still ... same probs.
Any hint would be really useful.
--
View this message in context: http://www.nabble.com/Sockets-not-connecting-...-Invalid-handle-returned-tf2225941.html#a6168387
Sent from the ActiveMQ - User forum at Nabble.com.
RE: Sockets not connecting ... Invalid handle returned
Posted by # Lalit Nagpal # <la...@gmail.com>.
refer
tabish121 wrote:
>
>>
>> I am running it on vs .net 2003 ... could that be a problem then.
>> I built the lib file using maven and set the linker to this lib file.
>
> Could be, then again it might not. We are not building or testing with
> the VC 2003 compiler, there could be something there that is not
> compatible.
>
>>
>> I am running it on .net 2003
>>
>> As I wrote earlier .... an invalid handle is getting returned from
>> socket = SocketFactory::createSocket( properties );
>>
>> And then it throws an exception on this line
>> // Cast it to an IO transport so we can wire up the socket
>> // input and output streams.
>> IOTransport* ioTransport = dynamic_cast<IOTransport*>( next );
>
> I don't think this is really the problem, there is probably an exception
> happening before this line that screws things up. Generally the VC
> debugger will stop on the line after the line where the exception is.
> You should also examine the next pointer in the debugger to see what it
> is really pointing too, if its not an IOTransport, then something has
> gone terribly wrong.
>
>>
>> What could be the reasons of getting an invalid handle from the
> statement
>> socket = SocketFactory::createSocket( properties );
>
> There are many reasons; one being that Winsock is retarded. Like I said
> earlier, I would step through the tcpsocket connect() to see where the
> problem is occurring, there are several calls in there that could be
> breaking.
>
>>
>> Regards
>>
>> Lalit ....
>>
>> tabish121 wrote:
>> >
>> >
>> > Sounds like for whatever reason a socket can't be opened to the
> broker.
>> > You may have to step through the code in the tcpsocket::connect and
> see
>> > what line is failing.
>> >
>> > The code from the website builds and runs fine here, you may need to
>> > refresh your browser cache to see the latest, or go right to SVN and
> get
>> > it from the examples folder in activemq-cpp. There is a VC++ 2005
>> > project file in there as well. You can download 2005 for free, it
> may
>> > be worth it to try that and see if there is something in the
> settings
>> > that is different from yours.
>> >
>> >>
>> >> Tim,
>> >>
>> >> Actually my broker had gone down so i gave some wrong info ...
> problem
>> > is
>> >> something else, please go through this explanation of what i found.
>> >>
>> >> If you look at the main function in the activemq-cpp client given
> on
>> > our
>> >> site
>> >> I am just pasting it here now. It says.
>> >>
>> >> HelloWorldProducer producer( 1000 );
>> >> HelloWorldConsumer consumer( 5000 );
>> >>
>> >> // Start the consumer thread.
>> >> Thread consumerThread( &consumer );
>> >> consumerThread.start();
>> >>
>> >> // Start the producer thread.
>> >> Thread producerThread( &producer );
>> >> producerThread.start();
>> >>
>> >> // Wait for the threads to complete.
>> >> producerThread.join();
>> >> consumerThread.join();
>> >>
>> >> When I debug the call goes to
>> >> socket->connect( host, port ); // this is inside the
> class
>> >> bufferedsocket.cpp
>> >>
>> >> after this it executes the connect method inside the class
>> > tcpsocket.cpp
>> >> but when the call comes out of this method it shows a INVALID
> HANDLE
>> > in
>> >> the
>> >> debug variable socket value
>> >>
>> >> Then from the producer call again goes to
>> >> bufferedsocket.cpp and executes the
>> >> socket->connect(host, port); method
>> >>
>> >> AFter all this is done
>> >> it bombs in the constructor of tcptransport.cpp
>> >> IOTransport* ioTransport = dynamic_cast<IOTransport*>( next
> );
>> >>
>> >> and the value of the variable socket in debug mode at this point of
>> > time
>> >> before executing this statement is INVALID_SOCKET_HANDLE=???
>> >>
>> >> Here is the exception then
>> >>
>> >> - ex {message={"caught unknown exception"} stackTrace={first=???
>> > last=???}
>> >> }
>> >> activemq::exceptions::ActiveMQException &
>> >> - cms::CMSException {...} cms::CMSException
>> >> + __vfptr 0x00484278 const
>> >> activemq::exceptions::ActiveMQException::`vftable' *
>> >> - message {"caught unknown exception"}
>> >> std::basic_string<char,std::char_traits<char>,std::allocator<char>
>>
>> >> - std::_String_val<char,std::allocator<char> > {_Alval={...} }
>> >> std::_String_val<char,std::allocator<char> >
>> >> std::_String_base {...} const std::_String_base
>> >> + _Alval {...} std::allocator<char>
>> >> - _Bx {_Buf=0x0069f9bc "po4" _Ptr=0x00346f70 "caught unknown
>> > exception" }
>> >> std::basic_string<char,std::char_traits<char>,std::allocator<char>
>> >> >::_Bxty
>> >> + _Buf 0x0069f9bc "po4" char [16]
>> >> - _Ptr 0x00346f70 "caught unknown exception" char *
>> >> 99 'c' char
>> >> _Mysize 24 unsigned int
>> >> _Myres 31 unsigned int
>> >> - stackTrace {first=??? last=???}
>> >>
>> >
> std::vector<std::pair<std::basic_string<char,std::char_traits<char>,std:
>> > :a
>> >> llocator<char>
>> >>
>>
>>>,int>,std::allocator<std::pair<std::basic_string<char,std::char_traits
> <
>> > ch
>> >> ar>,std::allocator<char>
>> >> >,int> > >
>> >> -
>> >>
>> >
> std::_Vector_val<std::pair<std::basic_string<char,std::char_traits<char>
>> > ,s
>> >> td::allocator<char>
>> >>
>>
>>>,int>,std::allocator<std::pair<std::basic_string<char,std::char_traits
> <
>> > ch
>> >> ar>,std::allocator<char>
>> >> >,int> > > {_Alval={...} }
>> >>
>> >
> std::_Vector_val<std::pair<std::basic_string<char,std::char_traits<char>
>> > ,s
>> >> td::allocator<char>
>> >>
>>
>>>,int>,std::allocator<std::pair<std::basic_string<char,std::char_traits
> <
>> > ch
>> >> ar>,std::allocator<char>
>> >> >,int> > >
>> >> - _Alval {...}
>> >>
>> >
> std::allocator<std::pair<std::basic_string<char,std::char_traits<char>,s
>> > td
>> >> ::allocator<char>
>> >> >,int> >
>> >>
>> >>
>> >
> std::_Allocator_base<std::pair<std::basic_string<char,std::char_traits<c
>> > ha
>> >> r>,std::allocator<char>
>> >> >,int> > {...}
>> >>
>> >
> std::_Allocator_base<std::pair<std::basic_string<char,std::char_traits<c
>> > ha
>> >> r>,std::allocator<char>
>> >> >,int> >
>> >> - _Myfirst 0x00b82770
>> >> {first={"D:\PCData\cpp2\activemq-cpp\win32-
>> >> msvc\..\src\main\activemq\transport\TcpTransport.cpp"}
>> >> second=59}
>> >>
>> >
> std::pair<std::basic_string<char,std::char_traits<char>,std::allocator<c
>> > ha
>> >> r>
>> >> >,int> *
>> >> + first
>> >> {"D:\PCData\cpp2\activemq-cpp\win32-
>> >> msvc\..\src\main\activemq\transport\TcpTransport.cpp"}
>> >> std::basic_string<char,std::char_traits<char>,std::allocator<char>
>>
>> >> second 59 int
>> >> - _Mylast 0x00b827b0 {first={???} second=3473784}
>> >>
>> >
> std::pair<std::basic_string<char,std::char_traits<char>,std::allocator<c
>> > ha
>> >> r>
>> >> >,int> *
>> >> - first {???}
>> >> std::basic_string<char,std::char_traits<char>,std::allocator<char>
>>
>> >> + std::_String_val<char,std::allocator<char> > {_Alval={...} }
>> >> std::_String_val<char,std::allocator<char> >
>> >> + _Bx {_Buf=0x00b827b4 "<<<<" _Ptr=0xabababab <Bad Ptr> }
>> >> std::basic_string<char,std::char_traits<char>,std::allocator<char>
>> >> >::_Bxty
>> >> _Mysize 32380142 unsigned int
>> >> _Myres 3529288 unsigned int
>> >> second 3473784 int
>> >> - _Myend 0x00b827b0 {first={???} second=3473784}
>> >>
>> >
> std::pair<std::basic_string<char,std::char_traits<char>,std::allocator<c
>> > ha
>> >> r>
>> >> >,int> *
>> >> - first {???}
>> >> std::basic_string<char,std::char_traits<char>,std::allocator<char>
>>
>> >> + std::_String_val<char,std::allocator<char> > {_Alval={...} }
>> >> std::_String_val<char,std::allocator<char> >
>> >> + _Bx {_Buf=0x00b827b4 "<<<<" _Ptr=0xabababab <Bad Ptr> }
>> >> std::basic_string<char,std::char_traits<char>,std::allocator<char>
>> >> >::_Bxty
>> >> _Mysize 32380142 unsigned int
>> >> _Myres 3529288 unsigned int
>> >> second 3473784 int
>> >>
>> >> I have attached the piece of code as a file. The one that i have
> got
>> >> running
>> >> on my machine (client example given on site - bit modified since on
>> > the
>> >> site
>> >> it is outdated now).
>> >>
>> >> Thanks
>> >>
>> >>
>> >> Bish, Tim wrote:
>> >> >
>> >> > So there are two different threads in the example code
> (main.cpp),
>> > each
>> >> > of them creates a connection to the broker. They each try and
>> > connect
>> >> > to the broker on the url "tcp://127.0.0.1:61613", so you need to
>> > ensure
>> >> > that you have the broker running on you local machine and have
> the
>> > stomp
>> >> > transport configured to be on port 61613, or you need to change
> this
>> > to
>> >> > be whatever ip and port the broker is at.
>> >> >
>> >> > Sounds like it fails on this call in each thread:
>> >> >
>> >> > connection = connectionFactory->createConnection();
>> >> >
>> >> > So you need to debug what is breaking, the exception stack trace
>> > should
>> >> > give you some clues. Either run in a console window or alter the
>> > code
>> >> > to grab this data and store it in a logfile or something.
>> >> >
>> >> > }catch ( CMSException& e ) {
>> >> > e.printStackTrace();
>> >> > }
>> >> >
>> >> > You can use one of these methods from CMSException to do this
>> >> >
>> >> > /**
>> >> > * Provides the stack trace for every point where
>> >> > * this exception was caught, marked, and rethrown.
>> >> > * @return vector containing stack trace strings
>> >> > */
>> >> > virtual std::vector< std::pair< std::string, int> >
>> >> > getStackTrace() const = 0;
>> >> >
>> >> > /**
>> >> > * Prints the stack trace to the given output stream.
>> >> > * @param stream the target output stream.
>> >> > */
>> >> > virtual void printStackTrace( std::ostream& stream )
> const =
>> > 0;
>> >> >
>> >> >
>> >> > Worse comes to worse you can step through the TcpSocket::connect
>> > method
>> >> > in the debugger to find out where exactly its breaking.
>> >> >
>> >> >>
>> >> >> If you look at the main function in the activemq-cpp client
> given
>> > on
>> >> > our
>> >> >> site
>> >> >> I am just pasting it here now. It says.
>> >> >>
>> >> >> HelloWorldProducer producer( 1000 );
>> >> >> HelloWorldConsumer consumer( 5000 );
>> >> >>
>> >> >> // Start the consumer thread.
>> >> >> Thread consumerThread( &consumer );
>> >> >> consumerThread.start();
>> >> >>
>> >> >> // Start the producer thread.
>> >> >> Thread producerThread( &producer );
>> >> >> producerThread.start();
>> >> >>
>> >> >> // Wait for the threads to complete.
>> >> >> producerThread.join();
>> >> >> consumerThread.join();
>> >> >>
>> >> >> When I debug the call goes to
>> >> >> connection = connectionFactory->createConnection(); // inside
>> >> >> HelloWorldConsumer.cpp and HelloWorldProducer.cpp
>> >> >>
>> >> >> It runs this piece of code in turn ...
>> >> >> if( status < 0 ){
>> >> >> close();
>> >> >> throw SocketException( __FILE__, __LINE__,
>> >> >> "Socket::connect - %s", ::strerror( errno ) );
>> >> >> }
>> >> >> and throws the exception ... from the class tcpsocket.cpp
>> >> >>
>> >> >>
>> >> >>
>> >> >> Bish, Tim wrote:
>> >> >> >
>> >> >> >>
>> >> >> >> The following piece of code in the class SocketFactory.cpp is
>> >> > throwing
>> >> >> >> exceptions ....
>> >> >> >> BufferedSocket* socket = new
> BufferedSocket(tcpSocket,
>> >> >> >> inputBufferSize, outputBufferSize);
>> >> >> >> socket->connect( host.c_str(), port );
>> >> >> >>
>> >> >> >> it returns an invalid handle actually. I can see the call
> coming
>> > in
>> >> >> > twice
>> >> >> >> to
>> >> >> >> this piece of code (producer and then the consumer ... both
> are
>> >> >> > threaded
>> >> >> >> and
>> >> >> >> do a join inside the main method). The second time the call
>> > comes
>> >> > in
>> >> >> > it
>> >> >> >> bombs.
>> >> >> >
>> >> >> > It shouldn't be calling the socket factory twice, especially
> not
>> >> > from
>> >> >> > producer and consumer as they have nothing to do with the
>> > sockets.
>> >> >> >
>> >> >> > What code are you trying to run? Example?
>> >> >> >
>> >> >> > If you run from a command window, what is the error that is
>> > printed
>> >> > out?
>> >> >> >
>> >> >> >>
>> >> >> >> Cant understand why this is happening ... any ideas on what
>> > could
>> >> > be
>> >> >> > the
>> >> >> >> reason.
>> >> >> >> I tried changing the port to 61614 for the broker and the
> code
>> > in
>> >> > the
>> >> >> >> client
>> >> >> >> too ... did not work still ... same probs.
>> >> >> >>
>> >> >> >> Any hint would be really useful.
>> >> >> >> --
>> >> >> >> View this message in context:
> http://www.nabble.com/Sockets-not-
>> >> >> >>
> connecting-...-Invalid-handle-returned-tf2225941.html#a6168387
>> >> >> >> Sent from the ActiveMQ - User forum at Nabble.com.
>> >> >> >
>> >> >> >
>> >> >> >
>> >> >>
>> >> >> --
>> >> >> View this message in context: http://www.nabble.com/Sockets-not-
>> >> >> connecting-...-Invalid-handle-returned-tf2225941.html#a6171212
>> >> >> Sent from the ActiveMQ - User forum at Nabble.com.
>> >> >
>> >> >
>> >> >
>> >>
>> >> --
>> >> View this message in context: http://www.nabble.com/Sockets-not-
>> >> connecting-...-Invalid-handle-returned-tf2225941.html#a6171774
>> >> Sent from the ActiveMQ - User forum at Nabble.com.
>> >
>> >
>> >
>>
>> --
>> View this message in context:
>>
> http://www.nabble.com/dynamic_cast%3CIOTransport%3E---bombs.-Socks-not-
>> connecting---Invalid-handle-tf2225941.html#a6172794
>> Sent from the ActiveMQ - User forum at Nabble.com.
>
>
>
--
View this message in context: http://www.nabble.com/dynamic_cast%3CIOTransport%3E---bombs.-Socks-not-connecting---Invalid-handle-tf2225941.html#a6287897
Sent from the ActiveMQ - User forum at Nabble.com.
RE: Sockets not connecting ... Invalid handle returned
Posted by # Lalit Nagpal # <la...@gmail.com>.
I am running it on vs .net 2003 ... could that be a problem then.
I built the lib file using maven and set the linker to this lib file.
I am running it on .net 2003
As I wrote earlier .... an invalid handle is getting returned from
socket = SocketFactory::createSocket( properties );
And then it throws an exception on this line
// Cast it to an IO transport so we can wire up the socket
// input and output streams.
IOTransport* ioTransport = dynamic_cast<IOTransport*>( next );
What could be the reasons of getting an invalid handle from the statement
socket = SocketFactory::createSocket( properties );
Regards
Lalit ....
tabish121 wrote:
>
>
> Sounds like for whatever reason a socket can't be opened to the broker.
> You may have to step through the code in the tcpsocket::connect and see
> what line is failing.
>
> The code from the website builds and runs fine here, you may need to
> refresh your browser cache to see the latest, or go right to SVN and get
> it from the examples folder in activemq-cpp. There is a VC++ 2005
> project file in there as well. You can download 2005 for free, it may
> be worth it to try that and see if there is something in the settings
> that is different from yours.
>
>>
>> Tim,
>>
>> Actually my broker had gone down so i gave some wrong info ... problem
> is
>> something else, please go through this explanation of what i found.
>>
>> If you look at the main function in the activemq-cpp client given on
> our
>> site
>> I am just pasting it here now. It says.
>>
>> HelloWorldProducer producer( 1000 );
>> HelloWorldConsumer consumer( 5000 );
>>
>> // Start the consumer thread.
>> Thread consumerThread( &consumer );
>> consumerThread.start();
>>
>> // Start the producer thread.
>> Thread producerThread( &producer );
>> producerThread.start();
>>
>> // Wait for the threads to complete.
>> producerThread.join();
>> consumerThread.join();
>>
>> When I debug the call goes to
>> socket->connect( host, port ); // this is inside the class
>> bufferedsocket.cpp
>>
>> after this it executes the connect method inside the class
> tcpsocket.cpp
>> but when the call comes out of this method it shows a INVALID HANDLE
> in
>> the
>> debug variable socket value
>>
>> Then from the producer call again goes to
>> bufferedsocket.cpp and executes the
>> socket->connect(host, port); method
>>
>> AFter all this is done
>> it bombs in the constructor of tcptransport.cpp
>> IOTransport* ioTransport = dynamic_cast<IOTransport*>( next );
>>
>> and the value of the variable socket in debug mode at this point of
> time
>> before executing this statement is INVALID_SOCKET_HANDLE=???
>>
>> Here is the exception then
>>
>> - ex {message={"caught unknown exception"} stackTrace={first=???
> last=???}
>> }
>> activemq::exceptions::ActiveMQException &
>> - cms::CMSException {...} cms::CMSException
>> + __vfptr 0x00484278 const
>> activemq::exceptions::ActiveMQException::`vftable' *
>> - message {"caught unknown exception"}
>> std::basic_string<char,std::char_traits<char>,std::allocator<char> >
>> - std::_String_val<char,std::allocator<char> > {_Alval={...} }
>> std::_String_val<char,std::allocator<char> >
>> std::_String_base {...} const std::_String_base
>> + _Alval {...} std::allocator<char>
>> - _Bx {_Buf=0x0069f9bc "po4" _Ptr=0x00346f70 "caught unknown
> exception" }
>> std::basic_string<char,std::char_traits<char>,std::allocator<char>
>> >::_Bxty
>> + _Buf 0x0069f9bc "po4" char [16]
>> - _Ptr 0x00346f70 "caught unknown exception" char *
>> 99 'c' char
>> _Mysize 24 unsigned int
>> _Myres 31 unsigned int
>> - stackTrace {first=??? last=???}
>>
> std::vector<std::pair<std::basic_string<char,std::char_traits<char>,std:
> :a
>> llocator<char>
>>
>>,int>,std::allocator<std::pair<std::basic_string<char,std::char_traits<
> ch
>> ar>,std::allocator<char>
>> >,int> > >
>> -
>>
> std::_Vector_val<std::pair<std::basic_string<char,std::char_traits<char>
> ,s
>> td::allocator<char>
>>
>>,int>,std::allocator<std::pair<std::basic_string<char,std::char_traits<
> ch
>> ar>,std::allocator<char>
>> >,int> > > {_Alval={...} }
>>
> std::_Vector_val<std::pair<std::basic_string<char,std::char_traits<char>
> ,s
>> td::allocator<char>
>>
>>,int>,std::allocator<std::pair<std::basic_string<char,std::char_traits<
> ch
>> ar>,std::allocator<char>
>> >,int> > >
>> - _Alval {...}
>>
> std::allocator<std::pair<std::basic_string<char,std::char_traits<char>,s
> td
>> ::allocator<char>
>> >,int> >
>>
>>
> std::_Allocator_base<std::pair<std::basic_string<char,std::char_traits<c
> ha
>> r>,std::allocator<char>
>> >,int> > {...}
>>
> std::_Allocator_base<std::pair<std::basic_string<char,std::char_traits<c
> ha
>> r>,std::allocator<char>
>> >,int> >
>> - _Myfirst 0x00b82770
>> {first={"D:\PCData\cpp2\activemq-cpp\win32-
>> msvc\..\src\main\activemq\transport\TcpTransport.cpp"}
>> second=59}
>>
> std::pair<std::basic_string<char,std::char_traits<char>,std::allocator<c
> ha
>> r>
>> >,int> *
>> + first
>> {"D:\PCData\cpp2\activemq-cpp\win32-
>> msvc\..\src\main\activemq\transport\TcpTransport.cpp"}
>> std::basic_string<char,std::char_traits<char>,std::allocator<char> >
>> second 59 int
>> - _Mylast 0x00b827b0 {first={???} second=3473784}
>>
> std::pair<std::basic_string<char,std::char_traits<char>,std::allocator<c
> ha
>> r>
>> >,int> *
>> - first {???}
>> std::basic_string<char,std::char_traits<char>,std::allocator<char> >
>> + std::_String_val<char,std::allocator<char> > {_Alval={...} }
>> std::_String_val<char,std::allocator<char> >
>> + _Bx {_Buf=0x00b827b4 "<<<<" _Ptr=0xabababab <Bad Ptr> }
>> std::basic_string<char,std::char_traits<char>,std::allocator<char>
>> >::_Bxty
>> _Mysize 32380142 unsigned int
>> _Myres 3529288 unsigned int
>> second 3473784 int
>> - _Myend 0x00b827b0 {first={???} second=3473784}
>>
> std::pair<std::basic_string<char,std::char_traits<char>,std::allocator<c
> ha
>> r>
>> >,int> *
>> - first {???}
>> std::basic_string<char,std::char_traits<char>,std::allocator<char> >
>> + std::_String_val<char,std::allocator<char> > {_Alval={...} }
>> std::_String_val<char,std::allocator<char> >
>> + _Bx {_Buf=0x00b827b4 "<<<<" _Ptr=0xabababab <Bad Ptr> }
>> std::basic_string<char,std::char_traits<char>,std::allocator<char>
>> >::_Bxty
>> _Mysize 32380142 unsigned int
>> _Myres 3529288 unsigned int
>> second 3473784 int
>>
>> I have attached the piece of code as a file. The one that i have got
>> running
>> on my machine (client example given on site - bit modified since on
> the
>> site
>> it is outdated now).
>>
>> Thanks
>>
>>
>> Bish, Tim wrote:
>> >
>> > So there are two different threads in the example code (main.cpp),
> each
>> > of them creates a connection to the broker. They each try and
> connect
>> > to the broker on the url "tcp://127.0.0.1:61613", so you need to
> ensure
>> > that you have the broker running on you local machine and have the
> stomp
>> > transport configured to be on port 61613, or you need to change this
> to
>> > be whatever ip and port the broker is at.
>> >
>> > Sounds like it fails on this call in each thread:
>> >
>> > connection = connectionFactory->createConnection();
>> >
>> > So you need to debug what is breaking, the exception stack trace
> should
>> > give you some clues. Either run in a console window or alter the
> code
>> > to grab this data and store it in a logfile or something.
>> >
>> > }catch ( CMSException& e ) {
>> > e.printStackTrace();
>> > }
>> >
>> > You can use one of these methods from CMSException to do this
>> >
>> > /**
>> > * Provides the stack trace for every point where
>> > * this exception was caught, marked, and rethrown.
>> > * @return vector containing stack trace strings
>> > */
>> > virtual std::vector< std::pair< std::string, int> >
>> > getStackTrace() const = 0;
>> >
>> > /**
>> > * Prints the stack trace to the given output stream.
>> > * @param stream the target output stream.
>> > */
>> > virtual void printStackTrace( std::ostream& stream ) const =
> 0;
>> >
>> >
>> > Worse comes to worse you can step through the TcpSocket::connect
> method
>> > in the debugger to find out where exactly its breaking.
>> >
>> >>
>> >> If you look at the main function in the activemq-cpp client given
> on
>> > our
>> >> site
>> >> I am just pasting it here now. It says.
>> >>
>> >> HelloWorldProducer producer( 1000 );
>> >> HelloWorldConsumer consumer( 5000 );
>> >>
>> >> // Start the consumer thread.
>> >> Thread consumerThread( &consumer );
>> >> consumerThread.start();
>> >>
>> >> // Start the producer thread.
>> >> Thread producerThread( &producer );
>> >> producerThread.start();
>> >>
>> >> // Wait for the threads to complete.
>> >> producerThread.join();
>> >> consumerThread.join();
>> >>
>> >> When I debug the call goes to
>> >> connection = connectionFactory->createConnection(); // inside
>> >> HelloWorldConsumer.cpp and HelloWorldProducer.cpp
>> >>
>> >> It runs this piece of code in turn ...
>> >> if( status < 0 ){
>> >> close();
>> >> throw SocketException( __FILE__, __LINE__,
>> >> "Socket::connect - %s", ::strerror( errno ) );
>> >> }
>> >> and throws the exception ... from the class tcpsocket.cpp
>> >>
>> >>
>> >>
>> >> Bish, Tim wrote:
>> >> >
>> >> >>
>> >> >> The following piece of code in the class SocketFactory.cpp is
>> > throwing
>> >> >> exceptions ....
>> >> >> BufferedSocket* socket = new BufferedSocket(tcpSocket,
>> >> >> inputBufferSize, outputBufferSize);
>> >> >> socket->connect( host.c_str(), port );
>> >> >>
>> >> >> it returns an invalid handle actually. I can see the call coming
> in
>> >> > twice
>> >> >> to
>> >> >> this piece of code (producer and then the consumer ... both are
>> >> > threaded
>> >> >> and
>> >> >> do a join inside the main method). The second time the call
> comes
>> > in
>> >> > it
>> >> >> bombs.
>> >> >
>> >> > It shouldn't be calling the socket factory twice, especially not
>> > from
>> >> > producer and consumer as they have nothing to do with the
> sockets.
>> >> >
>> >> > What code are you trying to run? Example?
>> >> >
>> >> > If you run from a command window, what is the error that is
> printed
>> > out?
>> >> >
>> >> >>
>> >> >> Cant understand why this is happening ... any ideas on what
> could
>> > be
>> >> > the
>> >> >> reason.
>> >> >> I tried changing the port to 61614 for the broker and the code
> in
>> > the
>> >> >> client
>> >> >> too ... did not work still ... same probs.
>> >> >>
>> >> >> Any hint would be really useful.
>> >> >> --
>> >> >> View this message in context: http://www.nabble.com/Sockets-not-
>> >> >> connecting-...-Invalid-handle-returned-tf2225941.html#a6168387
>> >> >> Sent from the ActiveMQ - User forum at Nabble.com.
>> >> >
>> >> >
>> >> >
>> >>
>> >> --
>> >> View this message in context: http://www.nabble.com/Sockets-not-
>> >> connecting-...-Invalid-handle-returned-tf2225941.html#a6171212
>> >> Sent from the ActiveMQ - User forum at Nabble.com.
>> >
>> >
>> >
>>
>> --
>> View this message in context: http://www.nabble.com/Sockets-not-
>> connecting-...-Invalid-handle-returned-tf2225941.html#a6171774
>> Sent from the ActiveMQ - User forum at Nabble.com.
>
>
>
--
View this message in context: http://www.nabble.com/dynamic_cast%3CIOTransport%3E---bombs.-Socks-not-connecting---Invalid-handle-tf2225941.html#a6172794
Sent from the ActiveMQ - User forum at Nabble.com.
RE: Sockets not connecting ... Invalid handle returned
Posted by # Lalit Nagpal # <la...@gmail.com>.
Tim,
Actually my broker had gone down so i gave some wrong info ... problem is
something else, please go through this explanation of what i found.
If you look at the main function in the activemq-cpp client given on our
site
I am just pasting it here now. It says.
HelloWorldProducer producer( 1000 );
HelloWorldConsumer consumer( 5000 );
// Start the consumer thread.
Thread consumerThread( &consumer );
consumerThread.start();
// Start the producer thread.
Thread producerThread( &producer );
producerThread.start();
// Wait for the threads to complete.
producerThread.join();
consumerThread.join();
When I debug the call goes to
socket->connect( host, port ); // this is inside the class
bufferedsocket.cpp
after this it executes the connect method inside the class tcpsocket.cpp
but when the call comes out of this method it shows a INVALID HANDLE in the
debug variable socket value
Then from the producer call again goes to
bufferedsocket.cpp and executes the
socket->connect(host, port); method
AFter all this is done
it bombs in the constructor of tcptransport.cpp
IOTransport* ioTransport = dynamic_cast<IOTransport*>( next );
and the value of the variable socket in debug mode at this point of time
before executing this statement is INVALID_SOCKET_HANDLE=???
Here is the exception then
- ex {message={"caught unknown exception"} stackTrace={first=??? last=???} }
activemq::exceptions::ActiveMQException &
- cms::CMSException {...} cms::CMSException
+ __vfptr 0x00484278 const
activemq::exceptions::ActiveMQException::`vftable' *
- message {"caught unknown exception"}
std::basic_string<char,std::char_traits<char>,std::allocator<char> >
- std::_String_val<char,std::allocator<char> > {_Alval={...} }
std::_String_val<char,std::allocator<char> >
std::_String_base {...} const std::_String_base
+ _Alval {...} std::allocator<char>
- _Bx {_Buf=0x0069f9bc "po4" _Ptr=0x00346f70 "caught unknown exception" }
std::basic_string<char,std::char_traits<char>,std::allocator<char> >::_Bxty
+ _Buf 0x0069f9bc "po4" char [16]
- _Ptr 0x00346f70 "caught unknown exception" char *
99 'c' char
_Mysize 24 unsigned int
_Myres 31 unsigned int
- stackTrace {first=??? last=???}
std::vector<std::pair<std::basic_string<char,std::char_traits<char>,std::allocator<char>
>,int>,std::allocator<std::pair<std::basic_string<char,std::char_traits<char>,std::allocator<char>
>,int> > >
-
std::_Vector_val<std::pair<std::basic_string<char,std::char_traits<char>,std::allocator<char>
>,int>,std::allocator<std::pair<std::basic_string<char,std::char_traits<char>,std::allocator<char>
>,int> > > {_Alval={...} }
std::_Vector_val<std::pair<std::basic_string<char,std::char_traits<char>,std::allocator<char>
>,int>,std::allocator<std::pair<std::basic_string<char,std::char_traits<char>,std::allocator<char>
>,int> > >
- _Alval {...}
std::allocator<std::pair<std::basic_string<char,std::char_traits<char>,std::allocator<char>
>,int> >
std::_Allocator_base<std::pair<std::basic_string<char,std::char_traits<char>,std::allocator<char>
>,int> > {...}
std::_Allocator_base<std::pair<std::basic_string<char,std::char_traits<char>,std::allocator<char>
>,int> >
- _Myfirst 0x00b82770
{first={"D:\PCData\cpp2\activemq-cpp\win32-msvc\..\src\main\activemq\transport\TcpTransport.cpp"}
second=59}
std::pair<std::basic_string<char,std::char_traits<char>,std::allocator<char>
>,int> *
+ first
{"D:\PCData\cpp2\activemq-cpp\win32-msvc\..\src\main\activemq\transport\TcpTransport.cpp"}
std::basic_string<char,std::char_traits<char>,std::allocator<char> >
second 59 int
- _Mylast 0x00b827b0 {first={???} second=3473784}
std::pair<std::basic_string<char,std::char_traits<char>,std::allocator<char>
>,int> *
- first {???}
std::basic_string<char,std::char_traits<char>,std::allocator<char> >
+ std::_String_val<char,std::allocator<char> > {_Alval={...} }
std::_String_val<char,std::allocator<char> >
+ _Bx {_Buf=0x00b827b4 "««««" _Ptr=0xabababab <Bad Ptr> }
std::basic_string<char,std::char_traits<char>,std::allocator<char> >::_Bxty
_Mysize 32380142 unsigned int
_Myres 3529288 unsigned int
second 3473784 int
- _Myend 0x00b827b0 {first={???} second=3473784}
std::pair<std::basic_string<char,std::char_traits<char>,std::allocator<char>
>,int> *
- first {???}
std::basic_string<char,std::char_traits<char>,std::allocator<char> >
+ std::_String_val<char,std::allocator<char> > {_Alval={...} }
std::_String_val<char,std::allocator<char> >
+ _Bx {_Buf=0x00b827b4 "««««" _Ptr=0xabababab <Bad Ptr> }
std::basic_string<char,std::char_traits<char>,std::allocator<char> >::_Bxty
_Mysize 32380142 unsigned int
_Myres 3529288 unsigned int
second 3473784 int
I have attached the piece of code as a file. The one that i have got running
on my machine (client example given on site - bit modified since on the site
it is outdated now).
Thanks
Bish, Tim wrote:
>
> So there are two different threads in the example code (main.cpp), each
> of them creates a connection to the broker. They each try and connect
> to the broker on the url "tcp://127.0.0.1:61613", so you need to ensure
> that you have the broker running on you local machine and have the stomp
> transport configured to be on port 61613, or you need to change this to
> be whatever ip and port the broker is at.
>
> Sounds like it fails on this call in each thread:
>
> connection = connectionFactory->createConnection();
>
> So you need to debug what is breaking, the exception stack trace should
> give you some clues. Either run in a console window or alter the code
> to grab this data and store it in a logfile or something.
>
> }catch ( CMSException& e ) {
> e.printStackTrace();
> }
>
> You can use one of these methods from CMSException to do this
>
> /**
> * Provides the stack trace for every point where
> * this exception was caught, marked, and rethrown.
> * @return vector containing stack trace strings
> */
> virtual std::vector< std::pair< std::string, int> >
> getStackTrace() const = 0;
>
> /**
> * Prints the stack trace to the given output stream.
> * @param stream the target output stream.
> */
> virtual void printStackTrace( std::ostream& stream ) const = 0;
>
>
> Worse comes to worse you can step through the TcpSocket::connect method
> in the debugger to find out where exactly its breaking.
>
>>
>> If you look at the main function in the activemq-cpp client given on
> our
>> site
>> I am just pasting it here now. It says.
>>
>> HelloWorldProducer producer( 1000 );
>> HelloWorldConsumer consumer( 5000 );
>>
>> // Start the consumer thread.
>> Thread consumerThread( &consumer );
>> consumerThread.start();
>>
>> // Start the producer thread.
>> Thread producerThread( &producer );
>> producerThread.start();
>>
>> // Wait for the threads to complete.
>> producerThread.join();
>> consumerThread.join();
>>
>> When I debug the call goes to
>> connection = connectionFactory->createConnection(); // inside
>> HelloWorldConsumer.cpp and HelloWorldProducer.cpp
>>
>> It runs this piece of code in turn ...
>> if( status < 0 ){
>> close();
>> throw SocketException( __FILE__, __LINE__,
>> "Socket::connect - %s", ::strerror( errno ) );
>> }
>> and throws the exception ... from the class tcpsocket.cpp
>>
>>
>>
>> Bish, Tim wrote:
>> >
>> >>
>> >> The following piece of code in the class SocketFactory.cpp is
> throwing
>> >> exceptions ....
>> >> BufferedSocket* socket = new BufferedSocket(tcpSocket,
>> >> inputBufferSize, outputBufferSize);
>> >> socket->connect( host.c_str(), port );
>> >>
>> >> it returns an invalid handle actually. I can see the call coming in
>> > twice
>> >> to
>> >> this piece of code (producer and then the consumer ... both are
>> > threaded
>> >> and
>> >> do a join inside the main method). The second time the call comes
> in
>> > it
>> >> bombs.
>> >
>> > It shouldn't be calling the socket factory twice, especially not
> from
>> > producer and consumer as they have nothing to do with the sockets.
>> >
>> > What code are you trying to run? Example?
>> >
>> > If you run from a command window, what is the error that is printed
> out?
>> >
>> >>
>> >> Cant understand why this is happening ... any ideas on what could
> be
>> > the
>> >> reason.
>> >> I tried changing the port to 61614 for the broker and the code in
> the
>> >> client
>> >> too ... did not work still ... same probs.
>> >>
>> >> Any hint would be really useful.
>> >> --
>> >> View this message in context: http://www.nabble.com/Sockets-not-
>> >> connecting-...-Invalid-handle-returned-tf2225941.html#a6168387
>> >> Sent from the ActiveMQ - User forum at Nabble.com.
>> >
>> >
>> >
>>
>> --
>> View this message in context: http://www.nabble.com/Sockets-not-
>> connecting-...-Invalid-handle-returned-tf2225941.html#a6171212
>> Sent from the ActiveMQ - User forum at Nabble.com.
>
>
>
--
View this message in context: http://www.nabble.com/Sockets-not-connecting-...-Invalid-handle-returned-tf2225941.html#a6171774
Sent from the ActiveMQ - User forum at Nabble.com.
RE: Sockets not connecting ... Invalid handle returned
Posted by # Lalit Nagpal # <la...@gmail.com>.
If you look at the main function in the activemq-cpp client given on our
site
I am just pasting it here now. It says.
HelloWorldProducer producer( 1000 );
HelloWorldConsumer consumer( 5000 );
// Start the consumer thread.
Thread consumerThread( &consumer );
consumerThread.start();
// Start the producer thread.
Thread producerThread( &producer );
producerThread.start();
// Wait for the threads to complete.
producerThread.join();
consumerThread.join();
When I debug the call goes to
connection = connectionFactory->createConnection(); // inside
HelloWorldConsumer.cpp and HelloWorldProducer.cpp
It runs this piece of code in turn ...
if( status < 0 ){
close();
throw SocketException( __FILE__, __LINE__,
"Socket::connect - %s", ::strerror( errno ) );
}
and throws the exception ... from the class tcpsocket.cpp
Bish, Tim wrote:
>
>>
>> The following piece of code in the class SocketFactory.cpp is throwing
>> exceptions ....
>> BufferedSocket* socket = new BufferedSocket(tcpSocket,
>> inputBufferSize, outputBufferSize);
>> socket->connect( host.c_str(), port );
>>
>> it returns an invalid handle actually. I can see the call coming in
> twice
>> to
>> this piece of code (producer and then the consumer ... both are
> threaded
>> and
>> do a join inside the main method). The second time the call comes in
> it
>> bombs.
>
> It shouldn't be calling the socket factory twice, especially not from
> producer and consumer as they have nothing to do with the sockets.
>
> What code are you trying to run? Example?
>
> If you run from a command window, what is the error that is printed out?
>
>>
>> Cant understand why this is happening ... any ideas on what could be
> the
>> reason.
>> I tried changing the port to 61614 for the broker and the code in the
>> client
>> too ... did not work still ... same probs.
>>
>> Any hint would be really useful.
>> --
>> View this message in context: http://www.nabble.com/Sockets-not-
>> connecting-...-Invalid-handle-returned-tf2225941.html#a6168387
>> Sent from the ActiveMQ - User forum at Nabble.com.
>
>
>
--
View this message in context: http://www.nabble.com/Sockets-not-connecting-...-Invalid-handle-returned-tf2225941.html#a6171212
Sent from the ActiveMQ - User forum at Nabble.com.