61 safe_write(struct cached_connection_ *connection, const void *data,  in safe_write()  argument
77 		nevents = _kevent(connection->write_queue, NULL, 0, &eventlist,  in safe_write()
80 			s_result = _sendto(connection->sockfd, data + result,  in safe_write()
105 safe_read(struct cached_connection_ *connection, void *data, size_t data_size)  in safe_read()  argument
120 		nevents = _kevent(connection->read_queue, NULL, 0, &eventlist,  in safe_read()
123 			s_result = _read(connection->sockfd, data + result,  in safe_read()
145 send_credentials(struct cached_connection_ *connection, int type)  in send_credentials()  argument
171 	EV_SET(&eventlist, connection->sockfd, EVFILT_WRITE, EV_ADD,  in send_credentials()
173 	(void)_kevent(connection->write_queue, &eventlist, 1, NULL, 0, NULL);  in send_credentials()
175 	nevents = _kevent(connection->write_queue, NULL, 0, &eventlist, 1,  in send_credentials()
178 		result = _sendmsg(connection->sockfd, &mhdr,  in send_credentials()
180 		EV_SET(&eventlist, connection->sockfd, EVFILT_WRITE, EV_ADD,  in send_credentials()
182 		_kevent(connection->write_queue, &eventlist, 1, NULL, 0, NULL);  in send_credentials()
239 __close_cached_connection(struct cached_connection_ *connection)  in __close_cached_connection()  argument
241 	assert(connection != NULL);  in __close_cached_connection()
243 	_close(connection->sockfd);  in __close_cached_connection()
244 	_close(connection->read_queue);  in __close_cached_connection()
245 	_close(connection->write_queue);  in __close_cached_connection()
246 	free(connection);  in __close_cached_connection()
255 __cached_write(struct cached_connection_ *connection, const char *entry_name,  in __cached_write()  argument
264 	result = send_credentials(connection, CET_WRITE_REQUEST);  in __cached_write()
269 	result = safe_write(connection, &name_size, sizeof(size_t));  in __cached_write()
273 	result = safe_write(connection, &key_size, sizeof(size_t));  in __cached_write()
277 	result = safe_write(connection, &data_size, sizeof(size_t));  in __cached_write()
281 	result = safe_write(connection, entry_name, name_size);  in __cached_write()
285 	result = safe_write(connection, key, key_size);  in __cached_write()
289 	result = safe_write(connection, data, data_size);  in __cached_write()
293 	result = safe_read(connection, &error_code, sizeof(int));  in __cached_write()
307 __cached_read(struct cached_connection_ *connection, const char *entry_name,  in __cached_read()  argument
314 	assert(connection != NULL);  in __cached_read()
318 	result = send_credentials(connection, CET_READ_REQUEST);  in __cached_read()
323 	result = safe_write(connection, &name_size, sizeof(size_t));  in __cached_read()
327 	result = safe_write(connection, &key_size, sizeof(size_t));  in __cached_read()
331 	result = safe_write(connection, entry_name, name_size);  in __cached_read()
335 	result = safe_write(connection, key, key_size);  in __cached_read()
339 	result = safe_read(connection, &rec_error_code, sizeof(int));  in __cached_read()
348 	result = safe_read(connection, &result_size, sizeof(size_t));  in __cached_read()
358 	result = safe_read(connection, data, result_size);  in __cached_read()
380 	struct cached_connection_ *connection, *retval;  in __open_cached_mp_write_session()  local
386 	connection = __open_cached_connection(params);  in __open_cached_mp_write_session()
387 	if (connection == NULL)  in __open_cached_mp_write_session()
389 	connection->mp_flag = 1;  in __open_cached_mp_write_session()
391 	result = send_credentials(connection, CET_MP_WRITE_SESSION_REQUEST);  in __open_cached_mp_write_session()
396 	result = safe_write(connection, &name_size, sizeof(size_t));  in __open_cached_mp_write_session()
400 	result = safe_write(connection, entry_name, name_size);  in __open_cached_mp_write_session()
404 	result = safe_read(connection, &error_code, sizeof(int));  in __open_cached_mp_write_session()
413 		__close_cached_connection(connection);  in __open_cached_mp_write_session()
415 		retval = connection;  in __open_cached_mp_write_session()
487 	struct cached_connection_ *connection, *retval;  in __open_cached_mp_read_session()  local
493 	connection = __open_cached_connection(params);  in __open_cached_mp_read_session()
494 	if (connection == NULL)  in __open_cached_mp_read_session()
496 	connection->mp_flag = 1;  in __open_cached_mp_read_session()
498 	result = send_credentials(connection, CET_MP_READ_SESSION_REQUEST);  in __open_cached_mp_read_session()
503 	result = safe_write(connection, &name_size, sizeof(size_t));  in __open_cached_mp_read_session()
507 	result = safe_write(connection, entry_name, name_size);  in __open_cached_mp_read_session()
511 	result = safe_read(connection, &error_code, sizeof(int));  in __open_cached_mp_read_session()
520 		__close_cached_connection(connection);  in __open_cached_mp_read_session()
522 		retval = connection;  in __open_cached_mp_read_session()