diff options
Diffstat (limited to 'src/ccapi/server/ccs_client.c')
| -rw-r--r-- | src/ccapi/server/ccs_client.c | 94 |
1 files changed, 47 insertions, 47 deletions
diff --git a/src/ccapi/server/ccs_client.c b/src/ccapi/server/ccs_client.c index 31ed14ff4..72ae89de1 100644 --- a/src/ccapi/server/ccs_client.c +++ b/src/ccapi/server/ccs_client.c @@ -43,39 +43,39 @@ cc_int32 ccs_client_new (ccs_client_t *out_client, { cc_int32 err = ccNoError; ccs_client_t client = NULL; - + if (!out_client ) { err = cci_check_error (ccErrBadParam); } if (!ccs_pipe_valid (in_client_pipe)) { err = cci_check_error (ccErrBadParam); } - + if (!err) { client = malloc (sizeof (*client)); - if (client) { + if (client) { *client = ccs_client_initializer; } else { - err = cci_check_error (ccErrNoMem); + err = cci_check_error (ccErrNoMem); } } - + if (!err) { err = ccs_callbackref_array_new (&client->callbacks); } - + if (!err) { err = ccs_iteratorref_array_new (&client->iterators); } - + if (!err) { err = ccs_pipe_copy (&client->client_pipe, in_client_pipe); } - + if (!err) { *out_client = client; client = NULL; } - + ccs_client_release (client); - - return cci_check_error (err); + + return cci_check_error (err); } /* ------------------------------------------------------------------------ */ @@ -83,26 +83,26 @@ cc_int32 ccs_client_new (ccs_client_t *out_client, cc_int32 ccs_client_release (ccs_client_t io_client) { cc_int32 err = ccNoError; - + if (!err && io_client) { cc_uint64 i; cc_uint64 callback_count = ccs_callbackref_array_count (io_client->callbacks); cc_uint64 iterator_count = ccs_iteratorref_array_count (io_client->iterators); - + for (i = 0; !err && i < callback_count; i++) { ccs_callback_t callback = ccs_callbackref_array_object_at_index (io_client->callbacks, i); - - cci_debug_printf ("%s: Invalidating callback reference %p.", + + cci_debug_printf ("%s: Invalidating callback reference %p.", __FUNCTION__, callback); ccs_callback_invalidate (callback); } - + for (i = 0; !err && i < iterator_count; i++) { ccs_generic_list_iterator_t iterator = ccs_iteratorref_array_object_at_index (io_client->iterators, i); - - cci_debug_printf ("%s: Invalidating iterator reference %p.", + + cci_debug_printf ("%s: Invalidating iterator reference %p.", __FUNCTION__, iterator); - ccs_generic_list_iterator_invalidate (iterator); + ccs_generic_list_iterator_invalidate (iterator); } ccs_callbackref_array_release (io_client->callbacks); @@ -110,8 +110,8 @@ cc_int32 ccs_client_release (ccs_client_t io_client) ccs_pipe_release (io_client->client_pipe); free (io_client); } - - return cci_check_error (err); + + return cci_check_error (err); } /* ------------------------------------------------------------------------ */ @@ -120,16 +120,16 @@ cc_int32 ccs_client_add_callback (ccs_client_t io_client, ccs_callback_t in_callback) { cc_int32 err = ccNoError; - + if (!io_client ) { err = cci_check_error (ccErrBadParam); } if (!in_callback) { err = cci_check_error (ccErrBadParam); } - + if (!err) { err = ccs_callbackref_array_insert (io_client->callbacks, in_callback, ccs_callbackref_array_count (io_client->callbacks)); } - - return cci_check_error (err); + + return cci_check_error (err); } @@ -140,16 +140,16 @@ cc_int32 ccs_client_remove_callback (ccs_client_t io_client, { cc_int32 err = ccNoError; cc_uint32 found_callback = 0; - + if (!io_client) { err = cci_check_error (ccErrBadParam); } - + if (!err) { cc_uint64 i; cc_uint64 lock_count = ccs_callbackref_array_count (io_client->callbacks); - + for (i = 0; !err && i < lock_count; i++) { ccs_callback_t callback = ccs_callbackref_array_object_at_index (io_client->callbacks, i); - + if (callback == in_callback) { cci_debug_printf ("%s: Removing callback reference %p.", __FUNCTION__, callback); found_callback = 1; @@ -158,12 +158,12 @@ cc_int32 ccs_client_remove_callback (ccs_client_t io_client, } } } - + if (!err && !found_callback) { cci_debug_printf ("%s: WARNING! callback not found.", __FUNCTION__); } - - return cci_check_error (err); + + return cci_check_error (err); } /* ------------------------------------------------------------------------ */ @@ -172,16 +172,16 @@ cc_int32 ccs_client_add_iterator (ccs_client_t io_client, ccs_generic_list_iterator_t in_iterator) { cc_int32 err = ccNoError; - + if (!io_client ) { err = cci_check_error (ccErrBadParam); } if (!in_iterator) { err = cci_check_error (ccErrBadParam); } - + if (!err) { err = ccs_iteratorref_array_insert (io_client->iterators, in_iterator, ccs_iteratorref_array_count (io_client->iterators)); } - - return cci_check_error (err); + + return cci_check_error (err); } /* ------------------------------------------------------------------------ */ @@ -191,16 +191,16 @@ cc_int32 ccs_client_remove_iterator (ccs_client_t io_client, { cc_int32 err = ccNoError; cc_uint32 found_iterator = 0; - + if (!io_client) { err = cci_check_error (ccErrBadParam); } - + if (!err) { cc_uint64 i; cc_uint64 lock_count = ccs_iteratorref_array_count (io_client->iterators); - + for (i = 0; !err && i < lock_count; i++) { ccs_generic_list_iterator_t iterator = ccs_iteratorref_array_object_at_index (io_client->iterators, i); - + if (iterator == in_iterator) { cci_debug_printf ("%s: Removing iterator reference %p.", __FUNCTION__, iterator); found_iterator = 1; @@ -209,12 +209,12 @@ cc_int32 ccs_client_remove_iterator (ccs_client_t io_client, } } } - + if (!err && !found_iterator) { cci_debug_printf ("%s: WARNING! iterator not found.", __FUNCTION__); } - - return cci_check_error (err); + + return cci_check_error (err); } /* ------------------------------------------------------------------------ */ @@ -224,14 +224,14 @@ cc_int32 ccs_client_uses_pipe (ccs_client_t in_client, cc_uint32 *out_uses_pipe) { cc_int32 err = ccNoError; - + if (!in_client ) { err = cci_check_error (ccErrBadParam); } if (!in_pipe ) { err = cci_check_error (ccErrBadParam); } if (!out_uses_pipe) { err = cci_check_error (ccErrBadParam); } - + if (!err) { err = ccs_pipe_compare (in_client->client_pipe, in_pipe, out_uses_pipe); } - - return cci_check_error (err); + + return cci_check_error (err); } |