clang-format
This commit is contained in:
		@@ -241,8 +241,7 @@ namespace ix
 | 
				
			|||||||
        }
 | 
					        }
 | 
				
			||||||
 | 
					
 | 
				
			||||||
        // Make a new cancellation object dealing with transfer timeout
 | 
					        // Make a new cancellation object dealing with transfer timeout
 | 
				
			||||||
        isCancellationRequested =
 | 
					        isCancellationRequested = makeCancellationRequestWithTimeout(args->transferTimeout, _stop);
 | 
				
			||||||
            makeCancellationRequestWithTimeout(args->transferTimeout, _stop);
 | 
					 | 
				
			||||||
 | 
					
 | 
				
			||||||
        if (args->verbose)
 | 
					        if (args->verbose)
 | 
				
			||||||
        {
 | 
					        {
 | 
				
			||||||
 
 | 
				
			|||||||
@@ -159,14 +159,8 @@ TEST_CASE("Cobra_to_sentry_bot", "[cobra_bots]")
 | 
				
			|||||||
        // Only run the bot for 3 seconds
 | 
					        // Only run the bot for 3 seconds
 | 
				
			||||||
        int runtime = 3;
 | 
					        int runtime = 3;
 | 
				
			||||||
 | 
					
 | 
				
			||||||
        int64_t sentCount = cobra_to_sentry_bot(config,
 | 
					        int64_t sentCount = cobra_to_sentry_bot(
 | 
				
			||||||
                                                channel,
 | 
					            config, channel, filter, position, sentryClient, verbose, enableHeartbeat, runtime);
 | 
				
			||||||
                                                filter,
 | 
					 | 
				
			||||||
                                                position,
 | 
					 | 
				
			||||||
                                                sentryClient,
 | 
					 | 
				
			||||||
                                                verbose,
 | 
					 | 
				
			||||||
                                                enableHeartbeat,
 | 
					 | 
				
			||||||
                                                runtime);
 | 
					 | 
				
			||||||
        //
 | 
					        //
 | 
				
			||||||
        // We want at least 2 messages to be sent
 | 
					        // We want at least 2 messages to be sent
 | 
				
			||||||
        //
 | 
					        //
 | 
				
			||||||
 
 | 
				
			|||||||
@@ -96,14 +96,8 @@ TEST_CASE("Cobra_to_stdout_bot", "[cobra_bots]")
 | 
				
			|||||||
        // We could try to capture the output ... not sure how.
 | 
					        // We could try to capture the output ... not sure how.
 | 
				
			||||||
        bool fluentd = true;
 | 
					        bool fluentd = true;
 | 
				
			||||||
 | 
					
 | 
				
			||||||
        int64_t sentCount = ix::cobra_to_stdout_bot(config,
 | 
					        int64_t sentCount = ix::cobra_to_stdout_bot(
 | 
				
			||||||
                                                    channel,
 | 
					            config, channel, filter, position, fluentd, quiet, enableHeartbeat, runtime);
 | 
				
			||||||
                                                    filter,
 | 
					 | 
				
			||||||
                                                    position,
 | 
					 | 
				
			||||||
                                                    fluentd,
 | 
					 | 
				
			||||||
                                                    quiet,
 | 
					 | 
				
			||||||
                                                    enableHeartbeat,
 | 
					 | 
				
			||||||
                                                    runtime);
 | 
					 | 
				
			||||||
        //
 | 
					        //
 | 
				
			||||||
        // We want at least 2 messages to be sent
 | 
					        // We want at least 2 messages to be sent
 | 
				
			||||||
        //
 | 
					        //
 | 
				
			||||||
 
 | 
				
			|||||||
@@ -4,7 +4,7 @@
 | 
				
			|||||||
 *  Copyright (c) 2019 Machine Zone. All rights reserved.
 | 
					 *  Copyright (c) 2019 Machine Zone. All rights reserved.
 | 
				
			||||||
 */
 | 
					 */
 | 
				
			||||||
 | 
					
 | 
				
			||||||
// Using inet_addr will trigger an error on uwp without this 
 | 
					// Using inet_addr will trigger an error on uwp without this
 | 
				
			||||||
// FIXME: use a different api
 | 
					// FIXME: use a different api
 | 
				
			||||||
#ifdef _WIN32
 | 
					#ifdef _WIN32
 | 
				
			||||||
#ifndef _WINSOCK_DEPRECATED_NO_WARNINGS
 | 
					#ifndef _WINSOCK_DEPRECATED_NO_WARNINGS
 | 
				
			||||||
 
 | 
				
			|||||||
							
								
								
									
										12
									
								
								ws/ws.cpp
									
									
									
									
									
								
							
							
						
						
									
										12
									
								
								ws/ws.cpp
									
									
									
									
									
								
							@@ -19,8 +19,8 @@
 | 
				
			|||||||
#include <ixwebsocket/IXNetSystem.h>
 | 
					#include <ixwebsocket/IXNetSystem.h>
 | 
				
			||||||
#include <ixwebsocket/IXSocket.h>
 | 
					#include <ixwebsocket/IXSocket.h>
 | 
				
			||||||
#include <ixwebsocket/IXUserAgent.h>
 | 
					#include <ixwebsocket/IXUserAgent.h>
 | 
				
			||||||
#include <spdlog/spdlog.h>
 | 
					 | 
				
			||||||
#include <spdlog/sinks/basic_file_sink.h>
 | 
					#include <spdlog/sinks/basic_file_sink.h>
 | 
				
			||||||
 | 
					#include <spdlog/spdlog.h>
 | 
				
			||||||
#include <sstream>
 | 
					#include <sstream>
 | 
				
			||||||
#include <string>
 | 
					#include <string>
 | 
				
			||||||
 | 
					
 | 
				
			||||||
@@ -522,14 +522,8 @@ int main(int argc, char** argv)
 | 
				
			|||||||
    else if (app.got_subcommand("cobra_subscribe"))
 | 
					    else if (app.got_subcommand("cobra_subscribe"))
 | 
				
			||||||
    {
 | 
					    {
 | 
				
			||||||
        bool enableHeartbeat = true;
 | 
					        bool enableHeartbeat = true;
 | 
				
			||||||
        int64_t sentCount = ix::cobra_to_stdout_bot(cobraConfig,
 | 
					        int64_t sentCount = ix::cobra_to_stdout_bot(
 | 
				
			||||||
                                                    channel,
 | 
					            cobraConfig, channel, filter, position, fluentd, quiet, enableHeartbeat, runtime);
 | 
				
			||||||
                                                    filter,
 | 
					 | 
				
			||||||
                                                    position,
 | 
					 | 
				
			||||||
                                                    fluentd,
 | 
					 | 
				
			||||||
                                                    quiet,
 | 
					 | 
				
			||||||
                                                    enableHeartbeat,
 | 
					 | 
				
			||||||
                                                    runtime);
 | 
					 | 
				
			||||||
        ret = (int) sentCount;
 | 
					        ret = (int) sentCount;
 | 
				
			||||||
    }
 | 
					    }
 | 
				
			||||||
    else if (app.got_subcommand("cobra_publish"))
 | 
					    else if (app.got_subcommand("cobra_publish"))
 | 
				
			||||||
 
 | 
				
			|||||||
		Reference in New Issue
	
	Block a user