|
Packit |
d14fb6 |
/* Copyright (c) 2013 Zdenek Styblik, All Rights Reserved
|
|
Packit |
d14fb6 |
*
|
|
Packit |
d14fb6 |
* Redistribution and use in source and binary forms, with or without
|
|
Packit |
d14fb6 |
* modification, are permitted provided that the following conditions
|
|
Packit |
d14fb6 |
* are met:
|
|
Packit |
d14fb6 |
*
|
|
Packit |
d14fb6 |
* Redistribution of source code must retain the above copyright
|
|
Packit |
d14fb6 |
* notice, this list of conditions and the following disclaimer.
|
|
Packit |
d14fb6 |
*
|
|
Packit |
d14fb6 |
* Redistribution in binary form must reproduce the above copyright
|
|
Packit |
d14fb6 |
* notice, this list of conditions and the following disclaimer in the
|
|
Packit |
d14fb6 |
* documentation and/or other materials provided with the distribution.
|
|
Packit |
d14fb6 |
*
|
|
Packit |
d14fb6 |
* Neither the name of Zdenek Styblik or the names of
|
|
Packit |
d14fb6 |
* contributors may be used to endorse or promote products derived
|
|
Packit |
d14fb6 |
* from this software without specific prior written permission.
|
|
Packit |
d14fb6 |
*
|
|
Packit |
d14fb6 |
* This software is provided "AS IS," without a warranty of any kind.
|
|
Packit |
d14fb6 |
* ALL EXPRESS OR IMPLIED CONDITIONS, REPRESENTATIONS AND WARRANTIES,
|
|
Packit |
d14fb6 |
* INCLUDING ANY IMPLIED WARRANTY OF MERCHANTABILITY, FITNESS FOR A
|
|
Packit |
d14fb6 |
* PARTICULAR PURPOSE OR NON-INFRINGEMENT, ARE HEREBY EXCLUDED.
|
|
Packit |
d14fb6 |
* Zdenek Styblik SHALL NOT BE LIABLE
|
|
Packit |
d14fb6 |
* FOR ANY DAMAGES SUFFERED BY LICENSEE AS A RESULT OF USING, MODIFYING
|
|
Packit |
d14fb6 |
* OR DISTRIBUTING THIS SOFTWARE OR ITS DERIVATIVES. IN NO EVENT WILL
|
|
Packit |
d14fb6 |
* Zdenek Styblik BE LIABLE FOR ANY LOST REVENUE, PROFIT OR DATA,
|
|
Packit |
d14fb6 |
* OR FOR DIRECT, INDIRECT, SPECIAL, CONSEQUENTIAL, INCIDENTAL OR
|
|
Packit |
d14fb6 |
* PUNITIVE DAMAGES, HOWEVER CAUSED AND REGARDLESS OF THE THEORY OF
|
|
Packit |
d14fb6 |
* LIABILITY, ARISING OUT OF THE USE OF OR INABILITY TO USE THIS SOFTWARE,
|
|
Packit |
d14fb6 |
* EVEN IF Zdenek Styblik HAS BEEN ADVISED OF THE POSSIBILITY OF SUCH DAMAGES.
|
|
Packit |
d14fb6 |
*/
|
|
Packit |
d14fb6 |
#include <errno.h>
|
|
Packit |
d14fb6 |
#include <limits.h>
|
|
Packit |
d14fb6 |
#include <stdio.h>
|
|
Packit |
d14fb6 |
#include <stdlib.h>
|
|
Packit |
d14fb6 |
#include <sys/socket.h>
|
|
Packit |
d14fb6 |
#include <sys/types.h>
|
|
Packit |
d14fb6 |
#include <sys/un.h>
|
|
Packit |
d14fb6 |
#include <unistd.h>
|
|
Packit |
d14fb6 |
|
|
Packit |
d14fb6 |
#include <ipmitool/ipmi.h>
|
|
Packit |
d14fb6 |
#include <ipmitool/ipmi_intf.h>
|
|
Packit |
d14fb6 |
#include <ipmitool/helper.h>
|
|
Packit |
d14fb6 |
#include <ipmitool/log.h>
|
|
Packit |
d14fb6 |
|
|
Packit |
d14fb6 |
#include "dummy.h"
|
|
Packit |
d14fb6 |
|
|
Packit |
d14fb6 |
#if defined(HAVE_CONFIG_H)
|
|
Packit |
d14fb6 |
# include <config.h>
|
|
Packit |
d14fb6 |
#endif
|
|
Packit |
d14fb6 |
|
|
Packit |
d14fb6 |
extern int verbose;
|
|
Packit |
d14fb6 |
|
|
Packit |
d14fb6 |
/* data_read - read data from socket
|
|
Packit |
d14fb6 |
*
|
|
Packit |
d14fb6 |
* @data_ptr - pointer to memory where to store read data
|
|
Packit |
d14fb6 |
* @data_len - how much to read from socket
|
|
Packit |
d14fb6 |
*
|
|
Packit |
d14fb6 |
* return 0 on success, otherwise (-1)
|
|
Packit |
d14fb6 |
*/
|
|
Packit |
d14fb6 |
int
|
|
Packit |
d14fb6 |
data_read(int fd, void *data_ptr, int data_len)
|
|
Packit |
d14fb6 |
{
|
|
Packit |
d14fb6 |
int rc = 0;
|
|
Packit |
d14fb6 |
int data_read = 0;
|
|
Packit |
d14fb6 |
int data_total = 0;
|
|
Packit |
d14fb6 |
int try = 1;
|
|
Packit |
d14fb6 |
int errno_save = 0;
|
|
Packit |
d14fb6 |
if (data_len < 0) {
|
|
Packit |
d14fb6 |
return (-1);
|
|
Packit |
d14fb6 |
}
|
|
Packit |
d14fb6 |
while (data_total < data_len && try < 4) {
|
|
Packit |
d14fb6 |
errno = 0;
|
|
Packit |
d14fb6 |
/* TODO - add poll() */
|
|
Packit |
d14fb6 |
data_read = read(fd, data_ptr, data_len);
|
|
Packit |
d14fb6 |
errno_save = errno;
|
|
Packit |
d14fb6 |
if (data_read > 0) {
|
|
Packit |
d14fb6 |
data_total+= data_read;
|
|
Packit |
d14fb6 |
}
|
|
Packit |
d14fb6 |
if (errno_save != 0) {
|
|
Packit |
d14fb6 |
if (errno_save == EINTR || errno_save == EAGAIN) {
|
|
Packit |
d14fb6 |
try++;
|
|
Packit |
d14fb6 |
sleep(2);
|
|
Packit |
d14fb6 |
continue;
|
|
Packit |
d14fb6 |
} else {
|
|
Packit |
d14fb6 |
errno = errno_save;
|
|
Packit |
d14fb6 |
perror("dummy failed on read(): ");
|
|
Packit |
d14fb6 |
rc = (-1);
|
|
Packit |
d14fb6 |
break;
|
|
Packit |
d14fb6 |
}
|
|
Packit |
d14fb6 |
}
|
|
Packit |
d14fb6 |
}
|
|
Packit |
d14fb6 |
if (try > 3 && data_total != data_len) {
|
|
Packit |
d14fb6 |
rc = (-1);
|
|
Packit |
d14fb6 |
}
|
|
Packit |
d14fb6 |
return rc;
|
|
Packit |
d14fb6 |
}
|
|
Packit |
d14fb6 |
|
|
Packit |
d14fb6 |
/* data_write - write data to the socket
|
|
Packit |
d14fb6 |
*
|
|
Packit |
d14fb6 |
* @data_ptr - ptr to data to send
|
|
Packit |
d14fb6 |
* @data_len - how long is the data to send
|
|
Packit |
d14fb6 |
*
|
|
Packit |
d14fb6 |
* returns 0 on success, otherwise (-1)
|
|
Packit |
d14fb6 |
*/
|
|
Packit |
d14fb6 |
int
|
|
Packit |
d14fb6 |
data_write(int fd, void *data_ptr, int data_len)
|
|
Packit |
d14fb6 |
{
|
|
Packit |
d14fb6 |
int rc = 0;
|
|
Packit |
d14fb6 |
int data_written = 0;
|
|
Packit |
d14fb6 |
int data_total = 0;
|
|
Packit |
d14fb6 |
int try = 1;
|
|
Packit |
d14fb6 |
int errno_save = 0;
|
|
Packit |
d14fb6 |
if (data_len < 0) {
|
|
Packit |
d14fb6 |
return (-1);
|
|
Packit |
d14fb6 |
}
|
|
Packit |
d14fb6 |
while (data_total < data_len && try < 4) {
|
|
Packit |
d14fb6 |
errno = 0;
|
|
Packit |
d14fb6 |
/* TODO - add poll() */
|
|
Packit |
d14fb6 |
data_written = write(fd, data_ptr, data_len);
|
|
Packit |
d14fb6 |
errno_save = errno;
|
|
Packit |
d14fb6 |
if (data_written > 0) {
|
|
Packit |
d14fb6 |
data_total+= data_written;
|
|
Packit |
d14fb6 |
}
|
|
Packit |
d14fb6 |
if (errno_save != 0) {
|
|
Packit |
d14fb6 |
if (errno_save == EINTR || errno_save == EAGAIN) {
|
|
Packit |
d14fb6 |
try++;
|
|
Packit |
d14fb6 |
sleep(2);
|
|
Packit |
d14fb6 |
continue;
|
|
Packit |
d14fb6 |
} else {
|
|
Packit |
d14fb6 |
errno = errno_save;
|
|
Packit |
d14fb6 |
perror("dummy failed on read(): ");
|
|
Packit |
d14fb6 |
rc = (-1);
|
|
Packit |
d14fb6 |
break;
|
|
Packit |
d14fb6 |
}
|
|
Packit |
d14fb6 |
}
|
|
Packit |
d14fb6 |
}
|
|
Packit |
d14fb6 |
if (try > 3 && data_total != data_len) {
|
|
Packit |
d14fb6 |
rc = (-1);
|
|
Packit |
d14fb6 |
}
|
|
Packit |
d14fb6 |
return rc;
|
|
Packit |
d14fb6 |
}
|
|
Packit |
d14fb6 |
|
|
Packit |
d14fb6 |
/* ipmi_dummyipmi_close - send "BYE" and close socket
|
|
Packit |
d14fb6 |
*
|
|
Packit |
d14fb6 |
* @intf - ptr to initialize ipmi_intf struct
|
|
Packit |
d14fb6 |
*
|
|
Packit |
d14fb6 |
* returns void
|
|
Packit |
d14fb6 |
*/
|
|
Packit |
d14fb6 |
static void
|
|
Packit |
d14fb6 |
ipmi_dummyipmi_close(struct ipmi_intf *intf)
|
|
Packit |
d14fb6 |
{
|
|
Packit |
d14fb6 |
struct dummy_rq req;
|
|
Packit |
d14fb6 |
if (intf->fd < 0) {
|
|
Packit |
d14fb6 |
return;
|
|
Packit |
d14fb6 |
}
|
|
Packit |
d14fb6 |
memset(&req, 0, sizeof(req));
|
|
Packit |
d14fb6 |
req.msg.netfn = 0x3f;
|
|
Packit |
d14fb6 |
req.msg.cmd = 0xff;
|
|
Packit |
d14fb6 |
if (data_write(intf->fd, &req, sizeof(req)) != 0) {
|
|
Packit |
d14fb6 |
lprintf(LOG_ERR, "dummy failed to send 'BYE'");
|
|
Packit |
d14fb6 |
}
|
|
Packit |
d14fb6 |
close(intf->fd);
|
|
Packit |
d14fb6 |
intf->fd = (-1);
|
|
Packit |
d14fb6 |
intf->opened = 0;
|
|
Packit |
d14fb6 |
}
|
|
Packit |
d14fb6 |
|
|
Packit |
d14fb6 |
/* ipmi_dummyipmi_open - open socket and prepare ipmi_intf struct
|
|
Packit |
d14fb6 |
*
|
|
Packit |
d14fb6 |
* @intf - ptr to ipmi_inf struct
|
|
Packit |
d14fb6 |
*
|
|
Packit |
d14fb6 |
* returns 0 on success, (-1) on error
|
|
Packit |
d14fb6 |
*/
|
|
Packit |
d14fb6 |
static int
|
|
Packit |
d14fb6 |
ipmi_dummyipmi_open(struct ipmi_intf *intf)
|
|
Packit |
d14fb6 |
{
|
|
Packit |
d14fb6 |
struct sockaddr_un address;
|
|
Packit |
d14fb6 |
int len;
|
|
Packit |
d14fb6 |
int rc;
|
|
Packit |
d14fb6 |
char *dummy_sock_path;
|
|
Packit |
d14fb6 |
|
|
Packit |
d14fb6 |
dummy_sock_path = getenv("IPMI_DUMMY_SOCK");
|
|
Packit |
d14fb6 |
if (dummy_sock_path == NULL) {
|
|
Packit |
d14fb6 |
lprintf(LOG_DEBUG, "No IPMI_DUMMY_SOCK set. Dummy mode ON.");
|
|
Packit |
d14fb6 |
intf->opened = 1;
|
|
Packit |
d14fb6 |
return intf->fd;
|
|
Packit |
d14fb6 |
}
|
|
Packit |
d14fb6 |
|
|
Packit |
d14fb6 |
if (intf->opened == 1) {
|
|
Packit |
d14fb6 |
return intf->fd;
|
|
Packit |
d14fb6 |
}
|
|
Packit |
d14fb6 |
intf->fd = socket(AF_UNIX, SOCK_STREAM, 0);
|
|
Packit |
d14fb6 |
if (intf->fd == (-1)) {
|
|
Packit |
d14fb6 |
lprintf(LOG_ERR, "dummy failed on socket()");
|
|
Packit |
d14fb6 |
return (-1);
|
|
Packit |
d14fb6 |
}
|
|
Packit |
d14fb6 |
address.sun_family = AF_UNIX;
|
|
Packit |
d14fb6 |
strcpy(address.sun_path, dummy_sock_path);
|
|
Packit |
d14fb6 |
len = sizeof(address);
|
|
Packit |
d14fb6 |
rc = connect(intf->fd, (struct sockaddr *)&address, len);
|
|
Packit |
d14fb6 |
if (rc != 0) {
|
|
Packit |
d14fb6 |
perror("dummy failed on connect(): ");
|
|
Packit |
d14fb6 |
return (-1);
|
|
Packit |
d14fb6 |
}
|
|
Packit |
d14fb6 |
intf->opened = 1;
|
|
Packit |
d14fb6 |
return intf->fd;
|
|
Packit |
d14fb6 |
}
|
|
Packit |
d14fb6 |
|
|
Packit |
d14fb6 |
/* ipmi_dummyipmi_send_cmd - send IPMI payload and await reply
|
|
Packit |
d14fb6 |
*
|
|
Packit |
d14fb6 |
* @intf - ptr to initialized ipmi_intf struct
|
|
Packit |
d14fb6 |
* @req - ptr to ipmi_rq struct to send
|
|
Packit |
d14fb6 |
*
|
|
Packit |
d14fb6 |
* return pointer to struct ipmi_rs OR NULL on error
|
|
Packit |
d14fb6 |
*/
|
|
Packit |
d14fb6 |
static struct ipmi_rs*
|
|
Packit |
d14fb6 |
ipmi_dummyipmi_send_cmd(struct ipmi_intf *intf, struct ipmi_rq *req)
|
|
Packit |
d14fb6 |
{
|
|
Packit |
d14fb6 |
static struct ipmi_rs rsp;
|
|
Packit |
d14fb6 |
struct dummy_rq req_dummy;
|
|
Packit |
d14fb6 |
struct dummy_rs rsp_dummy;
|
|
Packit |
d14fb6 |
char *dummy_sock_path;
|
|
Packit |
d14fb6 |
dummy_sock_path = getenv("IPMI_DUMMY_SOCK");
|
|
Packit |
d14fb6 |
if (dummy_sock_path == NULL) {
|
|
Packit |
d14fb6 |
lprintf(LOG_DEBUG, "No IPMI_DUMMY_SOCK set. Dummy mode ON.");
|
|
Packit |
d14fb6 |
return NULL;
|
|
Packit |
d14fb6 |
}
|
|
Packit |
d14fb6 |
if (intf == NULL || intf->fd < 0 || intf->opened != 1) {
|
|
Packit |
d14fb6 |
lprintf(LOG_ERR, "dummy failed on intf check.");
|
|
Packit |
d14fb6 |
return NULL;
|
|
Packit |
d14fb6 |
}
|
|
Packit |
d14fb6 |
|
|
Packit |
d14fb6 |
memset(&req_dummy, 0, sizeof(req_dummy));
|
|
Packit |
d14fb6 |
req_dummy.msg.netfn = req->msg.netfn;
|
|
Packit |
d14fb6 |
req_dummy.msg.lun = req->msg.lun;
|
|
Packit |
d14fb6 |
req_dummy.msg.cmd = req->msg.cmd;
|
|
Packit |
d14fb6 |
req_dummy.msg.target_cmd = req->msg.target_cmd;
|
|
Packit |
d14fb6 |
req_dummy.msg.data_len = req->msg.data_len;
|
|
Packit |
d14fb6 |
req_dummy.msg.data = req->msg.data;
|
|
Packit |
d14fb6 |
if (verbose) {
|
|
Packit |
d14fb6 |
lprintf(LOG_NOTICE, ">>> IPMI req");
|
|
Packit |
d14fb6 |
lprintf(LOG_NOTICE, "msg.data_len: %i",
|
|
Packit |
d14fb6 |
req_dummy.msg.data_len);
|
|
Packit |
d14fb6 |
lprintf(LOG_NOTICE, "msg.netfn: %x", req_dummy.msg.netfn);
|
|
Packit |
d14fb6 |
lprintf(LOG_NOTICE, "msg.cmd: %x", req_dummy.msg.cmd);
|
|
Packit |
d14fb6 |
lprintf(LOG_NOTICE, "msg.target_cmd: %x",
|
|
Packit |
d14fb6 |
req_dummy.msg.target_cmd);
|
|
Packit |
d14fb6 |
lprintf(LOG_NOTICE, "msg.lun: %x", req_dummy.msg.lun);
|
|
Packit |
d14fb6 |
lprintf(LOG_NOTICE, ">>>");
|
|
Packit |
d14fb6 |
}
|
|
Packit |
d14fb6 |
if (data_write(intf->fd, &req_dummy,
|
|
Packit |
d14fb6 |
sizeof(struct dummy_rq)) != 0) {
|
|
Packit |
d14fb6 |
return NULL;
|
|
Packit |
d14fb6 |
}
|
|
Packit |
d14fb6 |
if (req->msg.data_len > 0) {
|
|
Packit |
d14fb6 |
if (data_write(intf->fd, (uint8_t *)(req->msg.data),
|
|
Packit |
d14fb6 |
req_dummy.msg.data_len) != 0) {
|
|
Packit |
d14fb6 |
return NULL;
|
|
Packit |
d14fb6 |
}
|
|
Packit |
d14fb6 |
}
|
|
Packit |
d14fb6 |
|
|
Packit |
d14fb6 |
memset(&rsp_dummy, 0, sizeof(rsp_dummy));
|
|
Packit |
d14fb6 |
if (data_read(intf->fd, &rsp_dummy, sizeof(struct dummy_rs)) != 0) {
|
|
Packit |
d14fb6 |
return NULL;
|
|
Packit |
d14fb6 |
}
|
|
Packit |
d14fb6 |
if (rsp_dummy.data_len > 0) {
|
|
Packit |
d14fb6 |
if (data_read(intf->fd, (uint8_t *)&rsp.data,
|
|
Packit |
d14fb6 |
rsp_dummy.data_len) != 0) {
|
|
Packit |
d14fb6 |
return NULL;
|
|
Packit |
d14fb6 |
}
|
|
Packit |
d14fb6 |
}
|
|
Packit |
d14fb6 |
rsp.ccode = rsp_dummy.ccode;
|
|
Packit |
d14fb6 |
rsp.data_len = rsp_dummy.data_len;
|
|
Packit |
d14fb6 |
rsp.msg.netfn = rsp_dummy.msg.netfn;
|
|
Packit |
d14fb6 |
rsp.msg.cmd = rsp_dummy.msg.cmd;
|
|
Packit |
d14fb6 |
rsp.msg.seq = rsp_dummy.msg.seq;
|
|
Packit |
d14fb6 |
rsp.msg.lun = rsp_dummy.msg.lun;
|
|
Packit |
d14fb6 |
if (verbose) {
|
|
Packit |
d14fb6 |
lprintf(LOG_NOTICE, "<<< IPMI rsp");
|
|
Packit |
d14fb6 |
lprintf(LOG_NOTICE, "ccode: %x", rsp.ccode);
|
|
Packit |
d14fb6 |
lprintf(LOG_NOTICE, "data_len: %i", rsp.data_len);
|
|
Packit |
d14fb6 |
lprintf(LOG_NOTICE, "msg.netfn: %x", rsp.msg.netfn);
|
|
Packit |
d14fb6 |
lprintf(LOG_NOTICE, "msg.cmd: %x", rsp.msg.cmd);
|
|
Packit |
d14fb6 |
lprintf(LOG_NOTICE, "msg.seq: %x", rsp.msg.seq);
|
|
Packit |
d14fb6 |
lprintf(LOG_NOTICE, "msg.lun: %x", rsp.msg.lun);
|
|
Packit |
d14fb6 |
lprintf(LOG_NOTICE, "<<<");
|
|
Packit |
d14fb6 |
}
|
|
Packit |
d14fb6 |
return &rsp;
|
|
Packit |
d14fb6 |
}
|
|
Packit |
d14fb6 |
|
|
Packit |
d14fb6 |
struct ipmi_intf ipmi_dummy_intf = {
|
|
Packit |
d14fb6 |
.name = "dummy",
|
|
Packit |
d14fb6 |
.desc = "Linux DummyIPMI Interface",
|
|
Packit |
d14fb6 |
.open = ipmi_dummyipmi_open,
|
|
Packit |
d14fb6 |
.close = ipmi_dummyipmi_close,
|
|
Packit |
d14fb6 |
.sendrecv = ipmi_dummyipmi_send_cmd,
|
|
Packit |
d14fb6 |
.my_addr = IPMI_BMC_SLAVE_ADDR,
|
|
Packit |
d14fb6 |
.target_addr = IPMI_BMC_SLAVE_ADDR,
|
|
Packit |
d14fb6 |
};
|