Reator退出的问题

peakzhang

在服务器关闭后,客户端在delete this的时候发生错误,内存引用的错误,怎么解决呀?

2. int Client::open (void *p)
3. {
4. if (super::open (p) == -1)
5.   return -1;
6. ACE_Time_Value iter_delay (10);
7. ACE_Time_Value init_delay (10);
8. this->notifier_.reactor (this->reactor ());
9. this->msg_queue ()->notification_strategy (&this->notifier_);
10. return this->reactor ()->schedule_timer(this, 0, init_delay, iter_delay);
12. //this->reactor()->register_handler(this, ACE_Event_Handler::WRITE_MASK);
13. //ACE_Reactor::instance()->register_handler(this, ACE_Event_Handler::WRITE_MASK);
14. //this->msg_queue ()->notification_strategy (&this->notifier_);
15. //return 0;
16. }
17. int Client::handle_input (ACE_HANDLE fd)
18. {
19. char recv_data[40960];
20. memset(recv_data, 0, 40960);
21. ssize_t recv_cnt = 0;
22. int index = 0;
23. int stamp = -1;
24. BOOL bData = TRUE;
25. recv_cnt = this->peer().recv (recv_data, 40960);
26. count --;
27. if (recv_cnt != -1)
28. {
29.   ......
30. }
32. if (recv_cnt == 0 || ACE_OS::last_error () != EWOULDBLOCK)
33. {
34.   this->reactor()->end_reactor_event_loop();
35.   return -1;
36. }
37. return 0;
38. }
39. int Client::handle_timeout(const ACE_Time_Value &, const void *)
40. {
41. /*int ilen = 0;
42. BYTE *send_data = NULL;
43. ACE_Message_Block *mb;
44. ACE_NEW_RETURN (mb, ACE_Message_Block (128), -1);
45. titan.MakeBeatingTest(&send_data, ilen);
46. mb->copy((const char*)send_data, ilen);
47. ACE_ASSERT (ilen > 0);
48. this->putq (mb);*/
49. if (++this->iterations_ >= ITERATIONS)
50. {
51.   this->peer().close_writer();
52.   return 0;
53. }
54. ACE_Message_Block *mb;
55. ACE_NEW_RETURN(mb, ACE_Message_Block(128), -1);
56. char msg[128];
57. ACE_OS::sprintf(msg, "Iteration %d\n", this->iterations_);
58. this->putq(mb);
59. return 0;
60. }
61. int Client::handle_output (ACE_HANDLE fd)
62. {
63. char *aa = "fafda";
64. this->peer().send(aa, strlen(aa));
65. count ++;
66. ACE_Message_Block *mb;
67. ACE_Time_Value nowait (ACE_OS::gettimeofday ());
68. while (-1 != this->getq (mb, &nowait))
69. {
70.   ssize_t send_cnt = this->peer ().send (mb->rd_ptr (), mb->length ());
71.   if (send_cnt != -1)
72.    mb->rd_ptr (static_cast<size_t> (send_cnt));
73.   if (mb->length () > 0)
74.   {
75.    this->ungetq (mb);
76.    break;
77.   }
78.   mb->release ();
79. }
80. if (this->msg_queue ()->is_empty ())
81.   this->reactor ()->cancel_wakeup(this, ACE_Event_Handler::WRITE_MASK);
82. else
83.   this->reactor ()->schedule_wakeup(this, ACE_Event_Handler::DONT_CALL);
84. return 0;
85. }

复制代码

我实在是找不到在问题在那了

peakzhang

你没控制好内存操作，导致在delete this后，仍然有引用此对象的操作，导致了崩溃。

peakzhang

找到问题出现在那了,我在handle_input()里面用到了,COM组件,是由用COM组件没有释放完全,引起的错误