CUBRID Engine  latest
shard_proxy_function.h
Go to the documentation of this file.
1 /*
2  * Copyright 2008 Search Solution Corporation
3  * Copyright 2016 CUBRID Corporation
4  *
5  * Licensed under the Apache License, Version 2.0 (the "License");
6  * you may not use this file except in compliance with the License.
7  * You may obtain a copy of the License at
8  *
9  * http://www.apache.org/licenses/LICENSE-2.0
10  *
11  * Unless required by applicable law or agreed to in writing, software
12  * distributed under the License is distributed on an "AS IS" BASIS,
13  * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
14  * See the License for the specific language governing permissions and
15  * limitations under the License.
16  *
17  */
18 
19 
20 /*
21  * shard_proxy_function.h -
22  */
23 
24 #ifndef _SHARD_PROXY_FUNCTION_H_
25 #define _SHARD_PROXY_FUNCTION_H_
26 
27 #ident "$Id$"
28 
29 #include "cas_net_buf.h"
30 #include "shard_proxy_common.h"
31 
32 typedef int (*T_PROXY_CLIENT_FUNC) (T_PROXY_CONTEXT * ctx_p, T_PROXY_EVENT * event_p, int argc, char **argv);
33 typedef int (*T_PROXY_CAS_FUNC) (T_PROXY_CONTEXT * ctx_p, T_PROXY_EVENT * event_p);
34 
35 extern int proxy_check_cas_error (char *read_msg);
36 extern int proxy_get_cas_error_code (char *read_msg, T_BROKER_VERSION client_version);
37 extern int proxy_send_request_to_cas (T_PROXY_CONTEXT * ctx_p, T_PROXY_EVENT * event_p, int func_code);
38 
39 /* process client request */
40 extern int fn_proxy_client_end_tran (T_PROXY_CONTEXT * ctx_p, T_PROXY_EVENT * event_p, int argc, char **argv);
41 extern int fn_proxy_client_prepare (T_PROXY_CONTEXT * ctx_p, T_PROXY_EVENT * event_p, int argc, char **argv);
42 extern int fn_proxy_client_execute (T_PROXY_CONTEXT * ctx_p, T_PROXY_EVENT * event_p, int argc, char **argv);
43 extern int fn_proxy_client_set_db_parameter (T_PROXY_CONTEXT * ctx_p, T_PROXY_EVENT * event_p, int argc, char **argv);
44 extern int fn_proxy_client_get_db_parameter (T_PROXY_CONTEXT * ctx_p, T_PROXY_EVENT * event_p, int argc, char **argv);
45 extern int fn_proxy_client_close_req_handle (T_PROXY_CONTEXT * ctx_p, T_PROXY_EVENT * event_p, int argc, char **argv);
46 extern int fn_proxy_client_cursor (T_PROXY_CONTEXT * ctx_p, T_PROXY_EVENT * event_p, int argc, char **argv);
47 extern int fn_proxy_client_fetch (T_PROXY_CONTEXT * ctx_p, T_PROXY_EVENT * event_p, int argc, char **argv);
48 extern int fn_proxy_client_schema_info (T_PROXY_CONTEXT * ctx_p, T_PROXY_EVENT * event_p, int argc, char **argv);
49 extern int fn_proxy_client_check_cas (T_PROXY_CONTEXT * ctx_p, T_PROXY_EVENT * event_p, int argc, char **argv);
50 extern int fn_proxy_client_con_close (T_PROXY_CONTEXT * ctx_p, T_PROXY_EVENT * event_p, int argc, char **argv);
51 extern int fn_proxy_client_get_db_version (T_PROXY_CONTEXT * ctx_p, T_PROXY_EVENT * event_p, int argc, char **argv);
52 extern int fn_proxy_client_cursor_close (T_PROXY_CONTEXT * ctx_p, T_PROXY_EVENT * event_p, int argc, char **argv);
53 extern int fn_proxy_client_execute_array (T_PROXY_CONTEXT * ctx_p, T_PROXY_EVENT * event_p, int argc, char **argv);
54 extern int fn_proxy_get_shard_info (T_PROXY_CONTEXT * ctx_p, T_PROXY_EVENT * event_p, int argc, char **argv);
55 extern int fn_proxy_client_prepare_and_execute (T_PROXY_CONTEXT * ctx_p, T_PROXY_EVENT * event_p, int argc,
56  char **argv);
57 extern int fn_proxy_client_not_supported (T_PROXY_CONTEXT * ctx_p, T_PROXY_EVENT * event_p, int argc, char **argv);
58 
59 /* process cas response */
60 extern int fn_proxy_cas_end_tran (T_PROXY_CONTEXT * ctx_p, T_PROXY_EVENT * event_p);
61 extern int fn_proxy_cas_prepare (T_PROXY_CONTEXT * ctx_p, T_PROXY_EVENT * event_p);
62 extern int fn_proxy_cas_execute (T_PROXY_CONTEXT * ctx_p, T_PROXY_EVENT * event_p);
63 extern int fn_proxy_cas_execute_array (T_PROXY_CONTEXT * ctx_p, T_PROXY_EVENT * event_p);
64 extern int fn_proxy_cas_fetch (T_PROXY_CONTEXT * ctx_p, T_PROXY_EVENT * event_p);
65 extern int fn_proxy_cas_schema_info (T_PROXY_CONTEXT * ctx_p, T_PROXY_EVENT * event_p);
66 extern int fn_proxy_cas_prepare_and_execute (T_PROXY_CONTEXT * ctx_p, T_PROXY_EVENT * event_p);
67 extern int fn_proxy_cas_check_cas (T_PROXY_CONTEXT * ctx_p, T_PROXY_EVENT * event_p);
68 
69 extern int fn_proxy_cas_relay_only (T_PROXY_CONTEXT * ctx_p, T_PROXY_EVENT * event_p);
70 
71 extern int fn_proxy_client_conn_error (T_PROXY_CONTEXT * ctx_p);
72 extern int fn_proxy_cas_conn_error (T_PROXY_CONTEXT * ctx_p);
73 
74 extern int proxy_send_response_to_client (T_PROXY_CONTEXT * ctx_p, T_PROXY_EVENT * event_p);
75 extern int proxy_send_response_to_client_with_new_event (T_PROXY_CONTEXT * ctx_p, unsigned int type, int from,
76  T_PROXY_EVENT_FUNC resp_func);
77 
78 
79 #endif /* _SHARD_PROXY_FUNCTION_H_ */
T_PROXY_EVENT_FUNC
int(* T_PROXY_EVENT_FUNC)(char *driver_info, char **buffer)
Definition: shard_proxy_handler.h:34
fn_proxy_client_execute
int fn_proxy_client_execute(T_PROXY_CONTEXT *ctx_p, T_PROXY_EVENT *event_p, int argc, char **argv)
Definition: shard_proxy_function.c:1304
fn_proxy_cas_conn_error
int fn_proxy_cas_conn_error(T_PROXY_CONTEXT *ctx_p)
Definition: shard_proxy_function.c:3912
fn_proxy_client_conn_error
int fn_proxy_client_conn_error(T_PROXY_CONTEXT *ctx_p)
Definition: shard_proxy_function.c:3871
T_PROXY_CLIENT_FUNC
int(* T_PROXY_CLIENT_FUNC)(T_PROXY_CONTEXT *ctx_p, T_PROXY_EVENT *event_p, int argc, char **argv)
Definition: shard_proxy_function.h:32
fn_proxy_cas_end_tran
int fn_proxy_cas_end_tran(T_PROXY_CONTEXT *ctx_p, T_PROXY_EVENT *event_p)
Definition: shard_proxy_function.c:2958
fn_proxy_client_execute_array
int fn_proxy_client_execute_array(T_PROXY_CONTEXT *ctx_p, T_PROXY_EVENT *event_p, int argc, char **argv)
Definition: shard_proxy_function.c:2556
cas_net_buf.h
t_proxy_event
Definition: shard_proxy_common.h:79
fn_proxy_cas_fetch
int fn_proxy_cas_fetch(T_PROXY_CONTEXT *ctx_p, T_PROXY_EVENT *event_p)
Definition: shard_proxy_function.c:3427
argc
int argc
Definition: dynamic_load.c:951
fn_proxy_client_schema_info
int fn_proxy_client_schema_info(T_PROXY_CONTEXT *ctx_p, T_PROXY_EVENT *event_p, int argc, char **argv)
Definition: shard_proxy_function.c:2122
fn_proxy_client_get_db_version
int fn_proxy_client_get_db_version(T_PROXY_CONTEXT *ctx_p, T_PROXY_EVENT *event_p, int argc, char **argv)
Definition: shard_proxy_function.c:2414
t_proxy_context
Definition: shard_proxy_common.h:223
proxy_check_cas_error
int proxy_check_cas_error(char *read_msg)
Definition: shard_proxy_function.c:90
fn_proxy_client_fetch
int fn_proxy_client_fetch(T_PROXY_CONTEXT *ctx_p, T_PROXY_EVENT *event_p, int argc, char **argv)
Definition: shard_proxy_function.c:2033
fn_proxy_client_not_supported
int fn_proxy_client_not_supported(T_PROXY_CONTEXT *ctx_p, T_PROXY_EVENT *event_p, int argc, char **argv)
Definition: shard_proxy_function.c:2937
shard_proxy_common.h
fn_proxy_client_con_close
int fn_proxy_client_con_close(T_PROXY_CONTEXT *ctx_p, T_PROXY_EVENT *event_p, int argc, char **argv)
Definition: shard_proxy_function.c:2352
fn_proxy_client_check_cas
int fn_proxy_client_check_cas(T_PROXY_CONTEXT *ctx_p, T_PROXY_EVENT *event_p, int argc, char **argv)
Definition: shard_proxy_function.c:2254
proxy_send_response_to_client_with_new_event
int proxy_send_response_to_client_with_new_event(T_PROXY_CONTEXT *ctx_p, unsigned int type, int from, T_PROXY_EVENT_FUNC resp_func)
Definition: shard_proxy_function.c:327
fn_proxy_cas_schema_info
int fn_proxy_cas_schema_info(T_PROXY_CONTEXT *ctx_p, T_PROXY_EVENT *event_p)
Definition: shard_proxy_function.c:3467
fn_proxy_client_end_tran
int fn_proxy_client_end_tran(T_PROXY_CONTEXT *ctx_p, T_PROXY_EVENT *event_p, int argc, char **argv)
Definition: shard_proxy_function.c:829
fn_proxy_client_close_req_handle
int fn_proxy_client_close_req_handle(T_PROXY_CONTEXT *ctx_p, T_PROXY_EVENT *event_p, int argc, char **argv)
Definition: shard_proxy_function.c:1849
fn_proxy_cas_relay_only
int fn_proxy_cas_relay_only(T_PROXY_CONTEXT *ctx_p, T_PROXY_EVENT *event_p)
Definition: shard_proxy_function.c:3837
fn_proxy_client_set_db_parameter
int fn_proxy_client_set_db_parameter(T_PROXY_CONTEXT *ctx_p, T_PROXY_EVENT *event_p, int argc, char **argv)
Definition: shard_proxy_function.c:1673
fn_proxy_cas_check_cas
int fn_proxy_cas_check_cas(T_PROXY_CONTEXT *ctx_p, T_PROXY_EVENT *event_p)
Definition: shard_proxy_function.c:3739
proxy_send_request_to_cas
int proxy_send_request_to_cas(T_PROXY_CONTEXT *ctx_p, T_PROXY_EVENT *event_p, int func_code)
Definition: shard_proxy_function.c:123
fn_proxy_cas_execute
int fn_proxy_cas_execute(T_PROXY_CONTEXT *ctx_p, T_PROXY_EVENT *event_p)
Definition: shard_proxy_function.c:3279
fn_proxy_cas_prepare_and_execute
int fn_proxy_cas_prepare_and_execute(T_PROXY_CONTEXT *ctx_p, T_PROXY_EVENT *event_p)
Definition: shard_proxy_function.c:3584
fn_proxy_get_shard_info
int fn_proxy_get_shard_info(T_PROXY_CONTEXT *ctx_p, T_PROXY_EVENT *event_p, int argc, char **argv)
Definition: shard_proxy_function.c:2582
proxy_get_cas_error_code
int proxy_get_cas_error_code(char *read_msg, T_BROKER_VERSION client_version)
Definition: shard_proxy_function.c:104
fn_proxy_client_prepare_and_execute
int fn_proxy_client_prepare_and_execute(T_PROXY_CONTEXT *ctx_p, T_PROXY_EVENT *event_p, int argc, char **argv)
Definition: shard_proxy_function.c:2616
fn_proxy_client_cursor
int fn_proxy_client_cursor(T_PROXY_CONTEXT *ctx_p, T_PROXY_EVENT *event_p, int argc, char **argv)
Definition: shard_proxy_function.c:1943
argv
const char ** argv
Definition: dynamic_load.c:952
fn_proxy_cas_prepare
int fn_proxy_cas_prepare(T_PROXY_CONTEXT *ctx_p, T_PROXY_EVENT *event_p)
Definition: shard_proxy_function.c:3016
T_BROKER_VERSION
int T_BROKER_VERSION
Definition: cas_protocol.h:342
fn_proxy_client_prepare
int fn_proxy_client_prepare(T_PROXY_CONTEXT *ctx_p, T_PROXY_EVENT *event_p, int argc, char **argv)
Definition: shard_proxy_function.c:891
fn_proxy_client_get_db_parameter
int fn_proxy_client_get_db_parameter(T_PROXY_CONTEXT *ctx_p, T_PROXY_EVENT *event_p, int argc, char **argv)
Definition: shard_proxy_function.c:1770
fn_proxy_client_cursor_close
int fn_proxy_client_cursor_close(T_PROXY_CONTEXT *ctx_p, T_PROXY_EVENT *event_p, int argc, char **argv)
Definition: shard_proxy_function.c:2466
fn_proxy_cas_execute_array
int fn_proxy_cas_execute_array(T_PROXY_CONTEXT *ctx_p, T_PROXY_EVENT *event_p)
Definition: shard_proxy_function.c:3402
proxy_send_response_to_client
int proxy_send_response_to_client(T_PROXY_CONTEXT *ctx_p, T_PROXY_EVENT *event_p)
Definition: shard_proxy_function.c:295
T_PROXY_CAS_FUNC
int(* T_PROXY_CAS_FUNC)(T_PROXY_CONTEXT *ctx_p, T_PROXY_EVENT *event_p)
Definition: shard_proxy_function.h:33