Formatting, indentation
This commit is contained in:
@@ -133,14 +133,14 @@ void BroadcastListener::start(void)
|
|||||||
isListening.store(true);
|
isListening.store(true);
|
||||||
// Start the first async receive operation
|
// Start the first async receive operation
|
||||||
startReceive();
|
startReceive();
|
||||||
std::cout << "BroadcastListener started on port " << listeningPort
|
std::cout << __func__ << ": BroadcastListener started on port "
|
||||||
<< std::endl;
|
<< listeningPort << std::endl;
|
||||||
}
|
}
|
||||||
catch (const boost::system::system_error& e)
|
catch (const boost::system::system_error& e)
|
||||||
{
|
{
|
||||||
isListening.store(false);
|
isListening.store(false);
|
||||||
std::cerr << "Failed to start BroadcastListener: " << e.what()
|
std::cerr << __func__ << ": Failed to start BroadcastListener: "
|
||||||
<< std::endl;
|
<< e.what() << std::endl;
|
||||||
throw;
|
throw;
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
@@ -172,11 +172,11 @@ void BroadcastListener::stop(void)
|
|||||||
try
|
try
|
||||||
{
|
{
|
||||||
socket.close();
|
socket.close();
|
||||||
std::cout << "BroadcastListener stopped" << std::endl;
|
std::cout << __func__ << ": BroadcastListener stopped" << std::endl;
|
||||||
}
|
}
|
||||||
catch (const boost::system::system_error& e)
|
catch (const boost::system::system_error& e)
|
||||||
{
|
{
|
||||||
std::cerr << "Error stopping BroadcastListener: " << e.what()
|
std::cerr << __func__ << ": Error stopping BroadcastListener: " << e.what()
|
||||||
<< std::endl;
|
<< std::endl;
|
||||||
throw;
|
throw;
|
||||||
}
|
}
|
||||||
|
|||||||
@@ -45,7 +45,8 @@ void livoxProto1_destroyDeviceReq(
|
|||||||
+ ": DeviceManager not initialized");
|
+ ": DeviceManager not initialized");
|
||||||
}
|
}
|
||||||
|
|
||||||
protoState.deviceManager->destroyDeviceReq(device, callback);
|
protoState.deviceManager->destroyDeviceReq(
|
||||||
|
device, callback);
|
||||||
}
|
}
|
||||||
|
|
||||||
void livoxProto1_main(
|
void livoxProto1_main(
|
||||||
|
|||||||
@@ -36,8 +36,10 @@ void exitMarionetteLoop()
|
|||||||
|
|
||||||
void marionetteFinalizeReqCb(bool success)
|
void marionetteFinalizeReqCb(bool success)
|
||||||
{
|
{
|
||||||
if (!success) {
|
if (!success)
|
||||||
|
{
|
||||||
std::cerr << __func__ << ": Failed to finalize Marionette." << '\n';
|
std::cerr << __func__ << ": Failed to finalize Marionette." << '\n';
|
||||||
|
// Fallthrough.
|
||||||
}
|
}
|
||||||
std::cout << __func__ << ": Marionette finalized." << '\n';
|
std::cout << __func__ << ": Marionette finalized." << '\n';
|
||||||
exitMarionetteLoop();
|
exitMarionetteLoop();
|
||||||
|
|||||||
@@ -357,6 +357,7 @@ public:
|
|||||||
{
|
{
|
||||||
std::cerr << __func__ << ": Failed to attach device: "
|
std::cerr << __func__ << ": Failed to attach device: "
|
||||||
<< spec->deviceIdentifier << "\n";
|
<< spec->deviceIdentifier << "\n";
|
||||||
|
// Fallthrough.
|
||||||
}
|
}
|
||||||
|
|
||||||
if (!context->loop.incrementSuccessOrFailureAndTestForCompletionDueTo(
|
if (!context->loop.incrementSuccessOrFailureAndTestForCompletionDueTo(
|
||||||
@@ -430,6 +431,7 @@ public:
|
|||||||
{
|
{
|
||||||
std::cerr << __func__ << ": Failed to detach device: "
|
std::cerr << __func__ << ": Failed to detach device: "
|
||||||
<< spec->deviceIdentifier << "\n";
|
<< spec->deviceIdentifier << "\n";
|
||||||
|
// Fallthrough.
|
||||||
}
|
}
|
||||||
|
|
||||||
if (!context->loop.incrementSuccessOrFailureAndTestForCompletionDueTo(
|
if (!context->loop.incrementSuccessOrFailureAndTestForCompletionDueTo(
|
||||||
|
|||||||
Reference in New Issue
Block a user