bin/auditdistd/sender.c

82 static struct adist_host *adhost;
142 	if (proto_send(adhost->adh_conn, &val, sizeof(val)) < 0) {
146 	if (proto_recv(adhost->adh_conn, &val, sizeof(val)) < 0) {
153 		    adhost->adh_remoteaddr);
156 	if (proto_connection_recv(adhost->adh_conn, true, &conn) < 0) {
162 		    adhost->adh_remoteaddr);
166 	pjdlog_debug(1, "Connected to %s.", adhost->adh_remoteaddr);
178 		    adhost->adh_remoteaddr);
187 		    adhost->adh_remoteaddr);
194 		    adhost->adh_remoteaddr);
203 	adhost->adh_version = atoi(welcome + 5);
204 	if (adhost->adh_version > ADIST_VERSION) {
206 		    adhost->adh_remoteaddr, adhost->adh_version, ADIST_VERSION);
211 	pjdlog_debug(1, "Version %d negotiated with %s.", adhost->adh_version,
212 	    adhost->adh_remoteaddr);
216 		    adhost->adh_remoteaddr);
224 		    adhost->adh_remoteaddr);
230 	if (HMAC(EVP_sha256(), adhost->adh_password,
231 	    (int)strlen(adhost->adh_password), rnd, (int)sizeof(rnd), hash,
241 		    adhost->adh_remoteaddr);
256 		    adhost->adh_remoteaddr);
264 		    adhost->adh_remoteaddr);
270 	if (HMAC(EVP_sha256(), adhost->adh_password,
271 	    (int)strlen(adhost->adh_password), rnd, (int)sizeof(rnd), hash,
281 		    adhost->adh_remoteaddr);
287 	if (proto_recv(conn, &adhost->adh_trail_offset,
288 	    sizeof(adhost->adh_trail_offset)) == -1) {
291 		    adhost->adh_remoteaddr);
295 	adhost->adh_trail_offset = le64toh(adhost->adh_trail_offset);
296 	if (proto_recv(conn, &adhost->adh_trail_name,
297 	    sizeof(adhost->adh_trail_name)) == -1) {
300 		    adhost->adh_remoteaddr);
305 	    adhost->adh_trail_name, (uintmax_t)adhost->adh_trail_offset);
309 	PJDLOG_ASSERT(adhost->adh_remote == NULL);
311 	adhost->adh_remote = conn;
328 	if (adhost->adh_remote == NULL) {
332 	pjdlog_debug(2, "Closing connection to %s.", adhost->adh_remoteaddr);
333 	proto_close(adhost->adh_remote);
335 	adhost->adh_remote = NULL;
336 	adhost->adh_reset = true;
337 	adhost->adh_trail_name[0] = '\0';
338 	adhost->adh_trail_offset = 0;
342 	pjdlog_warning("Disconnected from %s.", adhost->adh_remoteaddr);
394 	if (adhost->adh_reset) {
396 		adhost->adh_reset = false;
400 		while (adhost->adh_remote == NULL)
402 		trail_start(adist_trail, adhost->adh_trail_name,
403 		    adhost->adh_trail_offset);
415 		if (adhost->adh_reset)
423 		    adhost->adh_directory,
460 			    adhost->adh_directory, trail_filename(adist_trail),
468 			    adhost->adh_directory, trail_filename(adist_trail));
501 	if (adhost->adh_remote == NULL) {
560 		if (adhost->adh_remote == NULL ||
561 		    proto_send(adhost->adh_remote, &adreq->adr_packet,
566 			if (adhost->adh_remote != NULL)
609 		if (adhost->adh_remote == NULL) {
617 		if (proto_recv(adhost->adh_remote, &adrep,
677 	PJDLOG_ASSERT(adhost->adh_role == ADIST_ROLE_SENDER);
680 	if (adhost->adh_remote != NULL) {
683 		    adhost->adh_remoteaddr);
693 	    adhost->adh_remoteaddr);
696 		    adhost->adh_remoteaddr);
699 		    adhost->adh_remoteaddr);
783 	adhost = adh;
789 	proto_send(adhost->adh_conn, NULL, 0);
791 	descriptors_cleanup(adhost);
794 	descriptors_assert(adhost, mode);
799 	pjdlog_prefix_set("[%s] (%s) ", adhost->adh_name,
800 	    role2str(adhost->adh_role));
802 	setproctitle("[%s] (%s) ", adhost->adh_name,
803 	    role2str(adhost->adh_role));
811 	adist_trail = trail_new(adhost->adh_directory, false);
816 	    role2str(adhost->adh_role), adhost->adh_name) != 0) {
830 		    adhost->adh_remoteaddr);
832 	adhost->adh_reset = true;