thodg/cgminer/api-example.c

• Show log

  Commit

• Hash : ec9390dc
  Author :
  Date : 2013-04-15T10:19:37
  

  Variable is already initialised in global scope.

Download

• api-example.c

• /*
   * Copyright 2011 Kano
   *
   * This program is free software; you can redistribute it and/or modify it
   * under the terms of the GNU General Public License as published by the Free
   * Software Foundation; either version 3 of the License, or (at your option)
   * any later version.  See COPYING for more details.
   */
  
  /* Compile:
   *   gcc api-example.c -I compat/jansson -o cgminer-api
   */
  
  #include "config.h"
  
  #include <stdio.h>
  #include <stdlib.h>
  #include <string.h>
  #include <ctype.h>
  #include <unistd.h>
  #include <stdbool.h>
  #include <stdint.h>
  #include <sys/types.h>
  
  #include "compat.h"
  #include "miner.h"
  
  #if defined(unix)
  	#include <errno.h>
  	#include <sys/socket.h>
  	#include <netinet/in.h>
  	#include <arpa/inet.h>
  	#include <netdb.h>
  
  	#define SOCKETTYPE int
  	#define SOCKETFAIL(a) ((a) < 0)
  	#define INVSOCK -1
  	#define CLOSESOCKET close
  
  	#define SOCKETINIT {}
  
  	#define SOCKERRMSG strerror(errno)
  #endif
  
  #ifdef WIN32
  	#include <winsock2.h>
  
  	#define SOCKETTYPE SOCKET
  	#define SOCKETFAIL(a) ((a) == SOCKET_ERROR)
  	#define INVSOCK INVALID_SOCKET
  	#define CLOSESOCKET closesocket
  
  	static char WSAbuf[1024];
  
  	struct WSAERRORS {
  		int id;
  		char *code;
  	} WSAErrors[] = {
  		{ 0,			"No error" },
  		{ WSAEINTR,		"Interrupted system call" },
  		{ WSAEBADF,		"Bad file number" },
  		{ WSAEACCES,		"Permission denied" },
  		{ WSAEFAULT,		"Bad address" },
  		{ WSAEINVAL,		"Invalid argument" },
  		{ WSAEMFILE,		"Too many open sockets" },
  		{ WSAEWOULDBLOCK,	"Operation would block" },
  		{ WSAEINPROGRESS,	"Operation now in progress" },
  		{ WSAEALREADY,		"Operation already in progress" },
  		{ WSAENOTSOCK,		"Socket operation on non-socket" },
  		{ WSAEDESTADDRREQ,	"Destination address required" },
  		{ WSAEMSGSIZE,		"Message too long" },
  		{ WSAEPROTOTYPE,	"Protocol wrong type for socket" },
  		{ WSAENOPROTOOPT,	"Bad protocol option" },
  		{ WSAEPROTONOSUPPORT,	"Protocol not supported" },
  		{ WSAESOCKTNOSUPPORT,	"Socket type not supported" },
  		{ WSAEOPNOTSUPP,	"Operation not supported on socket" },
  		{ WSAEPFNOSUPPORT,	"Protocol family not supported" },
  		{ WSAEAFNOSUPPORT,	"Address family not supported" },
  		{ WSAEADDRINUSE,	"Address already in use" },
  		{ WSAEADDRNOTAVAIL,	"Can't assign requested address" },
  		{ WSAENETDOWN,		"Network is down" },
  		{ WSAENETUNREACH,	"Network is unreachable" },
  		{ WSAENETRESET,		"Net connection reset" },
  		{ WSAECONNABORTED,	"Software caused connection abort" },
  		{ WSAECONNRESET,	"Connection reset by peer" },
  		{ WSAENOBUFS,		"No buffer space available" },
  		{ WSAEISCONN,		"Socket is already connected" },
  		{ WSAENOTCONN,		"Socket is not connected" },
  		{ WSAESHUTDOWN,		"Can't send after socket shutdown" },
  		{ WSAETOOMANYREFS,	"Too many references, can't splice" },
  		{ WSAETIMEDOUT,		"Connection timed out" },
  		{ WSAECONNREFUSED,	"Connection refused" },
  		{ WSAELOOP,		"Too many levels of symbolic links" },
  		{ WSAENAMETOOLONG,	"File name too long" },
  		{ WSAEHOSTDOWN,		"Host is down" },
  		{ WSAEHOSTUNREACH,	"No route to host" },
  		{ WSAENOTEMPTY,		"Directory not empty" },
  		{ WSAEPROCLIM,		"Too many processes" },
  		{ WSAEUSERS,		"Too many users" },
  		{ WSAEDQUOT,		"Disc quota exceeded" },
  		{ WSAESTALE,		"Stale NFS file handle" },
  		{ WSAEREMOTE,		"Too many levels of remote in path" },
  		{ WSASYSNOTREADY,	"Network system is unavailable" },
  		{ WSAVERNOTSUPPORTED,	"Winsock version out of range" },
  		{ WSANOTINITIALISED,	"WSAStartup not yet called" },
  		{ WSAEDISCON,		"Graceful shutdown in progress" },
  		{ WSAHOST_NOT_FOUND,	"Host not found" },
  		{ WSANO_DATA,		"No host data of that type was found" },
  		{ -1,			"Unknown error code" }
  	};
  
  	static char *WSAErrorMsg()
  	{
  		char *msg;
  		int i;
  		int id = WSAGetLastError();
  
  		/* Assume none of them are actually -1 */
  		for (i = 0; WSAErrors[i].id != -1; i++)
  			if (WSAErrors[i].id == id)
  				break;
  
  		sprintf(WSAbuf, "Socket Error: (%d) %s", id, WSAErrors[i].code);
  
  		return &(WSAbuf[0]);
  	}
  
  	#define SOCKERRMSG WSAErrorMsg()
  
  	static WSADATA WSA_Data;
  
  	#define SOCKETINIT	int wsa; \
  				if (wsa = WSAStartup(0x0202, &WSA_Data)) { \
  					printf("Socket startup failed: %d\n", wsa); \
  					return 1; \
  				}
  
  	#ifndef SHUT_RDWR
  	#define SHUT_RDWR SD_BOTH
  	#endif
  #endif
  
  #define RECVSIZE 65500
  
  static const char SEPARATOR = '|';
  static const char COMMA = ',';
  static const char EQ = '=';
  static int ONLY;
  
  void display(char *buf)
  {
  	char *nextobj, *item, *nextitem, *eq;
  	int itemcount;
  
  	while (buf != NULL) {
  		nextobj = strchr(buf, SEPARATOR);
  		if (nextobj != NULL)
  			*(nextobj++) = '\0';
  
  		if (*buf) {
  			item = buf;
  			itemcount = 0;
  			while (item != NULL) {
  				nextitem = strchr(item, COMMA);
  				if (nextitem != NULL)
  					*(nextitem++) = '\0';
  
  				if (*item) {
  					eq = strchr(item, EQ);
  					if (eq != NULL)
  						*(eq++) = '\0';
  
  					if (itemcount == 0)
  						printf("[%s%s] =>\n(\n", item, (eq != NULL && isdigit(*eq)) ? eq : "");
  
  					if (eq != NULL)
  						printf("   [%s] => %s\n", item, eq);
  					else
  						printf("   [%d] => %s\n", itemcount, item);
  				}
  
  				item = nextitem;
  				itemcount++;
  			}
  			if (itemcount > 0)
  				puts(")");
  		}
  
  		buf = nextobj;
  	}
  }
  
  int callapi(char *command, char *host, short int port)
  {
  	char buf[RECVSIZE+1];
  	struct hostent *ip;
  	struct sockaddr_in serv;
  	SOCKETTYPE sock;
  	int ret = 0;
  	int n, p;
  
  	SOCKETINIT;
  
  	ip = gethostbyname(host);
  
  	sock = socket(AF_INET, SOCK_STREAM, 0);
  	if (sock == INVSOCK) {
  		printf("Socket initialisation failed: %s\n", SOCKERRMSG);
  		return 1;
  	}
  
  	memset(&serv, 0, sizeof(serv));
  	serv.sin_family = AF_INET;
  	serv.sin_addr = *((struct in_addr *)ip->h_addr);
  	serv.sin_port = htons(port);
  
  	if (SOCKETFAIL(connect(sock, (struct sockaddr *)&serv, sizeof(struct sockaddr)))) {
  		printf("Socket connect failed: %s\n", SOCKERRMSG);
  		return 1;
  	}
  
  	n = send(sock, command, strlen(command), 0);
  	if (SOCKETFAIL(n)) {
  		printf("Send failed: %s\n", SOCKERRMSG);
  		ret = 1;
  	}
  	else {
  		p = 0;
  		buf[0] = '\0';
  		while (p < RECVSIZE) {
  			n = recv(sock, &buf[p], RECVSIZE - p , 0);
  
  			if (SOCKETFAIL(n)) {
  				printf("Recv failed: %s\n", SOCKERRMSG);
  				ret = 1;
  				break;
  			}
  
  			if (n == 0)
  				break;
  
  			p += n;
  			buf[p] = '\0';
  		}
  
  		if (ONLY)
  			printf("%s\n", buf);
  		else {
  			printf("Reply was '%s'\n", buf);
  			display(buf);
  		}
  	}
  
  	CLOSESOCKET(sock);
  
  	return ret;
  }
  
  static char *trim(char *str)
  {
  	char *ptr;
  
  	while (isspace(*str))
  		str++;
  
  	ptr = strchr(str, '\0');
  	while (ptr-- > str) {
  		if (isspace(*ptr))
  			*ptr = '\0';
  	}
  
  	return str;
  }
  
  int main(int argc, char *argv[])
  {
  	char *command = "summary";
  	char *host = "127.0.0.1";
  	short int port = 4028;
  	char *ptr;
  	int i = 1;
  
  	if (argc > 1)
  		if (strcmp(argv[1], "-?") == 0
  		||  strcmp(argv[1], "-h") == 0
  		||  strcmp(argv[1], "--help") == 0) {
  			fprintf(stderr, "usAge: %s [command [ip/host [port]]]\n", argv[0]);
  			return 1;
  		}
  
  	if (argc > 1)
  		if (strcmp(argv[1], "-o") == 0) {
  			ONLY = 1;
  			i = 2;
  		}
  
  	if (argc > i) {
  		ptr = trim(argv[i++]);
  		if (strlen(ptr) > 0)
  			command = ptr;
  	}
  
  	if (argc > i) {
  		ptr = trim(argv[i++]);
  		if (strlen(ptr) > 0)
  			host = ptr;
  	}
  
  	if (argc > i) {
  		ptr = trim(argv[i]);
  		if (strlen(ptr) > 0)
  			port = atoi(ptr);
  	}
  
  	return callapi(command, host, port);
  }
  

Download