blob: b72d05e15e7876e48d1c5f82755c49583da00f85 (
plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
|
/*
* rhctl
*
* Copyright (C) 2009-2014 Christian Pointner <equinox@helsinki.at>
*
* This file is part of rhctl.
*
* rhctl 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
* any later version.
*
* rhctl is distributed in the hope that it will be useful,
* but WITHOUT ANY WARRANTY; without even the implied warranty of
* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
* GNU General Public License for more details.
*
* You should have received a copy of the GNU General Public License
* along with rhctl. If not, see <http://www.gnu.org/licenses/>.
*/
#include <stdlib.h>
#include <string.h>
#include "command_queue.h"
#include "datatypes.h"
cmd_t* cmd_get_last(cmd_t* first)
{
if(!first)
return NULL;
while(first->next) {
first = first->next;
}
return first;
}
int cmd_push(cmd_t** first, int fd, cmd_id_t cmd, const char* param)
{
if(!first)
return -1;
cmd_t* new_cmd = malloc(sizeof(cmd_t));
if(!new_cmd)
return -2;
new_cmd->fd = fd;
new_cmd->cmd = cmd;
if(param) {
new_cmd->param = strdup(param);
if(!new_cmd->param) {
free(new_cmd);
return -2;
}
}
else
new_cmd->param = NULL;
new_cmd->sent = 0;
new_cmd->tv_start.tv_sec = 0;
new_cmd->tv_start.tv_usec = 0;
new_cmd->next = NULL;
if(!(*first)) {
*first = new_cmd;
return 0;
}
cmd_get_last(*first)->next = new_cmd;
return 0;
}
void cmd_sent(cmd_t* cmd)
{
if(!cmd)
return;
cmd->sent = 1;
gettimeofday(&cmd->tv_start, NULL);
}
int cmd_has_expired(cmd_t cmd)
{
struct timeval now;
timerclear(&now);
gettimeofday(&now, NULL);
cmd.tv_start.tv_sec++;
return timercmp(&cmd.tv_start, &now, <);
}
void cmd_pop(cmd_t** first)
{
if(!first || !(*first))
return;
cmd_t* deletee = *first;
*first = (*first)->next;
if(deletee->param)
free(deletee->param);
free(deletee);
}
void cmd_clear(cmd_t** first)
{
if(!first || !(*first))
return;
while(*first) {
cmd_t* deletee = *first;
*first = (*first)->next;
if(deletee->param)
free(deletee->param);
free(deletee);
}
}
|
