elev.c

#include <assert.h>
#include <stdlib.h>
#include <sys/socket.h>
#include <netdb.h>
#include <stdio.h>
#include <pthread.h>

#include "elev.h"

static int sockfd;
static pthread_mutex_t sockmtx;

int elev_init() {
	char ip[16] = "localhost";
	char port[8] = "15657";

	pthread_mutex_init(&sockmtx, NULL);

	sockfd = socket(AF_INET, SOCK_STREAM, 0);
	assert(sockfd != -1 && "Unable to set up socket");

	struct addrinfo hints = {
		.ai_family = AF_INET,
		.ai_socktype = SOCK_STREAM,
		.ai_protocol = IPPROTO_TCP,
	};
	struct addrinfo* res;
	getaddrinfo(ip, port, &hints, &res);

	int fail = connect(sockfd, res->ai_addr, res->ai_addrlen);
	assert(fail == 0 && "Unable to connect to simulator server");

	freeaddrinfo(res);

	send(sockfd, (char[4]) { 0 }, 4, 0);

	return 1; //jalla
}




void elev_set_motor_direction(elev_motor_direction_t dirn) {
	pthread_mutex_lock(&sockmtx);
	send(sockfd, (char[4]) { 1, dirn }, 4, 0);
	pthread_mutex_unlock(&sockmtx);
}


void elev_set_button_lamp(elev_button_type_t button, int floor, int value) {
	assert(floor >= 0);
	assert(floor < N_FLOORS);
	assert(button >= 0);
	assert(button < N_BUTTONS);

	pthread_mutex_lock(&sockmtx);
	send(sockfd, (char[4]) { 2, button, floor, value }, 4, 0);
	pthread_mutex_unlock(&sockmtx);
}


void elev_set_floor_indicator(int floor) {
	assert(floor >= 0);
	assert(floor < N_FLOORS);

	pthread_mutex_lock(&sockmtx);
	send(sockfd, (char[4]) { 3, floor }, 4, 0);
	pthread_mutex_unlock(&sockmtx);
}


void elev_set_door_open_lamp(int value) {
	pthread_mutex_lock(&sockmtx);
	send(sockfd, (char[4]) { 4, value }, 4, 0);
	pthread_mutex_unlock(&sockmtx);
}


void elev_set_stop_lamp(int value) {
	pthread_mutex_lock(&sockmtx);
	send(sockfd, (char[4]) { 5, value }, 4, 0);
	pthread_mutex_unlock(&sockmtx);
}




int elev_get_button_signal(elev_button_type_t button, int floor) {
	pthread_mutex_lock(&sockmtx);
	send(sockfd, (char[4]) { 6, button, floor }, 4, 0);
	char buf[4];
	recv(sockfd, buf, 4, 0);
	pthread_mutex_unlock(&sockmtx);
	return buf[1];
}


int elev_get_floor_sensor_signal(void) {
	pthread_mutex_lock(&sockmtx);
	send(sockfd, (char[4]) { 7 }, 4, 0);
	char buf[4];
	recv(sockfd, buf, 4, 0);
	pthread_mutex_unlock(&sockmtx);
	return buf[1] ? buf[2] : -1;
}


int elev_get_stop_signal(void) {
	pthread_mutex_lock(&sockmtx);
	send(sockfd, (char[4]) { 8 }, 4, 0);
	char buf[4];
	recv(sockfd, buf, 4, 0);
	pthread_mutex_unlock(&sockmtx);
	return buf[1];
}


int elev_get_obstruction_signal(void) {
	pthread_mutex_lock(&sockmtx);
	send(sockfd, (char[4]) { 9 }, 4, 0);
	char buf[4];
	recv(sockfd, buf, 4, 0);
	pthread_mutex_unlock(&sockmtx);
	return buf[1];
}