+++ /dev/null
-/***************************************************************************
- * service_nb.c
- *
- * Thu Nov 19 14:23:57 2009
- * Copyright 2009 Marcin Miklas
- * <marcin.miklas@teleca.com>
- ****************************************************************************/
-
-#include <stdio.h>
-#include <stdlib.h>
-#include <string.h>
-#include <netinet/in.h>
-
-#include "service.h"
-
-static void shut_down(void);
-static int disconnect(int socket, ServiceCallbacks* cb);
-
-#ifdef SERVICE_MAIN
-
-unsigned char* last_image=NULL;
-int last_image_size = 0;
-
-void put_image(unsigned char* img_buf, int img_size) {
- printf("Image received: size = %d\n",img_size);
- if(last_image) {
- free(last_image);
- last_image = NULL;
- last_image_size = 0;
- }
- last_image = malloc(img_size);
- memcpy(last_image,img_buf,img_size);
- last_image_size = img_size;
-}
-
-unsigned char* get_image(int* size) {
- if(size)
- *size = last_image_size;
-
- unsigned char* img = malloc(last_image_size);
- memcpy(img,last_image,last_image_size);
- return img;
-}
-
-void face_found() {
- printf("face found!\n");
-}
-
-int main(int args, char** argv)
-{
- ServiceCallbacks cb = {0};
- cb.log = (void (*)(const char*)) &puts;
- cb.put_image = &put_image;
- cb.get_image = &get_image;
- cb.face_found = &face_found;
- service(&cb);
- return 0;
-}
-#endif
-
-static int listener = 0;
-int fdmax = 0;
-fd_set all; // all active sockets
-
-void* service(ServiceCallbacks* cb)
-{
- LOG1("Activating service with SID '%d'\n", DEFAULT_SID);
-
- /* Activating a service means registering it with the Resource Manager,
- * so that it is visible to applications. The return value is the initial
- * listener socket (h_in3).
- */
- listener = n_activate(DEFAULT_SID, NULL, NULL);
- if (listener < 0) {
- return NULL;
- }
- else
- LOG("\tdone.\n");
- atexit(shut_down);
-
- fd_set read; // sockets ready for reading
- fd_set errors;
- FD_ZERO(&all);
- FD_SET(listener, &all);
- FD_ZERO(&read);
- fdmax = listener; //biggest socket number (right now,
- //'listener' is the only open socket)
- int quit = 0;
- while (!quit && (!cb->run_check || *(cb->run_check)))
- {
- read = all; //make a copy of the master set
- errors = all; //will contain sockets with error conditions set
- if (Hselect(Hgetinstance(), fdmax+1, &read, NULL, &errors, NULL) == -1)
- {
- LOG("Error on select\n");
- }
- /* Select modifies read so that it includes the sockets
- * that are ready for reading. Let's check which ones they were:
- */
- int i;
- for (i = 0; i <= fdmax; i++)
- {
- if (FD_ISSET(i, &read)) { // found a socket ready to be read
- if (i == listener) //service socket
- {
- LOG("Accepting new connection.\n");
- int socket = n_accept(i, NULL, 0);
- if (socket < 0) {
- LOG1("\terror: %d\n", socket);
- continue;
- }
- LOG1("\tdone - socket %d connected.\n", socket);
- FD_SET(socket, &all); //add to master set
- if (socket > fdmax)
- fdmax = socket;
- } //service socket handler
- else //data on an existing socket
- {
- int err = read_smsg(&i, HSReceiveBlocking, cb);
- if (err < 0) //error reading service message
- {
- n_disconnect(i);
- FD_CLR(i, &all);
- }
- else {
- switch(err) {
- case DISCONNECT:
- disconnect(i,cb);
- break;
- case QUIT:
- disconnect(i,cb);
- quit = 1;
- break;
- }
- }
- } //incoming data handler
- } // Handle sockets in the read set
- // check for errors:
- if (FD_ISSET(i, &errors)) {
- if (i == listener) //error on service socket
- {
- LOG("Error in service socket; quitting.\n");
- exit(-1);
- }
- FD_CLR(i, &all);
- n_disconnect(i);
- continue;
- }
- } // Read socket loop
- } // Main loop
-
- exit(0);
-}
-
-static int disconnect(int socket, ServiceCallbacks* cb)
-{
- FD_CLR(socket, &all);
- return n_disconnect(socket);
-}
-
-static void shut_down()
-{
- printf("Shutting down...\n");
- printf("Deactivating service...\n");
- HErrorCode err = n_deactivate(listener, NULL);
- if(err >= 0) {
- printf("Deactivated.\n");
- FD_CLR(listener, &all);
- }
- int i;
- // Close all open sockets:
- for (i = 0; i <= fdmax; i++)
- if (FD_ISSET(i, &all))
- n_disconnect(i);
-}
-
projects / jamendo / blobdiff