blob: 2d16ef3ba6596fe357130a6201f6a21aee69e8f3 (
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
|
/*
* Copyright (c) 2013 Red Hat.
* Copyright (c) 1995 Silicon Graphics, Inc. All Rights Reserved.
*
* This library is free software; you can redistribute it and/or modify it
* under the terms of the GNU Lesser General Public License as published
* by the Free Software Foundation; either version 2.1 of the License, or
* (at your option) any later version.
*
* This library 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 Lesser General Public
* License for more details.
*/
#include "pmapi.h"
#include "impl.h"
#include "pmda.h"
#include "internal.h"
int
pmStore(const pmResult *result)
{
int n;
int sts;
__pmContext *ctxp;
__pmDSO *dp;
if (result->numpmid < 1)
return PM_ERR_TOOSMALL;
for (n = 0; n < result->numpmid; n++) {
if (result->vset[n]->numval < 1) {
return PM_ERR_VALUE;
}
}
if ((sts = pmWhichContext()) >= 0) {
int ctx = sts;
ctxp = __pmHandleToPtr(sts);
if (ctxp == NULL)
return PM_ERR_NOCONTEXT;
if (ctxp->c_type == PM_CONTEXT_HOST) {
PM_INIT_LOCKS();
PM_LOCK(__pmLock_libpcp);
sts = __pmSendResult(ctxp->c_pmcd->pc_fd, __pmPtrToHandle(ctxp), result);
if (sts < 0)
sts = __pmMapErrno(sts);
else {
__pmPDU *pb;
int pinpdu;
pinpdu = sts = __pmGetPDU(ctxp->c_pmcd->pc_fd, ANY_SIZE,
ctxp->c_pmcd->pc_tout_sec, &pb);
if (sts == PDU_ERROR)
__pmDecodeError(pb, &sts);
else if (sts != PM_ERR_TIMEOUT)
sts = PM_ERR_IPC;
if (pinpdu > 0)
__pmUnpinPDUBuf(pb);
}
PM_UNLOCK(__pmLock_libpcp);
}
else if (ctxp->c_type == PM_CONTEXT_LOCAL) {
/*
* have to do them one at a time in case different DSOs
* involved ... need to copy each result->vset[n]
*/
pmResult tmp;
pmValueSet tmpvset;
if (PM_MULTIPLE_THREADS(PM_SCOPE_DSO_PMDA)) {
/* Local context requires single-threaded applications */
sts = PM_ERR_THREAD;
} else {
sts = 0;
for (n = 0; sts == 0 && n < result->numpmid; n++) {
if ((dp = __pmLookupDSO(((__pmID_int *)&result->vset[n]->pmid)->domain)) == NULL)
sts = PM_ERR_NOAGENT;
else {
tmp.numpmid = 1;
tmp.vset[0] = &tmpvset;
tmpvset.numval = 1;
tmpvset.pmid = result->vset[n]->pmid;
tmpvset.valfmt = result->vset[n]->valfmt;
tmpvset.vlist[0] = result->vset[n]->vlist[0];
if (dp->dispatch.comm.pmda_interface >= PMDA_INTERFACE_5)
dp->dispatch.version.four.ext->e_context = ctx;
sts = dp->dispatch.version.any.store(&tmp, dp->dispatch.version.any.ext);
}
}
}
}
else {
/* assume PM_CONTEXT_ARCHIVE -- this is an error */
sts = PM_ERR_NOTHOST;
}
PM_UNLOCK(ctxp->c_lock);
}
return sts;
}
|
