blob: 5a841a5407f6efccb88379bbe9d23714601c2025 (
plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
|
// $Id$
//---------------------------------------------------------------------------
#include "pch.h"
#pragma hdrstop
#include <cctype>
#include <dos.h>
#include <memory>
#include "ChatClientWnd.h"
//---------------------------------------------------------------------------
#pragma package(smart_init)
#pragma resource "*.dfm"
TChatClientWindow *ChatClientWindow;
//---------------------------------------------------------------------------
__fastcall TChatClientWindow::TChatClientWindow(TComponent* Owner)
: TForm(Owner)
{
nickname_ = InputBox ("Enter Nickname",
"Enter the nickname you would like to use:",
"noname");
if (!OpenDialog->Execute ())
throw Exception ("IOR file not selected - unable to continue");
ior_file_name_ = OpenDialog->FileName;
// Retrieve the ORB.
orb_ = CORBA::ORB_init (_argc, _argv, 0);
// Get reference to the Root POA
CORBA::Object_var obj =
orb_->resolve_initial_references ("RootPOA");
PortableServer::POA_var poa = PortableServer::POA::_narrow (obj);
// Activate the POA manager
PortableServer::POAManager_var mgr = poa->the_POAManager ();
mgr->activate ();
// set the orb in the receiver_i_ object.
receiver_i_.orb (orb_);
// read the ior from file
ReadIOR (ior_file_name_);
CORBA::Object_var server_object =
orb_->string_to_object (ior_.c_str ());
if (CORBA::is_nil (server_object.in ()))
throw Exception ("Invalid IOR " + ior_);
server_ = Broadcaster::_narrow (server_object);
receiver_var_ = receiver_i_._this ();
// Register ourselves with the server.
server_->add (receiver_var_, nickname_.c_str ());
Application->OnMessage = ApplicationMessage;
}
//---------------------------------------------------------------------------
void __fastcall TChatClientWindow::ReadIOR (String filename)
{
std::auto_ptr<TStringList> ior (new TStringList);
ior->LoadFromFile (filename);
ior_ = ior->Text;
}
//---------------------------------------------------------------------------
void __fastcall TChatClientWindow::WMMessageReceived (TMessage& Message)
{
String* str = (String*)Message.WParam;
for (int i = 1; i <= str->Length (); i++)
if (std::isspace ( (*str)[i]))
(*str)[i] = ' ';
OutputMemo->Lines->Append (str->Trim ());
delete str;
}
//---------------------------------------------------------------------------
void __fastcall TChatClientWindow::FormClose (TObject *Sender,
TCloseAction &Action)
{
try
{
// Remove ourselves from the server.
server_->remove (receiver_var_);
receiver_i_.shutdown ();
}
catch (CORBA::Exception&)
{
ShowMessage ("Exception in TChatClientWindow::FormClose");
}
}
//---------------------------------------------------------------------------
void __fastcall TChatClientWindow::ApplicationMessage (MSG& msg, bool& Handled)
{
if (orb_->work_pending ())
orb_->perform_work ();
}
//---------------------------------------------------------------------------
void __fastcall TChatClientWindow::InputMemoKeyPress (TObject *Sender, char &Key)
{
if (Key == '\n' || Key == '\r')
{
try
{
// Call the server function <say> to pass the string typed by
// the server.
server_->say (receiver_var_, InputMemo->Text.c_str ());
}
catch (CORBA::Exception&)
{
ShowMessage ("Exception in TChatClientWindow::InputMemoKeyPress");
}
Key = 0;
InputMemo->Lines->Clear ();
}
}
//---------------------------------------------------------------------------
void __fastcall TChatClientWindow::TimerToEnsureRegularMessagesTimer (TObject *Sender)
{
// We do nothing in this timer event handler. The purpose of the timer is
// to ensure that messages are sent regularly to the application, even if
// the system is otherwise idle. We need regular messages since we use the
// Application->OnMessage event to allow the ORB to perform pending work.
}
//---------------------------------------------------------------------------
|
