diff options
Diffstat (limited to 'omapip/connection.c')
| -rw-r--r-- | omapip/connection.c | 28 |
1 files changed, 14 insertions, 14 deletions
diff --git a/omapip/connection.c b/omapip/connection.c index 000f6d57..68baa660 100644 --- a/omapip/connection.c +++ b/omapip/connection.c @@ -163,7 +163,7 @@ isc_result_t omapi_connect_list (omapi_object_t *c, local_sin.sin_family = AF_INET; memset (&local_sin.sin_zero, 0, sizeof local_sin.sin_zero); - + if (bind (obj -> socket, (struct sockaddr *)&local_sin, sizeof local_sin) < 0) { omapi_connection_object_t **objp = &obj; @@ -196,7 +196,7 @@ isc_result_t omapi_connect_list (omapi_object_t *c, omapi_connection_dereference (&obj, MDL); return ISC_R_UNEXPECTED; } - + /* Set the file to nonblocking mode. */ if (fcntl (obj -> socket, F_SETFL, O_NONBLOCK) < 0) { omapi_connection_dereference (&obj, MDL); @@ -213,7 +213,7 @@ isc_result_t omapi_connect_list (omapi_object_t *c, (char *)&flag, sizeof(flag)) < 0) { omapi_connection_dereference (&obj, MDL); return ISC_R_UNEXPECTED; - } + } #endif status = (omapi_register_io_object @@ -285,7 +285,7 @@ void omapi_connection_register (omapi_connection_object_t *obj, #if defined (TRACING) if (trace_record ()) { /* Connection registration packet: - + int32_t index int32_t listener_index [-1 means no listener] u_int16_t remote_port @@ -365,7 +365,7 @@ static void trace_connect_input (trace_type_t *ttype, omapi_listener_reference (&listener, lp, MDL); omapi_listener_dereference (&lp, MDL); break; - } + } } omapi_array_foreach_end (trace_listeners, omapi_listener_object_t, lp); if (!listener) { @@ -411,7 +411,7 @@ static void trace_connect_input (trace_type_t *ttype, } } omapi_array_foreach_end (omapi_connections, omapi_connection_object_t, lp); - + log_error ("Spurious traced connect - index %ld, addr %s, port %d", (long int)connect_index, inet_ntoa (remote.sin_addr), ntohs (remote.sin_port)); @@ -428,7 +428,7 @@ static void trace_disconnect_input (trace_type_t *ttype, log_error ("trace disconnect: wrong length %d", length); return; } - + index = (int32_t *)buf; omapi_array_foreach_begin (omapi_connections, @@ -613,7 +613,7 @@ isc_result_t omapi_connection_connect (omapi_object_t *h) * pass it on as a signal. */ status = omapi_connection_connect_internal (h); - if (status == ISC_R_INPROGRESS) + if (status == ISC_R_INPROGRESS) return ISC_R_INPROGRESS; if (status != ISC_R_SUCCESS) @@ -705,7 +705,7 @@ static isc_result_t omapi_connection_connect_internal (omapi_object_t *h) } c -> state = omapi_connection_connected; } - + /* I don't know why this would fail, so I'm tempted not to test the return value. */ sl = sizeof (c -> local_addr); @@ -970,7 +970,7 @@ isc_result_t omapi_connection_set_value (omapi_object_t *h, return ISC_R_SUCCESS; } - + if (h -> inner && h -> inner -> type -> set_value) return (*(h -> inner -> type -> set_value)) (h -> inner, id, name, value); @@ -1013,7 +1013,7 @@ isc_result_t omapi_connection_get_value (omapi_object_t *h, status = dst_key_sigsize(c->in_key, &sigsize); if (status != ISC_R_SUCCESS) { return(status); - } + } return omapi_make_int_value(value, name, sigsize, MDL); @@ -1040,11 +1040,11 @@ isc_result_t omapi_connection_get_value (omapi_object_t *h, status = dst_key_sigsize(c->out_key, &sigsize); if (status != ISC_R_SUCCESS) { return(status); - } + } return omapi_make_int_value(value, name, sigsize, MDL); } - + if (h -> inner && h -> inner -> type -> get_value) return (*(h -> inner -> type -> get_value)) (h -> inner, id, name, value); @@ -1081,7 +1081,7 @@ isc_result_t omapi_connection_signal_handler (omapi_object_t *h, #ifdef DEBUG_PROTOCOL log_debug ("omapi_connection_signal_handler(%s)", name); #endif - + if (h -> inner && h -> inner -> type -> signal_handler) return (*(h -> inner -> type -> signal_handler)) (h -> inner, name, ap); |