Private RecMessage declarations. More...
#include "P_RecDefs.h"
Go to the source code of this file.
Functions | |
| void | RecMessageRegister () |
| RecMessage * | RecMessageAlloc (RecMessageT msg_type, int initial_size=256) |
| int | RecMessageFree (RecMessage *msg) |
| RecMessage * | RecMessageMarshal_Realloc (RecMessage *msg, const RecRecord *record) |
| int | RecMessageUnmarshalFirst (RecMessage *msg, RecMessageItr *itr, RecRecord **record) |
| int | RecMessageUnmarshalNext (RecMessage *msg, RecMessageItr *itr, RecRecord **record) |
| int | RecMessageSend (RecMessage *msg) |
| int | RecMessageRegisterRecvCb (RecMessageRecvCb recv_cb, void *cookie) |
| void * | RecMessageRecvThis (void *cookie, char *data_raw, int data_len) |
| RecMessage * | RecMessageReadFromDisk (const char *fpath) |
| int | RecMessageWriteToDisk (RecMessage *msg, const char *fpath) |
Detailed Description
Private RecMessage declarations.
License
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.
Definition in file P_RecMessage.h.
Function Documentation
| RecMessage* RecMessageAlloc | ( | RecMessageT | msg_type, | |
| int | initial_size = 256 | |||
| ) |
Definition at line 40 of file RecMessage.cc.
References ats_malloc(), RecMessageHdr::entries, RecMessageHdr::msg_type, RecMessageHdr::o_end, RecMessageHdr::o_start, and RecMessageHdr::o_write.
Referenced by RecSyncStatsFile(), send_pull_message(), send_push_message(), send_register_message(), send_reset_message(), and send_set_message().
| int RecMessageFree | ( | RecMessage * | msg | ) |
Definition at line 60 of file RecMessage.cc.
References ats_free().
Referenced by RecSyncStatsFile(), send_pull_message(), send_push_message(), send_register_message(), send_reset_message(), and send_set_message().
| RecMessage* RecMessageMarshal_Realloc | ( | RecMessage * | msg, | |
| const RecRecord * | record | |||
| ) |
Definition at line 70 of file RecMessage.cc.
References ats_realloc(), RecConfigMeta::check_expr, RecRecord::config_meta, RecRecord::data, RecRecord::data_default, RecRecord::data_type, RecMessageHdr::entries, INK_ALIGN_DEFAULT, ink_assert, RecMessageEleHdr::magic, memcpy, RecRecord::name, RecMessageHdr::o_end, RecMessageEleHdr::o_next, RecMessageHdr::o_start, RecMessageHdr::o_write, RecData::rec_string, RecRecord::rec_type, REC_TYPE_IS_CONFIG, and RECD_STRING.
Referenced by RecSyncStatsFile(), send_pull_message(), send_push_message(), send_register_message(), send_reset_message(), and send_set_message().
| RecMessage* RecMessageReadFromDisk | ( | const char * | fpath | ) |
Definition at line 257 of file RecMessage.cc.
References ats_free(), ats_malloc(), memcpy, RecMessageHdr::o_end, RecMessageHdr::o_start, REC_ERR_FAIL, REC_HANDLE_INVALID, RecFileClose(), RecFileOpenR(), and RecFileRead().
Referenced by RecReadStatsFile().
| void* RecMessageRecvThis | ( | void * | cookie, | |
| char * | data_raw, | |||
| int | data_len | |||
| ) |
Definition at line 245 of file RecMessage.cc.
References g_recv_cb, g_recv_cookie, and RecMessageHdr::msg_type.
Referenced by RecMessageInit().
| void RecMessageRegister | ( | ) |
| int RecMessageRegisterRecvCb | ( | RecMessageRecvCb | recv_cb, | |
| void * | cookie | |||
| ) |
Definition at line 229 of file RecMessage.cc.
References g_recv_cb, and g_recv_cookie.
Referenced by RecLocalInitMessage(), and RecProcessInitMessage().
| int RecMessageSend | ( | RecMessage * | msg | ) |
Definition at line 214 of file RecLocal.cc.
References g_mode_type, message_initialized_p, RecMessageHdr::o_end, RecMessageHdr::o_start, RecMessageHdr::o_write, RECM_CLIENT, and RECM_SERVER.
Referenced by send_pull_message(), send_push_message(), send_register_message(), send_reset_message(), and send_set_message().
| int RecMessageUnmarshalFirst | ( | RecMessage * | msg, | |
| RecMessageItr * | itr, | |||
| RecRecord ** | record | |||
| ) |
Definition at line 161 of file RecMessage.cc.
References RecMessageItr::ele_hdr, RecMessageItr::next, RecMessageHdr::o_start, and RecMessageUnmarshalNext().
Referenced by RecReadStatsFile(), and recv_message_cb().
| int RecMessageUnmarshalNext | ( | RecMessage * | msg, | |
| RecMessageItr * | itr, | |||
| RecRecord ** | record | |||
| ) |
Definition at line 174 of file RecMessage.cc.
References RecConfigMeta::check_expr, RecRecord::config_meta, RecRecord::data, RecRecord::data_default, RecRecord::data_type, RecMessageItr::ele_hdr, RecMessageHdr::entries, ink_assert, RecMessageEleHdr::magic, RecRecord::name, RecMessageItr::next, RecMessageEleHdr::o_next, RecMessageHdr::o_start, REC_MESSAGE_ELE_MAGIC, RecData::rec_string, RecRecord::rec_type, REC_TYPE_IS_CONFIG, RECD_STRING, and Warning.
Referenced by RecMessageUnmarshalFirst(), RecReadStatsFile(), and recv_message_cb().
| int RecMessageWriteToDisk | ( | RecMessage * | msg, | |
| const char * | fpath | |||
| ) |
Definition at line 296 of file RecMessage.cc.
References RecMessageHdr::o_end, RecMessageHdr::o_start, RecMessageHdr::o_write, RecFileClose(), RecFileOpenW(), and RecFileWrite().
Referenced by RecSyncStatsFile().
