| /* Licensed to the Apache Software Foundation (ASF) under one or more |
| * contributor license agreements. See the NOTICE file distributed with |
| * this work for additional information regarding copyright ownership. |
| * The ASF licenses this file to You under the Apache License, Version 2.0 |
| * (the "License"); you may not use this file except in compliance with |
| * the License. You may obtain a copy of the License at |
| * |
| * http://www.apache.org/licenses/LICENSE-2.0 |
| * |
| * Unless required by applicable law or agreed to in writing, software |
| * distributed under the License is distributed on an "AS IS" BASIS, |
| * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. |
| * See the License for the specific language governing permissions and |
| * limitations under the License. |
| */ |
| |
| #ifndef TESTSHM_H |
| #define TESTSHM_H |
| |
| #include "apr.h" |
| #include "apr_time.h" |
| #include "apr_atomic.h" |
| #include "apr_strings.h" |
| |
| #include <assert.h> |
| |
| typedef struct mbox { |
| char msg[1024]; |
| apr_uint32_t msgavail; |
| } mbox; |
| mbox *boxes; |
| |
| #define N_BOXES 10 |
| #define N_MESSAGES 100 |
| #define SHARED_SIZE (apr_size_t)(N_BOXES * sizeof(mbox)) |
| #define SHARED_FILENAME "data/apr.testshm.shm" |
| #define MSG "Sending a message" |
| |
| #if APR_HAS_SHARED_MEMORY |
| |
| static APR_INLINE |
| int msgwait(const char *msg, int count, int duration, int sleep_ms) |
| { |
| int recvd = 0, i; |
| apr_time_t start = apr_time_now(); |
| apr_interval_time_t sleep_duration = apr_time_from_sec(duration); |
| apr_interval_time_t sleep_delay = apr_time_from_msec(sleep_ms); |
| while (apr_time_now() - start < sleep_duration) { |
| for (i = 0; i < N_BOXES; i++) { |
| if (apr_atomic_cas32(&boxes[i].msgavail, 0, 1) == 1) { |
| if (msg) { |
| assert(strcmp(boxes[i].msg, msg) == 0); |
| } |
| *boxes[i].msg = '\0'; |
| if (++recvd == count) { |
| return recvd; |
| } |
| } |
| } |
| apr_sleep(sleep_delay); |
| } |
| return recvd; |
| } |
| |
| static APR_INLINE |
| int msgput(const char *msg, int boxnum) |
| { |
| if (apr_atomic_cas32(&boxes[boxnum].msgavail, -1, 0) != 0) { |
| return 0; |
| } |
| if (msg) { |
| apr_cpystrn(boxes[boxnum].msg, msg, sizeof(boxes[boxnum].msg)); |
| } |
| else { |
| *boxes[boxnum].msg = '\0'; |
| } |
| apr_atomic_set32(&boxes[boxnum].msgavail, 1); |
| return 1; |
| } |
| |
| #endif /* APR_HAS_SHARED_MEMORY */ |
| |
| #endif |