@@ -114,7 +114,7 @@ printDatum(const Datum &datum)
114114 */
115115template <class BUFFER , class Data = std::vector<UserTuple>>
116116void
117- printResponse (Response<BUFFER> &response, Data data = std::vector<UserTuple>())
117+ printResponse (Response<BUFFER> &response, Data data = std::vector<UserTuple>())
118118{
119119 if (response.body .error_stack != std::nullopt ) {
120120 Error err = (*response.body .error_stack )[0 ];
@@ -699,7 +699,7 @@ class StmtProcessorPrepare {
699699 std::string &stmt)
700700 {
701701 rid_t future = conn.prepare (stmt);
702-
702+
703703 client.wait (conn, future, WAIT_TIMEOUT);
704704 fail_unless (conn.futureIsReady (future));
705705 std::optional<Response<Buf_t>> response = conn.getResponse (future);
@@ -769,7 +769,7 @@ single_conn_sql(Connector<BUFFER, NetProvider> &client)
769769 " COLUMN2 VARCHAR(50), COLUMN3 DOUBLE);" ;
770770 auto stmt = StmtProcessor::process (client, conn, stmt_str);
771771 rid_t create_table = conn.execute (stmt, std::make_tuple ());
772-
772+
773773 client.wait (conn, create_table, WAIT_TIMEOUT);
774774 fail_unless (conn.futureIsReady (create_table));
775775 std::optional<Response<Buf_t>> response = conn.getResponse (create_table);
@@ -784,7 +784,7 @@ single_conn_sql(Connector<BUFFER, NetProvider> &client)
784784 stmt_str = " INSERT INTO TSQL VALUES (20, 'first', 3.2), (21, 'second', 5.4)" ;
785785 stmt = StmtProcessor::process (client, conn, stmt_str);
786786 rid_t insert = conn.execute (stmt, std::make_tuple ());
787-
787+
788788 client.wait (conn, insert, WAIT_TIMEOUT);
789789 fail_unless (conn.futureIsReady (insert));
790790 response = conn.getResponse (insert);
@@ -803,7 +803,7 @@ single_conn_sql(Connector<BUFFER, NetProvider> &client)
803803 stmt_str = " INSERT INTO TSQL VALUES (?, ?, ?), (?, ?, ?), (?, ?, ?);" ;
804804 stmt = StmtProcessor::process (client, conn, stmt_str);
805805 rid_t insert_args = conn.execute (stmt, args);
806-
806+
807807 client.wait (conn, insert_args, WAIT_TIMEOUT);
808808 fail_unless (conn.futureIsReady (insert_args));
809809 response = conn.getResponse (insert_args);
@@ -818,7 +818,7 @@ single_conn_sql(Connector<BUFFER, NetProvider> &client)
818818 stmt_str = " SELECT * FROM SEQSCAN TSQL;" ;
819819 stmt = StmtProcessor::process (client, conn, stmt_str);
820820 rid_t select = conn.execute (stmt, std::make_tuple ());
821-
821+
822822 client.wait (conn, select, WAIT_TIMEOUT);
823823 fail_unless (conn.futureIsReady (select));
824824 response = conn.getResponse (select);
@@ -841,7 +841,7 @@ single_conn_sql(Connector<BUFFER, NetProvider> &client)
841841 stmt_str = " DROP TABLE IF EXISTS TSQL;" ;
842842 stmt = StmtProcessor::process (client, conn, stmt_str);
843843 rid_t drop_table = conn.execute (stmt, std::make_tuple ());
844-
844+
845845 client.wait (conn, drop_table, WAIT_TIMEOUT);
846846 fail_unless (conn.futureIsReady (drop_table));
847847 response = conn.getResponse (drop_table);
@@ -902,7 +902,7 @@ single_conn_sql(Connector<BUFFER, NetProvider> &client)
902902 stmt_str = " SELECT * FROM SEQSCAN TSQL;" ;
903903 stmt = StmtProcessor::process (client, conn, stmt_str);
904904 select = conn.execute (stmt, std::make_tuple ());
905-
905+
906906 client.wait (conn, select, WAIT_TIMEOUT);
907907 fail_unless (conn.futureIsReady (select));
908908 response = conn.getResponse (select);
@@ -955,7 +955,7 @@ single_conn_sql(Connector<BUFFER, NetProvider> &client)
955955 stmt_str = " UPDATE \" _session_settings\" SET \" value\" = false WHERE \" name\" = 'sql_full_metadata';" ;
956956 stmt = StmtProcessor::process (client, conn, stmt_str);
957957 rid_t disable_metadata = conn.execute (stmt, std::make_tuple ());
958-
958+
959959 client.wait (conn, disable_metadata, WAIT_TIMEOUT);
960960 fail_unless (conn.futureIsReady (disable_metadata));
961961 response = conn.getResponse (disable_metadata);
0 commit comments