API new commands enablepool and disablepool (version already incremented)
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 119 120 121 122 123 124 125 126 127 128 129 130 131 132 133 134 135 136 137 138 139 140 141 142 143 144 145 146 147 148 149 150 151 152 153 154 155 156 157 158 159 160 161 162 163 164
diff --git a/README b/README
index 183e7d2..0f78dbb 100644
--- a/README
+++ b/README
@@ -654,6 +654,16 @@ The list of requests - a (*) means it requires privileged access - and replies a
highest priority (the pool is also enabled)
The Msg includes the pool URL
+ enablepool|N (*)
+ none There is no reply section just the STATUS section
+ stating the results of enabling pool N
+ The Msg includes the pool URL
+
+ disablepool|N (*)
+ none There is no reply section just the STATUS section
+ stating the results of disabling pool N
+ The Msg includes the pool URL
+
gpuenable|N (*)
none There is no reply section just the STATUS section
stating the results of the enable request
diff --git a/api.c b/api.c
index 60d1871..7141848 100644
--- a/api.c
+++ b/api.c
@@ -259,6 +259,11 @@ static const char *JSON_PARAMETER = "parameter";
#define MSG_SAVED 44
#define MSG_ACCDENY 45
#define MSG_ACCOK 46
+#define MSG_ENAPOOL 47
+#define MSG_DISPOOL 48
+#define MSG_ALRENAP 49
+#define MSG_ALRDISP 50
+#define MSG_DISLASTP 51
enum code_severity {
SEVERITY_ERR,
@@ -346,6 +351,11 @@ struct CODES {
{ SEVERITY_ERR, MSG_SAVED, PARAM_STR, "Configuration saved to file '%s'" },
{ SEVERITY_ERR, MSG_ACCDENY, PARAM_STR, "Access denied to '%s' command" },
{ SEVERITY_SUCC, MSG_ACCOK, PARAM_NONE, "Privileged access OK" },
+ { SEVERITY_SUCC, MSG_ENAPOOL, PARAM_POOL, "Enabling pool %d:'%s'" },
+ { SEVERITY_SUCC, MSG_DISPOOL, PARAM_POOL, "Disabling pool %d:'%s'" },
+ { SEVERITY_INFO, MSG_ALRENAP, PARAM_POOL, "Pool %d:'%s' already enabled" },
+ { SEVERITY_INFO, MSG_ALRDISP, PARAM_POOL, "Pool %d:'%s' already disabled" },
+ { SEVERITY_ERR, MSG_DISLASTP,PARAM_POOL, "Cannot disable last active pool %d:'%s'" },
{ SEVERITY_FAIL, 0, 0, NULL }
};
@@ -976,6 +986,79 @@ static void switchpool(__maybe_unused SOCKETTYPE c, char *param, bool isjson)
strcpy(io_buffer, message(MSG_SWITCHP, id, NULL, isjson));
}
+static void enablepool(__maybe_unused SOCKETTYPE c, char *param, bool isjson)
+{
+ struct pool *pool;
+ int id;
+
+ if (total_pools == 0) {
+ strcpy(io_buffer, message(MSG_NOPOOL, 0, NULL, isjson));
+ return;
+ }
+
+ if (param == NULL || *param == '\0') {
+ strcpy(io_buffer, message(MSG_MISPID, 0, NULL, isjson));
+ return;
+ }
+
+ id = atoi(param);
+ if (id < 0 || id >= total_pools) {
+ strcpy(io_buffer, message(MSG_INVPID, id, NULL, isjson));
+ return;
+ }
+
+ pool = pools[id];
+ if (pool->enabled == true) {
+ strcpy(io_buffer, message(MSG_ALRENAP, id, NULL, isjson));
+ return;
+ }
+
+ pool->enabled = true;
+ if (pool->prio < current_pool()->prio)
+ switch_pools(pool);
+
+ strcpy(io_buffer, message(MSG_ENAPOOL, id, NULL, isjson));
+}
+
+static void disablepool(__maybe_unused SOCKETTYPE c, char *param, bool isjson)
+{
+ struct pool *pool;
+ int id;
+
+ if (total_pools == 0) {
+ strcpy(io_buffer, message(MSG_NOPOOL, 0, NULL, isjson));
+ return;
+ }
+
+ if (param == NULL || *param == '\0') {
+ strcpy(io_buffer, message(MSG_MISPID, 0, NULL, isjson));
+ return;
+ }
+
+ id = atoi(param);
+ if (id < 0 || id >= total_pools) {
+ strcpy(io_buffer, message(MSG_INVPID, id, NULL, isjson));
+ return;
+ }
+
+ pool = pools[id];
+ if (pool->enabled == false) {
+ strcpy(io_buffer, message(MSG_ALRDISP, id, NULL, isjson));
+ return;
+ }
+
+ if (active_pools() <= 1) {
+ strcpy(io_buffer, message(MSG_DISLASTP, id, NULL, isjson));
+ return;
+ }
+
+ pool->enabled = false;
+ if (pool == current_pool())
+ switch_pools(NULL);
+
+ strcpy(io_buffer, message(MSG_DISPOOL, id, NULL, isjson));
+}
+
static bool splitgpuvalue(char *param, int *gpu, char **value, bool isjson)
{
int id;
@@ -1188,6 +1271,9 @@ struct CMDS {
{ "gpucount", gpucount, false },
{ "cpucount", cpucount, false },
{ "switchpool", switchpool, true },
+// { "addpool", addpool, true }, Not yet ...
+ { "enablepool", enablepool, true },
+ { "disablepool", disablepool, true },
{ "gpuintensity", gpuintensity, true },
{ "gpumem", gpumem, true },
{ "gpuengine", gpuengine, true },
diff --git a/cgminer.c b/cgminer.c
index 828a11e..3fbb5f7 100644
--- a/cgminer.c
+++ b/cgminer.c
@@ -360,7 +360,7 @@ static bool pool_isset(struct pool *pool, bool *var)
return ret;
}
-static struct pool *current_pool(void)
+struct pool *current_pool(void)
{
struct pool *pool;
diff --git a/miner.h b/miner.h
index 2e308fe..321759e 100644
--- a/miner.h
+++ b/miner.h
@@ -465,6 +465,7 @@ extern int set_memoryclock(int gpu, int iMemoryClock);
extern void api(int thr_id);
+extern struct pool *current_pool(void);
extern int active_pools(void);
extern int add_pool_details(bool live, char *url, char *user, char *pass);