RecMessage.cc File Reference

Record message definitions. More...

#include "libts.h"
#include "P_RecCore.h"
#include "P_RecFile.h"
#include "P_RecMessage.h"
#include "P_RecUtils.h"
#include "I_Layout.h"

Include dependency graph for RecMessage.cc:

Go to the source code of this file.

Functions
RecMessage *	RecMessageAlloc (RecMessageT msg_type, int initial_size)
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	RecMessageRegisterRecvCb (RecMessageRecvCb recv_cb, void *cookie)
void *	RecMessageRecvThis (void *, char *data_raw, int)
RecMessage *	RecMessageReadFromDisk (const char *fpath)
int	RecMessageWriteToDisk (RecMessage *msg, const char *fpath)
Variables
static RecMessageRecvCb	g_recv_cb = NULL
static void *	g_recv_cookie = NULL

---

Detailed Description

Record message definitions.

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 RecMessage.cc.

---

Function Documentation

RecMessage* RecMessageAlloc	(	RecMessageT	msg_type,
		int	initial_size
	)

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 *	,
		char *	data_raw,
		int
	)

Definition at line 245 of file RecMessage.cc.

References g_recv_cb, g_recv_cookie, and RecMessageHdr::msg_type.

Referenced by RecMessageInit().

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 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().

---

Variable Documentation

RecMessageRecvCb g_recv_cb = NULL [static]

Definition at line 33 of file RecMessage.cc.

Referenced by RecMessageRecvThis(), and RecMessageRegisterRecvCb().

void* g_recv_cookie = NULL [static]

Definition at line 34 of file RecMessage.cc.

Referenced by RecMessageRecvThis(), and RecMessageRegisterRecvCb().