summaryrefslogtreecommitdiff
path: root/cpp/demo/Glacier2/callback
diff options
context:
space:
mode:
Diffstat (limited to 'cpp/demo/Glacier2/callback')
-rw-r--r--cpp/demo/Glacier2/callback/CallbackI.cpp22
-rw-r--r--cpp/demo/Glacier2/callback/Client.cpp246
-rw-r--r--cpp/demo/Glacier2/callback/SessionI.cpp2
3 files changed, 135 insertions, 135 deletions
diff --git a/cpp/demo/Glacier2/callback/CallbackI.cpp b/cpp/demo/Glacier2/callback/CallbackI.cpp
index fb9ff794970..24389d5541a 100644
--- a/cpp/demo/Glacier2/callback/CallbackI.cpp
+++ b/cpp/demo/Glacier2/callback/CallbackI.cpp
@@ -18,14 +18,14 @@ CallbackReceiverI::callback(const Ice::Current&)
{
#ifdef __xlC__
- //
- // The xlC compiler synchronizes cin and cout; to see the messages
- // while accepting input through cin, we have to print the messages
- // with printf
- //
+ //
+ // The xlC compiler synchronizes cin and cout; to see the messages
+ // while accepting input through cin, we have to print the messages
+ // with printf
+ //
- printf("received callback\n");
- fflush(0);
+ printf("received callback\n");
+ fflush(0);
#else
cout << "received callback" << endl;
#endif
@@ -37,11 +37,11 @@ CallbackI::initiateCallback(const CallbackReceiverPrx& proxy, const Ice::Current
cout << "initiating callback to: " << current.adapter->getCommunicator()->proxyToString(proxy) << endl;
try
{
- proxy->callback(current.ctx);
+ proxy->callback(current.ctx);
}
catch(const Ice::Exception& ex)
{
- cout << ex << endl;
+ cout << ex << endl;
}
}
@@ -51,10 +51,10 @@ CallbackI::shutdown(const Ice::Current& c)
cout << "shutting down..." << endl;
try
{
- c.adapter->getCommunicator()->shutdown();
+ c.adapter->getCommunicator()->shutdown();
}
catch(const Ice::Exception& ex)
{
- cout << ex << endl;
+ cout << ex << endl;
}
}
diff --git a/cpp/demo/Glacier2/callback/Client.cpp b/cpp/demo/Glacier2/callback/Client.cpp
index 063ea984470..c8623250faf 100644
--- a/cpp/demo/Glacier2/callback/Client.cpp
+++ b/cpp/demo/Glacier2/callback/Client.cpp
@@ -33,16 +33,16 @@ void
menu()
{
cout <<
- "usage:\n"
- "t: invoke callback as twoway\n"
- "o: invoke callback as oneway\n"
- "O: invoke callback as batch oneway\n"
- "f: flush all batch requests\n"
- "v: set/reset override context field\n"
- "F: set/reset fake category\n"
- "s: shutdown server\n"
- "x: exit\n"
- "?: help\n";
+ "usage:\n"
+ "t: invoke callback as twoway\n"
+ "o: invoke callback as oneway\n"
+ "O: invoke callback as batch oneway\n"
+ "f: flush all batch requests\n"
+ "v: set/reset override context field\n"
+ "F: set/reset fake category\n"
+ "s: shutdown server\n"
+ "x: exit\n"
+ "?: help\n";
}
int
@@ -57,38 +57,38 @@ CallbackClient::run(int argc, char* argv[])
Ice::RouterPrx defaultRouter = communicator()->getDefaultRouter();
if(!defaultRouter)
{
- cerr << argv[0] << ": no default router set" << endl;
- return EXIT_FAILURE;
+ cerr << argv[0] << ": no default router set" << endl;
+ return EXIT_FAILURE;
}
Glacier2::RouterPrx router = Glacier2::RouterPrx::checkedCast(defaultRouter);
if(!router)
{
- cerr << argv[0] << ": configured router is not a Glacier2 router" << endl;
- return EXIT_FAILURE;
+ cerr << argv[0] << ": configured router is not a Glacier2 router" << endl;
+ return EXIT_FAILURE;
}
while(true)
{
- cout << "This demo accepts any user-id / password combination.\n";
+ cout << "This demo accepts any user-id / password combination.\n";
- string id;
- cout << "user id: " << flush;
- cin >> id;
+ string id;
+ cout << "user id: " << flush;
+ cin >> id;
- string pw;
- cout << "password: " << flush;
- cin >> pw;
+ string pw;
+ cout << "password: " << flush;
+ cin >> pw;
- try
- {
- router->createSession(id, pw);
- break;
- }
- catch(const Glacier2::PermissionDeniedException& ex)
- {
- cout << "permission denied:\n" << ex.reason << endl;
- }
+ try
+ {
+ router->createSession(id, pw);
+ break;
+ }
+ catch(const Glacier2::PermissionDeniedException& ex)
+ {
+ cout << "permission denied:\n" << ex.reason << endl;
+ }
}
Ice::Identity callbackReceiverIdent;
@@ -119,97 +119,97 @@ CallbackClient::run(int argc, char* argv[])
char c;
do
{
- try
- {
- cout << "==> ";
- cin >> c;
- if(c == 't')
- {
- Ice::Context context;
- context["_fwd"] = "t";
- if(!override.empty())
- {
- context["_ovrd"] = override;
- }
- twoway->initiateCallback(twowayR, context);
- }
- else if(c == 'o')
- {
- Ice::Context context;
- context["_fwd"] = "o";
- if(!override.empty())
- {
- context["_ovrd"] = override;
- }
- oneway->initiateCallback(onewayR, context);
- }
- else if(c == 'O')
- {
- Ice::Context context;
- context["_fwd"] = "O";
- if(!override.empty())
- {
- context["_ovrd"] = override;
- }
- batchOneway->initiateCallback(onewayR, context);
- }
- else if(c == 'f')
- {
- communicator()->flushBatchRequests();
- }
- else if(c == 'v')
- {
- if(override.empty())
+ try
+ {
+ cout << "==> ";
+ cin >> c;
+ if(c == 't')
+ {
+ Ice::Context context;
+ context["_fwd"] = "t";
+ if(!override.empty())
{
- override = "some_value";
- cout << "override context field is now `" << override << "'" << endl;
- }
- else
- {
- override.clear();
- cout << "override context field is empty" << endl;
- }
- }
- else if(c == 'F')
- {
- fake = !fake;
-
- if(fake)
- {
- twowayR = CallbackReceiverPrx::uncheckedCast(twowayR->ice_identity(callbackReceiverFakeIdent));
- onewayR = CallbackReceiverPrx::uncheckedCast(onewayR->ice_identity(callbackReceiverFakeIdent));
- }
- else
- {
- twowayR = CallbackReceiverPrx::uncheckedCast(twowayR->ice_identity(callbackReceiverIdent));
- onewayR = CallbackReceiverPrx::uncheckedCast(onewayR->ice_identity(callbackReceiverIdent));
- }
-
- cout << "callback receiver identity: " << communicator()->identityToString(twowayR->ice_getIdentity())
- << endl;
- }
- else if(c == 's')
- {
- twoway->shutdown();
- }
- else if(c == 'x')
- {
- // Nothing to do
- }
- else if(c == '?')
- {
- menu();
- }
- else
- {
- cout << "unknown command `" << c << "'" << endl;
- menu();
- }
- }
- catch(const Ice::Exception& ex)
- {
- cerr << ex << endl;
- }
+ context["_ovrd"] = override;
+ }
+ twoway->initiateCallback(twowayR, context);
+ }
+ else if(c == 'o')
+ {
+ Ice::Context context;
+ context["_fwd"] = "o";
+ if(!override.empty())
+ {
+ context["_ovrd"] = override;
+ }
+ oneway->initiateCallback(onewayR, context);
+ }
+ else if(c == 'O')
+ {
+ Ice::Context context;
+ context["_fwd"] = "O";
+ if(!override.empty())
+ {
+ context["_ovrd"] = override;
+ }
+ batchOneway->initiateCallback(onewayR, context);
+ }
+ else if(c == 'f')
+ {
+ communicator()->flushBatchRequests();
+ }
+ else if(c == 'v')
+ {
+ if(override.empty())
+ {
+ override = "some_value";
+ cout << "override context field is now `" << override << "'" << endl;
+ }
+ else
+ {
+ override.clear();
+ cout << "override context field is empty" << endl;
+ }
+ }
+ else if(c == 'F')
+ {
+ fake = !fake;
+
+ if(fake)
+ {
+ twowayR = CallbackReceiverPrx::uncheckedCast(twowayR->ice_identity(callbackReceiverFakeIdent));
+ onewayR = CallbackReceiverPrx::uncheckedCast(onewayR->ice_identity(callbackReceiverFakeIdent));
+ }
+ else
+ {
+ twowayR = CallbackReceiverPrx::uncheckedCast(twowayR->ice_identity(callbackReceiverIdent));
+ onewayR = CallbackReceiverPrx::uncheckedCast(onewayR->ice_identity(callbackReceiverIdent));
+ }
+
+ cout << "callback receiver identity: " << communicator()->identityToString(twowayR->ice_getIdentity())
+ << endl;
+ }
+ else if(c == 's')
+ {
+ twoway->shutdown();
+ }
+ else if(c == 'x')
+ {
+ // Nothing to do
+ }
+ else if(c == '?')
+ {
+ menu();
+ }
+ else
+ {
+ cout << "unknown command `" << c << "'" << endl;
+ menu();
+ }
+ }
+ catch(const Ice::Exception& ex)
+ {
+ cerr << ex << endl;
+ }
}
while(cin.good() && c != 'x');
@@ -221,15 +221,15 @@ CallbackClient::interruptCallback(int)
{
try
{
- communicator()->destroy();
+ communicator()->destroy();
}
catch(const IceUtil::Exception& ex)
{
- cerr << appName() << ": " << ex << endl;
+ cerr << appName() << ": " << ex << endl;
}
catch(...)
{
- cerr << appName() << ": unknown exception" << endl;
+ cerr << appName() << ": unknown exception" << endl;
}
exit(EXIT_SUCCESS);
}
diff --git a/cpp/demo/Glacier2/callback/SessionI.cpp b/cpp/demo/Glacier2/callback/SessionI.cpp
index 7169270aac9..8bd4a13e769 100644
--- a/cpp/demo/Glacier2/callback/SessionI.cpp
+++ b/cpp/demo/Glacier2/callback/SessionI.cpp
@@ -14,7 +14,7 @@ using namespace std;
bool
DummyPermissionsVerifierI::checkPermissions(const string& userId, const string& password, string&,
- const Ice::Current&) const
+ const Ice::Current&) const
{
cout << "verified user `" << userId << "' with password `" << password << "'" << endl;
return true;
generated by cgit v1.2.3 (git 2.46.0) at 2025-08-03 16:26:20 +0000