Home
last modified time | relevance | path

Searched refs:IS_MASTER_NODE_ID (Results 1 – 25 of 32) sorted by relevance

12

/dports/databases/pgpool-II-41/pgpool-II-4.1.10/src/protocol/
H A Dpool_proto2.c65 if (VALID_BACKEND(i) && !IS_MASTER_NODE_ID(i)) in AsciiRow()
122 if (VALID_BACKEND(j) && !IS_MASTER_NODE_ID(j)) in AsciiRow()
192 if (VALID_BACKEND(i) && !IS_MASTER_NODE_ID(i)) in BinaryRow()
225 if (VALID_BACKEND(j) && !IS_MASTER_NODE_ID(j)) in BinaryRow()
247 if (IS_MASTER_NODE_ID(j)) in BinaryRow()
258 if (IS_MASTER_NODE_ID(j)) in BinaryRow()
299 if (!VALID_BACKEND(i) || IS_MASTER_NODE_ID(i)) in CompletedResponse()
360 if (VALID_BACKEND(i) && !IS_MASTER_NODE_ID(i)) in CursorResponse()
578 if (IS_MASTER_NODE_ID(i)) in NotificationResponse()
617 if (VALID_BACKEND(i) && !IS_MASTER_NODE_ID(i)) in RowDescription()
[all …]
H A DCommandComplete.c445 if (!IS_MASTER_NODE_ID(i)) in handle_mismatch_tuples()
H A Dpool_process_query.c317 if (IS_MASTER_NODE_ID(i)) in pool_process_query()
728 if (VALID_BACKEND(i) && !IS_MASTER_NODE_ID(i)) in SimpleForwardToFrontend()
924 if (IS_MASTER_NODE_ID(i)) in ParameterStatus()
2744 if (VALID_BACKEND(i) && !IS_MASTER_NODE_ID(i)) in insert_lock()
3357 if (IS_MASTER_NODE_ID(i)) in read_kind_from_backend()
4023 if (VALID_BACKEND(i) && !IS_MASTER_NODE_ID(i) && in end_internal_transaction()
/dports/databases/pgpool-II-36/pgpool-II-3.6.28/src/protocol/
H A Dpool_proto2.c60 if (VALID_BACKEND(i) && !IS_MASTER_NODE_ID(i)) in AsciiRow()
116 if (VALID_BACKEND(j) && !IS_MASTER_NODE_ID(j)) in AsciiRow()
181 if (VALID_BACKEND(i) && !IS_MASTER_NODE_ID(i)) in BinaryRow()
213 if (VALID_BACKEND(j) && !IS_MASTER_NODE_ID(j)) in BinaryRow()
234 if (IS_MASTER_NODE_ID(j)) in BinaryRow()
245 if (IS_MASTER_NODE_ID(j)) in BinaryRow()
284 if (!VALID_BACKEND(i) || IS_MASTER_NODE_ID(i)) in CompletedResponse()
343 if (VALID_BACKEND(i) && !IS_MASTER_NODE_ID(i)) in CursorResponse()
553 if (IS_MASTER_NODE_ID(i)) in NotificationResponse()
586 if (VALID_BACKEND(i) && !IS_MASTER_NODE_ID(i)) in RowDescription()
[all …]
H A DCommandComplete.c362 if (!IS_MASTER_NODE_ID(i)) in handle_mismatch_tuples()
H A Dpool_process_query.c300 if (IS_MASTER_NODE_ID(i)) in pool_process_query()
765 if (VALID_BACKEND(i) && !IS_MASTER_NODE_ID(i)) in SimpleForwardToFrontend()
948 if (IS_MASTER_NODE_ID(i)) in ParameterStatus()
2738 if (VALID_BACKEND(i) && !IS_MASTER_NODE_ID(i)) in insert_lock()
3328 if (IS_MASTER_NODE_ID(i)) in read_kind_from_backend()
3986 if (VALID_BACKEND(i) && !IS_MASTER_NODE_ID(i) && in end_internal_transaction()
/dports/databases/pgpool-II-37/pgpool-II-3.7.22/src/protocol/
H A Dpool_proto2.c60 if (VALID_BACKEND(i) && !IS_MASTER_NODE_ID(i)) in AsciiRow()
116 if (VALID_BACKEND(j) && !IS_MASTER_NODE_ID(j)) in AsciiRow()
181 if (VALID_BACKEND(i) && !IS_MASTER_NODE_ID(i)) in BinaryRow()
213 if (VALID_BACKEND(j) && !IS_MASTER_NODE_ID(j)) in BinaryRow()
234 if (IS_MASTER_NODE_ID(j)) in BinaryRow()
245 if (IS_MASTER_NODE_ID(j)) in BinaryRow()
284 if (!VALID_BACKEND(i) || IS_MASTER_NODE_ID(i)) in CompletedResponse()
343 if (VALID_BACKEND(i) && !IS_MASTER_NODE_ID(i)) in CursorResponse()
553 if (IS_MASTER_NODE_ID(i)) in NotificationResponse()
586 if (VALID_BACKEND(i) && !IS_MASTER_NODE_ID(i)) in RowDescription()
[all …]
H A DCommandComplete.c361 if (!IS_MASTER_NODE_ID(i)) in handle_mismatch_tuples()
H A Dpool_process_query.c301 if (IS_MASTER_NODE_ID(i)) in pool_process_query()
766 if (VALID_BACKEND(i) && !IS_MASTER_NODE_ID(i)) in SimpleForwardToFrontend()
949 if (IS_MASTER_NODE_ID(i)) in ParameterStatus()
2739 if (VALID_BACKEND(i) && !IS_MASTER_NODE_ID(i)) in insert_lock()
3332 if (IS_MASTER_NODE_ID(i)) in read_kind_from_backend()
3991 if (VALID_BACKEND(i) && !IS_MASTER_NODE_ID(i) && in end_internal_transaction()
/dports/databases/pgpool-II-40/pgpool-II-4.0.17/src/protocol/
H A Dpool_proto2.c65 if (VALID_BACKEND(i) && !IS_MASTER_NODE_ID(i)) in AsciiRow()
122 if (VALID_BACKEND(j) && !IS_MASTER_NODE_ID(j)) in AsciiRow()
192 if (VALID_BACKEND(i) && !IS_MASTER_NODE_ID(i)) in BinaryRow()
225 if (VALID_BACKEND(j) && !IS_MASTER_NODE_ID(j)) in BinaryRow()
247 if (IS_MASTER_NODE_ID(j)) in BinaryRow()
258 if (IS_MASTER_NODE_ID(j)) in BinaryRow()
299 if (!VALID_BACKEND(i) || IS_MASTER_NODE_ID(i)) in CompletedResponse()
360 if (VALID_BACKEND(i) && !IS_MASTER_NODE_ID(i)) in CursorResponse()
578 if (IS_MASTER_NODE_ID(i)) in NotificationResponse()
617 if (VALID_BACKEND(i) && !IS_MASTER_NODE_ID(i)) in RowDescription()
[all …]
H A DCommandComplete.c383 if (!IS_MASTER_NODE_ID(i)) in handle_mismatch_tuples()
H A Dpool_process_query.c319 if (IS_MASTER_NODE_ID(i)) in pool_process_query()
819 if (VALID_BACKEND(i) && !IS_MASTER_NODE_ID(i)) in SimpleForwardToFrontend()
1008 if (IS_MASTER_NODE_ID(i)) in ParameterStatus()
2828 if (VALID_BACKEND(i) && !IS_MASTER_NODE_ID(i)) in insert_lock()
3441 if (IS_MASTER_NODE_ID(i)) in read_kind_from_backend()
4107 if (VALID_BACKEND(i) && !IS_MASTER_NODE_ID(i) && in end_internal_transaction()
/dports/databases/pgpool-II-37/pgpool-II-3.7.22/src/auth/
H A Dpool_auth.c547 if (IS_MASTER_NODE_ID(backend->db_node_id)) in do_clear_text_password()
641 if (IS_MASTER_NODE_ID(backend->db_node_id)) in do_clear_text_password()
687 if (IS_MASTER_NODE_ID(backend->db_node_id)) in do_crypt()
835 if (IS_MASTER_NODE_ID(backend->db_node_id)) in do_md5()
882 if (IS_MASTER_NODE_ID(backend->db_node_id)) in do_md5()
912 if (IS_MASTER_NODE_ID(backend->db_node_id)) in do_md5()
1121 if (!VALID_BACKEND(i) || IS_MASTER_NODE_ID(i)) in pool_read_message_length()
1172 if (VALID_BACKEND(i) && !IS_MASTER_NODE_ID(i)) in pool_read_message_length2()
1219 if (IS_MASTER_NODE_ID(i)) in pool_read_kind()
1272 if (IS_MASTER_NODE_ID(i)) in pool_read_int()
/dports/databases/pgpool-II-36/pgpool-II-3.6.28/src/auth/
H A Dpool_auth.c546 if (IS_MASTER_NODE_ID(backend->db_node_id)) in do_clear_text_password()
640 if (IS_MASTER_NODE_ID(backend->db_node_id)) in do_clear_text_password()
686 if (IS_MASTER_NODE_ID(backend->db_node_id)) in do_crypt()
834 if (IS_MASTER_NODE_ID(backend->db_node_id)) in do_md5()
881 if (IS_MASTER_NODE_ID(backend->db_node_id)) in do_md5()
911 if (IS_MASTER_NODE_ID(backend->db_node_id)) in do_md5()
1120 if (!VALID_BACKEND(i) || IS_MASTER_NODE_ID(i)) in pool_read_message_length()
1171 if (VALID_BACKEND(i) && !IS_MASTER_NODE_ID(i)) in pool_read_message_length2()
1218 if (IS_MASTER_NODE_ID(i)) in pool_read_kind()
1271 if (IS_MASTER_NODE_ID(i)) in pool_read_int()
/dports/databases/pgpool-II-41/pgpool-II-4.1.10/src/auth/
H A Dpool_auth.c1100 if (IS_MASTER_NODE_ID(backend->db_node_id)) in do_clear_text_password()
1137 if (IS_MASTER_NODE_ID(backend->db_node_id)) in do_crypt()
1777 if (IS_MASTER_NODE_ID(backend->db_node_id) && frontend->frontend_authenticated == false) in do_md5()
1830 if (IS_MASTER_NODE_ID(backend->db_node_id)) in do_md5()
2029 if (!VALID_BACKEND(i) || IS_MASTER_NODE_ID(i)) in pool_read_message_length()
2083 if (VALID_BACKEND(i) && !IS_MASTER_NODE_ID(i)) in pool_read_message_length2()
2132 if (IS_MASTER_NODE_ID(i)) in pool_read_kind()
2187 if (IS_MASTER_NODE_ID(i)) in pool_read_int()
2299 …if (frontend && IS_MASTER_NODE_ID(backend->db_node_id) && frontend->frontend_authenticated == fals… in do_SCRAM()
/dports/databases/pgpool-II-40/pgpool-II-4.0.17/src/auth/
H A Dpool_auth.c1091 if (IS_MASTER_NODE_ID(backend->db_node_id)) in do_clear_text_password()
1128 if (IS_MASTER_NODE_ID(backend->db_node_id)) in do_crypt()
1768 if (IS_MASTER_NODE_ID(backend->db_node_id) && frontend->frontend_authenticated == false) in do_md5()
1821 if (IS_MASTER_NODE_ID(backend->db_node_id)) in do_md5()
2020 if (!VALID_BACKEND(i) || IS_MASTER_NODE_ID(i)) in pool_read_message_length()
2074 if (VALID_BACKEND(i) && !IS_MASTER_NODE_ID(i)) in pool_read_message_length2()
2123 if (IS_MASTER_NODE_ID(i)) in pool_read_kind()
2178 if (IS_MASTER_NODE_ID(i)) in pool_read_int()
2290 …if (frontend && IS_MASTER_NODE_ID(backend->db_node_id) && frontend->frontend_authenticated == fals… in do_SCRAM()
/dports/databases/pgpool-II-36/pgpool-II-3.6.28/src/utils/
H A Dpool_stream.c165 if (!IS_MASTER_NODE_ID(cp->db_node_id) && (getpid() != mypid)) in pool_read()
317 if (!IS_MASTER_NODE_ID(cp->db_node_id)) in pool_read2()
899 if (!IS_MASTER_NODE_ID(cp->db_node_id)) in pool_read_string()
/dports/databases/pgpool-II-40/pgpool-II-4.0.17/src/utils/
H A Dpool_stream.c168 if (!IS_MASTER_NODE_ID(cp->db_node_id) && (getpid() != mypid)) in pool_read()
332 if (!IS_MASTER_NODE_ID(cp->db_node_id)) in pool_read2()
936 if (!IS_MASTER_NODE_ID(cp->db_node_id)) in pool_read_string()
/dports/databases/pgpool-II-41/pgpool-II-4.1.10/src/utils/
H A Dpool_stream.c175 if (!IS_MASTER_NODE_ID(cp->db_node_id) && (getpid() != mypid)) in pool_read()
343 if (!IS_MASTER_NODE_ID(cp->db_node_id)) in pool_read2()
947 if (!IS_MASTER_NODE_ID(cp->db_node_id)) in pool_read_string()
/dports/databases/pgpool-II-37/pgpool-II-3.7.22/src/utils/
H A Dpool_stream.c165 if (!IS_MASTER_NODE_ID(cp->db_node_id) && (getpid() != mypid)) in pool_read()
324 if (!IS_MASTER_NODE_ID(cp->db_node_id)) in pool_read2()
906 if (!IS_MASTER_NODE_ID(cp->db_node_id)) in pool_read_string()
/dports/databases/pgpool-II-36/pgpool-II-3.6.28/src/context/
H A Dpool_query_context.c772 if (is_commit && MASTER_SLAVE && !IS_MASTER_NODE_ID(i) && TSTATE(backend, i) == 'I') in pool_send_and_wait()
823 if (is_commit && MASTER_SLAVE && !IS_MASTER_NODE_ID(i) && TSTATE(backend, i) == 'I') in pool_send_and_wait()
1034 if (is_commit && MASTER_SLAVE && !IS_MASTER_NODE_ID(i) && TSTATE(backend, i) == 'I') in pool_extended_send_and_wait()
/dports/databases/pgpool-II-40/pgpool-II-4.0.17/src/context/
H A Dpool_query_context.c794 if (is_commit && MASTER_SLAVE && !IS_MASTER_NODE_ID(i) && TSTATE(backend, i) == 'I') in pool_send_and_wait()
845 if (is_commit && MASTER_SLAVE && !IS_MASTER_NODE_ID(i) && TSTATE(backend, i) == 'I') in pool_send_and_wait()
1053 if (is_commit && MASTER_SLAVE && !IS_MASTER_NODE_ID(i) && TSTATE(backend, i) == 'I') in pool_extended_send_and_wait()
/dports/databases/pgpool-II-37/pgpool-II-3.7.22/src/context/
H A Dpool_query_context.c765 if (is_commit && MASTER_SLAVE && !IS_MASTER_NODE_ID(i) && TSTATE(backend, i) == 'I') in pool_send_and_wait()
816 if (is_commit && MASTER_SLAVE && !IS_MASTER_NODE_ID(i) && TSTATE(backend, i) == 'I') in pool_send_and_wait()
1027 if (is_commit && MASTER_SLAVE && !IS_MASTER_NODE_ID(i) && TSTATE(backend, i) == 'I') in pool_extended_send_and_wait()
/dports/databases/pgpool-II-41/pgpool-II-4.1.10/src/context/
H A Dpool_query_context.c803 if (is_commit && MASTER_SLAVE && !IS_MASTER_NODE_ID(i) && TSTATE(backend, i) == 'I') in pool_send_and_wait()
854 if (is_commit && MASTER_SLAVE && !IS_MASTER_NODE_ID(i) && TSTATE(backend, i) == 'I') in pool_send_and_wait()
1062 if (is_commit && MASTER_SLAVE && !IS_MASTER_NODE_ID(i) && TSTATE(backend, i) == 'I') in pool_extended_send_and_wait()
/dports/databases/pgpool-II-37/pgpool-II-3.7.22/src/include/
H A Dpool.h352 #define IS_MASTER_NODE_ID(node_id) (MASTER_NODE_ID == (node_id)) macro

12