From: Mladen Turk Date: Tue, 25 Jul 2006 23:49:39 +0000 (+0000) Subject: Adjust the svn properties. X-Git-Tag: 2.3.0~2209 X-Git-Url: http://git.ipfire.org/cgi-bin/gitweb.cgi?a=commitdiff_plain;h=4487a05aa359987a9f62eca954afeb76e336f651;p=thirdparty%2Fapache%2Fhttpd.git Adjust the svn properties. git-svn-id: https://svn.apache.org/repos/asf/httpd/httpd/trunk@425559 13f79535-47bb-0310-9956-ffa450edef68 --- diff --git a/modules/proxy/ajp_utils.c b/modules/proxy/ajp_utils.c index 3532eb8546a..7a37ae1cfef 100644 --- a/modules/proxy/ajp_utils.c +++ b/modules/proxy/ajp_utils.c @@ -1,104 +1,104 @@ -/* Licensed to the Apache Software Foundation (ASF) under one or more - * contributor license agreements. See the NOTICE file distributed with - * this work for additional information regarding copyright ownership. - * The ASF licenses this file to You under the Apache License, Version 2.0 - * (the "License"); you may not use this file except in compliance with - * the License. You may obtain a copy of the License at - * - * http://www.apache.org/licenses/LICENSE-2.0 - * - * Unless required by applicable law or agreed to in writing, software - * distributed under the License is distributed on an "AS IS" BASIS, - * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. - * See the License for the specific language governing permissions and - * limitations under the License. - */ - -#include "ajp.h" - -/* - * Handle the CPING/CPONG - */ -apr_status_t ajp_handle_cping_cpong(apr_socket_t *sock, - request_rec *r, - apr_interval_time_t timeout) -{ - ajp_msg_t *msg; - apr_status_t rc; - apr_interval_time_t org; - apr_byte_t result; - - ap_log_error(APLOG_MARK, APLOG_DEBUG, 0, r->server, - "Into ajp_handle_cping_cpong"); - - rc = ajp_msg_create(r->pool, &msg); - if (rc != APR_SUCCESS) { - ap_log_error(APLOG_MARK, APLOG_ERR, 0, r->server, - "ajp_handle_cping_cpong: ajp_msg_create failed"); - return rc; - } - - rc = ajp_msg_serialize_cping(msg); - if (rc != APR_SUCCESS) { - ap_log_error(APLOG_MARK, APLOG_ERR, 0, r->server, - "ajp_handle_cping_cpong: ajp_marshal_into_msgb failed"); - return rc; - } - - rc = ajp_ilink_send(sock, msg); - if (rc != APR_SUCCESS) { - ap_log_error(APLOG_MARK, APLOG_ERR, 0, r->server, - "ajp_handle_cping_cpong: ajp_ilink_send failed"); - return rc; - } - - rc = apr_socket_timeout_get(sock, &org); - if (rc != APR_SUCCESS) { - ap_log_error(APLOG_MARK, APLOG_ERR, 0, r->server, - "ajp_handle_cping_cpong: apr_socket_timeout_get failed"); - return rc; - } - - /* Set CPING/CPONG response timeout */ - rc = apr_socket_timeout_set(sock, timeout); - if (rc != APR_SUCCESS) { - ap_log_error(APLOG_MARK, APLOG_ERR, 0, r->server, - "ajp_handle_cping_cpong: apr_socket_timeout_set failed"); - return rc; - } - ajp_msg_reuse(msg); - - /* Read CPONG reply */ - rc = ajp_ilink_receive(sock, msg); - if (rc != APR_SUCCESS) { - ap_log_error(APLOG_MARK, APLOG_ERR, 0, r->server, - "ajp_handle_cping_cpong: ajp_ilink_receive failed"); - return rc; - } - - rc = ajp_msg_get_uint8(msg, &result); - if (rc != APR_SUCCESS) { - ap_log_error(APLOG_MARK, APLOG_ERR, 0, r->server, - "ajp_handle_cping_cpong: invalid CPONG message"); - return rc; - } - if (result != CMD_AJP13_CPONG) { - ap_log_error(APLOG_MARK, APLOG_ERR, 0, r->server, - "ajp_handle_cping_cpong: awaited CPONG, received %d ", - result); - return APR_EGENERAL; - - } - - /* Restore original socket timeout */ - rc = apr_socket_timeout_set(sock, org); - if (rc != APR_SUCCESS) { - ap_log_error(APLOG_MARK, APLOG_ERR, 0, r->server, - "ajp_handle_cping_cpong: apr_socket_timeout_set failed"); - return rc; - } - - ap_log_error(APLOG_MARK, APLOG_DEBUG, 0, r->server, - "ajp_handle_cping_cpong: Done"); - return APR_SUCCESS; -} +/* Licensed to the Apache Software Foundation (ASF) under one or more + * contributor license agreements. See the NOTICE file distributed with + * this work for additional information regarding copyright ownership. + * The ASF licenses this file to You under the Apache License, Version 2.0 + * (the "License"); you may not use this file except in compliance with + * the License. You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + */ + +#include "ajp.h" + +/* + * Handle the CPING/CPONG + */ +apr_status_t ajp_handle_cping_cpong(apr_socket_t *sock, + request_rec *r, + apr_interval_time_t timeout) +{ + ajp_msg_t *msg; + apr_status_t rc; + apr_interval_time_t org; + apr_byte_t result; + + ap_log_error(APLOG_MARK, APLOG_DEBUG, 0, r->server, + "Into ajp_handle_cping_cpong"); + + rc = ajp_msg_create(r->pool, &msg); + if (rc != APR_SUCCESS) { + ap_log_error(APLOG_MARK, APLOG_ERR, 0, r->server, + "ajp_handle_cping_cpong: ajp_msg_create failed"); + return rc; + } + + rc = ajp_msg_serialize_cping(msg); + if (rc != APR_SUCCESS) { + ap_log_error(APLOG_MARK, APLOG_ERR, 0, r->server, + "ajp_handle_cping_cpong: ajp_marshal_into_msgb failed"); + return rc; + } + + rc = ajp_ilink_send(sock, msg); + if (rc != APR_SUCCESS) { + ap_log_error(APLOG_MARK, APLOG_ERR, 0, r->server, + "ajp_handle_cping_cpong: ajp_ilink_send failed"); + return rc; + } + + rc = apr_socket_timeout_get(sock, &org); + if (rc != APR_SUCCESS) { + ap_log_error(APLOG_MARK, APLOG_ERR, 0, r->server, + "ajp_handle_cping_cpong: apr_socket_timeout_get failed"); + return rc; + } + + /* Set CPING/CPONG response timeout */ + rc = apr_socket_timeout_set(sock, timeout); + if (rc != APR_SUCCESS) { + ap_log_error(APLOG_MARK, APLOG_ERR, 0, r->server, + "ajp_handle_cping_cpong: apr_socket_timeout_set failed"); + return rc; + } + ajp_msg_reuse(msg); + + /* Read CPONG reply */ + rc = ajp_ilink_receive(sock, msg); + if (rc != APR_SUCCESS) { + ap_log_error(APLOG_MARK, APLOG_ERR, 0, r->server, + "ajp_handle_cping_cpong: ajp_ilink_receive failed"); + return rc; + } + + rc = ajp_msg_get_uint8(msg, &result); + if (rc != APR_SUCCESS) { + ap_log_error(APLOG_MARK, APLOG_ERR, 0, r->server, + "ajp_handle_cping_cpong: invalid CPONG message"); + return rc; + } + if (result != CMD_AJP13_CPONG) { + ap_log_error(APLOG_MARK, APLOG_ERR, 0, r->server, + "ajp_handle_cping_cpong: awaited CPONG, received %d ", + result); + return APR_EGENERAL; + + } + + /* Restore original socket timeout */ + rc = apr_socket_timeout_set(sock, org); + if (rc != APR_SUCCESS) { + ap_log_error(APLOG_MARK, APLOG_ERR, 0, r->server, + "ajp_handle_cping_cpong: apr_socket_timeout_set failed"); + return rc; + } + + ap_log_error(APLOG_MARK, APLOG_DEBUG, 0, r->server, + "ajp_handle_cping_cpong: Done"); + return APR_SUCCESS; +}