Lines Matching defs:ccmsg

1 /*	$NetBSD: ccmsg.c,v 1.8 2025/01/26 16:25:44 christos Exp $	*/
42 #include <isccc/ccmsg.h>
50  * If no message could be parsed the ccmsg struct remains untouched.
53 try_parse_message(isccc_ccmsg_t *ccmsg) {
54 	REQUIRE(ccmsg != NULL);
57 	if (isc_buffer_peekuint32(ccmsg->buffer, &len) != ISC_R_SUCCESS) {
63 	if (len > ccmsg->maxsize) {
66 	if (isc_buffer_remaininglength(ccmsg->buffer) < sizeof(uint32_t) + len)
71 	isc_buffer_forward(ccmsg->buffer, sizeof(uint32_t));
72 	ccmsg->size = len;
79 	isccc_ccmsg_t *ccmsg = arg;
81 	REQUIRE(VALID_CCMSG(ccmsg));
83 	REQUIRE(handle == ccmsg->handle);
91 	eresult = isc_buffer_copyregion(ccmsg->buffer, region);
98 	eresult = try_parse_message(ccmsg);
106 	ccmsg->recv_cb(handle, eresult, ccmsg->recv_cbarg);
113 		 isccc_ccmsg_t *ccmsg) {
116 	REQUIRE(ccmsg != NULL);
118 	*ccmsg = (isccc_ccmsg_t){
125 	isc_buffer_allocate(ccmsg->mctx, &ccmsg->buffer,
128 	isc_nmhandle_attach(handle, &ccmsg->handle);
132 isccc_ccmsg_setmaxsize(isccc_ccmsg_t *ccmsg, unsigned int maxsize) {
133 	REQUIRE(VALID_CCMSG(ccmsg));
135 	ccmsg->maxsize = maxsize;
139 isccc_ccmsg_readmessage(isccc_ccmsg_t *ccmsg, isc_nm_cb_t cb, void *cbarg) {
140 	REQUIRE(VALID_CCMSG(ccmsg));
142 	if (ccmsg->size != 0) {
144 		isc_buffer_forward(ccmsg->buffer, ccmsg->size);
145 		ccmsg->size = 0;
146 		isc_buffer_trycompact(ccmsg->buffer);
149 	ccmsg->recv_cb = cb;
150 	ccmsg->recv_cbarg = cbarg;
153 	isc_result_t result = try_parse_message(ccmsg);
156 		isc_nm_read(ccmsg->handle, recv_data, ccmsg);
160 	ccmsg->recv_cb(ccmsg->handle, result, ccmsg->recv_cbarg);
165 	isccc_ccmsg_t *ccmsg = arg;
167 	REQUIRE(VALID_CCMSG(ccmsg));
168 	REQUIRE(ccmsg->send_cb != NULL);
170 	isc_nm_cb_t send_cb = ccmsg->send_cb;
171 	ccmsg->send_cb = NULL;
173 	send_cb(handle, eresult, ccmsg->send_cbarg);
179 isccc_ccmsg_sendmessage(isccc_ccmsg_t *ccmsg, isc_region_t *region,
181 	REQUIRE(VALID_CCMSG(ccmsg));
182 	REQUIRE(ccmsg->send_cb == NULL);
184 	ccmsg->send_cb = cb;
185 	ccmsg->send_cbarg = cbarg;
187 	isc_nmhandle_ref(ccmsg->handle);
188 	isc_nm_send(ccmsg->handle, region, ccmsg_senddone, ccmsg);
192 isccc_ccmsg_disconnect(isccc_ccmsg_t *ccmsg) {
193 	REQUIRE(VALID_CCMSG(ccmsg));
195 	if (ccmsg->handle != NULL) {
196 		isc_nm_read_stop(ccmsg->handle);
197 		isc_nmhandle_close(ccmsg->handle);
198 		isc_nmhandle_detach(&ccmsg->handle);
203 isccc_ccmsg_invalidate(isccc_ccmsg_t *ccmsg) {
204 	REQUIRE(VALID_CCMSG(ccmsg));
205 	REQUIRE(ccmsg->handle == NULL);
207 	ccmsg->magic = 0;
209 	isc_buffer_free(&ccmsg->buffer);
213 isccc_ccmsg_toregion(isccc_ccmsg_t *ccmsg, isccc_region_t *ccregion) {
214 	REQUIRE(VALID_CCMSG(ccmsg));
215 	REQUIRE(ccmsg->buffer);
216 	REQUIRE(isc_buffer_remaininglength(ccmsg->buffer) >= ccmsg->size);
218 	ccregion->rstart = isc_buffer_current(ccmsg->buffer);
219 	ccregion->rend = ccregion->rstart + ccmsg->size;